Upstream/Minestom
1
0
Fork 0
mirror of https://github.com/Minestom/Minestom.git synced 2025-01-21 15:41:38 +01:00
Code Issues Projects Releases Wiki Activity

Reuse flush method

Browse Source
This commit is contained in:
TheMode 2021-08-05 01:10:03 +02:00
parent 58487f4455
commit eb43dc0cc0
1 changed files with 10 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
src/main/java/net/minestom/server/network/player/NettyPlayerConnection.java
View File

@ -198,17 +198,11 @@ public class NettyPlayerConnection extends PlayerConnection {
public void write(@NotNull ByteBuffer buffer) {
synchronized (tickBuffer) {
buffer.flip();
if (tickBuffer.remaining() >= buffer.remaining()) {
// Enough buffer space
this.tickBuffer.put(buffer);
} else {
try {
this.channel.write(tickBuffer.flip());
this.tickBuffer.clear().put(buffer);
} catch (IOException ex) {
MinecraftServer.getExceptionManager().handleException(ex);
}
if (buffer.remaining() > tickBuffer.remaining()) {
// Tick buffer is full, flush before appending
flush();
}
this.tickBuffer.put(buffer);
}
}
@ -218,17 +212,13 @@ public class NettyPlayerConnection extends PlayerConnection {
public void write(@NotNull ServerPacket packet) {
synchronized (tickBuffer) {
final int position = tickBuffer.position();
this.tickBuffer.mark();
try {
PacketUtils.writeFramedPacket(tickBuffer, packet, compressed);
} catch (BufferOverflowException e) {
try {
this.channel.write(tickBuffer.position(position).flip());
this.tickBuffer.clear();
PacketUtils.writeFramedPacket(tickBuffer, packet, compressed);
} catch (IOException ex) {
MinecraftServer.getExceptionManager().handleException(ex);
}
this.tickBuffer.reset();
flush();
PacketUtils.writeFramedPacket(tickBuffer, packet, compressed);
}
}
}
@ -241,18 +231,15 @@ public class NettyPlayerConnection extends PlayerConnection {
}
public void flush() {
if (tickBuffer.position() == 0) {
// Nothing to write
return;
}
synchronized (tickBuffer) {
if (!channel.isOpen()) return;
if (tickBuffer.position() == 0) return;
try {
this.channel.write(tickBuffer.flip());
this.tickBuffer.clear();
} catch (IOException e) {
MinecraftServer.getExceptionManager().handleException(e);
} finally {
this.tickBuffer.clear();
}
}
}