Update network/protocol subs & more closely simulate client MTU decre…

…ment Signed-off-by: Joshua Castle <[email protected]>
Kas-tle · May 4, 2024 · d842c08 · d842c08
1 parent fca5b78
commit d842c08
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 2 deletions.
diff --git a/network b/network
diff --git a/protocol b/protocol
diff --git a/src/main/java/org/cloudburstmc/proxypass/ProxyPass.java b/src/main/java/org/cloudburstmc/proxypass/ProxyPass.java
@@ -24,6 +24,7 @@
 import org.cloudburstmc.nbt.*;
 import org.cloudburstmc.netty.channel.raknet.RakChannelFactory;
 import org.cloudburstmc.netty.channel.raknet.config.RakChannelOption;
+import org.cloudburstmc.netty.handler.codec.raknet.server.RakServerRateLimiter;
 import org.cloudburstmc.protocol.bedrock.BedrockPeer;
 import org.cloudburstmc.protocol.bedrock.BedrockPong;
 import org.cloudburstmc.protocol.bedrock.codec.BedrockCodec;
@@ -215,6 +216,7 @@ protected void initSession(ProxyServerSession session) {
                 .bind(this.proxyAddress)
                 .awaitUninterruptibly()
                 .channel();
+        this.server.pipeline().remove(RakServerRateLimiter.NAME);
         log.info("Bedrock server started on {}", proxyAddress);
 
         loop();
@@ -226,6 +228,7 @@ public void newClient(InetSocketAddress socketAddress, Consumer<ProxyClientSessi
                 .channelFactory(RakChannelFactory.client(NioDatagramChannel.class))
                 .option(RakChannelOption.RAK_PROTOCOL_VERSION, ProxyPass.CODEC.getRaknetProtocolVersion())
                 .option(RakChannelOption.RAK_COMPATIBILITY_MODE, true)
+                .option(RakChannelOption.RAK_MTU, 1492)
                 .handler(new BedrockChannelInitializer<ProxyClientSession>() {
 
                     @Override