Author: aconway
Date: Wed Dec 17 09:14:14 2008
New Revision: 727444
URL: http://svn.apache.org/viewvc?rev=727444&view=rev
Log:
Default --cluster-read-max to 0.
Modified:
qpid/trunk/qpid/cpp/src/qpid/sys/PollableQueue.h
Modified: qpid/trunk/qpid/cpp/src/qpid/sys/PollableQueue.h
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/sys/PollableQueue.h?rev=727444&r1=727443&r2=727444&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/sys/PollableQueue.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/sys/PollableQueue.h Wed Dec 17 09:14:14 2008
@@ -119,17 +119,15 @@
ScopedLock l(lock);
assert(dispatcher.id() == 0);
dispatcher = Thread::current();
- while (!stopped && !queue.empty()) {
- assert(batch.empty());
- batch.swap(queue);
- {
- ScopedUnlock u(lock); // Allow concurrent push to queue.
- callback(batch);
- }
- if (!batch.empty()) {
- queue.insert(queue.begin(), batch.begin(), batch.end()); // put
back unprocessed items.
- batch.clear();
- }
+ assert(batch.empty());
+ batch.swap(queue);
+ {
+ ScopedUnlock u(lock); // Allow concurrent push to queue.
+ callback(batch);
+ }
+ if (!batch.empty()) {
+ queue.insert(queue.begin(), batch.begin(), batch.end()); // put back
unprocessed items.
+ batch.clear();
}
dispatcher = Thread();
if (queue.empty()) condition.clear();
