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
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
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 @Nullable Optional<R>	get(long sectionPos)
private static long	getKey(ChunkPos chunkPos, int sectionY)
protected R	getOrCreate(long sectionPos)
protected Optional<R>	getOrLoad(long sectionPos)
boolean	hasWork()
protected void	onSectionLoad(long sectionPos)
protected boolean	outsideStoredRange(long sectionPos)
CompletableFuture<?>	prefetch(ChunkPos chunkPos)
void	remove(ChunkPos chunkPos)	Neo: Removes the data for the given chunk position.
protected void	setDirty(long sectionPos)
protected void	tick(BooleanSupplier haveTime)
private CompletableFuture<Optional<SectionStorage.PackedChunk<P>>>	tryRead(ChunkPos chunkPos)
private void	unpackChunk(ChunkPos chunkPos)
private void	unpackChunk(ChunkPos pos, @Nullable SectionStorage.PackedChunk<P> packedChunk)
private void	unpackPendingLoads()
private void	writeChunk(ChunkPos chunkPos)
private <T> com.mojang.serialization.Dynamic<T>	writeChunk(ChunkPos chunkPos, com.mojang.serialization.DynamicOps<T> ops)

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

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 haveTime)

unpackPendingLoads

private void unpackPendingLoads()

flushAll

public void flushAll()

hasWork

public boolean hasWork()

get

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

getOrLoad

protected Optional<R> getOrLoad(long sectionPos)

outsideStoredRange

protected boolean outsideStoredRange(long sectionPos)

getOrCreate

protected R getOrCreate(long sectionPos)

prefetch

public CompletableFuture<?> prefetch(ChunkPos chunkPos)

unpackChunk

private void unpackChunk(ChunkPos chunkPos)

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 chunkPos)

writeChunk

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

getKey

private static long getKey(ChunkPos chunkPos,
 int sectionY)

onSectionLoad

protected void onSectionLoad(long sectionPos)

setDirty

protected void setDirty(long sectionPos)

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