Mercurial > hg > Database > Christie

comparison src/main/java/christie/topology/manager/TopologyManager.java @ 118:daf37151dd97

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
refactor constract StartTopologyManage and StartTopologyNode
author akahori
date Fri, 07 Dec 2018 23:29:18 +0900
parents 3ae54e59ed68
children e295cb59e514
comparison
equal deleted inserted replaced
117:53e31b403815 118:daf37151dd97
22 cgm.setup(new CheckComingHost()); 22 cgm.setup(new CheckComingHost());
23 getLocalDGM().put("absCookieTable", new HashMap<String, String>()); 23 getLocalDGM().put("absCookieTable", new HashMap<String, String>());
24 24
25 if(topologyManagerConfig.dynamic) { 25 if(topologyManagerConfig.dynamic) {
26 getLocalDGM().put("running", true); 26 getLocalDGM().put("running", true);
27 getLocalDGM().put("start", "start");
27 28
28 if (topologyManagerConfig.type == TopologyType.Tree) { 29 if (topologyManagerConfig.type == TopologyType.Tree) {
29 getLocalDGM().put("parentManager", new ParentManager(topologyManagerConfig.hasChild)); 30 getLocalDGM().put("parentManager", new ParentManager(topologyManagerConfig.hasChild));
30 getLocalDGM().put("nameTable", new HashMap<String, HostMessage>()); 31 getLocalDGM().put("nameTable", new HashMap<String, HostMessage>());
31 getLocalDGM().put("hostCount", 0); 32 getLocalDGM().put("hostCount", 0);
32
33 cgm.setup(new CreateTreeTopology()); 33 cgm.setup(new CreateTreeTopology());
34 //cgm.setup(new ReceiveDisconnectMessage()); 34 //cgm.setup(new ReceiveDisconnectMessage());
35 } 35 }
36 36
37 }else{ 37 }else{
45 cgm.setup(new CreateHash()); 45 cgm.setup(new CreateHash());
46 cgm.setup(new TopologyFinish()); 46 cgm.setup(new TopologyFinish());
47 47
48 getLocalDGM().put("topology", new HashMap<String, HashMap<String, HostMessage>>()); 48 getLocalDGM().put("topology", new HashMap<String, HashMap<String, HostMessage>>());
49 getLocalDGM().put("createdList", new LinkedList<String>()); 49 getLocalDGM().put("createdList", new LinkedList<String>());
50
51 } 50 }
52 51
53 52
54 } 53 }