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
|
/****************************************************************************
* Copyright (c) 2004 Composent, 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:
* Composent, Inc. - initial API and implementation
*****************************************************************************/
package org.eclipse.ecf.provider.generic;
import java.io.IOException;
import java.io.Serializable;
import java.net.*;
import org.eclipse.ecf.core.sharedobject.ISharedObjectContainerConfig;
import org.eclipse.ecf.provider.comm.IConnectRequestHandler;
import org.eclipse.ecf.provider.comm.ISynchAsynchConnection;
public class TCPServerSOContainer extends ServerSOContainer implements IConnectRequestHandler {
public static final String DEFAULT_PROTOCOL = System.getProperty("org.eclipse.ecf.provider.generic.scheme", "ecftcp"); //$NON-NLS-1$ //$NON-NLS-2$
public static final int DEFAULT_PORT = Integer.parseInt(System.getProperty("org.eclipse.ecf.provider.generic.port", "3282")); //$NON-NLS-1$ //$NON-NLS-2$;
public static final int DEFAULT_KEEPALIVE = Integer.parseInt(System.getProperty("org.eclipse.ecf.provider.generic.keepalive", "30000")); //$NON-NLS-1$ //$NON-NLS-2$;
public static final String DEFAULT_NAME = System.getProperty("org.eclipse.ecf.provider.generic.name", "/server"); //$NON-NLS-1$ //$NON-NLS-2$"
public static String DEFAULT_HOST = System.getProperty("org.eclipse.ecf.provider.generic.host", "localhost"); //$NON-NLS-1$ //$NON-NLS-2$
static {
final Boolean useHostname = Boolean.valueOf(System.getProperty("org.eclipse.ecf.provider.generic.host.useHostName", "true")); //$NON-NLS-1$ //$NON-NLS-2$
if (useHostname.booleanValue()) {
try {
DEFAULT_HOST = InetAddress.getLocalHost().getCanonicalHostName();
} catch (UnknownHostException e) {
DEFAULT_HOST = "localhost"; //$NON-NLS-1$
}
}
}
// Keep alive value
protected int keepAlive;
protected TCPServerSOContainerGroup group;
protected boolean isSingle = false;
protected int getKeepAlive() {
return keepAlive;
}
public static String getServerURL(String host, String name) {
return DEFAULT_PROTOCOL + "://" + host + ":" + DEFAULT_PORT + name; //$NON-NLS-1$ //$NON-NLS-2$
}
public static String getDefaultServerURL() {
return getServerURL("localhost", DEFAULT_NAME); //$NON-NLS-1$
}
public TCPServerSOContainer(ISharedObjectContainerConfig config, TCPServerSOContainerGroup grp, int keepAlive) throws IOException, URISyntaxException {
super(config);
this.keepAlive = keepAlive;
// Make sure URI syntax is followed.
URI actualURI = new URI(getID().getName());
int urlPort = actualURI.getPort();
if (group == null) {
isSingle = true;
this.group = new TCPServerSOContainerGroup(urlPort);
this.group.putOnTheAir();
} else
this.group = grp;
String path = actualURI.getPath();
group.add(path, this);
}
public TCPServerSOContainer(ISharedObjectContainerConfig config, TCPServerSOContainerGroup listener, String path, int keepAlive) {
super(config);
initialize(listener, path, keepAlive);
}
protected void initialize(TCPServerSOContainerGroup listener, String path, int ka) {
this.keepAlive = ka;
this.group = listener;
this.group.add(path, this);
}
public void dispose() {
URI aURI = null;
try {
aURI = new URI(getID().getName());
} catch (Exception e) {
// Should never happen
}
group.remove(aURI.getPath());
if (isSingle)
group.takeOffTheAir();
super.dispose();
}
public TCPServerSOContainer(ISharedObjectContainerConfig config) throws IOException, URISyntaxException {
this(config, null, DEFAULT_KEEPALIVE);
}
public TCPServerSOContainer(ISharedObjectContainerConfig config, int keepAlive) throws IOException, URISyntaxException {
this(config, null, keepAlive);
}
public Serializable handleConnectRequest(Socket socket, String target, Serializable data, ISynchAsynchConnection conn) {
return acceptNewClient(socket, target, data, conn);
}
protected Serializable getConnectDataFromInput(Serializable input) throws Exception {
return input;
}
}
|
