Package net.minecraft.world.level.chunk.storage

Class SectionStorage<R,P>

java.lang.Object

net.minecraft.world.level.chunk.storage.SectionStorage<R,P>

All Implemented Interfaces:

AutoCloseable

Direct Known Subclasses:

PoiManager

public class SectionStorage<R,P>
extends Object
implements AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final record	SectionStorage.PackedChunk<T>

Field Summary

Fields

Modifier and Type	Field	Description
private final com.mojang.serialization.Codec<P>	codec
private final it.unimi.dsi.fastutil.longs.LongLinkedOpenHashSet	dirtyChunks
private final ChunkIOErrorReporter	errorReporter
private final Function<Runnable,R>	factory
protected final LevelHeightAccessor	levelHeightAccessor
private final it.unimi.dsi.fastutil.longs.LongSet	loadedChunks
private final Object	loadLock
(package private) static final org.slf4j.Logger	LOGGER
private final Function<R,P>	packer
private final it.unimi.dsi.fastutil.longs.Long2ObjectMap<CompletableFuture<Optional<SectionStorage.PackedChunk<P>>>>	pendingLoads
private final RegistryAccess	registryAccess
private static final String	SECTIONS_TAG
private final SimpleRegionStorage	simpleRegionStorage
private final it.unimi.dsi.fastutil.longs.Long2ObjectMap<Optional<R>>	storage
private final BiFunction<P,Runnable,R>	unpacker

Constructor Summary

Constructors

Constructor	Description
SectionStorage(SimpleRegionStorage pSimpleRegionStorage, com.mojang.serialization.Codec<P> pCodec, Function<R,P> pPacker, BiFunction<P,Runnable,R> pUnpacker, Function<Runnable,R> pFactory, RegistryAccess pRegistryAccess, ChunkIOErrorReporter pErrorReporter, LevelHeightAccessor pLevelHeightAccessor)

Method Summary

Modifier and Type	Method	Description
void	close()
void	flush(ChunkPos pChunkPos)
void	flushAll()
protected Optional<R>	get(long pSectionKey)
private static long	getKey(ChunkPos pChunkPos, int pSectionY)
protected R	getOrCreate(long pSectionKey)
protected Optional<R>	getOrLoad(long pSectionKey)
boolean	hasWork()
protected void	onSectionLoad(long pSectionKey)
protected boolean	outsideStoredRange(long pSectionKey)
CompletableFuture<?>	prefetch(ChunkPos pPos)
void	remove(ChunkPos chunkPos)	Neo: Removes the data for the given chunk position.
protected void	setDirty(long pSectionPos)
protected void	tick(BooleanSupplier pAheadOfTime)
private CompletableFuture<Optional<SectionStorage.PackedChunk<P>>>	tryRead(ChunkPos pChunkPos)
private void	unpackChunk(ChunkPos pPos)
private void	unpackChunk(ChunkPos pPos, SectionStorage.PackedChunk<P> pPackedChunk)
private void	unpackPendingLoads()
private void	writeChunk(ChunkPos pPos)
private <T> com.mojang.serialization.Dynamic<T>	writeChunk(ChunkPos pPos, com.mojang.serialization.DynamicOps<T> pOps)

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

static final org.slf4j.Logger LOGGER

SECTIONS_TAG

private static final String SECTIONS_TAG

See Also:

• Constant Field Values

simpleRegionStorage

private final SimpleRegionStorage simpleRegionStorage

storage

private final it.unimi.dsi.fastutil.longs.Long2ObjectMap<Optional<R>> storage

dirtyChunks

private final it.unimi.dsi.fastutil.longs.LongLinkedOpenHashSet dirtyChunks

codec

private final com.mojang.serialization.Codec<P> codec

packer

private final Function<R,P> packer

unpacker

private final BiFunction<P,Runnable,R> unpacker

factory

private final Function<Runnable,R> factory

registryAccess

private final RegistryAccess registryAccess

errorReporter

private final ChunkIOErrorReporter errorReporter

levelHeightAccessor

protected final LevelHeightAccessor levelHeightAccessor

loadedChunks

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

pendingLoads

private final it.unimi.dsi.fastutil.longs.Long2ObjectMap<CompletableFuture<Optional<SectionStorage.PackedChunk<P>>>> pendingLoads

loadLock

private final Object loadLock

Constructor Details

SectionStorage

public SectionStorage(SimpleRegionStorage pSimpleRegionStorage,
 com.mojang.serialization.Codec<P> pCodec,
 Function<R,P> pPacker,
 BiFunction<P,Runnable,R> pUnpacker,
 Function<Runnable,R> pFactory,
 RegistryAccess pRegistryAccess,
 ChunkIOErrorReporter pErrorReporter,
 LevelHeightAccessor pLevelHeightAccessor)

Method Details

tick

protected void tick(BooleanSupplier pAheadOfTime)

unpackPendingLoads

private void unpackPendingLoads()

flushAll

public void flushAll()

hasWork

public boolean hasWork()

get

@Nullable
protected Optional<R> get(long pSectionKey)

getOrLoad

protected Optional<R> getOrLoad(long pSectionKey)

outsideStoredRange

protected boolean outsideStoredRange(long pSectionKey)

getOrCreate

protected R getOrCreate(long pSectionKey)

prefetch

public CompletableFuture<?> prefetch(ChunkPos pPos)

unpackChunk

private void unpackChunk(ChunkPos pPos)

tryRead

private CompletableFuture<Optional<SectionStorage.PackedChunk<P>>> tryRead(ChunkPos pChunkPos)

unpackChunk

private void unpackChunk(ChunkPos pPos,
 @Nullable
 SectionStorage.PackedChunk<P> pPackedChunk)

writeChunk

private void writeChunk(ChunkPos pPos)

writeChunk

private <T> com.mojang.serialization.Dynamic<T> writeChunk(ChunkPos pPos,
 com.mojang.serialization.DynamicOps<T> pOps)

getKey

private static long getKey(ChunkPos pChunkPos,
 int pSectionY)

onSectionLoad

protected void onSectionLoad(long pSectionKey)

setDirty

protected void setDirty(long pSectionPos)

flush

public void flush(ChunkPos pChunkPos)

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException

remove

public void remove(ChunkPos chunkPos)

Neo: Removes the data for the given chunk position. See PR #937