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());
     }
 }