Mercurial > hg > Database > Alice

diff src/main/java/alice/datasegment/CompressedRemoteDataSegmentManager.java @ 530:4aeebea0c9b5 dispose

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
can't unzip
author Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
date Sun, 03 May 2015 10:04:28 +0900
parents cb7c31848d16
children b3c9554ccb1b
line wrap: on
line diff
--- a/src/main/java/alice/datasegment/CompressedRemoteDataSegmentManager.java	Fri May 01 18:19:16 2015 +0900
+++ b/src/main/java/alice/datasegment/CompressedRemoteDataSegmentManager.java	Sun May 03 10:04:28 2015 +0900
@@ -99,7 +99,9 @@
     public void take(Receiver receiver, CodeSegment cs, SendOption option) {
         int seq = this.seq.getAndIncrement();
         Command cmd = new Command(CommandType.TAKE, receiver, receiver.key, null, receiver.index, seq, replyQueue, cs, null);
+        cmd.setCompressFlag(option.isCompress());
         cmd.setQuickFlag(option.isQuick());
+
         seqHash.put(seq, cmd);
         if (option.isQuick()){
             connection.write(cmd);
@@ -114,7 +116,9 @@
     public void peek(Receiver receiver, CodeSegment cs, SendOption option) {
         int seq = this.seq.getAndIncrement();
         Command cmd = new Command(CommandType.PEEK, receiver, receiver.key, null, receiver.index, seq, replyQueue, cs, null);
+        cmd.setCompressFlag(option.isCompress());
         cmd.setQuickFlag(option.isQuick());
+
         seqHash.put(seq, cmd);
         if (option.isQuick()){
             connection.write(cmd);