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);


    }

}