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

update put
author akahori
date Tue, 25 Dec 2018 15:13:59 +0900
parents
children
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/test/java/christie/localTestTopology/localTestTopology.java	Tue Dec 25 15:13:59 2018 +0900
@@ -0,0 +1,40 @@
+package christie.localTestTopology;
+
+import christie.test.topology.localTestTopology.LTRemoteIncrement;
+import christie.topology.manager.StartTopologyManager;
+import christie.topology.manager.TopologyManagerConfig;
+import christie.topology.node.StartTopologyNode;
+import christie.topology.node.TopologyNodeConfig;
+
+public class localTestTopology {
+
+
+    public static void main(String[] args) {
+        /* Local Test */
+        int managerPort = 10000;
+        int nodeNum = 3;
+        String[] managerArg = {"--localPort", String.valueOf(managerPort), "--confFile", "scripts/ring.dot"};
+        TopologyManagerConfig topologyManagerConfig = new TopologyManagerConfig(managerArg);
+        new StartTopologyManager(topologyManagerConfig);
+
+
+        for (int i = 1; i<=nodeNum; i++) {
+
+            String[] nodeArg = {"--managerPort", String.valueOf(managerPort),
+                    "--managerHost", "localhost",
+                    "--localPort", String.valueOf(managerPort + i)};
+            /*try {
+                Thread.sleep(1000);
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }*/
+            TopologyNodeConfig topologyNodeConfig = new TopologyNodeConfig(nodeArg);
+            StartTopologyNode startTopologyNode = new StartTopologyNode(topologyNodeConfig, new LTRemoteIncrement());
+            startTopologyNode.getLocalDGM().put("num", 0);
+
+        }
+
+
+    }
+
+}