We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d7afa4b commit 46bffa8Copy full SHA for 46bffa8
include/core/composable/interprocess_decorator.hpp
@@ -13,6 +13,7 @@
13
#include <functional>
14
#include <fstream>
15
#include <queue>
16
+#include <cstring>
17
18
#ifdef _WIN32
19
#include <windows.h>
@@ -344,7 +345,7 @@ class SharedMemoryChannel : public IPCChannel<T> {
344
345
std::unique_lock<std::mutex> lock(*mutex_);
346
347
// For simplicity, we'll use a timeout-based approach
- if (!condition_->wait_for(lock, std::chrono::milliseconds(100))) {
348
+ if (condition_->wait_for(lock, std::chrono::milliseconds(100)) == std::cv_status::timeout) {
349
return false;
350
}
351
0 commit comments