Mirror/zeek
1
0
Fork 0
mirror of https://github.com/zeek/zeek.git synced 2025-10-02 14:48:21 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

Minor optimization to bro_broker::Manager::FlushPendingQueries

Browse source
This commit is contained in:
Jon Siwek 2018-06-14 12:41:21 -05:00
parent 8a00a2dbf8
commit 197ea03f8f
1 changed files with 10 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

11
src/broker/Manager.cc
View file

@ -241,8 +241,17 @@ void Manager::FlushPendingQueries()
{ {
// possibly an infinite loop if a query can recursively // possibly an infinite loop if a query can recursively
// generate more queries... // generate more queries...
Process(); for ( auto& s : data_stores )
{
while ( ! s.second->proxy.mailbox().empty() )
{
auto response = s.second->proxy.receive();
ProcessStoreResponse(s.second, move(response));
}
}
} }
SetIdle(false);
} }
uint16_t Manager::Listen(const string& addr, uint16_t port) uint16_t Manager::Listen(const string& addr, uint16_t port)