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 simpleRegionStorage, com.mojang.serialization.Codec<P> codec, Function<R,P> packer, BiFunction<P,Runnable,R> unpacker, Function<Runnable,R> factory, RegistryAccess registryAccess, ChunkIOErrorReporter errorReporter, LevelHeightAccessor levelHeightAccessor)

Method Summary

Modifier and Type	Method	Description
void	close()
void	flush(ChunkPos chunkPos)
void	flushAll()
protected Optional<R>	get(long sectionKey)
private static long	getKey(ChunkPos chunkPos, int sectionY)
protected R	getOrCreate(long sectionKey)
protected Optional<R>	getOrLoad(long sectionKey)
(package private) static int	getVersion(com.mojang.serialization.Dynamic<?> columnData)
boolean	hasWork()
protected void	onSectionLoad(long sectionKey)
protected boolean	outsideStoredRange(long sectionKey)
CompletableFuture<?>	prefetch(ChunkPos pos)
void	remove(ChunkPos chunkPos)	Neo: Removes the data for the given chunk position.
protected void	setDirty(long sectionPos)
protected void	tick(BooleanSupplier aheadOfTime)
private CompletableFuture<Optional<SectionStorage.PackedChunk<P>>>	tryRead(ChunkPos chunkPos)
private void	unpackChunk(ChunkPos pos)
private void	unpackChunk(ChunkPos pos, SectionStorage.PackedChunk<P> packedChunk)
private void	unpackPendingLoads()
private void	writeChunk(ChunkPos pos)
private <T> com.mojang.serialization.Dynamic<T>	writeChunk(ChunkPos pos, com.mojang.serialization.DynamicOps<T> ops)

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 simpleRegionStorage,
 com.mojang.serialization.Codec<P> codec,
 Function<R,P> packer,
 BiFunction<P,Runnable,R> unpacker,
 Function<Runnable,R> factory,
 RegistryAccess registryAccess,
 ChunkIOErrorReporter errorReporter,
 LevelHeightAccessor levelHeightAccessor)

Method Details

tick

protected void tick(BooleanSupplier aheadOfTime)

unpackPendingLoads

private void unpackPendingLoads()

flushAll

public void flushAll()

hasWork

public boolean hasWork()

get

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

getOrLoad

protected Optional<R> getOrLoad(long sectionKey)

outsideStoredRange

protected boolean outsideStoredRange(long sectionKey)

getOrCreate

protected R getOrCreate(long sectionKey)

prefetch

public CompletableFuture<?> prefetch(ChunkPos pos)

unpackChunk

private void unpackChunk(ChunkPos pos)

tryRead

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

unpackChunk

private void unpackChunk(ChunkPos pos,
 @Nullable
 SectionStorage.PackedChunk<P> packedChunk)

writeChunk

private void writeChunk(ChunkPos pos)

writeChunk

private <T> com.mojang.serialization.Dynamic<T> writeChunk(ChunkPos pos,
 com.mojang.serialization.DynamicOps<T> ops)

getKey

private static long getKey(ChunkPos chunkPos,
 int sectionY)

onSectionLoad

protected void onSectionLoad(long sectionKey)

setDirty

protected void setDirty(long sectionPos)

getVersion

static int getVersion(com.mojang.serialization.Dynamic<?> columnData)

flush

public void flush(ChunkPos chunkPos)

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