annotate src/main/java/christie/test/ring/FlipCodeGear.java @ 89:2c22b23fa725

update refactor
author akahori
date Sat, 15 Sep 2018 10:34:04 +0900
parents 6660ebba441e
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
35
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
1 package christie.test.ring;
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
2
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
3 import christie.annotation.Peek;
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
4 import christie.annotation.Take;
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
5 import christie.codegear.CodeGear;
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
6 import christie.codegear.CodeGearManager;
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
7
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
8 public class FlipCodeGear extends CodeGear{
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
9 @Take
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
10 int count;
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
11
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
12 @Take
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
13 long timestamp;
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
14
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
15 @Peek
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
16 String hostname;
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
17
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
18 @Take
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
19 boolean start;
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
20
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
21 @Override
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
22 protected void run(CodeGearManager cgm) {
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
23 System.out.println(hostname + " : count " + count);
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
24 if (count == 5) {
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
25 System.out.println(System.currentTimeMillis() - timestamp);
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
26 } else {
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
27 getDGM("remote").put("data", timestamp);
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
28 if (hostname.equals("node0")) {
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
29 getDGM("remote").put("count", ++count);
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
30 } else {
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
31 getDGM("remote").put("count", count);
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
32 }
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
33 }
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
34 cgm.setup(new FlipCodeGear());
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
35 getLocalDGM().put("start", start);
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
36 }
6660ebba441e add ring test but not working
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
37 }