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(Path p_196930_, boolean p_196931_, String p_196932_)

Method Summary

Modifier and Type	Method	Description
void	close()
private CompletableFuture<BitSet>	createOldDataForRegion(int p_223490_, int p_223491_)
private CompletableFuture<BitSet>	getOrCreateOldDataForRegion(int p_223464_, int p_223465_)
private boolean	isOldChunk(CompoundTag p_223485_)
boolean	isOldChunkAround(ChunkPos p_223472_, int p_223473_)
CompletableFuture<Optional<CompoundTag>>	loadAsync(ChunkPos p_156588_)
private void	runStore(ChunkPos p_63536_, IOWorker.PendingStore p_63537_)
CompletableFuture<Void>	scanChunk(ChunkPos p_196939_, StreamTagVisitor p_196940_)
CompletableFuture<Void>	store(ChunkPos p_63539_, CompoundTag p_63540_)
private void	storePendingChunk()
private <T> CompletableFuture<T>	submitTask(Supplier<com.mojang.datafixers.util.Either<T,Exception>> p_63546_)
CompletableFuture<Void>	synchronize(boolean p_182499_)
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(Path p_196930_,
 boolean p_196931_,
 String p_196932_)

Method Details

isOldChunkAround

public boolean isOldChunkAround(ChunkPos p_223472_,
 int p_223473_)

getOrCreateOldDataForRegion

private CompletableFuture<BitSet> getOrCreateOldDataForRegion(int p_223464_,
 int p_223465_)

createOldDataForRegion

private CompletableFuture<BitSet> createOldDataForRegion(int p_223490_,
 int p_223491_)

isOldChunk

private boolean isOldChunk(CompoundTag p_223485_)

store

public CompletableFuture<Void> store(ChunkPos p_63539_,
 @Nullable
 CompoundTag p_63540_)

loadAsync

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

synchronize

public CompletableFuture<Void> synchronize(boolean p_182499_)

scanChunk

public CompletableFuture<Void> scanChunk(ChunkPos p_196939_,
 StreamTagVisitor p_196940_)

Specified by:

scanChunk in interface ChunkScanAccess

submitTask

private <T> CompletableFuture<T> submitTask(Supplier<com.mojang.datafixers.util.Either<T,Exception>> p_63546_)

storePendingChunk

private void storePendingChunk()

tellStorePending

private void tellStorePending()

runStore

private void runStore(ChunkPos p_63536_,
 IOWorker.PendingStore p_63537_)

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException