Mercurial > hg > Database > Alice

annotate src/alice/test/topology/aquarium/CheckLocalIndex.java @ 303:6e0a909b4b12

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
add PingScheduler
author sugi
date Tue, 19 Nov 2013 14:04:57 +0900
parents 84b7eac2ff7d
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
134
53aff28cde6b change package
sugi
parents: 109
diff changeset
1 package alice.test.topology.aquarium;
109
96674c803853 set background
sugi
parents:
diff changeset
2
259
ccce30f84380 use "_CLIST" Key
sugi
parents: 217
diff changeset
3 import java.util.List;
ccce30f84380 use "_CLIST" Key
sugi
parents: 217
diff changeset
4
109
96674c803853 set background
sugi
parents:
diff changeset
5 import alice.codesegment.CodeSegment;
96674c803853 set background
sugi
parents:
diff changeset
6 import alice.datasegment.CommandType;
96674c803853 set background
sugi
parents:
diff changeset
7 import alice.datasegment.Receiver;
96674c803853 set background
sugi
parents:
diff changeset
8
96674c803853 set background
sugi
parents:
diff changeset
9 public class CheckLocalIndex extends CodeSegment {
96674c803853 set background
sugi
parents:
diff changeset
10
96674c803853 set background
sugi
parents:
diff changeset
11 private Receiver data = ids.create(CommandType.PEEK);
138
87f1a30a8c82 change range automatic
sugi
parents: 134
diff changeset
12 private Receiver list = ids.create(CommandType.PEEK);
109
96674c803853 set background
sugi
parents:
diff changeset
13
96674c803853 set background
sugi
parents:
diff changeset
14 public CheckLocalIndex(String key, int index){
259
ccce30f84380 use "_CLIST" Key
sugi
parents: 217
diff changeset
15 this.list.setKey("_CLIST");
217
b5c642ba998e change as** method and remove "local" key in TEST
sugi
parents: 216
diff changeset
16 this.data.setKey(key, index);
109
96674c803853 set background
sugi
parents:
diff changeset
17 }
96674c803853 set background
sugi
parents:
diff changeset
18
96674c803853 set background
sugi
parents:
diff changeset
19 @Override
96674c803853 set background
sugi
parents:
diff changeset
20 public void run() {
259
ccce30f84380 use "_CLIST" Key
sugi
parents: 217
diff changeset
21 @SuppressWarnings("unchecked")
ccce30f84380 use "_CLIST" Key
sugi
parents: 217
diff changeset
22 List<String> r = list.asClass(List.class);
290
4074077d118d Refactor iterating process with for-each sentence.
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 259
diff changeset
23 for (String node : r) {
4074077d118d Refactor iterating process with for-each sentence.
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 259
diff changeset
24 if (!node.equals(data.from)) {
303
6e0a909b4b12 add PingScheduler
sugi
parents: 294
diff changeset
25 System.out.println(data.from);
259
ccce30f84380 use "_CLIST" Key
sugi
parents: 217
diff changeset
26 ods.update(node, data.key, data.getVal());
138
87f1a30a8c82 change range automatic
sugi
parents: 134
diff changeset
27 }
87f1a30a8c82 change range automatic
sugi
parents: 134
diff changeset
28 }
259
ccce30f84380 use "_CLIST" Key
sugi
parents: 217
diff changeset
29 new CheckLocalIndex(data.key, data.index);
109
96674c803853 set background
sugi
parents:
diff changeset
30
96674c803853 set background
sugi
parents:
diff changeset
31 }
96674c803853 set background
sugi
parents:
diff changeset
32
96674c803853 set background
sugi
parents:
diff changeset
33 }