Repository: qpid-cpp Updated Branches: refs/heads/master af2bec7de -> b92ee09cf
QPID-7361: before waiting for credit, wakeup drive if we have stuff to write out Project: http://git-wip-us.apache.org/repos/asf/qpid-cpp/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-cpp/commit/b92ee09c Tree: http://git-wip-us.apache.org/repos/asf/qpid-cpp/tree/b92ee09c Diff: http://git-wip-us.apache.org/repos/asf/qpid-cpp/diff/b92ee09c Branch: refs/heads/master Commit: b92ee09cf65db171e635d97fe1428ee650c617c6 Parents: af2bec7 Author: Gordon Sim <[email protected]> Authored: Mon Jul 25 20:20:54 2016 +0100 Committer: Gordon Sim <[email protected]> Committed: Mon Jul 25 20:21:00 2016 +0100 ---------------------------------------------------------------------- src/qpid/messaging/amqp/ConnectionContext.cpp | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/b92ee09c/src/qpid/messaging/amqp/ConnectionContext.cpp ---------------------------------------------------------------------- diff --git a/src/qpid/messaging/amqp/ConnectionContext.cpp b/src/qpid/messaging/amqp/ConnectionContext.cpp index bb0d32e..25dd68d 100644 --- a/src/qpid/messaging/amqp/ConnectionContext.cpp +++ b/src/qpid/messaging/amqp/ConnectionContext.cpp @@ -500,6 +500,7 @@ void ConnectionContext::sendLH( } while (!snd->send(message, delivery)) { QPID_LOG(debug, "Waiting for capacity..."); + if (pn_transport_pending(engine)) wakeupDriver(); wait(ssn, snd);//wait for capacity } wakeupDriver(); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
