Mercurial > hg > Database > Alice
annotate src/main/java/alice/daemon/CommandMessage.java @ 599:3284428f525e dispose
add MetaCodeSegment & MetaDSM
author | Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp> |
---|---|
date | Mon, 15 Feb 2016 01:16:35 +0900 |
parents | ea21af9a4762 |
children |
rev | line source |
---|---|
345 | 1 package alice.daemon; |
2 | |
3 import org.msgpack.annotation.Message; | |
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 | 8 @Message |
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;//圧縮前のサイズ |
599
3284428f525e
add MetaCodeSegment & MetaDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
574
diff
changeset
|
17 public boolean meta = false; |
467 | 18 |
560
72ef96ba4195
add zeppedDataSize in CommandMessage
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
555
diff
changeset
|
19 //計測用 |
72ef96ba4195
add zeppedDataSize in CommandMessage
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
555
diff
changeset
|
20 public boolean setTime = false; |
72ef96ba4195
add zeppedDataSize in CommandMessage
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
555
diff
changeset
|
21 public long time; |
72ef96ba4195
add zeppedDataSize in CommandMessage
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
555
diff
changeset
|
22 public int depth; |
561
f1777341c5a2
add setZipped to CommandMessage&ReceiveData
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
560
diff
changeset
|
23 public boolean setZepped = false; |
f1777341c5a2
add setZipped to CommandMessage&ReceiveData
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
560
diff
changeset
|
24 public int zippedDataSize;//圧縮後のサイズ |
488 | 25 |
419 | 26 public CommandMessage() {} |
27 | |
450 | 28 public CommandMessage(int type, int index, int seq, String key |
599
3284428f525e
add MetaCodeSegment & MetaDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
574
diff
changeset
|
29 , boolean qFlag, boolean cFlag, int datasize, boolean mFlag) { |
419 | 30 this.type = type; |
31 this.index = index; | |
32 this.seq = seq; | |
33 this.key = key; | |
449 | 34 this.quickFlag = qFlag; |
452 | 35 this.compressed = cFlag; |
530 | 36 this.dataSize = datasize; |
599
3284428f525e
add MetaCodeSegment & MetaDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
574
diff
changeset
|
37 this.meta = mFlag; |
419 | 38 } |
555
2af387211a85
add zippedDataSize to ReceiveData
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
530
diff
changeset
|
39 |
345 | 40 } |