diff options
author | Benoit Foucher <benoit@zeroc.com> | 2013-09-04 02:11:20 -0700 |
---|---|---|
committer | Benoit Foucher <benoit@zeroc.com> | 2013-09-04 02:11:20 -0700 |
commit | d59684e5117cc834e65f0affa16ab4659c07359f (patch) | |
tree | 8bbba5ed7a6f8f37e59eb56b2533b7a3a97bef02 /cpp/src/IceGrid/RegistryI.cpp | |
parent | minor edits in CHANGES (diff) | |
download | ice-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.cpp | 17 |
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); |