CommonAPI 3.1.1

1 files changed, 203 insertions, 0 deletions

diff --git a/include/CommonAPI/Runtime.hpp b/include/CommonAPI/Runtime.hpp
new file mode 100644
index 0000000..1cb4f94
--- /dev/null
+++ b/include/CommonAPI/Runtime.hpp
@@ -0,0 +1,203 @@
+// Copyright (C) 2013-2015 Bayerische Motoren Werke Aktiengesellschaft (BMW AG)
+// This Source Code Form is subject to the terms of the Mozilla Public
+// License, v. 2.0. If a copy of the MPL was not distributed with this
+// file, You can obtain one at http://mozilla.org/MPL/2.0/.
+
+#if !defined (COMMONAPI_INTERNAL_COMPILATION)
+#error "Only <CommonAPI/CommonAPI.h> can be included directly, this file may disappear or change contents."
+#endif
+
+#ifndef COMMONAPI_RUNTIME_HPP_
+#define COMMONAPI_RUNTIME_HPP_
+
+#include <map>
+#include <memory>
+#include <mutex>
+#include <set>
+
+#include <CommonAPI/Export.hpp>
+#include <CommonAPI/Factory.hpp>
+#include <CommonAPI/Types.hpp>
+
+namespace CommonAPI {
+
+static const ConnectionId_t DEFAULT_CONNECTION_ID = "";
+
+class MainLoopContext;
+class Proxy;
+class ProxyManager;
+class StubBase;
+
+template<template<typename ...> class _ProxyType, template<typename> class _AttributeExtension>
+struct DefaultAttributeProxyHelper;
+
+template<template<typename ...> class _ProxyClass, template<typename> class _AttributeExtension>
+std::shared_ptr<
+	typename DefaultAttributeProxyHelper<_ProxyClass, _AttributeExtension>::class_t
+> createProxyWithDefaultAttributeExtension(
+	const std::string &_domain, const std::string &_instance);
+
+class Runtime {
+public:
+	COMMONAPI_EXPORT static std::string getProperty(const std::string &_name);
+	COMMONAPI_EXPORT static void setProperty(const std::string &_name, const std::string &_value);
+
+	COMMONAPI_EXPORT static std::shared_ptr<Runtime> get();
+
+	COMMONAPI_EXPORT Runtime();
+	COMMONAPI_EXPORT virtual ~Runtime();
+
+	COMMONAPI_EXPORT void init();
+
+    template<template<typename ...> class _ProxyClass, typename ... _AttributeExtensions>
+	COMMONAPI_EXPORT std::shared_ptr<
+        _ProxyClass<_AttributeExtensions...>
+    >
+    buildProxy(const std::string &_domain,
+               const std::string &_instance,
+               const ConnectionId_t &_connectionId = DEFAULT_CONNECTION_ID) {
+        std::shared_ptr<Proxy> proxy
+        	= createProxy(_domain,
+        				  _ProxyClass<_AttributeExtensions...>::getInterface(),
+						  _instance,
+						  _connectionId);
+
+        if (proxy) {
+            return std::make_shared<_ProxyClass<_AttributeExtensions...>>(proxy);
+        }
+        else {
+            return nullptr;
+        }
+    }
+
+    template<template<typename ...> class _ProxyClass, typename ... _AttributeExtensions>
+	COMMONAPI_EXPORT std::shared_ptr<
+        _ProxyClass<_AttributeExtensions...>
+    >
+    buildProxy(const std::string &_domain,
+               const std::string &_instance,
+               std::shared_ptr<MainLoopContext> _context) {
+        std::shared_ptr<Proxy> proxy
+			= createProxy(_domain,
+        				  _ProxyClass<_AttributeExtensions...>::getInterface(),
+						  _instance,
+						  _context);
+        if (proxy) {
+            return std::make_shared<_ProxyClass<_AttributeExtensions...>>(proxy);
+        }
+        else {
+            return nullptr;
+        }
+    }
+
+    template <template<typename ...> class _ProxyClass, template<typename> class _AttributeExtension>
+	COMMONAPI_EXPORT std::shared_ptr<typename DefaultAttributeProxyHelper<_ProxyClass, _AttributeExtension>::class_t>
+    buildProxyWithDefaultAttributeExtension(const std::string &_domain,
+                                            const std::string &_instance,
+											const ConnectionId_t &_connectionId = DEFAULT_CONNECTION_ID) {
+        std::shared_ptr<Proxy> proxy
+			= createProxy(_domain,
+        	 		      DefaultAttributeProxyHelper<_ProxyClass, _AttributeExtension>::class_t::getInterface(),
+        				  _instance,
+						  _connectionId);
+        if (proxy) {
+            return std::make_shared<typename DefaultAttributeProxyHelper<_ProxyClass, _AttributeExtension>::class_t>(proxy);
+        }
+        return nullptr;
+    }
+
+    template <template<typename ...> class _ProxyClass, template<typename> class _AttributeExtension>
+	COMMONAPI_EXPORT std::shared_ptr<typename DefaultAttributeProxyHelper<_ProxyClass, _AttributeExtension>::class_t>
+    buildProxyWithDefaultAttributeExtension(const std::string &_domain,
+                                            const std::string &_instance,
+                                            std::shared_ptr<MainLoopContext> _context) {
+        std::shared_ptr<Proxy> proxy
+			= createProxy(_domain,
+        	 		      DefaultAttributeProxyHelper<_ProxyClass, _AttributeExtension>::class_t::getInterface(),
+        				  _instance,
+						  _context);
+        if (proxy) {
+            return std::make_shared<typename DefaultAttributeProxyHelper<_ProxyClass, _AttributeExtension>::class_t>(proxy);
+        }
+        return nullptr;
+    }
+
+    template<typename _Stub>
+	COMMONAPI_EXPORT bool registerService(const std::string &_domain,
+						 const std::string &_instance,
+						 std::shared_ptr<_Stub> _service,
+						 const ConnectionId_t &_connectionId = DEFAULT_CONNECTION_ID) {
+		return registerStub(_domain, _Stub::StubInterface::getInterface(), _instance, _service, _connectionId);
+	}
+
+    template<typename _Stub>
+	COMMONAPI_EXPORT bool registerService(const std::string &_domain,
+    					 const std::string &_instance,
+    					 std::shared_ptr<_Stub> _service,
+    					 std::shared_ptr<MainLoopContext> _context) {
+    	return registerStub(_domain, _Stub::StubInterface::getInterface(), _instance, _service, _context);
+    }
+
+	COMMONAPI_EXPORT bool unregisterService(const std::string &_domain,
+							const std::string &_interface,
+							const std::string &_instance) {
+		return unregisterStub(_domain, _interface, _instance);
+	}
+
+	COMMONAPI_EXPORT bool registerFactory(const std::string &_ipc, std::shared_ptr<Factory> _factory);
+	COMMONAPI_EXPORT bool unregisterFactory(const std::string &_ipc);
+
+    inline const std::string &getDefaultBinding() const { return defaultBinding_; };
+
+private:
+	COMMONAPI_EXPORT bool readConfiguration();
+	COMMONAPI_EXPORT bool splitAddress(const std::string &, std::string &, std::string &, std::string &);
+
+	COMMONAPI_EXPORT std::shared_ptr<Proxy> createProxy(const std::string &, const std::string &, const std::string &,
+									   const ConnectionId_t &);
+	COMMONAPI_EXPORT std::shared_ptr<Proxy> createProxy(const std::string &, const std::string &, const std::string &,
+									   std::shared_ptr<MainLoopContext>);
+
+	COMMONAPI_EXPORT std::shared_ptr<Proxy> createProxyHelper(const std::string &, const std::string &, const std::string &,
+										     const ConnectionId_t &);
+	COMMONAPI_EXPORT std::shared_ptr<Proxy> createProxyHelper(const std::string &, const std::string &, const std::string &,
+										     std::shared_ptr<MainLoopContext>);
+
+
+	COMMONAPI_EXPORT bool registerStub(const std::string &, const std::string &, const std::string &,
+					  std::shared_ptr<StubBase>, const ConnectionId_t &);
+	COMMONAPI_EXPORT bool registerStub(const std::string &, const std::string &, const std::string &,
+					  std::shared_ptr<StubBase>, std::shared_ptr<MainLoopContext>);
+	COMMONAPI_EXPORT bool registerStubHelper(const std::string &, const std::string &, const std::string &,
+							std::shared_ptr<StubBase>, const ConnectionId_t &);
+	COMMONAPI_EXPORT bool registerStubHelper(const std::string &, const std::string &, const std::string &,
+							std::shared_ptr<StubBase>, std::shared_ptr<MainLoopContext>);
+
+	COMMONAPI_EXPORT bool unregisterStub(const std::string &, const std::string &, const std::string &);
+
+	COMMONAPI_EXPORT std::string getLibrary(const std::string &, const std::string &, const std::string &, bool);
+	COMMONAPI_EXPORT bool loadLibrary(const std::string &);
+
+private:
+	std::string defaultBinding_;
+	std::string defaultFolder_;
+	std::string defaultConfig_;
+
+	std::map<std::string, std::shared_ptr<Factory>> factories_;
+	std::shared_ptr<Factory> defaultFactory_;
+	std::map<std::string, std::map<bool, std::string>> libraries_;
+	std::set<std::string> loadedLibraries_; // Library name
+
+	std::mutex mutex_;
+	std::mutex factoriesMutex_;
+	std::mutex loadMutex_;
+
+	static std::map<std::string, std::string> properties_;
+	static std::shared_ptr<Runtime> theRuntime__;
+
+friend class ProxyManager;
+};
+
+} // namespace CommonAPI
+
+#endif // COMMONAPI_RUNTIME_HPP_