Mercurial > hg > Database > Christie

comparison src/main/java/christie/topology/manager/IncomingHosts.java @ 158:e295cb59e514

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
update refactor topology manager
author akahori
date Wed, 16 Jan 2019 18:57:04 +0900
parents 2e2d761ea806
children 3b9be156e280
comparison
equal deleted inserted replaced
157:7a2108775da7 158:e295cb59e514
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
28 //HashMap<String, LinkedList<HostMessage>> topology;
29
27 public IncomingHosts() { 30 public IncomingHosts() {
28 31
29 } 32 }
30 33
31 @Override 34 @Override
32 protected void run(CodeGearManager cgm) { 35 protected void run(CodeGearManager cgm) {
33 // not have or match cookie 36 // not have or match cookie
34 String nodeName = nodeNames.poll(); 37 String nodeName = nodeNames.poll();
35 getLocalDGM().put("nodeNames", nodeNames); 38 getLocalDGM().put("nodeNames", nodeNames);
36 39
37 String newHostName = newHost.getHostName();
38 int newHostPort = newHost.getPort();
39
40 // Manager connect to Node 40 // Manager connect to Node
41 cgm.createRemoteDGM(nodeName, newHostName, newHostPort); 41 cgm.createRemoteDGM(nodeName,
42 newHost.getHostName(),
43 newHost.getPort());
42 44
43 absCookieTable.put(MD5, nodeName); 45 absCookieTable.put(MD5, nodeName);
44 getLocalDGM().put("absCookieTable", absCookieTable); 46 getLocalDGM().put("absCookieTable", absCookieTable);
45 47
46 getDGM(nodeName).put( "nodeName", nodeName); 48 getDGM(nodeName).put( "nodeName", nodeName);
47 getDGM(nodeName).put("cookie", MD5); 49 getDGM(nodeName).put("cookie", MD5);
48 50
49 LinkedList<HostMessage> nodeInfoList = resultParse.get(nodeName); 51 LinkedList<HostMessage> nodeInfoList = resultParse.get(nodeName);
50 getDGM(nodeName).put("connectNodeNum", nodeInfoList.size()); 52 getDGM(nodeName).put("connectNodeNum",nodeInfoList.size());
51 for (HostMessage nodeInfo : nodeInfoList) { 53 for (HostMessage nodeInfo : nodeInfoList) {
52 nodeInfo.setHostAndPort(newHostName, newHostPort); 54
55 nodeInfo.setHostAndPort(newHost);
53 56
54 getLocalDGM().put("nodeInfo", nodeInfo); 57 getLocalDGM().put("nodeInfo", nodeInfo);
55 58 getDGM(nodeName).put("remoteNodeInfo", nodeInfo);
56 cgm.setup(new RecordTopology()); 59 cgm.setup(new RecordTopology());
57 } 60 }
58 getLocalDGM().put("resultParse", resultParse); 61 getLocalDGM().put("resultParse", resultParse);
59 62
60 cgm.setup(new IncomingHosts()); 63 cgm.setup(new IncomingHosts());