Mercurial > hg > Database > Alice

diff src/main/java/alice/daemon/IncomingTcpConnection.java @ 525:30a74eee59c7 dispose

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
working TestRemoteAlice
author Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
date Thu, 16 Apr 2015 20:33:53 +0900
parents 061478079bc7
children 928907206d21
line wrap: on
line diff
--- a/src/main/java/alice/daemon/IncomingTcpConnection.java	Fri Apr 10 17:56:55 2015 +0900
+++ b/src/main/java/alice/daemon/IncomingTcpConnection.java	Thu Apr 16 20:33:53 2015 +0900
@@ -58,7 +58,8 @@
                 switch (type) {
                 case UPDATE:
                 case PUT:
-                    rData = new ReceiveData(unpacker.getSerializedByteArray(unpacker.readInt()), msg.compressed, msg.serialized);
+                    rData = new ReceiveData(unpacker.getSerializedByteArray(unpacker.readInt()));
+                    rData.setCompressFlag(msg.compressed);
                     if (msg.setTime) {
                         rData.setTime = true;
                         rData.time = msg.time;
@@ -79,7 +80,8 @@
                     break;
                 case REPLY:
                     cmd = manager.getAndRemoveCmd(msg.seq);
-                    rData = new ReceiveData(unpacker.getSerializedByteArray(unpacker.readInt()), msg.compressed, msg.serialized);
+                    rData = new ReceiveData(unpacker.getSerializedByteArray(unpacker.readInt()));
+                    rData.setCompressFlag(msg.compressed);
                     Command rCmd = new Command(type, null, null, rData, msg.index, msg.seq, null, null, "");
                     cmd.cs.ids.reply(cmd.receiver, rCmd);
                     break;
@@ -88,7 +90,7 @@
                         DataSegment.get(reverseKey).response(msg.key);
                     break;
                 case RESPONSE:
-                    rData = new ReceiveData(new RespondData(reverseKey, System.currentTimeMillis()), false, false);
+                    rData = new ReceiveData(new RespondData(reverseKey, System.currentTimeMillis()));
                     DataSegment.getLocal().put(msg.key, rData, false);
                     break;
                 default: