Mercurial > hg > Database > Christie
diff src/test/java/christie/localTestTopology/localTestTopology.java @ 128:2886363f5e12
update put
author | akahori |
---|---|
date | Tue, 25 Dec 2018 15:13:59 +0900 |
parents | |
children |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/test/java/christie/localTestTopology/localTestTopology.java Tue Dec 25 15:13:59 2018 +0900 @@ -0,0 +1,40 @@ +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); + + } + + + } + +}