From 574c338d3731043fd598040ccba211e2e339d977 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Tue, 23 Sep 2008 18:35:52 +0000 Subject: Batch writing of outgoing messages (up to one buffers worth) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@698272 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/src/qpid/amqp_0_10/Connection.cpp | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) (limited to 'qpid/cpp') diff --git a/qpid/cpp/src/qpid/amqp_0_10/Connection.cpp b/qpid/cpp/src/qpid/amqp_0_10/Connection.cpp index 6e0566c3c1..9b8b7d93c7 100644 --- a/qpid/cpp/src/qpid/amqp_0_10/Connection.cpp +++ b/qpid/cpp/src/qpid/amqp_0_10/Connection.cpp @@ -79,10 +79,11 @@ size_t Connection::encode(const char* buffer, size_t size) { } size_t frameSize=0; while (!frameQueue.empty() && ((frameSize=frameQueue.front().size()) <= out.available())) { - frameQueue.front().encode(out); - QPID_LOG(trace, "SENT [" << identifier << "]: " << frameQueue.front()); - frameQueue.pop_front(); - buffered -= frameSize; + frameQueue.front().encode(out); + QPID_LOG(trace, "SENT [" << identifier << "]: " << frameQueue.front()); + frameQueue.pop_front(); + buffered -= frameSize; + if (frameQueue.empty() && out.available() > 0) connection->doOutput(); } assert(frameQueue.empty() || frameQueue.front().size() <= size); if (!frameQueue.empty() && frameQueue.front().size() > size) -- cgit v1.2.1