Skip to content

Commit 0c11760

Browse files
authored
Merge pull request #60 from lravich/fix_event_ack
adding ack event for RDMA_CM error event
2 parents 4d00b7a + c53d8d7 commit 0c11760

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

src/perftest_communication.c

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2321,7 +2321,7 @@ int rdma_cm_connect_events(struct pingpong_context *ctx,
23212321
rc = rdma_cm_events_dispatcher(ctx, user_param, event->id, event);
23222322
if (rc) {
23232323
error_message = "Failed to handle RDMA CM event.";
2324-
goto error;
2324+
goto ack;
23252325
}
23262326

23272327
rc = rdma_ack_cm_event(event);
@@ -2332,7 +2332,8 @@ int rdma_cm_connect_events(struct pingpong_context *ctx,
23322332
}
23332333

23342334
return rc;
2335-
2335+
ack:
2336+
rdma_ack_cm_event(event);
23362337
error:
23372338
return error_handler(error_message);
23382339
}
@@ -2374,7 +2375,7 @@ int rdma_cm_disconnect_nodes(struct pingpong_context *ctx,
23742375
rc = rdma_cm_events_dispatcher(ctx, user_param, event->id, event);
23752376
if (rc) {
23762377
error_message = "Failed to handle RDMA CM event.";
2377-
goto error;
2378+
goto ack;
23782379
}
23792380

23802381
rc = rdma_ack_cm_event(event);
@@ -2385,7 +2386,8 @@ int rdma_cm_disconnect_nodes(struct pingpong_context *ctx,
23852386
}
23862387

23872388
return rc;
2388-
2389+
ack:
2390+
rdma_ack_cm_event(event);
23892391
error:
23902392
return error_handler(error_message);
23912393
}

0 commit comments

Comments
 (0)