summaryrefslogtreecommitdiff
path: root/cpp/src/IceDiscovery/LocatorI.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/IceDiscovery/LocatorI.cpp')
-rw-r--r--cpp/src/IceDiscovery/LocatorI.cpp24
1 files changed, 12 insertions, 12 deletions
diff --git a/cpp/src/IceDiscovery/LocatorI.cpp b/cpp/src/IceDiscovery/LocatorI.cpp
index 09e70a0f9b3..196c1dcaa5d 100644
--- a/cpp/src/IceDiscovery/LocatorI.cpp
+++ b/cpp/src/IceDiscovery/LocatorI.cpp
@@ -26,7 +26,7 @@ LocatorRegistryI::LocatorRegistryI(const Ice::CommunicatorPtr& com) :
void
LocatorRegistryI::setAdapterDirectProxy_async(const AMD_LocatorRegistry_setAdapterDirectProxyPtr& cb,
const std::string& adapterId,
- const ObjectPrx& proxy,
+ const ObjectPrxPtr& proxy,
const Current&)
{
Lock sync(*this);
@@ -46,7 +46,7 @@ LocatorRegistryI::setReplicatedAdapterDirectProxy_async(
const AMD_LocatorRegistry_setReplicatedAdapterDirectProxyPtr& cb,
const std::string& adapterId,
const std::string& replicaGroupId,
- const ObjectPrx& proxy,
+ const ObjectPrxPtr& proxy,
const Current&)
{
Lock sync(*this);
@@ -79,13 +79,13 @@ LocatorRegistryI::setReplicatedAdapterDirectProxy_async(
void
LocatorRegistryI::setServerProcessProxy_async(const AMD_LocatorRegistry_setServerProcessProxyPtr& cb,
const std::string&,
- const ProcessPrx&,
+ const ProcessPrxPtr&,
const Current&)
{
cb->ice_response();
}
-Ice::ObjectPrx
+Ice::ObjectPrxPtr
LocatorRegistryI::findObject(const Ice::Identity& id) const
{
Lock sync(*this);
@@ -94,7 +94,7 @@ LocatorRegistryI::findObject(const Ice::Identity& id) const
return 0;
}
- Ice::ObjectPrx prx = _wellKnownProxy->ice_identity(id);
+ Ice::ObjectPrxPtr prx = _wellKnownProxy->ice_identity(id);
vector<string> adapterIds;
for(map<string, set<string> >::const_iterator p = _replicaGroups.begin(); p != _replicaGroups.end(); ++p)
@@ -112,7 +112,7 @@ LocatorRegistryI::findObject(const Ice::Identity& id) const
if(adapterIds.empty())
{
- for(map<string, Ice::ObjectPrx>::const_iterator p = _adapters.begin(); p != _adapters.end(); ++p)
+ for(map<string, Ice::ObjectPrxPtr>::const_iterator p = _adapters.begin(); p != _adapters.end(); ++p)
{
try
{
@@ -135,12 +135,12 @@ LocatorRegistryI::findObject(const Ice::Identity& id) const
return prx->ice_adapterId(adapterIds[0]);
}
-Ice::ObjectPrx
+Ice::ObjectPrxPtr
LocatorRegistryI::findAdapter(const string& adapterId, bool& isReplicaGroup) const
{
Lock sync(*this);
- map<string, Ice::ObjectPrx>::const_iterator p = _adapters.find(adapterId);
+ map<string, Ice::ObjectPrxPtr>::const_iterator p = _adapters.find(adapterId);
if(p != _adapters.end())
{
isReplicaGroup = false;
@@ -151,10 +151,10 @@ LocatorRegistryI::findAdapter(const string& adapterId, bool& isReplicaGroup) con
if(q != _replicaGroups.end())
{
Ice::EndpointSeq endpoints;
- Ice::ObjectPrx prx;
+ Ice::ObjectPrxPtr prx;
for(set<string>::const_iterator r = q->second.begin(); r != q->second.end(); ++r)
{
- map<string, Ice::ObjectPrx>::const_iterator s = _adapters.find(*r);
+ map<string, Ice::ObjectPrxPtr>::const_iterator s = _adapters.find(*r);
if(s == _adapters.end())
{
continue; // TODO: Inconsistency
@@ -180,7 +180,7 @@ LocatorRegistryI::findAdapter(const string& adapterId, bool& isReplicaGroup) con
return 0;
}
-LocatorI::LocatorI(const LookupIPtr& lookup, const LocatorRegistryPrx& registry) : _lookup(lookup), _registry(registry)
+LocatorI::LocatorI(const LookupIPtr& lookup, const LocatorRegistryPrxPtr& registry) : _lookup(lookup), _registry(registry)
{
}
@@ -200,7 +200,7 @@ LocatorI::findAdapterById_async(const AMD_Locator_findAdapterByIdPtr& cb,
_lookup->findAdapter(cb, adapterId);
}
-LocatorRegistryPrx
+LocatorRegistryPrxPtr
LocatorI::getRegistry(const Current&) const
{
return _registry;