view src/main/java/alice/test/topology/localTestTopology/LocalTestTopology.java @ 643:74dbb8809c73

add local topology test
author Shinji KONO <kono@ie.u-ryukyu.ac.jp>
date Sun, 31 Dec 2017 09:51:24 +0900
parents
children e0621f645e2e
line wrap: on
line source

package alice.test.topology.localTestTopology;

import alice.daemon.AliceDaemon;
import alice.datasegment.DataSegment;
import alice.topology.manager.StartTopologyManager;
import alice.topology.manager.TopologyManagerConfig;

import java.util.LinkedList;

public class LocalTestTopology {

    public static void main(String[] args) {
        LinkedList<LocalTestTopologyConfig> configs = new LinkedList<LocalTestTopologyConfig>();
        int port = 10000;
        configs.add(new LocalTestTopologyConfig(args, port++, "remote1"));
        configs.add(new LocalTestTopologyConfig(args, port++, "remote2"));
        configs.add(new LocalTestTopologyConfig(args, port++, "remote3"));

        TopologyManagerConfig topologyManagerConfigconf = new TopologyManagerConfig(args);
        new AliceDaemon(topologyManagerConfigconf).listen();
        new StartTopologyManager(topologyManagerConfigconf).execute();

        for (LocalTestTopologyConfig conf: configs ) {
            new AliceDaemon(conf).listen();
            DataSegment.connect(conf.key, "rev" + conf.key, conf.hostname, conf.connectPort);
        }
        new LTopologyStartCodeSegment(configs).execute();
    }

}