diff options
| author | Benoit Foucher <benoit@zeroc.com> | 2006-12-12 08:52:16 +0000 |
|---|---|---|
| committer | Benoit Foucher <benoit@zeroc.com> | 2006-12-12 08:52:16 +0000 |
| commit | 2c767a34f8da6b2cb1e015398818e42b545be4b2 (patch) | |
| tree | 53f70bb3455426c80e1c5a5a15ac0bf2e1f4541c /cpp/src/IceGrid/NodeSessionI.cpp | |
| parent | First cut for ShowLogDialog (diff) | |
| download | ice-2c767a34f8da6b2cb1e015398818e42b545be4b2.tar.bz2 ice-2c767a34f8da6b2cb1e015398818e42b545be4b2.tar.xz ice-2c767a34f8da6b2cb1e015398818e42b545be4b2.zip | |
Added timeouts
Diffstat (limited to 'cpp/src/IceGrid/NodeSessionI.cpp')
| -rw-r--r-- | cpp/src/IceGrid/NodeSessionI.cpp | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/cpp/src/IceGrid/NodeSessionI.cpp b/cpp/src/IceGrid/NodeSessionI.cpp index a86c04600df..d14a8e171f7 100644 --- a/cpp/src/IceGrid/NodeSessionI.cpp +++ b/cpp/src/IceGrid/NodeSessionI.cpp @@ -38,7 +38,8 @@ NodeSessionI::NodeSessionI(const DatabasePtr& database, info.proxy = _node; _database->addInternalObject(info, true); // Add or update previous node proxy. - _proxy = NodeSessionPrx::uncheckedCast(_database->getInternalAdapter()->addWithUUID(this)); + Ice::ObjectPrx prx = _database->getInternalAdapter()->addWithUUID(this)->ice_timeout(timeout * 1000); + _proxy = NodeSessionPrx::uncheckedCast(prx); } catch(...) { @@ -219,7 +220,7 @@ NodeSessionI::destroyImpl(bool shutdown) // // Next we notify the observer. // - NodeObserverTopicPtr::dynamicCast(_database->getObserverTopic(NodeObserverTopicName))->nodeDown(_info.name); + NodeObserverTopicPtr::dynamicCast(_database->getObserverTopic(NodeObserverTopicName))->nodeDown(_info.name); // // Unsubscribe the node replica observer. |