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

fix TopologyNode connect
author KaitoMaeshiro <aosskaito@cr.ie.u-ryukyu.ac.jp>
date Sun, 06 Feb 2022 16:47:41 +0900
parents 312de6b900bc
children
line wrap: on
line source

using System;
using System.Threading;
using Christie_net.codegear;
using Christie_net.topology.manager;
using Christie_net.topology.node;


namespace Christie_net.Test.Topology.LocalTestTopology
{
    public class StartLocalTestTopology : StartCodeGear
    {
        public StartLocalTestTopology(CodeGearManager cgm) : base(cgm) { }

        public static void Main(String[] args)
        {
            int managerPort = 10000;
            int nodeNum = 3;
            String[] managerArg = {"--localPort", managerPort.ToString(), "--confFile", "scripts/ring.dot"};
            TopologyManagerConfig topologyManagerConfig = new TopologyManagerConfig(managerArg);
            new StartTopologyManager(topologyManagerConfig);
            CodeGearManager nodeCGM = null;
            for (int i = 1; i<=nodeNum; i++) {
                nodeCGM = CreateCgm(managerPort + i);
                String[] nodeArg = {"--managerPort", managerPort.ToString(),
                    "--managerHost", "localhost"};
                TopologyNodeConfig cs  = new TopologyNodeConfig(nodeArg);

                new StartTopologyNode(nodeCGM, cs, new LTRemoteIncrement());

            }
            nodeCGM.GetLocalDGM().Put("num", 0);
            
            Thread.Sleep(10000);
            Console.WriteLine("TopologyManager done");
        }
    }
}