Mercurial > hg > Database > Alice
annotate src/main/java/alice/topology/node/StartTopologyNode.java @ 558:0259a8aba18c dispose
add ip to HostMessage.class, delete System.out in ReceiveData, some TopM class change using ip connection
| author | Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp> |
|---|---|
| date | Sat, 21 Nov 2015 18:23:51 +0900 |
| parents | 1a860019b2fe |
| children |
| rev | line source |
|---|---|
| 345 | 1 package alice.topology.node; |
| 2 | |
| 3 import java.net.InetAddress; | |
| 4 import java.net.UnknownHostException; | |
| 439 | 5 import java.util.ArrayList; |
| 6 | |
| 345 | 7 import alice.codesegment.CodeSegment; |
| 8 import alice.datasegment.DataSegment; | |
| 9 import alice.topology.HostMessage; | |
| 10 | |
| 11 public class StartTopologyNode extends CodeSegment { | |
| 12 | |
| 419 | 13 private TopologyNodeConfig conf; |
| 14 private CodeSegment startCS; | |
| 15 | |
| 16 public StartTopologyNode(TopologyNodeConfig conf, CodeSegment startCS) { | |
| 17 this.conf = conf; | |
| 18 this.startCS = startCS; | |
| 19 } | |
| 20 | |
| 21 @Override | |
| 22 public void run() { | |
|
557
1a860019b2fe
add ip to HostMessage.class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
523
diff
changeset
|
23 DataSegment.connect("manager", "manager", conf.getManagerHostIP(), conf.getManagerPort()); |
| 419 | 24 String localHostName = null; |
|
558
0259a8aba18c
add ip to HostMessage.class, delete System.out in ReceiveData, some TopM class change using ip connection
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
557
diff
changeset
|
25 String localIP = null; |
| 419 | 26 try { |
| 27 localHostName = InetAddress.getLocalHost().getHostName(); | |
|
558
0259a8aba18c
add ip to HostMessage.class, delete System.out in ReceiveData, some TopM class change using ip connection
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
557
diff
changeset
|
28 localIP = InetAddress.getLocalHost().getHostAddress(); |
| 419 | 29 } catch (UnknownHostException e) { |
| 30 e.printStackTrace(); | |
| 31 } | |
| 427 | 32 new SaveCookie(); |
| 419 | 33 |
|
558
0259a8aba18c
add ip to HostMessage.class, delete System.out in ReceiveData, some TopM class change using ip connection
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
557
diff
changeset
|
34 HostMessage host = new HostMessage(localHostName,localIP, conf.localPort); |
| 427 | 35 host.cookie = conf.cookie; |
| 419 | 36 ods.put("manager", "host", host); |
| 37 | |
| 439 | 38 ods.put("_CLIST", new ArrayList<String>()); |
| 467 | 39 |
| 419 | 40 IncomingAbstractHostName cs = new IncomingAbstractHostName(); |
| 41 cs.absName.setKey("local", "host"); | |
| 42 | |
| 43 IncomingReverseKey cs2 = new IncomingReverseKey(); | |
| 44 cs2.reverseKey.setKey("local", "reverseKey"); | |
| 45 cs2.reverseCount.setKey("local", "reverseCount"); | |
| 46 | |
| 47 ods.put("local", "reverseCount", 0); | |
| 48 | |
| 49 ConfigurationFinish cs3 = new ConfigurationFinish(startCS); | |
| 50 cs3.reverseCount.setKey("local", "reverseCount"); | |
| 51 cs3.configNodeNum.setKey("local", "configNodeNum"); | |
| 52 | |
| 53 } | |
| 54 | |
| 345 | 55 } |