# HG changeset patch # User akahori # Date 1545718439 -32400 # Node ID 2886363f5e12978f5300a75bed05f786847055fe # Parent 42f195de3152c9efaa25d53d5bad8ddb73b0532c update put diff -r 42f195de3152 -r 2886363f5e12 src/main/java/christie/codegear/CodeGear.java --- a/src/main/java/christie/codegear/CodeGear.java Tue Dec 18 15:14:45 2018 +0900 +++ b/src/main/java/christie/codegear/CodeGear.java Tue Dec 25 15:13:59 2018 +0900 @@ -66,12 +66,15 @@ return cgm.getDGM(dgmName); } - public void put(String dgmName, String key, Object data){ + public CodeGear put(String dgmName, String key, Object data){ getDGM(dgmName).put(key, data); + return this; } - public void put(String key, Object value){ + public CodeGear put(String key, Object value){ + localDGM.put(key, value); + return this; } public Boolean containsDGM(String dgmName){ return cgm.containsDGM(dgmName);} diff -r 42f195de3152 -r 2886363f5e12 src/test/java/christie/localTestTopology/localTestTopology.java --- /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); + + } + + + } + +}