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
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
|
package org.eclipse.ecf.internal.osgi.services.distribution;
import java.util.Map;
import org.eclipse.ecf.osgi.services.remoteserviceadmin.AbstractTopologyManager;
import org.eclipse.ecf.osgi.services.remoteserviceadmin.EndpointDescription;
import org.eclipse.ecf.osgi.services.remoteserviceadmin.RemoteConstants;
import org.eclipse.ecf.osgi.services.remoteserviceadmin.RemoteServiceAdmin;
import org.osgi.framework.BundleContext;
import org.osgi.framework.InvalidSyntaxException;
import org.osgi.framework.ServiceEvent;
import org.osgi.framework.ServiceReference;
import org.osgi.service.remoteserviceadmin.EndpointEvent;
import org.osgi.service.remoteserviceadmin.EndpointEventListener;
import org.osgi.service.remoteserviceadmin.EndpointListener;
import org.osgi.service.remoteserviceadmin.RemoteServiceAdminEvent;
public class BasicTopologyManagerImpl extends AbstractTopologyManager implements
EndpointListener, EndpointEventListener {
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 defaultScope = System
.getProperty("org.eclipse.ecf.osgi.services.discovery.endpointListenerScope"); //$NON-NLS-1$
private String ecfEndpointListenerScope;
private static final String ONLY_ECF_SCOPE = "(" + RemoteConstants.ENDPOINT_CONTAINER_ID_NAMESPACE + "=*)"; //$NON-NLS-1$ //$NON-NLS-2$
private static final String NO_ECF_SCOPE = "(!(" //$NON-NLS-1$
+ RemoteConstants.ENDPOINT_CONTAINER_ID_NAMESPACE + "=*))"; //$NON-NLS-1$
BasicTopologyManagerImpl(BundleContext context) {
super(context);
if (defaultScope != null)
this.ecfEndpointListenerScope = defaultScope;
// If loopback is allowed, then for this endpoint listener we only
// consider those that have a namespace (only ECF endpoint descriptions)
if (allowLoopbackReference)
ecfEndpointListenerScope = ONLY_ECF_SCOPE;
else {
// If loopback not allowed, then we have our scope include
// both !frameworkUUID same, and ONLY_ECF_SCOPE
StringBuffer elScope = new StringBuffer(""); //$NON-NLS-1$
// filter so that local framework uuid is not the same as local
// value
elScope.append("(&(!(").append(org.osgi.service.remoteserviceadmin.RemoteConstants.ENDPOINT_FRAMEWORK_UUID).append("=").append(getFrameworkUUID()).append("))"); //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$
elScope.append(ONLY_ECF_SCOPE);
elScope.append(")"); //$NON-NLS-1$
ecfEndpointListenerScope = elScope.toString();
}
}
String[] getScope() {
return new String[] { ecfEndpointListenerScope, NO_ECF_SCOPE };
}
protected String getFrameworkUUID() {
return super.getFrameworkUUID();
}
void exportRegisteredServices(String exportRegisteredSvcsClassname,
String exportRegisteredSvcsFilter) {
try {
final ServiceReference[] existingServiceRefs = getContext()
.getAllServiceReferences(exportRegisteredSvcsClassname,
exportRegisteredSvcsFilter);
// Now export as if the service was registering right now...i.e.
// perform
// export
if (existingServiceRefs != null && existingServiceRefs.length > 0) {
// After having collected all pre-registered services (with
// marker prop) we are going to asynchronously remote them.
// Registering potentially is a long-running operation (due to
// discovery I/O...) and thus should no be carried out in the
// OSGi FW thread. (https://bugs.eclipse.org/405027)
new Thread(new Runnable() {
public void run() {
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]);
}
}
}, "BasicTopologyManagerPreRegSrvExporter").start(); //$NON-NLS-1$
}
} 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);
}
}
// EndpointListener impl
/*
* (non-Javadoc)
*
* @see
* org.osgi.service.remoteserviceadmin.EndpointListener#endpointAdded(org
* .osgi.service.remoteserviceadmin.EndpointDescription, java.lang.String)
*
*
* From the R5 spec page 329 section 122.6.2:
*
* Notify the Endpoint Listener of a new Endpoint Description. The second
* parameter is the filter that matched the Endpoint Description.
* Registering the same Endpoint multiple times counts as a single
* registration.
*/
public void endpointAdded(
org.osgi.service.remoteserviceadmin.EndpointDescription endpoint,
String matchedFilter) {
handleEndpointAdded(endpoint, matchedFilter);
}
protected void handleEndpointAdded(
org.osgi.service.remoteserviceadmin.EndpointDescription endpoint,
String matchedFilter) {
if (matchedFilter.equals(ecfEndpointListenerScope)
&& (endpoint instanceof EndpointDescription)) {
handleECFEndpointAdded((EndpointDescription) endpoint);
}
}
/*
* (non-Javadoc)
*
* @see
* org.osgi.service.remoteserviceadmin.EndpointListener#endpointRemoved(
* org.osgi.service.remoteserviceadmin.EndpointDescription,
* java.lang.String)
*/
public void endpointRemoved(
org.osgi.service.remoteserviceadmin.EndpointDescription endpoint,
String matchedFilter) {
handleEndpointRemoved(endpoint, matchedFilter);
}
protected void handleEndpointRemoved(
org.osgi.service.remoteserviceadmin.EndpointDescription endpoint,
String matchedFilter) {
if (matchedFilter.equals(ecfEndpointListenerScope)
&& (endpoint instanceof EndpointDescription)) {
handleECFEndpointRemoved((EndpointDescription) endpoint);
}
}
// EventListenerHook impl
void event(ServiceEvent event, Map listeners) {
handleEvent(event, listeners);
}
// RemoteServiceAdminListener impl
void handleRemoteAdminEvent(RemoteServiceAdminEvent event) {
if (!(event instanceof RemoteServiceAdmin.RemoteServiceAdminEvent))
return;
RemoteServiceAdmin.RemoteServiceAdminEvent rsaEvent = (RemoteServiceAdmin.RemoteServiceAdminEvent) event;
int eventType = event.getType();
EndpointDescription endpointDescription = rsaEvent
.getEndpointDescription();
switch (eventType) {
case RemoteServiceAdminEvent.EXPORT_REGISTRATION:
advertiseEndpointDescription(endpointDescription);
break;
case RemoteServiceAdminEvent.EXPORT_UNREGISTRATION:
unadvertiseEndpointDescription(endpointDescription);
break;
case RemoteServiceAdminEvent.EXPORT_ERROR:
logError("handleExportError", "Export error with event=" + rsaEvent); //$NON-NLS-1$ //$NON-NLS-2$
break;
case RemoteServiceAdminEvent.IMPORT_REGISTRATION:
break;
case RemoteServiceAdminEvent.IMPORT_UNREGISTRATION:
break;
case RemoteServiceAdminEvent.IMPORT_ERROR:
break;
default:
logWarning(
"handleRemoteAdminEvent", "RemoteServiceAdminEvent=" + rsaEvent + " received with unrecognized type"); //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$
}
}
/**
* Implementation of
* org.osgi.service.remoteserviceadmin.EndpointEventListener for rfc 203/RSA
* 1.1
*
* @see EndpointEventListener#endpointChanged(EndpointEvent, String)
*/
public void endpointChanged(EndpointEvent event, String matchedFilter) {
int eventType = event.getType();
org.osgi.service.remoteserviceadmin.EndpointDescription ed = event
.getEndpoint();
switch (eventType) {
case EndpointEvent.ADDED:
handleEndpointAdded(ed, matchedFilter);
break;
case EndpointEvent.REMOVED:
handleEndpointRemoved(ed, matchedFilter);
break;
case EndpointEvent.MODIFIED:
handleEndpointModified(ed, matchedFilter);
break;
case EndpointEvent.MODIFIED_ENDMATCH:
handleEndpointModifiedEndmatch(ed, matchedFilter);
break;
}
}
protected void handleEndpointModifiedEndmatch(
org.osgi.service.remoteserviceadmin.EndpointDescription endpoint,
String matchedFilter) {
// By default do nothing for end match. subclasses may decide
// to change this behavior
}
protected void handleEndpointModified(
org.osgi.service.remoteserviceadmin.EndpointDescription endpoint,
String matchedFilter) {
if (matchedFilter.equals(ecfEndpointListenerScope)
&& (endpoint instanceof EndpointDescription)) {
handleECFEndpointModified((EndpointDescription) endpoint);
}
}
}
|
