diff --git a/Waterfall-Proxy-Patches/0010-Close-connections.patch b/Waterfall-Proxy-Patches/0010-Close-connections-Don-t-flush-if-not-necessary.patch similarity index 53% rename from Waterfall-Proxy-Patches/0010-Close-connections.patch rename to Waterfall-Proxy-Patches/0010-Close-connections-Don-t-flush-if-not-necessary.patch index cdfb344..39b0aff 100644 --- a/Waterfall-Proxy-Patches/0010-Close-connections.patch +++ b/Waterfall-Proxy-Patches/0010-Close-connections-Don-t-flush-if-not-necessary.patch @@ -1,11 +1,11 @@ -From f352e9224c1610b6047cc001a0555f4b940ff71d Mon Sep 17 00:00:00 2001 +From 180b59e0e41ddd48732dfb46c729b47c4469875b Mon Sep 17 00:00:00 2001 From: foss-mc <69294560+foss-mc@users.noreply.github.com> Date: Wed, 16 Dec 2020 18:06:17 +0800 -Subject: [PATCH] Close connections +Subject: [PATCH] Close connections & Don't flush if not necessary diff --git a/proxy/src/main/java/net/md_5/bungee/connection/InitialHandler.java b/proxy/src/main/java/net/md_5/bungee/connection/InitialHandler.java -index c2ec12b4..3e7f6d00 100644 +index c2ec12b4..1be9ae77 100644 --- a/proxy/src/main/java/net/md_5/bungee/connection/InitialHandler.java +++ b/proxy/src/main/java/net/md_5/bungee/connection/InitialHandler.java @@ -197,6 +197,13 @@ public class InitialHandler extends PacketHandler implements PendingConnection @@ -55,6 +55,68 @@ index c2ec12b4..3e7f6d00 100644 } @Override +@@ -619,7 +636,8 @@ public class InitialHandler extends PacketHandler implements PendingConnection + { + if ( canSendKickMessage() ) + { +- ch.delayedClose( new Kick( ComponentSerializer.toString( reason ) ) ); ++ // FlameCord - Changed delayedClose to close ++ ch.close( new Kick( ComponentSerializer.toString( reason ) ) ); + } else + { + ch.close(); +diff --git a/proxy/src/main/java/net/md_5/bungee/netty/ChannelWrapper.java b/proxy/src/main/java/net/md_5/bungee/netty/ChannelWrapper.java +index 6dc5633f..5c05f2b9 100644 +--- a/proxy/src/main/java/net/md_5/bungee/netty/ChannelWrapper.java ++++ b/proxy/src/main/java/net/md_5/bungee/netty/ChannelWrapper.java +@@ -80,40 +80,27 @@ public class ChannelWrapper + + if ( packet != null && ch.isActive() ) + { +- ch.writeAndFlush( packet ).addListeners( ChannelFutureListener.FIRE_EXCEPTION_ON_FAILURE, ChannelFutureListener.CLOSE ); ++ // FlameCord - Remove the firing of exceptions on failure ++ ch.writeAndFlush( packet ).addListeners( ChannelFutureListener.CLOSE ); + } else + { +- ch.flush(); ++ // FlameCord - Don't flush just close + ch.close(); + } + } + } + ++ // FlameCord - Deprecate and "disable" delayedClose because it doesn't have a reason to exist ++ @Deprecated + public void delayedClose(final Kick kick) + { +- if ( !closing ) +- { +- closing = true; +- +- // Minecraft client can take some time to switch protocols. +- // Sending the wrong disconnect packet whilst a protocol switch is in progress will crash it. +- // Delay 250ms to ensure that the protocol switch (if any) has definitely taken place. +- ch.eventLoop().schedule( new Runnable() +- { +- +- @Override +- public void run() +- { +- close( kick ); +- } +- }, 250, TimeUnit.MILLISECONDS ); +- } ++ close(kick); + } + + public void addBefore(String baseName, String name, ChannelHandler handler) + { + Preconditions.checkState( ch.eventLoop().inEventLoop(), "cannot add handler outside of event loop" ); +- ch.pipeline().flush(); ++ // FlameCord - Don't flush if not necessary + ch.pipeline().addBefore( baseName, name, handler ); + } + diff --git a/query/src/main/java/net/md_5/bungee/query/QueryHandler.java b/query/src/main/java/net/md_5/bungee/query/QueryHandler.java index 0c1ecfb8..b3bdfd05 100644 --- a/query/src/main/java/net/md_5/bungee/query/QueryHandler.java diff --git a/Waterfall-Proxy-Patches/0011-Use-elseIfs.patch b/Waterfall-Proxy-Patches/0011-Use-elseIfs.patch index 311d004..bb96181 100644 --- a/Waterfall-Proxy-Patches/0011-Use-elseIfs.patch +++ b/Waterfall-Proxy-Patches/0011-Use-elseIfs.patch @@ -1,11 +1,11 @@ -From 40440185e64d394ef7bda875820891ebea847ca8 Mon Sep 17 00:00:00 2001 +From 8483549f243a6d8aad3574fc2d6235c3326e2740 Mon Sep 17 00:00:00 2001 From: foss-mc <69294560+foss-mc@users.noreply.github.com> Date: Wed, 16 Dec 2020 18:07:26 +0800 Subject: [PATCH] Use elseIfs diff --git a/proxy/src/main/java/net/md_5/bungee/connection/DownstreamBridge.java b/proxy/src/main/java/net/md_5/bungee/connection/DownstreamBridge.java -index d54d8539..1be39af0 100644 +index d54d8539..0dd2884d 100644 --- a/proxy/src/main/java/net/md_5/bungee/connection/DownstreamBridge.java +++ b/proxy/src/main/java/net/md_5/bungee/connection/DownstreamBridge.java @@ -285,6 +285,7 @@ public class DownstreamBridge extends PacketHandler @@ -134,6 +134,24 @@ index d54d8539..1be39af0 100644 { ProxiedPlayer player = bungee.getPlayer( in.readUTF() ); if ( player != null ) +@@ -539,7 +539,7 @@ public class DownstreamBridge extends PacketHandler + out.writeUTF( player.getUUID() ); + } + } +- if ( subChannel.equals( "ServerIP" ) ) ++ else if ( subChannel.equals( "ServerIP" ) ) + { + ServerInfo info = bungee.getServerInfo( in.readUTF() ); + if ( info != null && !info.getAddress().isUnresolved() ) +@@ -550,7 +550,7 @@ public class DownstreamBridge extends PacketHandler + out.writeShort( info.getAddress().getPort() ); + } + } +- if ( subChannel.equals( "KickPlayer" ) ) ++ else if ( subChannel.equals( "KickPlayer" ) ) + { + ProxiedPlayer player = bungee.getPlayer( in.readUTF() ); + if ( player != null ) -- 2.20.1 diff --git a/Waterfall-Proxy-Patches/0015-use-address-getHostString.patch b/Waterfall-Proxy-Patches/0015-use-address-getHostString.patch new file mode 100644 index 0000000..ec2fe06 --- /dev/null +++ b/Waterfall-Proxy-Patches/0015-use-address-getHostString.patch @@ -0,0 +1,32 @@ +From 7fc05a47e12839eb256a9141ab122886ca788522 Mon Sep 17 00:00:00 2001 +From: foss-mc <69294560+foss-mc@users.noreply.github.com> +Date: Wed, 16 Dec 2020 18:24:42 +0800 +Subject: [PATCH] use address & getHostString + + +diff --git a/proxy/src/main/java/net/md_5/bungee/connection/DownstreamBridge.java b/proxy/src/main/java/net/md_5/bungee/connection/DownstreamBridge.java +index 0dd2884d..474551d3 100644 +--- a/proxy/src/main/java/net/md_5/bungee/connection/DownstreamBridge.java ++++ b/proxy/src/main/java/net/md_5/bungee/connection/DownstreamBridge.java +@@ -542,12 +542,15 @@ public class DownstreamBridge extends PacketHandler + else if ( subChannel.equals( "ServerIP" ) ) + { + ServerInfo info = bungee.getServerInfo( in.readUTF() ); +- if ( info != null && !info.getAddress().isUnresolved() ) ++ // FlameCord use address ++ InetSocketAddress address = info.getAddress(); ++ if ( info != null && !address.isUnresolved() ) + { + out.writeUTF( "ServerIP" ); + out.writeUTF( info.getName() ); +- out.writeUTF( info.getAddress().getAddress().getHostAddress() ); +- out.writeShort( info.getAddress().getPort() ); ++ // FlameCord - Use getHostString ++ out.writeUTF( address.getHostString() ); ++ out.writeShort( address.getPort() ); + } + } + else if ( subChannel.equals( "KickPlayer" ) ) +-- +2.20.1 + diff --git a/Waterfall-Proxy-Patches/0016-Change-state-to-encrypt-only-if-onlineMode-is-true.patch b/Waterfall-Proxy-Patches/0016-Change-state-to-encrypt-only-if-onlineMode-is-true.patch new file mode 100644 index 0000000..56c1ac1 --- /dev/null +++ b/Waterfall-Proxy-Patches/0016-Change-state-to-encrypt-only-if-onlineMode-is-true.patch @@ -0,0 +1,27 @@ +From 1fa924e0e980d172556ff43ee97caee5211c53a0 Mon Sep 17 00:00:00 2001 +From: foss-mc <69294560+foss-mc@users.noreply.github.com> +Date: Wed, 16 Dec 2020 18:25:03 +0800 +Subject: [PATCH] Change state to encrypt only if onlineMode is true + + +diff --git a/proxy/src/main/java/net/md_5/bungee/connection/InitialHandler.java b/proxy/src/main/java/net/md_5/bungee/connection/InitialHandler.java +index 1be9ae77..93486904 100644 +--- a/proxy/src/main/java/net/md_5/bungee/connection/InitialHandler.java ++++ b/proxy/src/main/java/net/md_5/bungee/connection/InitialHandler.java +@@ -452,11 +452,12 @@ public class InitialHandler extends PacketHandler implements PendingConnection + if ( onlineMode ) + { + unsafe().sendPacket( request = EncryptionUtil.encryptRequest() ); ++ // FlameCord - Change state to encrypt only if onlineMode is true ++ thisState = State.ENCRYPT; + } else + { + finish(); + } +- thisState = State.ENCRYPT; + } + }; + +-- +2.20.1 + diff --git a/Waterfall-Proxy-Patches/0017-Don-t-allow-name-containing-dot.patch b/Waterfall-Proxy-Patches/0017-Don-t-allow-name-containing-dot.patch new file mode 100644 index 0000000..0717839 --- /dev/null +++ b/Waterfall-Proxy-Patches/0017-Don-t-allow-name-containing-dot.patch @@ -0,0 +1,32 @@ +From 69632ee3a5f3963b39c933c2dba4d0c3ecf05f6c Mon Sep 17 00:00:00 2001 +From: foss-mc <69294560+foss-mc@users.noreply.github.com> +Date: Wed, 16 Dec 2020 18:25:51 +0800 +Subject: [PATCH] Don't allow name containing dot + + +diff --git a/proxy/src/main/java/net/md_5/bungee/connection/InitialHandler.java b/proxy/src/main/java/net/md_5/bungee/connection/InitialHandler.java +index 93486904..1f5492fb 100644 +--- a/proxy/src/main/java/net/md_5/bungee/connection/InitialHandler.java ++++ b/proxy/src/main/java/net/md_5/bungee/connection/InitialHandler.java +@@ -407,13 +407,16 @@ public class InitialHandler extends PacketHandler implements PendingConnection + Preconditions.checkState( thisState == State.USERNAME, "Not expecting USERNAME" ); + this.loginRequest = loginRequest; + +- if ( getName().contains( "." ) ) ++ // FlameCord - Use name ++ final String name = getName(); ++ ++ if ( name.contains( "." ) ) + { + disconnect( bungee.getTranslation( "name_invalid" ) ); + return; + } + +- if ( getName().length() > 16 ) ++ if ( name.length() > 16 ) + { + disconnect( bungee.getTranslation( "name_too_long" ) ); + return; +-- +2.20.1 + diff --git a/Waterfall-Proxy-Patches/0018-Use-pipeline-to-reduce-redundancy.patch b/Waterfall-Proxy-Patches/0018-Use-pipeline-to-reduce-redundancy.patch new file mode 100644 index 0000000..f4f9759 --- /dev/null +++ b/Waterfall-Proxy-Patches/0018-Use-pipeline-to-reduce-redundancy.patch @@ -0,0 +1,45 @@ +From d89f2f435ff551a128625efd7f1d30758aa479b8 Mon Sep 17 00:00:00 2001 +From: foss-mc <69294560+foss-mc@users.noreply.github.com> +Date: Wed, 16 Dec 2020 18:30:07 +0800 +Subject: [PATCH] Use pipeline to reduce redundancy + + +diff --git a/proxy/src/main/java/net/md_5/bungee/netty/ChannelWrapper.java b/proxy/src/main/java/net/md_5/bungee/netty/ChannelWrapper.java +index 5c05f2b9..f9493ff0 100644 +--- a/proxy/src/main/java/net/md_5/bungee/netty/ChannelWrapper.java ++++ b/proxy/src/main/java/net/md_5/bungee/netty/ChannelWrapper.java +@@ -5,6 +5,8 @@ import io.netty.channel.Channel; + import io.netty.channel.ChannelFutureListener; + import io.netty.channel.ChannelHandler; + import io.netty.channel.ChannelHandlerContext; ++import io.netty.channel.ChannelPipeline; ++ + import java.net.SocketAddress; + import java.util.concurrent.TimeUnit; + import lombok.Getter; +@@ -37,14 +39,18 @@ public class ChannelWrapper + + public void setProtocol(Protocol protocol) + { +- ch.pipeline().get( MinecraftDecoder.class ).setProtocol( protocol ); +- ch.pipeline().get( MinecraftEncoder.class ).setProtocol( protocol ); ++ // FlameCord - Use pipeline to reduce redundancy ++ final ChannelPipeline pipeline = ch.pipeline(); ++ pipeline.get( MinecraftDecoder.class ).setProtocol( protocol ); ++ pipeline.get( MinecraftEncoder.class ).setProtocol( protocol ); + } + + public void setVersion(int protocol) + { +- ch.pipeline().get( MinecraftDecoder.class ).setProtocolVersion( protocol ); +- ch.pipeline().get( MinecraftEncoder.class ).setProtocolVersion( protocol ); ++ // FlameCord - Use pipeline to reduce redundancy ++ final ChannelPipeline pipeline = ch.pipeline(); ++ pipeline.get( MinecraftDecoder.class ).setProtocolVersion( protocol ); ++ pipeline.get( MinecraftEncoder.class ).setProtocolVersion( protocol ); + } + + public void write(Object packet) +-- +2.20.1 + diff --git a/Waterfall-Proxy-Patches/0015-FlameCord-General-Patch.patch b/Waterfall-Proxy-Patches/0019-FlameCord-General-Patch.patch similarity index 88% rename from Waterfall-Proxy-Patches/0015-FlameCord-General-Patch.patch rename to Waterfall-Proxy-Patches/0019-FlameCord-General-Patch.patch index f84c150..4c4da2e 100644 --- a/Waterfall-Proxy-Patches/0015-FlameCord-General-Patch.patch +++ b/Waterfall-Proxy-Patches/0019-FlameCord-General-Patch.patch @@ -1,4 +1,4 @@ -From 1c6e0cad8181bf4807db81ddbbab9935245d593d Mon Sep 17 00:00:00 2001 +From aef48f2c46615cf285d05112a25300ee47475d81 Mon Sep 17 00:00:00 2001 From: Juan Cruz Linsalata Date: Mon, 12 Oct 2020 15:40:53 -0300 Subject: [PATCH] FlameCord General Patch @@ -898,39 +898,8 @@ index 6cc520c9..7c4c8f8a 100644 } b.connect().addListener( listener ); } -diff --git a/proxy/src/main/java/net/md_5/bungee/connection/DownstreamBridge.java b/proxy/src/main/java/net/md_5/bungee/connection/DownstreamBridge.java -index 1be39af0..474551d3 100644 ---- a/proxy/src/main/java/net/md_5/bungee/connection/DownstreamBridge.java -+++ b/proxy/src/main/java/net/md_5/bungee/connection/DownstreamBridge.java -@@ -539,18 +539,21 @@ public class DownstreamBridge extends PacketHandler - out.writeUTF( player.getUUID() ); - } - } -- if ( subChannel.equals( "ServerIP" ) ) -+ else if ( subChannel.equals( "ServerIP" ) ) - { - ServerInfo info = bungee.getServerInfo( in.readUTF() ); -- if ( info != null && !info.getAddress().isUnresolved() ) -+ // FlameCord use address -+ InetSocketAddress address = info.getAddress(); -+ if ( info != null && !address.isUnresolved() ) - { - out.writeUTF( "ServerIP" ); - out.writeUTF( info.getName() ); -- out.writeUTF( info.getAddress().getAddress().getHostAddress() ); -- out.writeShort( info.getAddress().getPort() ); -+ // FlameCord - Use getHostString -+ out.writeUTF( address.getHostString() ); -+ out.writeShort( address.getPort() ); - } - } -- if ( subChannel.equals( "KickPlayer" ) ) -+ else if ( subChannel.equals( "KickPlayer" ) ) - { - ProxiedPlayer player = bungee.getPlayer( in.readUTF() ); - if ( player != null ) diff --git a/proxy/src/main/java/net/md_5/bungee/connection/InitialHandler.java b/proxy/src/main/java/net/md_5/bungee/connection/InitialHandler.java -index 3e7f6d00..138dffa0 100644 +index 1f5492fb..138dffa0 100644 --- a/proxy/src/main/java/net/md_5/bungee/connection/InitialHandler.java +++ b/proxy/src/main/java/net/md_5/bungee/connection/InitialHandler.java @@ -19,6 +19,8 @@ import com.google.gson.Gson; @@ -985,40 +954,7 @@ index 3e7f6d00..138dffa0 100644 { bungee.getLogger().log( Level.INFO, "{0} has connected", this ); } -@@ -407,13 +418,16 @@ public class InitialHandler extends PacketHandler implements PendingConnection - Preconditions.checkState( thisState == State.USERNAME, "Not expecting USERNAME" ); - this.loginRequest = loginRequest; - -- if ( getName().contains( "." ) ) -+ // FlameCord - Use name -+ final String name = getName(); -+ -+ if ( name.contains( "." ) ) - { - disconnect( bungee.getTranslation( "name_invalid" ) ); - return; - } - -- if ( getName().length() > 16 ) -+ if ( name.length() > 16 ) - { - disconnect( bungee.getTranslation( "name_too_long" ) ); - return; -@@ -452,11 +466,12 @@ public class InitialHandler extends PacketHandler implements PendingConnection - if ( onlineMode ) - { - unsafe().sendPacket( request = EncryptionUtil.encryptRequest() ); -+ // FlameCord - Change state to encrypt only if onlineMode is true -+ thisState = State.ENCRYPT; - } else - { - finish(); - } -- thisState = State.ENCRYPT; - } - }; - -@@ -468,6 +483,8 @@ public class InitialHandler extends PacketHandler implements PendingConnection +@@ -472,6 +483,8 @@ public class InitialHandler extends PacketHandler implements PendingConnection public void handle(final EncryptionResponse encryptResponse) throws Exception { Preconditions.checkState( thisState == State.ENCRYPT, "Not expecting ENCRYPT" ); @@ -1027,7 +963,7 @@ index 3e7f6d00..138dffa0 100644 SecretKey sharedKey = EncryptionUtil.getSecret( encryptResponse, request ); BungeeCipher decrypt = EncryptionUtil.getCipher( false, sharedKey ); -@@ -502,7 +519,10 @@ public class InitialHandler extends PacketHandler implements PendingConnection +@@ -506,7 +519,10 @@ public class InitialHandler extends PacketHandler implements PendingConnection { loginProfile = obj; name = obj.getName(); @@ -1039,7 +975,7 @@ index 3e7f6d00..138dffa0 100644 finish(); return; } -@@ -520,6 +540,9 @@ public class InitialHandler extends PacketHandler implements PendingConnection +@@ -524,6 +540,9 @@ public class InitialHandler extends PacketHandler implements PendingConnection private void finish() { @@ -1049,7 +985,7 @@ index 3e7f6d00..138dffa0 100644 if ( isOnlineMode() ) { // Check for multiple connections -@@ -601,8 +624,6 @@ public class InitialHandler extends PacketHandler implements PendingConnection +@@ -605,8 +624,6 @@ public class InitialHandler extends PacketHandler implements PendingConnection } userCon.connect( server, null, true, ServerConnectEvent.Reason.JOIN_PROXY ); @@ -1058,17 +994,7 @@ index 3e7f6d00..138dffa0 100644 } } } ); -@@ -636,7 +657,8 @@ public class InitialHandler extends PacketHandler implements PendingConnection - { - if ( canSendKickMessage() ) - { -- ch.delayedClose( new Kick( ComponentSerializer.toString( reason ) ) ); -+ // FlameCord - Changed delayedClose to close -+ ch.close( new Kick( ComponentSerializer.toString( reason ) ) ); - } else - { - ch.close(); -@@ -693,7 +715,7 @@ public class InitialHandler extends PacketHandler implements PendingConnection +@@ -698,7 +715,7 @@ public class InitialHandler extends PacketHandler implements PendingConnection public void setUniqueId(UUID uuid) { Preconditions.checkState( thisState == State.USERNAME, "Can only set uuid while state is username" ); @@ -1114,90 +1040,10 @@ index 6cd71071..09909bd9 100644 } diff --git a/proxy/src/main/java/net/md_5/bungee/netty/ChannelWrapper.java b/proxy/src/main/java/net/md_5/bungee/netty/ChannelWrapper.java -index 6dc5633f..606866a5 100644 +index f9493ff0..606866a5 100644 --- a/proxy/src/main/java/net/md_5/bungee/netty/ChannelWrapper.java +++ b/proxy/src/main/java/net/md_5/bungee/netty/ChannelWrapper.java -@@ -5,6 +5,8 @@ import io.netty.channel.Channel; - import io.netty.channel.ChannelFutureListener; - import io.netty.channel.ChannelHandler; - import io.netty.channel.ChannelHandlerContext; -+import io.netty.channel.ChannelPipeline; -+ - import java.net.SocketAddress; - import java.util.concurrent.TimeUnit; - import lombok.Getter; -@@ -37,14 +39,18 @@ public class ChannelWrapper - - public void setProtocol(Protocol protocol) - { -- ch.pipeline().get( MinecraftDecoder.class ).setProtocol( protocol ); -- ch.pipeline().get( MinecraftEncoder.class ).setProtocol( protocol ); -+ // FlameCord - Use pipeline to reduce redundancy -+ final ChannelPipeline pipeline = ch.pipeline(); -+ pipeline.get( MinecraftDecoder.class ).setProtocol( protocol ); -+ pipeline.get( MinecraftEncoder.class ).setProtocol( protocol ); - } - - public void setVersion(int protocol) - { -- ch.pipeline().get( MinecraftDecoder.class ).setProtocolVersion( protocol ); -- ch.pipeline().get( MinecraftEncoder.class ).setProtocolVersion( protocol ); -+ // FlameCord - Use pipeline to reduce redundancy -+ final ChannelPipeline pipeline = ch.pipeline(); -+ pipeline.get( MinecraftDecoder.class ).setProtocolVersion( protocol ); -+ pipeline.get( MinecraftEncoder.class ).setProtocolVersion( protocol ); - } - - public void write(Object packet) -@@ -80,40 +86,27 @@ public class ChannelWrapper - - if ( packet != null && ch.isActive() ) - { -- ch.writeAndFlush( packet ).addListeners( ChannelFutureListener.FIRE_EXCEPTION_ON_FAILURE, ChannelFutureListener.CLOSE ); -+ // FlameCord - Remove the firing of exceptions on failure -+ ch.writeAndFlush( packet ).addListeners( ChannelFutureListener.CLOSE ); - } else - { -- ch.flush(); -+ // FlameCord - Don't flush just close - ch.close(); - } - } - } - -+ // FlameCord - Deprecate and "disable" delayedClose because it doesn't have a reason to exist -+ @Deprecated - public void delayedClose(final Kick kick) - { -- if ( !closing ) -- { -- closing = true; -- -- // Minecraft client can take some time to switch protocols. -- // Sending the wrong disconnect packet whilst a protocol switch is in progress will crash it. -- // Delay 250ms to ensure that the protocol switch (if any) has definitely taken place. -- ch.eventLoop().schedule( new Runnable() -- { -- -- @Override -- public void run() -- { -- close( kick ); -- } -- }, 250, TimeUnit.MILLISECONDS ); -- } -+ close(kick); - } - - public void addBefore(String baseName, String name, ChannelHandler handler) - { - Preconditions.checkState( ch.eventLoop().inEventLoop(), "cannot add handler outside of event loop" ); -- ch.pipeline().flush(); -+ // FlameCord - Don't flush if not necessary - ch.pipeline().addBefore( baseName, name, handler ); - } - -@@ -124,25 +117,27 @@ public class ChannelWrapper +@@ -117,25 +117,27 @@ public class ChannelWrapper public void setCompressionThreshold(int compressionThreshold) {