|
269
|
1 package alice.topology.manager.reconnection;
|
|
|
2
|
|
|
3 import java.util.ArrayList;
|
|
|
4 import java.util.HashMap;
|
|
|
5 import java.util.List;
|
|
|
6
|
|
270
|
7 import org.msgpack.type.ValueFactory;
|
|
|
8
|
|
269
|
9 import alice.codesegment.CodeSegment;
|
|
|
10 import alice.datasegment.CommandType;
|
|
|
11 import alice.datasegment.Receiver;
|
|
|
12 import alice.topology.HostMessage;
|
|
|
13
|
|
|
14 public class CheckConnectionList extends CodeSegment {
|
|
|
15
|
|
|
16 private Receiver name = ids.create(CommandType.TAKE);
|
|
|
17 private Receiver connection = ids.create(CommandType.TAKE);
|
|
|
18 private Receiver abs = ids.create(CommandType.PEEK);
|
|
|
19 private Receiver clone = ids.create(CommandType.TAKE);
|
|
|
20
|
|
|
21 public CheckConnectionList(){
|
|
|
22 name.setKey("_RECABSNAME");
|
|
|
23 connection.setKey("connection");
|
|
|
24 abs.setKey("_ABSIPTABLE");
|
|
270
|
25 clone.setKey("_HMCLONE");
|
|
269
|
26 }
|
|
|
27
|
|
|
28 @Override
|
|
|
29 public void run() {
|
|
|
30 System.out.println("CheckConnectionList");
|
|
|
31 @SuppressWarnings("unchecked")
|
|
|
32 HashMap<String, ArrayList<HostMessage>> connectionList = connection.asClass(HashMap.class);
|
|
|
33 @SuppressWarnings("unchecked")
|
|
|
34 List<HostMessage> ABSIPList = abs.asClass(List.class);
|
|
|
35 String absName = name.asClass(String.class);
|
|
|
36 HostMessage oldInfo = clone.asClass(HostMessage.class);
|
|
|
37 HostMessage newInfo = null;
|
|
|
38 for (HostMessage mes : ABSIPList){
|
|
|
39 if (mes.absName.equals(absName)){
|
|
|
40 newInfo = mes;
|
|
|
41 break;
|
|
|
42 }
|
|
|
43 }
|
|
|
44
|
|
|
45 List<HostMessage> clist = connectionList.get(absName);
|
|
|
46 for (HostMessage mes : clist){
|
|
|
47 ods.put(absName, mes);
|
|
|
48 for (HostMessage mes2 : ABSIPList){
|
|
|
49 if (mes.name.equals(mes2.name)&&mes.port == mes2.port){
|
|
|
50 String absName2 = mes2.getABSName();
|
|
|
51 List<HostMessage> clist2 = connectionList.get(absName2);
|
|
|
52 for (HostMessage mes3 : clist2){
|
|
|
53 if (mes3.name.equals(oldInfo.name)&&mes3.port == oldInfo.port){
|
|
|
54 mes3.name = newInfo.name;
|
|
|
55 mes3.port = newInfo.port;
|
|
270
|
56 System.out.println(mes3.port);
|
|
|
57 System.out.println(mes3.name);
|
|
|
58 System.out.println(absName2+" "+newInfo.port);
|
|
|
59 ods.put(absName2, "_RECODATA", mes3);
|
|
269
|
60 break;
|
|
|
61 }
|
|
270
|
62
|
|
|
63
|
|
269
|
64 }
|
|
|
65 break;
|
|
|
66 }
|
|
|
67 }
|
|
|
68 }
|
|
270
|
69 ods.put(absName, ValueFactory.createNilValue());
|
|
|
70
|
|
269
|
71
|
|
|
72 ods.update("connection", connectionList);
|
|
|
73 new ReceiveError();
|
|
|
74 }
|
|
|
75 }
|
|
|
76 |
