summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/ConnectRequestHandler.h
diff options
context:
space:
mode:
authorBenoit Foucher <benoit@zeroc.com>2014-05-23 11:59:44 +0200
committerBenoit Foucher <benoit@zeroc.com>2014-05-23 11:59:44 +0200
commitd81701ca8182942b7936f9fd84a019b695e9c890 (patch)
treedc036c9d701fbbe1afad67782bd78572c0f61974 /cpp/src/Ice/ConnectRequestHandler.h
parentFixed bug ICE-5543: stringToIdentity bug with escaped escapes (diff)
downloadice-d81701ca8182942b7936f9fd84a019b695e9c890.tar.bz2
ice-d81701ca8182942b7936f9fd84a019b695e9c890.tar.xz
ice-d81701ca8182942b7936f9fd84a019b695e9c890.zip
Added support for invocation timeouts and ACM heartbeats
Diffstat (limited to 'cpp/src/Ice/ConnectRequestHandler.h')
-rw-r--r--cpp/src/Ice/ConnectRequestHandler.h16
1 files changed, 10 insertions, 6 deletions
diff --git a/cpp/src/Ice/ConnectRequestHandler.h b/cpp/src/Ice/ConnectRequestHandler.h
index d1319dc5df5..d1832427550 100644
--- a/cpp/src/Ice/ConnectRequestHandler.h
+++ b/cpp/src/Ice/ConnectRequestHandler.h
@@ -41,11 +41,11 @@ public:
virtual void finishBatchRequest(BasicStream*);
virtual void abortBatchRequest();
- virtual Ice::ConnectionI* sendRequest(Outgoing*);
- virtual AsyncStatus sendAsyncRequest(const OutgoingAsyncPtr&);
+ virtual bool sendRequest(OutgoingMessageCallback*);
+ virtual AsyncStatus sendAsyncRequest(const OutgoingAsyncMessageCallbackPtr&);
- virtual bool flushBatchRequests(BatchOutgoing*);
- virtual AsyncStatus flushAsyncBatchRequests(const BatchOutgoingAsyncPtr&);
+ virtual void requestTimedOut(OutgoingMessageCallback*);
+ virtual void asyncRequestTimedOut(const OutgoingAsyncMessageCallbackPtr&);
virtual Ice::ConnectionIPtr getConnection(bool);
@@ -64,8 +64,12 @@ private:
struct Request
{
- OutgoingAsyncPtr out;
- BatchOutgoingAsyncPtr batchOut;
+ Request() : out(0), os(0)
+ {
+ }
+
+ OutgoingMessageCallback* out;
+ OutgoingAsyncMessageCallbackPtr outAsync;
BasicStream* os;
};