summaryrefslogtreecommitdiff
path: root/cpp/src/IceGrid/ReapThread.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/IceGrid/ReapThread.h')
-rw-r--r--cpp/src/IceGrid/ReapThread.h21
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