diff --git a/patches/server/Moonrise-optimisation-patches.patch b/patches/server/Moonrise-optimisation-patches.patch index c6bf9b2851..60b27cbf9b 100644 --- a/patches/server/Moonrise-optimisation-patches.patch +++ b/patches/server/Moonrise-optimisation-patches.patch @@ -346,6 +346,59 @@ diff --git a/src/main/java/ca/spottedleaf/moonrise/common/util/TickThread.java b index 0000000000000000000000000000000000000000..0000000000000000000000000000000000000000 100644 --- a/src/main/java/ca/spottedleaf/moonrise/common/util/TickThread.java +++ b/src/main/java/ca/spottedleaf/moonrise/common/util/TickThread.java +@@ -0,0 +0,0 @@ + package ca.spottedleaf.moonrise.common.util; + + import net.minecraft.core.BlockPos; +-import net.minecraft.server.level.ServerLevel; + import net.minecraft.world.entity.Entity; + import net.minecraft.world.level.ChunkPos; ++import net.minecraft.world.level.Level; + import net.minecraft.world.phys.AABB; + import net.minecraft.world.phys.Vec3; + import org.slf4j.Logger; +@@ -0,0 +0,0 @@ public class TickThread extends Thread { + } + } + +- public static void ensureTickThread(final ServerLevel world, final BlockPos pos, final String reason) { ++ public static void ensureTickThread(final Level world, final BlockPos pos, final String reason) { + if (!isTickThreadFor(world, pos)) { + LOGGER.error("Thread " + Thread.currentThread().getName() + " failed main thread check: " + reason, new Throwable()); + throw new IllegalStateException(reason); + } + } + +- public static void ensureTickThread(final ServerLevel world, final ChunkPos pos, final String reason) { ++ public static void ensureTickThread(final Level world, final ChunkPos pos, final String reason) { + if (!isTickThreadFor(world, pos)) { + LOGGER.error("Thread " + Thread.currentThread().getName() + " failed main thread check: " + reason, new Throwable()); + throw new IllegalStateException(reason); + } + } + +- public static void ensureTickThread(final ServerLevel world, final int chunkX, final int chunkZ, final String reason) { ++ public static void ensureTickThread(final Level world, final int chunkX, final int chunkZ, final String reason) { + if (!isTickThreadFor(world, chunkX, chunkZ)) { + LOGGER.error("Thread " + Thread.currentThread().getName() + " failed main thread check: " + reason, new Throwable()); + throw new IllegalStateException(reason); +@@ -0,0 +0,0 @@ public class TickThread extends Thread { + } + } + +- public static void ensureTickThread(final ServerLevel world, final AABB aabb, final String reason) { ++ public static void ensureTickThread(final Level world, final AABB aabb, final String reason) { + if (!isTickThreadFor(world, aabb)) { + LOGGER.error("Thread " + Thread.currentThread().getName() + " failed main thread check: " + reason, new Throwable()); + throw new IllegalStateException(reason); + } + } + +- public static void ensureTickThread(final ServerLevel world, final double blockX, final double blockZ, final String reason) { ++ public static void ensureTickThread(final Level world, final double blockX, final double blockZ, final String reason) { + if (!isTickThreadFor(world, blockX, blockZ)) { + LOGGER.error("Thread " + Thread.currentThread().getName() + " failed main thread check: " + reason, new Throwable()); + throw new IllegalStateException(reason); @@ -0,0 +0,0 @@ public class TickThread extends Thread { } @@ -355,6 +408,54 @@ index 0000000000000000000000000000000000000000..00000000000000000000000000000000 } public static boolean isShutdownThread() { + return false; + } + +- public static boolean isTickThreadFor(final ServerLevel world, final BlockPos pos) { ++ public static boolean isTickThreadFor(final Level world, final BlockPos pos) { + return isTickThread(); + } + +- public static boolean isTickThreadFor(final ServerLevel world, final ChunkPos pos) { ++ public static boolean isTickThreadFor(final Level world, final ChunkPos pos) { + return isTickThread(); + } + +- public static boolean isTickThreadFor(final ServerLevel world, final Vec3 pos) { ++ public static boolean isTickThreadFor(final Level world, final Vec3 pos) { + return isTickThread(); + } + +- public static boolean isTickThreadFor(final ServerLevel world, final int chunkX, final int chunkZ) { ++ public static boolean isTickThreadFor(final Level world, final int chunkX, final int chunkZ) { + return isTickThread(); + } + +- public static boolean isTickThreadFor(final ServerLevel world, final AABB aabb) { ++ public static boolean isTickThreadFor(final Level world, final AABB aabb) { + return isTickThread(); + } + +- public static boolean isTickThreadFor(final ServerLevel world, final double blockX, final double blockZ) { ++ public static boolean isTickThreadFor(final Level world, final double blockX, final double blockZ) { + return isTickThread(); + } + +- public static boolean isTickThreadFor(final ServerLevel world, final Vec3 position, final Vec3 deltaMovement, final int buffer) { ++ public static boolean isTickThreadFor(final Level world, final Vec3 position, final Vec3 deltaMovement, final int buffer) { + return isTickThread(); + } + +- public static boolean isTickThreadFor(final ServerLevel world, final int fromChunkX, final int fromChunkZ, final int toChunkX, final int toChunkZ) { ++ public static boolean isTickThreadFor(final Level world, final int fromChunkX, final int fromChunkZ, final int toChunkX, final int toChunkZ) { + return isTickThread(); + } + +- public static boolean isTickThreadFor(final ServerLevel world, final int chunkX, final int chunkZ, final int radius) { ++ public static boolean isTickThreadFor(final Level world, final int chunkX, final int chunkZ, final int radius) { + return isTickThread(); + } + diff --git a/src/main/java/ca/spottedleaf/moonrise/patches/block_counting/BlockCountingBitStorage.java b/src/main/java/ca/spottedleaf/moonrise/patches/block_counting/BlockCountingBitStorage.java new file mode 100644 index 0000000000000000000000000000000000000000..0000000000000000000000000000000000000000 @@ -7844,7 +7945,9 @@ index 0000000000000000000000000000000000000000..00000000000000000000000000000000 + public void scheduleTickingState(final int chunkX, final int chunkZ, final FullChunkStatus toStatus, + final boolean addTicket, final PrioritisedExecutor.Priority priority, + final Consumer onComplete) { -+ if (!TickThread.isTickThread()) { ++ final int radius = toStatus.ordinal() - 1; // 0 -> BORDER, 1 -> TICKING, 2 -> ENTITY_TICKING ++ ++ if (!TickThread.isTickThreadFor(this.world, chunkX, chunkZ, Math.max(0, radius))) { + this.scheduleChunkTask(chunkX, chunkZ, () -> { + ChunkTaskScheduler.this.scheduleTickingState(chunkX, chunkZ, toStatus, addTicket, priority, onComplete); + }, priority); @@ -7871,7 +7974,7 @@ index 0000000000000000000000000000000000000000..00000000000000000000000000000000 + this.chunkHolderManager.processTicketUpdates(); + } + -+ final Consumer loadCallback = (final LevelChunk chunk) -> { ++ final Consumer loadCallback = onComplete == null && !addTicket ? null : (final LevelChunk chunk) -> { + try { + if (onComplete != null) { + onComplete.accept(chunk); @@ -7902,7 +8005,6 @@ index 0000000000000000000000000000000000000000..00000000000000000000000000000000 + scheduled = true; + chunk = null; + -+ final int radius = toStatus.ordinal() - 1; // 0 -> BORDER, 1 -> TICKING, 2 -> ENTITY_TICKING + for (int dz = -radius; dz <= radius; ++dz) { + for (int dx = -radius; dx <= radius; ++dx) { + final NewChunkHolder neighbour = @@ -7914,7 +8016,9 @@ index 0000000000000000000000000000000000000000..00000000000000000000000000000000 + } + + // ticket level should schedule for us -+ chunkHolder.addFullStatusConsumer(toStatus, loadCallback); ++ if (loadCallback != null) { ++ chunkHolder.addFullStatusConsumer(toStatus, loadCallback); ++ } + } + } + } finally { @@ -7924,7 +8028,7 @@ index 0000000000000000000000000000000000000000..00000000000000000000000000000000 + this.chunkHolderManager.ticketLockArea.unlock(ticketLock); + } + -+ if (!scheduled) { ++ if (loadCallback != null && !scheduled) { + // couldn't schedule + try { + loadCallback.accept(chunk); @@ -8035,7 +8139,7 @@ index 0000000000000000000000000000000000000000..00000000000000000000000000000000 + + public void scheduleChunkLoad(final int chunkX, final int chunkZ, final ChunkStatus toStatus, final boolean addTicket, + final PrioritisedExecutor.Priority priority, final Consumer onComplete) { -+ if (!TickThread.isTickThread()) { ++ if (!TickThread.isTickThreadFor(this.world, chunkX, chunkZ)) { + this.scheduleChunkTask(chunkX, chunkZ, () -> { + ChunkTaskScheduler.this.scheduleChunkLoad(chunkX, chunkZ, toStatus, addTicket, priority, onComplete); + }, priority); @@ -8307,7 +8411,7 @@ index 0000000000000000000000000000000000000000..00000000000000000000000000000000 + } + + public PrioritisedExecutor.PrioritisedTask scheduleChunkTask(final int chunkX, final int chunkZ, final Runnable run) { -+ return this.mainThreadExecutor.queueRunnable(run); ++ return this.scheduleChunkTask(chunkX, chunkZ, run, PrioritisedExecutor.Priority.NORMAL); + } + + public PrioritisedExecutor.PrioritisedTask scheduleChunkTask(final int chunkX, final int chunkZ, final Runnable run,