Mercurial > hg > Database > Alice
annotate src/alice/test/codesegment/remote/RemoteIncrement.java @ 217:b5c642ba998e working
change as** method and remove "local" key in TEST
author | sugi |
---|---|
date | Wed, 27 Mar 2013 20:02:38 +0900 |
parents | b5daccf36104 |
children |
rev | line source |
---|---|
22
2ca2d961a8d2
implements outline of TopologyManager
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
19
diff
changeset
|
1 package alice.test.codesegment.remote; |
14 | 2 |
3 import alice.codesegment.CodeSegment; | |
18
72dd27d952b0
change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
16
diff
changeset
|
4 import alice.datasegment.CommandType; |
33
20c67f673224
change name of DataSegmentReceiver
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
32
diff
changeset
|
5 import alice.datasegment.Receiver; |
14 | 6 |
7 public class RemoteIncrement extends CodeSegment { | |
8 | |
33
20c67f673224
change name of DataSegmentReceiver
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
32
diff
changeset
|
9 public Receiver num = ids.create(CommandType.TAKE); |
58 | 10 |
11 /** | |
12 * Increment DataSegment value up to 10 | |
13 */ | |
14 | 14 @Override |
15 public void run() { | |
217 | 16 int num = this.num.asInteger(); |
16 | 17 System.out.println("[CodeSegment] " + num++); |
14 | 18 if (num == 10) System.exit(0); |
19 | |
18
72dd27d952b0
change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
16
diff
changeset
|
20 RemoteIncrement cs = new RemoteIncrement(); |
72dd27d952b0
change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
16
diff
changeset
|
21 cs.num.setKey("remote", "num"); |
14 | 22 |
34
ca079a730d0b
added method to OutputDataSegment and Receiver, to convert type from Value to Class<?> without MessagePack
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
33
diff
changeset
|
23 ods.put("local", "num", num); |
14 | 24 } |
25 | |
26 } |