Mercurial > hg > Database > Christie

comparison src/main/java/christie/topology/node/PrepareToClose.java @ 133:114e0e5b6564

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fix prepartoclose
author akahori
date Tue, 25 Dec 2018 17:10:49 +0900
parents 2e2d761ea806
children e295cb59e514
comparison
equal deleted inserted replaced
132:080c9bb8dcfb 133:114e0e5b6564
10 import java.util.List; 10 import java.util.List;
11 11
12 public class PrepareToClose extends CodeGear { 12 public class PrepareToClose extends CodeGear {
13 13
14 @Take 14 @Take
15 String _CLOSEMESSAGE; 15 String _CLOSEMESSEAGE;
16 16
17 @Peek 17 @Take
18 List<String> _CLIST; 18 List<String> _CLIST;
19 19
20 @Peek 20 @Peek
21 TopologyNodeConfig topologyNodeConfig; 21 TopologyNodeConfig topologyNodeConfig;
22 22
25 25
26 } 26 }
27 27
28 @Override 28 @Override
29 protected void run(CodeGearManager cgm) { 29 protected void run(CodeGearManager cgm) {
30
30 for(String dgmName: _CLIST){ 31 for(String dgmName: _CLIST){
31 getDGM(dgmName).shutdown(); 32 getDGM(dgmName).shutdown();
32 33 //_CLIST.remove(dgmName);
33 } 34 }
34 35
35 if(_CLIST.isEmpty()) { 36 getLocalDGM().finish();
36 getLocalDGM().finish();
37 }
38 37
39 /*if (_CLIST.contains(_CLOSEMESSEAGE)) { 38 /*if (_CLIST.contains(_CLOSEMESSEAGE)) {
40 _CLIST.remove(_CLOSEMESSEAGE); 39 _CLIST.remove(_CLOSEMESSEAGE);
41 40
42 getDGM(_CLOSEMESSEAGE).setSendError(false); 41 getDGM(_CLOSEMESSEAGE).setSendError(false);