diff src/main/java/christie/topology/node/PrepareToClose.java @ 127:42f195de3152

fix topologyManager
author akahori
date Tue, 18 Dec 2018 15:14:45 +0900
parents 76b6da075ce0
children 2e2d761ea806
line wrap: on
line diff
--- a/src/main/java/christie/topology/node/PrepareToClose.java	Tue Dec 18 15:12:45 2018 +0900
+++ b/src/main/java/christie/topology/node/PrepareToClose.java	Tue Dec 18 15:14:45 2018 +0900
@@ -5,6 +5,7 @@
 import christie.annotation.Take;
 import christie.codegear.CodeGear;
 import christie.codegear.CodeGearManager;
+import christie.datagear.DataGearManager;
 
 import java.util.List;
 
@@ -16,6 +17,9 @@
     @Peek
     List<String> _CLIST;
 
+    @Peek
+    TopologyNodeConfig topologyNodeConfig;
+
 
     public PrepareToClose() {
 
@@ -23,23 +27,25 @@
 
     @Override
     protected void run(CodeGearManager cgm) {
-        /*
-        if (_CLIST.contains(_CLOSEMESSEAGE)) {
+        for(String dgmName: _CLIST){
+            getDGM(dgmName).shutdown();
+        }
+
+        getLocalDGM().finish();
+
+        /*if (_CLIST.contains(_CLOSEMESSEAGE)) {
             _CLIST.remove(_CLOSEMESSEAGE);
 
-            DataSegmentManager manager = DataSegment.get(_CLOSEMESSEAGE);
-            manager.setSendError(false);
-
-            ods.put(_CLOSEMESSEAGE, "_CLOSEREADY", _CLOSEMESSEAGE);
-            ods.put("_CLOSEREADY", _CLOSEMESSEAGE);
+            getDGM(_CLOSEMESSEAGE).setSendError(false);
+            getDGM(_CLOSEMESSEAGE).close();
 
-            new CloseRemoteDataSegment();
-        } else {
-            // lost node is this node's parent, so already removed
-            new ReceiveCloseMessage(CommandType.TAKE);
-        }*/
+            getDGM(_CLOSEMESSEAGE).put("_CLOSEREADY", _CLOSEMESSEAGE);
+            getLocalDGM().put("_CLOSEREADY", _CLOSEMESSEAGE);
+
+            cgm.setup(new CloseRemoteDataGear());
+        }
         cgm.setup(new PrepareToClose());
-        //getLocalDGM().put("_CLIST", _CLIST);
+        getLocalDGM().put("_CLIST", _CLIST);*/
 
     }