Hotfix - timings close GH-74 w/ chunk sending
This commit is contained in:
@@ -927,7 +927,7 @@ public abstract class MinecraftServer implements IAsyncTaskHandler, IMojangStati
|
||||
public void t() {}
|
||||
|
||||
protected void a(BooleanSupplier booleansupplier) {
|
||||
co.aikar.timings.TimingsManager.FULL_SERVER_TICK.startTimingUnsafe(); // Paper // Akarin
|
||||
co.aikar.timings.TimingsManager.FULL_SERVER_TICK.startTiming(); // Paper // Akarin
|
||||
this.slackActivityAccountant.tickStarted(); // Spigot
|
||||
long i = SystemUtils.getMonotonicNanos(); long startTime = i; // Paper
|
||||
|
||||
@@ -998,7 +998,7 @@ public abstract class MinecraftServer implements IAsyncTaskHandler, IMojangStati
|
||||
PaperLightingQueue.processQueue(startTime); // Paper
|
||||
expiringMaps.removeIf(ExpiringMap::clean); // Paper
|
||||
this.slackActivityAccountant.tickEnded(l); // Spigot
|
||||
co.aikar.timings.TimingsManager.FULL_SERVER_TICK.stopTimingUnsafe(); // Paper // Akarin
|
||||
co.aikar.timings.TimingsManager.FULL_SERVER_TICK.stopTiming(); // Paper // Akarin
|
||||
}
|
||||
|
||||
public void b(BooleanSupplier booleansupplier) {
|
||||
|
||||
@@ -249,7 +249,7 @@ public class NetworkManager extends SimpleChannelInboundHandler<Packet<?>> {
|
||||
// Akarin start
|
||||
private final void dispatchPacket(Packet<?> packet, @Nullable GenericFutureListener<? extends Future<? super Void>> genericFutureListener) { this.b(packet, genericFutureListener); } // Paper - OBFHELPER
|
||||
private final void b(Packet<?> packet, @Nullable GenericFutureListener<? extends Future<? super Void>> genericfuturelistener) {
|
||||
if (!packet.canDispatchImmediately() && packet.getType() == PacketType.PLAY_OUT_MAP_CHUNK) {
|
||||
if (!packet.canDispatchImmediately()) {
|
||||
this.pendingChunkQueue.add((PacketPlayOutMapChunk) packet);
|
||||
return;
|
||||
}
|
||||
@@ -348,7 +348,7 @@ public class NetworkManager extends SimpleChannelInboundHandler<Packet<?>> {
|
||||
// Paper end
|
||||
|
||||
public void a() {
|
||||
//this.o(); // Akarin - remove packet queue
|
||||
this.o();
|
||||
if (this.packetListener instanceof ITickable) {
|
||||
((ITickable) this.packetListener).tick();
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user