fix(networking): Prevent hanging the network loop if an exception occurs

Author: KingRainbow44

src/main/java/emu/grasscutter/net/impl/NetworkTransportImpl.java

@@ -2,6 +2,7 @@
 
 import emu.grasscutter.net.INetworkTransport;
 import emu.grasscutter.server.game.GameSession;
+import emu.grasscutter.utils.Utils;
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.DefaultEventLoop;
 import io.netty.channel.EventLoop;
@@ -83,11 +84,20 @@ public void handleReceive(ByteBuf byteBuf, Ukcp ukcp) {
                     return;
                 }
 
-                transport.networkLoop.submit(() -> session.onReceived(byteBuf.array()));
+                // Copy the buffer to avoid reference issues.
+                var data = Utils.byteBufToArray(byteBuf);
+
+                transport.networkLoop.submit(() -> {
+                    // Fun fact: if we don't catch exceptions here,
+                    // we run the risk of locking the entire network loop.
+                    try {
+                        session.onReceived(data);
+                    } catch (Exception ex) {
+                        session.getLogger().warn("Unable to handle received data.", ex);
+                    }
+                });
             } catch (Exception ex) {
                 NetworkTransportImpl.log.warn("Unable to handle received data.", ex);
-            } finally {
-                byteBuf.release();
             }
         }
 

src/main/java/emu/grasscutter/server/game/GameSession.java

@@ -14,6 +14,7 @@
 import io.netty.buffer.*;
 import java.net.InetSocketAddress;
 import lombok.*;
+import org.slf4j.Logger;
 
 public class GameSession implements IGameSession {
     @Getter private final GameServer server;
@@ -49,6 +50,10 @@ public InetSocketAddress getAddress() {
         return this.session.getAddress();
     }
 
+    public Logger getLogger() {
+        return this.session.getLogger();
+    }
+
     public synchronized void setPlayer(Player player) {
         this.player = player;
         this.player.setSession(this);