Mercurial > hg > Database > Christie
view src/test/java/christie/localTestTopology/localTestTopology.java @ 133:114e0e5b6564
fix prepartoclose
author | akahori |
---|---|
date | Tue, 25 Dec 2018 17:10:49 +0900 |
parents | 2886363f5e12 |
children |
line wrap: on
line source
package christie.localTestTopology; import christie.test.topology.localTestTopology.LTRemoteIncrement; import christie.topology.manager.StartTopologyManager; import christie.topology.manager.TopologyManagerConfig; import christie.topology.node.StartTopologyNode; import christie.topology.node.TopologyNodeConfig; public class localTestTopology { public static void main(String[] args) { /* Local Test */ int managerPort = 10000; int nodeNum = 3; String[] managerArg = {"--localPort", String.valueOf(managerPort), "--confFile", "scripts/ring.dot"}; TopologyManagerConfig topologyManagerConfig = new TopologyManagerConfig(managerArg); new StartTopologyManager(topologyManagerConfig); for (int i = 1; i<=nodeNum; i++) { String[] nodeArg = {"--managerPort", String.valueOf(managerPort), "--managerHost", "localhost", "--localPort", String.valueOf(managerPort + i)}; /*try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); }*/ TopologyNodeConfig topologyNodeConfig = new TopologyNodeConfig(nodeArg); StartTopologyNode startTopologyNode = new StartTopologyNode(topologyNodeConfig, new LTRemoteIncrement()); startTopologyNode.getLocalDGM().put("num", 0); } } }