summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/Incoming.cpp
diff options
context:
space:
mode:
authorBenoit Foucher <benoit@zeroc.com>2012-08-06 15:02:15 +0200
committerBenoit Foucher <benoit@zeroc.com>2012-08-06 15:02:15 +0200
commit4f9a13928253344c0191b3116c4408c1d83604d9 (patch)
treedeca77fd2e69f0cb532c70de9adf14d6e3d628fe /cpp/src/Ice/Incoming.cpp
parentRebuilt dependencies (diff)
downloadice-4f9a13928253344c0191b3116c4408c1d83604d9.tar.bz2
ice-4f9a13928253344c0191b3116c4408c1d83604d9.tar.xz
ice-4f9a13928253344c0191b3116c4408c1d83604d9.zip
Removed Stream::format method, replace with startWriteEncaps parameter
Diffstat (limited to 'cpp/src/Ice/Incoming.cpp')
-rw-r--r--cpp/src/Ice/Incoming.cpp16
1 files changed, 12 insertions, 4 deletions
diff --git a/cpp/src/Ice/Incoming.cpp b/cpp/src/Ice/Incoming.cpp
index 15e49a61608..34f583bb1df 100644
--- a/cpp/src/Ice/Incoming.cpp
+++ b/cpp/src/Ice/Incoming.cpp
@@ -80,14 +80,14 @@ IceInternal::IncomingBase::__adopt(IncomingBase& other)
}
BasicStream*
-IncomingBase::__startWriteParams()
+IncomingBase::__startWriteParams(FormatType format)
{
if(_response)
{
assert(_os.b.size() == headerSize + 4); // Reply status position.
assert(_current.encoding >= Ice::Encoding_1_0); // Encoding for reply is known.
_os.write(static_cast<Ice::Byte>(0));
- _os.startWriteEncaps(_current.encoding);
+ _os.startWriteEncaps(_current.encoding, format);
}
//
@@ -141,6 +141,14 @@ IncomingBase::__writeParamEncaps(const Byte* v, Ice::Int sz, bool ok)
}
}
+void
+IncomingBase::__writeUserException(const Ice::UserException& ex, Ice::FormatType format)
+{
+ ::IceInternal::BasicStream* __os = __startWriteParams(format);
+ __os->write(ex);
+ __endWriteParams(false);
+}
+
void
IceInternal::IncomingBase::__warning(const Exception& ex) const
{
@@ -203,7 +211,7 @@ IceInternal::IncomingBase::__servantLocatorFinished()
{
_os.b.resize(headerSize + 4); // Reply status position.
_os.write(replyUserException);
- _os.startWriteEncaps(_current.encoding);
+ _os.startWriteEncaps(_current.encoding, DefaultFormat);
_os.write(ex);
_os.endWriteEncaps();
_connection->sendResponse(&_os, _compress);
@@ -567,7 +575,7 @@ IceInternal::Incoming::invoke(const ServantManagerPtr& servantManager, BasicStre
if(_response)
{
_os.write(replyUserException);
- _os.startWriteEncaps(encoding);
+ _os.startWriteEncaps(encoding, DefaultFormat);
_os.write(ex);
_os.endWriteEncaps();
_connection->sendResponse(&_os, _compress);