Mercurial > hg > Database > Alice

annotate src/main/java/alice/topology/manager/RecodeTopology.java @ 428:93995b7a9a05 dispose

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
change HostMessage field from parentAbsName to remoteAbsName
author sugi
date Tue, 22 Jul 2014 12:56:25 +0900
parents 2c6f86320691
children 1b32ea1263f3
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
422
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
1 package alice.topology.manager;
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
2
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
3 import java.util.HashMap;
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
4 import java.util.LinkedList;
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
5
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
6 import alice.codesegment.CodeSegment;
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
7 import alice.datasegment.CommandType;
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
8 import alice.datasegment.Receiver;
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
9 import alice.topology.HostMessage;
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
10
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
11 public class RecodeTopology extends CodeSegment {
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
12
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
13 private Receiver info = ids.create(CommandType.TAKE); // NodeInfo
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
14 private Receiver info1 = ids.create(CommandType.TAKE); // HashMap
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
15
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
16 public RecodeTopology(){
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
17 info.setKey("nodeInfo");
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
18 info1.setKey("topology");
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
19 }
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
20
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
21 @Override
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
22 public void run() {
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
23 HostMessage hostInfo = info.asClass(HostMessage.class);
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
24 @SuppressWarnings("unchecked")
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
25 HashMap<String, LinkedList<HostMessage>> topology = info1.asClass(HashMap.class);
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
26 LinkedList<HostMessage> connections;
428
93995b7a9a05 change HostMessage field from parentAbsName to remoteAbsName
sugi
parents: 422
diff changeset
27 if (!topology.containsKey(hostInfo.remoteAbsName)) {
422
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
28 connections = new LinkedList<HostMessage>();
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
29 } else {
428
93995b7a9a05 change HostMessage field from parentAbsName to remoteAbsName
sugi
parents: 422
diff changeset
30 connections = topology.get(hostInfo.remoteAbsName);
422
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
31 }
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
32 connections.add(hostInfo);
428
93995b7a9a05 change HostMessage field from parentAbsName to remoteAbsName
sugi
parents: 422
diff changeset
33 topology.put(hostInfo.remoteAbsName, connections);
422
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
34 ods.update(info1.key, topology);
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
35
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
36 for (LinkedList<HostMessage> list :topology.values()){
428
93995b7a9a05 change HostMessage field from parentAbsName to remoteAbsName
sugi
parents: 422
diff changeset
37 System.out.print(list.get(0).remoteAbsName+" : ");
422
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
38 for (HostMessage host : list){
428
93995b7a9a05 change HostMessage field from parentAbsName to remoteAbsName
sugi
parents: 422
diff changeset
39 System.out.print("[ "+host.absName+" "+host.name+" "+host.port+" "+host.connectionName+" "+host.reverseName+" ]");
422
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
40 }
428
93995b7a9a05 change HostMessage field from parentAbsName to remoteAbsName
sugi
parents: 422
diff changeset
41 System.out.println();
422
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
42 }
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
43 }
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
44
2c6f86320691 add topology state recoder
sugi
parents:
diff changeset
45 }