summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/ConnectRequestHandler.cpp
diff options
context:
space:
mode:
authorBenoit Foucher <benoit@zeroc.com>2009-11-25 15:05:41 +0100
committerBenoit Foucher <benoit@zeroc.com>2009-11-25 15:05:41 +0100
commit2fca2c1309c4991b21ff956709068122f19eef4a (patch)
treeb90e6fe1450508f5ce2962e21627a4535414e1a6 /cpp/src/Ice/ConnectRequestHandler.cpp
parentUpdate depends for SQL directories (diff)
downloadice-2fca2c1309c4991b21ff956709068122f19eef4a.tar.bz2
ice-2fca2c1309c4991b21ff956709068122f19eef4a.tar.xz
ice-2fca2c1309c4991b21ff956709068122f19eef4a.zip
- Cleaned up test/Ice/operations test
- Added test/Ice/ami test - sent callback is now always called
Diffstat (limited to 'cpp/src/Ice/ConnectRequestHandler.cpp')
-rw-r--r--cpp/src/Ice/ConnectRequestHandler.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/cpp/src/Ice/ConnectRequestHandler.cpp b/cpp/src/Ice/ConnectRequestHandler.cpp
index a68c3c51efd..6786b1cd37a 100644
--- a/cpp/src/Ice/ConnectRequestHandler.cpp
+++ b/cpp/src/Ice/ConnectRequestHandler.cpp
@@ -226,7 +226,7 @@ ConnectRequestHandler::sendRequest(Outgoing* out)
}
}
-bool
+AsyncStatus
ConnectRequestHandler::sendAsyncRequest(const OutgoingAsyncPtr& out)
{
{
@@ -236,7 +236,7 @@ ConnectRequestHandler::sendAsyncRequest(const OutgoingAsyncPtr& out)
Request req;
req.out = out;
_requests.push_back(req);
- return false;
+ return AsyncStatusQueued;
}
}
return _connection->sendAsyncRequest(out, _compress, _response);
@@ -248,7 +248,7 @@ ConnectRequestHandler::flushBatchRequests(BatchOutgoing* out)
return getConnection(true)->flushBatchRequests(out);
}
-bool
+AsyncStatus
ConnectRequestHandler::flushAsyncBatchRequests(const BatchOutgoingAsyncPtr& out)
{
{
@@ -258,7 +258,7 @@ ConnectRequestHandler::flushAsyncBatchRequests(const BatchOutgoingAsyncPtr& out)
Request req;
req.batchOut = out;
_requests.push_back(req);
- return false;
+ return AsyncStatusQueued;
}
}
return _connection->flushAsyncBatchRequests(out);
@@ -410,14 +410,14 @@ ConnectRequestHandler::flushRequests()
Request& req = _requests.front();
if(req.out)
{
- if(_connection->sendAsyncRequest(req.out, _compress, _response))
+ if(_connection->sendAsyncRequest(req.out, _compress, _response) & AsyncStatusInvokeSentCallback)
{
sentCallbacks.push_back(req.out);
}
}
else if(req.batchOut)
{
- if(_connection->flushAsyncBatchRequests(req.batchOut))
+ if(_connection->flushAsyncBatchRequests(req.batchOut) & AsyncStatusInvokeSentCallback)
{
sentCallbacks.push_back(req.batchOut);
}