summaryrefslogtreecommitdiff
path: root/cpp/src/IceGrid/AllocatableObjectCache.cpp
diff options
context:
space:
mode:
authorBenoit Foucher <benoit@zeroc.com>2015-06-08 13:05:22 +0200
committerBenoit Foucher <benoit@zeroc.com>2015-06-08 13:05:22 +0200
commitb2538adea86a17fccbacf87814361f050c97ae7e (patch)
treedb900e7f606ca8ce9d114f11cf3ac2e9cc2abaf4 /cpp/src/IceGrid/AllocatableObjectCache.cpp
parentFix IceSSL.CertFile property typo (diff)
downloadice-b2538adea86a17fccbacf87814361f050c97ae7e.tar.bz2
ice-b2538adea86a17fccbacf87814361f050c97ae7e.tar.xz
ice-b2538adea86a17fccbacf87814361f050c97ae7e.zip
Fixed ICE-6573 - IceGrid application update failure when updating server with allocatables and clients are waiting to allocate the allocatable
Diffstat (limited to 'cpp/src/IceGrid/AllocatableObjectCache.cpp')
-rw-r--r--cpp/src/IceGrid/AllocatableObjectCache.cpp28
1 files changed, 14 insertions, 14 deletions
diff --git a/cpp/src/IceGrid/AllocatableObjectCache.cpp b/cpp/src/IceGrid/AllocatableObjectCache.cpp
index 9d627317c8d..0efa6483cf3 100644
--- a/cpp/src/IceGrid/AllocatableObjectCache.cpp
+++ b/cpp/src/IceGrid/AllocatableObjectCache.cpp
@@ -55,7 +55,7 @@ AllocatableObjectCache::TypeEntry::remove(const AllocatableObjectEntryPtr& obj)
//
// No mutex protection here, this is called with the cache locked.
//
- vector<AllocatableObjectEntryPtr>::iterator q;
+ vector<AllocatableObjectEntryPtr>::iterator q;
q = lower_bound(_objects.begin(), _objects.end(), obj, AllocatableObjectEntryCI());
assert(q->get() == obj.get());
_objects.erase(q);
@@ -151,8 +151,8 @@ AllocatableObjectCache::add(const ObjectInfo& info, const AllocatablePtr& parent
if(_traceLevels && _traceLevels->object > 0)
{
Ice::Trace out(_traceLevels->logger, _traceLevels->objectCat);
- out << "added allocatable object `" << _communicator->identityToString(id) << "'";
- }
+ out << "added allocatable object `" << _communicator->identityToString(id) << "'";
+ }
}
AllocatableObjectEntryPtr
@@ -184,15 +184,15 @@ AllocatableObjectCache::remove(const Ice::Identity& id)
map<string, TypeEntry>::iterator p = _types.find(entry->getType());
assert(p != _types.end());
if(p->second.remove(entry))
- {
+ {
_types.erase(p);
}
if(_traceLevels && _traceLevels->object > 0)
{
Ice::Trace out(_traceLevels->logger, _traceLevels->objectCat);
- out << "removed allocatable object `" << _communicator->identityToString(id) << "'";
- }
+ out << "removed allocatable object `" << _communicator->identityToString(id) << "'";
+ }
}
//
@@ -250,8 +250,8 @@ AllocatableObjectCache::canTryAllocate(const AllocatableObjectEntryPtr& entry)
return p->second.canTryAllocate(entry, true);
}
-AllocatableObjectEntry::AllocatableObjectEntry(AllocatableObjectCache& cache,
- const ObjectInfo& info,
+AllocatableObjectEntry::AllocatableObjectEntry(AllocatableObjectCache& cache,
+ const ObjectInfo& info,
const AllocatablePtr& parent) :
Allocatable(true, parent),
_cache(cache),
@@ -291,9 +291,9 @@ AllocatableObjectEntry::allocated(const SessionIPtr& session)
if(traceLevels && traceLevels->object > 1)
{
Ice::Trace out(traceLevels->logger, traceLevels->objectCat);
- out << "object `" << _info.proxy->ice_toString() << "' allocated by `" << session->getId() << "' (" << _count
+ out << "object `" << _info.proxy->ice_toString() << "' allocated by `" << session->getId() << "' (" << _count
<< ")";
- }
+ }
Glacier2::IdentitySetPrx identities = session->getGlacier2IdentitySet();
if(identities)
@@ -311,7 +311,7 @@ AllocatableObjectEntry::allocated(const SessionIPtr& session)
Ice::Trace out(traceLevels->logger, traceLevels->objectCat);
out << "couldn't add Glacier2 filter for object `" << _info.proxy->ice_toString();
out << "' allocated by `" << session->getId() << "':\n" << ex;
- }
+ }
}
}
}
@@ -342,16 +342,16 @@ AllocatableObjectEntry::released(const SessionIPtr& session)
Ice::Trace out(traceLevels->logger, traceLevels->objectCat);
out << "couldn't remove Glacier2 filter for object `" << _info.proxy->ice_toString();
out << "' allocated by `" << session->getId() << "':\n" << ex;
- }
+ }
}
}
if(traceLevels && traceLevels->object > 1)
{
Ice::Trace out(traceLevels->logger, traceLevels->objectCat);
- out << "object `" << _info.proxy->ice_toString() << "' released by `" << session->getId() << "' (" << _count
+ out << "object `" << _info.proxy->ice_toString() << "' released by `" << session->getId() << "' (" << _count
<< ")";
- }
+ }
}
void