diff --git a/src/main/java/net/minestom/server/network/netty/NettyServer.java b/src/main/java/net/minestom/server/network/netty/NettyServer.java index 35044129d..e1ffef012 100644 --- a/src/main/java/net/minestom/server/network/netty/NettyServer.java +++ b/src/main/java/net/minestom/server/network/netty/NettyServer.java @@ -65,6 +65,7 @@ public class NettyServer { protected void initChannel(@NotNull SocketChannel ch) { ChannelConfig config = ch.config(); config.setOption(ChannelOption.TCP_NODELAY, true); + config.setOption(ChannelOption.SO_SNDBUF, 1_000_000); ChannelPipeline pipeline = ch.pipeline(); diff --git a/src/main/java/net/minestom/server/network/player/NettyPlayerConnection.java b/src/main/java/net/minestom/server/network/player/NettyPlayerConnection.java index fdb21f9ac..c5f3c5922 100644 --- a/src/main/java/net/minestom/server/network/player/NettyPlayerConnection.java +++ b/src/main/java/net/minestom/server/network/player/NettyPlayerConnection.java @@ -101,9 +101,9 @@ public class NettyPlayerConnection extends PlayerConnection { public void sendPacket(@NotNull ServerPacket serverPacket) { if (shouldSendPacket(serverPacket)) { if (getPlayer() != null) { - channel.write(serverPacket); // Flush on player update + this.channel.write(serverPacket); // Flush on player update } else { - channel.writeAndFlush(serverPacket); + this.channel.writeAndFlush(serverPacket); } } }