diff --git a/src/main/java/com/moilioncircle/redis/rdb/cli/ext/rct/MemoryRdbVisitor.java b/src/main/java/com/moilioncircle/redis/rdb/cli/ext/rct/MemoryRdbVisitor.java index 59271d48..d5897c50 100644 --- a/src/main/java/com/moilioncircle/redis/rdb/cli/ext/rct/MemoryRdbVisitor.java +++ b/src/main/java/com/moilioncircle/redis/rdb/cli/ext/rct/MemoryRdbVisitor.java @@ -953,8 +953,8 @@ protected Event doApplyStreamListPacks(RedisInputStream in, int version, byte[] if (!delete) length++; } } else { - numFields = Integer.parseInt(Strings.toString(listPackEntry(listPack))); - for (int i = 0; i < numFields; i++) { + int entryFields = Integer.parseInt(Strings.toString(listPackEntry(listPack))); + for (int i = 0; i < entryFields; i++) { byte[] field = listPackEntry(listPack); byte[] value = listPackEntry(listPack); max = Math.max(max, calc.calcElement(value)); @@ -1048,8 +1048,8 @@ protected Event doApplyStreamListPacks2(RedisInputStream in, int version, byte[] if (!delete) length++; } } else { - numFields = Integer.parseInt(Strings.toString(listPackEntry(listPack))); - for (int i = 0; i < numFields; i++) { + int entryFields = Integer.parseInt(Strings.toString(listPackEntry(listPack))); + for (int i = 0; i < entryFields; i++) { byte[] field = listPackEntry(listPack); byte[] value = listPackEntry(listPack); max = Math.max(max, calc.calcElement(value)); @@ -1149,8 +1149,8 @@ protected Event doApplyStreamListPacks3(RedisInputStream in, int version, byte[] if (!delete) length++; } } else { - numFields = Integer.parseInt(Strings.toString(listPackEntry(listPack))); - for (int i = 0; i < numFields; i++) { + int entryFields = Integer.parseInt(Strings.toString(listPackEntry(listPack))); + for (int i = 0; i < entryFields; i++) { byte[] field = listPackEntry(listPack); byte[] value = listPackEntry(listPack); max = Math.max(max, calc.calcElement(value));