Mercurial > hg > Database > Christie
view src/main/java/christie/topology/node/PrepareToClose.java @ 96:bf6ab64325f9
add Constoractor
author | akahori |
---|---|
date | Mon, 17 Sep 2018 11:20:26 +0900 |
parents | 76b6da075ce0 |
children | 42f195de3152 |
line wrap: on
line source
package christie.topology.node; import christie.annotation.Peek; import christie.annotation.Take; import christie.codegear.CodeGear; import christie.codegear.CodeGearManager; import java.util.List; public class PrepareToClose extends CodeGear { @Peek String _CLOSEMESSEAGE; @Peek List<String> _CLIST; public PrepareToClose() { } @Override protected void run(CodeGearManager cgm) { /* if (_CLIST.contains(_CLOSEMESSEAGE)) { _CLIST.remove(_CLOSEMESSEAGE); DataSegmentManager manager = DataSegment.get(_CLOSEMESSEAGE); manager.setSendError(false); ods.put(_CLOSEMESSEAGE, "_CLOSEREADY", _CLOSEMESSEAGE); ods.put("_CLOSEREADY", _CLOSEMESSEAGE); new CloseRemoteDataSegment(); } else { // lost node is this node's parent, so already removed new ReceiveCloseMessage(CommandType.TAKE); }*/ cgm.setup(new PrepareToClose()); //getLocalDGM().put("_CLIST", _CLIST); } }