Package net.minecraft.world.level.chunk.storage

Class IOWorker

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, ChunkScanAccess

public class IOWorker
extends Object
implements ChunkScanAccess, AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	IOWorker.PendingStore
(package private) static enum	IOWorker.Priority
(package private) static interface	IOWorker.ThrowingSupplier<T>

Field Summary

Fields

Modifier and Type	Field	Description
private final PriorityConsecutiveExecutor	consecutiveExecutor
private static final org.slf4j.Logger	LOGGER
private final SequencedMap<ChunkPos,IOWorker.PendingStore>	pendingWrites
private static final int	REGION_CACHE_SIZE
private final it.unimi.dsi.fastutil.longs.Long2ObjectLinkedOpenHashMap<CompletableFuture<BitSet>>	regionCacheForBlender
private final AtomicBoolean	shutdownRequested
private final RegionFileStorage	storage

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	IOWorker(RegionStorageInfo pInfo, Path pFolder, boolean pSync)

Method Summary

Modifier and Type	Method	Description
void	close()
private CompletableFuture<BitSet>	createOldDataForRegion(int pChunkX, int pChunkZ)
private CompletableFuture<BitSet>	getOrCreateOldDataForRegion(int pChunkX, int pChunkZ)
private boolean	isOldChunk(CompoundTag pChunkData)
boolean	isOldChunkAround(ChunkPos pChunkPos, int pRadius)
CompletableFuture<Optional<CompoundTag>>	loadAsync(ChunkPos pChunkPos)
private void	runStore(ChunkPos pChunkPos, IOWorker.PendingStore pPendingStore)
CompletableFuture<Void>	scanChunk(ChunkPos pChunkPos, StreamTagVisitor pVisitor)
RegionStorageInfo	storageInfo()
CompletableFuture<Void>	store(ChunkPos pChunkPos, Supplier<CompoundTag> pDataSupplier)
CompletableFuture<Void>	store(ChunkPos pChunkPos, CompoundTag pChunkData)
private void	storePendingChunk()
private <T> CompletableFuture<T>	submitTask(Supplier<T> pTask)
private <T> CompletableFuture<T>	submitThrowingTask(IOWorker.ThrowingSupplier<T> pTask)
CompletableFuture<Void>	synchronize(boolean pFlushStorage)
private void	tellStorePending()
private void	waitForShutdown()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

shutdownRequested

private final AtomicBoolean shutdownRequested

consecutiveExecutor

private final PriorityConsecutiveExecutor consecutiveExecutor

storage

private final RegionFileStorage storage

pendingWrites

private final SequencedMap<ChunkPos,IOWorker.PendingStore> pendingWrites

regionCacheForBlender

private final it.unimi.dsi.fastutil.longs.Long2ObjectLinkedOpenHashMap<CompletableFuture<BitSet>> regionCacheForBlender

REGION_CACHE_SIZE

private static final int REGION_CACHE_SIZE

See Also:

• Constant Field Values

Constructor Details

IOWorker

protected IOWorker(RegionStorageInfo pInfo,
 Path pFolder,
 boolean pSync)

Method Details

isOldChunkAround

public boolean isOldChunkAround(ChunkPos pChunkPos,
 int pRadius)

getOrCreateOldDataForRegion

private CompletableFuture<BitSet> getOrCreateOldDataForRegion(int pChunkX,
 int pChunkZ)

createOldDataForRegion

private CompletableFuture<BitSet> createOldDataForRegion(int pChunkX,
 int pChunkZ)

isOldChunk

private boolean isOldChunk(CompoundTag pChunkData)

store

public CompletableFuture<Void> store(ChunkPos pChunkPos,
 @Nullable
 CompoundTag pChunkData)

store

public CompletableFuture<Void> store(ChunkPos pChunkPos,
 Supplier<CompoundTag> pDataSupplier)

loadAsync

public CompletableFuture<Optional<CompoundTag>> loadAsync(ChunkPos pChunkPos)

synchronize

public CompletableFuture<Void> synchronize(boolean pFlushStorage)

scanChunk

public CompletableFuture<Void> scanChunk(ChunkPos pChunkPos,
 StreamTagVisitor pVisitor)

Specified by:

scanChunk in interface ChunkScanAccess

submitThrowingTask

private <T> CompletableFuture<T> submitThrowingTask(IOWorker.ThrowingSupplier<T> pTask)

submitTask

private <T> CompletableFuture<T> submitTask(Supplier<T> pTask)

storePendingChunk

private void storePendingChunk()

tellStorePending

private void tellStorePending()

runStore

private void runStore(ChunkPos pChunkPos,
 IOWorker.PendingStore pPendingStore)

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException

waitForShutdown

private void waitForShutdown()

storageInfo

public RegionStorageInfo storageInfo()