Mercurial > hg > Database > Alice
comparison 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 |
comparison
equal
deleted
inserted
replaced
642:cbfdcecf7e3c | 643:74dbb8809c73 |
---|---|
1 package alice.test.topology.localTestTopology; | |
2 | |
3 import alice.daemon.AliceDaemon; | |
4 import alice.datasegment.DataSegment; | |
5 import alice.topology.manager.StartTopologyManager; | |
6 import alice.topology.manager.TopologyManagerConfig; | |
7 | |
8 import java.util.LinkedList; | |
9 | |
10 public class LocalTestTopology { | |
11 | |
12 public static void main(String[] args) { | |
13 LinkedList<LocalTestTopologyConfig> configs = new LinkedList<LocalTestTopologyConfig>(); | |
14 int port = 10000; | |
15 configs.add(new LocalTestTopologyConfig(args, port++, "remote1")); | |
16 configs.add(new LocalTestTopologyConfig(args, port++, "remote2")); | |
17 configs.add(new LocalTestTopologyConfig(args, port++, "remote3")); | |
18 | |
19 TopologyManagerConfig topologyManagerConfigconf = new TopologyManagerConfig(args); | |
20 new AliceDaemon(topologyManagerConfigconf).listen(); | |
21 new StartTopologyManager(topologyManagerConfigconf).execute(); | |
22 | |
23 for (LocalTestTopologyConfig conf: configs ) { | |
24 new AliceDaemon(conf).listen(); | |
25 DataSegment.connect(conf.key, "rev" + conf.key, conf.hostname, conf.connectPort); | |
26 } | |
27 new LTopologyStartCodeSegment(configs).execute(); | |
28 } | |
29 | |
30 } |