diff options
author | Jose <jose@zeroc.com> | 2012-03-15 16:53:10 +0100 |
---|---|---|
committer | Jose <jose@zeroc.com> | 2012-03-15 16:53:10 +0100 |
commit | b2a3402c30a42b5b5344c2758166d1a3a6534f6b (patch) | |
tree | b111a0c07d9f2eedcad1b1c59a67ec050d5667dc /cpp/src/Ice/StreamI.cpp | |
parent | serialVersionUID fix to use IceUtilInternal::stringToInt64 for numeric conver... (diff) | |
download | ice-b2a3402c30a42b5b5344c2758166d1a3a6534f6b.tar.bz2 ice-b2a3402c30a42b5b5344c2758166d1a3a6534f6b.tar.xz ice-b2a3402c30a42b5b5344c2758166d1a3a6534f6b.zip |
ICE-4745 - Freeze serialization throws Ice.MemoryLimitException
Diffstat (limited to 'cpp/src/Ice/StreamI.cpp')
-rw-r--r-- | cpp/src/Ice/StreamI.cpp | 26 |
1 files changed, 13 insertions, 13 deletions
diff --git a/cpp/src/Ice/StreamI.cpp b/cpp/src/Ice/StreamI.cpp index 6c69b64bfa5..f9937495fb5 100644 --- a/cpp/src/Ice/StreamI.cpp +++ b/cpp/src/Ice/StreamI.cpp @@ -29,7 +29,7 @@ using namespace IceInternal; Ice::InputStreamI::InputStreamI(const Ice::CommunicatorPtr& communicator, const vector<Byte>& data) : _communicator(communicator) { - _is = new BasicStream(getInstance(communicator).get()); + _is = new BasicStream(getInstance(communicator).get(), true); _is->closure(this); _is->writeBlob(data); _is->i = _is->b.begin(); @@ -38,7 +38,7 @@ Ice::InputStreamI::InputStreamI(const Ice::CommunicatorPtr& communicator, const Ice::InputStreamI::InputStreamI(const Ice::CommunicatorPtr& communicator, const pair<const Byte*, const Byte*>& data) : _communicator(communicator) { - _is = new BasicStream(getInstance(communicator).get()); + _is = new BasicStream(getInstance(communicator).get(), true); _is->closure(this); _is->writeBlob(data.first, data.second - data.first); _is->i = _is->b.begin(); @@ -343,60 +343,60 @@ Ice::InputStreamI::read(Ice::Double& v) } void -Ice::InputStreamI::read(std::string& v, bool convert) +Ice::InputStreamI::read(string& v, bool convert) { _is->read(v, convert); } void -Ice::InputStreamI::read(std::vector<std::string>& v, bool convert) +Ice::InputStreamI::read(vector<string>& v, bool convert) { _is->read(v, convert); } void -Ice::InputStreamI::read(std::wstring& v) +Ice::InputStreamI::read(wstring& v) { _is->read(v); } void -Ice::InputStreamI::read(std::pair<const bool*, const bool*>& p, ::IceUtil::ScopedArray<bool>& result) +Ice::InputStreamI::read(pair<const bool*, const bool*>& p, ::IceUtil::ScopedArray<bool>& result) { result.reset(_is->read(p)); } void -Ice::InputStreamI::read(std::pair<const Ice::Byte*, const Ice::Byte*>& p) +Ice::InputStreamI::read(pair<const Ice::Byte*, const Ice::Byte*>& p) { _is->read(p); } void -Ice::InputStreamI::read(std::pair<const Ice::Short*, const Ice::Short*>& p, ::IceUtil::ScopedArray<Ice::Short>& result) +Ice::InputStreamI::read(pair<const Ice::Short*, const Ice::Short*>& p, ::IceUtil::ScopedArray<Ice::Short>& result) { result.reset(_is->read(p)); } void -Ice::InputStreamI::read(std::pair<const Ice::Int*, const Ice::Int*>& p, ::IceUtil::ScopedArray<Ice::Int>& result) +Ice::InputStreamI::read(pair<const Ice::Int*, const Ice::Int*>& p, ::IceUtil::ScopedArray<Ice::Int>& result) { result.reset(_is->read(p)); } void -Ice::InputStreamI::read(std::pair<const Ice::Long*, const Ice::Long*>& p, ::IceUtil::ScopedArray<Ice::Long>& result) +Ice::InputStreamI::read(pair<const Ice::Long*, const Ice::Long*>& p, ::IceUtil::ScopedArray<Ice::Long>& result) { result.reset(_is->read(p)); } void -Ice::InputStreamI::read(std::pair<const Ice::Float*, const Ice::Float*>& p, ::IceUtil::ScopedArray<Ice::Float>& result) +Ice::InputStreamI::read(pair<const Ice::Float*, const Ice::Float*>& p, ::IceUtil::ScopedArray<Ice::Float>& result) { result.reset(_is->read(p)); } void -Ice::InputStreamI::read(std::pair<const Ice::Double*, const Ice::Double*>& p, +Ice::InputStreamI::read(pair<const Ice::Double*, const Ice::Double*>& p, ::IceUtil::ScopedArray<Ice::Double>& result) { result.reset(_is->read(p)); @@ -465,7 +465,7 @@ Ice::OutputStreamI::OutputStreamI(const Ice::CommunicatorPtr& communicator, Basi { if(!_os) { - _os = new BasicStream(getInstance(communicator).get()); + _os = new BasicStream(getInstance(communicator).get(), true); } _os->closure(this); } |