Mercurial > hg > Database > Christie

comparison src/main/java/christie/topology/manager/IncomingHosts.java @ 160:3b9be156e280

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
update topologymanager
author akahori
date Mon, 21 Jan 2019 21:40:53 +0900
parents e295cb59e514
children 5c5a5da0d13d
comparison
equal deleted inserted replaced
159:a0391cfdcef6 160:3b9be156e280
22 @Take // new coming host info 22 @Take // new coming host info
23 HostMessage newHost; 23 HostMessage newHost;
24 @Take 24 @Take
25 String MD5; 25 String MD5;
26 26
27 //@Peek 27 @Peek
28 //HashMap<String, LinkedList<HostMessage>> topology; 28 int _TOTALNODENUM;
29 29
30 public IncomingHosts() { 30 public IncomingHosts() {
31 31
32 } 32 }
33 33
44 44
45 absCookieTable.put(MD5, nodeName); 45 absCookieTable.put(MD5, nodeName);
46 getLocalDGM().put("absCookieTable", absCookieTable); 46 getLocalDGM().put("absCookieTable", absCookieTable);
47 47
48 getDGM(nodeName).put( "nodeName", nodeName); 48 getDGM(nodeName).put( "nodeName", nodeName);
49 getDGM(nodeName).put( "_TOTALNODENUM", _TOTALNODENUM);// use paxos
49 getDGM(nodeName).put("cookie", MD5); 50 getDGM(nodeName).put("cookie", MD5);
50 51
51 LinkedList<HostMessage> nodeInfoList = resultParse.get(nodeName); 52 LinkedList<HostMessage> nodeInfoList = resultParse.get(nodeName);
52 getDGM(nodeName).put("connectNodeNum",nodeInfoList.size()); 53 getDGM(nodeName).put("connectNodeNum",nodeInfoList.size());
53 for (HostMessage nodeInfo : nodeInfoList) { 54 for (HostMessage nodeInfo : nodeInfoList) {