From f0f6049cdba1db4914ef0d837a84183fa206c227 Mon Sep 17 00:00:00 2001 From: Thomas Sauzedde Date: Fri, 10 Sep 2010 17:05:18 +0200 Subject: [PATCH] Fix processBulKReply against TCP fragmentation. see http://github.com/xetorthio/jedis/issues#issue/10 --- src/main/java/redis/clients/jedis/Protocol.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/main/java/redis/clients/jedis/Protocol.java b/src/main/java/redis/clients/jedis/Protocol.java index ff96e8b..3c1ff30 100644 --- a/src/main/java/redis/clients/jedis/Protocol.java +++ b/src/main/java/redis/clients/jedis/Protocol.java @@ -139,8 +139,11 @@ public class Protocol { return null; } byte[] read = new byte[len]; + int offset = 0; try { - is.read(read); + while(offset < len) { + offset += is.read(read, offset, (len - offset)); + } // read 2 more bytes for the command delimiter is.read(); is.read();