Mercurial > hg > Database > Christie
view src/main/java/christie/test/topology/localTestTopology/StartLocalTestTopology.java @ 272:b592fe1d4a4e default tip
create example Attendance
author | matac42 <matac@cr.ie.u-ryukyu.ac.jp> |
---|---|
date | Thu, 01 Jul 2021 20:41:07 +0900 |
parents | d92f0bbad1eb |
children |
line wrap: on
line source
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; public class StartLocalTestTopology extends StartCodeGear{ public StartLocalTestTopology(CodeGearManager cgm) { super(cgm); } 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); CodeGearManager nodeCGM = null; for (int i = 1; i<=nodeNum; i++) { nodeCGM = createCGM(managerPort + i); String[] nodeArg = {"--managerPort", String.valueOf(managerPort), "--managerHost", "localhost"}; TopologyNodeConfig cs = new TopologyNodeConfig(nodeArg); new StartTopologyNode(nodeCGM, cs, new LTRemoteIncrement()); } nodeCGM.getLocalDGM().put("num", 0); } }