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, 0 insertions, 3 deletions

diff --git a/cpp/src/qpid/broker/SemanticHandler.cpp b/cpp/src/qpid/broker/SemanticHandler.cpp
index ba43b5ecba..768ea9ea08 100644
--- a/cpp/src/qpid/broker/SemanticHandler.cpp
+++ b/cpp/src/qpid/broker/SemanticHandler.cpp
@@ -93,7 +93,6 @@ void SemanticHandler::sendCompletion()
 {
     SequenceNumber mark = incoming.getMark();
     SequenceNumberSet range = incoming.getRange();
-    Mutex::ScopedLock l(outLock);
     session.getProxy().getExecution().complete(mark.getValue(), range);
 }
 
@@ -128,7 +127,6 @@ void SemanticHandler::handleCommand(framing::AMQMethodBody* method)
     if (!invoker.wasHandled()) {
         throw NotImplementedException("Not implemented");
     } else if (invoker.hasResult()) {
-        Mutex::ScopedLock l(outLock);
         session.getProxy().getExecution().result(id.getValue(), invoker.getResult());
     }
     if (method->isSync()) { 
@@ -166,7 +164,6 @@ void SemanticHandler::handleContent(AMQFrame& frame)
 
 DeliveryId SemanticHandler::deliver(QueuedMessage& msg, DeliveryToken::shared_ptr token)
 {
-    Mutex::ScopedLock l(outLock);
     SessionHandler* handler = session.getHandler();
     if (handler) {
         uint32_t maxFrameSize = handler->getConnection().getFrameMax();