Mercurial > hg > Database > Alice
diff src/main/java/alice/daemon/IncomingTcpConnection.java @ 488:7ef0ebb40c9b dispose
add measurement data in protocol
author | sugi |
---|---|
date | Mon, 08 Dec 2014 23:11:26 +0900 |
parents | c06070403ed4 |
children | 118e150ac9f3 |
line wrap: on
line diff
--- a/src/main/java/alice/daemon/IncomingTcpConnection.java Mon Dec 08 20:55:10 2014 +0900 +++ b/src/main/java/alice/daemon/IncomingTcpConnection.java Mon Dec 08 23:11:26 2014 +0900 @@ -60,6 +60,11 @@ case UPDATE: case PUT: rData = new ReceiveData(getSerializedByteArray(unpacker), msg.compressed, msg.serialized); + if (msg.setTime) { + rData.setTime = true; + rData.time = msg.time; + rData.depth = msg.depth; + } cmd = new Command(type, null, null, rData, 0, 0, null, null, reverseKey); lmanager.getDataSegmentKey(msg.key).runCommand(cmd); break;