view 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 source

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

        }


    }

}