summaryrefslogtreecommitdiffstats
path: root/mcop/objectmanager.cc
diff options
context:
space:
mode:
authortpearson <tpearson@283d02a7-25f6-0310-bc7c-ecb5cbfe19da>2010-01-05 00:01:18 +0000
committertpearson <tpearson@283d02a7-25f6-0310-bc7c-ecb5cbfe19da>2010-01-05 00:01:18 +0000
commit42995d7bf396933ee60c5f89c354ea89cf13df0d (patch)
treecfdcea0ac57420e7baf570bfe435e107bb842541 /mcop/objectmanager.cc
downloadarts-42995d7bf396933ee60c5f89c354ea89cf13df0d.tar.gz
arts-42995d7bf396933ee60c5f89c354ea89cf13df0d.zip
Copy of aRts for Trinity modifications
git-svn-id: svn://anonsvn.kde.org/home/kde/branches/trinity/dependencies/arts@1070145 283d02a7-25f6-0310-bc7c-ecb5cbfe19da
Diffstat (limited to 'mcop/objectmanager.cc')
-rw-r--r--mcop/objectmanager.cc289
1 files changed, 289 insertions, 0 deletions
diff --git a/mcop/objectmanager.cc b/mcop/objectmanager.cc
new file mode 100644
index 0000000..0617ea4
--- /dev/null
+++ b/mcop/objectmanager.cc
@@ -0,0 +1,289 @@
+ /*
+
+ Copyright (C) 2000,2001 Stefan Westerfeld
+ stefan@space.twc.de
+
+ This library is free software; you can redistribute it and/or
+ modify it under the terms of the GNU Library General Public
+ License as published by the Free Software Foundation; either
+ version 2 of the License, or (at your option) any later version.
+
+ This library is distributed in the hope that it will be useful,
+ but WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ Library General Public License for more details.
+
+ You should have received a copy of the GNU Library General Public License
+ along with this library; see the file COPYING.LIB. If not, write to
+ the Free Software Foundation, Inc., 59 Temple Place - Suite 330,
+ Boston, MA 02111-1307, USA.
+
+ */
+
+#include <config.h>
+#include "mcoputils.h"
+#include "mcopconfig.h"
+#include "objectmanager.h"
+#include "dispatcher.h"
+#include "extensionloader.h"
+#include "debug.h"
+#include <stdio.h>
+#include <unistd.h>
+#include <iostream>
+
+using namespace std;
+using namespace Arts;
+
+class Arts::ObjectManagerPrivate {
+public:
+ struct LoaderData {
+ LoaderData() : init(false) { }
+ bool init;
+ Loader loader;
+ };
+
+ list<ExtensionLoader *> extensions;
+ map<string, long> capabilities;
+ map<string, LoaderData> loaders;
+};
+
+Object_skel *ObjectManager::create(const string& name)
+{
+ list<Factory *>::iterator i;
+
+ /* first try: look through all factories we have */
+
+ for(i = factories.begin();i != factories.end(); i++)
+ {
+ Factory *f = *i;
+ if(f->interfaceName() == name ) return f->createInstance();
+ }
+
+ /* second try: look if there is a suitable extension we could load */
+
+ TraderQuery query;
+ query.supports("InterfaceName", name);
+ vector<TraderOffer> *offers = query.query();
+
+ vector<TraderOffer>::iterator oi;
+ for(oi = offers->begin(); oi != offers->end(); oi++)
+ {
+ /*
+ * check whether we provide everything that this
+ * implementation requires to run
+ */
+ bool requirementsOk = true;
+ vector<string> *requires = oi->getProperty("Requires");
+
+ vector<string>::iterator ri;
+ for(ri = requires->begin(); ri != requires->end(); ri++)
+ {
+ if(d->capabilities[*ri] <= 0)
+ requirementsOk = false;
+ }
+ delete requires;
+
+ vector<string> *language = oi->getProperty("Language");
+ vector<string> *libs = oi->getProperty("Library");
+
+ if(language->size() == 0 && libs->size() == 1)
+ {
+ arts_warning("ObjectManager: %s - assuming 'Language=C++' because library given",name.c_str());
+ language->push_back("C++");
+ }
+ if(language->size() != 1)
+ {
+ arts_warning("ObjectManager: %s - Language missing", name.c_str());
+ requirementsOk = false;
+ }
+ if(requirementsOk && language->front() == "C++" && libs->empty())
+ {
+ arts_warning("ObjectManager: %s - Library missing", name.c_str());
+ requirementsOk = false;
+ }
+
+ /* loading C++ components */
+ if(requirementsOk && language->front() == "C++")
+ {
+ string library = libs->front();
+
+ ExtensionLoader *e = new ExtensionLoader(library);
+ if(e->success())
+ {
+ d->extensions.push_back(e);
+ for(i = factories.begin();i != factories.end(); i++)
+ {
+ Factory *f = *i;
+ if(f->interfaceName() == name)
+ {
+ delete language;
+ delete libs;
+ delete offers;
+ return f->createInstance();
+ }
+ }
+ }
+ else
+ {
+ arts_warning("MCOP ObjectManager:"
+ " Could not load extension %s.", library.c_str());
+ delete e;
+ }
+ }
+ delete libs;
+
+ /* other languages/binary formats */
+ if(requirementsOk)
+ {
+ string lang = language->front();
+ ObjectManagerPrivate::LoaderData &ld = d->loaders[lang];
+
+ if(!ld.init)
+ {
+ TraderQuery query;
+ query.supports("Interface", "Arts::Loader");
+ query.supports("LoadLanguage", lang);
+
+ vector<TraderOffer> *loffers = query.query();
+
+ // TODO: error checking for SubClass
+ if(loffers->size() > 0)
+ {
+ ld.loader = SubClass(loffers->front().interfaceName());
+ }
+ else
+ {
+ ld.loader = Arts::Loader::null();
+ }
+
+ delete loffers;
+ }
+ ld.init = true;
+
+ if(!ld.loader.isNull())
+ {
+ /*
+ * ### change when breaking BC:
+ * it's bad that ObjectManager has to return _skel()s, but
+ * well, can't change it now
+ */
+
+ Object obj = ld.loader.loadObject(*oi);
+ delete language;
+ delete offers;
+ return obj._base()->_copy()->_skel();
+ }
+ }
+
+ delete language;
+ }
+
+ arts_warning("MCOP ObjectManager: can't find implementation for %s.",
+ name.c_str());
+
+ delete offers;
+ return 0;
+}
+
+void ObjectManager::registerFactory(Factory *factory)
+{
+ factories.push_back(factory);
+}
+
+void ObjectManager::removeFactory(Factory *factory)
+{
+ list<Factory *>::iterator i;
+
+ i = factories.begin();
+ while(i != factories.end())
+ {
+ if(*i == factory) {
+ factories.erase(i);
+ i = factories.begin();
+ }
+ else i++;
+ }
+}
+
+ObjectManager *ObjectManager::_instance = 0;
+
+ObjectManager::ObjectManager()
+{
+ assert(!_instance);
+ _instance = this;
+ d = new ObjectManagerPrivate;
+}
+
+ObjectManager::~ObjectManager()
+{
+ // they should be unloaded before this object can be deleted
+ assert(d->extensions.empty());
+ delete d;
+ assert(_instance);
+ _instance = 0;
+}
+
+ObjectManager *ObjectManager::the()
+{
+ assert(_instance);
+ return _instance;
+}
+
+void ObjectManager::shutdownExtensions()
+{
+ // give up references to the loaders
+ d->loaders.clear();
+
+ // shuts down all dynamically loaded extensions
+ list<ExtensionLoader *>::iterator i;
+ for(i=d->extensions.begin(); i != d->extensions.end(); i++)
+ (*i)->shutdown();
+}
+
+void ObjectManager::removeExtensions()
+{
+ // unloads all dynamically loaded extensions
+ list<ExtensionLoader *>::iterator i;
+ for(i=d->extensions.begin(); i != d->extensions.end(); i++)
+ delete *i;
+
+ d->extensions.clear();
+}
+
+/*
+ * global references
+ */
+
+bool ObjectManager::addGlobalReference(Object object, const string& name)
+{
+ bool result;
+
+ result = Dispatcher::the()->globalComm().put(name,object.toString());
+ if(result)
+ referenceNames.push_back(name);
+
+ return result;
+}
+
+string ObjectManager::getGlobalReference(const string& name)
+{
+ return Dispatcher::the()->globalComm().get(name);
+}
+
+void ObjectManager::removeGlobalReferences()
+{
+ list<string>::iterator i;
+
+ for(i=referenceNames.begin(); i != referenceNames.end();i++)
+ Dispatcher::the()->globalComm().erase(*i);
+}
+
+void ObjectManager::provideCapability(const string& name)
+{
+ d->capabilities[name]++;
+}
+
+void ObjectManager::removeCapability(const string& name)
+{
+ d->capabilities[name]--;
+}