summaryrefslogtreecommitdiff
path: root/cpp/src/IceGrid/NodeI.cpp
diff options
context:
space:
mode:
authorBenoit Foucher <benoit@zeroc.com>2006-07-25 17:25:58 +0000
committerBenoit Foucher <benoit@zeroc.com>2006-07-25 17:25:58 +0000
commit95779a66eb32286140dec13a1641f5723d322168 (patch)
treedd86f141a0460bfa7746bc563cde037eedd7cd84 /cpp/src/IceGrid/NodeI.cpp
parenthttp://bugzilla.zeroc.com/bugzilla/show_bug.cgi?id=1189 (diff)
downloadice-95779a66eb32286140dec13a1641f5723d322168.tar.bz2
ice-95779a66eb32286140dec13a1641f5723d322168.tar.xz
ice-95779a66eb32286140dec13a1641f5723d322168.zip
More replication work.
Diffstat (limited to 'cpp/src/IceGrid/NodeI.cpp')
-rw-r--r--cpp/src/IceGrid/NodeI.cpp20
1 files changed, 9 insertions, 11 deletions
diff --git a/cpp/src/IceGrid/NodeI.cpp b/cpp/src/IceGrid/NodeI.cpp
index 134303b7ffc..b6ee2e13b88 100644
--- a/cpp/src/IceGrid/NodeI.cpp
+++ b/cpp/src/IceGrid/NodeI.cpp
@@ -198,8 +198,7 @@ NodeI::NodeI(const Ice::ObjectAdapterPtr& adapter,
_tmpDir = _dataDir + "/tmp";
Ice::PropertiesPtr properties = getCommunicator()->getProperties();
- const string instanceNameProperty = "IceGrid.InstanceName";
- const_cast<string&>(_instanceName) = properties->getPropertyWithDefault(instanceNameProperty, "IceGrid");
+ const_cast<string&>(_instanceName) = getCommunicator()->getDefaultLocator()->ice_getIdentity().category;
const_cast<Ice::Int&>(_waitTime) = properties->getPropertyAsIntWithDefault("IceGrid.Node.WaitTime", 60);
}
@@ -551,15 +550,14 @@ NodeI::getUserAccountMapper() const
NodeSessionPrx
NodeI::registerWithRegistry(const InternalRegistryPrx& registry)
{
- NodeSessionPrx session = registry->registerNode(_name, _proxy, _platform.getNodeInfo());
- NodeObserverPrx observer = session->getObserver();
- if(observer)
- {
- IceUtil::Mutex::Lock sync(_observerMutex);
- _observer = observer;
- }
- checkConsistency(session);
- return session;
+ return registry->registerNode(_name, _proxy, _platform.getNodeInfo());
+}
+
+void
+NodeI::setObserver(const NodeObserverPrx& observer)
+{
+ IceUtil::Mutex::Lock sync(_observerMutex);
+ _observer = observer;
}
void