E  java/lang/Object()V)java/util/concurrent/atomic/AtomicBoolean   0net/minecraft/world/level/chunk/storage/IOWorkershutdownRequested+Ljava/util/concurrent/atomic/AtomicBoolean;java/util/LinkedHashMap    pendingWritesLjava/util/SequencedMap;8it/unimi/dsi/fastutil/longs/Long2ObjectLinkedOpenHashMap   regionCacheForBlender:Lit/unimi/dsi/fastutil/longs/Long2ObjectLinkedOpenHashMap;9net/minecraft/world/level/chunk/storage/RegionFileStorage ! "S(Lnet/minecraft/world/level/chunk/storage/RegionStorageInfo;Ljava/nio/file/Path;Z)V $ %&storage;Lnet/minecraft/world/level/chunk/storage/RegionFileStorage;(5net/minecraft/util/thread/PriorityConsecutiveExecutor *+, -.9net/minecraft/world/level/chunk/storage/IOWorker$Priorityvalues>()[Lnet/minecraft/world/level/chunk/storage/IOWorker$Priority; 012 34net/minecraft/util/UtilioPool!()Lnet/minecraft/TracingExecutor; 678 9:9net/minecraft/world/level/chunk/storage/RegionStorageInfotype()Ljava/lang/String;< =>makeConcatWithConstants&(Ljava/lang/String;)Ljava/lang/String; '@ A5(ILjava/util/concurrent/Executor;Ljava/lang/String;)V C DEconsecutiveExecutor7Lnet/minecraft/util/thread/PriorityConsecutiveExecutor;G"net/minecraft/world/level/ChunkPos FI JKx()I FM NKz FP Q(II)V FS TK getRegionX FV WK getRegionZ Y Z[getOrCreateOldDataForRegion,(II)Ljava/util/concurrent/CompletableFuture; ]^_ `a&java/util/concurrent/CompletableFuturejoin()Ljava/lang/Object;cjava/util/BitSet be fgisEmpty()Z Fi jk minFromRegion((II)Lnet/minecraft/world/level/ChunkPos; mno pqjava/lang/Mathmax(II)I ms tqmin bv wxget(I)Z Fz {|pack(II)J ~ getAndMoveToFirst(J)Ljava/lang/Object; [createOldDataForRegion  putAndMoveToFirst'(JLjava/lang/Object;)Ljava/lang/Object;  Ksize  a removeLast wS(Lnet/minecraft/world/level/chunk/storage/IOWorker;II)Ljava/util/function/Supplier; 0 4backgroundExecutor ]  supplyAsyncf(Ljava/util/function/Supplier;Ljava/util/concurrent/Executor;)Ljava/util/concurrent/CompletableFuture; DataVersion  net/minecraft/nbt/CompoundTaggetIntOr(Ljava/lang/String;I)I%net/minecraft/util/datafix/DataFixers blending_data  getCompound((Ljava/lang/String;)Ljava/util/Optional;  gjava/util/Optional isPresent w>(Lnet/minecraft/nbt/CompoundTag;)Ljava/util/function/Supplier; storek(Lnet/minecraft/world/level/ChunkPos;Ljava/util/function/Supplier;)Ljava/util/concurrent/CompletableFuture; w(Lnet/minecraft/world/level/chunk/storage/IOWorker;Ljava/util/function/Supplier;Lnet/minecraft/world/level/ChunkPos;)Ljava/util/function/Supplier;  submitTaskG(Ljava/util/function/Supplier;)Ljava/util/concurrent/CompletableFuture;  java/util/function/Functionidentity()Ljava/util/function/Function; ]  thenComposeG(Ljava/util/function/Function;)Ljava/util/concurrent/CompletableFuture; w(Lnet/minecraft/world/level/chunk/storage/IOWorker;Lnet/minecraft/world/level/ChunkPos;)Lnet/minecraft/world/level/chunk/storage/IOWorker$ThrowingSupplier; submitThrowingTaskm(Lnet/minecraft/world/level/chunk/storage/IOWorker$ThrowingSupplier;)Ljava/util/concurrent/CompletableFuture; wQ(Lnet/minecraft/world/level/chunk/storage/IOWorker;)Ljava/util/function/Supplier; applyQ(Lnet/minecraft/world/level/chunk/storage/IOWorker;)Ljava/util/function/Function; w(Lnet/minecraft/world/level/chunk/storage/IOWorker;Lnet/minecraft/world/level/ChunkPos;Lnet/minecraft/nbt/StreamTagVisitor;)Lnet/minecraft/world/level/chunk/storage/IOWorker$ThrowingSupplier; *  FOREGROUND;Lnet/minecraft/world/level/chunk/storage/IOWorker$Priority; * Kordinal accept(Lnet/minecraft/world/level/chunk/storage/IOWorker;Lnet/minecraft/world/level/chunk/storage/IOWorker$ThrowingSupplier;)Ljava/util/function/Consumer; ' scheduleWithResultH(ILjava/util/function/Consumer;)Ljava/util/concurrent/CompletableFuture; n(Lnet/minecraft/world/level/chunk/storage/IOWorker;Ljava/util/function/Supplier;)Ljava/util/function/Consumer;  java/util/SequencedMappollFirstEntry()Ljava/util/Map$Entry;  ajava/util/Map$EntrygetKey agetValue=net/minecraft/world/level/chunk/storage/IOWorker$PendingStore runStoref(Lnet/minecraft/world/level/ChunkPos;Lnet/minecraft/world/level/chunk/storage/IOWorker$PendingStore;)V tellStorePending:net/minecraft/util/thread/StrictQueue$RunnableWithPriority *  BACKGROUND  runH(Lnet/minecraft/world/level/chunk/storage/IOWorker;)Ljava/lang/Runnable;   (ILjava/lang/Runnable;)V ' schedule(Ljava/lang/Runnable;)V  dataLnet/minecraft/nbt/CompoundTag;  writeF(Lnet/minecraft/world/level/ChunkPos;Lnet/minecraft/nbt/CompoundTag;)V  result(Ljava/util/concurrent/CompletableFuture; ] complete(Ljava/lang/Object;)Z!java/lang/Exception # $%LOGGERLorg/slf4j/Logger;'Failed to store chunk {} )*+ ,-org/slf4j/Loggererror9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V ]/ 01completeExceptionally(Ljava/lang/Throwable;)Z 3 45 compareAndSet(ZZ)Z 7 8waitForShutdown ': ;close :>Failed to close storage )@ ,A*(Ljava/lang/String;Ljava/lang/Throwable;)V *C DSHUTDOWN F G()Ljava/util/function/Consumer; I JKinfo=()Lnet/minecraft/world/level/chunk/storage/RegionStorageInfo; MNO PQnet/minecraft/util/UnitINSTANCELnet/minecraft/util/Unit; S wg UVW wajava/util/function/Supplier YVZAnet/minecraft/world/level/chunk/storage/IOWorker$ThrowingSupplier \ w]&(Ljava/lang/Object;)Ljava/lang/Object; _ `a acceptAsRoot'(Lnet/minecraft/nbt/StreamTagVisitor;)V c de scanChunkK(Lnet/minecraft/world/level/ChunkPos;Lnet/minecraft/nbt/StreamTagVisitor;)VgFailed to bulk scan chunk {} )i j-warn l wm()Ljava/util/function/Supplier;o wpw(Lnet/minecraft/world/level/chunk/storage/IOWorker;)Lnet/minecraft/world/level/chunk/storage/IOWorker$ThrowingSupplier; r sflushuFailed to synchronize chunks )w jA y -z()Ljava/util/Collection; |}~ java/util/Collectionstream()Ljava/util/stream/Stream;  java/util/stream/Streammap8(Ljava/util/function/Function;)Ljava/util/stream/Stream; "()Ljava/util/function/IntFunction;  toArray5(Ljava/util/function/IntFunction;)[Ljava/lang/Object;)[Ljava/util/concurrent/CompletableFuture; ] allOfS([Ljava/util/concurrent/CompletableFuture;)Ljava/util/concurrent/CompletableFuture;  copyData!()Lnet/minecraft/nbt/CompoundTag;   ofNullable((Ljava/lang/Object;)Ljava/util/Optional;  readE(Lnet/minecraft/world/level/ChunkPos;)Lnet/minecraft/nbt/CompoundTag;Failed to read chunk {} >(Lnet/minecraft/nbt/CompoundTag;)Ljava/util/function/Function;  computeIfAbsentC(Ljava/lang/Object;Ljava/util/function/Function;)Ljava/lang/Object;  "(Lnet/minecraft/nbt/CompoundTag;)V F k maxFromRegion b F  rangeClosedc(Lnet/minecraft/world/level/ChunkPos;Lnet/minecraft/world/level/ChunkPos;)Ljava/util/stream/Stream; c(Lnet/minecraft/world/level/chunk/storage/IOWorker;Ljava/util/BitSet;)Ljava/util/function/Consumer;  forEach (Ljava/util/function/Consumer;)V(net/minecraft/nbt/visitors/CollectFields(net/minecraft/nbt/visitors/FieldSelector  net/minecraft/nbt/IntTagTYPELnet/minecraft/nbt/TagType;  0(Lnet/minecraft/nbt/TagType;Ljava/lang/String;)V   .([Lnet/minecraft/nbt/visitors/FieldSelector;)V  dr(Lnet/minecraft/world/level/ChunkPos;Lnet/minecraft/nbt/StreamTagVisitor;)Ljava/util/concurrent/CompletableFuture;Failed to scan chunk {}   getResult()Lnet/minecraft/nbt/Tag;   isOldChunk"(Lnet/minecraft/nbt/CompoundTag;)Z F KgetRegionLocalZ F KgetRegionLocalX b set(I)Vl   STORE_EMPTYLjava/util/function/Supplier;  com/mojang/logging/LogUtils getLogger()Lorg/slf4j/Logger;java/lang/AutoCloseable7net/minecraft/world/level/chunk/storage/ChunkScanAccess Signature>Ljava/util/function/Supplier;}Ljava/util/SequencedMap;xLit/unimi/dsi/fastutil/longs/Long2ObjectLinkedOpenHashMap;>;REGION_CACHE_SIZEI ConstantValueCodeLineNumberTableLocalVariableTablethis2Lnet/minecraft/world/level/chunk/storage/IOWorker;;Lnet/minecraft/world/level/chunk/storage/RegionStorageInfo;dirLjava/nio/file/Path;syncZMethodParametersisOldChunkAround((Lnet/minecraft/world/level/ChunkPos;I)Z chunkIndexLjava/util/BitSet; minChunkPos$Lnet/minecraft/world/level/ChunkPos; startChunkX startChunkZ endChunkX endChunkZregionZregionXposrangefromto StackMapTable regionPosJLocalVariableTypeTable;java/lang/Throwable@(II)Ljava/util/concurrent/CompletableFuture;tagm(Lnet/minecraft/world/level/ChunkPos;Lnet/minecraft/nbt/CompoundTag;)Ljava/util/concurrent/CompletableFuture;value(Lnet/minecraft/world/level/ChunkPos;Lnet/minecraft/nbt/CompoundTag;)Ljava/util/concurrent/CompletableFuture;supplier(Lnet/minecraft/world/level/ChunkPos;Ljava/util/function/Supplier;)Ljava/util/concurrent/CompletableFuture; loadAsyncN(Lnet/minecraft/world/level/ChunkPos;)Ljava/util/concurrent/CompletableFuture;(Lnet/minecraft/world/level/ChunkPos;)Ljava/util/concurrent/CompletableFuture;>; synchronize+(Z)Ljava/util/concurrent/CompletableFuture; currentWrites:Ljava/util/concurrent/CompletableFuture;=(Z)Ljava/util/concurrent/CompletableFuture;visitor$Lnet/minecraft/nbt/StreamTagVisitor;(Lnet/minecraft/world/level/ChunkPos;Lnet/minecraft/nbt/StreamTagVisitor;)Ljava/util/concurrent/CompletableFuture;taskCLnet/minecraft/world/level/chunk/storage/IOWorker$ThrowingSupplier;HLnet/minecraft/world/level/chunk/storage/IOWorker$ThrowingSupplier;(Lnet/minecraft/world/level/chunk/storage/IOWorker$ThrowingSupplier;)Ljava/util/concurrent/CompletableFuture;"Ljava/util/function/Supplier;g(Ljava/util/function/Supplier;)Ljava/util/concurrent/CompletableFuture;storePendingChunkentryLjava/util/Map$Entry;zLjava/util/Map$Entry;eLjava/lang/Exception;?Lnet/minecraft/world/level/chunk/storage/IOWorker$PendingStore; Exceptions?java/io/IOException storageInfolambda$waitForShutdown$0+(Ljava/util/concurrent/CompletableFuture;)Vfuturelambda$submitTask$0H(Ljava/util/function/Supplier;Ljava/util/concurrent/CompletableFuture;)Vlambda$submitThrowingTask$0n(Lnet/minecraft/world/level/chunk/storage/IOWorker$ThrowingSupplier;Ljava/util/concurrent/CompletableFuture;)Vlambda$scanChunk$0Z(Lnet/minecraft/world/level/ChunkPos;Lnet/minecraft/nbt/StreamTagVisitor;)Ljava/lang/Void; pendingStoreL"net/minecraft/nbt/StreamTagVisitorlambda$synchronize$58(Ljava/lang/Void;)Ljava/util/concurrent/CompletionStage;ignoreLjava/lang/Void;lambda$synchronize$6()Ljava/lang/Void;lambda$synchronize$3lambda$synchronize$4lambda$synchronize$0*()Ljava/util/concurrent/CompletableFuture;lambda$synchronize$2,(I)[Ljava/util/concurrent/CompletableFuture;x$0lambda$synchronize$1i(Lnet/minecraft/world/level/chunk/storage/IOWorker$PendingStore;)Ljava/util/concurrent/CompletableFuture;lambda$loadAsync$0:(Lnet/minecraft/world/level/ChunkPos;)Ljava/util/Optional;lambda$store$1k(Ljava/util/function/Supplier;Lnet/minecraft/world/level/ChunkPos;)Ljava/util/concurrent/CompletableFuture;lambda$store$2(Lnet/minecraft/nbt/CompoundTag;Lnet/minecraft/world/level/ChunkPos;)Lnet/minecraft/world/level/chunk/storage/IOWorker$PendingStore;plambda$store$0@(Lnet/minecraft/nbt/CompoundTag;)Lnet/minecraft/nbt/CompoundTag;lambda$createOldDataForRegion$0(II)Ljava/util/BitSet; resultSetlambda$createOldDataForRegion$19(Ljava/util/BitSet;Lnet/minecraft/world/level/ChunkPos;)VchunkTag collectFields*Lnet/minecraft/nbt/visitors/CollectFields;Lnet/minecraft/nbt/Tag;onet/minecraft/nbt/Taglambda$static$0 SourceFile IOWorker.java NestMembersBootstrapMethodsw IOWorker-az { ef}()Ljava/util/BitSet;  cd  ^_V  \]()Ljava/util/Optional;  UV]  SNN  MN  HIR(Ljava/lang/Object;)V  FGB  DE  6  AB  QR  TR  Z[[(I)Ljava/lang/Object;  WXX  `ae(Lnet/minecraft/world/level/ChunkPos;)Lnet/minecraft/world/level/chunk/storage/IOWorker$PendingStore;  hi'(Lnet/minecraft/world/level/ChunkPos;)V  p  =$java/lang/invoke/StringConcatFactory(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;  "java/lang/invoke/LambdaMetafactory metafactory(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite; InnerClassesPriorityThrowingSupplier java/util/MapEntry PendingStore%net/minecraft/util/thread/StrictQueueRunnableWithPriority%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandlesLookup! $%DE%&%"O**Y *Y*Y*Y+, #*'Y)/+5;?BPFKM%Q3RNS*OOJOO JlFY+Hd+LdONFY+H`+L`O:-R6R-U6U*X\b:dh:-HHdl6 -LLdl6 HHdr6 LLdr6  6   0 6  h `6u τS=ZVW)Y9ZI\Y]a^dbmc}defhijklihZYs  #N4J Y m|  }l  \ J 8 ?/  ) [ /FF$bP FFFbF  FFF Z[VyB*Y:*!}]:+*:*!W* *Wð:MNNSN* wxyz {(}3~@HN43VVVP 3H]  [U*   ^++  J *+,     ! !"k**,+   # # #$%&@ **+Ȱ   '()+**M,*,*  ++s* *+ ]s,dK **+,Ȱ     -. -/[*B׶*+01 0203[*B׶*+0 04056**L+*+F+*   %)* 78  79I*BY*    0*#+,,WN"&+-(,-.W  &/*:;00 0<X  ;0* 2*6*B9*#<L"=+?" & " # &'*-"+#,/.# :;0 T =>8E*BBۺE\W 23 @K2*#H6  AB3 *LW2  CDEm* R,+TW*  0CFG$* R,+XW N,-.W*   #*:;$$01$CX HI?*+[N---,^ *#+,bN"f+-h-./ & $-/0=4!J<0:;?? ?-.$ FK = MN> *k  OP QRSN? **nȰ  OPTRp*#qL"t+v+    :;I = UVS)*x{ ) WX/] Y Z[/* <\]8*+[M, ,*#+N-N"+-h-'( "#()64#):;88 *J< M = ^_++TN*,-:- %4++#+  ! J< `a= Y*  b  cd,* !ef,hN:bY:-* )>,,,&   g hi@ {YYYSYYSN*,-ζ\W:",h-:':*י, h,`6+*47 . *479GHNftzR9:;t ]j{{g { *QklN-m7 bF 1n p/q+" /1rstY*uvxy|x~xxxxxxx2* @Y