diff options
Diffstat (limited to 'cpp')
| -rw-r--r-- | cpp/src/qpid/amqp_0_10/Connection.cpp | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/cpp/src/qpid/amqp_0_10/Connection.cpp b/cpp/src/qpid/amqp_0_10/Connection.cpp index 6e0566c3c1..9b8b7d93c7 100644 --- a/cpp/src/qpid/amqp_0_10/Connection.cpp +++ b/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) |