Mercurial > hg > Database > Christie

comparison src/main/java/christie/test/topology/localTestTopology/StartLocalTestTopology.java @ 79:0a724c973fc9

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fix conffile
author akahori
date Wed, 05 Sep 2018 10:47:04 +0900
parents 32f6f9de97c1
children 1e66fd626aff
comparison
equal deleted inserted replaced
78:046b8bfc7100 79:0a724c973fc9
20 public static void main(String[] args) { 20 public static void main(String[] args) {
21 LinkedList<LocalTestTopologyConfig> configs = new LinkedList<LocalTestTopologyConfig>(); 21 LinkedList<LocalTestTopologyConfig> configs = new LinkedList<LocalTestTopologyConfig>();
22 configs.add(new LocalTestTopologyConfig(args, 10001, "node0")); 22 configs.add(new LocalTestTopologyConfig(args, 10001, "node0"));
23 configs.add(new LocalTestTopologyConfig(args, 10002, "node1")); 23 configs.add(new LocalTestTopologyConfig(args, 10002, "node1"));
24 configs.add(new LocalTestTopologyConfig(args, 10003, "node2")); 24 configs.add(new LocalTestTopologyConfig(args, 10003, "node2"));
25 25 String[] managerArg = {"--localPort", String.valueOf(10000), "--confFile", "scripts/ring.dot", "--showTime"};
26 TopologyManagerConfig topologyManagerConfig = new TopologyManagerConfig(new String[]{"--confFile", "scripts/ring.dot", "--showTime"}); 26 TopologyManagerConfig topologyManagerConfig = new TopologyManagerConfig(managerArg);
27 CodeGearManager topologyManagerCGM = createCGM(10000); 27 CodeGearManager topologyManagerCGM = createCGM(topologyManagerConfig.localPort);
28 new StartTopologyManager(topologyManagerCGM, topologyManagerConfig); 28 new StartTopologyManager(topologyManagerCGM, topologyManagerConfig);
29 29
30 for (LocalTestTopologyConfig conf: configs ) { 30 for (LocalTestTopologyConfig conf: configs ) {
31 CodeGearManager nodeCGM = createCGM(conf.connectPort); 31 CodeGearManager nodeCGM = createCGM(conf.localPort);
32 String[] csarg = {"--host","localhost","--localKey",conf.key }; 32 String[] nodeArg = {"--localKey",conf.key,
33 TopologyNodeConfig cs = new TopologyNodeConfig(csarg); 33 "--managerPort", String.valueOf(topologyManagerConfig.localPort),
34 "--managerHost", "localhost"};
35 TopologyNodeConfig cs = new TopologyNodeConfig(nodeArg);
34 36
35 new StartTopologyNode(nodeCGM, cs, new LTRemoteIncrement(conf)); 37 new StartTopologyNode(nodeCGM, cs, new LTRemoteIncrement(conf));
36 } 38 }
37 topologyManagerCGM.setup(new StartLTCodeGear()); 39 topologyManagerCGM.setup(new StartLTCodeGear());
38 } 40 }