Drop empty packets

RaphiMC · Feb 8, 2024 · c624ce8 · c624ce8
1 parent 721a328
commit c624ce8
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/src/main/java/net/raphimc/viabedrock/netty/CompressionCodec.java b/src/main/java/net/raphimc/viabedrock/netty/CompressionCodec.java
@@ -43,6 +43,10 @@ public void handlerRemoved(ChannelHandlerContext ctx) throws Exception {
 
     @Override
     protected void encode(ChannelHandlerContext ctx, ByteBuf in, ByteBuf out) throws Exception {
+        if (!in.isReadable()) {
+            return;
+        }
+
         final int inputSize = in.readableBytes();
         final CompressionAlgorithm compressionAlgorithm = this.protocolCompression.getCompressionAlgorithmForSize(inputSize);
         if (compressionAlgorithm instanceof NoopCompression) {
@@ -66,6 +70,10 @@ protected void encode(ChannelHandlerContext ctx, ByteBuf in, ByteBuf out) throws
 
     @Override
     protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
+        if (!in.isReadable()) {
+            return;
+        }
+
         final int algorithm = in.readUnsignedByte();
         final CompressionAlgorithm compressionAlgorithm = this.protocolCompression.getAlgorithmById(algorithm);
         if (compressionAlgorithm instanceof NoopCompression) {