net.minecraft.world.server

Class ChunkManager

java.lang.Object

net.minecraft.world.chunk.storage.ChunkLoader

net.minecraft.world.server.ChunkManager

All Implemented Interfaces:

java.lang.AutoCloseable, ChunkHolder.IPlayerProvider

public class ChunkManager
extends ChunkLoader
implements ChunkHolder.IPlayerProvider

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field and Description
private it.unimi.dsi.fastutil.longs.Long2ObjectLinkedOpenHashMap<ChunkHolder>	chunksToUnload
private java.io.File	dimensionDirectory
private it.unimi.dsi.fastutil.ints.Int2ObjectMap<ChunkManager.EntityTracker>	entities
private java.util.function.Supplier<DimensionSavedDataManager>	field_219259_m
private ChunkTaskPriorityQueueSorter	field_219263_q
private ITaskExecutor<ChunkTaskPriorityQueueSorter.FunctionEntry<java.lang.Runnable>>	field_219264_r
private ITaskExecutor<ChunkTaskPriorityQueueSorter.FunctionEntry<java.lang.Runnable>>	field_219265_s
private IChunkStatusListener	field_219266_t
private java.util.concurrent.atomic.AtomicInteger	field_219268_v
private ChunkGenerator<?>	generator
private it.unimi.dsi.fastutil.longs.Long2ObjectLinkedOpenHashMap<ChunkHolder>	immutableLoadedChunks
private boolean	immutableLoadedChunksDirty
private ServerWorldLightManager	lightManager
private it.unimi.dsi.fastutil.longs.Long2ObjectLinkedOpenHashMap<ChunkHolder>	loadedChunks
private it.unimi.dsi.fastutil.longs.LongSet	loadedPositions
private static org.apache.logging.log4j.Logger	LOGGER
private ThreadTaskExecutor<java.lang.Runnable>	mainThread
static int	MAX_LOADED_LEVEL
private PlayerGenerationTracker	playerGenerationTracker
private PointOfInterestManager	pointOfInterestManager
private java.util.Queue<java.lang.Runnable>	saveTasks
private TemplateManager	templateManager
private ChunkManager.ProxyTicketManager	ticketManager
private it.unimi.dsi.fastutil.longs.LongSet	unloadableChunks
private int	viewDistance
private ServerWorld	world

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

dataFixer

Constructor Summary

Constructors

Constructor and Description

ChunkManager(ServerWorld worldIn, java.io.File worldDirectory, com.mojang.datafixers.DataFixer p_i51538_3_, TemplateManager templateManagerIn, java.util.concurrent.Executor p_i51538_5_, ThreadTaskExecutor<java.lang.Runnable> mainThreadIn, IChunkLightProvider p_i51538_7_, ChunkGenerator<?> generatorIn, IChunkStatusListener p_i51538_9_, java.util.function.Supplier<DimensionSavedDataManager> p_i51538_10_, int p_i51538_11_)

Method Summary

Modifier and Type	Method and Description
private boolean	cannotGenerateChunks(ServerPlayerEntity player)
void	close()
java.lang.String	func_219170_a(ChunkPos pos)
int	func_219174_c()
java.util.concurrent.CompletableFuture<com.mojang.datafixers.util.Either<Chunk,ChunkHolder.IChunkLoadingError>>	func_219179_a(ChunkHolder p_219179_1_)
java.util.concurrent.CompletableFuture<com.mojang.datafixers.util.Either<Chunk,ChunkHolder.IChunkLoadingError>>	func_219188_b(ChunkPos p_219188_1_)
protected java.util.function.IntSupplier	func_219191_c(long chunkPosIn)
private java.util.concurrent.CompletableFuture<com.mojang.datafixers.util.Either<IChunk,ChunkHolder.IChunkLoadingError>>	func_219200_b(ChunkHolder p_219200_1_)
private ChunkStatus	func_219205_a(ChunkStatus p_219205_1_, int p_219205_2_)
protected void	func_219209_c(ChunkPos p_219209_1_)
private static int	func_219215_b(ChunkPos pos, ServerPlayerEntity player, boolean p_219215_2_)
protected ChunkHolder	func_219219_b(long chunkPosIn)
protected ChunkHolder	func_219220_a(long chunkPosIn)
private boolean	func_219229_a(IChunk chunkIn)
private java.util.concurrent.CompletableFuture<com.mojang.datafixers.util.Either<java.util.List<IChunk>,ChunkHolder.IChunkLoadingError>>	func_219236_a(ChunkPos pos, int p_219236_2_, java.util.function.IntFunction<ChunkStatus> p_219236_3_)
java.util.concurrent.CompletableFuture<com.mojang.datafixers.util.Either<IChunk,ChunkHolder.IChunkLoadingError>>	func_219244_a(ChunkHolder p_219244_1_, ChunkStatus p_219244_2_)
java.util.concurrent.CompletableFuture<com.mojang.datafixers.util.Either<Chunk,ChunkHolder.IChunkLoadingError>>	func_222961_b(ChunkHolder p_222961_1_)
java.util.concurrent.CompletableFuture<java.lang.Void>	func_222973_a(Chunk p_222973_1_)
private java.util.concurrent.CompletableFuture<com.mojang.datafixers.util.Either<IChunk,ChunkHolder.IChunkLoadingError>>	func_223156_b(ChunkHolder p_223156_1_, ChunkStatus p_223156_2_)
private java.util.concurrent.CompletableFuture<com.mojang.datafixers.util.Either<IChunk,ChunkHolder.IChunkLoadingError>>	func_223172_f(ChunkPos p_223172_1_)
private SectionPos	func_223489_c(ServerPlayerEntity p_223489_1_)
private static java.lang.String	func_225402_a(java.util.concurrent.CompletableFuture<com.mojang.datafixers.util.Either<Chunk,ChunkHolder.IChunkLoadingError>> p_225402_0_)
(package private) void	func_225406_a(java.io.Writer p_225406_1_)
private static int	getChunkDistance(ChunkPos chunkPosIn, int x, int y)
private static double	getDistanceSquaredToChunk(ChunkPos chunkPosIn, Entity entityIn)
protected ServerWorldLightManager	getLightManager()
int	getLoadedChunkCount()
protected java.lang.Iterable<ChunkHolder>	getLoadedChunksIterable()
protected PointOfInterestManager	getPointOfInterestManager()
protected ChunkManager.ProxyTicketManager	getTicketManager()
java.util.stream.Stream<ServerPlayerEntity>	getTrackingPlayers(ChunkPos pos, boolean boundaryOnly)
(package private) boolean	isOutsideSpawningRadius(ChunkPos chunkPosIn)
private CompoundNBT	loadChunkData(ChunkPos pos)
protected boolean	refreshOffThreadCache()
protected void	save(boolean flush)
private void	scheduleSave(long chunkPosIn, ChunkHolder chunkHolderIn)
private void	scheduleUnloads(java.util.function.BooleanSupplier hasMoreTime)
private void	sendChunkData(ServerPlayerEntity player, IPacket<?>[] packetCache, Chunk chunkIn)
protected void	sendToAllTracking(Entity p_219222_1_, IPacket<?> p_219222_2_)
protected void	sendToTrackingAndSelf(Entity p_219225_1_, IPacket<?> p_219225_2_)
private ChunkHolder	setChunkLevel(long chunkPosIn, int newLevel, ChunkHolder holder, int oldLevel)
protected void	setChunkLoadedAtClient(ServerPlayerEntity player, ChunkPos chunkPosIn, IPacket<?>[] packetCache, boolean wasLoaded, boolean load)
(package private) void	setPlayerTracking(ServerPlayerEntity player, boolean track)
protected void	setViewDistance(int viewDistance)
protected void	tick(java.util.function.BooleanSupplier hasMoreTime)
protected void	tickEntityTracker()
protected void	track(Entity entityIn)
protected void	untrack(Entity p_219231_1_)
void	updatePlayerPosition(ServerPlayerEntity player)

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

func_227079_i_, getDataVersion, readChunk, updateChunkData, writeChunk

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOGGER

private static final org.apache.logging.log4j.Logger LOGGER

MAX_LOADED_LEVEL

public static final int MAX_LOADED_LEVEL

loadedChunks

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

immutableLoadedChunks

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

chunksToUnload

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

loadedPositions

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

world

private final ServerWorld world

lightManager

private final ServerWorldLightManager lightManager

mainThread

private final ThreadTaskExecutor<java.lang.Runnable> mainThread

generator

private final ChunkGenerator<?> generator

field_219259_m

private final java.util.function.Supplier<DimensionSavedDataManager> field_219259_m

pointOfInterestManager

private final PointOfInterestManager pointOfInterestManager

unloadableChunks

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

immutableLoadedChunksDirty

private boolean immutableLoadedChunksDirty

field_219263_q

private final ChunkTaskPriorityQueueSorter field_219263_q

field_219264_r

private final ITaskExecutor<ChunkTaskPriorityQueueSorter.FunctionEntry<java.lang.Runnable>> field_219264_r

field_219265_s

private final ITaskExecutor<ChunkTaskPriorityQueueSorter.FunctionEntry<java.lang.Runnable>> field_219265_s

field_219266_t

private final IChunkStatusListener field_219266_t

ticketManager

private final ChunkManager.ProxyTicketManager ticketManager

field_219268_v

private final java.util.concurrent.atomic.AtomicInteger field_219268_v

templateManager

private final TemplateManager templateManager

dimensionDirectory

private final java.io.File dimensionDirectory

playerGenerationTracker

private final PlayerGenerationTracker playerGenerationTracker

entities

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

saveTasks

private final java.util.Queue<java.lang.Runnable> saveTasks

viewDistance

private int viewDistance

Constructor Detail

ChunkManager

public ChunkManager(ServerWorld worldIn,
                    java.io.File worldDirectory,
                    com.mojang.datafixers.DataFixer p_i51538_3_,
                    TemplateManager templateManagerIn,
                    java.util.concurrent.Executor p_i51538_5_,
                    ThreadTaskExecutor<java.lang.Runnable> mainThreadIn,
                    IChunkLightProvider p_i51538_7_,
                    ChunkGenerator<?> generatorIn,
                    IChunkStatusListener p_i51538_9_,
                    java.util.function.Supplier<DimensionSavedDataManager> p_i51538_10_,
                    int p_i51538_11_)

Method Detail

getDistanceSquaredToChunk

private static double getDistanceSquaredToChunk(ChunkPos chunkPosIn,
                                                Entity entityIn)

func_219215_b

private static int func_219215_b(ChunkPos pos,
                                 ServerPlayerEntity player,
                                 boolean p_219215_2_)

getChunkDistance

private static int getChunkDistance(ChunkPos chunkPosIn,
                                    int x,
                                    int y)

getLightManager

protected ServerWorldLightManager getLightManager()

func_219220_a

@Nullable
protected ChunkHolder func_219220_a(long chunkPosIn)

func_219219_b

@Nullable
protected ChunkHolder func_219219_b(long chunkPosIn)

func_219191_c

protected java.util.function.IntSupplier func_219191_c(long chunkPosIn)

func_219170_a

public java.lang.String func_219170_a(ChunkPos pos)

func_219236_a

private java.util.concurrent.CompletableFuture<com.mojang.datafixers.util.Either<java.util.List<IChunk>,ChunkHolder.IChunkLoadingError>> func_219236_a(ChunkPos pos,
                                                                                                                                                       int p_219236_2_,
                                                                                                                                                       java.util.function.IntFunction<ChunkStatus> p_219236_3_)

func_219188_b

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

setChunkLevel

@Nullable
private ChunkHolder setChunkLevel(long chunkPosIn,
                                            int newLevel,
                                            @Nullable
                                            ChunkHolder holder,
                                            int oldLevel)

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class ChunkLoader

Throws:

java.io.IOException

save

protected void save(boolean flush)

tick

protected void tick(java.util.function.BooleanSupplier hasMoreTime)

scheduleUnloads

private void scheduleUnloads(java.util.function.BooleanSupplier hasMoreTime)

scheduleSave

private void scheduleSave(long chunkPosIn,
                          ChunkHolder chunkHolderIn)

refreshOffThreadCache

protected boolean refreshOffThreadCache()

func_219244_a

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

func_223172_f

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

func_223156_b

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

func_219209_c

protected void func_219209_c(ChunkPos p_219209_1_)

func_219205_a

private ChunkStatus func_219205_a(ChunkStatus p_219205_1_,
                                  int p_219205_2_)

func_219200_b

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

func_219179_a

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

func_222961_b

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

func_219174_c

public int func_219174_c()

func_219229_a

private boolean func_219229_a(IChunk chunkIn)

setViewDistance

protected void setViewDistance(int viewDistance)

setChunkLoadedAtClient

protected void setChunkLoadedAtClient(ServerPlayerEntity player,
                                      ChunkPos chunkPosIn,
                                      IPacket<?>[] packetCache,
                                      boolean wasLoaded,
                                      boolean load)

getLoadedChunkCount

public int getLoadedChunkCount()

getTicketManager

protected ChunkManager.ProxyTicketManager getTicketManager()

getLoadedChunksIterable

protected java.lang.Iterable<ChunkHolder> getLoadedChunksIterable()

func_225406_a

void func_225406_a(java.io.Writer p_225406_1_)
            throws java.io.IOException

Throws:

java.io.IOException

func_225402_a

private static java.lang.String func_225402_a(java.util.concurrent.CompletableFuture<com.mojang.datafixers.util.Either<Chunk,ChunkHolder.IChunkLoadingError>> p_225402_0_)

loadChunkData

@Nullable
private CompoundNBT loadChunkData(ChunkPos pos)
                                     throws java.io.IOException

Throws:

java.io.IOException

isOutsideSpawningRadius

boolean isOutsideSpawningRadius(ChunkPos chunkPosIn)

cannotGenerateChunks

private boolean cannotGenerateChunks(ServerPlayerEntity player)

setPlayerTracking

void setPlayerTracking(ServerPlayerEntity player,
                       boolean track)

func_223489_c

private SectionPos func_223489_c(ServerPlayerEntity p_223489_1_)

updatePlayerPosition

public void updatePlayerPosition(ServerPlayerEntity player)

getTrackingPlayers

public java.util.stream.Stream<ServerPlayerEntity> getTrackingPlayers(ChunkPos pos,
                                                                      boolean boundaryOnly)

Specified by:

getTrackingPlayers in interface ChunkHolder.IPlayerProvider

track

protected void track(Entity entityIn)

untrack

protected void untrack(Entity p_219231_1_)

tickEntityTracker

protected void tickEntityTracker()

sendToAllTracking

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

sendToTrackingAndSelf

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

sendChunkData

private void sendChunkData(ServerPlayerEntity player,
                           IPacket<?>[] packetCache,
                           Chunk chunkIn)

getPointOfInterestManager

protected PointOfInterestManager getPointOfInterestManager()

func_222973_a

public java.util.concurrent.CompletableFuture<java.lang.Void> func_222973_a(Chunk p_222973_1_)