summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/StreamI.cpp
diff options
context:
space:
mode:
authorJose <jose@zeroc.com>2012-03-15 16:53:10 +0100
committerJose <jose@zeroc.com>2012-03-15 16:53:10 +0100
commitb2a3402c30a42b5b5344c2758166d1a3a6534f6b (patch)
treeb111a0c07d9f2eedcad1b1c59a67ec050d5667dc /cpp/src/Ice/StreamI.cpp
parentserialVersionUID fix to use IceUtilInternal::stringToInt64 for numeric conver... (diff)
downloadice-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.cpp26
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);
}