mirror of
https://github.com/VolmitSoftware/Iris.git
synced 2026-10-26 14:00:26 +00:00
Pregen failure handling
- Chunk generator reports generation failures to the running pregen job - Pregen methods forward generation failures to the async method - Async pregen fails every outstanding request through an in-flight ledger - In-flight requests settle once and ignore late completions - Pregen aborts with the failing chunk as its cause - Admission drain waits with a 60 second deadline - Closing the admission gate fails leftover requests - Tests cover failure propagation, the ledger and the drain deadline
This commit is contained in:
1 parent
3722602a78
commit
6c7796f12f
16 files changed
+436
-14
No files matched your search
@@ -30,6 +30,7 @@ import java.util.concurrent.Semaphore;
|
|||||||
import art.arcane.iris.spi.IrisServices;
|
import art.arcane.iris.spi.IrisServices;
|
||||||
import art.arcane.iris.platform.bukkit.BukkitPlatform;
|
import art.arcane.iris.platform.bukkit.BukkitPlatform;
|
||||||
import art.arcane.iris.configuration.IrisSettings;
|
import art.arcane.iris.configuration.IrisSettings;
|
||||||
|
import art.arcane.iris.studio.view.PregeneratorJob;
|
||||||
import art.arcane.iris.world.IrisWorlds;
|
import art.arcane.iris.world.IrisWorlds;
|
||||||
import art.arcane.iris.pack.loading.IrisData;
|
import art.arcane.iris.pack.loading.IrisData;
|
||||||
import art.arcane.iris.platform.bukkit.nms.INMS;
|
import art.arcane.iris.platform.bukkit.nms.INMS;
|
||||||
@@ -1290,6 +1291,15 @@ public class BukkitChunkGenerator extends ChunkGenerator implements PlatformChun
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void generateNoise(@NotNull WorldInfo world, @NotNull Random random, int x, int z, @NotNull ChunkGenerator.ChunkData d) {
|
public void generateNoise(@NotNull WorldInfo world, @NotNull Random random, int x, int z, @NotNull ChunkGenerator.ChunkData d) {
|
||||||
|
try {
|
||||||
|
generateNoiseChunk(world, random, x, z, d);
|
||||||
|
} catch (Throwable e) {
|
||||||
|
PregeneratorJob.reportChunkGenerationFailure(this.world.identity(), x, z, e);
|
||||||
|
throw e;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void generateNoiseChunk(WorldInfo world, Random random, int x, int z, ChunkGenerator.ChunkData d) {
|
||||||
if (closing) {
|
if (closing) {
|
||||||
throw new IllegalStateException("Iris chunk generation was rejected while the generator is closing.");
|
throw new IllegalStateException("Iris chunk generation was rejected while the generator is closing.");
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -254,6 +254,14 @@ public class PregeneratorJob implements PregenListener, PregenRenderSource {
|
|||||||
return instance.get();
|
return instance.get();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public static void reportChunkGenerationFailure(String worldIdentity, int chunkX, int chunkZ, Throwable failure) {
|
||||||
|
PregeneratorJob inst = instance.get();
|
||||||
|
if (inst == null || worldIdentity == null || !worldIdentity.equals(inst.worldIdentity())) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
inst.pregenerator.onChunkGenerationFailed(chunkX, chunkZ, failure);
|
||||||
|
}
|
||||||
|
|
||||||
public static boolean pauseResume() {
|
public static boolean pauseResume() {
|
||||||
PregeneratorJob inst = instance.get();
|
PregeneratorJob inst = instance.get();
|
||||||
return inst != null && inst.togglePause();
|
return inst != null && inst.togglePause();
|
||||||
|
|||||||
@@ -85,6 +85,11 @@ public class AsyncOrMedievalPregenMethod implements PregeneratorMethod {
|
|||||||
method.onRegionBounds(minRegionX, minRegionZ, maxRegionX, maxRegionZ);
|
method.onRegionBounds(minRegionX, minRegionZ, maxRegionX, maxRegionZ);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void onChunkGenerationFailed(int chunkX, int chunkZ, Throwable failure) {
|
||||||
|
method.onChunkGenerationFailed(chunkX, chunkZ, failure);
|
||||||
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void onPregenStart(int centerBlockX, int centerBlockZ) {
|
public void onPregenStart(int centerBlockX, int centerBlockZ) {
|
||||||
method.onPregenStart(centerBlockX, centerBlockZ);
|
method.onPregenStart(centerBlockX, centerBlockZ);
|
||||||
|
|||||||
@@ -21,6 +21,7 @@ package art.arcane.iris.world.pregen;
|
|||||||
import art.arcane.iris.spi.IrisLogging;
|
import art.arcane.iris.spi.IrisLogging;
|
||||||
import art.arcane.iris.world.lifecycle.WorldLifecycleService;
|
import art.arcane.iris.world.lifecycle.WorldLifecycleService;
|
||||||
import art.arcane.volmlib.nativelib.terrain.NativeWorkerPool;
|
import art.arcane.volmlib.nativelib.terrain.NativeWorkerPool;
|
||||||
|
import java.util.Map;
|
||||||
import java.util.Objects;
|
import java.util.Objects;
|
||||||
import art.arcane.iris.world.IrisPaperLikeBackendMode;
|
import art.arcane.iris.world.IrisPaperLikeBackendMode;
|
||||||
import art.arcane.iris.world.IrisRuntimeSchedulerMode;
|
import art.arcane.iris.world.IrisRuntimeSchedulerMode;
|
||||||
@@ -55,6 +56,7 @@ import java.util.concurrent.TimeoutException;
|
|||||||
import java.util.concurrent.atomic.AtomicBoolean;
|
import java.util.concurrent.atomic.AtomicBoolean;
|
||||||
import java.util.concurrent.atomic.AtomicInteger;
|
import java.util.concurrent.atomic.AtomicInteger;
|
||||||
import java.util.concurrent.atomic.AtomicLong;
|
import java.util.concurrent.atomic.AtomicLong;
|
||||||
|
import java.util.concurrent.atomic.AtomicReference;
|
||||||
|
|
||||||
public class AsyncPregenMethod implements PregeneratorMethod {
|
public class AsyncPregenMethod implements PregeneratorMethod {
|
||||||
// THREAD_COUNT records the pool's original size while boosted; BOOST_HOLDERS counts live
|
// THREAD_COUNT records the pool's original size while boosted; BOOST_HOLDERS counts live
|
||||||
@@ -64,7 +66,8 @@ public class AsyncPregenMethod implements PregeneratorMethod {
|
|||||||
private static final AtomicInteger BOOST_HOLDERS = new AtomicInteger();
|
private static final AtomicInteger BOOST_HOLDERS = new AtomicInteger();
|
||||||
private static final int ADAPTIVE_SLOW_REQUEST_STEP = 3;
|
private static final int ADAPTIVE_SLOW_REQUEST_STEP = 3;
|
||||||
private static final int ADAPTIVE_RECOVERY_INTERVAL = 8;
|
private static final int ADAPTIVE_RECOVERY_INTERVAL = 8;
|
||||||
private static final long CLOSE_DRAIN_WARNING_SECONDS = 60L;
|
private static final long CLOSE_DRAIN_WARNING_SECONDS = 20L;
|
||||||
|
private static final long CLOSE_DRAIN_TIMEOUT_SECONDS = 60L;
|
||||||
private static final long FLUSH_TIMEOUT_SECONDS = 120L;
|
private static final long FLUSH_TIMEOUT_SECONDS = 120L;
|
||||||
private static final long MANTLE_CLEANUP_DRAIN_SECONDS = 60L;
|
private static final long MANTLE_CLEANUP_DRAIN_SECONDS = 60L;
|
||||||
private static final long CHUNK_FLUSH_DRAIN_SECONDS = 30L;
|
private static final long CHUNK_FLUSH_DRAIN_SECONDS = 30L;
|
||||||
@@ -113,6 +116,8 @@ public class AsyncPregenMethod implements PregeneratorMethod {
|
|||||||
private final AtomicLong failed = new AtomicLong();
|
private final AtomicLong failed = new AtomicLong();
|
||||||
private final AtomicLong lastProgressAt = new AtomicLong(M.ms());
|
private final AtomicLong lastProgressAt = new AtomicLong(M.ms());
|
||||||
private final AtomicBoolean closing = new AtomicBoolean();
|
private final AtomicBoolean closing = new AtomicBoolean();
|
||||||
|
private final PregenInFlightRequests inFlightRequests = new PregenInFlightRequests();
|
||||||
|
private final AtomicReference<GenerationFailure> generationFailure = new AtomicReference<>();
|
||||||
private final AtomicBoolean holdsWorkerBoost = new AtomicBoolean();
|
private final AtomicBoolean holdsWorkerBoost = new AtomicBoolean();
|
||||||
private volatile Engine metricsEngine;
|
private volatile Engine metricsEngine;
|
||||||
private volatile Mantle cachedMantle;
|
private volatile Mantle cachedMantle;
|
||||||
@@ -449,10 +454,20 @@ public class AsyncPregenMethod implements PregeneratorMethod {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private void completeChunk(int x, int z, PregenListener listener, Chunk chunk, Throwable throwable) {
|
private void completeChunk(int x, int z, PregenListener listener, Chunk chunk, Throwable throwable) {
|
||||||
|
PregenListener owner = inFlightRequests.settle(PregenInFlightRequests.key(x, z));
|
||||||
|
if (owner == null) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
settleChunk(x, z, owner, chunk, throwable, true);
|
||||||
|
}
|
||||||
|
|
||||||
|
private void settleChunk(int x, int z, PregenListener listener, Chunk chunk, Throwable throwable, boolean reportFailure) {
|
||||||
boolean success = false;
|
boolean success = false;
|
||||||
try {
|
try {
|
||||||
if (throwable != null) {
|
if (throwable != null) {
|
||||||
onChunkFutureFailure(x, z, throwable);
|
if (reportFailure) {
|
||||||
|
onChunkFutureFailure(x, z, throwable);
|
||||||
|
}
|
||||||
onChunkFailedToLoad(x, z);
|
onChunkFailedToLoad(x, z);
|
||||||
listener.onChunkFailed(x, z);
|
listener.onChunkFailed(x, z);
|
||||||
} else if (chunk == null) {
|
} else if (chunk == null) {
|
||||||
@@ -652,11 +667,57 @@ public class AsyncPregenMethod implements PregeneratorMethod {
|
|||||||
+ " stalledForMs=" + stalledFor;
|
+ " stalledForMs=" + stalledFor;
|
||||||
}
|
}
|
||||||
|
|
||||||
private void markSubmitted() {
|
private void markSubmitted(int x, int z, PregenListener listener) {
|
||||||
|
inFlightRequests.add(PregenInFlightRequests.key(x, z), listener);
|
||||||
submitted.incrementAndGet();
|
submitted.incrementAndGet();
|
||||||
inFlight.incrementAndGet();
|
inFlight.incrementAndGet();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void onChunkGenerationFailed(int chunkX, int chunkZ, Throwable failure) {
|
||||||
|
GenerationFailure recorded = new GenerationFailure(chunkX, chunkZ, failure);
|
||||||
|
if (generationFailure.compareAndSet(null, recorded)) {
|
||||||
|
IrisLogging.error("Async pregen aborting: Iris failed to generate chunk " + chunkX + "," + chunkZ
|
||||||
|
+ " and the server's chunk system will not complete the " + inFlightRequests.size()
|
||||||
|
+ " outstanding chunk request(s). " + metricsSnapshot());
|
||||||
|
}
|
||||||
|
failOutstandingRequests(failure);
|
||||||
|
}
|
||||||
|
|
||||||
|
private void failOutstandingRequests(Throwable failure) {
|
||||||
|
Map<Long, PregenListener> outstanding = inFlightRequests.drain();
|
||||||
|
for (Map.Entry<Long, PregenListener> entry : outstanding.entrySet()) {
|
||||||
|
long key = entry.getKey();
|
||||||
|
settleChunk(PregenInFlightRequests.chunkX(key), PregenInFlightRequests.chunkZ(key), entry.getValue(),
|
||||||
|
null, failure, false);
|
||||||
|
}
|
||||||
|
admission.wake();
|
||||||
|
backpressure.signalProgress();
|
||||||
|
}
|
||||||
|
|
||||||
|
private void throwIfGenerationFailed() {
|
||||||
|
GenerationFailure failure = generationFailure.get();
|
||||||
|
if (failure != null) {
|
||||||
|
throw new IllegalStateException("Pregen aborted: Iris failed to generate chunk " + failure.chunkX() + ","
|
||||||
|
+ failure.chunkZ() + " in world " + world.getName()
|
||||||
|
+ " and the server's chunk system stopped completing requests.", failure.cause());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void abandonOutstandingRequests(PregenAdmissionGate.Drain drain) {
|
||||||
|
Map<Long, PregenListener> abandoned = inFlightRequests.drain();
|
||||||
|
IrisLogging.error("Async pregen abandoned " + abandoned.size() + " chunk request(s) that did not complete within "
|
||||||
|
+ CLOSE_DRAIN_TIMEOUT_SECONDS + "s of closing (" + drain.outstanding()
|
||||||
|
+ " permit(s) still held). They are not cached and regenerate on the next run. " + metricsSnapshot());
|
||||||
|
IllegalStateException cause = new IllegalStateException(
|
||||||
|
"Async chunk request never completed before the pregen closed in world " + world.getName() + ".");
|
||||||
|
for (Map.Entry<Long, PregenListener> entry : abandoned.entrySet()) {
|
||||||
|
long key = entry.getKey();
|
||||||
|
settleChunk(PregenInFlightRequests.chunkX(key), PregenInFlightRequests.chunkZ(key), entry.getValue(),
|
||||||
|
null, cause, false);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
private void markFinished(boolean success) {
|
private void markFinished(boolean success) {
|
||||||
if (success) {
|
if (success) {
|
||||||
completed.incrementAndGet();
|
completed.incrementAndGet();
|
||||||
@@ -774,11 +835,17 @@ public class AsyncPregenMethod implements PregeneratorMethod {
|
|||||||
// A stop request interrupts the pregen worker; shield the drain and flush so chunks still hit disk.
|
// A stop request interrupts the pregen worker; shield the drain and flush so chunks still hit disk.
|
||||||
boolean interrupted = Thread.interrupted();
|
boolean interrupted = Thread.interrupted();
|
||||||
try {
|
try {
|
||||||
interrupted |= admission.awaitDrain(
|
PregenAdmissionGate.Drain drain = admission.awaitDrain(
|
||||||
CLOSE_DRAIN_WARNING_SECONDS,
|
CLOSE_DRAIN_WARNING_SECONDS,
|
||||||
TimeUnit.SECONDS,
|
TimeUnit.SECONDS,
|
||||||
|
CLOSE_DRAIN_TIMEOUT_SECONDS,
|
||||||
|
TimeUnit.SECONDS,
|
||||||
() -> IrisLogging.warn("Async pregen is still draining outstanding chunks. " + metricsSnapshot())
|
() -> IrisLogging.warn("Async pregen is still draining outstanding chunks. " + metricsSnapshot())
|
||||||
);
|
);
|
||||||
|
interrupted |= drain.interrupted();
|
||||||
|
if (!drain.drained()) {
|
||||||
|
abandonOutstandingRequests(drain);
|
||||||
|
}
|
||||||
|
|
||||||
mantleCleanup.close(MANTLE_CLEANUP_DRAIN_SECONDS, TimeUnit.SECONDS);
|
mantleCleanup.close(MANTLE_CLEANUP_DRAIN_SECONDS, TimeUnit.SECONDS);
|
||||||
flushAllRemainingChunks();
|
flushAllRemainingChunks();
|
||||||
@@ -808,7 +875,7 @@ public class AsyncPregenMethod implements PregeneratorMethod {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private boolean isCancelled() {
|
private boolean isCancelled() {
|
||||||
return closing.get() || Thread.currentThread().isInterrupted();
|
return closing.get() || generationFailure.get() != null || Thread.currentThread().isInterrupted();
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
@@ -835,6 +902,7 @@ public class AsyncPregenMethod implements PregeneratorMethod {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void generateChunk(int x, int z, PregenListener listener) {
|
public void generateChunk(int x, int z, PregenListener listener) {
|
||||||
|
throwIfGenerationFailed();
|
||||||
listener.onChunkGenerating(x, z);
|
listener.onChunkGenerating(x, z);
|
||||||
if (MantleHeapPressure.overHighWater()) {
|
if (MantleHeapPressure.overHighWater()) {
|
||||||
reclaimMemory();
|
reclaimMemory();
|
||||||
@@ -865,9 +933,14 @@ public class AsyncPregenMethod implements PregeneratorMethod {
|
|||||||
recordPermitWait(waited.permitMs());
|
recordPermitWait(waited.permitMs());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
throwIfGenerationFailed();
|
||||||
regionPending.computeIfAbsent(rkey(x >> 5, z >> 5), k -> new AtomicInteger(1)).incrementAndGet();
|
regionPending.computeIfAbsent(rkey(x >> 5, z >> 5), k -> new AtomicInteger(1)).incrementAndGet();
|
||||||
markSubmitted();
|
markSubmitted(x, z, listener);
|
||||||
executor.generate(x, z, listener);
|
executor.generate(x, z, listener);
|
||||||
|
GenerationFailure failure = generationFailure.get();
|
||||||
|
if (failure != null) {
|
||||||
|
failOutstandingRequests(failure.cause());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private void reclaimHeapPressure() {
|
private void reclaimHeapPressure() {
|
||||||
@@ -1104,6 +1177,9 @@ public class AsyncPregenMethod implements PregeneratorMethod {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private record GenerationFailure(int chunkX, int chunkZ, Throwable cause) {
|
||||||
|
}
|
||||||
|
|
||||||
private record ChunkAsyncMethodSelection(Method urgentMethod, Method standardMethod, String mode) {
|
private record ChunkAsyncMethodSelection(Method urgentMethod, Method standardMethod, String mode) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -189,6 +189,11 @@ public class CachedPregenMethod implements PregeneratorMethod {
|
|||||||
method.onRegionBounds(minRegionX, minRegionZ, maxRegionX, maxRegionZ);
|
method.onRegionBounds(minRegionX, minRegionZ, maxRegionX, maxRegionZ);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void onChunkGenerationFailed(int chunkX, int chunkZ, Throwable failure) {
|
||||||
|
method.onChunkGenerationFailed(chunkX, chunkZ, failure);
|
||||||
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void onPregenStart(int centerBlockX, int centerBlockZ) {
|
public void onPregenStart(int centerBlockX, int centerBlockZ) {
|
||||||
method.onPregenStart(centerBlockX, centerBlockZ);
|
method.onPregenStart(centerBlockX, centerBlockZ);
|
||||||
|
|||||||
@@ -78,6 +78,11 @@ public class HybridPregenMethod implements PregeneratorMethod {
|
|||||||
inWorld.onRegionBounds(minRegionX, minRegionZ, maxRegionX, maxRegionZ);
|
inWorld.onRegionBounds(minRegionX, minRegionZ, maxRegionX, maxRegionZ);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void onChunkGenerationFailed(int chunkX, int chunkZ, Throwable failure) {
|
||||||
|
inWorld.onChunkGenerationFailed(chunkX, chunkZ, failure);
|
||||||
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void onPregenStart(int centerBlockX, int centerBlockZ) {
|
public void onPregenStart(int centerBlockX, int centerBlockZ) {
|
||||||
inWorld.onPregenStart(centerBlockX, centerBlockZ);
|
inWorld.onPregenStart(centerBlockX, centerBlockZ);
|
||||||
|
|||||||
@@ -215,6 +215,10 @@ public class IrisPregenerator {
|
|||||||
signalState();
|
signalState();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public void onChunkGenerationFailed(int chunkX, int chunkZ, Throwable failure) {
|
||||||
|
generator.onChunkGenerationFailed(chunkX, chunkZ, failure);
|
||||||
|
}
|
||||||
|
|
||||||
public void start() {
|
public void start() {
|
||||||
PrecisionStopwatch p = PrecisionStopwatch.start();
|
PrecisionStopwatch p = PrecisionStopwatch.start();
|
||||||
boolean completed = false;
|
boolean completed = false;
|
||||||
|
|||||||
@@ -111,14 +111,20 @@ public final class PregenAdmissionGate {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public boolean awaitDrain(long warningInterval, TimeUnit timeUnit, Runnable onWait) {
|
public Drain awaitDrain(long warningInterval, TimeUnit warningUnit, long deadline, TimeUnit deadlineUnit, Runnable onWait) {
|
||||||
|
long warningNanos = warningUnit.toNanos(warningInterval);
|
||||||
|
long deadlineAt = System.nanoTime() + deadlineUnit.toNanos(deadline);
|
||||||
boolean interrupted = false;
|
boolean interrupted = false;
|
||||||
lock.lock();
|
lock.lock();
|
||||||
try {
|
try {
|
||||||
while (free < permits) {
|
while (free < permits) {
|
||||||
|
long remaining = deadlineAt - System.nanoTime();
|
||||||
|
if (remaining <= 0L) {
|
||||||
|
return new Drain(false, interrupted, permits - free);
|
||||||
|
}
|
||||||
boolean signalled = false;
|
boolean signalled = false;
|
||||||
try {
|
try {
|
||||||
signalled = changed.await(warningInterval, timeUnit);
|
signalled = changed.awaitNanos(Math.min(warningNanos, remaining)) > 0L;
|
||||||
} catch (InterruptedException e) {
|
} catch (InterruptedException e) {
|
||||||
interrupted = true;
|
interrupted = true;
|
||||||
continue;
|
continue;
|
||||||
@@ -127,10 +133,12 @@ public final class PregenAdmissionGate {
|
|||||||
onWait.run();
|
onWait.run();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
return new Drain(true, interrupted, 0);
|
||||||
} finally {
|
} finally {
|
||||||
lock.unlock();
|
lock.unlock();
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
return interrupted;
|
public record Drain(boolean drained, boolean interrupted, int outstanding) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -0,0 +1,47 @@
|
|||||||
|
package art.arcane.iris.world.pregen;
|
||||||
|
|
||||||
|
import java.util.HashMap;
|
||||||
|
import java.util.Iterator;
|
||||||
|
import java.util.Map;
|
||||||
|
import java.util.Objects;
|
||||||
|
import java.util.concurrent.ConcurrentHashMap;
|
||||||
|
|
||||||
|
public final class PregenInFlightRequests {
|
||||||
|
private final ConcurrentHashMap<Long, PregenListener> requests = new ConcurrentHashMap<>();
|
||||||
|
|
||||||
|
public static long key(int chunkX, int chunkZ) {
|
||||||
|
return ((long) chunkX << 32) | (chunkZ & 0xFFFFFFFFL);
|
||||||
|
}
|
||||||
|
|
||||||
|
public static int chunkX(long key) {
|
||||||
|
return (int) (key >> 32);
|
||||||
|
}
|
||||||
|
|
||||||
|
public static int chunkZ(long key) {
|
||||||
|
return (int) key;
|
||||||
|
}
|
||||||
|
|
||||||
|
public boolean add(long key, PregenListener listener) {
|
||||||
|
return requests.putIfAbsent(key, Objects.requireNonNull(listener, "listener")) == null;
|
||||||
|
}
|
||||||
|
|
||||||
|
public PregenListener settle(long key) {
|
||||||
|
return requests.remove(key);
|
||||||
|
}
|
||||||
|
|
||||||
|
public Map<Long, PregenListener> drain() {
|
||||||
|
HashMap<Long, PregenListener> drained = new HashMap<>();
|
||||||
|
Iterator<Map.Entry<Long, PregenListener>> iterator = requests.entrySet().iterator();
|
||||||
|
while (iterator.hasNext()) {
|
||||||
|
Map.Entry<Long, PregenListener> entry = iterator.next();
|
||||||
|
if (requests.remove(entry.getKey(), entry.getValue())) {
|
||||||
|
drained.put(entry.getKey(), entry.getValue());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return drained;
|
||||||
|
}
|
||||||
|
|
||||||
|
public int size() {
|
||||||
|
return requests.size();
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -83,6 +83,9 @@ public interface PregeneratorMethod {
|
|||||||
default void onRegionBounds(int minRegionX, int minRegionZ, int maxRegionX, int maxRegionZ) {
|
default void onRegionBounds(int minRegionX, int minRegionZ, int maxRegionX, int maxRegionZ) {
|
||||||
}
|
}
|
||||||
|
|
||||||
|
default void onChunkGenerationFailed(int chunkX, int chunkZ, Throwable failure) {
|
||||||
|
}
|
||||||
|
|
||||||
default void onPregenStart(int centerBlockX, int centerBlockZ) {
|
default void onPregenStart(int centerBlockX, int centerBlockZ) {
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
+147
@@ -0,0 +1,147 @@
|
|||||||
|
package art.arcane.iris.world.pregen;
|
||||||
|
|
||||||
|
import org.bukkit.Chunk;
|
||||||
|
import org.bukkit.World;
|
||||||
|
import org.junit.Test;
|
||||||
|
|
||||||
|
import java.lang.reflect.Field;
|
||||||
|
import java.lang.reflect.Method;
|
||||||
|
import java.util.concurrent.ConcurrentHashMap;
|
||||||
|
import java.util.concurrent.atomic.AtomicBoolean;
|
||||||
|
import java.util.concurrent.atomic.AtomicInteger;
|
||||||
|
import java.util.concurrent.atomic.AtomicLong;
|
||||||
|
import java.util.concurrent.atomic.AtomicReference;
|
||||||
|
|
||||||
|
import static org.junit.Assert.assertEquals;
|
||||||
|
import static org.junit.Assert.assertNotNull;
|
||||||
|
import static org.junit.Assert.assertSame;
|
||||||
|
import static org.junit.Assert.assertThrows;
|
||||||
|
import static org.mockito.Mockito.CALLS_REAL_METHODS;
|
||||||
|
import static org.mockito.Mockito.mock;
|
||||||
|
import static org.mockito.Mockito.never;
|
||||||
|
import static org.mockito.Mockito.verify;
|
||||||
|
import static org.mockito.Mockito.when;
|
||||||
|
|
||||||
|
public class AsyncPregenGenerationFailureTest {
|
||||||
|
@Test
|
||||||
|
public void aGenerationFailureFailsEveryOutstandingRequestAndReleasesTheirPermits() throws Exception {
|
||||||
|
Harness harness = Harness.withOutstanding(2);
|
||||||
|
IllegalStateException cause = new IllegalStateException("Accepted hydrology layer exceeds the mantle bounds");
|
||||||
|
|
||||||
|
harness.method.onChunkGenerationFailed(48, -4, cause);
|
||||||
|
|
||||||
|
assertEquals(2, harness.admission.availablePermits());
|
||||||
|
assertEquals(2, harness.failed.get());
|
||||||
|
assertEquals(0, harness.inFlight.get());
|
||||||
|
assertEquals(0, harness.requests.size());
|
||||||
|
verify(harness.listener).onChunkFailed(10, 0);
|
||||||
|
verify(harness.listener).onChunkFailed(11, 0);
|
||||||
|
|
||||||
|
IllegalStateException abort = assertThrows(IllegalStateException.class,
|
||||||
|
() -> harness.method.generateChunk(12, 0, harness.listener));
|
||||||
|
assertSame(cause, abort.getCause());
|
||||||
|
verify(harness.listener, never()).onChunkGenerating(12, 0);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void aLateCompletionForASettledRequestIsIgnored() throws Exception {
|
||||||
|
Harness harness = Harness.withOutstanding(2);
|
||||||
|
harness.method.onChunkGenerationFailed(48, -4, new IllegalStateException("boom"));
|
||||||
|
|
||||||
|
harness.completeChunk(10, 0, null, null);
|
||||||
|
harness.completeChunk(11, 0, null, new IllegalStateException("late failure"));
|
||||||
|
|
||||||
|
assertEquals(2, harness.failed.get());
|
||||||
|
assertEquals(0, harness.completed.get());
|
||||||
|
assertEquals(0, harness.inFlight.get());
|
||||||
|
assertEquals(2, harness.admission.availablePermits());
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void closingAbandonsRequestsThatNeverCompleteAndReturnsTheirPermits() throws Exception {
|
||||||
|
Harness harness = Harness.withOutstanding(2);
|
||||||
|
|
||||||
|
harness.abandon(new PregenAdmissionGate.Drain(false, false, 2));
|
||||||
|
|
||||||
|
assertEquals(2, harness.admission.availablePermits());
|
||||||
|
assertEquals(2, harness.failed.get());
|
||||||
|
assertEquals(0, harness.requests.size());
|
||||||
|
verify(harness.listener).onChunkFailed(10, 0);
|
||||||
|
verify(harness.listener).onChunkFailed(11, 0);
|
||||||
|
}
|
||||||
|
|
||||||
|
private static final class Harness {
|
||||||
|
private final AsyncPregenMethod method;
|
||||||
|
private final PregenAdmissionGate admission;
|
||||||
|
private final PregenInFlightRequests requests;
|
||||||
|
private final PregenListener listener;
|
||||||
|
private final AtomicInteger inFlight;
|
||||||
|
private final AtomicLong failed;
|
||||||
|
private final AtomicLong completed;
|
||||||
|
|
||||||
|
private Harness(AsyncPregenMethod method, PregenAdmissionGate admission, PregenInFlightRequests requests,
|
||||||
|
PregenListener listener, AtomicInteger inFlight, AtomicLong failed, AtomicLong completed) {
|
||||||
|
this.method = method;
|
||||||
|
this.admission = admission;
|
||||||
|
this.requests = requests;
|
||||||
|
this.listener = listener;
|
||||||
|
this.inFlight = inFlight;
|
||||||
|
this.failed = failed;
|
||||||
|
this.completed = completed;
|
||||||
|
}
|
||||||
|
|
||||||
|
static Harness withOutstanding(int outstanding) throws Exception {
|
||||||
|
AsyncPregenMethod method = mock(AsyncPregenMethod.class, CALLS_REAL_METHODS);
|
||||||
|
World world = mock(World.class);
|
||||||
|
when(world.getName()).thenReturn("qa");
|
||||||
|
PregenAdmissionGate admission = new PregenAdmissionGate(outstanding, 50L, System::currentTimeMillis);
|
||||||
|
PregenInFlightRequests requests = new PregenInFlightRequests();
|
||||||
|
PregenListener listener = mock(PregenListener.class);
|
||||||
|
AtomicInteger inFlight = new AtomicInteger(outstanding);
|
||||||
|
AtomicLong failed = new AtomicLong();
|
||||||
|
AtomicLong completed = new AtomicLong();
|
||||||
|
for (int index = 0; index < outstanding; index++) {
|
||||||
|
assertNotNull(admission.admit(() -> false, () -> false));
|
||||||
|
requests.add(PregenInFlightRequests.key(10 + index, 0), listener);
|
||||||
|
}
|
||||||
|
set(method, "world", world);
|
||||||
|
set(method, "admission", admission);
|
||||||
|
set(method, "backpressure", mock(PregenMantleBackpressure.class));
|
||||||
|
set(method, "mantleCleanup", mock(PregenSerialWorker.class));
|
||||||
|
set(method, "inFlightRequests", requests);
|
||||||
|
set(method, "generationFailure", new AtomicReference<>());
|
||||||
|
set(method, "regionPending", new ConcurrentHashMap<>());
|
||||||
|
set(method, "lastFailedReleaseLogAt", new AtomicLong());
|
||||||
|
set(method, "slowRequestWarnIntervalMs", 15_000);
|
||||||
|
set(method, "inFlight", inFlight);
|
||||||
|
set(method, "submitted", new AtomicLong(outstanding));
|
||||||
|
set(method, "completed", completed);
|
||||||
|
set(method, "failed", failed);
|
||||||
|
set(method, "lastProgressAt", new AtomicLong());
|
||||||
|
set(method, "adaptiveInFlightLimit", new AtomicInteger(outstanding));
|
||||||
|
set(method, "threads", outstanding);
|
||||||
|
set(method, "closing", new AtomicBoolean());
|
||||||
|
return new Harness(method, admission, requests, listener, inFlight, failed, completed);
|
||||||
|
}
|
||||||
|
|
||||||
|
void completeChunk(int x, int z, Chunk chunk, Throwable throwable) throws Exception {
|
||||||
|
Method complete = AsyncPregenMethod.class.getDeclaredMethod(
|
||||||
|
"completeChunk", int.class, int.class, PregenListener.class, Chunk.class, Throwable.class);
|
||||||
|
complete.setAccessible(true);
|
||||||
|
complete.invoke(method, x, z, listener, chunk, throwable);
|
||||||
|
}
|
||||||
|
|
||||||
|
void abandon(PregenAdmissionGate.Drain drain) throws Exception {
|
||||||
|
Method abandon = AsyncPregenMethod.class.getDeclaredMethod(
|
||||||
|
"abandonOutstandingRequests", PregenAdmissionGate.Drain.class);
|
||||||
|
abandon.setAccessible(true);
|
||||||
|
abandon.invoke(method, drain);
|
||||||
|
}
|
||||||
|
|
||||||
|
private static void set(AsyncPregenMethod method, String name, Object value) throws Exception {
|
||||||
|
Field field = AsyncPregenMethod.class.getDeclaredField(name);
|
||||||
|
field.setAccessible(true);
|
||||||
|
field.set(method, value);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
+6
-2
@@ -140,9 +140,11 @@ public class AsyncPregenMethodConcurrencyCapTest {
|
|||||||
AtomicInteger warnings = new AtomicInteger();
|
AtomicInteger warnings = new AtomicInteger();
|
||||||
ExecutorService executor = Executors.newSingleThreadExecutor();
|
ExecutorService executor = Executors.newSingleThreadExecutor();
|
||||||
try {
|
try {
|
||||||
Future<Boolean> drain = executor.submit(() -> gate.awaitDrain(
|
Future<PregenAdmissionGate.Drain> drain = executor.submit(() -> gate.awaitDrain(
|
||||||
10L,
|
10L,
|
||||||
TimeUnit.MILLISECONDS,
|
TimeUnit.MILLISECONDS,
|
||||||
|
5L,
|
||||||
|
TimeUnit.SECONDS,
|
||||||
warnings::incrementAndGet
|
warnings::incrementAndGet
|
||||||
));
|
));
|
||||||
|
|
||||||
@@ -152,7 +154,9 @@ public class AsyncPregenMethodConcurrencyCapTest {
|
|||||||
gate.release();
|
gate.release();
|
||||||
gate.release();
|
gate.release();
|
||||||
|
|
||||||
assertFalse(drain.get(1L, TimeUnit.SECONDS));
|
PregenAdmissionGate.Drain result = drain.get(1L, TimeUnit.SECONDS);
|
||||||
|
assertTrue(result.drained());
|
||||||
|
assertFalse(result.interrupted());
|
||||||
assertTrue(warnings.get() > 0);
|
assertTrue(warnings.get() > 0);
|
||||||
assertEquals(2, gate.availablePermits());
|
assertEquals(2, gate.availablePermits());
|
||||||
} finally {
|
} finally {
|
||||||
|
|||||||
+2
@@ -464,6 +464,8 @@ public class AsyncPregenServerSaveOwnershipTest {
|
|||||||
set("regionPending", pendingRegions);
|
set("regionPending", pendingRegions);
|
||||||
set("pendingEvictions", evictions);
|
set("pendingEvictions", evictions);
|
||||||
set("chunkIoExecutor", (Executor) Runnable::run);
|
set("chunkIoExecutor", (Executor) Runnable::run);
|
||||||
|
set("generationFailure", new AtomicReference<>());
|
||||||
|
set("inFlightRequests", new PregenInFlightRequests());
|
||||||
when(chunk.getX()).thenReturn(2);
|
when(chunk.getX()).thenReturn(2);
|
||||||
when(chunk.getZ()).thenReturn(3);
|
when(chunk.getZ()).thenReturn(3);
|
||||||
when(binding.saveAndUnloadChunk(world, 2, 3)).thenReturn(true);
|
when(binding.saveAndUnloadChunk(world, 2, 3)).thenReturn(true);
|
||||||
|
|||||||
@@ -113,7 +113,8 @@ public class AsyncPregenWorkerBoostTest {
|
|||||||
AsyncPregenMethod method = mock(AsyncPregenMethod.class, CALLS_REAL_METHODS);
|
AsyncPregenMethod method = mock(AsyncPregenMethod.class, CALLS_REAL_METHODS);
|
||||||
PregenAdmissionGate admission = mock(PregenAdmissionGate.class);
|
PregenAdmissionGate admission = mock(PregenAdmissionGate.class);
|
||||||
IllegalStateException failure = new IllegalStateException("drain failed");
|
IllegalStateException failure = new IllegalStateException("drain failed");
|
||||||
when(admission.awaitDrain(anyLong(), any(TimeUnit.class), any(Runnable.class))).thenThrow(failure);
|
when(admission.awaitDrain(anyLong(), any(TimeUnit.class), anyLong(), any(TimeUnit.class), any(Runnable.class)))
|
||||||
|
.thenThrow(failure);
|
||||||
set(method, "closing", new AtomicBoolean());
|
set(method, "closing", new AtomicBoolean());
|
||||||
set(method, "holdsWorkerBoost", new AtomicBoolean(true));
|
set(method, "holdsWorkerBoost", new AtomicBoolean(true));
|
||||||
set(method, "admission", admission);
|
set(method, "admission", admission);
|
||||||
|
|||||||
@@ -12,6 +12,7 @@ import java.util.concurrent.atomic.AtomicInteger;
|
|||||||
import java.util.concurrent.atomic.AtomicLong;
|
import java.util.concurrent.atomic.AtomicLong;
|
||||||
|
|
||||||
import static org.junit.Assert.assertEquals;
|
import static org.junit.Assert.assertEquals;
|
||||||
|
import static org.junit.Assert.assertFalse;
|
||||||
import static org.junit.Assert.assertNotNull;
|
import static org.junit.Assert.assertNotNull;
|
||||||
import static org.junit.Assert.assertNull;
|
import static org.junit.Assert.assertNull;
|
||||||
import static org.junit.Assert.assertTrue;
|
import static org.junit.Assert.assertTrue;
|
||||||
@@ -162,7 +163,8 @@ public class PregenAdmissionGateTest {
|
|||||||
AtomicInteger warnings = new AtomicInteger();
|
AtomicInteger warnings = new AtomicInteger();
|
||||||
ExecutorService executor = Executors.newSingleThreadExecutor();
|
ExecutorService executor = Executors.newSingleThreadExecutor();
|
||||||
try {
|
try {
|
||||||
Future<Boolean> drain = executor.submit(() -> gate.awaitDrain(5L, TimeUnit.MILLISECONDS, warnings::incrementAndGet));
|
Future<PregenAdmissionGate.Drain> drain = executor.submit(() -> gate.awaitDrain(
|
||||||
|
5L, TimeUnit.MILLISECONDS, 5L, TimeUnit.SECONDS, warnings::incrementAndGet));
|
||||||
|
|
||||||
while (warnings.get() < 2) {
|
while (warnings.get() < 2) {
|
||||||
Thread.onSpinWait();
|
Thread.onSpinWait();
|
||||||
@@ -170,13 +172,46 @@ public class PregenAdmissionGateTest {
|
|||||||
gate.release();
|
gate.release();
|
||||||
gate.release();
|
gate.release();
|
||||||
|
|
||||||
assertEquals(Boolean.FALSE, drain.get(5, TimeUnit.SECONDS));
|
PregenAdmissionGate.Drain result = drain.get(5, TimeUnit.SECONDS);
|
||||||
|
assertTrue(result.drained());
|
||||||
|
assertFalse(result.interrupted());
|
||||||
|
assertEquals(0, result.outstanding());
|
||||||
assertEquals(2, gate.availablePermits());
|
assertEquals(2, gate.availablePermits());
|
||||||
} finally {
|
} finally {
|
||||||
executor.shutdownNow();
|
executor.shutdownNow();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void drainGivesUpAtItsDeadlineWhilePermitsStayHeld() throws Exception {
|
||||||
|
PregenAdmissionGate gate = new PregenAdmissionGate(2, GENEROUS_BOUND_MS, System::currentTimeMillis);
|
||||||
|
assertNotNull(gate.admit(() -> false, () -> false));
|
||||||
|
assertNotNull(gate.admit(() -> false, () -> false));
|
||||||
|
AtomicInteger warnings = new AtomicInteger();
|
||||||
|
|
||||||
|
PregenAdmissionGate.Drain result = gate.awaitDrain(
|
||||||
|
5L, TimeUnit.MILLISECONDS, 80L, TimeUnit.MILLISECONDS, warnings::incrementAndGet);
|
||||||
|
|
||||||
|
assertFalse(result.drained());
|
||||||
|
assertFalse(result.interrupted());
|
||||||
|
assertEquals(2, result.outstanding());
|
||||||
|
assertTrue(warnings.get() > 0);
|
||||||
|
assertEquals(0, gate.availablePermits());
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void drainReturnsAtOnceWhenNothingIsHeld() {
|
||||||
|
PregenAdmissionGate gate = new PregenAdmissionGate(2, GENEROUS_BOUND_MS, System::currentTimeMillis);
|
||||||
|
AtomicInteger warnings = new AtomicInteger();
|
||||||
|
|
||||||
|
PregenAdmissionGate.Drain result = gate.awaitDrain(
|
||||||
|
5L, TimeUnit.MILLISECONDS, 5L, TimeUnit.SECONDS, warnings::incrementAndGet);
|
||||||
|
|
||||||
|
assertTrue(result.drained());
|
||||||
|
assertEquals(0, result.outstanding());
|
||||||
|
assertEquals(0, warnings.get());
|
||||||
|
}
|
||||||
|
|
||||||
@Test(expected = IllegalArgumentException.class)
|
@Test(expected = IllegalArgumentException.class)
|
||||||
public void aGateWithoutPermitsIsRejected() {
|
public void aGateWithoutPermitsIsRejected() {
|
||||||
new PregenAdmissionGate(0, GENEROUS_BOUND_MS, System::currentTimeMillis);
|
new PregenAdmissionGate(0, GENEROUS_BOUND_MS, System::currentTimeMillis);
|
||||||
|
|||||||
@@ -0,0 +1,62 @@
|
|||||||
|
package art.arcane.iris.world.pregen;
|
||||||
|
|
||||||
|
import org.junit.Test;
|
||||||
|
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
|
import static org.junit.Assert.assertEquals;
|
||||||
|
import static org.junit.Assert.assertFalse;
|
||||||
|
import static org.junit.Assert.assertNull;
|
||||||
|
import static org.junit.Assert.assertSame;
|
||||||
|
import static org.junit.Assert.assertTrue;
|
||||||
|
import static org.mockito.Mockito.mock;
|
||||||
|
|
||||||
|
public class PregenInFlightRequestsTest {
|
||||||
|
@Test
|
||||||
|
public void settlingARequestReturnsItsListenerOnlyOnce() {
|
||||||
|
PregenInFlightRequests requests = new PregenInFlightRequests();
|
||||||
|
PregenListener listener = mock(PregenListener.class);
|
||||||
|
long key = PregenInFlightRequests.key(48, -4);
|
||||||
|
|
||||||
|
assertTrue(requests.add(key, listener));
|
||||||
|
assertEquals(1, requests.size());
|
||||||
|
assertSame(listener, requests.settle(key));
|
||||||
|
assertNull(requests.settle(key));
|
||||||
|
assertEquals(0, requests.size());
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void aDuplicateSubmissionKeepsTheOriginalRequest() {
|
||||||
|
PregenInFlightRequests requests = new PregenInFlightRequests();
|
||||||
|
PregenListener first = mock(PregenListener.class);
|
||||||
|
PregenListener second = mock(PregenListener.class);
|
||||||
|
long key = PregenInFlightRequests.key(1, 2);
|
||||||
|
|
||||||
|
assertTrue(requests.add(key, first));
|
||||||
|
assertFalse(requests.add(key, second));
|
||||||
|
assertSame(first, requests.settle(key));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void drainingHandsBackEveryOutstandingRequestExactlyOnce() {
|
||||||
|
PregenInFlightRequests requests = new PregenInFlightRequests();
|
||||||
|
PregenListener listener = mock(PregenListener.class);
|
||||||
|
requests.add(PregenInFlightRequests.key(0, 0), listener);
|
||||||
|
requests.add(PregenInFlightRequests.key(1, 0), listener);
|
||||||
|
requests.add(PregenInFlightRequests.key(-7, 9), listener);
|
||||||
|
|
||||||
|
Map<Long, PregenListener> drained = requests.drain();
|
||||||
|
|
||||||
|
assertEquals(3, drained.size());
|
||||||
|
assertEquals(0, requests.size());
|
||||||
|
assertTrue(requests.drain().isEmpty());
|
||||||
|
assertNull(requests.settle(PregenInFlightRequests.key(1, 0)));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void keysDistinguishNegativeCoordinates() {
|
||||||
|
assertTrue(PregenInFlightRequests.key(1, -1) != PregenInFlightRequests.key(-1, 1));
|
||||||
|
assertTrue(PregenInFlightRequests.key(0, -1) != PregenInFlightRequests.key(-1, 0));
|
||||||
|
assertEquals(PregenInFlightRequests.key(48, -4), PregenInFlightRequests.key(48, -4));
|
||||||
|
}
|
||||||
|
}
|
||||||
Reference in new issue
Block a user