Mercurial > hg > Database > Christie

comparison src/test/java/christie/localTestTopology/localTestTopology.java @ 128:2886363f5e12

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
update put
author akahori
date Tue, 25 Dec 2018 15:13:59 +0900
parents
children
comparison
equal deleted inserted replaced
127:42f195de3152 128:2886363f5e12
1 package christie.localTestTopology;
2
3 import christie.test.topology.localTestTopology.LTRemoteIncrement;
4 import christie.topology.manager.StartTopologyManager;
5 import christie.topology.manager.TopologyManagerConfig;
6 import christie.topology.node.StartTopologyNode;
7 import christie.topology.node.TopologyNodeConfig;
8
9 public class localTestTopology {
10
11
12 public static void main(String[] args) {
13 /* Local Test */
14 int managerPort = 10000;
15 int nodeNum = 3;
16 String[] managerArg = {"--localPort", String.valueOf(managerPort), "--confFile", "scripts/ring.dot"};
17 TopologyManagerConfig topologyManagerConfig = new TopologyManagerConfig(managerArg);
18 new StartTopologyManager(topologyManagerConfig);
19
20
21 for (int i = 1; i<=nodeNum; i++) {
22
23 String[] nodeArg = {"--managerPort", String.valueOf(managerPort),
24 "--managerHost", "localhost",
25 "--localPort", String.valueOf(managerPort + i)};
26 /*try {
27 Thread.sleep(1000);
28 } catch (InterruptedException e) {
29 e.printStackTrace();
30 }*/
31 TopologyNodeConfig topologyNodeConfig = new TopologyNodeConfig(nodeArg);
32 StartTopologyNode startTopologyNode = new StartTopologyNode(topologyNodeConfig, new LTRemoteIncrement());
33 startTopologyNode.getLocalDGM().put("num", 0);
34
35 }
36
37
38 }
39
40 }