Upstream/Minestom
1
0
Fork 0
mirror of https://github.com/Minestom/Minestom.git synced 2025-01-02 22:47:49 +01:00
Code Issues Projects Releases Wiki Activity

Cleanup

Browse Source
This commit is contained in:
TheMode 2021-08-25 10:45:35 +02:00
parent 2ae0c0bbcd
commit 5e18f48a1b
1 changed files with 14 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -244,26 +244,20 @@ public final class PacketUtils {
} }
private synchronized void append(PlayerConnection playerConnection, ServerPacket serverPacket) { private synchronized void append(PlayerConnection playerConnection, ServerPacket serverPacket) {
final boolean hasConnection = playerConnection != null;
var entityIdMap = entry.entityIdMap;
BinaryBuffer buffer = entry.buffer; BinaryBuffer buffer = entry.buffer;
final ByteBuffer framedPacket = createFramedPacket(serverPacket).flip();
if (!buffer.canWrite(framedPacket.limit())) process();
final int start = buffer.writerOffset(); final int start = buffer.writerOffset();
final ByteBuffer framedPacket = createFramedPacket(serverPacket); buffer.write(framedPacket);
buffer.write(framedPacket.flip());
final int end = buffer.writerOffset(); final int end = buffer.writerOffset();
if (playerConnection != null) {
if (hasConnection) { List<IntIntPair> list = entry.entityIdMap.computeIfAbsent(playerConnection, playerConnection1 -> new ArrayList<>());
List<IntIntPair> list = entityIdMap.computeIfAbsent(playerConnection, playerConnection1 -> new ArrayList<>());
list.add(IntIntPair.of(start, end)); list.add(IntIntPair.of(start, end));
} }
} }
private synchronized void process() { private synchronized void process() {
final var entityIdMap = entry.entityIdMap;
BinaryBuffer buffer = entry.buffer; BinaryBuffer buffer = entry.buffer;
final int readable = buffer.readableBytes();
final Set<Player> viewers = viewable.getViewers(); final Set<Player> viewers = viewable.getViewers();
if (viewers.isEmpty()) return; if (viewers.isEmpty()) return;
@ -275,39 +269,39 @@ public final class PacketUtils {
// TODO for non-socket connection // TODO for non-socket connection
}; };
final List<IntIntPair> pairs = entityIdMap.get(connection); final List<IntIntPair> pairs = entry.entityIdMap.get(connection);
if (pairs != null) { if (pairs != null) {
// Player should not be sent at least one packet, ignore ranges
int lastWrite = 0; int lastWrite = 0;
for (var pair : pairs) { for (IntIntPair pair : pairs) {
final int start = pair.leftInt(); final int start = pair.leftInt();
final int end = pair.rightInt();
if (start > lastWrite) { if (start > lastWrite) {
ByteBuffer slice = buffer.asByteBuffer(lastWrite, start); ByteBuffer slice = buffer.asByteBuffer(lastWrite, start);
slice.position(slice.limit()); slice.position(slice.limit());
writer.accept(slice); writer.accept(slice);
} }
lastWrite = end; lastWrite = pair.rightInt();
} }
// Write remaining // Write remaining
final int remaining = readable - lastWrite; final int remaining = buffer.writerOffset() - lastWrite;
if (remaining > 0) { if (remaining > 0) {
ByteBuffer remainSlice = buffer.asByteBuffer(lastWrite, remaining); ByteBuffer remainSlice = buffer.asByteBuffer(lastWrite, remaining);
remainSlice.position(remaining); remainSlice.position(remaining);
writer.accept(remainSlice); writer.accept(remainSlice);
} }
} else { } else {
// Send full buffer
ByteBuffer result = buffer.asByteBuffer(0, buffer.writerOffset()); ByteBuffer result = buffer.asByteBuffer(0, buffer.writerOffset());
result.position(result.limit()); result.position(result.limit());
writer.accept(result); writer.accept(result);
} }
} }
this.entry.reset(); this.entry.reset();
} }
private static class Entry { private static class Entry {
Map<PlayerConnection, List<IntIntPair>> entityIdMap = new ConcurrentHashMap<>(); private final Map<PlayerConnection, List<IntIntPair>> entityIdMap = new ConcurrentHashMap<>();
BinaryBuffer buffer = BinaryBuffer.ofSize(Server.SOCKET_BUFFER_SIZE); private final BinaryBuffer buffer = BinaryBuffer.ofSize(Server.SOCKET_BUFFER_SIZE);
void reset() { void reset() {
this.entityIdMap.clear(); this.entityIdMap.clear();
@ -333,6 +327,7 @@ public final class PacketUtils {
} }
public static void flush() { public static void flush() {
// TODO clear map
for (ViewableStorage viewableStorage : VIEWABLE_STORAGE_MAP.values()) { for (ViewableStorage viewableStorage : VIEWABLE_STORAGE_MAP.values()) {
viewableStorage.process(); viewableStorage.process();
} }