From df82c0b566b35fb654aaef46ee87e50b8276bd65 Mon Sep 17 00:00:00 2001
From: Andrew Steinborn <git@steinborn.me>
Date: Tue, 23 Jun 2020 07:56:19 -0400
Subject: [PATCH] Suppress some really annoying spam

---
 .../proxy/connection/MinecraftConnection.java | 19 ++++++++++++++++---
 1 file changed, 16 insertions(+), 3 deletions(-)

diff --git a/proxy/src/main/java/com/velocitypowered/proxy/connection/MinecraftConnection.java b/proxy/src/main/java/com/velocitypowered/proxy/connection/MinecraftConnection.java
index 2765676e0..189e73eb5 100644
--- a/proxy/src/main/java/com/velocitypowered/proxy/connection/MinecraftConnection.java
+++ b/proxy/src/main/java/com/velocitypowered/proxy/connection/MinecraftConnection.java
@@ -205,10 +205,15 @@ public class MinecraftConnection extends ChannelInboundHandlerAdapter {
    */
   public void closeWith(Object msg) {
     if (channel.isActive()) {
-      channel.eventLoop().execute(() -> {
+      if (channel.eventLoop().inEventLoop()) {
         knownDisconnect = true;
         channel.writeAndFlush(msg).addListener(ChannelFutureListener.CLOSE);
-      });
+      } else {
+        channel.eventLoop().execute(() -> {
+          knownDisconnect = true;
+          channel.writeAndFlush(msg).addListener(ChannelFutureListener.CLOSE);
+        });
+      }
     }
   }
 
@@ -217,7 +222,15 @@ public class MinecraftConnection extends ChannelInboundHandlerAdapter {
    */
   public void close() {
     if (channel.isActive()) {
-      channel.close();
+      if (channel.eventLoop().inEventLoop()) {
+        knownDisconnect = true;
+        channel.close();
+      } else {
+        channel.eventLoop().execute(() -> {
+          knownDisconnect = true;
+          channel.close();
+        });
+      }
     }
   }