summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/CollocatedRequestHandler.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/Ice/CollocatedRequestHandler.h')
-rw-r--r--cpp/src/Ice/CollocatedRequestHandler.h24
1 files changed, 12 insertions, 12 deletions
diff --git a/cpp/src/Ice/CollocatedRequestHandler.h b/cpp/src/Ice/CollocatedRequestHandler.h
index a3ac1387045..3930c12ce1c 100644
--- a/cpp/src/Ice/CollocatedRequestHandler.h
+++ b/cpp/src/Ice/CollocatedRequestHandler.h
@@ -31,10 +31,10 @@ typedef IceUtil::Handle<ObjectAdapterI> ObjectAdapterIPtr;
namespace IceInternal
{
+class OutgoingBase;
class Outgoing;
-class BatchOutgoing;
+class OutgoingAsyncBase;
class OutgoingAsync;
-class BatchOutgoingAsync;
class CollocatedRequestHandler : public RequestHandler, public ResponseHandler, private IceUtil::Monitor<IceUtil::Mutex>
{
@@ -50,11 +50,11 @@ public:
virtual void finishBatchRequest(BasicStream*);
virtual void abortBatchRequest();
- virtual bool sendRequest(OutgoingMessageCallback*);
- virtual AsyncStatus sendAsyncRequest(const OutgoingAsyncMessageCallbackPtr&);
+ virtual bool sendRequest(OutgoingBase*);
+ virtual AsyncStatus sendAsyncRequest(const OutgoingAsyncBasePtr&);
- virtual void requestTimedOut(OutgoingMessageCallback*);
- virtual void asyncRequestTimedOut(const OutgoingAsyncMessageCallbackPtr&);
+ virtual void requestCanceled(OutgoingBase*, const Ice::LocalException&);
+ virtual void asyncRequestCanceled(const OutgoingAsyncBasePtr&, const Ice::LocalException&);
virtual void sendResponse(Ice::Int, BasicStream*, Ice::Byte);
virtual void sendNoResponse();
@@ -68,11 +68,11 @@ public:
void invokeRequest(Outgoing*);
AsyncStatus invokeAsyncRequest(OutgoingAsync*);
- void invokeBatchRequests(BatchOutgoing*);
- AsyncStatus invokeAsyncBatchRequests(BatchOutgoingAsync*);
+ void invokeBatchRequests(OutgoingBase*);
+ AsyncStatus invokeAsyncBatchRequests(OutgoingAsyncBase*);
- bool sent(OutgoingMessageCallback*);
- bool sentAsync(OutgoingAsyncMessageCallback*);
+ bool sent(OutgoingBase*);
+ bool sentAsync(OutgoingAsyncBase*);
void invokeAll(BasicStream*, Ice::Int, Ice::Int, bool);
@@ -88,8 +88,8 @@ private:
int _requestId;
- std::map<OutgoingMessageCallback*, Ice::Int> _sendRequests;
- std::map<OutgoingAsyncMessageCallbackPtr, Ice::Int> _sendAsyncRequests;
+ std::map<OutgoingBase*, Ice::Int> _sendRequests;
+ std::map<OutgoingAsyncBasePtr, Ice::Int> _sendAsyncRequests;
std::map<Ice::Int, Outgoing*> _requests;
std::map<Ice::Int, OutgoingAsyncPtr> _asyncRequests;