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 info, Path folder, boolean sync)
Method Summary

Modifier and Type

Method

Description

void

close()

private CompletableFuture<BitSet>

createOldDataForRegion(int chunkX, int chunkZ)

private CompletableFuture<BitSet>

getOrCreateOldDataForRegion(int chunkX, int chunkZ)

private boolean

isOldChunk(CompoundTag chunkData)

boolean

isOldChunkAround(ChunkPos chunkPos, int radius)

CompletableFuture<Optional<CompoundTag>>

loadAsync(ChunkPos chunkPos)

private void

runStore(ChunkPos chunkPos, IOWorker.PendingStore pendingStore)

CompletableFuture<Void>

scanChunk(ChunkPos chunkPos, StreamTagVisitor visitor)

RegionStorageInfo

storageInfo()

CompletableFuture<Void>

store(ChunkPos chunkPos, CompoundTag chunkData)

private void

storePendingChunk()

private <T> CompletableFuture<T>

submitTask(Supplier<com.mojang.datafixers.util.Either<T,Exception>> task)

CompletableFuture<Void>

synchronize(boolean flushStorage)

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 info, Path folder, boolean sync)
Method Details
- isOldChunkAround
  
  public boolean isOldChunkAround(ChunkPos chunkPos, int radius)
- getOrCreateOldDataForRegion
  
  private CompletableFuture<BitSet> getOrCreateOldDataForRegion(int chunkX, int chunkZ)
- createOldDataForRegion
  
  private CompletableFuture<BitSet> createOldDataForRegion(int chunkX, int chunkZ)
- isOldChunk
  
  private boolean isOldChunk(CompoundTag chunkData)
- store
  
  public CompletableFuture<Void> store(ChunkPos chunkPos, @Nullable CompoundTag chunkData)
- loadAsync
  
  public CompletableFuture<Optional<CompoundTag>> loadAsync(ChunkPos chunkPos)
- synchronize
  
  public CompletableFuture<Void> synchronize(boolean flushStorage)
- scanChunk
  
  public CompletableFuture<Void> scanChunk(ChunkPos chunkPos, StreamTagVisitor visitor)
  
  Specified by:
  
  scanChunk in interface ChunkScanAccess
- submitTask
  
  private <T> CompletableFuture<T> submitTask(Supplier<com.mojang.datafixers.util.Either<T,Exception>> task)
- storePendingChunk
  
  private void storePendingChunk()
- tellStorePending
  
  private void tellStorePending()
- runStore
  
  private void runStore(ChunkPos chunkPos, IOWorker.PendingStore pendingStore)
- close
  
  public void close() throws IOException
  
  Specified by:
  
  close in interface AutoCloseable
  
  Throws:
  
  IOException
- storageInfo
  
  public RegionStorageInfo storageInfo()

Class IOWorker

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Details

LOGGER

shutdownRequested

mailbox

storage

pendingWrites

regionCacheForBlender

REGION_CACHE_SIZE

Constructor Details

IOWorker

Method Details

isOldChunkAround

getOrCreateOldDataForRegion

createOldDataForRegion

isOldChunk

store

loadAsync

synchronize

scanChunk

submitTask

storePendingChunk

tellStorePending

runStore

close

storageInfo