blob: a5cfbe6d904422b895301ba7d4bbe704348da247 (
plain)
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
|
package org.apache.tuscany.sca.binding.erlang.impl;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import org.apache.tuscany.sca.binding.erlang.ErlangBinding;
import org.apache.tuscany.sca.binding.erlang.impl.exceptions.ErlangException;
import org.apache.tuscany.sca.runtime.RuntimeComponentService;
import com.ericsson.otp.erlang.OtpConnection;
import com.ericsson.otp.erlang.OtpSelf;
public class ErlangNode implements Runnable {
private Map<String, RuntimeComponentService> services = new HashMap<String, RuntimeComponentService>();
private Map<String, ErlangBinding> bindings = new HashMap<String, ErlangBinding>();
private String name;
private OtpSelf self;
private ExecutorService executors;
private boolean stopRequested;
public ErlangNode(String name) throws Exception {
this.name = name;
self = new OtpSelf(name);
boolean registered = self.publishPort();
if (!registered) {
// TODO: externalize messages?
throw new ErlangException(
"Problem with publishing service under epmd server.");
}
}
private void stop() {
stopRequested = true;
executors.shutdownNow();
}
public void run() {
executors = Executors.newFixedThreadPool(10);
while (!stopRequested) {
try {
OtpConnection connection = self.accept();
executors.execute(new RpcExecutor(services, bindings,
connection));
} catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
}
}
public void registerModule(ErlangBinding binding,
RuntimeComponentService service) throws ErlangException {
if (services.containsKey(binding.getModule())) {
// TODO: externalize message
// TODO: really want to throw exception? Log only?
throw new ErlangException("Module " + binding.getModule()
+ " already defined under " + name
+ " node. Duplicate module won't be started");
} else {
if (services.size() == 0) {
// TODO: should ErlangNode manage its thread?
Thread selfThread = new Thread(this);
selfThread.start();
}
services.put(binding.getModule(), service);
bindings.put(binding.getModule(), binding);
}
}
public void unregisterModule(ErlangBinding binding) throws ErlangException {
if (services.containsKey(binding.getModule())) {
services.remove(binding.getModule());
bindings.remove(binding.getModule());
if (services.size() == 0) {
stop();
}
}
}
}
|
