Upstream/Minestom
1
0
Fork 0
mirror of https://github.com/Minestom/Minestom.git synced 2024-12-26 02:57:37 +01:00
Code Issues Projects Releases Wiki Activity

Fix synchronization issue with viewable packets

Browse Source
This commit is contained in:
themode 2022-02-05 08:21:19 +01:00
parent 0934c8ef16
commit 2e02dfd4d8
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/net/minestom/server/utils/PacketUtils.java
View File

@ -284,7 +284,7 @@ public final class PacketUtils {
PooledBuffers.registerBuffer(this, buffer); PooledBuffers.registerBuffer(this, buffer);
} }
private void append(Viewable viewable, ServerPacket serverPacket, Player player) { private synchronized void append(Viewable viewable, ServerPacket serverPacket, Player player) {
final ByteBuffer framedPacket = createFramedPacket(serverPacket); final ByteBuffer framedPacket = createFramedPacket(serverPacket);
final int packetSize = framedPacket.limit(); final int packetSize = framedPacket.limit();
if (packetSize >= buffer.capacity()) { if (packetSize >= buffer.capacity()) {
@ -307,7 +307,7 @@ public final class PacketUtils {
} }
} }
private void process(Viewable viewable) { private synchronized void process(Viewable viewable) {
if (buffer.writerOffset() == 0) return; if (buffer.writerOffset() == 0) return;
ByteBuffer copy = ByteBuffer.allocateDirect(buffer.writerOffset()); ByteBuffer copy = ByteBuffer.allocateDirect(buffer.writerOffset());
copy.put(buffer.asByteBuffer(0, copy.capacity())); copy.put(buffer.asByteBuffer(0, copy.capacity()));