Mercurial > hg > Database > Christie
view src/test/java/christie/example/PrefixTree/CountMessage.java @ 217:5647450a26ca
update PrefixTree
author | ichikitakahiro <e165713@ie.u-ryukyu.ac.jp> |
---|---|
date | Fri, 15 Mar 2019 17:55:35 +0900 |
parents | 437f06e034b8 |
children |
line wrap: on
line source
package christie.example.PrefixTree; import christie.annotation.Peek; import christie.annotation.Take; import christie.codegear.CodeGear; import christie.codegear.CodeGearManager; import christie.topology.Message; import christie.topology.TopologyDataGear; public class CountMessage extends CodeGear { @Take Message ack; @Peek int totalNodeNum; @Peek TopologyDataGear topoDG; @Take int count; @Override protected void run(CodeGearManager cgm) { count ++; if(count == totalNodeNum){ System.out.print("success"); for(String nodeName : topoDG.getConnectionList()) { put(nodeName, "start", new Message()); } cgm.setup(new CountCalculate()); }else{ cgm.setup(new CountMessage()); put("count",count); } } }