EC  java/lang/Object()V   com/google/common/collect/Sets newHashSet()Ljava/util/HashSet;  ?net/minecraft/world/level/entity/PersistentEntitySectionManager knownUuidsLjava/util/Set;2it/unimi/dsi/fastutil/longs/Long2ObjectOpenHashMap   chunkVisibility,Lit/unimi/dsi/fastutil/longs/Long2ObjectMap;  chunkLoadStatuses+it/unimi/dsi/fastutil/longs/LongOpenHashSet  ! "#chunksToUnload%Lit/unimi/dsi/fastutil/longs/LongSet; %&' () com/google/common/collect/QueuesnewConcurrentLinkedQueue.()Ljava/util/concurrent/ConcurrentLinkedQueue; + ,- loadingInboxLjava/util/Queue;/-net/minecraft/world/level/entity/EntityLookup . 2 34visibleEntityStorage/Lnet/minecraft/world/level/entity/EntityLookup;65net/minecraft/world/level/entity/EntitySectionStorage 58 9E(Ljava/lang/Class;Lit/unimi/dsi/fastutil/longs/Long2ObjectFunction;)V ; <=sectionStorage7Lnet/minecraft/world/level/entity/EntitySectionStorage; ?@A BC+net/minecraft/world/level/entity/VisibilityHIDDEN-Lnet/minecraft/world/level/entity/Visibility; EFG HI*it/unimi/dsi/fastutil/longs/Long2ObjectMapdefaultReturnValue(Ljava/lang/Object;)V KLM NOOnet/minecraft/world/level/entity/PersistentEntitySectionManager$ChunkLoadStatusFRESHQLnet/minecraft/world/level/entity/PersistentEntitySectionManager$ChunkLoadStatus; Q RS callbacks0Lnet/minecraft/world/level/entity/LevelCallback; U VWpermanentStorage:Lnet/minecraft/world/level/entity/EntityPersistentStorage;Y9net/minecraft/world/level/entity/LevelEntityGetterAdapter X[ \i(Lnet/minecraft/world/level/entity/EntityLookup;Lnet/minecraft/world/level/entity/EntitySectionStorage;)V ^ _` entityGetter4Lnet/minecraft/world/level/entity/LevelEntityGetter; bcd ef.net/minecraft/world/level/entity/EntitySectionisEmpty()Z 5h ijremove(J)V lmn op-net/minecraft/world/level/entity/EntityAccessgetUUID()Ljava/util/UUID; rst uv java/util/Setadd(Ljava/lang/Object;)Z x yzLOGGERLorg/slf4j/Logger;|'UUID of added entity already exists: {} ~ org/slf4j/Loggerwarn'(Ljava/lang/String;Ljava/lang/Object;)V   addEntity3(Lnet/minecraft/world/level/entity/EntityAccess;Z)Z   addEntityUuid2(Lnet/minecraft/world/level/entity/EntityAccess;)Z l  blockPosition()Lnet/minecraft/core/BlockPos;  net/minecraft/core/SectionPosasLong (Lnet/minecraft/core/BlockPos;)J 5 getOrCreateSection3(J)Lnet/minecraft/world/level/entity/EntitySection; b u2(Lnet/minecraft/world/level/entity/EntityAccess;)VHnet/minecraft/world/level/entity/PersistentEntitySectionManager$Callback (Lnet/minecraft/world/level/entity/PersistentEntitySectionManager;Lnet/minecraft/world/level/entity/EntityAccess;JLnet/minecraft/world/level/entity/EntitySection;)V l setLevelCallback;(Lnet/minecraft/world/level/entity/EntityInLevelCallback;)V  I.net/minecraft/world/level/entity/LevelCallback onCreated b  getStatus/()Lnet/minecraft/world/level/entity/Visibility;  getEffectiveStatus(Lnet/minecraft/world/level/entity/EntityAccess;Lnet/minecraft/world/level/entity/Visibility;)Lnet/minecraft/world/level/entity/Visibility; ? f isAccessible   startTracking ? f isTicking   startTicking l fisAlwaysTicking ? CTICKING  "net/minecraft/world/level/ChunkPospack()J E get(J)Ljava/lang/Object; accept`(Lnet/minecraft/world/level/entity/PersistentEntitySectionManager;)Ljava/util/function/Consumer;  java/util/stream/StreamforEach (Ljava/util/function/Consumer;)V IonTickingStart I onTickingEnd . IonTrackingStart I onTrackingEnd . i ? fromFullChunkStatus[(Lnet/minecraft/server/level/FullChunkStatus;)Lnet/minecraft/world/level/entity/Visibility;  updateChunkStatusT(Lnet/minecraft/world/level/ChunkPos;Lnet/minecraft/world/level/entity/Visibility;)V E i  u#it/unimi/dsi/fastutil/longs/LongSet(J)Z E put'(JLjava/lang/Object;)Ljava/lang/Object; i  jensureChunkQueuedForLoad 5 getExistingSectionsInChunk(J)Ljava/util/stream/Stream; (Lnet/minecraft/world/level/entity/PersistentEntitySectionManager;Lnet/minecraft/world/level/entity/Visibility;)Ljava/util/function/Consumer;   jrequestChunkLoad K  OPENDING apply()Ljava/util/function/Function;  flatMap8(Ljava/util/function/Function;)Ljava/util/stream/Stream;  java/util/stream/CollectorstoList()Ljava/util/stream/Collector;  collect0(Ljava/util/stream/Collector;)Ljava/lang/Object; java/util/List c K# $OLOADED&.net/minecraft/world/level/entity/ChunkEntities ( )*unpack'(J)Lnet/minecraft/world/level/ChunkPos; ,-. /0'com/google/common/collect/ImmutableListof+()Lcom/google/common/collect/ImmutableList; %2 37(Lnet/minecraft/world/level/ChunkPos;Ljava/util/List;)V 567 898net/minecraft/world/level/entity/EntityPersistentStorage storeEntities3(Lnet/minecraft/world/level/entity/ChunkEntities;)V  5< => loadEntitiesN(Lnet/minecraft/world/level/ChunkPos;)Ljava/util/concurrent/CompletableFuture; @AB CDjava/util/ObjectsrequireNonNull&(Ljava/lang/Object;)Ljava/lang/Object;F G0(Ljava/util/Queue;)Ljava/util/function/Consumer; IJK LM&java/util/concurrent/CompletableFuture thenAcceptG(Ljava/util/function/Consumer;)Ljava/util/concurrent/CompletableFuture;O PC(Lnet/minecraft/world/level/ChunkPos;)Ljava/util/function/Function; IR ST exceptionallyG(Ljava/util/function/Function;)Ljava/util/concurrent/CompletableFuture; W XYstoreChunkSections!(JLjava/util/function/Consumer;)Z [\] ^_/net/minecraft/world/entity/Entity$RemovalReasonUNLOADED_TO_CHUNK1Lnet/minecraft/world/entity/Entity$RemovalReason; la bc setRemoved4(Lnet/minecraft/world/entity/Entity$RemovalReason;)V efg hi6net/minecraft/world/level/entity/EntityInLevelCallbackNULL8Lnet/minecraft/world/level/entity/EntityInLevelCallback;k lmteste(Lnet/minecraft/world/level/entity/PersistentEntitySectionManager;)Ljava/util/function/LongPredicate; o pqremoveIf%(Ljava/util/function/LongPredicate;)Z stu vwjava/util/Queuepoll()Ljava/lang/Object; %y z{ getEntities()Ljava/util/stream/Stream; %~ getPos&()Lnet/minecraft/world/level/ChunkPos;  processPendingLoads  processUnloads 5  getAllChunksWithExistingSections'()Lit/unimi/dsi/fastutil/longs/LongSet;  +it/unimi/dsi/fastutil/longs/Long2ObjectMaps fastIterable\(Lit/unimi/dsi/fastutil/longs/Long2ObjectMap;)Lit/unimi/dsi/fastutil/objects/ObjectIterable;  ,it/unimi/dsi/fastutil/objects/ObjectIterableiterator0()Lit/unimi/dsi/fastutil/objects/ObjectIterator;  fjava/util/IteratorhasNext  wnext0it/unimi/dsi/fastutil/longs/Long2ObjectMap$Entry  wgetValue   getLongKey  getAllChunksToSave  m(Lnet/minecraft/world/level/entity/PersistentEntitySectionManager;)Lit/unimi/dsi/fastutil/longs/LongConsumer;  -(Lit/unimi/dsi/fastutil/longs/LongConsumer;)V c 5 flush(Z)V k  saveAll 5 close r vcontains   net/minecraft/util/CsvOutputbuilder(()Lnet/minecraft/util/CsvOutput$Builder;x  $net/minecraft/util/CsvOutput$Builder addColumn:(Ljava/lang/String;)Lnet/minecraft/util/CsvOutput$Builder;yz visibility load_status entity_count  build0(Ljava/io/Writer;)Lnet/minecraft/util/CsvOutput;  (Lnet/minecraft/world/level/entity/PersistentEntitySectionManager;Lnet/minecraft/util/CsvOutput;)Lit/unimi/dsi/fastutil/longs/LongConsumer; r size()I . count 5 E s   makeConcatWithConstants(IIIIIII)Ljava/lang/String; 5 "getExistingSectionPositionsInChunk (J)Ljava/util/stream/LongStream;  (Lnet/minecraft/world/level/entity/PersistentEntitySectionManager;Lnet/minecraft/util/CsvOutput;Lnet/minecraft/world/level/entity/PersistentEntitySectionManager$ChunkLoadStatus;)Ljava/util/function/LongConsumer;  java/util/stream/LongStream$(Ljava/util/function/LongConsumer;)V 5  getSection  (J)I  java/lang/IntegervalueOf(I)Ljava/lang/Integer;     b  writeRow([Ljava/lang/Object;)Vjava/io/IOExceptionjava/io/UncheckedIOException  (Ljava/io/IOException;)V  processChunkUnload ()Ljava/util/function/Consumer; l  {getPassengersAndSelf#Failed to read chunk {} ~% &'error9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V by* l+ ()Ljava/util/function/Predicate; - ./filter9(Ljava/util/function/Predicate;)Ljava/util/stream/Stream; b1 2\(Lnet/minecraft/world/level/entity/Visibility;)Lnet/minecraft/world/level/entity/Visibility;**** <=> ?@com/mojang/logging/LogUtils getLogger()Lorg/slf4j/Logger;Bjava/lang/AutoCloseable Signature!Ljava/util/Set;5Lnet/minecraft/world/level/entity/LevelCallback;?Lnet/minecraft/world/level/entity/EntityPersistentStorage;4Lnet/minecraft/world/level/entity/EntityLookup;;9Lnet/minecraft/world/level/entity/LevelEntityGetter;[Lit/unimi/dsi/fastutil/longs/Long2ObjectMap;Lit/unimi/dsi/fastutil/longs/Long2ObjectMap;HLjava/util/Queue;>;~(Ljava/lang/Class;Lnet/minecraft/world/level/entity/LevelCallback;Lnet/minecraft/world/level/entity/EntityPersistentStorage;)VCodeLineNumberTableLocalVariableTablethisALnet/minecraft/world/level/entity/PersistentEntitySectionManager; entityClassLjava/lang/Class;LocalVariableTypeTableFLnet/minecraft/world/level/entity/PersistentEntitySectionManager;Ljava/lang/Class;MethodParameters(Ljava/lang/Class;Lnet/minecraft/world/level/entity/LevelCallback;Lnet/minecraft/world/level/entity/EntityPersistentStorage;)VremoveSectionIfEmpty4(JLnet/minecraft/world/level/entity/EntitySection;)V sectionPosJsection0Lnet/minecraft/world/level/entity/EntitySection;5Lnet/minecraft/world/level/entity/EntitySection; StackMapTable9(JLnet/minecraft/world/level/entity/EntitySection;)Ventity/Lnet/minecraft/world/level/entity/EntityAccess;TT;(TT;)Z addNewEntityloadedZ sectionKey entitySectionstatus(TT;Z)Z(TT;Lnet/minecraft/world/level/entity/Visibility;)Lnet/minecraft/world/level/entity/Visibility;'(Lnet/minecraft/world/level/ChunkPos;)Zpos$Lnet/minecraft/world/level/ChunkPos;addLegacyChunkEntities(Ljava/util/stream/Stream;)VentitiesLjava/util/stream/Stream;Ljava/util/stream/Stream;!(Ljava/util/stream/Stream;)VaddWorldGenChunkEntities(TT;)V stopTicking stopTrackingS(Lnet/minecraft/world/level/ChunkPos;Lnet/minecraft/server/level/FullChunkStatus;)VfullChunkStatus,Lnet/minecraft/server/level/FullChunkStatus; chunkStatus chunkPosKeychunkPoschunkLoadStatussavedEntityVisitorLjava/util/function/Consumer;rootEntitiesToSaveLjava/util/List;"Ljava/util/function/Consumer;Ljava/util/List;&(JLjava/util/function/Consumer;)ZchunkKeystoreSuccessful unloadEntitye loadedChunk0Lnet/minecraft/world/level/entity/ChunkEntities;5Lnet/minecraft/world/level/entity/ChunkEntities;tickentry2Lit/unimi/dsi/fastutil/longs/Long2ObjectMap$Entry;resultLit/unimi/dsi/fastutil/longs/Long2ObjectMap$Entry;autoSave chunksToSave ExceptionsisLoaded(Ljava/util/UUID;)ZuuidLjava/util/UUID;getEntityGetter6()Lnet/minecraft/world/level/entity/LevelEntityGetter;;()Lnet/minecraft/world/level/entity/LevelEntityGetter;canPositionTick (Lnet/minecraft/core/BlockPos;)ZLnet/minecraft/core/BlockPos;areEntitiesLoaded dumpSections(Ljava/io/Writer;)VoutputLjava/io/Writer; csvOutputLnet/minecraft/util/CsvOutput; gatherStats()Ljava/lang/String;RuntimeInvisibleAnnotations$Lnet/minecraft/util/VisibleForDebug;lambda$dumpSections$0"(Lnet/minecraft/util/CsvOutput;J)V loadStatuslambda$dumpSections$1s(Lnet/minecraft/util/CsvOutput;Lnet/minecraft/world/level/entity/PersistentEntitySectionManager$ChunkLoadStatus;J)VLjava/io/IOException;lambda$saveAll$0 shouldUnloadlambda$saveAll$1lambda$autoSave$0lambda$autoSave$1lambda$processPendingLoads$0lambda$processUnloads$0lambda$processChunkUnload$0lambda$requestChunkLoad$0K(Lnet/minecraft/world/level/ChunkPos;Ljava/lang/Throwable;)Ljava/lang/Void;tLjava/lang/Throwable;lambda$storeChunkSections$0K(Lnet/minecraft/world/level/entity/EntitySection;)Ljava/util/stream/Stream;lambda$updateChunkStatus$0`(Lnet/minecraft/world/level/entity/Visibility;Lnet/minecraft/world/level/entity/EntitySection;)VpreviousStatus wasAccessible wasTickinglambda$updateChunkStatus$4lambda$updateChunkStatus$3lambda$updateChunkStatus$2lambda$updateChunkStatus$1!lambda$addWorldGenChunkEntities$0lambda$addLegacyChunkEntities$0_Ljava/lang/Object;Ljava/lang/AutoCloseable; SourceFile#PersistentEntitySectionManager.java NestMembersBootstrapMethodsI      3(Lnet/minecraft/world/level/entity/EntitySection;)VD    ss9  '(Ljava/lang/Throwable;)Ljava/lang/Void;      j  j     ,,,,,,        v  l f shouldBeSaved    z    {" # & ' * +,- ./"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;1 234 5$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; InnerClassesChunkLoadStatusCallback:!net/minecraft/world/entity/Entity RemovalReasonEntryBuilder?%java/lang/invoke/MethodHandles$LookupAjava/lang/invoke/MethodHandlesLookup!A yzCDRSCEVWCF34CG<=CH_`CICJCK"#,-CL6MN0** *Y*Y*Y *$**.Y01*5Y+*7:*>D*JD*,P*-T*XY*1*:Z]O: !,3>NZfkpP*QRSTRSVWU*QVSWREVFX SRVCYZ[N{-a *:gOP QR\]^_UQV^`aX \^CbN!* +kqw{+}OP!QR!cdU!QV!ceaXcCfgNW*+OPQRcdUQVceXcCfN8k*++B*:!:++Y*+! *P++:*+*+O: $6:DOW\diP>kQRkcdkhiWj]Mk_OlCU kQVkceMk`a 9b? X chCm Nd* +OPcdlCU cea@?X clCnoNZ*+Ĺ?OPQRpqU QVXprsNa +*O  P QR tuU QV tvXtCwxsNa +*O  P QR tuU QV tvXtCwN_ *P+O  P QR cdU QV ceXcCyzN_ *P+O  P QR cdU QV ceXcCyNk*1+*P+OPQRcdUQVceXcCy{Nk*P+*1+O PQRcdUQVceXcCy|Nn ,N*+-O P* QR pq }~CU  QVX p}NV+B,>*!W* !W*!,W* !W*!*:!*,O&  %1<AU P*VQRVpqVCQ]U VQVa%X pjN*KN-J*O P QR] OU QVaKXXYN\*K: *: :!$"*T%Y'+14J **T%Y'14-:OB&+8BJ!a#c&k(p)r./0P4QR]O8ZU QV8ZaKGX C jN9* W'N*T-;**Y?WEH-NQWO456"7488<P 9QR9]&pqU 9QVXN**UV>*WO? EGKLP QR] iU QVaXNa+Z`+dOP QRPQRdU QVXNQ* *jnWO U\P QRU QVN8**r%YL)+x*|*+}IJ"W̱O`b c7eP8QR*U8QV*a 6%NM **OhijP  QRU  QVNF*:L*M,),N-"+-W+Oop(q4rAtDuP (FQR>#U(FQVa+NP**O yP QRU QVN7*L+!*T*+*nW*TO,6P7QR2#U 7QVa &NR**TO P QRU QVNQ * +OP QR U  QVXNA*]OP QRU QVCNZ*+?OPQRpU QVXpoNZ*+Ĺ?OPQRpqU QVXpNg*"OPQR]U QVa@XN@Ƕ϶ѶӶն׶+M*:*,O*  $(,?P @QR@,U @QVXNA* *1*:***** O" $-6@P AQRU AQVND*1OP QRU QVN&* K:*: *+O%P*&QR&&]OU &QVN-]*:!:P+Y!SY!SY! SYSY,SY S :YMPO6  ",7CJMPR\P>R ]QR]]O]j] S^_U]QV S^`aPKb N-*>> * *VO P -QR-]iU -QVa @ I N+OP djN/*>> *W*VWOz|}#.P /QR/]iU /QVa @   N+OP dNN*+WObPQRdU QVNo*>*OVXZPQR]U QVaNX+*!OBPQRcdU QV NGw"*+$O 9 :Ppq N9*(),OP ^_N,+0N-6+6-6+6!,(3,*4$,(5,*6&!,(7,*8!,(9,*:O: (AKgq PRQRC^_C iiiiU QVaA?b?%"" ND*OP da @ ND*OP da @ ND*OP da @ ND*OP da @NN*+WOPQRdU QVNN*+WOPQRdU QVN;wO~CK))))))))))))0))) ) ))))))!)$)%)(62K7@8[9;@E< = >@B