Mercurial > hg > Database > Christie

changeset 217:5647450a26ca

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
update PrefixTree
author ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
date Fri, 15 Mar 2019 17:55:35 +0900
parents 437f06e034b8
children 30f3525e8b15
files src/test/java/christie/example/PrefixTree/CountMessage.java src/test/java/christie/example/PrefixTree/sendOrDisplay.java
diffstat 2 files changed, 7 insertions(+), 1 deletions(-) [+]
line wrap: on
line diff
--- a/src/test/java/christie/example/PrefixTree/CountMessage.java	Mon Mar 11 22:21:23 2019 +0900
+++ b/src/test/java/christie/example/PrefixTree/CountMessage.java	Fri Mar 15 17:55:35 2019 +0900
@@ -27,7 +27,6 @@
             System.out.print("success");
              for(String nodeName : topoDG.getConnectionList()) {
                 put(nodeName, "start", new Message());
-                //child0,1へのメッセージ送信はできてる。
             }
 
             cgm.setup(new CountCalculate());
--- a/src/test/java/christie/example/PrefixTree/sendOrDisplay.java	Mon Mar 11 22:21:23 2019 +0900
+++ b/src/test/java/christie/example/PrefixTree/sendOrDisplay.java	Fri Mar 15 17:55:35 2019 +0900
@@ -4,7 +4,9 @@
 import christie.annotation.Take;
 import christie.codegear.CodeGear;
 import christie.codegear.CodeGearManager;
+import christie.topology.Message;
 import christie.topology.TopologyDataGear;
+import christie.topology.node.TopologyNodeConfig;
 
 public class sendOrDisplay extends CodeGear {
     @Take
@@ -13,12 +15,17 @@
     @Peek
     TopologyDataGear topoDG;
 
+    @Peek
+    TopologyNodeConfig topologyNodeConfig;
+
     @Override
     protected void run(CodeGearManager cgm) {
          if(topoDG.getConnectionList().contains("parent")){
             put("parent", "pushedNum", num);
         }else{
             System.out.println("total:" + num);
+
+             getDGM(topologyNodeConfig.getManagerKey()).put("FINISHMESSAGE", new Message());
         }
     }
 }