summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/ConnectionI.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/Ice/ConnectionI.h')
-rw-r--r--cpp/src/Ice/ConnectionI.h21
1 files changed, 10 insertions, 11 deletions
diff --git a/cpp/src/Ice/ConnectionI.h b/cpp/src/Ice/ConnectionI.h
index 1d44498610b..05e12bbe3ee 100644
--- a/cpp/src/Ice/ConnectionI.h
+++ b/cpp/src/Ice/ConnectionI.h
@@ -29,7 +29,7 @@
#include <Ice/ConnectorF.h>
#include <Ice/LoggerF.h>
#include <Ice/TraceLevelsF.h>
-#include <Ice/OutgoingAsyncF.h>
+#include <Ice/OutgoingAsync.h>
#include <Ice/EventHandler.h>
#include <Ice/RequestHandler.h>
#include <Ice/ResponseHandler.h>
@@ -188,10 +188,10 @@ public:
IceInternal::BatchRequestQueuePtr getBatchRequestQueue() const;
- virtual void flushBatchRequests(); // From Connection.
+ virtual void flushBatchRequests();
#ifdef ICE_CPP11_MAPPING
- virtual ::std::function<void ()>
+ virtual std::function<void ()>
flushBatchRequests_async(::std::function<void (::std::exception_ptr)>,
::std::function<void (bool)> = nullptr);
#else
@@ -203,13 +203,9 @@ public:
virtual void end_flushBatchRequests(const AsyncResultPtr&);
#endif
-#ifdef ICE_CPP11_MAPPING
- virtual void setCloseCallback(::std::function<void (::std::shared_ptr<::Ice::Connection>)>);
- virtual void setHeartbeatCallback(::std::function<void (::std::shared_ptr<::Ice::Connection>)>);
-#else
- virtual void setCloseCallback(const Ice::CloseCallbackPtr&);
- virtual void setHeartbeatCallback(const Ice::HeartbeatCallbackPtr&);
-#endif
+ virtual void setCloseCallback(ICE_IN(ICE_CLOSE_CALLBACK));
+ virtual void setHeartbeatCallback(ICE_IN(ICE_HEARTBEAT_CALLBACK));
+
virtual void setACM(const IceUtil::Optional<int>&,
const IceUtil::Optional<ACMClose>&,
const IceUtil::Optional<ACMHeartbeat>&);
@@ -264,6 +260,8 @@ public:
virtual ~ConnectionI();
+ using EnableSharedFromThis<ConnectionI>::shared_from_this;
+
private:
ConnectionI(const Ice::CommunicatorPtr&, const IceInternal::InstancePtr&, const IceInternal::ACMMonitorPtr&,
@@ -324,7 +322,9 @@ private:
void reap();
+#ifndef ICE_CPP11_MAPPING
AsyncResultPtr __begin_flushBatchRequests(const IceInternal::CallbackBasePtr&, const LocalObjectPtr&);
+#endif
Ice::CommunicatorPtr _communicator;
const IceInternal::InstancePtr _instance;
@@ -394,7 +394,6 @@ private:
ICE_CLOSE_CALLBACK _closeCallback;
ICE_HEARTBEAT_CALLBACK _heartbeatCallback;
-
};
}