diff options
| author | Benoit Foucher <benoit@zeroc.com> | 2017-02-06 11:17:34 +0100 |
|---|---|---|
| committer | Benoit Foucher <benoit@zeroc.com> | 2017-02-06 11:17:34 +0100 |
| commit | 18ab8207bd14def950fd399c60d9ee54fab75d3b (patch) | |
| tree | a82af333127184acc6be6e0969919cb20be5e8b3 /cpp/src/Ice/BatchRequestQueue.h | |
| parent | Fixed ICE-7548 - getAdminProxy no longer returns 0 if synchronization is in p... (diff) | |
| download | ice-18ab8207bd14def950fd399c60d9ee54fab75d3b.tar.bz2 ice-18ab8207bd14def950fd399c60d9ee54fab75d3b.tar.xz ice-18ab8207bd14def950fd399c60d9ee54fab75d3b.zip | |
Fixed ICE-7169 and ICE-7375 - add option to specify if batch requests flushed with the communicator/connection should be compressed
Diffstat (limited to 'cpp/src/Ice/BatchRequestQueue.h')
| -rw-r--r-- | cpp/src/Ice/BatchRequestQueue.h | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/cpp/src/Ice/BatchRequestQueue.h b/cpp/src/Ice/BatchRequestQueue.h index 878b2a2ef6d..9bdc2b90790 100644 --- a/cpp/src/Ice/BatchRequestQueue.h +++ b/cpp/src/Ice/BatchRequestQueue.h @@ -33,12 +33,12 @@ public: void finishBatchRequest(Ice::OutputStream*, const Ice::ObjectPrxPtr&, const std::string&); void abortBatchRequest(Ice::OutputStream*); - int swap(Ice::OutputStream*); + int swap(Ice::OutputStream*, bool&); void destroy(const Ice::LocalException&); bool isEmpty(); - void enqueueBatchRequest(); + void enqueueBatchRequest(const Ice::ObjectPrxPtr&); private: @@ -52,6 +52,7 @@ private: Ice::OutputStream _batchStream; bool _batchStreamInUse; bool _batchStreamCanFlush; + bool _batchCompress; int _batchRequestNum; size_t _batchMarker; IceInternal::UniquePtr<Ice::LocalException> _exception; |