Package net.minecraft.world.storage

Class StorageIoWorker

java.lang.Object

net.minecraft.world.storage.StorageIoWorker

All Implemented Interfaces:

AutoCloseable, NbtScannable

public class StorageIoWorker
extends Object
implements NbtScannable, AutoCloseable

Mappings:

Namespace	Name
official	cyl
intermediary	net/minecraft/class_4698
named	net/minecraft/world/storage/StorageIoWorker

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static enum	StorageIoWorker.Priority
private static class	StorageIoWorker.Result

Field Summary

Fields

Modifier and Type	Field	Description
private final Long2ObjectLinkedOpenHashMap<CompletableFuture<BitSet>>	blendingStatusCaches
private final AtomicBoolean	closed
private final TaskExecutor<TaskQueue.PrioritizedTask>	executor
private static final Logger	LOGGER
private static final int	MAX_CACHE_SIZE
private final Map<ChunkPos,StorageIoWorker.Result>	results
private final RegionBasedStorage	storage

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	StorageIoWorker(Path directory, boolean dsync, String name)

Method Summary

Modifier and Type	Method	Description
void	close()
CompletableFuture<Void>	completeAll(boolean sync)
private CompletableFuture<BitSet>	computeBlendingStatus(int chunkX, int chunkZ)
private CompletableFuture<BitSet>	getOrComputeBlendingStatus(int chunkX, int chunkZ)
private boolean	needsBlending(NbtCompound nbt)
boolean	needsBlending(ChunkPos chunkPos, int checkRadius)
CompletableFuture<Optional<NbtCompound>>	readChunkData(ChunkPos pos)
private <T> CompletableFuture<T>	run(Supplier<com.mojang.datafixers.util.Either<T,Exception>> task)
CompletableFuture<Void>	scanChunk(ChunkPos pos, NbtScanner scanner)
CompletableFuture<Void>	setResult(ChunkPos pos, @Nullable NbtCompound nbt)
private void	write(ChunkPos pos, StorageIoWorker.Result result)
private void	writeRemainingResults()
private void	writeResult()

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

private static final Logger LOGGER

Mappings:

Namespace	Name	Mixin selector
official	a	Lcyl;a:Lorg/slf4j/Logger;
intermediary	field_21495	Lnet/minecraft/class_4698;field_21495:Lorg/slf4j/Logger;
named	LOGGER	Lnet/minecraft/world/storage/StorageIoWorker;LOGGER:Lorg/slf4j/Logger;

MAX_CACHE_SIZE

private static final int MAX_CACHE_SIZE

See Also:

• Constant Field Values

Mappings:

Namespace	Name	Mixin selector
official	g	Lcyl;g:I
intermediary	field_38241	Lnet/minecraft/class_4698;field_38241:I
named	MAX_CACHE_SIZE	Lnet/minecraft/world/storage/StorageIoWorker;MAX_CACHE_SIZE:I

closed

private final AtomicBoolean closed

Mappings:

Namespace	Name	Mixin selector
official	b	Lcyl;b:Ljava/util/concurrent/atomic/AtomicBoolean;
intermediary	field_21497	Lnet/minecraft/class_4698;field_21497:Ljava/util/concurrent/atomic/AtomicBoolean;
named	closed	Lnet/minecraft/world/storage/StorageIoWorker;closed:Ljava/util/concurrent/atomic/AtomicBoolean;

executor

private final TaskExecutor<TaskQueue.PrioritizedTask> executor

Mappings:

Namespace	Name	Mixin selector
official	c	Lcyl;c:Lazc;
intermediary	field_24468	Lnet/minecraft/class_4698;field_24468:Lnet/minecraft/class_3846;
named	executor	Lnet/minecraft/world/storage/StorageIoWorker;executor:Lnet/minecraft/util/thread/TaskExecutor;

storage

private final RegionBasedStorage storage

Mappings:

Namespace	Name	Mixin selector
official	d	Lcyl;d:Lcyo;
intermediary	field_21499	Lnet/minecraft/class_4698;field_21499:Lnet/minecraft/class_2867;
named	storage	Lnet/minecraft/world/storage/StorageIoWorker;storage:Lnet/minecraft/world/storage/RegionBasedStorage;

results

private final Map<ChunkPos,StorageIoWorker.Result> results

Mappings:

Namespace	Name	Mixin selector
official	e	Lcyl;e:Ljava/util/Map;
intermediary	field_21500	Lnet/minecraft/class_4698;field_21500:Ljava/util/Map;
named	results	Lnet/minecraft/world/storage/StorageIoWorker;results:Ljava/util/Map;

blendingStatusCaches

private final Long2ObjectLinkedOpenHashMap<CompletableFuture<BitSet>> blendingStatusCaches

Mappings:

Namespace	Name	Mixin selector
official	f	Lcyl;f:Lit/unimi/dsi/fastutil/longs/Long2ObjectLinkedOpenHashMap;
intermediary	field_38240	Lnet/minecraft/class_4698;field_38240:Lit/unimi/dsi/fastutil/longs/Long2ObjectLinkedOpenHashMap;
named	blendingStatusCaches	Lnet/minecraft/world/storage/StorageIoWorker;blendingStatusCaches:Lit/unimi/dsi/fastutil/longs/Long2ObjectLinkedOpenHashMap;

Constructor Details

StorageIoWorker

protected StorageIoWorker(Path directory,
 boolean dsync,
 String name)

Mappings:

Namespace	Name	Mixin selector
official	<init>	Lcyl;<init>(Ljava/nio/file/Path;ZLjava/lang/String;)V
intermediary	<init>	Lnet/minecraft/class_4698;<init>(Ljava/nio/file/Path;ZLjava/lang/String;)V
named	<init>	Lnet/minecraft/world/storage/StorageIoWorker;<init>(Ljava/nio/file/Path;ZLjava/lang/String;)V

Method Details

needsBlending

public boolean needsBlending(ChunkPos chunkPos,
 int checkRadius)

Mappings:

Namespace	Name	Mixin selector
official	a	Lcyl;a(Lcge;I)Z
intermediary	method_42330	Lnet/minecraft/class_4698;method_42330(Lnet/minecraft/class_1923;I)Z
named	needsBlending	Lnet/minecraft/world/storage/StorageIoWorker;needsBlending(Lnet/minecraft/util/math/ChunkPos;I)Z

getOrComputeBlendingStatus

private CompletableFuture<BitSet> getOrComputeBlendingStatus(int chunkX,
 int chunkZ)

Mappings:

Namespace	Name	Mixin selector
official	a	Lcyl;a(II)Ljava/util/concurrent/CompletableFuture;
intermediary	method_42329	Lnet/minecraft/class_4698;method_42329(II)Ljava/util/concurrent/CompletableFuture;
named	getOrComputeBlendingStatus	Lnet/minecraft/world/storage/StorageIoWorker;getOrComputeBlendingStatus(II)Ljava/util/concurrent/CompletableFuture;

computeBlendingStatus

private CompletableFuture<BitSet> computeBlendingStatus(int chunkX,
 int chunkZ)

Mappings:

Namespace	Name	Mixin selector
official	b	Lcyl;b(II)Ljava/util/concurrent/CompletableFuture;
intermediary	method_42333	Lnet/minecraft/class_4698;method_42333(II)Ljava/util/concurrent/CompletableFuture;
named	computeBlendingStatus	Lnet/minecraft/world/storage/StorageIoWorker;computeBlendingStatus(II)Ljava/util/concurrent/CompletableFuture;

needsBlending

private boolean needsBlending(NbtCompound nbt)

Mappings:

Namespace	Name	Mixin selector
official	a	Lcyl;a(Lpj;)Z
intermediary	method_42332	Lnet/minecraft/class_4698;method_42332(Lnet/minecraft/class_2487;)Z
named	needsBlending	Lnet/minecraft/world/storage/StorageIoWorker;needsBlending(Lnet/minecraft/nbt/NbtCompound;)Z

setResult

public CompletableFuture<Void> setResult(ChunkPos pos,
 @Nullable
 @Nullable NbtCompound nbt)

Mappings:

Namespace	Name	Mixin selector
official	a	Lcyl;a(Lcge;Lpj;)Ljava/util/concurrent/CompletableFuture;
intermediary	method_23703	Lnet/minecraft/class_4698;method_23703(Lnet/minecraft/class_1923;Lnet/minecraft/class_2487;)Ljava/util/concurrent/CompletableFuture;
named	setResult	Lnet/minecraft/world/storage/StorageIoWorker;setResult(Lnet/minecraft/util/math/ChunkPos;Lnet/minecraft/nbt/NbtCompound;)Ljava/util/concurrent/CompletableFuture;

readChunkData

public CompletableFuture<Optional<NbtCompound>> readChunkData(ChunkPos pos)

Mappings:

Namespace	Name	Mixin selector
official	a	Lcyl;a(Lcge;)Ljava/util/concurrent/CompletableFuture;
intermediary	method_31738	Lnet/minecraft/class_4698;method_31738(Lnet/minecraft/class_1923;)Ljava/util/concurrent/CompletableFuture;
named	readChunkData	Lnet/minecraft/world/storage/StorageIoWorker;readChunkData(Lnet/minecraft/util/math/ChunkPos;)Ljava/util/concurrent/CompletableFuture;

completeAll

public CompletableFuture<Void> completeAll(boolean sync)

Mappings:

Namespace	Name	Mixin selector
official	a	Lcyl;a(Z)Ljava/util/concurrent/CompletableFuture;
intermediary	method_23698	Lnet/minecraft/class_4698;method_23698(Z)Ljava/util/concurrent/CompletableFuture;
named	completeAll	Lnet/minecraft/world/storage/StorageIoWorker;completeAll(Z)Ljava/util/concurrent/CompletableFuture;

scanChunk

public CompletableFuture<Void> scanChunk(ChunkPos pos,
 NbtScanner scanner)

Specified by:

scanChunk in interface NbtScannable

Mappings:

Namespace	Name	Mixin selector
official	a	Lcyh;a(Lcge;Lpz;)Ljava/util/concurrent/CompletableFuture;
intermediary	method_39795	Lnet/minecraft/class_6830;method_39795(Lnet/minecraft/class_1923;Lnet/minecraft/class_6836;)Ljava/util/concurrent/CompletableFuture;
named	scanChunk	Lnet/minecraft/world/storage/NbtScannable;scanChunk(Lnet/minecraft/util/math/ChunkPos;Lnet/minecraft/nbt/scanner/NbtScanner;)Ljava/util/concurrent/CompletableFuture;

run

private <T> CompletableFuture<T> run(Supplier<com.mojang.datafixers.util.Either<T,Exception>> task)

Mappings:

Namespace	Name	Mixin selector
official	a	Lcyl;a(Ljava/util/function/Supplier;)Ljava/util/concurrent/CompletableFuture;
intermediary	method_23709	Lnet/minecraft/class_4698;method_23709(Ljava/util/function/Supplier;)Ljava/util/concurrent/CompletableFuture;
named	run	Lnet/minecraft/world/storage/StorageIoWorker;run(Ljava/util/function/Supplier;)Ljava/util/concurrent/CompletableFuture;

writeResult

private void writeResult()

Mappings:

Namespace	Name	Mixin selector
official	a	Lcyl;a()V
intermediary	method_23719	Lnet/minecraft/class_4698;method_23719()V
named	writeResult	Lnet/minecraft/world/storage/StorageIoWorker;writeResult()V

writeRemainingResults

private void writeRemainingResults()

Mappings:

Namespace	Name	Mixin selector
official	b	Lcyl;b()V
intermediary	method_27945	Lnet/minecraft/class_4698;method_27945()V
named	writeRemainingResults	Lnet/minecraft/world/storage/StorageIoWorker;writeRemainingResults()V

write

private void write(ChunkPos pos,
 StorageIoWorker.Result result)

Mappings:

Namespace	Name	Mixin selector
official	a	Lcyl;a(Lcge;Lcyl$a;)V
intermediary	method_23701	Lnet/minecraft/class_4698;method_23701(Lnet/minecraft/class_1923;Lnet/minecraft/class_4698$class_4699;)V
named	write	Lnet/minecraft/world/storage/StorageIoWorker;write(Lnet/minecraft/util/math/ChunkPos;Lnet/minecraft/world/storage/StorageIoWorker$Result;)V

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException