tyler.durden/icinga2
1
0
Fork 0
mirror of https://github.com/Icinga/icinga2.git synced 2025-07-26 07:04:37 +02:00
Code Issues Packages Projects Releases Wiki Activity

Fix workqueue dispatch.

Browse Source
This commit is contained in:
Gunnar Beutner 2013-09-18 17:38:26 +02:00
parent ad3a8f19ed
commit 2487d7069c
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
lib/base/workqueue.cpp
View File

@ -38,9 +38,11 @@ void WorkQueue::Enqueue(const WorkCallback& item)
m_Items.push_back(item); m_Items.push_back(item);
m_CV.notify_all(); m_CV.notify_all();
if (!m_Executing) if (!m_Executing) {
m_Executing = true;
Utility::QueueAsyncCallback(boost::bind(&WorkQueue::ExecuteItem, this)); Utility::QueueAsyncCallback(boost::bind(&WorkQueue::ExecuteItem, this));
} }
}
void WorkQueue::Join(void) void WorkQueue::Join(void)
{ {
@ -59,7 +61,6 @@ void WorkQueue::Clear(void)
void WorkQueue::ExecuteItem(void) void WorkQueue::ExecuteItem(void)
{ {
boost::mutex::scoped_lock lock(m_Mutex); boost::mutex::scoped_lock lock(m_Mutex);
m_Executing = true;
while (!m_Items.empty()) { while (!m_Items.empty()) {
try { try {