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 2014/04/30 22:14:51 UTC
svn commit: r1591470 -
/qpid/trunk/qpid/cpp/src/qpid/messaging/amqp/ConnectionContext.cpp
Author: gsim
Date: Wed Apr 30 20:14:50 2014
New Revision: 1591470
URL: http://svn.apache.org/r1591470
Log:
QPID-5737: wakeup driver for output which may be necessary if sessions outgoing window has been moved forward by peer
Modified:
qpid/trunk/qpid/cpp/src/qpid/messaging/amqp/ConnectionContext.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/messaging/amqp/ConnectionContext.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/messaging/amqp/ConnectionContext.cpp?rev=1591470&r1=1591469&r2=1591470&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/messaging/amqp/ConnectionContext.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/messaging/amqp/ConnectionContext.cpp Wed Apr 30 20:14:50 2014
@@ -130,6 +130,7 @@ void ConnectionContext::sync(boost::shar
while (!ssn->settled()) {
QPID_LOG(debug, "Waiting for sends to settle on sync()");
wait(ssn);//wait until message has been confirmed
+ wakeupDriver();
}
checkClosed(ssn);
}
@@ -142,6 +143,7 @@ void ConnectionContext::endSession(boost
while (!ssn->settled()) {
QPID_LOG(debug, "Waiting for sends to settle before closing");
wait(ssn);//wait until message has been confirmed
+ wakeupDriver();
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org