summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/ValueFactoryManager.cpp
diff options
context:
space:
mode:
authorJoe George <joe@zeroc.com>2015-12-08 11:33:42 -0500
committerJoe George <joe@zeroc.com>2015-12-08 16:09:24 -0500
commit6a43686ce26de5d2d5edf4a485ecff3a242c26b6 (patch)
treed31e4f16dc9ed6e28056a7224e045a4638955f5e /cpp/src/Ice/ValueFactoryManager.cpp
parentC++11 mapping IceDiscovery plug-in (diff)
downloadice-6a43686ce26de5d2d5edf4a485ecff3a242c26b6.tar.bz2
ice-6a43686ce26de5d2d5edf4a485ecff3a242c26b6.tar.xz
ice-6a43686ce26de5d2d5edf4a485ecff3a242c26b6.zip
ICE-6908 - Add ValueFactory
ValueFactory is a replacement for ObjectFactory (which is still available if needed). It is an interface with only one operation and can has the "delegate" metadata.
Diffstat (limited to 'cpp/src/Ice/ValueFactoryManager.cpp')
-rw-r--r--cpp/src/Ice/ValueFactoryManager.cpp175
1 files changed, 175 insertions, 0 deletions
diff --git a/cpp/src/Ice/ValueFactoryManager.cpp b/cpp/src/Ice/ValueFactoryManager.cpp
new file mode 100644
index 00000000000..6a5b534e14c
--- /dev/null
+++ b/cpp/src/Ice/ValueFactoryManager.cpp
@@ -0,0 +1,175 @@
+
+// **********************************************************************
+//
+// Copyright (c) 2003-2015 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/ValueFactoryManager.h>
+#include <Ice/ValueFactory.h>
+#include <Ice/ObjectFactory.h>
+#include <Ice/Object.h>
+#include <Ice/Functional.h>
+#include <Ice/LocalException.h>
+
+using namespace std;
+using namespace Ice;
+using namespace IceInternal;
+
+IceUtil::Shared* IceInternal::upCast(ValueFactoryManager* p) { return p; }
+
+#ifndef ICE_CPP11_MAPPING
+IceUtil::Shared* IceInternal::upCast(ValueFactoryWrapper* p) { return p; }
+
+ValueFactoryWrapper::ValueFactoryWrapper(const Ice::ObjectFactoryPtr& factory) : _objectFactory(factory)
+{
+}
+
+Ice::ValuePtr
+ValueFactoryWrapper::create(const string& id)
+{
+ return _objectFactory->create(id);
+}
+#endif
+
+void
+IceInternal::ValueFactoryManager::add(const ICE_VALUE_FACTORY& factory, const string& id)
+{
+ IceUtil::Mutex::Lock sync(*this);
+
+ if((_factoryMapHint != _factoryMap.end() && _factoryMapHint->first == id)
+ || _factoryMap.find(id) != _factoryMap.end())
+ {
+ AlreadyRegisteredException ex(__FILE__, __LINE__);
+ ex.kindOfObject = "value factory";
+ ex.id = id;
+ throw ex;
+ }
+
+ _factoryMapHint = _factoryMap.insert(_factoryMapHint, pair<const string, ICE_VALUE_FACTORY>(id, factory));
+}
+
+void
+IceInternal::ValueFactoryManager::add(const Ice::ObjectFactoryPtr& factory, const string& id)
+{
+ IceUtil::Mutex::Lock sync(*this);
+
+ // Check value factory map since an object factory is added to both object
+ // and value factory maps, but not vise versa
+ if((_factoryMapHint != _factoryMap.end() && _factoryMapHint->first == id)
+ || _factoryMap.find(id) != _factoryMap.end())
+ {
+ AlreadyRegisteredException ex(__FILE__, __LINE__);
+ ex.kindOfObject = "value factory";
+ ex.id = id;
+ throw ex;
+ }
+
+#ifdef ICE_CPP11_MAPPING
+ _factoryMapHint = _factoryMap.insert(_factoryMapHint,
+ pair<const string, ICE_VALUE_FACTORY>(id,
+ [factory](const string& id)
+ {
+ return factory->create(id);
+ }
+ ));
+#else
+ _factoryMapHint = _factoryMap.insert(_factoryMapHint,
+ pair<const string, ICE_VALUE_FACTORY>(id, new ValueFactoryWrapper(factory)));
+#endif
+
+ _objectFactoryMapHint = _objectFactoryMap.insert(_objectFactoryMapHint,
+ pair<const string, Ice::ObjectFactoryPtr>(id, factory));
+}
+
+ICE_VALUE_FACTORY
+IceInternal::ValueFactoryManager::find(const string& id) const
+{
+ IceUtil::Mutex::Lock sync(*this);
+
+ FactoryMap& factoryMap = const_cast<FactoryMap&>(_factoryMap);
+
+ FactoryMap::iterator p = factoryMap.end();
+ if(_factoryMapHint != factoryMap.end())
+ {
+ if(_factoryMapHint->first == id)
+ {
+ p = _factoryMapHint;
+ }
+ }
+
+ if(p == factoryMap.end())
+ {
+ p = factoryMap.find(id);
+ }
+
+ if(p != factoryMap.end())
+ {
+ _factoryMapHint = p;
+ return p->second;
+ }
+ else
+ {
+ return ICE_NULLPTR;
+ }
+}
+
+Ice::ObjectFactoryPtr
+IceInternal::ValueFactoryManager::findObjectFactory(const string& id) const
+{
+ IceUtil::Mutex::Lock sync(*this);
+
+ ObjectFactoryMap& objectfactoryMap = const_cast<ObjectFactoryMap&>(_objectFactoryMap);
+
+ ObjectFactoryMap::iterator p = objectfactoryMap.end();
+ if(_objectFactoryMapHint != objectfactoryMap.end())
+ {
+ if(_objectFactoryMapHint->first == id)
+ {
+ p = _objectFactoryMapHint;
+ }
+ }
+
+ if(p == objectfactoryMap.end())
+ {
+ p = objectfactoryMap.find(id);
+ }
+
+ if(p != objectfactoryMap.end())
+ {
+ _objectFactoryMapHint = p;
+ return p->second;
+ }
+ else
+ {
+ return ICE_NULLPTR;
+ }
+}
+
+IceInternal::ValueFactoryManager::ValueFactoryManager() :
+ _factoryMapHint(_factoryMap.end()),
+ _objectFactoryMapHint(_objectFactoryMap.end())
+{
+}
+
+void
+IceInternal::ValueFactoryManager::destroy()
+{
+ ObjectFactoryMap oldMap;
+ {
+ IceUtil::Mutex::Lock sync(*this);
+ _factoryMap.clear();
+ _factoryMapHint = _factoryMap.end();
+ oldMap.swap(_objectFactoryMap);
+ _objectFactoryMapHint = _objectFactoryMap.end();
+ }
+
+ //
+ // Destroy all outside lock
+ //
+ for_each(oldMap.begin(), oldMap.end(),
+ Ice::secondVoidMemFun<const string, Ice::ObjectFactory>(&Ice::ObjectFactory::destroy));
+}