Ec  java/lang/Object()V-net/minecraft/util/thread/ConsecutiveExecutor  net/minecraft/util/UtilnonCriticalIoPool!()Lnet/minecraft/TracingExecutor;download-queue  4(Ljava/util/concurrent/Executor;Ljava/lang/String;)V  (net/minecraft/server/packs/DownloadQueuetasks/Lnet/minecraft/util/thread/ConsecutiveExecutor;  cacheDirLjava/nio/file/Path;  ! "#net/minecraft/util/FileUtilcreateDirectoriesSafe(Ljava/nio/file/Path;)V %&' ()1net/minecraft/server/packs/DownloadQueue$LogEntryCODEC Lcom/mojang/serialization/Codec;+log.json -./ 01java/nio/file/Pathresolve((Ljava/lang/String;)Ljava/nio/file/Path; 345 67(net/minecraft/util/eventlog/JsonEventLogopen`(Lcom/mojang/serialization/Codec;Ljava/nio/file/Path;)Lnet/minecraft/util/eventlog/JsonEventLog; 9 :;eventLog*Lnet/minecraft/util/eventlog/JsonEventLog; =>? @A/net/minecraft/server/packs/DownloadCacheCleanervacuumCacheDir(Ljava/nio/file/Path;I)VC4net/minecraft/server/packs/DownloadQueue$BatchResult BF GHaccept(Lnet/minecraft/server/packs/DownloadQueue;Lnet/minecraft/server/packs/DownloadQueue$BatchConfig;Lnet/minecraft/server/packs/DownloadQueue$BatchResult;)Ljava/util/function/BiConsumer; JKL MN java/util/MapforEach"(Ljava/util/function/BiConsumer;)V PQR STjava/nio/file/Filessize(Ljava/nio/file/Path;)J -V WX relativize*(Ljava/nio/file/Path;)Ljava/nio/file/Path;Z6net/minecraft/server/packs/DownloadQueue$FileInfoEntry -\ ]^toString()Ljava/lang/String; Y` a(Ljava/lang/String;J)V cde fg!com/mojang/datafixers/util/Eitherright7(Ljava/lang/Object;)Lcom/mojang/datafixers/util/Either;ijava/io/IOException k lmLOGGERLorg/slf4j/Logger;oFailed to get file size of {} qrs tuorg/slf4j/Loggererror9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)Vw no_access cy zgleft| }~get(Lnet/minecraft/server/packs/DownloadQueue;Lnet/minecraft/server/packs/DownloadQueue$BatchConfig;Ljava/util/Map;)Ljava/util/function/Supplier;  java/util/ObjectsrequireNonNull&(Ljava/lang/Object;)Ljava/lang/Object; executeP(Lnet/minecraft/util/thread/ConsecutiveExecutor;)Ljava/util/concurrent/Executor;  &java/util/concurrent/CompletableFuture supplyAsyncf(Ljava/util/function/Supplier;Ljava/util/concurrent/Executor;)Ljava/util/concurrent/CompletableFuture;  close 3   runDownload}(Lnet/minecraft/server/packs/DownloadQueue$BatchConfig;Ljava/util/Map;)Lnet/minecraft/server/packs/DownloadQueue$BatchResult; \java/util/UUID  8net/minecraft/server/packs/DownloadQueue$DownloadRequesturlLjava/net/URL;  4net/minecraft/server/packs/DownloadQueue$BatchConfigheadersLjava/util/Map;  hashFunction%Lcom/google/common/hash/HashFunction; hash!Lcom/google/common/hash/HashCode; maxSizeI proxyLjava/net/Proxy; listener6Lnet/minecraft/util/HttpUtil$DownloadProgressListener;  net/minecraft/util/HttpUtil downloadFile(Ljava/nio/file/Path;Ljava/net/URL;Ljava/util/Map;Lcom/google/common/hash/HashFunction;Lcom/google/common/hash/HashCode;ILjava/net/Proxy;Lnet/minecraft/util/HttpUtil$DownloadProgressListener;)Ljava/nio/file/Path; B  downloaded J put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;java/lang/ExceptionFailed to download {} B failedLjava/util/Set;   java/util/Setadd(Ljava/lang/Object;)Z \ java/net/URL  java/time/Instantnow()Ljava/time/Instant;  java/util/Optional ofNullable((Ljava/lang/Object;)Ljava/util/Optional; apply()Ljava/util/function/Function; map3(Ljava/util/function/Function;)Ljava/util/Optional;   getFileInfo9(Ljava/nio/file/Path;)Lcom/mojang/datafixers/util/Either;download_failed % o(Ljava/util/UUID;Ljava/lang/String;Ljava/time/Instant;Ljava/util/Optional;Lcom/mojang/datafixers/util/Either;)V 3 write(Ljava/lang/Object;)VFailed to log download of {}  com/mojang/logging/LogUtils getLogger()Lorg/slf4j/Logger;java/lang/AutoCloseableMAX_KEPT_PACKS ConstantValue Signature_Lnet/minecraft/util/eventlog/JsonEventLog;CodeLineNumberTableLocalVariableTablethis*Lnet/minecraft/server/packs/DownloadQueue; ExceptionsMethodParametersconfig6Lnet/minecraft/server/packs/DownloadQueue$BatchConfig;requestsresult6Lnet/minecraft/server/packs/DownloadQueue$BatchResult;LocalVariableTypeTable[Ljava/util/Map;(Lnet/minecraft/server/packs/DownloadQueue$BatchConfig;Ljava/util/Map;)Lnet/minecraft/server/packs/DownloadQueue$BatchResult;J relativePatheLjava/io/IOException;downloadedFile StackMapTable(Ljava/nio/file/Path;)Lcom/mojang/datafixers/util/Either; downloadBatcho(Lnet/minecraft/server/packs/DownloadQueue$BatchConfig;Ljava/util/Map;)Ljava/util/concurrent/CompletableFuture;(Lnet/minecraft/server/packs/DownloadQueue$BatchConfig;Ljava/util/Map;)Ljava/util/concurrent/CompletableFuture;lambda$downloadBatch$0lambda$runDownload$0(Lnet/minecraft/server/packs/DownloadQueue$BatchConfig;Lnet/minecraft/server/packs/DownloadQueue$BatchResult;Ljava/util/UUID;Lnet/minecraft/server/packs/DownloadQueue$DownloadRequest;)VLjava/lang/Exception;idLjava/util/UUID;request:Lnet/minecraft/server/packs/DownloadQueue$DownloadRequest; targetDir+java/lang/String SourceFileDownloadQueue.java NestMembersBootstrapMethods2'(Ljava/lang/Object;Ljava/lang/Object;)V4 5 "#7M(Ljava/util/UUID;Lnet/minecraft/server/packs/DownloadQueue$DownloadRequest;)V9()Ljava/lang/Object;; < !>8()Lnet/minecraft/server/packs/DownloadQueue$BatchResult;@(Ljava/lang/Runnable;)VB CDE F@5net/minecraft/util/thread/AbstractConsecutiveExecutorscheduleI J\Kcom/google/common/hash/HashCodeM5(Lcom/google/common/hash/HashCode;)Ljava/lang/String;O PQR ST"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; InnerClassesLogEntry BatchResult BatchConfig FileInfoEntryDownloadRequest\4net/minecraft/util/HttpUtil$DownloadProgressListenerDownloadProgressListener_%java/lang/invoke/MethodHandles$Lookupajava/lang/invoke/MethodHandlesLookup!lm:;#6**Y *++*$+*,28+< ][^_`/b5c 6  6 hzBYDN,*+-EI- fg} *    7+OA*+U:YY[ _bMjn+,pvx#$h $%1 4S%7  7dhj*+,{*YW       A**8     h!E*+,    "# *-,::+++++:,-W!:jp,-W*8%Y-ո޺ *x:jpDGe Jhik7lDpGmInZoerstvu~vwr{yz| \ I$$  %&'()GB--1B--3ii*B--3ii*cH,j "-./ B%Y0*N136N8:=N?A?NGHLU:%VBWXYYZ[] ^`b