From 0000000000000000000000000000000000000000 Mon Sep 17 00:00:00 2001 From: Aikar Date: Thu, 4 Jun 2020 22:43:29 -0400 Subject: [PATCH] Optimize Light Engine Massive update to light to improve performance and chunk loading/generation. 1) Massive bit packing/unpacking optimizations and inlining. A lot of performance has to do with constant packing and unpacking of bits. We now inline a most bit operations, and re-use base x/y/z bits in many places. This helps with cpu level processing to just do all the math at once instead of having to jump in and out of function calls. This much logic also is likely over the JVM Inline limit for JIT too. 2) Applied a few of JellySquid's Phosphor mod optimizations such as - ensuring we don't notify neighbor chunks when neighbor chunk doesn't need to be notified - reduce hasLight checks in initializing light, and prob some more, they are tagged JellySquid where phosphor influence was used. 3) Optimize hot path accesses to getting updating chunk to have less branching 4) Optimize getBlock accesses to have less branching, and less unpacking 5) Have a separate urgent bucket for chunk light tasks. These tasks will always cut in line over non blocking light tasks. 6) Retain chunk priority while light tasks are enqueued. So if a task comes in at high priority but the queue is full of tasks already at a lower priority, before the task was simply added to the end. Now it can cut in line to the front. this applies for both urgent and non urgent tasks. 7) Buffer non urgent tasks even if queueUpdate is called multiple times to improve efficiency. 8) Fix NPE risk that crashes server in getting nibble data diff --git a/src/main/java/net/minecraft/server/level/ChunkHolder.java b/src/main/java/net/minecraft/server/level/ChunkHolder.java index 8260636da673ef095728c208db2d6237bab2db19..9e3629884709126574a52ad44fe7523f01dbcce9 100644 --- a/src/main/java/net/minecraft/server/level/ChunkHolder.java +++ b/src/main/java/net/minecraft/server/level/ChunkHolder.java @@ -753,6 +753,7 @@ public class ChunkHolder { ioPriority = com.destroystokyo.paper.io.PrioritizedTaskQueue.HIGH_PRIORITY; } chunkMap.level.asyncChunkTaskManager.raisePriority(pos.x, pos.z, ioPriority); + chunkMap.level.getChunkSource().getLightEngine().queue.changePriority(pos.toLong(), getCurrentPriority(), priority); } if (getCurrentPriority() != priority) { this.onLevelChange.onLevelChange(this.pos, this::getCurrentPriority, priority, this::setPriority); // use preferred priority diff --git a/src/main/java/net/minecraft/server/level/ChunkMap.java b/src/main/java/net/minecraft/server/level/ChunkMap.java index acc566d14926dcf9e88f3e0837884e4c823d777c..f4dd30c8b3326db72d3b3068ee2291de6f15de7c 100644 --- a/src/main/java/net/minecraft/server/level/ChunkMap.java +++ b/src/main/java/net/minecraft/server/level/ChunkMap.java @@ -98,6 +98,7 @@ import net.minecraft.world.level.levelgen.structure.StructureStart; import net.minecraft.world.level.levelgen.structure.templatesystem.StructureManager; import net.minecraft.world.level.storage.DimensionDataStorage; import net.minecraft.world.level.storage.LevelStorageSource; +import net.minecraft.world.level.storage.PrimaryLevelData; import it.unimi.dsi.fastutil.objects.ObjectRBTreeSet; // Paper import org.apache.commons.lang3.mutable.MutableBoolean; import org.apache.logging.log4j.LogManager; @@ -328,6 +329,7 @@ public class ChunkMap extends ChunkStorage implements ChunkHolder.PlayerProvider } // Paper end + private final java.util.concurrent.ExecutorService lightThread; public ChunkMap(ServerLevel worldserver, LevelStorageSource.LevelStorageAccess convertable_conversionsession, DataFixer dataFixer, StructureManager definedstructuremanager, Executor workerExecutor, BlockableEventLoop mainThreadExecutor, LightChunkGetter chunkProvider, ChunkGenerator chunkGenerator, ChunkProgressListener worldGenerationProgressListener, Supplier supplier, int i, boolean flag) { super(new File(convertable_conversionsession.getDimensionPath(worldserver.dimension()), "region"), dataFixer, flag); //this.visibleChunks = this.updatingChunks.clone(); // Paper - no more cloning @@ -359,7 +361,15 @@ public class ChunkMap extends ChunkStorage implements ChunkHolder.PlayerProvider ProcessorHandle mailbox = ProcessorHandle.of("main", mainThreadExecutor::tell); this.progressListener = worldGenerationProgressListener; - ProcessorMailbox lightthreaded; ProcessorMailbox threadedmailbox1 = lightthreaded = ProcessorMailbox.create(workerExecutor, "light"); // Paper + // Paper start - use light thread + ProcessorMailbox lightthreaded; ProcessorMailbox threadedmailbox1 = lightthreaded = ProcessorMailbox.create(lightThread = java.util.concurrent.Executors.newSingleThreadExecutor(r -> { + Thread thread = new Thread(r); + thread.setName(((PrimaryLevelData)level.getLevelData()).getLevelName() + " - Light"); + thread.setDaemon(true); + thread.setPriority(Thread.NORM_PRIORITY+1); + return thread; + }), "light"); + // Paper end this.queueSorter = new ChunkTaskPriorityQueueSorter(ImmutableList.of(threadedmailbox, mailbox, threadedmailbox1), workerExecutor, Integer.MAX_VALUE); this.worldgenMailbox = this.queueSorter.getProcessor(threadedmailbox, false); @@ -705,6 +715,7 @@ public class ChunkMap extends ChunkStorage implements ChunkHolder.PlayerProvider // Paper end } + protected final IntSupplier getPrioritySupplier(long i) { return getChunkQueueLevel(i); } // Paper - OBFHELPER protected IntSupplier getChunkQueueLevel(long pos) { return () -> { ChunkHolder playerchunk = this.getVisibleChunkIfPresent(pos); @@ -832,6 +843,7 @@ public class ChunkMap extends ChunkStorage implements ChunkHolder.PlayerProvider @Override public void close() throws IOException { try { + this.lightThread.shutdown(); // Paper this.queueSorter.close(); this.level.asyncChunkTaskManager.close(true); // Paper - Required since we're closing regionfiles in the next line this.poiManager.close(); diff --git a/src/main/java/net/minecraft/server/level/SectionTracker.java b/src/main/java/net/minecraft/server/level/SectionTracker.java index 125ae965bb539ae24c60cb992eb7cfc35fd65b25..9fa6c290373b0e0cc0e7ed84c0c2363c8ad14dd3 100644 --- a/src/main/java/net/minecraft/server/level/SectionTracker.java +++ b/src/main/java/net/minecraft/server/level/SectionTracker.java @@ -1,6 +1,5 @@ package net.minecraft.server.level; -import net.minecraft.core.SectionPos; import net.minecraft.world.level.lighting.DynamicGraphMinFixedPoint; public abstract class SectionTracker extends DynamicGraphMinFixedPoint { @@ -16,14 +15,20 @@ public abstract class SectionTracker extends DynamicGraphMinFixedPoint { @Override protected void checkNeighborsAfterUpdate(long id, int level, boolean decrease) { + // Paper start + int x = (int) (id >> 42); + int y = (int) (id << 44 >> 44); + int z = (int) (id << 22 >> 42); + // Paper end for (int k = -1; k <= 1; ++k) { for (int l = -1; l <= 1; ++l) { for (int i1 = -1; i1 <= 1; ++i1) { - long j1 = SectionPos.offset(id, k, l, i1); + if (k == 0 && l == 0 && i1 == 0) continue; // Paper + long j1 = (((long) (x + k) & 4194303L) << 42) | (((long) (y + l) & 1048575L)) | (((long) (z + i1) & 4194303L) << 20); // Paper - if (j1 != id) { + //if (j1 != i) { // Paper - checked above this.checkNeighbor(id, j1, level, decrease); - } + //} // Paper } } } @@ -34,10 +39,15 @@ public abstract class SectionTracker extends DynamicGraphMinFixedPoint { protected int getComputedLevel(long id, long excludedId, int maxLevel) { int l = maxLevel; + // Paper start + int x = (int) (id >> 42); + int y = (int) (id << 44 >> 44); + int z = (int) (id << 22 >> 42); + // Paper end for (int i1 = -1; i1 <= 1; ++i1) { for (int j1 = -1; j1 <= 1; ++j1) { for (int k1 = -1; k1 <= 1; ++k1) { - long l1 = SectionPos.offset(id, i1, j1, k1); + long l1 = (((long) (x + i1) & 4194303L) << 42) | (((long) (y + j1) & 1048575L)) | (((long) (z + k1) & 4194303L) << 20); // Paper if (l1 == id) { l1 = Long.MAX_VALUE; diff --git a/src/main/java/net/minecraft/server/level/ServerChunkCache.java b/src/main/java/net/minecraft/server/level/ServerChunkCache.java index f36badcafbad7fb4537ffdf54d9e266ae3d72459..7a615a18f1f297adfe7e046407a019d8933e9ed9 100644 --- a/src/main/java/net/minecraft/server/level/ServerChunkCache.java +++ b/src/main/java/net/minecraft/server/level/ServerChunkCache.java @@ -1072,7 +1072,7 @@ public class ServerChunkCache extends ChunkSource { if (ServerChunkCache.this.runDistanceManagerUpdates()) { return true; } else { - ServerChunkCache.this.lightEngine.tryScheduleUpdate(); + ServerChunkCache.this.lightEngine.tryScheduleUpdate(); // Paper - not needed return super.pollTask() || execChunkTask; // Paper } } finally { diff --git a/src/main/java/net/minecraft/server/level/ThreadedLevelLightEngine.java b/src/main/java/net/minecraft/server/level/ThreadedLevelLightEngine.java index cc4190b3a8904d1eaae0f542a3b3090583f5ff82..14835bfab300d305faee2db705d7386dc16427f5 100644 --- a/src/main/java/net/minecraft/server/level/ThreadedLevelLightEngine.java +++ b/src/main/java/net/minecraft/server/level/ThreadedLevelLightEngine.java @@ -1,6 +1,7 @@ package net.minecraft.server.level; import com.mojang.datafixers.util.Pair; +import it.unimi.dsi.fastutil.longs.Long2ObjectLinkedOpenHashMap; // Paper import it.unimi.dsi.fastutil.objects.ObjectArrayList; import it.unimi.dsi.fastutil.objects.ObjectList; import it.unimi.dsi.fastutil.objects.ObjectListIterator; @@ -16,6 +17,7 @@ import net.minecraft.util.thread.ProcessorMailbox; import net.minecraft.world.level.ChunkPos; import net.minecraft.world.level.LightLayer; import net.minecraft.world.level.chunk.ChunkAccess; +import net.minecraft.world.level.chunk.ChunkStatus; import net.minecraft.world.level.chunk.DataLayer; import net.minecraft.world.level.chunk.LevelChunkSection; import net.minecraft.world.level.chunk.LightChunkGetter; @@ -27,15 +29,149 @@ public class ThreadedLevelLightEngine extends LevelLightEngine implements AutoCl private static final Logger LOGGER = LogManager.getLogger(); private final ProcessorMailbox taskMailbox; - private final ObjectList> lightTasks = new ObjectArrayList(); - private final ChunkMap chunkMap; + // Paper start + private static final int MAX_PRIORITIES = ChunkMap.MAX_CHUNK_DISTANCE + 2; + + private boolean isChunkLightStatus(long pair) { + ChunkHolder playerChunk = playerChunkMap.getVisibleChunkIfPresent(pair); + if (playerChunk == null) { + return false; + } + ChunkStatus status = ChunkHolder.getStatus(playerChunk.getTicketLevel()); + return status != null && status.isAtLeastStatus(ChunkStatus.LIGHT); + } + + static class ChunkLightQueue { + public boolean shouldFastUpdate; + java.util.ArrayDeque pre = new java.util.ArrayDeque(); + java.util.ArrayDeque post = new java.util.ArrayDeque(); + + ChunkLightQueue(long chunk) {} + } + + static class PendingLightTask { + long chunkId; + IntSupplier priority; + Runnable pre; + Runnable post; + boolean fastUpdate; + + public PendingLightTask(long chunkId, IntSupplier priority, Runnable pre, Runnable post, boolean fastUpdate) { + this.chunkId = chunkId; + this.priority = priority; + this.pre = pre; + this.post = post; + this.fastUpdate = fastUpdate; + } + } + + + // Retain the chunks priority level for queued light tasks + class LightQueue { + private int size = 0; + private final Long2ObjectLinkedOpenHashMap[] buckets = new Long2ObjectLinkedOpenHashMap[MAX_PRIORITIES]; + private final java.util.concurrent.ConcurrentLinkedQueue pendingTasks = new java.util.concurrent.ConcurrentLinkedQueue<>(); + private final java.util.concurrent.ConcurrentLinkedQueue priorityChanges = new java.util.concurrent.ConcurrentLinkedQueue<>(); + + private LightQueue() { + for (int i = 0; i < buckets.length; i++) { + buckets[i] = new Long2ObjectLinkedOpenHashMap<>(); + } + } + + public void changePriority(long pair, int currentPriority, int priority) { + this.priorityChanges.add(() -> { + ChunkLightQueue remove = this.buckets[currentPriority].remove(pair); + if (remove != null) { + ChunkLightQueue existing = this.buckets[Math.max(1, priority)].put(pair, remove); + if (existing != null) { + remove.pre.addAll(existing.pre); + remove.post.addAll(existing.post); + } + } + }); + } + + public final void addChunk(long chunkId, IntSupplier priority, Runnable pre, Runnable post) { + pendingTasks.add(new PendingLightTask(chunkId, priority, pre, post, true)); + tryScheduleUpdate(); + } + + public final void add(long chunkId, IntSupplier priority, ThreadedLevelLightEngine.TaskType type, Runnable run) { + pendingTasks.add(new PendingLightTask(chunkId, priority, type == TaskType.PRE_UPDATE ? run : null, type == TaskType.POST_UPDATE ? run : null, false)); + } + public final void add(PendingLightTask update) { + int priority = update.priority.getAsInt(); + ChunkLightQueue lightQueue = this.buckets[priority].computeIfAbsent(update.chunkId, ChunkLightQueue::new); + + if (update.pre != null) { + this.size++; + lightQueue.pre.add(update.pre); + } + if (update.post != null) { + this.size++; + lightQueue.post.add(update.post); + } + if (update.fastUpdate) { + lightQueue.shouldFastUpdate = true; + } + } + + public final boolean isEmpty() { + return this.size == 0 && this.pendingTasks.isEmpty(); + } + + public final int size() { + return this.size; + } + + public boolean poll(java.util.List pre, java.util.List post) { + PendingLightTask pending; + while ((pending = pendingTasks.poll()) != null) { + add(pending); + } + Runnable run; + while ((run = priorityChanges.poll()) != null) { + run.run(); + } + boolean hasWork = false; + Long2ObjectLinkedOpenHashMap[] buckets = this.buckets; + int priority = 0; + while (priority < MAX_PRIORITIES && !isEmpty()) { + Long2ObjectLinkedOpenHashMap bucket = buckets[priority]; + if (bucket.isEmpty()) { + priority++; + if (hasWork) { + return true; + } else { + continue; + } + } + ChunkLightQueue queue = bucket.removeFirst(); + this.size -= queue.pre.size() + queue.post.size(); + pre.addAll(queue.pre); + post.addAll(queue.post); + queue.pre.clear(); + queue.post.clear(); + hasWork = true; + if (queue.shouldFastUpdate) { + return true; + } + } + return hasWork; + } + } + + final LightQueue queue = new LightQueue(); + // Paper end + private final ChunkMap chunkMap; private final ChunkMap playerChunkMap; // Paper private final ProcessorHandle> sorterMailbox; private volatile int taskPerBatch = 5; private final AtomicBoolean scheduled = new AtomicBoolean(); public ThreadedLevelLightEngine(LightChunkGetter chunkProvider, ChunkMap chunkStorage, boolean hasBlockLight, ProcessorMailbox processor, ProcessorHandle> executor) { super(chunkProvider, true, hasBlockLight); - this.chunkMap = chunkStorage; + this.chunkMap = chunkStorage; this.playerChunkMap = chunkMap; // Paper this.sorterMailbox = executor; this.taskMailbox = processor; } @@ -122,13 +258,9 @@ public class ThreadedLevelLightEngine extends LevelLightEngine implements AutoCl } private void addTask(int x, int z, IntSupplier completedLevelSupplier, ThreadedLevelLightEngine.TaskType stage, Runnable task) { - this.sorterMailbox.tell(ChunkTaskPriorityQueueSorter.message(() -> { - this.lightTasks.add(Pair.of(stage, task)); - if (this.lightTasks.size() >= this.taskPerBatch) { - this.runUpdate(); - } - - }, ChunkPos.asLong(x, z), completedLevelSupplier)); + // Paper start - replace method + this.queue.add(ChunkPos.asLong(x, z), completedLevelSupplier, stage, task); + // Paper end } @Override @@ -145,8 +277,19 @@ public class ThreadedLevelLightEngine extends LevelLightEngine implements AutoCl public CompletableFuture lightChunk(ChunkAccess chunk, boolean excludeBlocks) { ChunkPos chunkcoordintpair = chunk.getPos(); - chunk.setLightCorrect(false); - this.addTask(chunkcoordintpair.x, chunkcoordintpair.z, ThreadedLevelLightEngine.TaskType.PRE_UPDATE, Util.name(() -> { + // Paper start + //ichunkaccess.b(false); // Don't need to disable this + long pair = chunkcoordintpair.toLong(); + CompletableFuture future = new CompletableFuture<>(); + IntSupplier prioritySupplier = playerChunkMap.getPrioritySupplier(pair); + boolean[] skippedPre = {false}; + this.queue.addChunk(pair, prioritySupplier, Util.name(() -> { + if (!isChunkLightStatus(pair)) { + future.complete(chunk); + skippedPre[0] = true; + return; + } + // Paper end LevelChunkSection[] achunksection = chunk.getSections(); for (int i = 0; i < 16; ++i) { @@ -164,55 +307,48 @@ public class ThreadedLevelLightEngine extends LevelLightEngine implements AutoCl }); } - this.chunkMap.releaseLightTicket(chunkcoordintpair); + // this.d.c(chunkcoordintpair); // Paper - move into post task below }, () -> { return "lightChunk " + chunkcoordintpair + " " + excludeBlocks; - })); - return CompletableFuture.supplyAsync(() -> { + // Paper start - merge the 2 together + }), () -> { + this.chunkMap.releaseLightTicket(chunkcoordintpair); // Paper - release light tickets as post task to ensure they stay loaded until fully done + if (skippedPre[0]) return; // Paper - future's already complete chunk.setLightCorrect(true); super.retainData(chunkcoordintpair, false); - return chunk; - }, (runnable) -> { - this.addTask(chunkcoordintpair.x, chunkcoordintpair.z, ThreadedLevelLightEngine.TaskType.POST_UPDATE, runnable); + // Paper start + future.complete(chunk); }); + return future; + // Paper end } public void tryScheduleUpdate() { - if ((!this.lightTasks.isEmpty() || super.hasLightWork()) && this.scheduled.compareAndSet(false, true)) { + if ((!this.queue.isEmpty() || super.hasLightWork()) && this.scheduled.compareAndSet(false, true)) { // Paper this.taskMailbox.tell((() -> { // Paper - decompile error this.runUpdate(); this.scheduled.set(false); + tryScheduleUpdate(); // Paper - if we still have work to do, do it! })); } } + // Paper start - replace impl + private final java.util.List pre = new java.util.ArrayList<>(); + private final java.util.List post = new java.util.ArrayList<>(); private void runUpdate() { - int i = Math.min(this.lightTasks.size(), this.taskPerBatch); - ObjectListIterator> objectlistiterator = this.lightTasks.iterator(); - - Pair pair; - int j; - - for (j = 0; objectlistiterator.hasNext() && j < i; ++j) { - pair = (Pair) objectlistiterator.next(); - if (pair.getFirst() == ThreadedLevelLightEngine.TaskType.PRE_UPDATE) { - ((Runnable) pair.getSecond()).run(); - } + if (queue.poll(pre, post)) { + pre.forEach(Runnable::run); + pre.clear(); + super.runUpdates(Integer.MAX_VALUE, true, true); + post.forEach(Runnable::run); + post.clear(); + } else { + // might have level updates to go still + super.runUpdates(Integer.MAX_VALUE, true, true); } - - objectlistiterator.back(j); - super.runUpdates(Integer.MAX_VALUE, true, true); - - for (j = 0; objectlistiterator.hasNext() && j < i; ++j) { - pair = (Pair) objectlistiterator.next(); - if (pair.getFirst() == ThreadedLevelLightEngine.TaskType.POST_UPDATE) { - ((Runnable) pair.getSecond()).run(); - } - - objectlistiterator.remove(); - } - + // Paper end } public void setTaskPerBatch(int taskBatchSize) { diff --git a/src/main/java/net/minecraft/util/thread/ProcessorMailbox.java b/src/main/java/net/minecraft/util/thread/ProcessorMailbox.java index c763aa0c0cf49dd844af94a820103258b49021ae..195535835bdc63f7cfdebeaa957dde590262ea42 100644 --- a/src/main/java/net/minecraft/util/thread/ProcessorMailbox.java +++ b/src/main/java/net/minecraft/util/thread/ProcessorMailbox.java @@ -110,7 +110,8 @@ public class ProcessorMailbox implements ProcessorHandle, AutoCloseable, R } - @Override + + public final void queue(T t0) { tell(t0); } @Override // Paper - OBFHELPER public void tell(T message) { this.queue.push(message); this.registerForExecution(); diff --git a/src/main/java/net/minecraft/world/level/chunk/DataLayer.java b/src/main/java/net/minecraft/world/level/chunk/DataLayer.java index 83e9d8bff9a31fe13a0e22445cd6eecb7abe8561..1e8ce9894fd0a121da83020c6064b7833af1c5f2 100644 --- a/src/main/java/net/minecraft/world/level/chunk/DataLayer.java +++ b/src/main/java/net/minecraft/world/level/chunk/DataLayer.java @@ -11,6 +11,13 @@ import net.minecraft.server.MCUtil; public class DataLayer { // Paper start + public static final DataLayer EMPTY_NIBBLE_ARRAY = new DataLayer() { + @Override + public byte[] getData() { + throw new IllegalStateException(); + } + }; + public long lightCacheKey = Long.MIN_VALUE; public static byte[] EMPTY_NIBBLE = new byte[2048]; private static final int nibbleBucketSizeMultiplier = Integer.getInteger("Paper.nibbleBucketSize", 3072); private static final int maxPoolSize = Integer.getInteger("Paper.maxNibblePoolSize", (int) Math.min(6, Math.max(1, Runtime.getRuntime().maxMemory() / 1024 / 1024 / 1024)) * (nibbleBucketSizeMultiplier * 8)); diff --git a/src/main/java/net/minecraft/world/level/lighting/BlockLightEngine.java b/src/main/java/net/minecraft/world/level/lighting/BlockLightEngine.java index 709fc42057f8a0282c3c942067e63abb874d9042..eaaaecb67966e5e366cf59f92674c82d1d87552e 100644 --- a/src/main/java/net/minecraft/world/level/lighting/BlockLightEngine.java +++ b/src/main/java/net/minecraft/world/level/lighting/BlockLightEngine.java @@ -23,9 +23,11 @@ public final class BlockLightEngine extends LayerLightEngine> 38); + int k = (int) ((blockPos << 52) >> 52); + int l = (int) ((blockPos << 26) >> 38); + // Paper end BlockGetter iblockaccess = this.chunkSource.getChunkForLighting(j >> 4, l >> 4); return iblockaccess != null ? iblockaccess.getLightEmission(this.pos.set(j, k, l)) : 0; @@ -40,25 +42,33 @@ public final class BlockLightEngine extends LayerLightEngine= 15) { return level; } else { - int l = Integer.signum(BlockPos.getX(targetId) - BlockPos.getX(sourceId)); - int i1 = Integer.signum(BlockPos.getY(targetId) - BlockPos.getY(sourceId)); - int j1 = Integer.signum(BlockPos.getZ(targetId) - BlockPos.getZ(sourceId)); + // Paper start - reuse math - credit to JellySquid for idea + int jx = (int) (targetId >> 38); + int jy = (int) ((targetId << 52) >> 52); + int jz = (int) ((targetId << 26) >> 38); + int ix = (int) (sourceId >> 38); + int iy = (int) ((sourceId << 52) >> 52); + int iz = (int) ((sourceId << 26) >> 38); + int l = Integer.signum(jx - ix); + int i1 = Integer.signum(jy - iy); + int j1 = Integer.signum(jz - iz); + // Paper end Direction enumdirection = Direction.fromNormal(l, i1, j1); if (enumdirection == null) { return 15; } else { //MutableInt mutableint = new MutableInt(); // Paper - share mutableint, single threaded - BlockState iblockdata = this.getStateAndOpacity(targetId, mutableint); - - if (mutableint.getValue() >= 15) { + BlockState iblockdata = this.getBlockOptimized(jx, jy, jz, mutableint); // Paper + int blockedLight = mutableint.getValue(); // Paper + if (blockedLight >= 15) { // Paper return 15; } else { - BlockState iblockdata1 = this.getStateAndOpacity(sourceId, (MutableInt) null); + BlockState iblockdata1 = this.getBlockOptimized(ix, iy, iz); // Paper VoxelShape voxelshape = this.getShape(iblockdata1, sourceId, enumdirection); VoxelShape voxelshape1 = this.getShape(iblockdata, targetId, enumdirection.getOpposite()); - return Shapes.faceShapeOccludes(voxelshape, voxelshape1) ? 15 : level + Math.max(1, mutableint.getValue()); + return Shapes.faceShapeOccludes(voxelshape, voxelshape1) ? 15 : level + Math.max(1, blockedLight); // Paper } } } @@ -66,14 +76,19 @@ public final class BlockLightEngine extends LayerLightEngine> 38); + int y = (int) ((id << 52) >> 52); + int z = (int) ((id << 26) >> 38); + long k = SectionPos.blockPosAsSectionLong(x, y, z); + // Paper end Direction[] aenumdirection = BlockLightEngine.DIRECTIONS; int l = aenumdirection.length; for (int i1 = 0; i1 < l; ++i1) { Direction enumdirection = aenumdirection[i1]; - long j1 = BlockPos.offset(id, enumdirection); - long k1 = SectionPos.blockToSection(j1); + long j1 = BlockPos.getAdjacent(x, y, z, enumdirection); // Paper + long k1 = SectionPos.blockToSection(j1); // Paper if (k == k1 || ((BlockLightSectionStorage) this.storage).storingLightForSection(k1)) { this.checkNeighbor(id, j1, level, decrease); @@ -98,27 +113,37 @@ public final class BlockLightEngine extends LayerLightEngine> 38); + int baseY = (int) ((id << 52) >> 52); + int baseZ = (int) ((id << 26) >> 38); + long j1 = SectionPos.blockPosAsSectionLong(baseX, baseY, baseZ); + DataLayer nibblearray = this.storage.updating.getUpdatingOptimized(j1); + // Paper end Direction[] aenumdirection = BlockLightEngine.DIRECTIONS; int k1 = aenumdirection.length; for (int l1 = 0; l1 < k1; ++l1) { Direction enumdirection = aenumdirection[l1]; - long i2 = BlockPos.offset(id, enumdirection); + // Paper start + int newX = baseX + enumdirection.getStepX(); + int newY = baseY + enumdirection.getStepY(); + int newZ = baseZ + enumdirection.getStepZ(); + long i2 = BlockPos.asLong(newX, newY, newZ); if (i2 != excludedId) { - long j2 = SectionPos.blockToSection(i2); + long j2 = SectionPos.blockPosAsSectionLong(newX, newY, newZ); + // Paper end DataLayer nibblearray1; if (j1 == j2) { nibblearray1 = nibblearray; } else { - nibblearray1 = ((BlockLightSectionStorage) this.storage).getDataLayer(j2, true); + nibblearray1 = ((BlockLightSectionStorage) this.storage).updating.getUpdatingOptimized(j2); // Paper } if (nibblearray1 != null) { - int k2 = this.computeLevelFromNeighbor(i2, id, this.getLevel(nibblearray1, i2)); + int k2 = this.computeLevelFromNeighbor(i2, id, this.getNibbleLightInverse(nibblearray1, newX, newY, newZ)); // Paper if (l > k2) { l = k2; diff --git a/src/main/java/net/minecraft/world/level/lighting/BlockLightSectionStorage.java b/src/main/java/net/minecraft/world/level/lighting/BlockLightSectionStorage.java index a1ad4d73ddaf6afe97a1f1ff7e0622b52fac8761..f771ef8d841567b421b6c0529af3f0713c79eb7c 100644 --- a/src/main/java/net/minecraft/world/level/lighting/BlockLightSectionStorage.java +++ b/src/main/java/net/minecraft/world/level/lighting/BlockLightSectionStorage.java @@ -1,8 +1,6 @@ package net.minecraft.world.level.lighting; import it.unimi.dsi.fastutil.longs.Long2ObjectOpenHashMap; -import net.minecraft.core.BlockPos; -import net.minecraft.core.SectionPos; import net.minecraft.world.level.LightLayer; import net.minecraft.world.level.chunk.DataLayer; import net.minecraft.world.level.chunk.LightChunkGetter; @@ -15,10 +13,14 @@ public class BlockLightSectionStorage extends LayerLightSectionStorage> 38); + int baseY = (int) ((blockPos << 52) >> 52); + int baseZ = (int) ((blockPos << 26) >> 38); + long j = (((long) (baseX >> 4) & 4194303L) << 42) | (((long) (baseY >> 4) & 1048575L)) | (((long) (baseZ >> 4) & 4194303L) << 20); + DataLayer nibblearray = this.e_visible.lookup.apply(j); + return nibblearray == null ? 0 : nibblearray.get(baseX & 15, baseY & 15, baseZ & 15); + // Paper end } public static final class BlockDataLayerStorageMap extends DataLayerStorageMap { diff --git a/src/main/java/net/minecraft/world/level/lighting/DataLayerStorageMap.java b/src/main/java/net/minecraft/world/level/lighting/DataLayerStorageMap.java index 54cca3b376e5ce02936edc8b9c17e67e17f07147..ed2ed6194670016086be580dc4514d5d3d1b235b 100644 --- a/src/main/java/net/minecraft/world/level/lighting/DataLayerStorageMap.java +++ b/src/main/java/net/minecraft/world/level/lighting/DataLayerStorageMap.java @@ -7,13 +7,18 @@ import net.minecraft.world.level.chunk.DataLayer; public abstract class DataLayerStorageMap> { - private final long[] lastSectionKeys = new long[2]; - private final DataLayer[] lastSections = new DataLayer[2]; + // private final long[] b = new long[2]; // Paper - unused + private final DataLayer[] lastSections = new DataLayer[]{DataLayer.EMPTY_NIBBLE_ARRAY, DataLayer.EMPTY_NIBBLE_ARRAY}; private final DataLayer[] cache = lastSections; // Paper - OBFHELPER private boolean cacheEnabled; protected final com.destroystokyo.paper.util.map.QueuedChangesMapLong2Object data; // Paper - avoid copying light data protected final boolean isVisible; // Paper - avoid copying light data - java.util.function.Function lookup; // Paper - faster branchless lookup + // Paper start - faster lookups with less branching, use interface to avoid boxing instead of Function + public final NibbleArrayAccess lookup; + public interface NibbleArrayAccess { + DataLayer apply(long id); + } + // Paper end // Paper start - avoid copying light data protected DataLayerStorageMap(com.destroystokyo.paper.util.map.QueuedChangesMapLong2Object data, boolean isVisible) { if (isVisible) { @@ -21,12 +26,14 @@ public abstract class DataLayerStorageMap> { } this.data = data; this.isVisible = isVisible; + // Paper end - avoid copying light data + // Paper start - faster lookups with less branching if (isVisible) { lookup = data::getVisibleAsync; } else { - lookup = data::getUpdating; + lookup = data.getUpdatingMap()::get; // jump straight the sub map } - // Paper end - avoid copying light data + // Paper end this.clearCache(); this.cacheEnabled = true; } @@ -36,7 +43,9 @@ public abstract class DataLayerStorageMap> { public void copyDataLayer(long pos) { if (this.isVisible) { throw new IllegalStateException("writing to visible data"); } // Paper - avoid copying light data DataLayer updating = this.data.getUpdating(pos); // Paper - pool nibbles - this.data.queueUpdate(pos, new DataLayer().markPoolSafe(updating.getCloneIfSet())); // Paper - avoid copying light data - pool safe clone + DataLayer nibblearray = new DataLayer().markPoolSafe(updating.getCloneIfSet()); // Paper + nibblearray.lightCacheKey = pos; // Paper + this.data.queueUpdate(pos, nibblearray); // Paper - avoid copying light data - pool safe clone if (updating.cleaner != null) MCUtil.scheduleTask(2, updating.cleaner, "Light Engine Release"); // Paper - delay clean incase anything holding ref was still using it this.clearCache(); } @@ -45,34 +54,34 @@ public abstract class DataLayerStorageMap> { return lookup.apply(chunkPos) != null; // Paper - avoid copying light data } - @Nullable - public final DataLayer getLayer(long chunkPos) { // Paper - final - if (this.cacheEnabled) { - for (int j = 0; j < 2; ++j) { - if (chunkPos == this.lastSectionKeys[j]) { - return this.lastSections[j]; - } - } - } - - DataLayer nibblearray = lookup.apply(chunkPos); // Paper - avoid copying light data + // Paper start - less branching as we know we are using cache and updating + public final DataLayer getUpdatingOptimized(final long i) { // Paper - final + final DataLayer[] cache = this.cache; + if (cache[0].lightCacheKey == i) return cache[0]; + if (cache[1].lightCacheKey == i) return cache[1]; + final DataLayer nibblearray = this.lookup.apply(i); // Paper - avoid copying light data if (nibblearray == null) { return null; } else { - if (this.cacheEnabled) { - for (int k = 1; k > 0; --k) { - this.lastSectionKeys[k] = this.lastSectionKeys[k - 1]; - this.lastSections[k] = this.lastSections[k - 1]; - } - - this.lastSectionKeys[0] = chunkPos; - this.lastSections[0] = nibblearray; - } - + cache[1] = cache[0]; + cache[0] = nibblearray; return nibblearray; } } + // Paper end + + @Nullable + public final DataLayer getLayer(final long chunkPos) { // Paper - final + // Paper start - optimize visible case or missed updating cases + if (this.cacheEnabled) { + // short circuit to optimized + return getUpdatingOptimized(chunkPos); + } + + return this.lookup.apply(chunkPos); + // Paper end + } @Nullable public DataLayer removeLayer(long chunkPos) { @@ -82,13 +91,14 @@ public abstract class DataLayerStorageMap> { public void setLayer(long pos, DataLayer data) { if (this.isVisible) { throw new IllegalStateException("writing to visible data"); } // Paper - avoid copying light data + data.lightCacheKey = pos; // Paper this.data.queueUpdate(pos, data); // Paper - avoid copying light data } public void clearCache() { for (int i = 0; i < 2; ++i) { - this.lastSectionKeys[i] = Long.MAX_VALUE; - this.lastSections[i] = null; + // this.b[i] = Long.MAX_VALUE; // Paper - Unused + this.lastSections[i] = DataLayer.EMPTY_NIBBLE_ARRAY; // Paper } } diff --git a/src/main/java/net/minecraft/world/level/lighting/LayerLightEngine.java b/src/main/java/net/minecraft/world/level/lighting/LayerLightEngine.java index 53f38fa95f4ffad12c73d94ab1d7ecf7ee78af09..088ea8a14f1bb264b59fcec626b1a28d7f6d7c47 100644 --- a/src/main/java/net/minecraft/world/level/lighting/LayerLightEngine.java +++ b/src/main/java/net/minecraft/world/level/lighting/LayerLightEngine.java @@ -10,6 +10,7 @@ import net.minecraft.world.level.ChunkPos; import net.minecraft.world.level.LightLayer; import net.minecraft.world.level.block.Blocks; import net.minecraft.world.level.block.state.BlockState; +import net.minecraft.world.level.chunk.ChunkAccess; import net.minecraft.world.level.chunk.DataLayer; import net.minecraft.world.level.chunk.LightChunkGetter; import net.minecraft.world.phys.shapes.Shapes; @@ -23,10 +24,37 @@ public abstract class LayerLightEngine, S exten protected final LightLayer layer; protected final S storage; private boolean runningLightUpdates; - protected final BlockPos.MutableBlockPos pos = new BlockPos.MutableBlockPos(); + protected final BlockPos.MutableBlockPos pos = new BlockPos.MutableBlockPos(); protected final BlockPos.MutableBlockPos pos = pos; // Paper private final long[] lastChunkPos = new long[2]; - private final BlockGetter[] lastChunk = new BlockGetter[2]; + private final ChunkAccess[] h = new ChunkAccess[2]; // Paper + // Paper start - see fully commented out method below (look for Bedrock) + // optimized method with less branching for when scenarios arent needed. + // avoid using mutable version if can + protected final BlockState getBlockOptimized(int x, int y, int z, MutableInt mutableint) { + ChunkAccess iblockaccess = this.a(x >> 4, z >> 4); + + if (iblockaccess == null) { + mutableint.setValue(16); + return Blocks.BEDROCK.defaultBlockState(); + } else { + this.pos.setValues(x, y, z); + BlockState iblockdata = iblockaccess.getType(x, y, z); + mutableint.setValue(iblockdata.getLightBlock(this.chunkSource.getLevel(), this.pos)); + return iblockdata.canOcclude() && iblockdata.useShapeForLightOcclusion() ? iblockdata : Blocks.AIR.defaultBlockState(); + } + } + protected final BlockState getBlockOptimized(int x, int y, int z) { + ChunkAccess iblockaccess = this.a(x >> 4, z >> 4); + + if (iblockaccess == null) { + return Blocks.BEDROCK.defaultBlockState(); + } else { + BlockState iblockdata = iblockaccess.getType(x, y, z); + return iblockdata.canOcclude() && iblockdata.useShapeForLightOcclusion() ? iblockdata : Blocks.AIR.defaultBlockState(); + } + } + // Paper end public LayerLightEngine(LightChunkGetter chunkProvider, LightLayer type, S lightStorage) { super(16, 256, 8192); this.chunkSource = chunkProvider; @@ -45,63 +73,65 @@ public abstract class LayerLightEngine, S exten } @Nullable - private BlockGetter getChunk(int chunkX, int chunkZ) { - long k = ChunkPos.asLong(chunkX, chunkZ); + private ChunkAccess a(int i, int j) { // Paper + long k = ChunkPos.asLong(i, j); for (int l = 0; l < 2; ++l) { if (k == this.lastChunkPos[l]) { - return this.lastChunk[l]; + return this.h[l]; } } - BlockGetter iblockaccess = this.chunkSource.getChunkForLighting(chunkX, chunkZ); + ChunkAccess iblockaccess = (ChunkAccess) this.chunkSource.getChunkForLighting(i, j); // Paper for (int i1 = 1; i1 > 0; --i1) { this.lastChunkPos[i1] = this.lastChunkPos[i1 - 1]; - this.lastChunk[i1] = this.lastChunk[i1 - 1]; + this.h[i1] = this.h[i1 - 1]; } this.lastChunkPos[0] = k; - this.lastChunk[0] = iblockaccess; + this.h[0] = iblockaccess; return iblockaccess; } private void clearCache() { Arrays.fill(this.lastChunkPos, ChunkPos.INVALID_CHUNK_POS); - Arrays.fill(this.lastChunk, (Object) null); + Arrays.fill(this.h, (Object) null); } - protected BlockState getStateAndOpacity(long pos, @Nullable MutableInt mutableint) { - if (pos == Long.MAX_VALUE) { - if (mutableint != null) { - mutableint.setValue(0); - } - - return Blocks.AIR.defaultBlockState(); - } else { - int j = SectionPos.blockToSectionCoord(BlockPos.getX(pos)); - int k = SectionPos.blockToSectionCoord(BlockPos.getZ(pos)); - BlockGetter iblockaccess = this.getChunk(j, k); - - if (iblockaccess == null) { - if (mutableint != null) { - mutableint.setValue(16); - } - - return Blocks.BEDROCK.defaultBlockState(); - } else { - this.pos.set(pos); - BlockState iblockdata = iblockaccess.getBlockState(this.pos); - boolean flag = iblockdata.canOcclude() && iblockdata.useShapeForLightOcclusion(); - - if (mutableint != null) { - mutableint.setValue(iblockdata.getLightBlock(this.chunkSource.getLevel(), (BlockPos) this.pos)); - } - - return flag ? iblockdata : Blocks.AIR.defaultBlockState(); - } - } - } + // Paper start - comment out, see getBlockOptimized +// protected IBlockData a(long i, @Nullable MutableInt mutableint) { +// if (i == Long.MAX_VALUE) { +// if (mutableint != null) { +// mutableint.setValue(0); +// } +// +// return Blocks.AIR.getBlockData(); +// } else { +// int j = SectionPosition.a(BlockPosition.b(i)); +// int k = SectionPosition.a(BlockPosition.d(i)); +// IBlockAccess iblockaccess = this.a(j, k); +// +// if (iblockaccess == null) { +// if (mutableint != null) { +// mutableint.setValue(16); +// } +// +// return Blocks.BEDROCK.getBlockData(); +// } else { +// this.d.g(i); +// IBlockData iblockdata = iblockaccess.getType(this.d); +// boolean flag = iblockdata.l() && iblockdata.e(); +// +// if (mutableint != null) { +// mutableint.setValue(iblockdata.b(this.a.getWorld(), (BlockPosition) this.d)); +// } +// +// return flag ? iblockdata : Blocks.AIR.getBlockData(); +// } +// } +// } + // Paper end protected VoxelShape getShape(BlockState world, long pos, Direction facing) { return world.canOcclude() ? world.getFaceOcclusionShape(this.chunkSource.getLevel(), this.pos.set(pos), facing) : Shapes.empty(); @@ -136,8 +166,9 @@ public abstract class LayerLightEngine, S exten return id == Long.MAX_VALUE ? 0 : 15 - this.storage.getStoredLevel(id); } + protected int getNibbleLightInverse(DataLayer nibblearray, int x, int y, int z) { return 15 - nibblearray.get(x & 15, y & 15, z & 15); } // Paper - x/y/z version of below protected int getLevel(DataLayer section, long blockPos) { - return 15 - section.get(SectionPos.sectionRelative(BlockPos.getX(blockPos)), SectionPos.sectionRelative(BlockPos.getY(blockPos)), SectionPos.sectionRelative(BlockPos.getZ(blockPos))); + return 15 - section.get((int) (blockPos >> 38) & 15, (int) ((blockPos << 52) >> 52) & 15, (int) ((blockPos << 26) >> 38) & 15); // Paper } @Override diff --git a/src/main/java/net/minecraft/world/level/lighting/LayerLightSectionStorage.java b/src/main/java/net/minecraft/world/level/lighting/LayerLightSectionStorage.java index 5757bcfded35f112d52a7c81586850ba50e0d8dd..17a6610b352af5d3e2cbcdf9b4d9b0d4d356b5cf 100644 --- a/src/main/java/net/minecraft/world/level/lighting/LayerLightSectionStorage.java +++ b/src/main/java/net/minecraft/world/level/lighting/LayerLightSectionStorage.java @@ -27,9 +27,9 @@ public abstract class LayerLightSectionStorage> protected final LongSet toMarkNoData = new LongOpenHashSet(); protected final LongSet toMarkData = new LongOpenHashSet(); protected volatile M e_visible; protected final Object visibleUpdateLock = new Object(); // Paper - diff on change, should be "visible" - force compile fail on usage change - protected final M updatingSectionData; // Paper - diff on change, should be "updating" + protected final M updatingSectionData; protected final M updating; // Paper - diff on change, should be "updating" protected final LongSet changedSections = new LongOpenHashSet(); - protected final LongSet sectionsAffectedByLightUpdates = new LongOpenHashSet(); + protected final LongSet sectionsAffectedByLightUpdates = new LongOpenHashSet(); LongSet dirty = sectionsAffectedByLightUpdates; // Paper - OBFHELPER protected final Long2ObjectMap queuedSections = Long2ObjectMaps.synchronize(new Long2ObjectOpenHashMap()); private final LongSet untrustedSections = new LongOpenHashSet(); private final LongSet columnsToRetainQueuedDataFor = new LongOpenHashSet(); @@ -37,33 +37,33 @@ public abstract class LayerLightSectionStorage> protected volatile boolean hasToRemove; protected LayerLightSectionStorage(LightLayer lightType, LightChunkGetter chunkProvider, M lightData) { - super(3, 16, 256); + super(3, 256, 256); // Paper - bump expected size of level sets to improve collisions and reduce rehashing (seen a lot of it) this.layer = lightType; this.chunkSource = chunkProvider; - this.updatingSectionData = lightData; + this.updatingSectionData = lightData; updating = lightData; // Paper this.e_visible = lightData.copy(); // Paper - avoid copying light data this.e_visible.disableCache(); // Paper - avoid copying light data } - protected boolean storingLightForSection(long sectionPos) { - return this.getDataLayer(sectionPos, true) != null; + protected final boolean storingLightForSection(long sectionPos) { // Paper - final to help inlining + return this.updating.getUpdatingOptimized(sectionPos) != null; // Paper - inline to avoid branching } @Nullable protected DataLayer getDataLayer(long sectionPos, boolean cached) { // Paper start - avoid copying light data if (cached) { - return this.getDataLayer(this.updatingSectionData, sectionPos); + return this.updating.getUpdatingOptimized(sectionPos); } else { synchronized (this.visibleUpdateLock) { - return this.getDataLayer(this.e_visible, sectionPos); + return this.e_visible.lookup.apply(sectionPos); } } // Paper end - avoid copying light data } @Nullable - protected DataLayer getDataLayer(M storage, long sectionPos) { + protected final DataLayer getDataLayer(M storage, long sectionPos) { // Paper return storage.getLayer(sectionPos); } @@ -77,27 +77,57 @@ public abstract class LayerLightSectionStorage> protected abstract int getLightValue(long blockPos); protected int getStoredLevel(long blockPos) { - long j = SectionPos.blockToSection(blockPos); - DataLayer nibblearray = this.getDataLayer(j, true); + // Paper start - reuse and inline math, use Optimized Updating path + final int x = (int) (blockPos >> 38); + final int y = (int) ((blockPos << 52) >> 52); + final int z = (int) ((blockPos << 26) >> 38); + long j = SectionPos.blockPosAsSectionLong(x, y, z); + DataLayer nibblearray = this.updating.getUpdatingOptimized(j); + // BUG: Sometimes returns null and crashes, try to recover, but to prevent crash just return no light. + if (nibblearray == null) { + nibblearray = this.e_visible.lookup.apply(j); + } + if (nibblearray == null) { + System.err.println("Null nibble, preventing crash " + BlockPos.of(blockPos)); + return 0; + } - return nibblearray.get(SectionPos.sectionRelative(BlockPos.getX(blockPos)), SectionPos.sectionRelative(BlockPos.getY(blockPos)), SectionPos.sectionRelative(BlockPos.getZ(blockPos))); + return nibblearray.get(x & 15, y & 15, z & 15); // Paper - inline operations + // Paper end } protected void setStoredLevel(long blockPos, int value) { - long k = SectionPos.blockToSection(blockPos); + // Paper start - cache part of the math done in loop below + int x = (int) (blockPos >> 38); + int y = (int) ((blockPos << 52) >> 52); + int z = (int) ((blockPos << 26) >> 38); + long k = SectionPos.blockPosAsSectionLong(x, y, z); + // Paper end if (this.changedSections.add(k)) { this.updatingSectionData.copyDataLayer(k); } DataLayer nibblearray = this.getDataLayer(k, true); - - nibblearray.set(SectionPos.sectionRelative(BlockPos.getX(blockPos)), SectionPos.sectionRelative(BlockPos.getY(blockPos)), SectionPos.sectionRelative(BlockPos.getZ(blockPos)), value); - - for (int l = -1; l <= 1; ++l) { - for (int i1 = -1; i1 <= 1; ++i1) { - for (int j1 = -1; j1 <= 1; ++j1) { - this.sectionsAffectedByLightUpdates.add(SectionPos.blockToSection(BlockPos.offset(blockPos, i1, j1, l))); + nibblearray.set(x & 15, y & 15, z & 15, value); // Paper - use already calculated x/y/z + + // Paper start - credit to JellySquid for a major optimization here: + /* + * An extremely important optimization is made here in regards to adding items to the pending notification set. The + * original implementation attempts to add the coordinate of every chunk which contains a neighboring block position + * even though a huge number of loop iterations will simply map to block positions within the same updating chunk. + * + * Our implementation here avoids this by pre-calculating the min/max chunk coordinates so we can iterate over only + * the relevant chunk positions once. This reduces what would always be 27 iterations to just 1-8 iterations. + * + * @reason Use faster implementation + * @author JellySquid + */ + for (int z2 = (z - 1) >> 4; z2 <= (z + 1) >> 4; ++z2) { + for (int x2 = (x - 1) >> 4; x2 <= (x + 1) >> 4; ++x2) { + for (int y2 = (y - 1) >> 4; y2 <= (y + 1) >> 4; ++y2) { + this.dirty.add(SectionPos.asLong(x2, y2, z2)); + // Paper end } } } @@ -129,17 +159,23 @@ public abstract class LayerLightSectionStorage> } if (k >= 2 && level != 2) { - if (this.toRemove.contains(id)) { - this.toRemove.remove(id); - } else { + if (!this.toRemove.remove(id)) { // Paper - remove useless contains - credit to JellySquid + //this.p.remove(i); // Paper + //} else { // Paper this.updatingSectionData.setLayer(id, this.createDataLayer(id)); this.changedSections.add(id); this.onNodeAdded(id); - for (int l = -1; l <= 1; ++l) { - for (int i1 = -1; i1 <= 1; ++i1) { - for (int j1 = -1; j1 <= 1; ++j1) { - this.sectionsAffectedByLightUpdates.add(SectionPos.blockToSection(BlockPos.offset(id, i1, j1, l))); + // Paper start - reuse x/y/z and only notify valid chunks - Credit to JellySquid (See above method for notes) + int x = (int) (id >> 38); + int y = (int) ((id << 52) >> 52); + int z = (int) ((id << 26) >> 38); + + for (int z2 = (z - 1) >> 4; z2 <= (z + 1) >> 4; ++z2) { + for (int x2 = (x - 1) >> 4; x2 <= (x + 1) >> 4; ++x2) { + for (int y2 = (y - 1) >> 4; y2 <= (y + 1) >> 4; ++y2) { + this.dirty.add(SectionPos.asLong(x2, y2, z2)); + // Paper end } } } @@ -165,9 +201,9 @@ public abstract class LayerLightSectionStorage> return SectionPos.blockToSection(j) == sectionPos; }); } else { - int j = SectionPos.sectionToBlockCoord(SectionPos.x(sectionPos)); - int k = SectionPos.sectionToBlockCoord(SectionPos.y(sectionPos)); - int l = SectionPos.sectionToBlockCoord(SectionPos.z(sectionPos)); + int j = (int) (sectionPos >> 42) << 4; // Paper - inline + int k = (int) (sectionPos << 44 >> 44) << 4; // Paper - inline + int l = (int) (sectionPos << 22 >> 42) << 4; // Paper - inline for (int i1 = 0; i1 < 16; ++i1) { for (int j1 = 0; j1 < 16; ++j1) { @@ -194,7 +230,7 @@ public abstract class LayerLightSectionStorage> DataLayer nibblearray; while (longiterator.hasNext()) { - i = (Long) longiterator.next(); + i = longiterator.nextLong(); // Paper this.clearQueuedSectionBlocks(lightProvider, i); DataLayer nibblearray1 = (DataLayer) this.queuedSections.remove(i); @@ -212,7 +248,7 @@ public abstract class LayerLightSectionStorage> longiterator = this.toRemove.iterator(); while (longiterator.hasNext()) { - i = (Long) longiterator.next(); + i = longiterator.nextLong(); // Paper this.onNodeRemoved(i); } @@ -223,12 +259,13 @@ public abstract class LayerLightSectionStorage> Entry entry; long j; + DataLayer test = null; // Paper while (objectiterator.hasNext()) { entry = (Entry) objectiterator.next(); j = entry.getLongKey(); - if (this.storingLightForSection(j)) { + if ((test = this.updating.getUpdatingOptimized(j)) != null) { // Paper - dont look up nibble twice nibblearray = (DataLayer) entry.getValue(); - if (this.updatingSectionData.getLayer(j) != nibblearray) { + if (test != nibblearray) { // Paper this.clearQueuedSectionBlocks(lightProvider, j); this.updatingSectionData.setLayer(j, nibblearray); this.changedSections.add(j); @@ -241,14 +278,14 @@ public abstract class LayerLightSectionStorage> longiterator = this.queuedSections.keySet().iterator(); while (longiterator.hasNext()) { - i = (Long) longiterator.next(); + i = longiterator.nextLong(); // Paper this.checkEdgesForSection(lightProvider, i); } } else { longiterator = this.untrustedSections.iterator(); while (longiterator.hasNext()) { - i = (Long) longiterator.next(); + i = longiterator.nextLong(); // Paper this.checkEdgesForSection(lightProvider, i); } } @@ -269,15 +306,20 @@ public abstract class LayerLightSectionStorage> private void checkEdgesForSection(LayerLightEngine lightProvider, long sectionPos) { if (this.storingLightForSection(sectionPos)) { - int j = SectionPos.sectionToBlockCoord(SectionPos.x(sectionPos)); - int k = SectionPos.sectionToBlockCoord(SectionPos.y(sectionPos)); - int l = SectionPos.sectionToBlockCoord(SectionPos.z(sectionPos)); + // Paper start + int secX = (int) (sectionPos >> 42); + int secY = (int) (sectionPos << 44 >> 44); + int secZ = (int) (sectionPos << 22 >> 42); + int j = secX << 4; // baseX + int k = secY << 4; // baseY + int l = secZ << 4; // baseZ + // Paper end Direction[] aenumdirection = LayerLightSectionStorage.DIRECTIONS; int i1 = aenumdirection.length; for (int j1 = 0; j1 < i1; ++j1) { Direction enumdirection = aenumdirection[j1]; - long k1 = SectionPos.offset(sectionPos, enumdirection); + long k1 = SectionPos.getAdjacentFromSectionPos(secX, secY, secZ, enumdirection); // Paper - avoid extra unpacking if (!this.queuedSections.containsKey(k1) && this.storingLightForSection(k1)) { for (int l1 = 0; l1 < 16; ++l1) { diff --git a/src/main/java/net/minecraft/world/level/lighting/SkyLightEngine.java b/src/main/java/net/minecraft/world/level/lighting/SkyLightEngine.java index ff1fbc46776b26ca56c3293e40ed55028230ec46..da4003aebc8d5ffce695071af9a27139568d773f 100644 --- a/src/main/java/net/minecraft/world/level/lighting/SkyLightEngine.java +++ b/src/main/java/net/minecraft/world/level/lighting/SkyLightEngine.java @@ -4,6 +4,7 @@ import net.minecraft.core.BlockPos; import net.minecraft.core.Direction; import net.minecraft.core.SectionPos; import net.minecraft.world.level.LightLayer; +import net.minecraft.world.level.block.Blocks; import net.minecraft.world.level.block.state.BlockState; import net.minecraft.world.level.chunk.DataLayer; import net.minecraft.world.level.chunk.LightChunkGetter; @@ -38,21 +39,25 @@ public final class SkyLightEngine extends LayerLightEngine= 15) { + // Paper start - use x/y/z and optimized block lookup + int jx = (int) (targetId >> 38); + int jy = (int) ((targetId << 52) >> 52); + int jz = (int) ((targetId << 26) >> 38); + BlockState iblockdata = this.getBlockOptimized(jx, jy, jz, mutableint); + int blockedLight = mutableint.getValue(); + if (blockedLight >= 15) { + // Paper end return 15; } else { - int l = BlockPos.getX(sourceId); - int i1 = BlockPos.getY(sourceId); - int j1 = BlockPos.getZ(sourceId); - int k1 = BlockPos.getX(targetId); - int l1 = BlockPos.getY(targetId); - int i2 = BlockPos.getZ(targetId); - boolean flag = l == k1 && j1 == i2; - int j2 = Integer.signum(k1 - l); - int k2 = Integer.signum(l1 - i1); - int l2 = Integer.signum(i2 - j1); + // Paper start - inline math + int ix = (int) (sourceId >> 38); + int iy = (int) ((sourceId << 52) >> 52); + int iz = (int) ((sourceId << 26) >> 38); + boolean flag = ix == jx && iz == jz; + int j2 = Integer.signum(jx - ix); + int k2 = Integer.signum(jy - iy); + int l2 = Integer.signum(jz - iz); + // Paper end Direction enumdirection; if (sourceId == Long.MAX_VALUE) { @@ -61,7 +66,7 @@ public final class SkyLightEngine extends LayerLightEngine l1; + boolean flag1 = sourceId == Long.MAX_VALUE || flag && iy > jy; // Paper rename vars to iy > jy - return flag1 && level == 0 && mutableint.getValue() == 0 ? 0 : level + Math.max(1, mutableint.getValue()); + return flag1 && level == 0 && blockedLight == 0 ? 0 : level + Math.max(1, blockedLight); // Paper } } } @@ -101,10 +106,14 @@ public final class SkyLightEngine extends LayerLightEngine> 38); + int baseY = (int) ((id << 52) >> 52); + int baseZ = (int) ((id << 26) >> 38); + long k = SectionPos.blockPosAsSectionLong(baseX, baseY, baseZ); + int i1 = baseY & 15; + int j1 = baseY >> 4; + // Paper end int k1; if (i1 != 0) { @@ -119,15 +128,16 @@ public final class SkyLightEngine extends LayerLightEngine> 38); + int baseY = (int) ((id << 52) >> 52); + int baseZ = (int) ((id << 26) >> 38); + long j1 = SectionPos.blockPosAsSectionLong(baseX, baseY, baseZ); + DataLayer nibblearray = this.storage.updating.getUpdatingOptimized(j1); + // Paper end Direction[] aenumdirection = SkyLightEngine.DIRECTIONS; int k1 = aenumdirection.length; for (int l1 = 0; l1 < k1; ++l1) { Direction enumdirection = aenumdirection[l1]; - long i2 = BlockPos.offset(id, enumdirection); - long j2 = SectionPos.blockToSection(i2); + // Paper start + int newX = baseX + enumdirection.getStepX(); + int newY = baseY + enumdirection.getStepY(); + int newZ = baseZ + enumdirection.getStepZ(); + long i2 = BlockPos.asLong(newX, newY, newZ); + long j2 = SectionPos.blockPosAsSectionLong(newX, newY, newZ); + // Paper end DataLayer nibblearray1; if (j1 == j2) { nibblearray1 = nibblearray; } else { - nibblearray1 = ((SkyLightSectionStorage) this.storage).getDataLayer(j2, true); + nibblearray1 = ((SkyLightSectionStorage) this.storage).updating.getUpdatingOptimized(j2); // Paper } if (nibblearray1 != null) { if (i2 != excludedId) { - int k2 = this.computeLevelFromNeighbor(i2, id, this.getLevel(nibblearray1, i2)); + int k2 = this.computeLevelFromNeighbor(i2, id, this.getNibbleLightInverse(nibblearray1, newX, newY, newZ)); // Paper if (l > k2) { l = k2; @@ -215,7 +235,7 @@ public final class SkyLightEngine extends LayerLightEngine> 38); + int baseY = (int) ((blockPos << 52) >> 52); + int baseZ = (int) ((blockPos << 26) >> 38); + long j = SectionPos.blockPosAsSectionLong(baseX, baseY, baseZ); + // Paper end int k = SectionPos.y(j); synchronized (this.visibleUpdateLock) { // Paper - avoid copying light data SkyLightSectionStorage.SkyDataLayerStorageMap lightenginestoragesky_a = (SkyLightSectionStorage.SkyDataLayerStorageMap) this.e_visible; // Paper - avoid copying light data - must be after lock acquire @@ -49,7 +54,7 @@ public class SkyLightSectionStorage extends LayerLightSectionStorage> 52) & 15, (int) baseZ & 15); // Paper - y changed above } else { return 15; } @@ -168,7 +173,7 @@ public class SkyLightSectionStorage extends LayerLightSectionStorage> 42) << 4; // Paper + int baseY = (int) (i << 44 >> 44) << 4; // Paper + int baseZ = (int) (i << 22 >> 42) << 4; // Paper j = this.getLevel(i); if (j != 2 && !this.sectionsToRemoveSourcesFrom.contains(i) && this.sectionsWithSources.add(i)) { int l; @@ -203,10 +211,10 @@ public class SkyLightSectionStorage extends LayerLightSectionStorage> 42) << 4; // Paper + int baseY = (int) (i << 44 >> 44) << 4; // Paper + int baseZ = (int) (i << 22 >> 42) << 4; // Paper if (this.sectionsWithSources.remove(i) && this.storingLightForSection(i)) { for (j = 0; j < 16; ++j) { for (k = 0; k < 16; ++k) { - long l3 = BlockPos.asLong(SectionPos.sectionToBlockCoord(SectionPos.x(i)) + j, SectionPos.sectionToBlockCoord(SectionPos.y(i)) + 16 - 1, SectionPos.sectionToBlockCoord(SectionPos.z(i)) + k); + long l3 = BlockPos.asLong(baseX + j, baseY + 16 - 1, baseZ + k); // Paper lightProvider.checkEdge(Long.MAX_VALUE, l3, 15, false); }