3F#org/elasticsearch/index/store/Store9org/elasticsearch/index/shard/AbstractIndexShardComponent/org/elasticsearch/index/CloseableIndexComponentjava/io/Closeable Store.java7org/elasticsearch/index/store/Store$VerifyingIndexInput VerifyingIndexInput8org/elasticsearch/index/store/Store$VerifyingIndexOutput VerifyingIndexOutput3org/elasticsearch/index/store/Store$LegacyChecksumsLegacyChecksums0org/elasticsearch/index/store/Store$RecoveryDiff RecoveryDiff4org/elasticsearch/index/store/Store$MetadataSnapshotMetadataSnapshot2org/elasticsearch/index/store/Store$StoreDirectoryStoreDirectoryCODECLjava/lang/String;storeVERSION_STACK_TRACEI VERSION_STARTVERSION CORRUPTED corrupted_'isClosed+Ljava/util/concurrent/atomic/AtomicBoolean;refCount+Ljava/util/concurrent/atomic/AtomicInteger; codecService,Lorg/elasticsearch/index/codec/CodecService;directoryService0Lorg/elasticsearch/index/store/DirectoryService; directory4Lorg/elasticsearch/index/store/Store$StoreDirectory;distributorDirectory4Lorg/elasticsearch/index/store/DistributorDirectory;CHECKSUMS_PREFIX _checksums-6$assertionsDisabledZ(Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/index/codec/CodecService;Lorg/elasticsearch/index/store/DirectoryService;Lorg/elasticsearch/index/store/distributor/Distributor;)Vjava/io/IOException<(Lorg/elasticsearch/common/inject/Inject;0Lorg/elasticsearch/index/settings/IndexSettings;V(Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/common/settings/Settings;)V :@ A)java/util/concurrent/atomic/AtomicBooleanC(Z)V :E DF )* H)java/util/concurrent/atomic/AtomicIntegerJ(I)V :L KM +, O -. Q /0 S2org/elasticsearch/index/store/DistributorDirectoryU:(Lorg/elasticsearch/index/store/distributor/Distributor;)V :W VX 34 ZK(Lorg/elasticsearch/index/store/Store;Lorg/apache/lucene/store/Directory;)V :\ ] 12 _this%Lorg/elasticsearch/index/store/Store;shardId'Lorg/elasticsearch/index/shard/ShardId; indexSettings,Lorg/elasticsearch/common/settings/Settings; distributor7Lorg/elasticsearch/index/store/distributor/Distributor;%()Lorg/apache/lucene/store/Directory; ensureOpen()V jk lreadLastCommittedSegmentsInfo(()Lorg/apache/lucene/index/SegmentInfos; 1i preadSegmentsInfop(Lorg/apache/lucene/index/IndexCommit;Lorg/apache/lucene/store/Directory;)Lorg/apache/lucene/index/SegmentInfos; rs tjava/io/EOFExceptionvjava/lang/Exceptionx&org/elasticsearch/common/lucene/LucenezreadSegmentInfosK(Lorg/apache/lucene/store/Directory;)Lorg/apache/lucene/index/SegmentInfos; |} {~ |s {$org/apache/lucene/index/SegmentInfos-org/apache/lucene/index/CorruptIndexException)Read past EOF while reading segment infos*(Ljava/lang/String;Ljava/lang/Throwable;)V : 4Hit unexpected exception while reading segment infoseofLjava/io/EOFException; exceptionLjava/io/IOException;exLjava/lang/Exception;commit%Lorg/apache/lucene/index/IndexCommit;#Lorg/apache/lucene/store/Directory;get()I K.org/apache/lucene/store/AlreadyClosedExceptionStore is already closed(Ljava/lang/String;)V : getMetadataOrEmpty8()Lorg/elasticsearch/index/store/Store$MetadataSnapshot;.org/apache/lucene/index/IndexNotFoundExceptionjava/io/FileNotFoundException!java/nio/file/NoSuchFileException getMetadata](Lorg/apache/lucene/index/IndexCommit;)Lorg/elasticsearch/index/store/Store$MetadataSnapshot; logger+Lorg/elasticsearch/common/logging/ESLogger; ;Failed to open / find files while reading metadata snapshotjava/lang/Object)org/elasticsearch/common/logging/ESLoggerinfo((Ljava/lang/String;[Ljava/lang/Object;)V EMPTY6Lorg/elasticsearch/index/store/Store$MetadataSnapshot; 0Lorg/apache/lucene/index/IndexNotFoundException;failIfCorrupted k v(Lorg/apache/lucene/index/IndexCommit;Lorg/apache/lucene/store/Directory;Lorg/elasticsearch/common/logging/ESLogger;)V : markStoreCorrupted2(Lorg/apache/lucene/index/CorruptIndexException;)V /Lorg/apache/lucene/index/CorruptIndexException; deleteContentlistAll()[Ljava/lang/String; V[Ljava/lang/String; deleteFile Vjava/lang/Stringefilearr$len$i$files lastExceptionstats,()Lorg/elasticsearch/index/store/StoreStats;(org/elasticsearch/index/store/StoreStats+org/elasticsearch/common/lucene/Directories estimateSize&(Lorg/apache/lucene/store/Directory;)J .org/elasticsearch/index/store/DirectoryServicethrottleTimeInNanos()J (JJ)V :  renameFile'(Ljava/lang/String;Ljava/lang/String;)VW(Lorg/elasticsearch/index/store/DirectoryService;Ljava/lang/String;Ljava/lang/String;)V VfromtosuggestUseCompoundFile()ZincRef tryIncRef java/lang/StringBuilder :k @Store is already closed can't increment refCount current count [append-(Ljava/lang/String;)Ljava/lang/StringBuilder;  (I)Ljava/lang/StringBuilder;   ] toString()Ljava/lang/String;    compareAndSet(II)Z  KidecRefdecrementAndGet  K 89 java/lang/AssertionError  closeInternal k  close(ZZ)Z # D$ k & access$0007(Lorg/elasticsearch/index/store/Store$StoreDirectory;)V () *failed to close directory,debug=(Ljava/lang/String;Ljava/lang/Throwable;[Ljava/lang/Object;)V ./ 0readMetadataSnapshotr([Ljava/io/File;Lorg/elasticsearch/common/logging/ESLogger;)Lorg/elasticsearch/index/store/Store$MetadataSnapshot;!org/apache/lucene/store/Directory4$[Lorg/apache/lucene/store/Directory;6)org/apache/lucene/store/SimpleFSDirectory8(Ljava/io/File;)V :: 9;'([Lorg/apache/lucene/store/Directory;)V := V>%org/elasticsearch/index/shard/ShardId@B(Ljava/lang/String;I)V :D AEM(Lorg/apache/lucene/store/Directory;Lorg/elasticsearch/index/shard/ShardId;)V G Horg/apache/lucene/util/IOUtilsJ([Ljava/io/Closeable;)V "L KMjava/lang/ThrowableOdirindexLocations[Ljava/io/File;dirscreateVerifyingOutput(Ljava/lang/String;Lorg/apache/lucene/store/IOContext;Lorg/elasticsearch/index/store/StoreFileMetaData;)Lorg/apache/lucene/store/IndexOutput;/org/elasticsearch/index/store/StoreFileMetaDataWhasLegacyChecksum Y XZchecksum \ X]create legacy output for {}_ . a createOutput\(Ljava/lang/String;Lorg/apache/lucene/store/IOContext;)Lorg/apache/lucene/store/IndexOutput; cd 5e writtenBy"()Lorg/apache/lucene/util/Version; gh Xiorg/apache/lucene/util/Versionk LUCENE_48 Lorg/apache/lucene/util/Version; mn lo onOrAfter#(Lorg/apache/lucene/util/Version;)Z qr lsY(Lorg/elasticsearch/index/store/StoreFileMetaData;Lorg/apache/lucene/store/IndexOutput;)V :u vfilenamecontext#Lorg/apache/lucene/store/IOContext;metadata1Lorg/elasticsearch/index/store/StoreFileMetaData;verify((Lorg/apache/lucene/store/IndexOutput;)V }k output%Lorg/apache/lucene/store/IndexOutput;openVerifyingInput(Ljava/lang/String;Lorg/apache/lucene/store/IOContext;Lorg/elasticsearch/index/store/StoreFileMetaData;)Lorg/apache/lucene/store/IndexInput;open legacy input for {} openInput[(Ljava/lang/String;Lorg/apache/lucene/store/IOContext;)Lorg/apache/lucene/store/IndexInput;  5'(Lorg/apache/lucene/store/IndexInput;)V :  input$Lorg/apache/lucene/store/IndexInput;checkIntegrity4(Lorg/elasticsearch/index/store/StoreFileMetaData;)Zname  X!org/apache/lucene/store/IOContextREADONCE z "org/apache/lucene/codecs/CodecUtilchecksumEntireFile'(Lorg/apache/lucene/store/IndexInput;)J  "org/apache/lucene/store/IndexInput "k  addSuppressed(Ljava/lang/Throwable;)V  Px2Ljava/lang/Throwable;mdisMarkedCorrupted 5 startsWith(Ljava/lang/String;)Z   cd java/util/ArrayList java/util/ListopenChecksumInputc(Ljava/lang/String;Lorg/apache/lucene/store/IOContext;)Lorg/apache/lucene/store/ChecksumIndexInput;  5 checkHeader:(Lorg/apache/lucene/store/DataInput;Ljava/lang/String;II)I  *org/apache/lucene/store/ChecksumIndexInput readString   A  Preexisting corrupted index [ ] caused by: java/lang/System lineSeparator   add(Ljava/lang/Object;)Z   checkFooter/(Lorg/apache/lucene/store/ChecksumIndexInput;)J   isEmpty  "org/elasticsearch/ExceptionsHelperrethrowAndSuppress(Ljava/util/List;)V  versionmsgbuilderLjava/lang/StringBuilder;,Lorg/apache/lucene/store/ChecksumIndexInput;ALjava/util/List;Ljava/util/List; isChecksum.cksendsWith  digestToString(J)Ljava/lang/String;java/lang/Long(JI)Ljava/lang/String;   digestJ deleteQuiet([Ljava/lang/String;)V 5   org/elasticsearch/common/StringsrandomBase64UUID  DEFAULT z  writeHeader:(Lorg/apache/lucene/store/DataOutput;Ljava/lang/String;I)V   detailedMessage+(Ljava/lang/Throwable;ZI)Ljava/lang/String;    #org/apache/lucene/store/IndexOutput writeString   stackTrace)(Ljava/lang/Throwable;)Ljava/lang/String;   writeFooter ~  Can't mark store as corruptedwarn / java/util/Collections! singleton#(Ljava/lang/Object;)Ljava/util/Set; #$ "%sync(Ljava/util/Collection;)V '( 5)uuid access$100S(Lorg/elasticsearch/index/store/Store;)Lorg/elasticsearch/index/codec/CodecService;x0 access$200x1 access$300[(Lorg/elasticsearch/index/store/Store;)Lorg/elasticsearch/index/store/DistributorDirectory; access$400[(Lorg/elasticsearch/index/store/Store;)Lorg/elasticsearch/index/store/Store$StoreDirectory;java/lang/Class6desiredAssertionStatus 8 79 ConstantValueCodeLocalVariableTableLineNumberTable ExceptionsRuntimeVisibleAnnotations"RuntimeVisibleParameterAnnotations StackMapTableLocalVariableTypeTable SourceFile InnerClasses! ; !;"#!;$%!;"&;()*+,-./012345;789#:;<G*+,B*DYGI*KYNP*-R*T*VYY[*Y**[^`=>GabGcdGefG-.G/0Ggh>"^UV_#`)a6bFc?=@>A?1i<7 *m*`=  ab> ghno<3 *qu=  ab>p?= rs<,* +*+MY,M,MY,w= y=4 ! ,,1>yz|}~ !B D@wK=By?=jk<P*P Y= ab> B<*LL*  =  ab> B FC=?=<0*= ab>?=<!*m*»Y+*[*ŰM*,,= !ab!>BY?=k<PG*m*[LM+N-66%-2:*[ԧ ::M,,$-0$-0$-5==\ 27$0,!)!Gab ;9>: $-0257:@DFB====D=?=<J*mY*`*T= ab> ?=<X*m*[*T+,= ab>?=<,= ab>k<k0*+YY*P  = 0ab>/B/<y!*P<*P`=!!ab>   B k<t#*P< Y*!=#ab!>"B"k<L*I%*'= ab> !#Bk<v*`+L*-+1 == ab>'* ( )+BJ= 23<ru*5M>*,9Y*2F3565!8*99:E@L;M@QAT=U>a@eAh@qBB7jG=SP?=UV<n-[ -^!*`Y+Sb*q+,f-j Y-jpt YY-*q+,fw=*nabnxnyzn{|>NO"P,RAS\TB?= }~<J* *= >XY[B?=<m-[ -^!*Y+Sb*q+,-j Y-jpt Y Y*q+,=*mabmxmyzm{|>^_"`,bAc\dB?= }<J* * = >hikB?=<~+jx+jptk*q+MN,X,K-,@:-5,.:N:,-,:-,M269P%*KP%*S]adPKUSvy==>;f#Sz~ab~|>* no%p*qKoSqvsyqzr|uBO 9XPP FPGPXPPP XB=<4*m*qL+M,>6,2:(=> $!!!4ab (>y} ~ *,~2B?=k<B*m*`*I= ab>?=G<*MYN,:662:(*:: 6 : Y+Ʒ:  ɶW ˶W  W  жW ŶW-Y ѹWXU ڧH:   <ڧ4:  :  : ! ڧ:  --P>P>P=If! P_ ]R  ;&!!1cd  C   >^ &0>IP]ft| B 5A} 5AP* 5APP GPHP5APPP 5A ?=<O*7 *= >(B@ <1$= >/<)+M,>6,2:*q: P=H"&#! !)ab)> "(B(P<*m*Y(M*q,fN:- -+-+--P-D:8-1:::--:-N*- *q,&*VZ]P0MpP0MyPp{y!==H_-q!+ab>B !0 7!A"I#M$py$&$%')B[ ]PP FPHPPPP B= ?=,-</*R= .b>M/s<:*+u=.0>M?=12</*[= .b>M34</*`= .b>M5k<4:>MB @D E2