Mercurial > hg > Database > Christie
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);*/ }