Fix TCP message reading

iggy-rs · Oct 17, 2024 · 16edc49 · 16edc49
1 parent 82f7ac0
commit 16edc49
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/main/java/rs/iggy/clients/blocking/tcp/TcpConnectionHandler.java b/src/main/java/rs/iggy/clients/blocking/tcp/TcpConnectionHandler.java
@@ -65,9 +65,11 @@ protected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteB
             if (byteBuf.readableBytes() < RESPONSE_INITIAL_BYTES_LENGTH) {
                 return;
             }
+            byteBuf.markReaderIndex();
             var status = byteBuf.readUnsignedIntLE();
             var responseLength = byteBuf.readUnsignedIntLE();
             if (byteBuf.readableBytes() < responseLength) {
+                byteBuf.resetReaderIndex();
                 return;
             }
             var length = Long.valueOf(responseLength).intValue();