net.minecraft.world.storage

public class StorageIoWorker

implements AutoCloseable, NbtScannable

net.minecraft.world.level.chunk.storage.IOWorker
net.minecraft.class_4698
net.minecraft.world.storage.StorageIoWorker

Field summary

Modifier and TypeField
public static final Supplier<NbtCompound>
STORE_EMPTY
field_63958
NULL_NBT_SUPPLIER
private static final org.slf4j.Logger
LOGGER
field_21495
LOGGER
private final AtomicBoolean
shutdownRequested
field_21497
closed
private final PrioritizedConsecutiveExecutor
consecutiveExecutor
field_54149
executor
private final RegionBasedStorage
storage
field_21499
storage
private final SequencedMap<ChunkPos, StorageIoWorker$Result>
pendingWrites
field_21500
results
private final it.unimi.dsi.fastutil.longs.Long2ObjectLinkedOpenHashMap<CompletableFuture<BitSet>>
regionCacheForBlender
field_38240
blendingStatusCaches
private static final int
REGION_CACHE_SIZE
field_38241
MAX_CACHE_SIZE

Constructor summary

ModifierConstructor
protected (StorageKey storageKey, Path directory, boolean dsync)

Method summary

Modifier and TypeMethod
public boolean
isOldChunkAround(ChunkPos pos, int range)
method_42330(class_1923 arg0, int arg1)
needsBlending(ChunkPos chunkPos, int checkRadius)
private CompletableFuture<BitSet>
getOrCreateOldDataForRegion(int regionX, int regionZ)
method_42329(int arg0, int arg1)
getOrComputeBlendingStatus(int chunkX, int chunkZ)
private CompletableFuture<BitSet>
createOldDataForRegion(int regionX, int regionZ)
method_42333(int arg0, int arg1)
computeBlendingStatus(int chunkX, int chunkZ)
private boolean
isOldChunk(CompoundTag tag)
method_42332(class_2487 arg0)
needsBlending(NbtCompound nbt)
public CompletableFuture<Void>
store(ChunkPos pos, CompoundTag value)
method_23703(class_1923 arg0, class_2487 arg1)
setResult(ChunkPos pos, NbtCompound nbt)
public CompletableFuture<Void>
store(ChunkPos pos, Supplier<CompoundTag> supplier)
method_61773(class_1923 arg0, Supplier<class_2487> arg1)
setResult(ChunkPos pos, Supplier<NbtCompound> nbtSupplier)
public CompletableFuture<Optional<NbtCompound>>
loadAsync(ChunkPos pos)
method_31738(class_1923 arg0)
readChunkData(ChunkPos pos)
public CompletableFuture<Void>
synchronize(boolean flush)
method_23698(boolean arg0)
completeAll(boolean sync)
public CompletableFuture<Void>
scanChunk(ChunkPos pos, StreamTagVisitor visitor)
method_39795(class_1923 arg0, class_6836 arg1)
scanChunk(ChunkPos arg0, NbtScanner arg1)
private <T> CompletableFuture<T>
submitThrowingTask(IOWorker$ThrowingSupplier<T> task)
method_64026(class_4698$class_10195<T> arg0)
run(StorageIoWorker$Callable<T> task)
private <T> CompletableFuture<T>
submitTask(Supplier<T> task)
method_23709(Supplier<T> arg0)
run(Supplier<T> task)
private void
storePendingChunk()
method_23719()
writeResult()
private void
tellStorePending()
method_27945()
writeRemainingResults()
private void
runStore(ChunkPos pos, IOWorker$PendingStore write)
method_23701(class_1923 arg0, class_4698$class_4699 arg1)
write(ChunkPos pos, StorageIoWorker$Result result)
public void
close()
private void
waitForShutdown()
method_64030()
runRemainingTasks()
public StorageKey
storageInfo()
method_61004()
getStorageKey()
private static void
lambda$waitForShutdown$0(CompletableFuture arg0)
method_64028(CompletableFuture arg0)
method_64028(CompletableFuture future)
private void
lambda$submitTask$0(Supplier arg0, CompletableFuture arg1)
method_64029(Supplier arg0, CompletableFuture arg1)
method_64029(Supplier arg0, CompletableFuture arg1)
private void
lambda$submitThrowingTask$0(IOWorker$ThrowingSupplier arg0, CompletableFuture arg1)
method_64027(class_4698$class_10195 arg0, CompletableFuture arg1)
method_64027(StorageIoWorker$Callable arg0, CompletableFuture future)
private Void
lambda$scanChunk$0(ChunkPos arg0, StreamTagVisitor arg1)
method_39801(class_1923 arg0, class_6836 arg1)
method_39801(ChunkPos arg0, NbtScanner arg1)
private CompletionStage
lambda$synchronize$5(Void arg0)
method_37479(Void arg0)
method_37479(Void void_)
private static Void
lambda$synchronize$6()
method_64031()
method_64031()
private CompletionStage
lambda$synchronize$3(Void arg0)
method_27940(Void arg0)
method_27940(Void void_)
private Void
lambda$synchronize$4()
method_27946()
method_27946()
private CompletableFuture
lambda$synchronize$0()
method_27947()
method_27947()
private static CompletableFuture[]
lambda$synchronize$2(int arg0)
method_23699(int arg0)
method_23699(int arg0)
private static CompletableFuture
lambda$synchronize$1(IOWorker$PendingStore arg0)
method_23705(class_4698$class_4699 arg0)
method_23705(StorageIoWorker$Result result)
private Optional
lambda$loadAsync$0(ChunkPos arg0)
method_27943(class_1923 arg0)
method_27943(ChunkPos arg0)
private CompletableFuture
lambda$store$1(Supplier arg0, ChunkPos arg1)
method_61774(Supplier arg0, class_1923 arg1)
method_61774(Supplier arg0, ChunkPos arg1)
private static StorageIoWorker$Result
lambda$store$2(CompoundTag arg0, ChunkPos arg1)
method_23711(class_2487 arg0, class_1923 arg1)
method_23711(NbtCompound arg0, ChunkPos pos2)
private static NbtCompound
lambda$store$0(CompoundTag arg0)
method_27944(class_2487 arg0)
method_27944(NbtCompound arg0)
private BitSet
lambda$createOldDataForRegion$0(int arg0, int arg1)
method_42334(int arg0, int arg1)
method_42334(int arg0, int arg1)
private void
lambda$createOldDataForRegion$1(BitSet arg0, ChunkPos arg1)
method_42331(BitSet arg0, class_1923 arg1)
method_42331(BitSet arg0, ChunkPos chunkPos)
private static NbtCompound
lambda$static$0()
method_75891()
method_75891()