Mercurial > hg > Database > Christie
changeset 132:080c9bb8dcfb
fix test TreeTopo
author | akahori |
---|---|
date | Tue, 25 Dec 2018 15:18:35 +0900 |
parents | 5c608008c29a |
children | 114e0e5b6564 |
files | src/main/java/christie/test/topology/treeTestTopology/StartTreeTestTopology.java |
diffstat | 1 files changed, 4 insertions(+), 5 deletions(-) [+] |
line wrap: on
line diff
--- a/src/main/java/christie/test/topology/treeTestTopology/StartTreeTestTopology.java Tue Dec 25 15:18:01 2018 +0900 +++ b/src/main/java/christie/test/topology/treeTestTopology/StartTreeTestTopology.java Tue Dec 25 15:18:35 2018 +0900 @@ -17,19 +17,18 @@ public static void main(String[] args) { int topologyManagerPort = 10000; int topologyNodePort = 10001; - int nodeNum = 3; + 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++) { - CodeGearManager nodeCGM = createCGM(topologyNodePort + i); String[] nodeArg = { "--managerPort", String.valueOf(topologyManagerPort), - "--managerHost", "localhost"}; + "--managerHost", "localhost", + "--localPort", String.valueOf(topologyNodePort + i)}; TopologyNodeConfig cs = new TopologyNodeConfig(nodeArg); - new StartTopologyNode(nodeCGM, cs, new ChildCodeGear()); - nodeCGM.getLocalDGM().put("maxNodeNum", topologyManagerConfig.hasChild); + new StartTopologyNode(cs, new ChildCodeGear()).put("maxNodeNum", topologyManagerConfig.hasChild); } }