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

Set threading::Manager terminating state

Browse source 
Coverity CID 1417429
This commit is contained in:
Jon Siwek 2020-02-05 17:35:46 -08:00
parent 4e87b6ee73
commit e62c0e0c9f
1 changed files with 3 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

3
src/threading/Manager.cc
View file

@ -23,6 +23,7 @@ Manager::Manager()
did_process = true; did_process = true;
next_beat = 0; next_beat = 0;
terminating = false;
} }
Manager::~Manager() Manager::~Manager()
@ -37,6 +38,7 @@ Manager::~Manager()
void Manager::Terminate() void Manager::Terminate()
{ {
DBG_LOG(DBG_THREADING, "Terminating thread manager ..."); DBG_LOG(DBG_THREADING, "Terminating thread manager ...");
terminating = true;
// First process remaining thread output for the message threads. // First process remaining thread output for the message threads.
do Flush(); while ( did_process ); do Flush(); while ( did_process );
@ -58,6 +60,7 @@ void Manager::Terminate()
all_threads.clear(); all_threads.clear();
msg_threads.clear(); msg_threads.clear();
terminating = false;
} }
void Manager::AddThread(BasicThread* thread) void Manager::AddThread(BasicThread* thread)