Author: gsim
Date: Mon Nov 24 11:33:54 2008
New Revision: 720271
URL: http://svn.apache.org/viewvc?rev=720271&view=rev
Log:
QPID-1478: Same fix is required in SslConnector unfortunately.
Modified:
incubator/qpid/trunk/qpid/cpp/src/qpid/client/SslConnector.cpp
Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/client/SslConnector.cpp
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/client/SslConnector.cpp?rev=720271&r1=720270&r2=720271&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/client/SslConnector.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/client/SslConnector.cpp Mon Nov 24
11:33:54 2008
@@ -283,7 +283,7 @@
void SslConnector::Writer::handle(framing::AMQFrame& frame) {
Mutex::ScopedLock l(lock);
frames.push_back(frame);
- if (frame.getEof()) {//or if we already have a buffers worth
+ if (frame.getEof() || (bounds && bounds->getCurrentSize() >=
maxFrameSize)) {
lastEof = frames.size();
aio->notifyPendingWrite();
}