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

Fixed a performance issue with utf8 characters.

Browse Source 
When an utf8 char was detected in a string, jedis flushed its output buffer
for each char. Now, the buffer is only flushed when it is really full.
This commit is contained in:
Cyril Bonté
2010-10-09 20:46:50 +02:00
parent 3b880bba43
commit 3f21dcd0eb
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/redis/clients/util/RedisOutputStream.java
View File

@@ -119,13 +119,13 @@ public final class RedisOutputStream extends FilterOutputStream {
flushBuffer(); flushBuffer();
} }
} else if (c < 0x800) { } else if (c < 0x800) {
if(2 < buf.length - count) { if(2 >= buf.length - count) {
flushBuffer(); flushBuffer();
} }
buf[count++] = (byte)(0xc0 | (c >> 6)); buf[count++] = (byte)(0xc0 | (c >> 6));
buf[count++] = (byte)(0x80 | (c & 0x3f)); buf[count++] = (byte)(0x80 | (c & 0x3f));
} else if (isSurrogate(c)) { } else if (isSurrogate(c)) {
if(4 < buf.length - count) { if(4 >= buf.length - count) {
flushBuffer(); flushBuffer();
} }
int uc = Character.toCodePoint(c, str.charAt(i++)); int uc = Character.toCodePoint(c, str.charAt(i++));
@@ -134,7 +134,7 @@ public final class RedisOutputStream extends FilterOutputStream {
buf[count++] = ((byte)(0x80 | ((uc >> 6) & 0x3f))); buf[count++] = ((byte)(0x80 | ((uc >> 6) & 0x3f)));
buf[count++] = ((byte)(0x80 | (uc & 0x3f))); buf[count++] = ((byte)(0x80 | (uc & 0x3f)));
} else { } else {
if(3 < buf.length - count) { if(3 >= buf.length - count) {
flushBuffer(); flushBuffer();
} }
buf[count++] =((byte)(0xe0 | ((c >> 12)))); buf[count++] =((byte)(0xe0 | ((c >> 12))));