Mercurial > hg > Database > Christie
view src/main/java/christie/test/topology/treeTestTopology/StartTreeTestTopology.java @ 203:720f7014d871
add PrefixTree
author | ichikitakahiro <e165713@ie.u-ryukyu.ac.jp> |
---|---|
date | Sun, 10 Mar 2019 23:42:41 +0900 |
parents | 080c9bb8dcfb |
children | 8ba56d64865f |
line wrap: on
line source
package christie.test.topology.treeTestTopology; 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; public class StartTreeTestTopology extends StartCodeGear { public StartTreeTestTopology(CodeGearManager cgm) { super(cgm); } public static void main(String[] args) { int topologyManagerPort = 10000; int topologyNodePort = 10001; int nodeNum = 3; // 4以上にしたらtopologymanagerがfinishするので動かないけど...どうしよう. String[] managerArg = {"--localPort", String.valueOf(topologyManagerPort), "--Topology", "tree"}; TopologyManagerConfig topologyManagerConfig = new TopologyManagerConfig(managerArg); new StartTopologyManager(topologyManagerConfig); for (int i = 0; i < nodeNum; i++) { String[] nodeArg = { "--managerPort", String.valueOf(topologyManagerPort), "--managerHost", "localhost", "--localPort", String.valueOf(topologyNodePort + i)}; TopologyNodeConfig cs = new TopologyNodeConfig(nodeArg); new StartTopologyNode(cs, new ChildCodeGear()).put("maxNodeNum", topologyManagerConfig.hasChild); } } }