Mirror/zeek
1
0
Fork 0
mirror of https://github.com/zeek/zeek.git synced 2025-10-13 20:18:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

OnLoop: notify_all() instead of notify_one()

Browse source 
There might be more than one thread blocked waiting for room in the
queue, ensure they all wake up when shutting down.
This commit is contained in:
Arne Welzel 2025-05-06 11:52:57 +02:00
parent e986caddf0
commit 6ebec6dde7
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/cluster/OnLoop.h
View file

@ -97,8 +97,8 @@ public:
std::scoped_lock lock(mtx);
SetClosed(true);
// Wake a process stuck in queueing.
cond.notify_one();
// Wake other threads stuck in queueing, if any.
cond.notify_all();
}
// Wait for any active queuers to vanish, should be quick.