Fix not forwarding channelReadComplete events in some cases

2021-08-04 23:01:28 -04:00
parent d3e1b358fb
commit c32bc88064
1 changed files with 6 additions and 2 deletions
--- a/proxy/src/main/java/com/velocitypowered/proxy/protocol/netty/AutoReadHolderHandler.java
+++ b/proxy/src/main/java/com/velocitypowered/proxy/protocol/netty/AutoReadHolderHandler.java
@@ -62,8 +62,12 @@ public class AutoReadHolderHandler extends ChannelDuplexHandler {

  @Override
  public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
-    if (this.queuedMessages.isEmpty()) {
-      ctx.fireChannelReadComplete();
+    if (ctx.channel().config().isAutoRead()) {
+      if (!this.queuedMessages.isEmpty()) {
+        this.drainQueuedMessages(ctx); // will also call fireChannelReadComplete()
+      } else {
+        ctx.fireChannelReadComplete();
+      }
    }
  }