Mercurial > hg > Database > Christie
annotate src/test/java/christie/example/PrefixTree/CountMessage.java @ 202:d0d1e5a9c39d
add PrefixTree
author | ichikitakahiro <e165713@ie.u-ryukyu.ac.jp> |
---|---|
date | Sun, 10 Mar 2019 22:55:21 +0900 |
parents | d15467cd08cc |
children | 437f06e034b8 |
rev | line source |
---|---|
201
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
1 package christie.example.PrefixTree; |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
2 |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
3 import christie.annotation.Peek; |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
4 import christie.annotation.Take; |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
5 import christie.codegear.CodeGear; |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
6 import christie.codegear.CodeGearManager; |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
7 import christie.topology.Message; |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
8 import christie.topology.TopologyDataGear; |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
9 |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
10 public class CountMessage extends CodeGear { |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
11 @Take |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
12 Message ack; |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
13 |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
14 @Peek |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
15 int totalNodeNum; |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
16 |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
17 @Peek |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
18 TopologyDataGear topoDG; |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
19 |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
20 @Take |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
21 int count; |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
22 |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
23 @Override |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
24 protected void run(CodeGearManager cgm) { |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
25 count ++; |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
26 if(count == totalNodeNum){ |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
27 System.out.print("success"); |
202 | 28 for(String nodeName : topoDG.getConnectionList()) { |
201
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
29 put(nodeName, "start", new Message()); |
202 | 30 System.out.println(nodeName); |
201
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
31 } |
202 | 32 |
33 cgm.setup(new CountCalculate()); | |
201
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
34 }else{ |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
35 cgm.setup(new CountMessage()); |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
36 put("count",count); |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
37 } |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
38 |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
39 } |
d15467cd08cc
add example PrefixTree
ichikitakahiro <e165713@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
40 } |