changeset 450:5b14d0b60201 dispose

change CommandMessage constructor
author sugi
date Tue, 28 Oct 2014 10:54:29 +0900
parents 09a80f83c605
children ad1547756565
files src/main/java/alice/daemon/CommandMessage.java src/main/java/alice/datasegment/Command.java
diffstat 2 files changed, 5 insertions(+), 2 deletions(-) [+]
line wrap: on
line diff
--- a/src/main/java/alice/daemon/CommandMessage.java	Tue Oct 28 00:24:34 2014 +0900
+++ b/src/main/java/alice/daemon/CommandMessage.java	Tue Oct 28 10:54:29 2014 +0900
@@ -14,11 +14,14 @@
     
     public CommandMessage() {}
 
-    public CommandMessage(int type, int index, int seq, String key, boolean qFlag) {
+    public CommandMessage(int type, int index, int seq, String key
+            , boolean qFlag, boolean sFlag, boolean cFlag) {
         this.type = type;
         this.index = index;
         this.seq = seq;
         this.key = key;
         this.quickFlag = qFlag;
+        this.serializedFlag = sFlag;
+        this.compressedFlag = cFlag;
     }
 }
--- a/src/main/java/alice/datasegment/Command.java	Tue Oct 28 00:24:34 2014 +0900
+++ b/src/main/java/alice/datasegment/Command.java	Tue Oct 28 10:54:29 2014 +0900
@@ -91,7 +91,7 @@
         ByteBuffer buf = null;
         MessagePack msg = SingletonMessage.getInstance();
         try {
-            byte[] header = msg.write(new CommandMessage(type.id, index, seq, key, quickFlag));
+            byte[] header = msg.write(new CommandMessage(type.id, index, seq, key, quickFlag, serializeFlag, compressFlag));
             
             switch (type) {
             case UPDATE: