diff options
| author | Marc Laukien <marc@zeroc.com> | 2004-06-29 18:28:25 +0000 |
|---|---|---|
| committer | Marc Laukien <marc@zeroc.com> | 2004-06-29 18:28:25 +0000 |
| commit | f098ebef83642e89e32296f4448cce7ae9437f73 (patch) | |
| tree | 642ce0df570dc1743dd19364d4ff8dcf962e8b4f /cpp/src/Ice/Connection.cpp | |
| parent | bug fix for empty local class (diff) | |
| download | ice-f098ebef83642e89e32296f4448cce7ae9437f73.tar.bz2 ice-f098ebef83642e89e32296f4448cce7ae9437f73.tar.xz ice-f098ebef83642e89e32296f4448cce7ae9437f73.zip | |
fixes
Diffstat (limited to 'cpp/src/Ice/Connection.cpp')
| -rw-r--r-- | cpp/src/Ice/Connection.cpp | 30 |
1 files changed, 23 insertions, 7 deletions
diff --git a/cpp/src/Ice/Connection.cpp b/cpp/src/Ice/Connection.cpp index eeec4f100e0..c95653f48b2 100644 --- a/cpp/src/Ice/Connection.cpp +++ b/cpp/src/Ice/Connection.cpp @@ -425,7 +425,7 @@ IceInternal::Connection::sendRequest(BasicStream* os, Outgoing* out, bool compre if(compress && os->b.size() >= 100) // Only compress messages larger than 100 bytes. { // - // Message compressed, request compressed response. + // Message compressed. Request compressed response, if any. // os->b[9] = 2; @@ -445,10 +445,10 @@ IceInternal::Connection::sendRequest(BasicStream* os, Outgoing* out, bool compre } else { - if(out && compress) + if(compress) { // - // Message not compressed, but request compressed response. + // Message not compressed. Request compressed response, if any. // os->b[9] = 1; } @@ -586,7 +586,7 @@ IceInternal::Connection::sendAsyncRequest(BasicStream* os, const OutgoingAsyncPt if(compress && os->b.size() >= 100) // Only compress messages larger than 100 bytes. { // - // Message compressed, request compressed response. + // Message compressed. Request compressed response, if any. // os->b[9] = 2; @@ -609,7 +609,7 @@ IceInternal::Connection::sendAsyncRequest(BasicStream* os, const OutgoingAsyncPt if(compress) { // - // Message not compressed, but request compressed response. + // Message not compressed. Request compressed response, if any. // os->b[9] = 1; } @@ -808,7 +808,7 @@ IceInternal::Connection::flushBatchRequest() if(_batchRequestCompress && _batchStream.b.size() >= 100) // Only compress messages larger than 100 bytes. { // - // Message compressed, request compressed response. + // Message compressed. Request compressed response, if any. // _batchStream.b[9] = 2; @@ -828,6 +828,14 @@ IceInternal::Connection::flushBatchRequest() } else { + if(_batchRequestCompress) + { + // + // Message not compressed. Request compressed response, if any. + // + _batchStream.b[9] = 1; + } + // // No compression, just fill in the message size. // @@ -896,7 +904,7 @@ IceInternal::Connection::sendResponse(BasicStream* os, Byte compressFlag) if(compressFlag > 0 && os->b.size() >= 100) { // - // Response is compressed. + // Message compressed. Request compressed response, if any. // os->b[9] = 2; @@ -916,6 +924,14 @@ IceInternal::Connection::sendResponse(BasicStream* os, Byte compressFlag) } else { + if(compressFlag > 0) + { + // + // Message not compressed. Request compressed response, if any. + // + os->b[9] = 1; + } + // // No compression, just fill in the message size. // |