Mercurial > hg > Database > Alice
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: