summaryrefslogtreecommitdiff
path: root/cpp/src/IceGrid/ReplicaSessionManager.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/IceGrid/ReplicaSessionManager.h')
-rw-r--r--cpp/src/IceGrid/ReplicaSessionManager.h18
1 files changed, 9 insertions, 9 deletions
diff --git a/cpp/src/IceGrid/ReplicaSessionManager.h b/cpp/src/IceGrid/ReplicaSessionManager.h
index 78d88f70b6a..4143c82b113 100644
--- a/cpp/src/IceGrid/ReplicaSessionManager.h
+++ b/cpp/src/IceGrid/ReplicaSessionManager.h
@@ -37,25 +37,25 @@ public:
{
public:
- Thread(ReplicaSessionManager& manager, const InternalRegistryPrx& master, const Ice::LoggerPtr& logger) :
+ Thread(ReplicaSessionManager& manager, const InternalRegistryPrx& master, const Ice::LoggerPtr& logger) :
SessionKeepAliveThread<ReplicaSessionPrx>(master, logger),
_manager(manager)
{
}
- virtual ReplicaSessionPrx
+ virtual ReplicaSessionPrx
createSession(InternalRegistryPrx& master, IceUtil::Time& timeout)
{
return _manager.createSession(master, timeout);
}
- virtual void
+ virtual void
destroySession(const ReplicaSessionPrx& session)
{
_manager.destroySession(session);
}
- virtual bool
+ virtual bool
keepAlive(const ReplicaSessionPrx& session)
{
return _manager.keepAlive(session);
@@ -64,13 +64,13 @@ public:
void registerAllWellKnownObjects();
private:
-
+
ReplicaSessionManager& _manager;
};
typedef IceUtil::Handle<Thread> ThreadPtr;
ReplicaSessionManager(const Ice::CommunicatorPtr&, const std::string&);
- void create(const std::string&, const InternalReplicaInfoPtr&, const DatabasePtr&,
+ void create(const std::string&, const InternalReplicaInfoPtr&, const DatabasePtr&,
const WellKnownObjectsManagerPtr&, const InternalRegistryPrx&);
void create(const InternalRegistryPrx&);
NodePrxSeq getNodes(const NodePrxSeq&) const;
@@ -80,17 +80,17 @@ public:
ReplicaSessionPrx getSession() const { return _thread ? _thread->getSession() : ReplicaSessionPrx(); }
IceGrid::InternalRegistryPrx findInternalRegistryForReplica(const Ice::Identity&);
-
+
private:
friend class Thread;
- bool isDestroyed()
+ bool isDestroyed()
{
Lock sync(*this);
return !_communicator;
}
-
+
ReplicaSessionPrx createSession(InternalRegistryPrx&, IceUtil::Time&);
ReplicaSessionPrx createSessionImpl(const InternalRegistryPrx&, IceUtil::Time&);
void destroySession(const ReplicaSessionPrx&);