diff options
| author | Benoit Foucher <benoit@zeroc.com> | 2005-10-20 13:24:19 +0000 |
|---|---|---|
| committer | Benoit Foucher <benoit@zeroc.com> | 2005-10-20 13:24:19 +0000 |
| commit | 280c0231d0a4630a3327dca70d467613e6e97aea (patch) | |
| tree | e408728be00bcac1b06a6582e437602f8526c5af /cpp/src/IceGrid/SessionManagerI.cpp | |
| parent | - Update required version of Mono to 1.1.8 in INSTALL.MONO file (diff) | |
| download | ice-280c0231d0a4630a3327dca70d467613e6e97aea.tar.bz2 ice-280c0231d0a4630a3327dca70d467613e6e97aea.tar.xz ice-280c0231d0a4630a3327dca70d467613e6e97aea.zip | |
Observer bug fixes.
Diffstat (limited to 'cpp/src/IceGrid/SessionManagerI.cpp')
| -rw-r--r-- | cpp/src/IceGrid/SessionManagerI.cpp | 15 |
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; |