tyler.durden
/
icinga2
mirror of https://github.com/Icinga/icinga2.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove default WQ limits 

refs #10002
This commit is contained in:
Gunnar Beutner 2015-09-02 09:16:20 +02:00
parent 5c77e6eafe
commit 35acba7dc1
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
lib/base/workqueue.cpp
View File

@ -76,7 +76,7 @@ void WorkQueue::Enqueue(const Task& task, bool allowInterleaved)
}
if (!wq_thread) {
while (m_Tasks.size() >= m_MaxItems)
while (m_Tasks.size() >= m_MaxItems && m_MaxItems != 0)
m_CVFull.wait(lock);
}
@ -198,7 +198,7 @@ void WorkQueue::WorkerThreadProc(void)
if (m_Stopped)
break;
if (m_Tasks.size() >= m_MaxItems)
if (m_Tasks.size() >= m_MaxItems && m_MaxItems != 0)
m_CVFull.notify_all();
Task task = m_Tasks.front();

2
lib/base/workqueue.hpp
View File

@ -44,7 +44,7 @@ class I2_BASE_API WorkQueue
public:
typedef boost::function<void (boost::exception_ptr)> ExceptionCallback;
WorkQueue(size_t maxItems = 25000, int threadCount = 1);
WorkQueue(size_t maxItems = 0, int threadCount = 1);
~WorkQueue(void);
void Enqueue(const Task& task, bool allowInterleaved = false);