summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/IncomingAsync.cpp
diff options
context:
space:
mode:
authorBenoit Foucher <benoit@zeroc.com>2012-04-18 14:33:16 +0200
committerBenoit Foucher <benoit@zeroc.com>2012-04-18 14:33:16 +0200
commit2ba4d4e0ca7aeade69ee00ab17d5fa1b69372ffc (patch)
tree0a381f9b284eb7ca5acc9bca5a97659d19874f9d /cpp/src/Ice/IncomingAsync.cpp
parentICE-4828 - Buffer.h undeclared ptrdiff_t issue on OpenSUSE (diff)
downloadice-2ba4d4e0ca7aeade69ee00ab17d5fa1b69372ffc.tar.bz2
ice-2ba4d4e0ca7aeade69ee00ab17d5fa1b69372ffc.tar.xz
ice-2ba4d4e0ca7aeade69ee00ab17d5fa1b69372ffc.zip
Added support for encoding versioning
Diffstat (limited to 'cpp/src/Ice/IncomingAsync.cpp')
-rw-r--r--cpp/src/Ice/IncomingAsync.cpp23
1 files changed, 6 insertions, 17 deletions
diff --git a/cpp/src/Ice/IncomingAsync.cpp b/cpp/src/Ice/IncomingAsync.cpp
index 38df435abe1..9f220ec25fd 100644
--- a/cpp/src/Ice/IncomingAsync.cpp
+++ b/cpp/src/Ice/IncomingAsync.cpp
@@ -81,7 +81,7 @@ IceInternal::IncomingAsync::__deactivate(Incoming& in)
_active = false;
}
- in.adopt(*this);
+ in.__adopt(*this);
}
void
@@ -187,7 +187,7 @@ IceInternal::IncomingAsync::ice_exception()
}
void
-IceInternal::IncomingAsync::__response(bool ok)
+IceInternal::IncomingAsync::__response()
{
try
{
@@ -200,17 +200,6 @@ IceInternal::IncomingAsync::__response(bool ok)
if(_response)
{
- _os.endWriteEncaps();
-
- if(ok)
- {
- *(_os.b.begin() + headerSize + 4) = replyOK;
- }
- else
- {
- *(_os.b.begin() + headerSize + 4) = replyUserException;
- }
-
_connection->sendResponse(&_os, _compress);
}
else
@@ -312,14 +301,14 @@ IceAsync::Ice::AMD_Object_ice_invoke::ice_response(bool ok, const vector<Byte>&
{
try
{
- __getOs()->writeBlob(outParams);
+ __writeParamEncaps(&outParams[0], outParams.size(), ok);
}
catch(const LocalException& ex)
{
__exception(ex);
return;
}
- __response(ok);
+ __response();
}
}
@@ -330,13 +319,13 @@ IceAsync::Ice::AMD_Object_ice_invoke::ice_response(bool ok, const pair<const Byt
{
try
{
- __getOs()->writeBlob(outParams.first, static_cast<Int>(outParams.second - outParams.first));
+ __writeParamEncaps(outParams.first, static_cast<Int>(outParams.second - outParams.first), ok);
}
catch(const LocalException& ex)
{
__exception(ex);
return;
}
- __response(ok);
+ __response();
}
}