Fix race condition in the control plugin

2025-10-14 00:56:47 +00:00 · 2018-09-12 16:14:32 +02:00
1 changed files with 1 additions and 1 deletions
--- a/fairmq/plugins/Control.cxx
+++ b/fairmq/plugins/Control.cxx
@ -227,7 +227,7 @@ auto Control::WaitForNextState() -> DeviceState
    unique_lock<mutex> lock{fEventsMutex};
    while (fEvents.empty())
    {
-        fNewEvent.wait(lock);
+        fNewEvent.wait_for(lock, chrono::milliseconds(50));
    }

    auto result = fEvents.front();