Mercurial > hg > Database > Christie
diff src/main/java/christie/topology/node/ConfigurationFinish.java @ 117:53e31b403815
fix topologyManager
author | akahori |
---|---|
date | Thu, 06 Dec 2018 23:07:26 +0900 |
parents | 2c22b23fa725 |
children | d92f0bbad1eb |
line wrap: on
line diff
--- a/src/main/java/christie/topology/node/ConfigurationFinish.java Thu Dec 06 02:42:10 2018 +0900 +++ b/src/main/java/christie/topology/node/ConfigurationFinish.java Thu Dec 06 23:07:26 2018 +0900 @@ -1,12 +1,16 @@ package christie.topology.node; import christie.annotation.Peek; +import christie.annotation.Take; import christie.codegear.CodeGear; import christie.codegear.CodeGearManager; public class ConfigurationFinish extends CodeGear { - @Peek + @Take + String reverseNodeName; + + @Take int reverseCount; @Peek @@ -20,6 +24,8 @@ @Override protected void run(CodeGearManager cgm) { + reverseCount++; + System.out.println(reverseCount + " " + connectNodeNum); if (reverseCount == connectNodeNum) { getDGM(topologyNodeConfig.getManagerKey()).put("nodePrepareDone", "done"); cgm.setup(new Start()); @@ -30,9 +36,10 @@ cgm.setup(new PrepareToClose()); ClosedEventManager.getInstance().register(DeleteConnection.class); ClosedEventManager.getInstance().setKey();*/ - return; + + }else { + getLocalDGM().put("reverseCount", reverseCount); + cgm.setup(new ConfigurationFinish()); } - - cgm.setup(new ConfigurationFinish()); } }