Mercurial > hg > Database > Alice
view src/main/java/alice/test/topology/localTestTopology/LocalTestTopology.java @ 644:e0621f645e2e
add local topology test
author | Shinji KONO <kono@ie.u-ryukyu.ac.jp> |
---|---|
date | Sun, 31 Dec 2017 09:59:59 +0900 |
parents | 74dbb8809c73 |
children | cb16036404ba |
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; int toplogyManagerPort = port++; configs.add(new LocalTestTopologyConfig(args, port++, "remote1")); configs.add(new LocalTestTopologyConfig(args, port++, "remote2")); configs.add(new LocalTestTopologyConfig(args, port++, "remote3")); TopologyManagerConfig topologyManagerConfig = new TopologyManagerConfig(args); new AliceDaemon(topologyManagerConfig).listen(); new StartTopologyManager(topologyManagerConfig).execute(); for (LocalTestTopologyConfig conf: configs ) { new AliceDaemon(conf).listen(); DataSegment.connect(conf.key, "rev" + conf.key, conf.hostname, toplogyManagerPort); } new LTopologyStartCodeSegment(configs).execute(); } }