summaryrefslogtreecommitdiff
path: root/cpp/src/IceGrid/SessionManagerI.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/IceGrid/SessionManagerI.cpp')
-rw-r--r--cpp/src/IceGrid/SessionManagerI.cpp15
1 files changed, 11 insertions, 4 deletions
diff --git a/cpp/src/IceGrid/SessionManagerI.cpp b/cpp/src/IceGrid/SessionManagerI.cpp
index 201471aa015..1b57c03489a 100644
--- a/cpp/src/IceGrid/SessionManagerI.cpp
+++ b/cpp/src/IceGrid/SessionManagerI.cpp
@@ -20,15 +20,21 @@ using namespace IceGrid;
SessionManagerI::SessionManagerI(RegistryObserverTopic& regTopic,
NodeObserverTopic& nodeTopic,
const DatabasePtr& database,
- const ReapThreadPtr& reaper) :
- _registryObserverTopic(regTopic), _nodeObserverTopic(nodeTopic), _database(database), _reaper(reaper)
+ const ReapThreadPtr& reaper,
+ int sessionTimeout) :
+ _registryObserverTopic(regTopic),
+ _nodeObserverTopic(nodeTopic),
+ _database(database),
+ _reaper(reaper),
+ _sessionTimeout(sessionTimeout)
{
}
Glacier2::SessionPrx
SessionManagerI::create(const string& userId, const Ice::Current& current)
{
- SessionIPtr session = new Glacier2ObserverSessionI(userId, _database, _registryObserverTopic, _nodeObserverTopic);
+ SessionIPtr session =
+ new Glacier2ObserverSessionI(userId, _database, _registryObserverTopic, _nodeObserverTopic, _sessionTimeout);
Glacier2::SessionPrx proxy = Glacier2::SessionPrx::uncheckedCast(current.adapter->addWithUUID(session));
_reaper->add(proxy, session);
return proxy;
@@ -37,7 +43,8 @@ SessionManagerI::create(const string& userId, const Ice::Current& current)
SessionPrx
SessionManagerI::createLocalSession(const string& userId, const Ice::Current& current)
{
- SessionIPtr session = new LocalObserverSessionI(userId, _database, _registryObserverTopic, _nodeObserverTopic);
+ SessionIPtr session =
+ new LocalObserverSessionI(userId, _database, _registryObserverTopic, _nodeObserverTopic, _sessionTimeout);
SessionPrx proxy = SessionPrx::uncheckedCast(current.adapter->addWithUUID(session));
_reaper->add(proxy, session);
return proxy;