Mercurial > hg > Database > Christie-sharp

annotate Test/Topology/LocalTestTopology/StartLocalTestTopology.cs @ 71:1169915705ab default tip

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fix TopologyNode connect
author KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
date Sun, 06 Feb 2022 16:47:41 +0900
parents 312de6b900bc
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
66
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
1 using System;
71
1169915705ab fix TopologyNode connect
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents: 66
diff changeset
2 using System.Threading;
66
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
3 using Christie_net.codegear;
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
4 using Christie_net.topology.manager;
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
5 using Christie_net.topology.node;
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
6
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
7
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
8 namespace Christie_net.Test.Topology.LocalTestTopology
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
9 {
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
10 public class StartLocalTestTopology : StartCodeGear
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
11 {
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
12 public StartLocalTestTopology(CodeGearManager cgm) : base(cgm) { }
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
13
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
14 public static void Main(String[] args)
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
15 {
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
16 int managerPort = 10000;
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
17 int nodeNum = 3;
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
18 String[] managerArg = {"--localPort", managerPort.ToString(), "--confFile", "scripts/ring.dot"};
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
19 TopologyManagerConfig topologyManagerConfig = new TopologyManagerConfig(managerArg);
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
20 new StartTopologyManager(topologyManagerConfig);
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
21 CodeGearManager nodeCGM = null;
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
22 for (int i = 1; i<=nodeNum; i++) {
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
23 nodeCGM = CreateCgm(managerPort + i);
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
24 String[] nodeArg = {"--managerPort", managerPort.ToString(),
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
25 "--managerHost", "localhost"};
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
26 TopologyNodeConfig cs = new TopologyNodeConfig(nodeArg);
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
27
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
28 new StartTopologyNode(nodeCGM, cs, new LTRemoteIncrement());
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
29
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
30 }
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
31 nodeCGM.GetLocalDGM().Put("num", 0);
71
1169915705ab fix TopologyNode connect
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents: 66
diff changeset
32
1169915705ab fix TopologyNode connect
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents: 66
diff changeset
33 Thread.Sleep(10000);
1169915705ab fix TopologyNode connect
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents: 66
diff changeset
34 Console.WriteLine("TopologyManager done");
66
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
35 }
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
36 }
312de6b900bc fix TopologyManager
KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
37 }