diff options
Diffstat (limited to 'cpp/src/tests/storePerfTools/asyncPerf')
| -rw-r--r-- | cpp/src/tests/storePerfTools/asyncPerf/MockPersistableQueue.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/cpp/src/tests/storePerfTools/asyncPerf/MockPersistableQueue.cpp b/cpp/src/tests/storePerfTools/asyncPerf/MockPersistableQueue.cpp index ff9b76c421..3b92af9803 100644 --- a/cpp/src/tests/storePerfTools/asyncPerf/MockPersistableQueue.cpp +++ b/cpp/src/tests/storePerfTools/asyncPerf/MockPersistableQueue.cpp @@ -323,7 +323,7 @@ void MockPersistableQueue::pop(QueuedMessagePtr& qm) { qpid::sys::ScopedLock<qpid::sys::Mutex> l(m_enqueuedMsgsMutex); - if (m_enqueuedMsgs.empty()) { + while (m_enqueuedMsgs.empty()) { m_dequeueCondition.wait(m_enqueuedMsgsMutex); } qm = m_enqueuedMsgs.front(); |