Changes to threading: queues serialiser removed, io threads used to drive dispatch to consumers

Fix to PersistableMessage: use correct lock when accessing synclist, don't hold enqueue lock when notifying queues



git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@599395 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 5 insertions, 5 deletions

diff --git a/cpp/src/qpid/broker/PersistableMessage.cpp b/cpp/src/qpid/broker/PersistableMessage.cpp
index c68cfcb52f..a00a623988 100644
--- a/cpp/src/qpid/broker/PersistableMessage.cpp
+++ b/cpp/src/qpid/broker/PersistableMessage.cpp
@@ -28,11 +28,11 @@ using namespace qpid::broker;
 
 void PersistableMessage::flush()
 {
-	sys::ScopedLock<sys::Mutex> l(storeLock);
-	if (store) {
-         for (syncList::iterator i = synclist.begin(); i != synclist.end(); ++i) {
-			  store->flush(*(*i));
-         } 
+    sys::ScopedLock<sys::Mutex> l(storeLock);
+    if (store) {
+        for (syncList::iterator i = synclist.begin(); i != synclist.end(); ++i) {
+            store->flush(*(*i));
+        } 
     }
 }