summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/ConnectRequestHandler.cpp
diff options
context:
space:
mode:
authorBenoit Foucher <benoit@zeroc.com>2009-11-23 13:28:08 +0100
committerBenoit Foucher <benoit@zeroc.com>2009-11-23 13:28:08 +0100
commit2c578015edcb36cdc0acd0227295de1dcca1b995 (patch)
treee163980b5dabb43a40089a29fdf8ff47a3e07f1c /cpp/src/Ice/ConnectRequestHandler.cpp
parentno longer generating inspect method for each Ruby exception (diff)
downloadice-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.cpp18
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
{