3\5org/elasticsearch/indices/recovery/RecoverySource$1$1java/lang/Objectjava/lang/RunnableRecoverySource.java3org/elasticsearch/indices/recovery/RecoverySource$1phase1?(Lorg/elasticsearch/index/deletionpolicy/SnapshotIndexCommit;)V 4org/elasticsearch/index/store/Store$MetadataSnapshot #org/elasticsearch/index/store/StoreMetadataSnapshot8org/elasticsearch/transport/TransportRequestOptions$Type3org/elasticsearch/transport/TransportRequestOptionsType val$store%Lorg/elasticsearch/index/store/Store;val$recoverySourceMetadata6Lorg/elasticsearch/index/store/Store$MetadataSnapshot;val$nameLjava/lang/String;val$corruptedEngine-Ljava/util/concurrent/atomic/AtomicReference;val$exceptions+Ljava/util/concurrent/CopyOnWriteArrayList; val$latch%Ljava/util/concurrent/CountDownLatch;this$15Lorg/elasticsearch/indices/recovery/RecoverySource$1;"(Lorg/elasticsearch/indices/recovery/RecoverySource$1;Lorg/elasticsearch/index/store/Store;Lorg/elasticsearch/index/store/Store$MetadataSnapshot;Ljava/lang/String;Ljava/util/concurrent/atomic/AtomicReference;Ljava/util/concurrent/CopyOnWriteArrayList;Ljava/util/concurrent/CountDownLatch;)V #$ '  )  +  -  /  1 !" 3()V %5 6this7Lorg/elasticsearch/indices/recovery/RecoverySource$1$1;runjava/lang/Throwable;incRef =5 >getE(Ljava/lang/String;)Lorg/elasticsearch/index/store/StoreFileMetaData; @A Bthis$03Lorg/elasticsearch/indices/recovery/RecoverySource; DE F1org/elasticsearch/indices/recovery/RecoverySourceH access$800j(Lorg/elasticsearch/indices/recovery/RecoverySource;)Lorg/elasticsearch/indices/recovery/RecoverySettings; JK IL3org/elasticsearch/indices/recovery/RecoverySettingsN fileChunkSize/()Lorg/elasticsearch/common/unit/ByteSizeValue; PQ OR+org/elasticsearch/common/unit/ByteSizeValueTbytes()J VW UX directory%()Lorg/apache/lucene/store/Directory; Z[ \!org/apache/lucene/store/IOContext^READONCE#Lorg/apache/lucene/store/IOContext; `a _b!org/apache/lucene/store/Directoryd openInput[(Ljava/lang/String;Lorg/apache/lucene/store/IOContext;)Lorg/apache/lucene/store/IndexInput; fg ehcompress()Z jk Ol3org/elasticsearch/common/compress/CompressorFactoryn isCompressed'(Lorg/apache/lucene/store/IndexInput;)Z pq or"org/apache/lucene/store/IndexInputt/org/elasticsearch/index/store/StoreFileMetaDatav[Bxlength zW u{ val$shard:Lorg/elasticsearch/index/shard/service/InternalIndexShard; }~ 8org/elasticsearch/index/shard/service/InternalIndexShardstate1()Lorg/elasticsearch/index/shard/IndexShardState; -org/elasticsearch/index/shard/IndexShardStateCLOSED/Lorg/elasticsearch/index/shard/IndexShardState; 7org/elasticsearch/index/shard/IndexShardClosedExceptionshardId)()Lorg/elasticsearch/index/shard/ShardId; *(Lorg/elasticsearch/index/shard/ShardId;)V % getFilePointer W u rateLimiter'()Lorg/apache/lucene/store/RateLimiter; O#org/apache/lucene/store/RateLimiterpause(J)J  readBytes([BIIZ)V u)org/elasticsearch/common/bytes/BytesArray([BII)V %  access$700c(Lorg/elasticsearch/indices/recovery/RecoverySource;)Lorg/elasticsearch/transport/TransportService; I val$request9Lorg/elasticsearch/indices/recovery/StartRecoveryRequest; 7org/elasticsearch/indices/recovery/StartRecoveryRequest targetNode0()Lorg/elasticsearch/cluster/node/DiscoveryNode; (internal:index/shard/recovery/file_chunk;org/elasticsearch/indices/recovery/RecoveryFileChunkRequest recoveryId W ,org/elasticsearch/transport/TransportService,org/elasticsearch/cluster/node/DiscoveryNodejava/lang/String%org/elasticsearch/index/shard/ShardId(JLorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/index/store/StoreFileMetaData;JLorg/elasticsearch/common/bytes/BytesReference;Z)V % options7()Lorg/elasticsearch/transport/TransportRequestOptions;  withCompress8(Z)Lorg/elasticsearch/transport/TransportRequestOptions; RECOVERY:Lorg/elasticsearch/transport/TransportRequestOptions$Type; withTypeq(Lorg/elasticsearch/transport/TransportRequestOptions$Type;)Lorg/elasticsearch/transport/TransportRequestOptions;  access$600^(Lorg/elasticsearch/indices/recovery/RecoverySource;)Lorg/elasticsearch/common/unit/TimeValue; I withTimeout`(Lorg/elasticsearch/common/unit/TimeValue;)Lorg/elasticsearch/transport/TransportRequestOptions; 9org/elasticsearch/transport/EmptyTransportResponseHandler INSTANCE_SAME;Lorg/elasticsearch/transport/EmptyTransportResponseHandler;  submitRequest(Lorg/elasticsearch/cluster/node/DiscoveryNode;Ljava/lang/String;Lorg/elasticsearch/transport/TransportRequest;Lorg/elasticsearch/transport/TransportRequestOptions;Lorg/elasticsearch/transport/TransportResponseHandler;)Lorg/elasticsearch/transport/TransportFuture; +org/elasticsearch/transport/TransportFuturetxGet()Ljava/lang/Object; java/io/Closeableorg/apache/lucene/util/IOUtilscloseWhileHandlingException([Ljava/io/Closeable;)V decRef 5 #java/util/concurrent/CountDownLatch countDown 5 -org/apache/lucene/index/CorruptIndexException"org/elasticsearch/ExceptionsHelperunwrap=(Ljava/lang/Throwable;Ljava/lang/Class;)Ljava/lang/Throwable;    checkIntegrity4(Lorg/elasticsearch/index/store/StoreFileMetaData;)Z    access$900`(Lorg/elasticsearch/indices/recovery/RecoverySource;)Lorg/elasticsearch/common/logging/ESLogger;  I/{} Corrupted file detected {} checksum mismatch)org/elasticsearch/common/logging/ESLoggerwarn((Ljava/lang/String;[Ljava/lang/Object;)V  +java/util/concurrent/atomic/AtomicReference compareAndSet'(Ljava/lang/Object;Ljava/lang/Object;)Z  ! @ # addSuppressed(Ljava/lang/Throwable;)V %& '4org/elasticsearch/transport/RemoteTransportException)8File corruption occured on recovery but checksums are ok+*(Ljava/lang/String;Ljava/lang/Throwable;)V %- *. *')java/util/concurrent/CopyOnWriteArrayList1add(ILjava/lang/Object;)V 34 25 access$1000 7 I83{} File corruption on recovery {} local checksum OK:=(Ljava/lang/String;Ljava/lang/Throwable;[Ljava/lang/Object;)V < =toReadIpositionJcontent+Lorg/elasticsearch/common/bytes/BytesArray; BUFFER_SIZEbufshouldCompressRequestZlen readCount exception6Lorg/elasticsearch/transport/RemoteTransportException;corruptIndexException/Lorg/apache/lucene/index/CorruptIndexException;eLjava/lang/Throwable; indexInput$Lorg/apache/lucene/store/IndexInput;md1Lorg/elasticsearch/index/store/StoreFileMetaData;CodeLocalVariableTableLineNumberTable StackMapTable SourceFileEnclosingMethod InnerClasses  !"#$%&UV,*+(*,**-,*.*0*2*4*7V ,89W:5UXL**?*,*.CM*(GMSY>:**]*.ciL*(GMm6+s6+|7 7*(Y*(a e6 +7 *(GM*(GM X+ Y :  a7*(G*(Y*(*(,  ̸Բض*(GW Y+S***4:*4N- Y:**,H*(GY*(SY,S*0"f*0$-(U*Y,/:-0*26*(G9;Y*(SY,S> *2-6Y+S***4:*40:Y+S***4:*4 cjttvtX<AHRRTRXa6anuacaV?@ AB rCD '1E@,,FxM GH]IB`JB9KLMNOP89QRzSTW5 ',>MTW]`hxUXcjqt*-6AHOR^anu|XWuwy)@+^ uwy w uwy w,uw[< B<`<H[< B<uw<< uwYZ [" @