summaryrefslogtreecommitdiff
path: root/cpp/src/IceGrid/RegistryI.cpp
diff options
context:
space:
mode:
authorBenoit Foucher <benoit@zeroc.com>2013-09-04 02:11:20 -0700
committerBenoit Foucher <benoit@zeroc.com>2013-09-04 02:11:20 -0700
commitd59684e5117cc834e65f0affa16ab4659c07359f (patch)
tree8bbba5ed7a6f8f37e59eb56b2533b7a3a97bef02 /cpp/src/IceGrid/RegistryI.cpp
parentminor edits in CHANGES (diff)
downloadice-d59684e5117cc834e65f0affa16ab4659c07359f.tar.bz2
ice-d59684e5117cc834e65f0affa16ab4659c07359f.tar.xz
ice-d59684e5117cc834e65f0affa16ab4659c07359f.zip
Fixed IceGrid/replication test failures on Ubuntu
Diffstat (limited to 'cpp/src/IceGrid/RegistryI.cpp')
-rw-r--r--cpp/src/IceGrid/RegistryI.cpp17
1 files changed, 11 insertions, 6 deletions
diff --git a/cpp/src/IceGrid/RegistryI.cpp b/cpp/src/IceGrid/RegistryI.cpp
index c18adab07de..3c6128ea918 100644
--- a/cpp/src/IceGrid/RegistryI.cpp
+++ b/cpp/src/IceGrid/RegistryI.cpp
@@ -445,9 +445,12 @@ RegistryI::startImpl()
{
Ice::Long serial;
IceGrid::InternalRegistryPrx registry = IceGrid::InternalRegistryPrx::checkedCast(proxy);
- _database->syncApplications(registry->getApplications(serial), serial);
- _database->syncAdapters(registry->getAdapters(serial), serial);
- _database->syncObjects(registry->getObjects(serial), serial);
+ ApplicationInfoSeq applications = registry->getApplications(serial);
+ _database->syncApplications(applications, serial);
+ AdapterInfoSeq adapters = registry->getAdapters(serial);
+ _database->syncAdapters(adapters, serial);
+ ObjectInfoSeq objects = registry->getObjects(serial);
+ _database->syncObjects(objects, serial);
}
catch(const Ice::OperationNotExistException&)
{
@@ -1482,11 +1485,12 @@ RegistryI::registerReplicas(const InternalRegistryPrx& internalRegistry, const N
break;
}
}
+ ObjectInfoSeq infos;
if(registry)
{
try
{
- _database->removeObject(registry->ice_getIdentity());
+ infos.push_back(_database->getObjectInfo(registry->ice_getIdentity()));
}
catch(const ObjectNotRegisteredException&)
{
@@ -1494,12 +1498,13 @@ RegistryI::registerReplicas(const InternalRegistryPrx& internalRegistry, const N
}
try
{
- _database->removeObject(replica->ice_getIdentity());
+ infos.push_back(_database->getObjectInfo(replica->ice_getIdentity()));
}
catch(const ObjectNotRegisteredException&)
{
}
-
+ _database->removeRegistryWellKnownObjects(infos);
+
if(_traceLevels && _traceLevels->replica > 1)
{
Ice::Trace out(_traceLevels->logger, _traceLevels->replicaCat);