Mercurial > hg > Database > Alice
changeset 560:72ef96ba4195 dispose
add zeppedDataSize in CommandMessage
| author | Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp> |
|---|---|
| date | Tue, 24 Nov 2015 00:46:42 +0900 |
| parents | 2af387211a85 |
| children | f1777341c5a2 |
| files | src/main/java/alice/daemon/CommandMessage.java src/main/java/alice/daemon/IncomingTcpConnection.java |
| diffstat | 2 files changed, 10 insertions(+), 4 deletions(-) [+] |
line wrap: on
line diff
--- a/src/main/java/alice/daemon/CommandMessage.java Thu Nov 19 02:25:33 2015 +0900 +++ b/src/main/java/alice/daemon/CommandMessage.java Tue Nov 24 00:46:42 2015 +0900 @@ -14,11 +14,13 @@ public boolean quickFlag = false;//SEDAを挟まずに処理を行うかどうか public boolean serialized = false;//シリアライズされているかどうか public boolean compressed = false;//圧縮されているかどうか - public int dataSize = 0;// + public int dataSize = 0;//圧縮前のサイズ - public boolean setTime = false;//計測用 - public long time;// - public int depth;// + //計測用 + public boolean setTime = false; + public long time; + public int depth; + public int zeppedDataSize = 0;//圧縮後のサイズ public CommandMessage() {}
--- a/src/main/java/alice/daemon/IncomingTcpConnection.java Thu Nov 19 02:25:33 2015 +0900 +++ b/src/main/java/alice/daemon/IncomingTcpConnection.java Tue Nov 24 00:46:42 2015 +0900 @@ -68,7 +68,11 @@ if (msg.setTime) { rData.setTimes(msg.time, true, msg.depth); + } + if (msg.zeppedDataSize == 0){ rData.setZippedDataSize(dataSize); + } else { + rData.setZippedDataSize(msg.zeppedDataSize); } cmd = new Command(type, null, null, rData, 0, 0, null, null, reverseKey);