net.minecraft.server.world

Class ChunkTicketManager

java.lang.Object

net.minecraft.server.world.ChunkTicketManager

Direct Known Subclasses:

ThreadedAnvilChunkStorage.TicketManager

public abstract class ChunkTicketManager
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	ChunkTicketManager.DistanceFromNearestPlayerTracker
(package private) class	ChunkTicketManager.NearbyChunkTicketUpdater
(package private) class	ChunkTicketManager.TicketDistanceLevelPropagator

Field Summary

Fields

Modifier and Type	Field and Description
private long	age
private Set<ChunkHolder>	chunkHolders
private it.unimi.dsi.fastutil.longs.LongSet	chunkPositions
private ChunkTicketManager.DistanceFromNearestPlayerTracker	distanceFromNearestPlayerTracker
private ChunkTicketManager.TicketDistanceLevelPropagator	distanceFromTicketTracker
private ChunkTaskPrioritySystem	levelUpdateListener
private static Logger	LOGGER
private Executor	mainThreadExecutor
private static int	NEARBY_PLAYER_TICKET_LEVEL
private ChunkTicketManager.NearbyChunkTicketUpdater	nearbyChunkTicketUpdater
private it.unimi.dsi.fastutil.longs.Long2ObjectMap<it.unimi.dsi.fastutil.objects.ObjectSet<ServerPlayerEntity>>	playersByChunkPos
private MessageListener<ChunkTaskPrioritySystem.Task<Runnable>>	playerTicketThrottler
private MessageListener<ChunkTaskPrioritySystem.UnblockingMessage>	playerTicketThrottlerUnblocker
private it.unimi.dsi.fastutil.longs.Long2ObjectOpenHashMap<SortedArraySet<ChunkTicket<?>>>	ticketsByPosition

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ChunkTicketManager(Executor workerExecutor, Executor mainThreadExecutor)

Method Summary

Modifier and Type	Method and Description
<T> void	addTicket(ChunkTicketType<T> type, ChunkPos pos, int radius, T argument)
private void	addTicket(long position, ChunkTicket<?> ticket)
<T> void	addTicketWithLevel(ChunkTicketType<T> type, ChunkPos pos, int level, T argument)
protected abstract ChunkHolder	getChunkHolder(long pos)
private static int	getLevel(SortedArraySet<ChunkTicket<?>> sortedArraySet)
int	getSpawningChunkCount()
protected String	getTicket(long pos)
private SortedArraySet<ChunkTicket<?>>	getTicketSet(long position)
void	handleChunkEnter(ChunkSectionPos pos, ServerPlayerEntity player)
void	handleChunkLeave(ChunkSectionPos pos, ServerPlayerEntity player)
protected abstract boolean	isUnloaded(long pos)
boolean	method_20800(long long2)
protected void	purge()
<T> void	removeTicket(ChunkTicketType<T> type, ChunkPos pos, int radius, T argument)
private void	removeTicket(long pos, ChunkTicket<?> ticket)
<T> void	removeTicketWithLevel(ChunkTicketType<T> type, ChunkPos pos, int level, T argument)
protected void	setChunkForced(ChunkPos pos, boolean forced)
protected abstract ChunkHolder	setLevel(long pos, int level, ChunkHolder holder, int int2)
protected void	setWatchDistance(int viewDistance)
boolean	tick(ThreadedAnvilChunkStorage chunkStorage)
String	toDumpString()

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

NEARBY_PLAYER_TICKET_LEVEL

private static final int NEARBY_PLAYER_TICKET_LEVEL

playersByChunkPos

private final it.unimi.dsi.fastutil.longs.Long2ObjectMap<it.unimi.dsi.fastutil.objects.ObjectSet<ServerPlayerEntity>> playersByChunkPos

ticketsByPosition

private final it.unimi.dsi.fastutil.longs.Long2ObjectOpenHashMap<SortedArraySet<ChunkTicket<?>>> ticketsByPosition

distanceFromTicketTracker

private final ChunkTicketManager.TicketDistanceLevelPropagator distanceFromTicketTracker

distanceFromNearestPlayerTracker

private final ChunkTicketManager.DistanceFromNearestPlayerTracker distanceFromNearestPlayerTracker

nearbyChunkTicketUpdater

private final ChunkTicketManager.NearbyChunkTicketUpdater nearbyChunkTicketUpdater

chunkHolders

private final Set<ChunkHolder> chunkHolders

levelUpdateListener

private final ChunkTaskPrioritySystem levelUpdateListener

playerTicketThrottler

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

playerTicketThrottlerUnblocker

private final MessageListener<ChunkTaskPrioritySystem.UnblockingMessage> playerTicketThrottlerUnblocker

chunkPositions

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

mainThreadExecutor

private final Executor mainThreadExecutor

age

private long age

Constructor Detail

ChunkTicketManager

protected ChunkTicketManager(Executor workerExecutor,
                             Executor mainThreadExecutor)

Method Detail

purge

protected void purge()

getLevel

private static int getLevel(SortedArraySet<ChunkTicket<?>> sortedArraySet)

isUnloaded

protected abstract boolean isUnloaded(long pos)

getChunkHolder

@Nullable
protected abstract ChunkHolder getChunkHolder(long pos)

setLevel

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

tick

public boolean tick(ThreadedAnvilChunkStorage chunkStorage)

addTicket

private void addTicket(long position,
                       ChunkTicket<?> ticket)

removeTicket

private void removeTicket(long pos,
                          ChunkTicket<?> ticket)

addTicketWithLevel

public <T> void addTicketWithLevel(ChunkTicketType<T> type,
                                   ChunkPos pos,
                                   int level,
                                   T argument)

removeTicketWithLevel

public <T> void removeTicketWithLevel(ChunkTicketType<T> type,
                                      ChunkPos pos,
                                      int level,
                                      T argument)

addTicket

public <T> void addTicket(ChunkTicketType<T> type,
                          ChunkPos pos,
                          int radius,
                          T argument)

removeTicket

public <T> void removeTicket(ChunkTicketType<T> type,
                             ChunkPos pos,
                             int radius,
                             T argument)

getTicketSet

private SortedArraySet<ChunkTicket<?>> getTicketSet(long position)

setChunkForced

protected void setChunkForced(ChunkPos pos,
                              boolean forced)

handleChunkEnter

public void handleChunkEnter(ChunkSectionPos pos,
                             ServerPlayerEntity player)

handleChunkLeave

public void handleChunkLeave(ChunkSectionPos pos,
                             ServerPlayerEntity player)

getTicket

protected String getTicket(long pos)

setWatchDistance

protected void setWatchDistance(int viewDistance)

getSpawningChunkCount

public int getSpawningChunkCount()

method_20800

public boolean method_20800(long long2)

toDumpString

public String toDumpString()