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

Improve performance in MOVED and ASK response parsing

Browse Source
This commit is contained in:
Marcos Nils
2014-01-17 12:06:20 -03:00
parent 23b54c2cef
commit 37f629765e
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -79,11 +79,10 @@ public final class Protocol {
String message = is.readLine(); String message = is.readLine();
//TODO: I'm not sure if this is the best way to do this. //TODO: I'm not sure if this is the best way to do this.
//Maybe Read only first 5 bytes instead? //Maybe Read only first 5 bytes instead?
// if (message.startsWith(MOVED_RESPONSE)) {
if (message.contains(MOVED_RESPONSE)) {
String[] movedInfo = parseTargetHostAndSlot(message); String[] movedInfo = parseTargetHostAndSlot(message);
throw new JedisMovedDataException(message, new HostAndPort(movedInfo[1], Integer.valueOf(movedInfo[2])), Integer.valueOf(movedInfo[0])); throw new JedisMovedDataException(message, new HostAndPort(movedInfo[1], Integer.valueOf(movedInfo[2])), Integer.valueOf(movedInfo[0]));
} else if (message.contains(ASK_RESPONSE)) { } else if (message.startsWith(ASK_RESPONSE)) {
String[] askInfo = parseTargetHostAndSlot(message); String[] askInfo = parseTargetHostAndSlot(message);
throw new JedisAskDataException(message, new HostAndPort(askInfo[1], Integer.valueOf(askInfo[2])), Integer.valueOf(askInfo[0])); throw new JedisAskDataException(message, new HostAndPort(askInfo[1], Integer.valueOf(askInfo[2])), Integer.valueOf(askInfo[0]));
} }