Mercurial > hg > Database > Alice

annotate src/main/java/alice/test/topology/localTestTopology/LocalTestTopology.java @ 646:3c060de44c2e

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
debug toplogy test
author Shinji KONO <kono@ie.u-ryukyu.ac.jp>
date Sun, 31 Dec 2017 12:06:45 +0900
parents cb16036404ba
children e321c5ec9b58
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
643
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
1 package alice.test.topology.localTestTopology;
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
2
646
3c060de44c2e debug toplogy test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 645
diff changeset
3 import alice.codesegment.CodeSegment;
643
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
4 import alice.daemon.AliceDaemon;
646
3c060de44c2e debug toplogy test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 645
diff changeset
5 import alice.datasegment.*;
643
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
6 import alice.topology.manager.StartTopologyManager;
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
7 import alice.topology.manager.TopologyManagerConfig;
645
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
8 import alice.topology.node.StartTopologyNode;
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
9 import alice.topology.node.TopologyNodeConfig;
643
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
10
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
11 import java.util.LinkedList;
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
12
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
13 public class LocalTestTopology {
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
14
645
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
15
643
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
16 public static void main(String[] args) {
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
17 LinkedList<LocalTestTopologyConfig> configs = new LinkedList<LocalTestTopologyConfig>();
645
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
18 int port = 10001;
643
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
19 configs.add(new LocalTestTopologyConfig(args, port++, "remote1"));
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
20 configs.add(new LocalTestTopologyConfig(args, port++, "remote2"));
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
21 configs.add(new LocalTestTopologyConfig(args, port++, "remote3"));
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
22
644
e0621f645e2e add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 643
diff changeset
23 TopologyManagerConfig topologyManagerConfig = new TopologyManagerConfig(args);
e0621f645e2e add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 643
diff changeset
24 new AliceDaemon(topologyManagerConfig).listen();
e0621f645e2e add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 643
diff changeset
25 new StartTopologyManager(topologyManagerConfig).execute();
643
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
26
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
27 for (LocalTestTopologyConfig conf: configs ) {
646
3c060de44c2e debug toplogy test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 645
diff changeset
28 new AliceDaemon(conf).listen();
3c060de44c2e debug toplogy test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 645
diff changeset
29 DataSegment.connect(conf.key,conf.key,"localhost",conf.localPort);
3c060de44c2e debug toplogy test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 645
diff changeset
30 String[] csarg = {"-port ", Integer.toString(topologyManagerConfig.localPort), "-host","localhost","-localKey",conf.key };
645
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
31 TopologyNodeConfig cs = new TopologyNodeConfig(csarg);
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
32 cs.setLocalKey(conf.key);
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
33 cs.setManagerKey("manager");
646
3c060de44c2e debug toplogy test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 645
diff changeset
34 new StartTopologyNode(cs, new LTRemoteIncrement(conf)).execute();
643
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
35 }
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
36 new LTopologyStartCodeSegment(configs).execute();
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
37 }
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
38
74dbb8809c73 add local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
39 }