fixed flushing issue

microsoft · Sep 11, 2023 · ee02cd5 · ee02cd5
1 parent 16277e3
commit ee02cd5
Showing 1 changed file with 1 addition and 3 deletions.
diff --git 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");