diff options
Diffstat (limited to 'cpp/src/Ice/Connection.cpp')
| -rw-r--r-- | cpp/src/Ice/Connection.cpp | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/cpp/src/Ice/Connection.cpp b/cpp/src/Ice/Connection.cpp index 098b9a20aab..6b99accd7ed 100644 --- a/cpp/src/Ice/Connection.cpp +++ b/cpp/src/Ice/Connection.cpp @@ -1034,7 +1034,10 @@ IceInternal::Connection::compress(BasicStream& uncompressed, BasicStream& compre int bzError = BZ2_bzBuffToBuffCompress(compressed.b.begin() + headerSize + sizeof(Int), &compressedLen, uncompressed.b.begin() + headerSize, uncompressedLen, 1, 0, 0); - assert(bzError == BZ_OK); // TODO: Local exception + if (bzError != BZ_OK) + { + throw CompressionException(__FILE__, __LINE__); + } compressed.b.resize(headerSize + sizeof(Int) + compressedLen); // @@ -1079,7 +1082,10 @@ IceInternal::Connection::uncompress(BasicStream& compressed, BasicStream& uncomp compressed.b.begin() + headerSize + sizeof(Int), compressedLen, 0, 0); - assert(bzError == BZ_OK); + if (bzError != BZ_OK) + { + throw CompressionException(__FILE__, __LINE__); + } copy(compressed.b.begin(), compressed.b.begin() + headerSize, uncompressed.b.begin()); } |