Mercurial > hg > Database > Alice

annotate src/main/java/alice/test/codesegment/remote/RemoteIncrement.java @ 647:e321c5ec9b58

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fix toplogy manager; ring worked
author suruga
date Sun, 31 Dec 2017 19:32:27 +0900
parents 646f705e65b1
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
1 package alice.test.codesegment.remote;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
2
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
3 import alice.codesegment.CodeSegment;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
4 import alice.datasegment.CommandType;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
5 import alice.datasegment.Receiver;
647
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
6 import org.msgpack.type.ValueFactory;
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
7
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
8 public class RemoteIncrement extends CodeSegment {
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
9
533
b3c9554ccb1b change compressed API to set data specified DSM name
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 526
diff changeset
10 public Receiver num = ids.create(CommandType.TAKE);//true でCompressedDSMからtake
647
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
11 public Receiver nullValue = ids.create(CommandType.TAKE);//true でCompressedDSMからtake
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
12
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
13 RemoteIncrement() {
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
14 num.setKey("compressedlocal", "num");
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
15 nullValue.setKey("null-value");
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
16 }
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
17
419
aefbe41fcf12 change tab to space
sugi
parents: 345
diff changeset
18 /**
aefbe41fcf12 change tab to space
sugi
parents: 345
diff changeset
19 * Increment DataSegment value up to 10
aefbe41fcf12 change tab to space
sugi
parents: 345
diff changeset
20 */
aefbe41fcf12 change tab to space
sugi
parents: 345
diff changeset
21 @Override
aefbe41fcf12 change tab to space
sugi
parents: 345
diff changeset
22 public void run() {
574
ea21af9a4762 delete serializeFlag, fix MessagePack pack&unpack
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 536
diff changeset
23 String z = "";
577
924e5f52a61f change ids compress local
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 574
diff changeset
24 if (num.isCompressed()){
574
ea21af9a4762 delete serializeFlag, fix MessagePack pack&unpack
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 536
diff changeset
25 z = "zMP";
ea21af9a4762 delete serializeFlag, fix MessagePack pack&unpack
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 536
diff changeset
26 }
419
aefbe41fcf12 change tab to space
sugi
parents: 345
diff changeset
27 int num = this.num.asInteger();
647
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
28 if ( nullValue.getVal() == null ) {
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
29 System.out.println("get null value");
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
30 }
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
31 ods.put("null-value", ValueFactory.createNilValue());
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
32
574
ea21af9a4762 delete serializeFlag, fix MessagePack pack&unpack
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 536
diff changeset
33 System.out.println("[CodeSegment" + z + "] " + num++);
641
646f705e65b1 setkey on remote
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 577
diff changeset
34 if (num == 10) System.exit(0);
419
aefbe41fcf12 change tab to space
sugi
parents: 345
diff changeset
35
aefbe41fcf12 change tab to space
sugi
parents: 345
diff changeset
36 RemoteIncrement cs = new RemoteIncrement();
aefbe41fcf12 change tab to space
sugi
parents: 345
diff changeset
37
641
646f705e65b1 setkey on remote
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 577
diff changeset
38 if ( num % 2 == 0 )
646f705e65b1 setkey on remote
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 577
diff changeset
39 ods.put("compressedremote", "num", num);
646f705e65b1 setkey on remote
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 577
diff changeset
40 else
646f705e65b1 setkey on remote
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 577
diff changeset
41 ods.put("remote", "num", num);
574
ea21af9a4762 delete serializeFlag, fix MessagePack pack&unpack
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 536
diff changeset
42
ea21af9a4762 delete serializeFlag, fix MessagePack pack&unpack
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 536
diff changeset
43 cs.num.setKey("compressedlocal", "num");
419
aefbe41fcf12 change tab to space
sugi
parents: 345
diff changeset
44 }
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
45
525
30a74eee59c7 working TestRemoteAlice
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 419
diff changeset
46 }