More adapter replication changes.

1 files changed, 147 insertions, 0 deletions

diff --git a/cpp/src/IceGrid/ObjectCache.cpp b/cpp/src/IceGrid/ObjectCache.cpp
new file mode 100644
index 00000000000..700b0bba438
--- /dev/null
+++ b/cpp/src/IceGrid/ObjectCache.cpp
@@ -0,0 +1,147 @@
+// **********************************************************************
+//
+// Copyright (c) 2003-2005 ZeroC, Inc. All rights reserved.
+//
+// This copy of Ice is licensed to you under the terms described in the
+// ICE_LICENSE file included in this distribution.
+//
+// **********************************************************************
+
+#include <Ice/Communicator.h>
+#include <Ice/IdentityUtil.h>
+
+#include <IceGrid/ObjectCache.h>
+#include <IceGrid/NodeSessionI.h>
+#include <IceGrid/ServerCache.h>
+
+using namespace std;
+using namespace IceGrid;
+
+ObjectCache::ObjectCache(const Ice::CommunicatorPtr& communicator) : 
+    _communicator(communicator)
+{
+}
+
+void
+ObjectCache::add(const string& adapterId, const ObjectDescriptor& desc)
+{
+    Lock sync(*this);
+    assert(!getImpl(desc.id));
+
+    ObjectEntryPtr entry = getImpl(desc.id, true);
+    entry->set(_communicator, adapterId, desc);
+
+    map<string, set<Ice::Identity> >::iterator p = _types.find(entry->getType());
+    if(p == _types.end())
+    {
+	p = _types.insert(p, make_pair(entry->getType(), set<Ice::Identity>()));
+    }
+    p->second.insert(desc.id);
+}
+
+ObjectEntryPtr
+ObjectCache::get(const Ice::Identity& id) const
+{
+    Lock sync(*this);
+    ObjectCache& self = const_cast<ObjectCache&>(*this);
+    ObjectEntryPtr entry = self.getImpl(id);
+    if(!entry)
+    {
+	ObjectNotExistException ex;
+	ex.id = id;
+	throw ex;
+    }
+    return entry;
+}
+
+ObjectEntryPtr
+ObjectCache::remove(const Ice::Identity& id)
+{
+    Lock sync(*this);
+    ObjectEntryPtr entry = removeImpl(id);
+    assert(entry);
+
+    map<string, set<Ice::Identity> >::iterator p = _types.find(entry->getType());
+    assert(p != _types.end());
+    p->second.erase(id);
+    if(p->second.empty())
+    {
+	_types.erase(p);
+    }
+
+    return entry;
+}
+
+Ice::ObjectProxySeq
+ObjectCache::getObjectsWithType(const string& type)
+{
+    Lock sync(*this);
+    Ice::ObjectProxySeq proxies;
+    map<string, set<Ice::Identity> >::const_iterator p = _types.find(type);
+    if(p == _types.end())
+    {
+	return proxies;
+    }
+    for(set<Ice::Identity>::const_iterator q = p->second.begin(); q != p->second.end(); ++q)
+    {
+	proxies.push_back(getImpl(*q)->getProxy());
+    }
+    return proxies;
+}
+
+ObjectInfoSeq
+ObjectCache::getAll(const string& expression)
+{
+    Lock sync(*this);
+    ObjectInfoSeq infos;
+    for(map<Ice::Identity, ObjectEntryPtr>::const_iterator p = _entries.begin(); p != _entries.end(); ++p)
+    {
+	if(expression.empty() || IceUtil::match(Ice::identityToString(p->first), expression, true))
+	{
+	    infos.push_back(p->second->getObjectInfo());
+	}
+    }
+    return infos;
+}
+
+ObjectEntry::ObjectEntry(Cache<Ice::Identity, ObjectEntry>&, const Ice::Identity&)
+{
+}
+
+void
+ObjectEntry::set(const Ice::CommunicatorPtr& communicator, const string& adapterId, const ObjectDescriptor& desc)
+{
+    _adapterId = adapterId;
+    _info.proxy = communicator->stringToProxy(Ice::identityToString(desc.id) + "@" + adapterId);
+    _info.type = desc.type;
+}
+
+Ice::ObjectPrx
+ObjectEntry::getProxy() const
+{
+    return _info.proxy;
+}
+
+string
+ObjectEntry::getAdapterId() const
+{
+    return _adapterId;
+}
+
+string
+ObjectEntry::getType() const
+{
+    return _info.type;
+}
+
+const ObjectInfo&
+ObjectEntry::getObjectInfo() const
+{
+    return _info;
+}
+
+bool
+ObjectEntry::canRemove()
+{
+    return true;
+}