# HG changeset patch # User Shinji KONO # Date 1514681999 -32400 # Node ID e0621f645e2e0b6458dec9fa82ae5d22d6646fc2 # Parent 74dbb8809c737ee20e19604d256fb535236d1b2f add local topology test diff -r 74dbb8809c73 -r e0621f645e2e src/main/java/alice/test/topology/localTestTopology/LocalTestTopology.java --- a/src/main/java/alice/test/topology/localTestTopology/LocalTestTopology.java Sun Dec 31 09:51:24 2017 +0900 +++ b/src/main/java/alice/test/topology/localTestTopology/LocalTestTopology.java Sun Dec 31 09:59:59 2017 +0900 @@ -12,17 +12,18 @@ public static void main(String[] args) { LinkedList configs = new LinkedList(); int port = 10000; + int toplogyManagerPort = port++; configs.add(new LocalTestTopologyConfig(args, port++, "remote1")); configs.add(new LocalTestTopologyConfig(args, port++, "remote2")); configs.add(new LocalTestTopologyConfig(args, port++, "remote3")); - TopologyManagerConfig topologyManagerConfigconf = new TopologyManagerConfig(args); - new AliceDaemon(topologyManagerConfigconf).listen(); - new StartTopologyManager(topologyManagerConfigconf).execute(); + TopologyManagerConfig topologyManagerConfig = new TopologyManagerConfig(args); + new AliceDaemon(topologyManagerConfig).listen(); + new StartTopologyManager(topologyManagerConfig).execute(); for (LocalTestTopologyConfig conf: configs ) { new AliceDaemon(conf).listen(); - DataSegment.connect(conf.key, "rev" + conf.key, conf.hostname, conf.connectPort); + DataSegment.connect(conf.key, "rev" + conf.key, conf.hostname, toplogyManagerPort); } new LTopologyStartCodeSegment(configs).execute(); } diff -r 74dbb8809c73 -r e0621f645e2e src/main/java/alice/test/topology/localTestTopology/LocalTestTopologyConfig.java --- a/src/main/java/alice/test/topology/localTestTopology/LocalTestTopologyConfig.java Sun Dec 31 09:51:24 2017 +0900 +++ b/src/main/java/alice/test/topology/localTestTopology/LocalTestTopologyConfig.java Sun Dec 31 09:59:59 2017 +0900 @@ -12,6 +12,7 @@ super(args); hostname = "127.0.0.1"; connectPort = port; + localPort = port; key = dsmName; }