Package net.minecraft.world.server

Class ChunkManager

java.lang.Object

net.minecraft.world.chunk.storage.ChunkLoader

net.minecraft.world.server.ChunkManager

All Implemented Interfaces:

AutoCloseable, ChunkHolder.IPlayerProvider

public class ChunkManager
extends ChunkLoader
implements ChunkHolder.IPlayerProvider

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	ChunkManager.EntityTracker
(package private) class	ChunkManager.ProxyTicketManager

Field Summary

Fields

Modifier and Type	Field	Description
private final it.unimi.dsi.fastutil.longs.Long2ByteMap	chunkTypeCache
private final ChunkManager.ProxyTicketManager	distanceManager
private final it.unimi.dsi.fastutil.longs.LongSet	entitiesInLevel
private final it.unimi.dsi.fastutil.ints.Int2ObjectMap<ChunkManager.EntityTracker>	entityMap
private final ChunkGenerator	generator
private final ServerWorld	level
private final ServerWorldLightManager	lightEngine
private static final org.apache.logging.log4j.Logger	LOGGER
private final ThreadTaskExecutor<Runnable>	mainThreadExecutor
private final ITaskExecutor<ChunkTaskPriorityQueueSorter.FunctionEntry<Runnable>>	mainThreadMailbox
static final int	MAX_CHUNK_DISTANCE
private boolean	modified
private final Supplier<DimensionSavedDataManager>	overworldDataStorage
private final it.unimi.dsi.fastutil.longs.Long2ObjectLinkedOpenHashMap<ChunkHolder>	pendingUnloads
private final PlayerGenerationTracker	playerMap
private final PointOfInterestManager	poiManager
private final IChunkStatusListener	progressListener
private final ChunkTaskPriorityQueueSorter	queueSorter
private final File	storageFolder
private final TemplateManager	structureManager
private final AtomicInteger	tickingGenerated
private final it.unimi.dsi.fastutil.longs.LongSet	toDrop
private final Queue<Runnable>	unloadQueue
private final it.unimi.dsi.fastutil.longs.Long2ObjectLinkedOpenHashMap<ChunkHolder>	updatingChunkMap
private int	viewDistance
private it.unimi.dsi.fastutil.longs.Long2ObjectLinkedOpenHashMap<ChunkHolder>	visibleChunkMap
private final ITaskExecutor<ChunkTaskPriorityQueueSorter.FunctionEntry<Runnable>>	worldgenMailbox

Fields inherited from class net.minecraft.world.chunk.storage.ChunkLoader

fixerUpper

Constructor Summary

Constructors

Constructor

Description

ChunkManager(ServerWorld p_i232602_1_, SaveFormat.LevelSave p_i232602_2_, com.mojang.datafixers.DataFixer p_i232602_3_, TemplateManager p_i232602_4_, Executor p_i232602_5_, ThreadTaskExecutor<Runnable> p_i232602_6_, IChunkLightProvider p_i232602_7_, ChunkGenerator p_i232602_8_, IChunkStatusListener p_i232602_9_, Supplier<DimensionSavedDataManager> p_i232602_10_, int p_i232602_11_, boolean p_i232602_12_)

Method Summary

Modifier and Type	Method	Description
protected void	addEntity(Entity p_219210_1_)
protected void	broadcast(Entity p_219222_1_, IPacket<?> p_219222_2_)
protected void	broadcastAndSend(Entity p_219225_1_, IPacket<?> p_219225_2_)
private static int	checkerboardDistance(ChunkPos p_219232_0_, int p_219232_1_, int p_219232_2_)
private static int	checkerboardDistance(ChunkPos p_219215_0_, ServerPlayerEntity p_219215_1_, boolean p_219215_2_)
void	close()
(package private) void	dumpChunks(Writer p_225406_1_)
private static double	euclideanDistanceSquared(ChunkPos p_219217_0_, Entity p_219217_1_)
String	getChunkDebugData(ChunkPos p_219170_1_)
protected IntSupplier	getChunkQueueLevel(long p_219191_1_)
private CompletableFuture<com.mojang.datafixers.util.Either<List<IChunk>,ChunkHolder.IChunkLoadingError>>	getChunkRangeFuture(ChunkPos p_219236_1_, int p_219236_2_, IntFunction<ChunkStatus> p_219236_3_)
protected Iterable<ChunkHolder>	getChunks()
private ChunkStatus	getDependencyStatus(ChunkStatus p_219205_1_, int p_219205_2_)
protected ChunkManager.ProxyTicketManager	getDistanceManager()
CompletableFuture<com.mojang.datafixers.util.Either<Chunk,ChunkHolder.IChunkLoadingError>>	getEntityTickingRangeFuture(ChunkPos p_219188_1_)
protected ServerWorldLightManager	getLightEngine()
Stream<ServerPlayerEntity>	getPlayers(ChunkPos p_219097_1_, boolean p_219097_2_)
protected PointOfInterestManager	getPoiManager()
int	getTickingGenerated()
protected ChunkHolder	getUpdatingChunkIfPresent(long p_219220_1_)
protected ChunkHolder	getVisibleChunkIfPresent(long p_219219_1_)
private boolean	isExistingChunkFull(ChunkPos p_241090_1_)
private byte	markPosition(ChunkPos p_241088_1_, ChunkStatus.Type p_241088_2_)
private void	markPositionReplaceable(ChunkPos p_241089_1_)
void	move(ServerPlayerEntity p_219183_1_)
(package private) boolean	noPlayersCloseForSpawning(ChunkPos p_219243_1_)
CompletableFuture<Void>	packTicks(Chunk p_222973_1_)
private void	playerLoadedChunk(ServerPlayerEntity p_219180_1_, IPacket<?>[] p_219180_2_, Chunk p_219180_3_)
CompletableFuture<com.mojang.datafixers.util.Either<Chunk,ChunkHolder.IChunkLoadingError>>	postProcess(ChunkHolder p_219179_1_)
private static String	printFuture(CompletableFuture<com.mojang.datafixers.util.Either<Chunk,ChunkHolder.IChunkLoadingError>> p_225402_0_)
private void	processUnloads(BooleanSupplier p_223155_1_)
protected boolean	promoteChunkMap()
private CompletableFuture<com.mojang.datafixers.util.Either<IChunk,ChunkHolder.IChunkLoadingError>>	protoChunkToFullChunk(ChunkHolder p_219200_1_)
private CompoundNBT	readChunk(ChunkPos p_219178_1_)
protected void	releaseLightTicket(ChunkPos p_219209_1_)
protected void	removeEntity(Entity p_219231_1_)
private boolean	save(IChunk p_219229_1_)
protected void	saveAllChunks(boolean p_219177_1_)
CompletableFuture<com.mojang.datafixers.util.Either<IChunk,ChunkHolder.IChunkLoadingError>>	schedule(ChunkHolder p_219244_1_, ChunkStatus p_219244_2_)
private CompletableFuture<com.mojang.datafixers.util.Either<IChunk,ChunkHolder.IChunkLoadingError>>	scheduleChunkGeneration(ChunkHolder p_223156_1_, ChunkStatus p_223156_2_)
private CompletableFuture<com.mojang.datafixers.util.Either<IChunk,ChunkHolder.IChunkLoadingError>>	scheduleChunkLoad(ChunkPos p_223172_1_)
private void	scheduleUnload(long p_219212_1_, ChunkHolder p_219212_3_)
protected void	setViewDistance(int p_219175_1_)
int	size()
private boolean	skipPlayer(ServerPlayerEntity p_219187_1_)
protected void	tick()
protected void	tick(BooleanSupplier p_219204_1_)
CompletableFuture<com.mojang.datafixers.util.Either<Chunk,ChunkHolder.IChunkLoadingError>>	unpackTicks(ChunkHolder p_222961_1_)
private ChunkHolder	updateChunkScheduling(long p_219213_1_, int p_219213_3_, ChunkHolder p_219213_4_, int p_219213_5_)
protected void	updateChunkTracking(ServerPlayerEntity p_219199_1_, ChunkPos p_219199_2_, IPacket<?>[] p_219199_3_, boolean p_219199_4_, boolean p_219199_5_)
private SectionPos	updatePlayerPos(ServerPlayerEntity p_223489_1_)
(package private) void	updatePlayerStatus(ServerPlayerEntity p_219234_1_, boolean p_219234_2_)

Methods inherited from class net.minecraft.world.chunk.storage.ChunkLoader

flushWorker, getVersion, read, upgradeChunkTag, write

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.apache.logging.log4j.Logger LOGGER

MAX_CHUNK_DISTANCE

public static final int MAX_CHUNK_DISTANCE

updatingChunkMap

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

visibleChunkMap

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

pendingUnloads

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

entitiesInLevel

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

level

private final ServerWorld level

lightEngine

private final ServerWorldLightManager lightEngine

mainThreadExecutor

private final ThreadTaskExecutor<Runnable> mainThreadExecutor

generator

private final ChunkGenerator generator

overworldDataStorage

private final Supplier<DimensionSavedDataManager> overworldDataStorage

poiManager

private final PointOfInterestManager poiManager

toDrop

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

modified

private boolean modified

queueSorter

private final ChunkTaskPriorityQueueSorter queueSorter

worldgenMailbox

private final ITaskExecutor<ChunkTaskPriorityQueueSorter.FunctionEntry<Runnable>> worldgenMailbox

mainThreadMailbox

private final ITaskExecutor<ChunkTaskPriorityQueueSorter.FunctionEntry<Runnable>> mainThreadMailbox

progressListener

private final IChunkStatusListener progressListener

distanceManager

private final ChunkManager.ProxyTicketManager distanceManager

tickingGenerated

private final AtomicInteger tickingGenerated

structureManager

private final TemplateManager structureManager

storageFolder

private final File storageFolder

playerMap

private final PlayerGenerationTracker playerMap

entityMap

private final it.unimi.dsi.fastutil.ints.Int2ObjectMap<ChunkManager.EntityTracker> entityMap

chunkTypeCache

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

unloadQueue

private final Queue<Runnable> unloadQueue

viewDistance

private int viewDistance

Constructor Details

ChunkManager

public ChunkManager(ServerWorld p_i232602_1_,
 SaveFormat.LevelSave p_i232602_2_,
 com.mojang.datafixers.DataFixer p_i232602_3_,
 TemplateManager p_i232602_4_,
 Executor p_i232602_5_,
 ThreadTaskExecutor<Runnable> p_i232602_6_,
 IChunkLightProvider p_i232602_7_,
 ChunkGenerator p_i232602_8_,
 IChunkStatusListener p_i232602_9_,
 Supplier<DimensionSavedDataManager> p_i232602_10_,
 int p_i232602_11_,
 boolean p_i232602_12_)

Method Details

euclideanDistanceSquared

private static double euclideanDistanceSquared(ChunkPos p_219217_0_,
 Entity p_219217_1_)

checkerboardDistance

private static int checkerboardDistance(ChunkPos p_219215_0_,
 ServerPlayerEntity p_219215_1_,
 boolean p_219215_2_)

checkerboardDistance

private static int checkerboardDistance(ChunkPos p_219232_0_,
 int p_219232_1_,
 int p_219232_2_)

getLightEngine

protected ServerWorldLightManager getLightEngine()

getUpdatingChunkIfPresent

@Nullable
protected ChunkHolder getUpdatingChunkIfPresent(long p_219220_1_)

getVisibleChunkIfPresent

@Nullable
protected ChunkHolder getVisibleChunkIfPresent(long p_219219_1_)

getChunkQueueLevel

protected IntSupplier getChunkQueueLevel(long p_219191_1_)

getChunkDebugData

public String getChunkDebugData(ChunkPos p_219170_1_)

getChunkRangeFuture

private CompletableFuture<com.mojang.datafixers.util.Either<List<IChunk>,ChunkHolder.IChunkLoadingError>> getChunkRangeFuture(ChunkPos p_219236_1_,
 int p_219236_2_,
 IntFunction<ChunkStatus> p_219236_3_)

getEntityTickingRangeFuture

public CompletableFuture<com.mojang.datafixers.util.Either<Chunk,ChunkHolder.IChunkLoadingError>> getEntityTickingRangeFuture(ChunkPos p_219188_1_)

updateChunkScheduling

@Nullable
private ChunkHolder updateChunkScheduling(long p_219213_1_,
 int p_219213_3_,
 @Nullable
 ChunkHolder p_219213_4_,
 int p_219213_5_)

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Overrides:

close in class ChunkLoader

Throws:

IOException

saveAllChunks

protected void saveAllChunks(boolean p_219177_1_)

tick

protected void tick(BooleanSupplier p_219204_1_)

processUnloads

private void processUnloads(BooleanSupplier p_223155_1_)

scheduleUnload

private void scheduleUnload(long p_219212_1_,
 ChunkHolder p_219212_3_)

promoteChunkMap

protected boolean promoteChunkMap()

schedule

public CompletableFuture<com.mojang.datafixers.util.Either<IChunk,ChunkHolder.IChunkLoadingError>> schedule(ChunkHolder p_219244_1_,
 ChunkStatus p_219244_2_)

scheduleChunkLoad

private CompletableFuture<com.mojang.datafixers.util.Either<IChunk,ChunkHolder.IChunkLoadingError>> scheduleChunkLoad(ChunkPos p_223172_1_)

markPositionReplaceable

private void markPositionReplaceable(ChunkPos p_241089_1_)

markPosition

private byte markPosition(ChunkPos p_241088_1_,
 ChunkStatus.Type p_241088_2_)

scheduleChunkGeneration

private CompletableFuture<com.mojang.datafixers.util.Either<IChunk,ChunkHolder.IChunkLoadingError>> scheduleChunkGeneration(ChunkHolder p_223156_1_,
 ChunkStatus p_223156_2_)

releaseLightTicket

protected void releaseLightTicket(ChunkPos p_219209_1_)

getDependencyStatus

private ChunkStatus getDependencyStatus(ChunkStatus p_219205_1_,
 int p_219205_2_)

protoChunkToFullChunk

private CompletableFuture<com.mojang.datafixers.util.Either<IChunk,ChunkHolder.IChunkLoadingError>> protoChunkToFullChunk(ChunkHolder p_219200_1_)

postProcess

public CompletableFuture<com.mojang.datafixers.util.Either<Chunk,ChunkHolder.IChunkLoadingError>> postProcess(ChunkHolder p_219179_1_)

unpackTicks

public CompletableFuture<com.mojang.datafixers.util.Either<Chunk,ChunkHolder.IChunkLoadingError>> unpackTicks(ChunkHolder p_222961_1_)

getTickingGenerated

public int getTickingGenerated()

save

private boolean save(IChunk p_219229_1_)

isExistingChunkFull

private boolean isExistingChunkFull(ChunkPos p_241090_1_)

setViewDistance

protected void setViewDistance(int p_219175_1_)

updateChunkTracking

protected void updateChunkTracking(ServerPlayerEntity p_219199_1_,
 ChunkPos p_219199_2_,
 IPacket<?>[] p_219199_3_,
 boolean p_219199_4_,
 boolean p_219199_5_)

size

public int size()

getDistanceManager

protected ChunkManager.ProxyTicketManager getDistanceManager()

getChunks

protected Iterable<ChunkHolder> getChunks()

dumpChunks

void dumpChunks(Writer p_225406_1_)
         throws IOException

Throws:

IOException

printFuture

private static String printFuture(CompletableFuture<com.mojang.datafixers.util.Either<Chunk,ChunkHolder.IChunkLoadingError>> p_225402_0_)

readChunk

@Nullable
private CompoundNBT readChunk(ChunkPos p_219178_1_)
                       throws IOException

Throws:

IOException

noPlayersCloseForSpawning

boolean noPlayersCloseForSpawning(ChunkPos p_219243_1_)

skipPlayer

private boolean skipPlayer(ServerPlayerEntity p_219187_1_)

updatePlayerStatus

void updatePlayerStatus(ServerPlayerEntity p_219234_1_,
 boolean p_219234_2_)

updatePlayerPos

private SectionPos updatePlayerPos(ServerPlayerEntity p_223489_1_)

move

public void move(ServerPlayerEntity p_219183_1_)

getPlayers

public Stream<ServerPlayerEntity> getPlayers(ChunkPos p_219097_1_,
 boolean p_219097_2_)

Specified by:

getPlayers in interface ChunkHolder.IPlayerProvider

addEntity

protected void addEntity(Entity p_219210_1_)

removeEntity

protected void removeEntity(Entity p_219231_1_)

tick

protected void tick()

broadcast

protected void broadcast(Entity p_219222_1_,
 IPacket<?> p_219222_2_)

broadcastAndSend

protected void broadcastAndSend(Entity p_219225_1_,
 IPacket<?> p_219225_2_)

playerLoadedChunk

private void playerLoadedChunk(ServerPlayerEntity p_219180_1_,
 IPacket<?>[] p_219180_2_,
 Chunk p_219180_3_)

getPoiManager

protected PointOfInterestManager getPoiManager()

packTicks

public CompletableFuture<Void> packTicks(Chunk p_222973_1_)