microsoft/mscclpp
1
0
Fork 0
mirror of https://github.com/microsoft/mscclpp.git synced 2026-05-12 01:10:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

timeout fix

Browse Source
This commit is contained in:
Saeed Maleki
2023-05-10 20:24:33 +00:00
parent 1769138568
commit 33eb4093ac
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/connection.cc
View File

@@ -137,7 +137,7 @@ void IBConnection::flush()
auto elapsed = timer.elapsed();
if (elapsed > MSCCLPP_POLLING_WAIT) {
throw Error("pollCq is stuck: waited for " + std::to_string(elapsed) + " seconds. Expected " +
throw Error("pollCq is stuck: waited for " + std::to_string(elapsed/1e6) + " seconds. Expected " +
std::to_string(numSignaledSends) + " signals",
ErrorCode::InternalError);
}

2
src/include/connection.hpp
View File

@@ -2,7 +2,7 @@
#define MSCCLPP_CONNECTION_HPP_
// TODO(saemal): make this configurable
#define MSCCLPP_POLLING_WAIT 10000 // in microseconds
#define MSCCLPP_POLLING_WAIT 3e7 // in microseconds
#include "communicator.hpp"
#include "ib.hpp"