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.h9
1 files changed, 4 insertions, 5 deletions
diff --git a/cpp/src/IceGrid/ReplicaSessionManager.h b/cpp/src/IceGrid/ReplicaSessionManager.h
index 1f906d8bf5f..0628912404a 100644
--- a/cpp/src/IceGrid/ReplicaSessionManager.h
+++ b/cpp/src/IceGrid/ReplicaSessionManager.h
@@ -69,8 +69,7 @@ public:
};
typedef IceUtil::Handle<Thread> ThreadPtr;
- ReplicaSessionManager();
-
+ ReplicaSessionManager(const Ice::CommunicatorPtr&);
void create(const std::string&, const InternalReplicaInfoPtr&, const DatabasePtr&,
const WellKnownObjectsManagerPtr&, const InternalRegistryPrx&);
void create(const InternalRegistryPrx&);
@@ -80,6 +79,8 @@ public:
void registerAllWellKnownObjects();
ReplicaSessionPrx getSession() const { return _thread->getSession(); }
+ IceGrid::InternalRegistryPrx findInternalRegistryForReplica(const Ice::Identity&);
+
private:
friend class Thread;
@@ -87,7 +88,7 @@ private:
bool isDestroyed()
{
Lock sync(*this);
- return !_thread;
+ return !_communicator;
}
ReplicaSessionPrx createSession(InternalRegistryPrx&, IceUtil::Time&);
@@ -98,14 +99,12 @@ private:
ThreadPtr _thread;
std::string _name;
InternalReplicaInfoPtr _info;
- InternalRegistryPrx _master;
RegistryPrx _registry;
InternalRegistryPrx _internalRegistry;
DatabaseObserverPrx _observer;
DatabasePtr _database;
WellKnownObjectsManagerPtr _wellKnownObjects;
TraceLevelsPtr _traceLevels;
- std::vector<QueryPrx> _queryObjects;
};
}