Mercurial > hg > Database > Alice

annotate src/main/java/alice/daemon/CommandMessage.java @ 574:ea21af9a4762 dispose

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
delete serializeFlag, fix MessagePack pack&unpack
author Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
date Tue, 15 Dec 2015 11:49:07 +0900
parents f1777341c5a2
children 3284428f525e
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.daemon;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
2
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
3 import org.msgpack.annotation.Message;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
4
523
145c425db88d add CompressedLDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 488
diff changeset
5 /**
145c425db88d add CompressedLDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 488
diff changeset
6 * DSのヘッダー
145c425db88d add CompressedLDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 488
diff changeset
7 */
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
8 @Message
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
9 public class CommandMessage {
523
145c425db88d add CompressedLDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 488
diff changeset
10 public int type;//PUT, PEEKなどのコマンドタイプ
145c425db88d add CompressedLDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 488
diff changeset
11 public int index;//キューの中でのDSの位置？
145c425db88d add CompressedLDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 488
diff changeset
12 public int seq;//DSの待ち合わせを行っているCSを表すunique number
145c425db88d add CompressedLDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 488
diff changeset
13 public String key;//DS key
145c425db88d add CompressedLDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 488
diff changeset
14 public boolean quickFlag = false;//SEDAを挟まずに処理を行うかどうか
145c425db88d add CompressedLDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 488
diff changeset
15 public boolean compressed = false;//圧縮されているかどうか
560
72ef96ba4195 add zeppedDataSize in CommandMessage
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 555
diff changeset
16 public int dataSize = 0;//圧縮前のサイズ
467
6e304a7a60e7 remove white space
sugi
parents: 452
diff changeset
17
560
72ef96ba4195 add zeppedDataSize in CommandMessage
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 555
diff changeset
18 //計測用
72ef96ba4195 add zeppedDataSize in CommandMessage
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 555
diff changeset
19 public boolean setTime = false;
72ef96ba4195 add zeppedDataSize in CommandMessage
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 555
diff changeset
20 public long time;
72ef96ba4195 add zeppedDataSize in CommandMessage
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 555
diff changeset
21 public int depth;
561
f1777341c5a2 add setZipped to CommandMessage&ReceiveData
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 560
diff changeset
22 public boolean setZepped = false;
f1777341c5a2 add setZipped to CommandMessage&ReceiveData
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 560
diff changeset
23 public int zippedDataSize;//圧縮後のサイズ
488
7ef0ebb40c9b add measurement data in protocol
sugi
parents: 467
diff changeset
24
419
aefbe41fcf12 change tab to space
sugi
parents: 345
diff changeset
25 public CommandMessage() {}
aefbe41fcf12 change tab to space
sugi
parents: 345
diff changeset
26
450
5b14d0b60201 change CommandMessage constructor
sugi
parents: 449
diff changeset
27 public CommandMessage(int type, int index, int seq, String key
574
ea21af9a4762 delete serializeFlag, fix MessagePack pack&unpack
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 561
diff changeset
28 , boolean qFlag, boolean cFlag, int datasize) {
419
aefbe41fcf12 change tab to space
sugi
parents: 345
diff changeset
29 this.type = type;
aefbe41fcf12 change tab to space
sugi
parents: 345
diff changeset
30 this.index = index;
aefbe41fcf12 change tab to space
sugi
parents: 345
diff changeset
31 this.seq = seq;
aefbe41fcf12 change tab to space
sugi
parents: 345
diff changeset
32 this.key = key;
449
09a80f83c605 add Serialized and compressed flag on protocol header
sugi
parents: 443
diff changeset
33 this.quickFlag = qFlag;
452
f68d103498e0 refactor (InputDataSegment holder class changed)
sugi
parents: 450
diff changeset
34 this.compressed = cFlag;
530
4aeebea0c9b5 can't unzip
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 529
diff changeset
35 this.dataSize = datasize;
419
aefbe41fcf12 change tab to space
sugi
parents: 345
diff changeset
36 }
555
2af387211a85 add zippedDataSize to ReceiveData
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 530
diff changeset
37
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
38 }