also fixing the timeout for flush

microsoft · Oct 13, 2023 · 4d93a7b · 4d93a7b
1 parent ff5291e
commit 4d93a7b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/connection.cc b/src/connection.cc
@@ -163,8 +163,8 @@ void IBConnection::flush(int64_t timeoutUsec) {
     }
 
     auto elapsed = timer.elapsed();
-    if ((timeoutUsec >= 0) && (elapsed * 1e3 > timeoutUsec)) {
-      throw Error("pollCq is stuck: waited for " + std::to_string(elapsed / 1e3) + " seconds. Expected " +
+    if ((timeoutUsec >= 0) && (elapsed > timeoutUsec)) {
+      throw Error("pollCq is stuck: waited for " + std::to_string(elapsed / 1e6) + " seconds. Expected " +
                       std::to_string(numSignaledSends) + " signals",
                   ErrorCode::InternalError);
     }