QPID-5737: wakeup driver for output which may be necessary if sessions outgoing window has been moved forward by peer

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

1 files changed, 2 insertions, 0 deletions

diff --git a/qpid/cpp/src/qpid/messaging/amqp/ConnectionContext.cpp b/qpid/cpp/src/qpid/messaging/amqp/ConnectionContext.cpp
index d78269e440..e8b0c6c18e 100644
--- a/qpid/cpp/src/qpid/messaging/amqp/ConnectionContext.cpp
+++ b/qpid/cpp/src/qpid/messaging/amqp/ConnectionContext.cpp
@@ -130,6 +130,7 @@ void ConnectionContext::sync(boost::shared_ptr<SessionContext> ssn)
     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::shared_ptr<SessionContext> ssn)
         while (!ssn->settled()) {
             QPID_LOG(debug, "Waiting for sends to settle before closing");
             wait(ssn);//wait until message has been confirmed
+            wakeupDriver();
         }
     }