Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat (limited to 'target_explorer/plugins/org.eclipse.tm.te.runtime.services/src/org/eclipse/tm/te/runtime/services/ServiceManager.java')
-rw-r--r--target_explorer/plugins/org.eclipse.tm.te.runtime.services/src/org/eclipse/tm/te/runtime/services/ServiceManager.java175
1 files changed, 175 insertions, 0 deletions
diff --git a/target_explorer/plugins/org.eclipse.tm.te.runtime.services/src/org/eclipse/tm/te/runtime/services/ServiceManager.java b/target_explorer/plugins/org.eclipse.tm.te.runtime.services/src/org/eclipse/tm/te/runtime/services/ServiceManager.java
new file mode 100644
index 000000000..b085aa4e3
--- /dev/null
+++ b/target_explorer/plugins/org.eclipse.tm.te.runtime.services/src/org/eclipse/tm/te/runtime/services/ServiceManager.java
@@ -0,0 +1,175 @@
+/*******************************************************************************
+ * Copyright (c) 2011 Wind River Systems, Inc. and others. All rights reserved.
+ * This program and the accompanying materials are made available under the terms
+ * of the Eclipse Public License v1.0 which accompanies this distribution, and is
+ * available at http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ * Wind River Systems - initial API and implementation
+ *******************************************************************************/
+package org.eclipse.tm.te.runtime.services;
+
+import org.eclipse.core.runtime.IConfigurationElement;
+import org.eclipse.core.runtime.IExtension;
+import org.eclipse.core.runtime.IExtensionPoint;
+import org.eclipse.core.runtime.IStatus;
+import org.eclipse.core.runtime.Platform;
+import org.eclipse.core.runtime.Status;
+import org.eclipse.tm.te.runtime.activator.CoreBundleActivator;
+import org.eclipse.tm.te.runtime.services.interfaces.IService;
+import org.osgi.framework.Bundle;
+
+/**
+ * Common service manager implementation, handling the extension point
+ * <code>org.eclipse.tm.te.runtime.services</code>.
+ */
+public class ServiceManager extends AbstractServiceManager<IService> {
+ /*
+ * Thread save singleton instance creation.
+ */
+ private static class LazyInstance {
+ public static ServiceManager fInstance = new ServiceManager();
+ }
+
+ /**
+ * Constructor.
+ */
+ ServiceManager() {
+ super();
+ }
+
+ /**
+ * Returns the singleton instance of the service manager.
+ */
+ public static ServiceManager getInstance() {
+ return LazyInstance.fInstance;
+ }
+
+ /**
+ * Get a global unbound service that implements at least the needed service type.
+ *
+ * If an interface type is given, the service with the highest implementation is returned.
+ * This may result in a random selection depending on the extension registration order,
+ * especially when a service interface is implemented two times in different hierarchy paths.
+ *
+ * If a class type is given, if available, the service of exactly that class is returned.
+ * Otherwise the highest implementation is returned.
+ *
+ * @param serviceType The service type the service should at least implement or extend.
+ * @return The service or <code>null</code>.
+ */
+ public IService getService(Class<? extends IService> serviceType, boolean unique) {
+ return super.getService("", serviceType, unique); //$NON-NLS-1$
+ }
+
+ /**
+ * Get a global unbound service that implements at least the needed service type.
+ *
+ * If an interface type is given, the service with the highest implementation is returned.
+ * This may result in a random selection depending on the extension registration order,
+ * especially when a service interface is implemented two times in different hierarchy paths.
+ *
+ * If a class type is given, if available, the service of exactly that class is returned.
+ * Otherwise the highest implementation is returned.
+ *
+ * @param serviceType The service type the service should at least implement or extend.
+ * @return The service or <code>null</code>.
+ */
+ public IService getService(Class<? extends IService> serviceType) {
+ return super.getService("", serviceType); //$NON-NLS-1$
+ }
+
+ /* (non-Javadoc)
+ * @see com.windriver.core.runtime.services.AbstractServiceManager#loadServices()
+ */
+ @SuppressWarnings("unchecked")
+ @Override
+ protected void loadServices() {
+ IExtensionPoint ep = Platform.getExtensionRegistry().getExtensionPoint("org.eclipse.tm.te.runtime.services"); //$NON-NLS-1$
+ if (ep != null) {
+ IExtension[] extensions = ep.getExtensions();
+ if (extensions != null) {
+ for (IExtension extension : extensions) {
+ IConfigurationElement[] configElements = extension.getConfigurationElements();
+ if (configElements != null) {
+ for (IConfigurationElement configElement : configElements) {
+ // Determine the unique id to bind the service contributions to.
+ String id = null;
+
+ if ("backendServices".equals(configElement.getName())) { //$NON-NLS-1$
+ id = configElement.getAttribute("backendId"); //$NON-NLS-1$
+
+ // For a backend service declaration, the backend id is mandatory
+ if (id == null || "".equals(id)) { //$NON-NLS-1$
+ IStatus status = new Status(IStatus.WARNING, CoreBundleActivator.getUniqueIdentifier(),
+ "Skipped backend service contributions from contributor '" + configElement.getDeclaringExtension().getNamespaceIdentifier() + "'." //$NON-NLS-1$ //$NON-NLS-2$
+ + " Reason: Missing mandatory backend id."); //$NON-NLS-1$
+ Platform.getLog(CoreBundleActivator.getContext().getBundle()).log(status);
+ continue;
+ }
+ }
+ else if ("dataSourceServices".equals(configElement.getName())) { //$NON-NLS-1$
+ id = configElement.getAttribute("dataSourceId"); //$NON-NLS-1$
+
+ // For a data source service declaration, the data source id is mandatory
+ if (id == null || "".equals(id)) { //$NON-NLS-1$
+ IStatus status = new Status(IStatus.WARNING, CoreBundleActivator.getUniqueIdentifier(),
+ "Skipped data source service contributions from contributor '" + configElement.getDeclaringExtension().getNamespaceIdentifier() + "'." //$NON-NLS-1$ //$NON-NLS-2$
+ + " Reason: Missing mandatory data source id."); //$NON-NLS-1$
+ Platform.getLog(CoreBundleActivator.getContext().getBundle()).log(status);
+ continue;
+ }
+ }
+ else if ("genericServices".equals(configElement.getName())) { //$NON-NLS-1$
+ id = configElement.getAttribute("id"); //$NON-NLS-1$
+ }
+
+ // Normalize the id
+ if (id == null) id = ""; //$NON-NLS-1$
+
+ // Get the service contributions
+ IConfigurationElement[] services = configElement.getChildren("service"); //$NON-NLS-1$
+ // Process the service contributions
+ for (IConfigurationElement service : services) {
+ ServiceProxy proxy = getServiceProxy(service);
+ IConfigurationElement[] serviceTypes = service.getChildren("serviceType"); //$NON-NLS-1$
+ if (serviceTypes != null && serviceTypes.length > 0) {
+ for (IConfigurationElement serviceType : serviceTypes) {
+ try {
+ String type = serviceType.getAttribute("class"); //$NON-NLS-1$
+ String bundleId = serviceType.getAttribute("bundleId"); //$NON-NLS-1$
+
+ // If a bundle id got specified, use the specified bundle to load the service class
+ Bundle bundle = bundleId != null ? bundle = Platform.getBundle(bundleId) : null;
+ // If we don't have a bundle to load from yet, fallback to the declaring bundle
+ if (bundle == null) bundle = Platform.getBundle(configElement.getDeclaringExtension().getNamespaceIdentifier());
+ // And finally, use our own bundle to load the class.
+ // This fallback is expected to never be used.
+ if (bundle == null) bundle = CoreBundleActivator.getContext().getBundle();
+
+ // Try to load the service type class now.
+ Class<?> typeClass = bundle != null ? bundle.loadClass(type) : Class.forName(type);
+ proxy.addType((Class<IService>)typeClass);
+ }
+ catch (Exception e) {
+ IStatus status = new Status(IStatus.WARNING, CoreBundleActivator.getUniqueIdentifier(),
+ "Cannot create service type '" + serviceType.getAttribute("class") //$NON-NLS-1$//$NON-NLS-2$
+ + "' for service '" + service.getAttribute("class") + "'.", e); //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$
+ Platform.getLog(CoreBundleActivator.getContext().getBundle()).log(status);
+ }
+ }
+ }
+ if (!addService(id, proxy)) {
+ IStatus status = new Status(IStatus.WARNING, CoreBundleActivator.getUniqueIdentifier(),
+ "Failed to bind service '" + proxy.clazz + "' to id '" + id + "'.", null); //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$
+ Platform.getLog(CoreBundleActivator.getContext().getBundle()).log(status);
+ }
+ }
+ }
+ }
+ }
+ }
+ }
+ }
+
+}

Back to the top