diff --git a/client_module/source/common/net/sock/ibv/IBVSocket.c b/client_module/source/common/net/sock/ibv/IBVSocket.c index 9f4a83c3..589bc556 100644 --- a/client_module/source/common/net/sock/ibv/IBVSocket.c +++ b/client_module/source/common/net/sock/ibv/IBVSocket.c @@ -1918,12 +1918,12 @@ void __IBVSocket_sendCompletionHandler(struct ib_cq *cq, void *cq_context) IBVCommContext* commContext = _this->commContext; int reqNotifySendRes; - atomic_inc(&commContext->sendCompEventCount); - reqNotifySendRes = ib_req_notify_cq(commContext->sendCQ, IB_CQ_NEXT_COMP); if(unlikely(reqNotifySendRes) ) ibv_print_info("Couldn't request CQ notification\n"); + atomic_inc(&commContext->sendCompEventCount); + wake_up(&commContext->sendCompWaitQ); }