Mercurial > hg > Database > Alice
annotate src/main/java/alice/test/codesegment/remote/compress/TestCompress.java @ 598:35f83005271e dispose
add comment
author | Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp> |
---|---|
date | Wed, 10 Feb 2016 20:55:51 +0900 |
parents | f5322e53bbf6 |
children |
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); |
598 | 28 System.out.println("zipped size :" + info.getReceiveData().getZippedDataSize()); |
597
f5322e53bbf6
add TestCompressReceive
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
596
diff
changeset
|
29 } else if (num == 0) { |
590 | 30 long time = System.currentTimeMillis(); |
31 | |
32 System.out.println("time: " + (time - info2.asClass(long.class))); | |
33 | |
596 | 34 System.exit(0); |
590 | 35 return; |
36 } | |
37 | |
596 | 38 ods.flip("remote", "data", info); |
39 | |
590 | 40 TestCompress cs = new TestCompress(--num); |
41 | |
42 } | |
43 } |