diff --git a/src/connection.cc b/src/connection.cc index 942ba46ab..ae9e760fc 100644 --- a/src/connection.cc +++ b/src/connection.cc @@ -173,9 +173,7 @@ void IBConnection::flush(int64_t timeoutUsec) { if (wc->status != IBV_WC_SUCCESS) { throw mscclpp::IbError("pollCq failed: status " + std::to_string(wc->status), wc->status); } - if (wc->opcode == IBV_WC_RDMA_WRITE) { - numSignaledSends--; - } + numSignaledSends--; } } INFO(MSCCLPP_NET, "IBConnection flushing connection");