Mercurial > hg > Database > Christie
diff src/main/java/christie/test/topology/localTestTopology/StartLocalTestTopology.java @ 69:251e306094d4
update localTestTopology
author | akahori |
---|---|
date | Sat, 01 Sep 2018 08:10:55 +0900 |
parents | src/main/java/christie/test/topology/localTestTopology/LocalTestTopology.java@597315102875 |
children | 32f6f9de97c1 |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/main/java/christie/test/topology/localTestTopology/StartLocalTestTopology.java Sat Sep 01 08:10:55 2018 +0900 @@ -0,0 +1,40 @@ +package christie.test.topology.localTestTopology; + + +import christie.codegear.CodeGearManager; +import christie.codegear.StartCodeGear; +import christie.topology.manager.StartTopologyManager; +import christie.topology.manager.TopologyManagerConfig; +import christie.topology.node.StartTopologyNode; +import christie.topology.node.TopologyNodeConfig; + +import java.util.LinkedList; + +public class StartLocalTestTopology extends StartCodeGear{ + + + public StartLocalTestTopology(CodeGearManager cgm) { + super(cgm); + } + + public static void main(String[] args) { + LinkedList<LocalTestTopologyConfig> configs = new LinkedList<LocalTestTopologyConfig>(); + configs.add(new LocalTestTopologyConfig(args, 10001, "node0")); + configs.add(new LocalTestTopologyConfig(args, 10002, "node1")); + configs.add(new LocalTestTopologyConfig(args, 10003, "node2")); + + TopologyManagerConfig topologyManagerConfig = new TopologyManagerConfig(new String[]{"--confFile", "/Users/e155753/Specialized_subject/kono/hg/Alice/Alice/scripts/ring.dot", "--showTime"}); + CodeGearManager topologyManagerCGM = createCGM(10000); + new StartTopologyManager(topologyManagerCGM, topologyManagerConfig); + + for (LocalTestTopologyConfig conf: configs ) { + CodeGearManager nodeCGM = createCGM(conf.connectPort); + String[] csarg = {"--host","localhost","--localKey",conf.key }; + TopologyNodeConfig cs = new TopologyNodeConfig(csarg); + + new StartTopologyNode(nodeCGM, cs, new LTRemoteIncrement(conf)); + } + topologyManagerCGM.setup(new StartLTCodeGear()); + } + +}