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;