mirror of
https://github.com/Icinga/icinga2.git
synced 2025-07-23 13:45:04 +02:00
commit
7d501e0a20
@ -236,7 +236,8 @@ void ThreadPool::ManagerThreadProc(void)
|
|||||||
{
|
{
|
||||||
boost::mutex::scoped_lock lock(m_Mutex);
|
boost::mutex::scoped_lock lock(m_Mutex);
|
||||||
|
|
||||||
m_MgmtCV.timed_wait(lock, boost::posix_time::seconds(5));
|
if (!m_Stopped)
|
||||||
|
m_MgmtCV.timed_wait(lock, boost::posix_time::seconds(5));
|
||||||
|
|
||||||
if (m_Stopped)
|
if (m_Stopped)
|
||||||
break;
|
break;
|
||||||
@ -345,7 +346,8 @@ void ThreadPool::StatsThreadProc(void)
|
|||||||
for (;;) {
|
for (;;) {
|
||||||
boost::mutex::scoped_lock lock(m_Mutex);
|
boost::mutex::scoped_lock lock(m_Mutex);
|
||||||
|
|
||||||
m_MgmtCV.timed_wait(lock, boost::posix_time::milliseconds(250));
|
if (!m_Stopped)
|
||||||
|
m_MgmtCV.timed_wait(lock, boost::posix_time::milliseconds(250));
|
||||||
|
|
||||||
if (m_Stopped)
|
if (m_Stopped)
|
||||||
break;
|
break;
|
||||||
|
Loading…
x
Reference in New Issue
Block a user