Mercurial > hg > Database > Alice
annotate src/main/java/alice/test/codesegment/remote/compress/TestCompress.java @ 597:f5322e53bbf6 dispose
add TestCompressReceive
author | Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp> |
---|---|
date | Wed, 10 Feb 2016 20:32:25 +0900 |
parents | 2b8e6b8b5d20 |
children | 35f83005271e |
rev | line source |
---|---|
591
25fe2f78ac40
add remote compress test
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
590
diff
changeset
|
1 package alice.test.codesegment.remote.compress; |
590 | 2 |
3 import alice.codesegment.CodeSegment; | |
4 import alice.datasegment.CommandType; | |
5 import alice.datasegment.Receiver; | |
6 | |
7 /** | |
8 * Created by e125769 on 2/9/16. | |
9 */ | |
10 public class TestCompress extends CodeSegment{ | |
11 // create input datasegment arg1 | |
12 Receiver info = ids.create(CommandType.TAKE); | |
13 Receiver info2 = ids.create(CommandType.PEEK); | |
14 int num; | |
15 | |
16 public TestCompress(int num){ | |
17 this.num = num; | |
18 info.setKey("data"); | |
19 info2.setKey("time"); | |
20 } | |
21 | |
22 @Override | |
23 public void run() { | |
24 | |
597
f5322e53bbf6
add TestCompressReceive
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
596
diff
changeset
|
25 if (num == 100){ |
f5322e53bbf6
add TestCompressReceive
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
596
diff
changeset
|
26 long time = System.currentTimeMillis(); |
f5322e53bbf6
add TestCompressReceive
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
596
diff
changeset
|
27 ods.update("time", time); |
f5322e53bbf6
add TestCompressReceive
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
596
diff
changeset
|
28 } else if (num == 0) { |
590 | 29 long time = System.currentTimeMillis(); |
30 | |
31 System.out.println("time: " + (time - info2.asClass(long.class))); | |
32 | |
596 | 33 System.exit(0); |
590 | 34 return; |
35 } | |
36 | |
596 | 37 ods.flip("remote", "data", info); |
38 | |
590 | 39 TestCompress cs = new TestCompress(--num); |
40 | |
41 } | |
42 } |