diff options
author | Benoit Foucher <benoit@zeroc.com> | 2012-04-18 14:33:16 +0200 |
---|---|---|
committer | Benoit Foucher <benoit@zeroc.com> | 2012-04-18 14:33:16 +0200 |
commit | 2ba4d4e0ca7aeade69ee00ab17d5fa1b69372ffc (patch) | |
tree | 0a381f9b284eb7ca5acc9bca5a97659d19874f9d /cpp/src/Ice/IncomingAsync.cpp | |
parent | ICE-4828 - Buffer.h undeclared ptrdiff_t issue on OpenSUSE (diff) | |
download | ice-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.cpp | 23 |
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(); } } |