diff options
author | Benoit Foucher <benoit@zeroc.com> | 2009-11-23 13:28:08 +0100 |
---|---|---|
committer | Benoit Foucher <benoit@zeroc.com> | 2009-11-23 13:28:08 +0100 |
commit | 2c578015edcb36cdc0acd0227295de1dcca1b995 (patch) | |
tree | e163980b5dabb43a40089a29fdf8ff47a3e07f1c /cpp/src/Ice/ConnectRequestHandler.cpp | |
parent | no longer generating inspect method for each Ruby exception (diff) | |
download | ice-2c578015edcb36cdc0acd0227295de1dcca1b995.tar.bz2 ice-2c578015edcb36cdc0acd0227295de1dcca1b995.tar.xz ice-2c578015edcb36cdc0acd0227295de1dcca1b995.zip |
New AMI mapping
Diffstat (limited to 'cpp/src/Ice/ConnectRequestHandler.cpp')
-rw-r--r-- | cpp/src/Ice/ConnectRequestHandler.cpp | 18 |
1 files changed, 6 insertions, 12 deletions
diff --git a/cpp/src/Ice/ConnectRequestHandler.cpp b/cpp/src/Ice/ConnectRequestHandler.cpp index f400b03d418..a68c3c51efd 100644 --- a/cpp/src/Ice/ConnectRequestHandler.cpp +++ b/cpp/src/Ice/ConnectRequestHandler.cpp @@ -86,7 +86,7 @@ public: current.ioCompleted(); for(vector<OutgoingAsyncMessageCallbackPtr>::const_iterator p = _callbacks.begin(); p != _callbacks.end(); ++p) { - (*p)->__sentCallback(_instance); + (*p)->__sent(); } } @@ -412,20 +412,14 @@ ConnectRequestHandler::flushRequests() { if(_connection->sendAsyncRequest(req.out, _compress, _response)) { - if(dynamic_cast<Ice::AMISentCallback*>(req.out.get())) - { - sentCallbacks.push_back(req.out); - } + sentCallbacks.push_back(req.out); } } else if(req.batchOut) { if(_connection->flushAsyncBatchRequests(req.batchOut)) { - if(dynamic_cast<Ice::AMISentCallback*>(req.batchOut.get())) - { - sentCallbacks.push_back(req.batchOut); - } + sentCallbacks.push_back(req.batchOut); } } else @@ -504,11 +498,11 @@ ConnectRequestHandler::flushRequestsWithException(const Ice::LocalException& ex) { if(p->out) { - p->out->__finished(ex); + p->out->__finished(ex, false); } else if(p->batchOut) { - p->batchOut->__finished(ex); + p->batchOut->__finished(ex, false); } else { @@ -530,7 +524,7 @@ ConnectRequestHandler::flushRequestsWithException(const LocalExceptionWrapper& e } else if(p->batchOut) { - p->batchOut->__finished(*ex.get()); + p->batchOut->__finished(*ex.get(), false); } else { |