comparison src/main/java/alice/topology/manager/SearchHostName.java @ 539:0832af83583f dispose

command init on AliceDaemon
author Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
date Mon, 03 Aug 2015 18:31:19 +0900
parents 268b1280dc18
children f3f7e256ee03
comparison
equal deleted inserted replaced
538:8c17a9e66cc7 539:0832af83583f
1 package alice.topology.manager; 1 package alice.topology.manager;
2 2
3 import java.util.HashMap; 3 import java.util.HashMap;
4 import java.util.LinkedList; 4 import java.util.LinkedList;
5 5
6 import alice.daemon.AliceDaemon;
6 import org.msgpack.type.ValueFactory; 7 import org.msgpack.type.ValueFactory;
7 8
8 import alice.codesegment.CodeSegment; 9 import alice.codesegment.CodeSegment;
9 import alice.datasegment.CommandType; 10 import alice.datasegment.CommandType;
10 import alice.datasegment.DataSegment; 11 import alice.datasegment.DataSegment;
28 HostMessage hostInfo = info.asClass(HostMessage.class); 29 HostMessage hostInfo = info.asClass(HostMessage.class);
29 boolean running = info2.asClass(boolean.class); 30 boolean running = info2.asClass(boolean.class);
30 @SuppressWarnings("unchecked") 31 @SuppressWarnings("unchecked")
31 HashMap<String, LinkedList<HostMessage>> topology = info1.asClass(HashMap.class); 32 HashMap<String, LinkedList<HostMessage>> topology = info1.asClass(HashMap.class);
32 33
33 DataSegment.remove(hostInfo.absName); 34 AliceDaemon.dataSegment.remove(hostInfo.absName);
34 DataSegment.connect(hostInfo.absName, "", hostInfo.name, hostInfo.port); 35 AliceDaemon.dataSegment.connect(hostInfo.absName, "", hostInfo.name, hostInfo.port);
35 ods.put(hostInfo.absName, "host", hostInfo.absName); 36 ods.put(hostInfo.absName, "host", hostInfo.absName);
36 37
37 // put Host dataSegment on reconnect node 38 // put Host dataSegment on reconnect node
38 if (topology.containsKey(hostInfo.absName)) { 39 if (topology.containsKey(hostInfo.absName)) {
39 LinkedList<HostMessage> clist = topology.get(hostInfo.absName); 40 LinkedList<HostMessage> clist = topology.get(hostInfo.absName);