rik/jlibredis
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix processBulKReply against TCP fragmentation.

Browse Source 
see http://github.com/xetorthio/jedis/issues#issue/10
This commit is contained in:
Thomas Sauzedde
2010-09-10 17:05:18 +02:00
parent 562fa70a0c
commit f0f6049cdb
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/redis/clients/jedis/Protocol.java
View File

@@ -139,8 +139,11 @@ public class Protocol {
return null; return null;
} }
byte[] read = new byte[len]; byte[] read = new byte[len];
int offset = 0;
try { try {
is.read(read); while(offset < len) {
offset += is.read(read, offset, (len - offset));
}
// read 2 more bytes for the command delimiter // read 2 more bytes for the command delimiter
is.read(); is.read();
is.read(); is.read();