diff options
Diffstat (limited to 'cpp/src/IceGrid/ObjectCache.cpp')
-rw-r--r-- | cpp/src/IceGrid/ObjectCache.cpp | 38 |
1 files changed, 19 insertions, 19 deletions
diff --git a/cpp/src/IceGrid/ObjectCache.cpp b/cpp/src/IceGrid/ObjectCache.cpp index 693a525116b..180289d28da 100644 --- a/cpp/src/IceGrid/ObjectCache.cpp +++ b/cpp/src/IceGrid/ObjectCache.cpp @@ -74,7 +74,7 @@ ObjectCache::ObjectCache(const Ice::CommunicatorPtr& communicator) : _communicat } void -ObjectCache::add(const ObjectInfo& info, const string& application) +ObjectCache::add(const ObjectInfo& info, const string& application, const string& server) { const Ice::Identity& id = info.proxy->ice_getIdentity(); @@ -86,7 +86,7 @@ ObjectCache::add(const ObjectInfo& info, const string& application) return; } - ObjectEntryPtr entry = new ObjectEntry(info, application); + ObjectEntryPtr entry = new ObjectEntry(info, application, server); addImpl(id, entry); map<string, TypeEntry>::iterator p = _types.find(entry->getType()); @@ -99,8 +99,8 @@ ObjectCache::add(const ObjectInfo& info, const string& application) if(_traceLevels && _traceLevels->object > 0) { Ice::Trace out(_traceLevels->logger, _traceLevels->objectCat); - out << "added object `" << _communicator->identityToString(id) << "'"; - } + out << "added object `" << _communicator->identityToString(id) << "'"; + } } ObjectEntryPtr @@ -131,33 +131,27 @@ ObjectCache::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 object `" << _communicator->identityToString(id) << "'"; - } + out << "removed object `" << _communicator->identityToString(id) << "'"; + } } -Ice::ObjectProxySeq +vector<ObjectEntryPtr> ObjectCache::getObjectsByType(const string& type) { Lock sync(*this); - Ice::ObjectProxySeq proxies; map<string, TypeEntry>::const_iterator p = _types.find(type); if(p == _types.end()) { - return proxies; - } - const vector<ObjectEntryPtr>& objects = p->second.getObjects(); - for(vector<ObjectEntryPtr>::const_iterator q = objects.begin(); q != objects.end(); ++q) - { - proxies.push_back((*q)->getProxy()); + return vector<ObjectEntryPtr>(); } - return proxies; + return p->second.getObjects(); } ObjectInfoSeq @@ -194,9 +188,10 @@ ObjectCache::getAllByType(const string& type) return infos; } -ObjectEntry::ObjectEntry(const ObjectInfo& info, const string& application) : +ObjectEntry::ObjectEntry(const ObjectInfo& info, const string& application, const string& server) : _info(info), - _application(application) + _application(application), + _server(server) { } @@ -218,6 +213,12 @@ ObjectEntry::getApplication() const return _application; } +string +ObjectEntry::getServer() const +{ + return _server; +} + const ObjectInfo& ObjectEntry::getObjectInfo() const { @@ -229,4 +230,3 @@ ObjectEntry::canRemove() { return true; } - |