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
|
/*******************************************************************************
* Copyright (c) 2009 EclipseSource 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:
* EclipseSource - initial API and implementation
******************************************************************************/
package org.eclipse.ecf.osgi.services.distribution;
import java.util.ArrayList;
import java.util.List;
import org.eclipse.core.runtime.IProgressMonitor;
import org.eclipse.ecf.core.ContainerConnectException;
import org.eclipse.ecf.core.IContainer;
import org.eclipse.ecf.core.identity.ID;
import org.eclipse.ecf.core.security.IConnectContext;
import org.eclipse.ecf.discovery.identity.IServiceID;
import org.eclipse.ecf.osgi.services.discovery.IServiceEndpointDescription;
import org.eclipse.ecf.osgi.services.discovery.IServicePublication;
import org.eclipse.ecf.remoteservice.IRemoteServiceContainer;
/**
* Default implementation of IProxyContainerFinder.
*
*/
public class DefaultProxyContainerFinder extends AbstractContainerFinder
implements IProxyContainerFinder {
protected IContainer[] getContainers(IServiceID serviceID,
IServiceEndpointDescription endpointDescription) {
// Get all containers available
IContainer[] allContainers = getAllContainers();
// If none then return null
if (allContainers == null)
return null;
List results = new ArrayList();
for (int i = 0; i < allContainers.length; i++) {
// Do *not* include containers with same ID as endpoint ID
ID containerID = allContainers[i].getID();
if (containerID == null
|| containerID.equals(endpointDescription
.getECFEndpointID()))
continue;
// And make sure that the namespaces match
if (includeContainerWithConnectNamespace(
allContainers[i],
(String) endpointDescription
.getProperty(IServicePublication.PROP_KEY_ENDPOINT_CONTAINERID_NAMESPACE)))
results.add(allContainers[i]);
}
return (IContainer[]) results.toArray(new IContainer[] {});
}
protected IRemoteServiceContainer[] getRemoteServiceContainers(
IServiceID serviceID,
IServiceEndpointDescription endpointDescription) {
IContainer[] containers = getContainers(serviceID, endpointDescription);
if (containers == null)
return null;
return getRemoteServiceContainers(containers);
}
public IRemoteServiceContainer[] findProxyContainers(IServiceID serviceID,
IServiceEndpointDescription endpointDescription,
IProgressMonitor monitor) {
trace("findProxyContainers", "serviceID=" + serviceID
+ " endpointDescription=" + endpointDescription);
// Get remote service containers under consideration
IRemoteServiceContainer[] rsContainers = getRemoteServiceContainers(
serviceID, endpointDescription);
// If none available then return
if (rsContainers == null) {
logWarning("findProxyContainers",
"No remote service containers found");
return EMPTY_REMOTE_SERVICE_CONTAINER_ARRAY;
}
trace("findProxyContainers", "getRemoteServiceContainers.length="
+ rsContainers.length);
ID connectTargetID = endpointDescription.getConnectTargetID();
IRemoteServiceContainer[] connectedContainers = (connectTargetID == null) ? rsContainers
: connectRemoteServiceContainers(rsContainers, connectTargetID,
monitor);
if (connectedContainers == null) {
logWarning("findProxyContainers",
"No remote service containers found after connect");
return EMPTY_REMOTE_SERVICE_CONTAINER_ARRAY;
}
trace("findProxyContainers", "connectRemoteServiceContainers.length="
+ rsContainers.length);
return connectedContainers;
}
protected IConnectContext getConnectContext(
IRemoteServiceContainer rsContainer, ID connectTargetID) {
return null;
}
protected IRemoteServiceContainer[] connectRemoteServiceContainers(
IRemoteServiceContainer[] rsContainers, ID connectTargetID,
IProgressMonitor monitor) {
List results = new ArrayList();
for (int i = 0; i < rsContainers.length; i++) {
IContainer c = rsContainers[i].getContainer();
try {
if (c.getConnectedID() == null) {
connectContainer(c, connectTargetID, getConnectContext(
rsContainers[i], connectTargetID));
results.add(rsContainers[i]);
}
} catch (ContainerConnectException e) {
logError("connectRemoteServiceContainers",
"Exception connecting container=" + c.getID()
+ " to connectTargetID=" + connectTargetID, e);
}
}
return (IRemoteServiceContainer[]) results
.toArray(new IRemoteServiceContainer[] {});
}
}
|
