summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/BasicStream.cpp
diff options
context:
space:
mode:
authorDwayne Boone <dwayne@zeroc.com>2006-12-22 15:56:26 +0000
committerDwayne Boone <dwayne@zeroc.com>2006-12-22 15:56:26 +0000
commitcdad6934fd09e809cdb02404e98e1c63ebbfcb63 (patch)
treed449267709aff3b81ca155b9e11373850859825a /cpp/src/Ice/BasicStream.cpp
parentadding Ice.CacheMessageBuffers (diff)
downloadice-cdad6934fd09e809cdb02404e98e1c63ebbfcb63.tar.bz2
ice-cdad6934fd09e809cdb02404e98e1c63ebbfcb63.tar.xz
ice-cdad6934fd09e809cdb02404e98e1c63ebbfcb63.zip
Added autoflushing of batches
Diffstat (limited to 'cpp/src/Ice/BasicStream.cpp')
-rw-r--r--cpp/src/Ice/BasicStream.cpp4
1 files changed, 3 insertions, 1 deletions
diff --git a/cpp/src/Ice/BasicStream.cpp b/cpp/src/Ice/BasicStream.cpp
index 061a8ed0981..e3048ec7cac 100644
--- a/cpp/src/Ice/BasicStream.cpp
+++ b/cpp/src/Ice/BasicStream.cpp
@@ -30,7 +30,7 @@ using namespace std;
using namespace Ice;
using namespace IceInternal;
-IceInternal::BasicStream::BasicStream(Instance* instance) :
+IceInternal::BasicStream::BasicStream(Instance* instance, bool unlimited) :
IceInternal::Buffer(instance->messageSizeMax()),
_instance(instance),
_currentReadEncaps(0),
@@ -38,6 +38,7 @@ IceInternal::BasicStream::BasicStream(Instance* instance) :
_traceSlicing(-1),
_sliceObjects(true),
_messageSizeMax(_instance->messageSizeMax()), // Cached for efficiency.
+ _unlimited(unlimited),
_stringConverter(instance->initializationData().stringConverter),
_wstringConverter(instance->initializationData().wstringConverter),
_seqDataStack(0),
@@ -122,6 +123,7 @@ IceInternal::BasicStream::swap(BasicStream& other)
std::swap(_seqDataStack, other._seqDataStack);
std::swap(_objectList, other._objectList);
+ std::swap(_unlimited, other._unlimited);
}
//