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: [email protected]
For additional commands, e-mail: [email protected]
