|
49
|
1 package christie.topology.node;
|
|
|
2
|
|
61
|
3 import christie.annotation.Peek;
|
|
49
|
4 import christie.codegear.CodeGear;
|
|
|
5 import christie.codegear.CodeGearManager;
|
|
|
6 import christie.topology.HostMessage;
|
|
|
7 import christie.topology.manager.IncomingHosts;
|
|
|
8
|
|
|
9 import java.net.InetAddress;
|
|
|
10 import java.net.UnknownHostException;
|
|
|
11 import java.util.ArrayList;
|
|
|
12
|
|
|
13 public class TopologyNode extends CodeGear{
|
|
|
14
|
|
61
|
15 @Peek
|
|
|
16 TopologyNodeConfig topologyNodeConfig;
|
|
49
|
17
|
|
61
|
18 public TopologyNode() {
|
|
49
|
19 }
|
|
|
20
|
|
|
21 @Override
|
|
|
22 protected void run(CodeGearManager cgm) {
|
|
61
|
23
|
|
|
24 cgm.createRemoteDGM(topologyNodeConfig.getManagerKey(),
|
|
58
|
25 topologyNodeConfig.getManagerHostName(),
|
|
|
26 topologyNodeConfig.getManagerPort());
|
|
61
|
27
|
|
|
28
|
|
49
|
29 String localHostName = null;
|
|
|
30 try {
|
|
|
31 localHostName = InetAddress.getLocalHost().getHostAddress();
|
|
|
32 } catch (UnknownHostException e) {
|
|
|
33 e.printStackTrace();
|
|
|
34 }
|
|
61
|
35
|
|
49
|
36 HostMessage host = new HostMessage(localHostName, cgm.localPort);
|
|
58
|
37 host.cookie = topologyNodeConfig.cookie;
|
|
49
|
38
|
|
61
|
39 getDGM(topologyNodeConfig.getManagerKey()).put("hostMessage", host);
|
|
77
|
40
|
|
49
|
41 getLocalDGM().put("_CLIST", new ArrayList<String>());
|
|
|
42 getLocalDGM().put("reverseCount", 0);
|
|
|
43
|
|
61
|
44 cgm.setup(new SaveCookie());
|
|
66
|
45 cgm.setup(new IncomingConnectionInfo());
|
|
61
|
46 cgm.setup(new IncomingReverseKey());
|
|
71
|
47 cgm.setup(new ConfigurationFinish());
|
|
49
|
48
|
|
|
49 }
|
|
|
50 }
|
