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	cqy
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 AtomicBoolean	closed
private final TaskExecutor<TaskQueue.PrioritizedTask>	executor
private static final Logger	LOGGER
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)
@Nullable NbtCompound	getNbt(ChunkPos pos)
protected CompletableFuture<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	Lcqy;a:Lorg/apache/logging/log4j/Logger;
intermediary	field_21495	Lnet/minecraft/class_4698;field_21495:Lorg/apache/logging/log4j/Logger;
named	LOGGER	Lnet/minecraft/world/storage/StorageIoWorker;LOGGER:Lorg/apache/logging/log4j/Logger;

closed

private final AtomicBoolean closed

Mappings:

Namespace	Name	Mixin selector
official	b	Lcqy;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	Lcqy;c:Lauk;
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	Lcqy;d:Lcrb;
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	Lcqy;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;

Constructor Details

StorageIoWorker

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

Mappings:

Namespace	Name	Mixin selector
official	<init>	Lcqy;<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

setResult

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

Mappings:

Namespace	Name	Mixin selector
official	a	Lcqy;a(Lbzk;Loc;)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;

getNbt

@Nullable
public @Nullable NbtCompound getNbt(ChunkPos pos)
                             throws IOException

Throws:

IOException

Mappings:

Namespace	Name	Mixin selector
official	a	Lcqy;a(Lbzk;)Loc;
intermediary	method_23700	Lnet/minecraft/class_4698;method_23700(Lnet/minecraft/class_1923;)Lnet/minecraft/class_2487;
named	getNbt	Lnet/minecraft/world/storage/StorageIoWorker;getNbt(Lnet/minecraft/util/math/ChunkPos;)Lnet/minecraft/nbt/NbtCompound;

readChunkData

protected CompletableFuture<NbtCompound> readChunkData(ChunkPos pos)

Mappings:

Namespace	Name	Mixin selector
official	b	Lcqy;b(Lbzk;)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	Lcqy;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	Lcqu;a(Lbzk;Los;)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	Lcqy;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	Lcqy;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	Lcqy;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	Lcqy;a(Lbzk;Lcqy$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