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
|
package org.eclipse.ecf.internal.osgi.services.distribution;
import java.util.Collection;
import java.util.Dictionary;
import java.util.Properties;
import org.eclipse.ecf.osgi.services.remoteserviceadmin.AbstractTopologyManager;
import org.osgi.framework.BundleContext;
import org.osgi.framework.InvalidSyntaxException;
import org.osgi.framework.ServiceEvent;
import org.osgi.framework.ServiceReference;
import org.osgi.framework.ServiceRegistration;
import org.osgi.framework.hooks.service.EventHook;
import org.osgi.service.remoteserviceadmin.EndpointListener;
public class BasicTopologyManager extends AbstractTopologyManager implements
EventHook, EndpointListener {
private static final boolean allowLoopbackReference = new Boolean(
System.getProperty(
"org.eclipse.ecf.osgi.services.discovery.allowLoopbackReference", //$NON-NLS-1$
"false")).booleanValue(); //$NON-NLS-1$
private static final String endpointListenerScope = System
.getProperty("org.eclipse.ecf.osgi.services.discovery.endpointListenerScope"); //$NON-NLS-1$
private boolean exportRegisteredSvcs = new Boolean(
System.getProperty(
"org.eclipse.ecf.osgi.services.basictopologymanager.exportRegisteredSvcs", "true")).booleanValue(); //$NON-NLS-1$ //$NON-NLS-2$
private String exportRegisteredSvcsClassname = System
.getProperty("org.eclipse.ecf.osgi.services.basictopologymanager.exportRegisteredSvcsClassname"); //$NON-NLS-1$
private String exportRegisteredSvcsFilter = System
.getProperty(
"org.eclipse.ecf.osgi.services.basictopologymanager.exportRegisteredSvcsFilter", "(service.exported.interfaces=*)"); //$NON-NLS-1$ //$NON-NLS-2$
private ServiceRegistration endpointListenerRegistration;
private ServiceRegistration eventHookRegistration;
public BasicTopologyManager(BundleContext context) {
super(context);
}
public void setExportRegisteredSvcs(boolean val) {
this.exportRegisteredSvcs = val;
}
public void setExportRegisteredSvcsClassname(String classname) {
this.exportRegisteredSvcsClassname = classname;
}
public void setExportRegisteredSvcsFilter(String filter) {
this.exportRegisteredSvcsFilter = filter;
}
private String getEndpointListenerScope() {
// If it's set via system property, then simply use it
if (endpointListenerScope != null)
return endpointListenerScope;
// Otherwise create it
// if allowLoopbackReference is true, then return a filter to match all
// endpoint description ids
StringBuffer elScope = new StringBuffer("("); //$NON-NLS-1$
if (allowLoopbackReference) {
elScope.append(org.osgi.service.remoteserviceadmin.RemoteConstants.ENDPOINT_ID);
elScope.append("=*"); //$NON-NLS-1$
} else {
// filter so that local framework uuid is not the same as local
// value
elScope.append("!("); //$NON-NLS-1$
elScope.append(org.osgi.service.remoteserviceadmin.RemoteConstants.ENDPOINT_FRAMEWORK_UUID);
elScope.append("="); //$NON-NLS-1$
elScope.append(getFrameworkUUID());
elScope.append(")"); //$NON-NLS-1$
}
elScope.append(")"); //$NON-NLS-1$
String result = elScope.toString();
trace("getEndpointListenerScope", "endpointListenerScope=" + result); //$NON-NLS-1$ //$NON-NLS-2$
return result;
}
public void exportRegisteredServices(String exportRegisteredSvcsClassname,
String exportRegisteredSvcsFilter) {
ServiceReference[] existingServiceRefs = null;
try {
existingServiceRefs = getContext().getAllServiceReferences(
exportRegisteredSvcsClassname, exportRegisteredSvcsFilter);
} catch (InvalidSyntaxException e) {
logError(
"exportRegisteredServices", //$NON-NLS-1$
"Could not retrieve existing service references for exportRegisteredSvcsClassname=" //$NON-NLS-1$
+ exportRegisteredSvcsClassname
+ " and exportRegisteredSvcsFilter=" //$NON-NLS-1$
+ exportRegisteredSvcsFilter, e);
}
// Now export as if the service was registering right now...i.e. perform
// export
if (existingServiceRefs != null)
for (int i = 0; i < existingServiceRefs.length; i++)
// This method will check the service properties for
// remote service props. If previously registered as a
// remote service, it will export the remote
// service if not it will simply return/skip
handleServiceRegistering(existingServiceRefs[i]);
}
public void start() throws Exception {
// First export any previously registered remote services
if (exportRegisteredSvcs)
exportRegisteredServices(exportRegisteredSvcsClassname,
exportRegisteredSvcsFilter);
// Register as EndpointListener, so that it gets notified when Endpoints
// are discovered
Properties props = new Properties();
props.put(
org.osgi.service.remoteserviceadmin.EndpointListener.ENDPOINT_LISTENER_SCOPE,
getEndpointListenerScope());
endpointListenerRegistration = getContext().registerService(
EndpointListener.class.getName(), this, (Dictionary) props);
// Register as EventHook, so that we get notified when remote services
// are registered
eventHookRegistration = getContext().registerService(
EventHook.class.getName(), this, null);
}
public void endpointAdded(
org.osgi.service.remoteserviceadmin.EndpointDescription endpoint,
String matchedFilter) {
handleEndpointAdded(endpoint, matchedFilter);
}
public void endpointRemoved(
org.osgi.service.remoteserviceadmin.EndpointDescription endpoint,
String matchedFilter) {
handleEndpointRemoved(endpoint, matchedFilter);
}
public void event(ServiceEvent event, Collection contexts) {
handleEvent(event, contexts);
}
public void close() {
if (eventHookRegistration != null) {
eventHookRegistration.unregister();
eventHookRegistration = null;
}
if (endpointListenerRegistration != null) {
endpointListenerRegistration.unregister();
endpointListenerRegistration = null;
}
super.close();
}
}
|
