diff options
author | Joe George <joe@zeroc.com> | 2015-12-23 14:48:40 -0500 |
---|---|---|
committer | Joe George <joe@zeroc.com> | 2015-12-24 10:01:11 -0500 |
commit | e84da5f580821cae8dab292e19cc1296c07a8ed5 (patch) | |
tree | 1e8783c55c7dccd5adda2b87b47b8a7c118a1147 /cpp/src/IceGrid/ReapThread.h | |
parent | Fixes related to EnableSharedFromThis (diff) | |
download | ice-e84da5f580821cae8dab292e19cc1296c07a8ed5.tar.bz2 ice-e84da5f580821cae8dab292e19cc1296c07a8ed5.tar.xz ice-e84da5f580821cae8dab292e19cc1296c07a8ed5.zip |
ICE-6898 - "Delegate" functions for ACM callbacks
- Add delegate local interfaces CloseCallback and HeartbeatCallback and
remove ConnectionCallback.
- Replace setCallback by setCloseCallback and setHeartbeatCallback
Diffstat (limited to 'cpp/src/IceGrid/ReapThread.h')
-rw-r--r-- | cpp/src/IceGrid/ReapThread.h | 21 |
1 files changed, 11 insertions, 10 deletions
diff --git a/cpp/src/IceGrid/ReapThread.h b/cpp/src/IceGrid/ReapThread.h index 94c4dd9d1e7..b5ac79643de 100644 --- a/cpp/src/IceGrid/ReapThread.h +++ b/cpp/src/IceGrid/ReapThread.h @@ -42,10 +42,10 @@ template<class T> class SessionReapable : public Reapable { typedef IceUtil::Handle<T> TPtr; - + public: - - SessionReapable(const Ice::LoggerPtr& logger, const TPtr& session) : + + SessionReapable(const Ice::LoggerPtr& logger, const TPtr& session) : _logger(logger), _session(session) { } @@ -53,7 +53,7 @@ public: virtual ~SessionReapable() { } - + virtual IceUtil::Time timestamp() const { @@ -94,15 +94,15 @@ template<class T> class SessionReapableWithHeartbeat : public SessionReapable<T> { typedef IceUtil::Handle<T> TPtr; - + public: - SessionReapableWithHeartbeat(const Ice::LoggerPtr& logger, const TPtr& session) : + SessionReapableWithHeartbeat(const Ice::LoggerPtr& logger, const TPtr& session) : SessionReapable<T>(logger, session) { } - virtual void + virtual void heartbeat() const { try @@ -121,7 +121,7 @@ class ReapThread : public IceUtil::Thread, public IceUtil::Monitor<IceUtil::Mute public: ReapThread(); - + virtual void run(); void terminate(); void add(const ReapablePtr&, int, const Ice::ConnectionPtr& = Ice::ConnectionPtr()); @@ -132,8 +132,9 @@ public: private: bool calcWakeInterval(); - - Ice::ConnectionCallbackPtr _callback; + + Ice::CloseCallbackPtr _closeCallback; + Ice::HeartbeatCallbackPtr _heartbeatCallback; IceUtil::Time _wakeInterval; bool _terminated; struct ReapableItem |