1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
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);
}
}
}
}
}
}
}
}
}
|
