diff options
author | MiniDigger | Martin <[email protected]> | 2024-01-14 11:04:49 +0100 |
---|---|---|
committer | MiniDigger | Martin <[email protected]> | 2024-01-14 11:04:49 +0100 |
commit | bee74680e607c2e29b038329f62181238911cd83 (patch) | |
tree | 708fd1a4a0227d9071243adf2a42d5e9e96cde4a /patch-remap/og/net/minecraft/server/network/ServerConnection.patch | |
parent | 0a44692ef6ff6e255d48eb3ba1bb114166eafda9 (diff) | |
download | Paper-softspoon.tar.gz Paper-softspoon.zip |
add remapped patches as a testsoftspoon
Diffstat (limited to 'patch-remap/og/net/minecraft/server/network/ServerConnection.patch')
-rw-r--r-- | patch-remap/og/net/minecraft/server/network/ServerConnection.patch | 30 |
1 files changed, 30 insertions, 0 deletions
diff --git a/patch-remap/og/net/minecraft/server/network/ServerConnection.patch b/patch-remap/og/net/minecraft/server/network/ServerConnection.patch new file mode 100644 index 0000000000..1108bf2026 --- /dev/null +++ b/patch-remap/og/net/minecraft/server/network/ServerConnection.patch @@ -0,0 +1,30 @@ +--- a/net/minecraft/server/network/ServerConnection.java ++++ b/net/minecraft/server/network/ServerConnection.java +@@ -98,15 +98,25 @@ + + NetworkManager.configureSerialization(channelpipeline, EnumProtocolDirection.SERVERBOUND, (BandwidthDebugMonitor) null); + int j = ServerConnection.this.server.getRateLimitPacketsPerSecond(); +- Object object = j > 0 ? new NetworkManagerServer(j) : new NetworkManager(EnumProtocolDirection.SERVERBOUND); ++ NetworkManager object = j > 0 ? new NetworkManagerServer(j) : new NetworkManager(EnumProtocolDirection.SERVERBOUND); // CraftBukkit - decompile error + + ServerConnection.this.connections.add(object); + ((NetworkManager) object).configurePacketHandler(channelpipeline); + ((NetworkManager) object).setListenerForServerboundHandshake(new HandshakeListener(ServerConnection.this.server, (NetworkManager) object)); + } +- }).group(eventloopgroup).localAddress(inetaddress, i)).bind().syncUninterruptibly()); ++ }).group(eventloopgroup).localAddress(inetaddress, i)).option(ChannelOption.AUTO_READ, false).bind().syncUninterruptibly()); // CraftBukkit ++ } ++ } ++ ++ // CraftBukkit start ++ public void acceptConnections() { ++ synchronized (this.channels) { ++ for (ChannelFuture future : this.channels) { ++ future.channel().config().setAutoRead(true); ++ } + } + } ++ // CraftBukkit end + + public SocketAddress startMemoryChannel() { + List list = this.channels; |