diff options
| author | Benoit Foucher <benoit@zeroc.com> | 2006-09-04 19:39:59 +0000 |
|---|---|---|
| committer | Benoit Foucher <benoit@zeroc.com> | 2006-09-04 19:39:59 +0000 |
| commit | 1ce69fc8c36f2b7fa1d71ebe18e7ac4de01e3268 (patch) | |
| tree | cd87f8121980159fdafd6b01e6802ea594478b93 /cpp/src/IceGrid/NodeSessionI.cpp | |
| parent | icegridadmin always uses routed config if possible. added error messages if (diff) | |
| download | ice-1ce69fc8c36f2b7fa1d71ebe18e7ac4de01e3268.tar.bz2 ice-1ce69fc8c36f2b7fa1d71ebe18e7ac4de01e3268.tar.xz ice-1ce69fc8c36f2b7fa1d71ebe18e7ac4de01e3268.zip | |
Improved observers, refactored topic manager and initialization Added
icegridadmin commands to examine the registries
Diffstat (limited to 'cpp/src/IceGrid/NodeSessionI.cpp')
| -rw-r--r-- | cpp/src/IceGrid/NodeSessionI.cpp | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/cpp/src/IceGrid/NodeSessionI.cpp b/cpp/src/IceGrid/NodeSessionI.cpp index dd30db0f798..2b19cfc59b1 100644 --- a/cpp/src/IceGrid/NodeSessionI.cpp +++ b/cpp/src/IceGrid/NodeSessionI.cpp @@ -70,7 +70,7 @@ NodeSessionI::getTimeout(const Ice::Current& current) const NodeObserverPrx NodeSessionI::getObserver(const Ice::Current& current) const { - NodeObserverTopicPtr topic = _database->getNodeObserverTopic(); + NodeObserverTopicPtr topic = NodeObserverTopicPtr::dynamicCast(_database->getObserverTopic(NodeObserverTopicName)); if(topic) { return topic->getPublisher(); @@ -90,14 +90,15 @@ NodeSessionI::getServers(const Ice::Current& current) const void NodeSessionI::destroy(const Ice::Current& current) { - Lock sync(*this); - if(_destroy) { - throw Ice::ObjectNotExistException(__FILE__, __LINE__); + Lock sync(*this); + if(_destroy) + { + throw Ice::ObjectNotExistException(__FILE__, __LINE__); + } + _destroy = true; } - _destroy = true; - _database->removeNode(_name, this, !current.adapter); if(current.adapter) @@ -106,7 +107,6 @@ NodeSessionI::destroy(const Ice::Current& current) { current.adapter->remove(current.id); } - catch(const Ice::ObjectAdapterDeactivatedException&) { } |