mirror of https://github.com/Icinga/icinga2.git
parent
553bd3246b
commit
954d2d53a2
|
@ -73,7 +73,7 @@ void WorkQueue::Enqueue(const WorkCallback& callback, bool allowInterleaved)
|
||||||
if (wq_thread)
|
if (wq_thread)
|
||||||
ProcessItems(lock, true);
|
ProcessItems(lock, true);
|
||||||
else
|
else
|
||||||
m_CVEmpty.notify_one();
|
m_CVEmpty.notify_all();
|
||||||
}
|
}
|
||||||
|
|
||||||
void WorkQueue::Join(void)
|
void WorkQueue::Join(void)
|
||||||
|
@ -119,7 +119,7 @@ void WorkQueue::ProcessItems(boost::mutex::scoped_lock& lock, bool interleaved)
|
||||||
return;
|
return;
|
||||||
|
|
||||||
m_Items.pop_front();
|
m_Items.pop_front();
|
||||||
m_CVFull.notify_all();
|
m_CVFull.notify_one();
|
||||||
|
|
||||||
lock.unlock();
|
lock.unlock();
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue