Upstream/Waterfall
1
0
Fork 0
mirror of https://github.com/PaperMC/Waterfall.git synced 2024-12-27 11:07:39 +01:00
Code Issues Projects Releases Wiki Activity

Apply SpigotMC/BungeeCord#2908 (#546)

Browse Source
This commit is contained in:
Andrew Steinborn 2020-07-16 15:31:47 -04:00 committed by GitHub
parent 7ddd12de76
commit 6f55959a10
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 67 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

67
BungeeCord-Patches/0057-Apply-SpigotMC-BungeeCord-2908-Don-t-frame-packets-f.patch Normal file
View File

@ -0,0 +1,67 @@
From 8126691800a7ed841c85871095dd29fbf2e2c90e Mon Sep 17 00:00:00 2001
From: Andrew Steinborn <git@steinborn.me>
Date: Thu, 16 Jul 2020 15:23:20 -0400
Subject: [PATCH] Apply SpigotMC/BungeeCord#2908 (Don't frame packets for dead
connections)
diff --git a/protocol/src/main/java/net/md_5/bungee/protocol/LegacyDecoder.java b/protocol/src/main/java/net/md_5/bungee/protocol/LegacyDecoder.java
index 334a8eab..5518bf26 100644
--- a/protocol/src/main/java/net/md_5/bungee/protocol/LegacyDecoder.java
+++ b/protocol/src/main/java/net/md_5/bungee/protocol/LegacyDecoder.java
@@ -14,6 +14,13 @@ public class LegacyDecoder extends ByteToMessageDecoder
@Override
protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception
{
+ // See check in Varint21FrameDecoder for more details
+ if ( !ctx.channel().isActive() )
+ {
+ in.skipBytes( in.readableBytes() );
+ return;
+ }
+
if ( !in.isReadable() )
{
return;
diff --git a/protocol/src/main/java/net/md_5/bungee/protocol/MinecraftDecoder.java b/protocol/src/main/java/net/md_5/bungee/protocol/MinecraftDecoder.java
index 6c3c7ab8..1a647f2b 100644
--- a/protocol/src/main/java/net/md_5/bungee/protocol/MinecraftDecoder.java
+++ b/protocol/src/main/java/net/md_5/bungee/protocol/MinecraftDecoder.java
@@ -30,6 +30,13 @@ public class MinecraftDecoder extends MessageToMessageDecoder<ByteBuf>
@Override
protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception
{
+ // See Varint21FrameDecoder for the general reasoning. We add this here as ByteToMessageDecoder#handlerRemoved()
+ // will fire any cumulated data through the pipeline, so we want to try and stop it here.
+ if ( !ctx.channel().isActive() )
+ {
+ return;
+ }
+
Protocol.DirectionData prot = ( server ) ? protocol.TO_SERVER : protocol.TO_CLIENT;
ByteBuf slice = in.copy(); // Can't slice this one due to EntityMap :(
diff --git a/protocol/src/main/java/net/md_5/bungee/protocol/Varint21FrameDecoder.java b/protocol/src/main/java/net/md_5/bungee/protocol/Varint21FrameDecoder.java
index 743d65e4..c0d37142 100644
--- a/protocol/src/main/java/net/md_5/bungee/protocol/Varint21FrameDecoder.java
+++ b/protocol/src/main/java/net/md_5/bungee/protocol/Varint21FrameDecoder.java
@@ -15,6 +15,16 @@ public class Varint21FrameDecoder extends ByteToMessageDecoder
@Override
protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception
{
+ // If we decode an invalid packet and an exception is thrown (thus triggering a close of the connection),
+ // the Netty ByteToMessageDecoder will continue to frame more packets and potentially call fireChannelRead()
+ // on them, likely with more invalid packets. Therefore, check if the connection is no longer active and if so
+ // sliently discard the packet.
+ if ( !ctx.channel().isActive() )
+ {
+ in.skipBytes( in.readableBytes() );
+ return;
+ }
+
in.markReaderIndex();
for ( int i = 0; i < 3; i++ ) // Waterfall
--
2.26.2