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

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOGGER
private final ProcessorMailbox<StrictQueue.IntRunnable>	mailbox
private final Map<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, CompoundTag pChunkData)
private void	storePendingChunk()
private <T> CompletableFuture<T>	submitTask(Supplier<com.mojang.datafixers.util.Either<T,Exception>> pTask)
CompletableFuture<Void>	synchronize(boolean pFlushStorage)
private void	tellStorePending()

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

mailbox

private final ProcessorMailbox<StrictQueue.IntRunnable> mailbox

storage

private final RegionFileStorage storage

pendingWrites

private final Map<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)

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

submitTask

private <T> CompletableFuture<T> submitTask(Supplier<com.mojang.datafixers.util.Either<T,Exception>> 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

storageInfo

public RegionStorageInfo storageInfo()