Mercurial > hg > Database > Alice
annotate src/alice/test/codesegment/local/TestCodeSegment.java @ 248:913ee9dfec4f
add recycle method
author | sugi |
---|---|
date | Wed, 29 May 2013 15:39:55 +0900 |
parents | 3f20b6401823 |
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.local; |
3 | 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; |
213 | 6 import org.msgpack.type.Value; |
3 | 7 |
8 public class TestCodeSegment extends CodeSegment { | |
9 | |
57 | 10 // create input datasegment arg1 |
182 | 11 Receiver arg1 = ids.create(CommandType.PEEK); |
16 | 12 |
3 | 13 @Override |
14 public void run() { | |
248 | 15 System.out.println("type = " + arg1.type); |
213 | 16 System.out.println("index = " + arg1.index); |
17 System.out.println("data = " + arg1.getVal()); | |
18 System.out.println(((Value)arg1.getVal()).getType()); | |
197 | 19 |
213 | 20 if (arg1.index == 10) { |
197 | 21 System.exit(0); |
22 return; | |
182 | 23 } |
150 | 24 |
197 | 25 TestCodeSegment cs = new TestCodeSegment(); |
213 | 26 cs.arg1.setKey("key1", arg1.index); |
169 | 27 |
57 | 28 // DataSegment.get("local").update |
197 | 29 ods.update("local", "key1", "String data"); |
3 | 30 } |
31 | |
32 } |