diff options
author | Benoit Foucher <benoit@zeroc.com> | 2009-11-25 15:05:41 +0100 |
---|---|---|
committer | Benoit Foucher <benoit@zeroc.com> | 2009-11-25 15:05:41 +0100 |
commit | 2fca2c1309c4991b21ff956709068122f19eef4a (patch) | |
tree | b90e6fe1450508f5ce2962e21627a4535414e1a6 /cpp/src/Ice/ConnectRequestHandler.cpp | |
parent | Update depends for SQL directories (diff) | |
download | ice-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.cpp | 12 |
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); } |