ThreadedAnvilChunkStorage (FabricMC_yarn

java.lang.Object
- net.minecraft.world.storage.VersionedChunkStorage
- - net.minecraft.server.world.ThreadedAnvilChunkStorage

All Implemented Interfaces:: AutoCloseable, ChunkHolder.PlayersWatchingChunkProvider

public class ThreadedAnvilChunkStorage
extends VersionedChunkStorage
implements ChunkHolder.PlayersWatchingChunkProvider

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

(package private) class ThreadedAnvilChunkStorage.EntityTracker

(package private) class ThreadedAnvilChunkStorage.TicketManager

Nested Classes
Modifier and Type	Class and Description
`(package private) class`	`ThreadedAnvilChunkStorage.EntityTracker`
`(package private) class`	`ThreadedAnvilChunkStorage.TicketManager`

Field Summary

Fields
Modifier and Type	Field and Description
`private ChunkGenerator`	`chunkGenerator`
`private boolean`	`chunkHolderListDirty`
`private it.unimi.dsi.fastutil.longs.Long2ObjectLinkedOpenHashMap<ChunkHolder>`	`chunkHolders`
`private it.unimi.dsi.fastutil.longs.Long2ObjectLinkedOpenHashMap<ChunkHolder>`	`chunksToUnload`
`private ChunkTaskPrioritySystem`	`chunkTaskPrioritySystem`
`private it.unimi.dsi.fastutil.longs.Long2ByteMap`	`chunkToType`
`private it.unimi.dsi.fastutil.longs.Long2ObjectLinkedOpenHashMap<ChunkHolder>`	`currentChunkHolders`
`private it.unimi.dsi.fastutil.ints.Int2ObjectMap<ThreadedAnvilChunkStorage.EntityTracker>`	`entityTrackers`
`private it.unimi.dsi.fastutil.longs.LongSet`	`loadedChunks`
`private static Logger`	`LOGGER`
`private MessageListener<ChunkTaskPrioritySystem.Task<Runnable>>`	`mainExecutor`
`private ThreadExecutor<Runnable>`	`mainThreadExecutor`
`static int`	`MAX_LEVEL` Specifies the maximum ticket level a chunk can be before a chunk's `ChunkHolder.LevelType` is `ChunkHolder.LevelType.BORDER`.
`private Supplier<PersistentStateManager>`	`persistentStateManagerFactory`
`private PlayerChunkWatchingManager`	`playerChunkWatchingManager`
`private PointOfInterestStorage`	`pointOfInterestStorage`
`private File`	`saveDir`
`private ServerLightingProvider`	`serverLightingProvider`
`private StructureManager`	`structureManager`
`private ThreadedAnvilChunkStorage.TicketManager`	`ticketManager`
`private AtomicInteger`	`totalChunksLoadedCount`
`private it.unimi.dsi.fastutil.longs.LongSet`	`unloadedChunks`
`private Queue<Runnable>`	`unloadTaskQueue`
`private int`	`watchDistance`
`private ServerWorld`	`world`
`private WorldGenerationProgressListener`	`worldGenerationProgressListener`
`private MessageListener<ChunkTaskPrioritySystem.Task<Runnable>>`	`worldGenExecutor`

Fields inherited from class net.minecraft.world.storage.VersionedChunkStorage
dataFixer

Constructor Summary

Constructors
Constructor and Description
`ThreadedAnvilChunkStorage(ServerWorld serverWorld, LevelStorage.Session session, com.mojang.datafixers.DataFixer dataFixer, StructureManager structureManager, Executor workerExecutor, ThreadExecutor<Runnable> mainThreadExecutor, ChunkProvider chunkProvider, ChunkGenerator chunkGenerator, WorldGenerationProgressListener worldGenerationProgressListener, Supplier<PersistentStateManager> supplier, int int2, boolean bool)`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`close()`
`private CompletableFuture<com.mojang.datafixers.util.Either<Chunk,ChunkHolder.Unloaded>>`	`convertToFullChunk(ChunkHolder chunkHolder)`
`private boolean`	`doesNotGenerateChunks(ServerPlayerEntity player)`
`(package private) void`	`dump(Writer writer)`
`CompletableFuture<Void>`	`enableTickSchedulers(WorldChunk worldChunk)`
`protected Iterable<ChunkHolder>`	`entryIterator()`
`private static int`	`getChebyshevDistance(ChunkPos pos, int x, int z)`
`private static int`	`getChebyshevDistance(ChunkPos pos, ServerPlayerEntity player, boolean useCameraPosition)`
`CompletableFuture<com.mojang.datafixers.util.Either<Chunk,ChunkHolder.Unloaded>>`	`getChunk(ChunkHolder holder, ChunkStatus requiredStatus)`
`protected ChunkHolder`	`getChunkHolder(long pos)`
`String`	`getChunkLoadingDebugInfo(ChunkPos chunkPos)`
`protected IntSupplier`	`getCompletedLevelSupplier(long pos)`
`protected ChunkHolder`	`getCurrentChunkHolder(long pos)`
`private static String`	`getFutureStatus(CompletableFuture<com.mojang.datafixers.util.Either<WorldChunk,ChunkHolder.Unloaded>> completableFuture)`
`protected ServerLightingProvider`	`getLightProvider()`
`int`	`getLoadedChunkCount()`
`Stream<ServerPlayerEntity>`	`getPlayersWatchingChunk(ChunkPos chunkPos, boolean onlyOnWatchDistanceEdge)`
`protected PointOfInterestStorage`	`getPointOfInterestStorage()`
`private CompletableFuture<com.mojang.datafixers.util.Either<List<Chunk>,ChunkHolder.Unloaded>>`	`getRegion(ChunkPos centerChunk, int margin, IntFunction<ChunkStatus> distanceToStatus)`
`private ChunkStatus`	`getRequiredStatusForGeneration(ChunkStatus centerChunkTargetStatus, int distance)`
`private static double`	`getSquaredDistance(ChunkPos pos, Entity entity)`
`protected ThreadedAnvilChunkStorage.TicketManager`	`getTicketManager()`
`int`	`getTotalChunksLoadedCount()`
`private CompoundTag`	`getUpdatedChunkTag(ChunkPos pos)`
`(package private) void`	`handlePlayerAddedOrRemoved(ServerPlayerEntity player, boolean added)`
`(package private) boolean`	`isTooFarFromPlayersToSpawnMobs(ChunkPos chunkPos)`
`private CompletableFuture<com.mojang.datafixers.util.Either<Chunk,ChunkHolder.Unloaded>>`	`loadChunk(ChunkPos pos)`
`protected void`	`loadEntity(Entity entity)`
`CompletableFuture<com.mojang.datafixers.util.Either<WorldChunk,ChunkHolder.Unloaded>>`	`makeChunkAccessible(ChunkHolder holder)`
`CompletableFuture<com.mojang.datafixers.util.Either<WorldChunk,ChunkHolder.Unloaded>>`	`makeChunkEntitiesTickable(ChunkPos pos)`
`CompletableFuture<com.mojang.datafixers.util.Either<WorldChunk,ChunkHolder.Unloaded>>`	`makeChunkTickable(ChunkHolder holder)`
`private ChunkSectionPos`	`method_20726(ServerPlayerEntity serverPlayerEntity)`
`private byte`	`method_27053(ChunkPos chunkPos, ChunkStatus.ChunkType chunkType)`
`private void`	`method_27054(ChunkPos chunkPos)`
`private boolean`	`method_27055(ChunkPos chunkPos)`
`protected void`	`releaseLightTicket(ChunkPos pos)`
`protected void`	`save(boolean flush)`
`private boolean`	`save(Chunk chunk)`
`private void`	`sendChunkDataPackets(ServerPlayerEntity player, Packet<?>[] packets, WorldChunk chunk)`
`protected void`	`sendToNearbyPlayers(Entity entity, Packet<?> packet)`
`protected void`	`sendToOtherNearbyPlayers(Entity entity, Packet<?> packet)`
`protected void`	`sendWatchPackets(ServerPlayerEntity player, ChunkPos pos, Packet<?>[] packets, boolean withinMaxWatchDistance, boolean withinViewDistance)`
`private ChunkHolder`	`setLevel(long pos, int level, ChunkHolder holder, int int2)`
`protected void`	`setViewDistance(int watchDistance)`
`protected void`	`tick(BooleanSupplier shouldKeepTicking)`
`protected void`	`tickPlayerMovement()`
`private void`	`tryUnloadChunk(long pos, ChunkHolder chunkHolder)`
`private void`	`unloadChunks(BooleanSupplier shouldKeepTicking)`
`protected void`	`unloadEntity(Entity entity)`
`void`	`updateCameraPosition(ServerPlayerEntity player)`
`protected boolean`	`updateHolderMap()`
`private CompletableFuture<com.mojang.datafixers.util.Either<Chunk,ChunkHolder.Unloaded>>`	`upgradeChunk(ChunkHolder holder, ChunkStatus requiredStatus)`

Methods inherited from class net.minecraft.world.storage.VersionedChunkStorage
completeAll, getDataVersion, getNbt, setTagAt, updateChunkTag

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOGGER
```
private static final Logger LOGGER
```

MAX_LEVEL
```
public static final int MAX_LEVEL
```
Specifies the maximum ticket level a chunk can be before a chunk's ChunkHolder.LevelType is ChunkHolder.LevelType.BORDER.

currentChunkHolders

private final it.unimi.dsi.fastutil.longs.Long2ObjectLinkedOpenHashMap<ChunkHolder> currentChunkHolders

chunkHolders

private volatile it.unimi.dsi.fastutil.longs.Long2ObjectLinkedOpenHashMap<ChunkHolder> chunkHolders

chunksToUnload

private final it.unimi.dsi.fastutil.longs.Long2ObjectLinkedOpenHashMap<ChunkHolder> chunksToUnload

loadedChunks

private final it.unimi.dsi.fastutil.longs.LongSet loadedChunks

world
```
private final ServerWorld world
```

serverLightingProvider

private final ServerLightingProvider serverLightingProvider

mainThreadExecutor

private final ThreadExecutor<Runnable> mainThreadExecutor

chunkGenerator

private final ChunkGenerator chunkGenerator

persistentStateManagerFactory

private final Supplier<PersistentStateManager> persistentStateManagerFactory

pointOfInterestStorage

private final PointOfInterestStorage pointOfInterestStorage

unloadedChunks

private final it.unimi.dsi.fastutil.longs.LongSet unloadedChunks

chunkHolderListDirty
```
private boolean chunkHolderListDirty
```

chunkTaskPrioritySystem

private final ChunkTaskPrioritySystem chunkTaskPrioritySystem

worldGenExecutor

private final MessageListener<ChunkTaskPrioritySystem.Task<Runnable>> worldGenExecutor

mainExecutor

private final MessageListener<ChunkTaskPrioritySystem.Task<Runnable>> mainExecutor

worldGenerationProgressListener

private final WorldGenerationProgressListener worldGenerationProgressListener

ticketManager

private final ThreadedAnvilChunkStorage.TicketManager ticketManager

totalChunksLoadedCount

private final AtomicInteger totalChunksLoadedCount

structureManager

private final StructureManager structureManager

saveDir
```
private final File saveDir
```

playerChunkWatchingManager

private final PlayerChunkWatchingManager playerChunkWatchingManager

entityTrackers

private final it.unimi.dsi.fastutil.ints.Int2ObjectMap<ThreadedAnvilChunkStorage.EntityTracker> entityTrackers

chunkToType

private final it.unimi.dsi.fastutil.longs.Long2ByteMap chunkToType

unloadTaskQueue

private final Queue<Runnable> unloadTaskQueue

watchDistance
```
private int watchDistance
```

Constructor Detail

ThreadedAnvilChunkStorage

public ThreadedAnvilChunkStorage(ServerWorld serverWorld,
                                 LevelStorage.Session session,
                                 com.mojang.datafixers.DataFixer dataFixer,
                                 StructureManager structureManager,
                                 Executor workerExecutor,
                                 ThreadExecutor<Runnable> mainThreadExecutor,
                                 ChunkProvider chunkProvider,
                                 ChunkGenerator chunkGenerator,
                                 WorldGenerationProgressListener worldGenerationProgressListener,
                                 Supplier<PersistentStateManager> supplier,
                                 int int2,
                                 boolean bool)

Method Detail

getSquaredDistance

private static double getSquaredDistance(ChunkPos pos,
                                         Entity entity)

getChebyshevDistance

private static int getChebyshevDistance(ChunkPos pos,
                                        ServerPlayerEntity player,
                                        boolean useCameraPosition)

getChebyshevDistance

private static int getChebyshevDistance(ChunkPos pos,
                                        int x,
                                        int z)

getLightProvider

protected ServerLightingProvider getLightProvider()

getCurrentChunkHolder

@Nullable
protected ChunkHolder getCurrentChunkHolder(long pos)

getChunkHolder

@Nullable
protected ChunkHolder getChunkHolder(long pos)

getCompletedLevelSupplier

protected IntSupplier getCompletedLevelSupplier(long pos)

getChunkLoadingDebugInfo

@Environment(value=CLIENT)
public String getChunkLoadingDebugInfo(ChunkPos chunkPos)

getRegion

private CompletableFuture<com.mojang.datafixers.util.Either<List<Chunk>,ChunkHolder.Unloaded>> getRegion(ChunkPos centerChunk,
                                                                                                         int margin,
                                                                                                         IntFunction<ChunkStatus> distanceToStatus)

makeChunkEntitiesTickable

public CompletableFuture<com.mojang.datafixers.util.Either<WorldChunk,ChunkHolder.Unloaded>> makeChunkEntitiesTickable(ChunkPos pos)

setLevel

@Nullable
private ChunkHolder setLevel(long pos,
                                       int level,
                                       @Nullable
                                       ChunkHolder holder,
                                       int int2)

close
```
public void close()
           throws IOException
```
Specified by:

close in interface AutoCloseable

Overrides:

close in class VersionedChunkStorage

Throws:

IOException

save
```
protected void save(boolean flush)
```

tick

protected void tick(BooleanSupplier shouldKeepTicking)

unloadChunks

private void unloadChunks(BooleanSupplier shouldKeepTicking)

tryUnloadChunk

private void tryUnloadChunk(long pos,
                            ChunkHolder chunkHolder)

updateHolderMap
```
protected boolean updateHolderMap()
```

getChunk

public CompletableFuture<com.mojang.datafixers.util.Either<Chunk,ChunkHolder.Unloaded>> getChunk(ChunkHolder holder,
                                                                                                 ChunkStatus requiredStatus)

loadChunk

private CompletableFuture<com.mojang.datafixers.util.Either<Chunk,ChunkHolder.Unloaded>> loadChunk(ChunkPos pos)

method_27054

private void method_27054(ChunkPos chunkPos)

method_27053

private byte method_27053(ChunkPos chunkPos,
                          ChunkStatus.ChunkType chunkType)

upgradeChunk

private CompletableFuture<com.mojang.datafixers.util.Either<Chunk,ChunkHolder.Unloaded>> upgradeChunk(ChunkHolder holder,
                                                                                                      ChunkStatus requiredStatus)

releaseLightTicket

protected void releaseLightTicket(ChunkPos pos)

getRequiredStatusForGeneration

private ChunkStatus getRequiredStatusForGeneration(ChunkStatus centerChunkTargetStatus,
                                                   int distance)

convertToFullChunk

private CompletableFuture<com.mojang.datafixers.util.Either<Chunk,ChunkHolder.Unloaded>> convertToFullChunk(ChunkHolder chunkHolder)

makeChunkTickable

public CompletableFuture<com.mojang.datafixers.util.Either<WorldChunk,ChunkHolder.Unloaded>> makeChunkTickable(ChunkHolder holder)

makeChunkAccessible

public CompletableFuture<com.mojang.datafixers.util.Either<WorldChunk,ChunkHolder.Unloaded>> makeChunkAccessible(ChunkHolder holder)

getTotalChunksLoadedCount

public int getTotalChunksLoadedCount()

save
```
private boolean save(Chunk chunk)
```

method_27055

private boolean method_27055(ChunkPos chunkPos)

setViewDistance

protected void setViewDistance(int watchDistance)

sendWatchPackets

protected void sendWatchPackets(ServerPlayerEntity player,
                                ChunkPos pos,
                                Packet<?>[] packets,
                                boolean withinMaxWatchDistance,
                                boolean withinViewDistance)

getLoadedChunkCount
```
public int getLoadedChunkCount()
```

getTicketManager

protected ThreadedAnvilChunkStorage.TicketManager getTicketManager()

entryIterator

protected Iterable<ChunkHolder> entryIterator()

dump

void dump(Writer writer)
   throws IOException

Throws:: IOException

getFutureStatus

private static String getFutureStatus(CompletableFuture<com.mojang.datafixers.util.Either<WorldChunk,ChunkHolder.Unloaded>> completableFuture)

getUpdatedChunkTag

@Nullable
private CompoundTag getUpdatedChunkTag(ChunkPos pos)
                                          throws IOException

Throws:: IOException

isTooFarFromPlayersToSpawnMobs

boolean isTooFarFromPlayersToSpawnMobs(ChunkPos chunkPos)

doesNotGenerateChunks

private boolean doesNotGenerateChunks(ServerPlayerEntity player)

handlePlayerAddedOrRemoved

void handlePlayerAddedOrRemoved(ServerPlayerEntity player,
                                boolean added)

method_20726

private ChunkSectionPos method_20726(ServerPlayerEntity serverPlayerEntity)

updateCameraPosition

public void updateCameraPosition(ServerPlayerEntity player)

getPlayersWatchingChunk

public Stream<ServerPlayerEntity> getPlayersWatchingChunk(ChunkPos chunkPos,
                                                          boolean onlyOnWatchDistanceEdge)

Specified by:: getPlayersWatchingChunk in interface ChunkHolder.PlayersWatchingChunkProvider

loadEntity

protected void loadEntity(Entity entity)

unloadEntity

protected void unloadEntity(Entity entity)

tickPlayerMovement
```
protected void tickPlayerMovement()
```

sendToOtherNearbyPlayers

protected void sendToOtherNearbyPlayers(Entity entity,
                                        Packet<?> packet)

sendToNearbyPlayers

protected void sendToNearbyPlayers(Entity entity,
                                   Packet<?> packet)

sendChunkDataPackets

private void sendChunkDataPackets(ServerPlayerEntity player,
                                  Packet<?>[] packets,
                                  WorldChunk chunk)

getPointOfInterestStorage

protected PointOfInterestStorage getPointOfInterestStorage()

enableTickSchedulers

public CompletableFuture<Void> enableTickSchedulers(WorldChunk worldChunk)

Class ThreadedAnvilChunkStorage

Nested Class Summary

Field Summary

Fields inherited from class net.minecraft.world.storage.VersionedChunkStorage

Constructor Summary

Method Summary

Methods inherited from class net.minecraft.world.storage.VersionedChunkStorage

Methods inherited from class java.lang.Object

Field Detail

LOGGER

MAX_LEVEL

currentChunkHolders

chunkHolders

chunksToUnload

loadedChunks

world

serverLightingProvider

mainThreadExecutor

chunkGenerator

persistentStateManagerFactory

pointOfInterestStorage

unloadedChunks

chunkHolderListDirty

chunkTaskPrioritySystem

worldGenExecutor

mainExecutor

worldGenerationProgressListener

ticketManager

totalChunksLoadedCount

structureManager

saveDir

playerChunkWatchingManager

entityTrackers

chunkToType

unloadTaskQueue

watchDistance

Constructor Detail

ThreadedAnvilChunkStorage

Method Detail

getSquaredDistance

getChebyshevDistance

getChebyshevDistance

getLightProvider

getCurrentChunkHolder

getChunkHolder

getCompletedLevelSupplier

getChunkLoadingDebugInfo

getRegion

makeChunkEntitiesTickable

setLevel

close

save

tick

unloadChunks

tryUnloadChunk

updateHolderMap

getChunk

loadChunk

method_27054

method_27053

upgradeChunk

releaseLightTicket

getRequiredStatusForGeneration

convertToFullChunk

makeChunkTickable

makeChunkAccessible

getTotalChunksLoadedCount

save

method_27055

setViewDistance

sendWatchPackets

getLoadedChunkCount

getTicketManager

entryIterator

dump

getFutureStatus

getUpdatedChunkTag

isTooFarFromPlayersToSpawnMobs

doesNotGenerateChunks

handlePlayerAddedOrRemoved