Upstream/BungeeCord
1
0
Fork 0
mirror of https://github.com/SpigotMC/BungeeCord.git synced 2025-01-26 17:41:34 +01:00
Code Issues Projects Releases Wiki Activity

#3769: Fix possible NoSuchElementException changing compression

Browse Source
This commit is contained in:
Outfluencer 2025-01-07 20:46:11 +11:00 committed by md_5
parent d99570214a
commit 1265a9927b
No known key found for this signature in database
GPG Key ID: E8E901AC7C617C11
1 changed files with 20 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
proxy/src/main/java/net/md_5/bungee/netty/ChannelWrapper.java
View File

@ -180,26 +180,32 @@ public class ChannelWrapper
public void setCompressionThreshold(int compressionThreshold)
{
if ( ch.pipeline().get( PacketCompressor.class ) == null && compressionThreshold >= 0 )
{
addBefore( PipelineUtils.PACKET_ENCODER, "compress", new PacketCompressor() );
}
PacketCompressor compressor = ch.pipeline().get( PacketCompressor.class );
PacketDecompressor decompressor = ch.pipeline().get( PacketDecompressor.class );
if ( compressionThreshold >= 0 )
{
ch.pipeline().get( PacketCompressor.class ).setThreshold( compressionThreshold );
if ( compressor == null )
{
addBefore( PipelineUtils.PACKET_ENCODER, "compress", compressor = new PacketCompressor() );
}
compressor.setThreshold( compressionThreshold );
if ( decompressor == null )
{
addBefore( PipelineUtils.PACKET_DECODER, "decompress", decompressor = new PacketDecompressor() );
}
} else
{
ch.pipeline().remove( "compress" );
if ( compressor != null )
{
ch.pipeline().remove( "compress" );
}
if ( decompressor != null )
{
ch.pipeline().remove( "decompress" );
}
}
if ( ch.pipeline().get( PacketDecompressor.class ) == null && compressionThreshold >= 0 )
{
addBefore( PipelineUtils.PACKET_DECODER, "decompress", new PacketDecompressor() );
}
if ( compressionThreshold < 0 )
{
ch.pipeline().remove( "decompress" );
}
// disable use of composite buffers if we use natives
updateComposite();
}