fix readInt bug

leonchen83 · Sep 23, 2016 · 2910969 · 2910969
1 parent 374830e
commit 2910969
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/main/java/com/moilioncircle/redis/replicator/io/RedisInputStream.java b/src/main/java/com/moilioncircle/redis/replicator/io/RedisInputStream.java
@@ -113,7 +113,8 @@ public int readInt(int length, boolean littleEndian) throws IOException {
                 r = (r << 8) | v;
             }
         }
-        return r;
+        int c;
+        return r << (c = (4 - length << 3)) >> c;
     }
 
     public long readUInt(int length) throws IOException {
@@ -138,7 +139,8 @@ public int readInt(byte[] bytes, boolean littleEndian) {
                 r = (r << 8) | v;
             }
         }
-        return r;
+        int c;
+        return r << (c = (4 - length << 3)) >> c;
     }
 
     public long readLong(int length, boolean littleEndian) throws IOException {