You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2007/11/02 14:09:46 UTC
svn commit: r591320 -
/incubator/qpid/trunk/qpid/cpp/src/qpid/broker/SemanticHandler.cpp
Author: gsim
Date: Fri Nov 2 06:09:46 2007
New Revision: 591320
URL: http://svn.apache.org/viewvc?rev=591320&view=rev
Log:
Sending of results must be synchronised w.r.t. other frames (e.g. message delivery).
Modified:
incubator/qpid/trunk/qpid/cpp/src/qpid/broker/SemanticHandler.cpp
Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/broker/SemanticHandler.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/broker/SemanticHandler.cpp?rev=591320&r1=591319&r2=591320&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/broker/SemanticHandler.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/broker/SemanticHandler.cpp Fri Nov 2 06:09:46 2007
@@ -127,6 +127,7 @@
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()) {