Class PersistentEntitySectionManager<T extends EntityAccess>

java.lang.Object

net.minecraft.world.level.entity.PersistentEntitySectionManager<T>

All Implemented Interfaces:

AutoCloseable

public class PersistentEntitySectionManager<T extends EntityAccess>
extends Object
implements AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	PersistentEntitySectionManager.Callback
private static enum	PersistentEntitySectionManager.ChunkLoadStatus

Field Summary

Fields

Modifier and Type	Field	Description
private final LevelCallback<T>	callbacks
private final it.unimi.dsi.fastutil.longs.Long2ObjectMap<PersistentEntitySectionManager.ChunkLoadStatus>	chunkLoadStatuses
private final it.unimi.dsi.fastutil.longs.LongSet	chunksToUnload
private final it.unimi.dsi.fastutil.longs.Long2ObjectMap<Visibility>	chunkVisibility
private final LevelEntityGetter<T>	entityGetter
private final Set<UUID>	knownUuids
private final Queue<ChunkEntities<T>>	loadingInbox
private static final org.slf4j.Logger	LOGGER
private final EntityPersistentStorage<T>	permanentStorage
private final EntitySectionStorage<T>	sectionStorage
private final EntityLookup<T>	visibleEntityStorage

Constructor Summary

Constructors

Constructor	Description
PersistentEntitySectionManager(Class<T> entityClass, LevelCallback<T> callbacks, EntityPersistentStorage<T> permanentStorage)

Method Summary

Modifier and Type	Method	Description
private boolean	addEntity(T entity, boolean loaded)
private boolean	addEntityUuid(T entity)
private boolean	addEntityWithoutEvent(T entity, boolean loaded)
void	addLegacyChunkEntities(Stream<T> entities)
boolean	addNewEntity(T entity)
boolean	addNewEntityWithoutEvent(T entity)
void	addWorldGenChunkEntities(Stream<T> entities)
boolean	areEntitiesLoaded(long chunkKey)
void	autoSave()
boolean	canPositionTick(BlockPos pos)
boolean	canPositionTick(ChunkPos pos)
void	close()
int	count()
void	dumpSections(Writer output)
private void	ensureChunkQueuedForLoad(long chunkPos)
String	gatherStats()
private it.unimi.dsi.fastutil.longs.LongSet	getAllChunksToSave()
private static <T extends EntityAccess> Visibility	getEffectiveStatus(T entity, Visibility status)
LevelEntityGetter<T>	getEntityGetter()
boolean	isLoaded(UUID uuid)
boolean	isTicking(ChunkPos pos)
private boolean	processChunkUnload(long chunkKey)
void	processPendingLoads()
private void	processUnloads()
private void	removeSectionIfEmpty(long sectionPos, EntitySection<T> section)
private void	requestChunkLoad(long chunkKey)
void	saveAll()
private void	startTicking(T entity)
private void	startTracking(T entity)
private void	stopTicking(T entity)
private void	stopTracking(T entity)
private boolean	storeChunkSections(long chunkPos, Consumer<T> savedEntityVisitor)
void	tick()
private void	unloadEntity(EntityAccess e)
void	updateChunkStatus(ChunkPos pos, FullChunkStatus fullChunkStatus)
void	updateChunkStatus(ChunkPos pos, Visibility chunkStatus)

Methods inherited from class Object

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

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

knownUuids

private final Set<UUID> knownUuids

callbacks

private final LevelCallback<T extends EntityAccess> callbacks

permanentStorage

private final EntityPersistentStorage<T extends EntityAccess> permanentStorage

visibleEntityStorage

private final EntityLookup<T extends EntityAccess> visibleEntityStorage

sectionStorage

private final EntitySectionStorage<T extends EntityAccess> sectionStorage

entityGetter

private final LevelEntityGetter<T extends EntityAccess> entityGetter

chunkVisibility

private final it.unimi.dsi.fastutil.longs.Long2ObjectMap<Visibility> chunkVisibility

chunkLoadStatuses

private final it.unimi.dsi.fastutil.longs.Long2ObjectMap<PersistentEntitySectionManager.ChunkLoadStatus> chunkLoadStatuses

chunksToUnload

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

loadingInbox

private final Queue<ChunkEntities<T extends EntityAccess>> loadingInbox

Constructor Details

PersistentEntitySectionManager

public PersistentEntitySectionManager(Class<T> entityClass,
 LevelCallback<T> callbacks,
 EntityPersistentStorage<T> permanentStorage)

Method Details

removeSectionIfEmpty

private void removeSectionIfEmpty(long sectionPos,
 EntitySection<T> section)

addEntityUuid

private boolean addEntityUuid(T entity)

addNewEntity

public boolean addNewEntity(T entity)

addNewEntityWithoutEvent

public boolean addNewEntityWithoutEvent(T entity)

addEntity

private boolean addEntity(T entity,
 boolean loaded)

addEntityWithoutEvent

private boolean addEntityWithoutEvent(T entity,
 boolean loaded)

getEffectiveStatus

private static <T extends EntityAccess> Visibility getEffectiveStatus(T entity,
 Visibility status)

isTicking

public boolean isTicking(ChunkPos pos)

addLegacyChunkEntities

public void addLegacyChunkEntities(Stream<T> entities)

addWorldGenChunkEntities

public void addWorldGenChunkEntities(Stream<T> entities)

startTicking

private void startTicking(T entity)

stopTicking

private void stopTicking(T entity)

startTracking

private void startTracking(T entity)

stopTracking

private void stopTracking(T entity)

updateChunkStatus

public void updateChunkStatus(ChunkPos pos,
 FullChunkStatus fullChunkStatus)

updateChunkStatus

public void updateChunkStatus(ChunkPos pos,
 Visibility chunkStatus)

ensureChunkQueuedForLoad

private void ensureChunkQueuedForLoad(long chunkPos)

storeChunkSections

private boolean storeChunkSections(long chunkPos,
 Consumer<T> savedEntityVisitor)

requestChunkLoad

private void requestChunkLoad(long chunkKey)

processChunkUnload

private boolean processChunkUnload(long chunkKey)

unloadEntity

private void unloadEntity(EntityAccess e)

processUnloads

private void processUnloads()

processPendingLoads

public void processPendingLoads()

tick

public void tick()

getAllChunksToSave

private it.unimi.dsi.fastutil.longs.LongSet getAllChunksToSave()

autoSave

public void autoSave()

saveAll

public void saveAll()

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException

isLoaded

public boolean isLoaded(UUID uuid)

getEntityGetter

public LevelEntityGetter<T> getEntityGetter()

canPositionTick

public boolean canPositionTick(BlockPos pos)

canPositionTick

public boolean canPositionTick(ChunkPos pos)

areEntitiesLoaded

public boolean areEntitiesLoaded(long chunkKey)

dumpSections

public void dumpSections(Writer output)
                  throws IOException

Throws:

IOException

gatherStats

public String gatherStats()

count

public int count()