38org/elasticsearch/index/translog/fs/SimpleFsTranslogFilejava/lang/Object2org/elasticsearch/index/translog/fs/FsTranslogFileSimpleFsTranslogFile.java2org/elasticsearch/index/translog/Translog$Location)org/elasticsearch/index/translog/Translog LocationidJshardId'Lorg/elasticsearch/index/shard/ShardId;raf2Lorg/elasticsearch/index/translog/fs/RafReference;closed+Ljava/util/concurrent/atomic/AtomicBoolean;rwl*Ljava/util/concurrent/locks/ReadWriteLock;translogStream1Lorg/elasticsearch/index/translog/TranslogStream; headerSizeIoperationCounter lastPositionlastWrittenPositionlastSyncPosition](Lorg/elasticsearch/index/shard/ShardId;JLorg/elasticsearch/index/translog/fs/RafReference;)Vjava/io/IOException!()V # $)java/util/concurrent/atomic/AtomicBoolean& '$  )1java/util/concurrent/locks/ReentrantReadWriteLock+ ,$  .  0  2  4  6  8  :  <0org/elasticsearch/index/translog/fs/RafReference>()Ljava/io/RandomAccessFile; @ ?Ajava/io/RandomAccessFileC setLength(J)V EF DGfile()Ljava/io/File; IJ ?K0org/elasticsearch/index/translog/TranslogStreamsMtranslogStreamForA(Ljava/io/File;)Lorg/elasticsearch/index/translog/TranslogStream; OP NQ  Schannel!()Ljava/nio/channels/FileChannel; UV ?W/org/elasticsearch/index/translog/TranslogStreamY writeHeader"(Ljava/nio/channels/FileChannel;)I [\ Z]  _this:Lorg/elasticsearch/index/translog/fs/SimpleFsTranslogFile;()JestimatedNumberOfOperations()ItranslogSizeInBytesadde(Lorg/elasticsearch/common/bytes/BytesReference;)Lorg/elasticsearch/index/translog/Translog$Location;(java/util/concurrent/locks/ReadWriteLocki writeLock#()Ljava/util/concurrent/locks/Lock; kl jmjava/util/concurrent/locks/Lockolock q# pr-org/elasticsearch/common/bytes/BytesReferencetwriteTo+(Ljava/nio/channels/GatheringByteChannel;)V vw uxlength ze u{(JJI)V } ~unlock # pjava/lang/Throwablepositiondata/Lorg/elasticsearch/common/bytes/BytesReference;read8(Lorg/elasticsearch/index/translog/Translog$Location;)[BreadLock l jtranslogLocation  size  $org/elasticsearch/common/io/ChannelsreadFromFileChannel%(Ljava/nio/channels/FileChannel;JI)[B location4Lorg/elasticsearch/index/translog/Translog$Location;close(Z)Vjava/lang/Exception compareAndSet(ZZ)Z 'sync # 2org/elasticsearch/index/translog/TranslogExceptionfailed to sync on closeQ(Lorg/elasticsearch/index/shard/ShardId;Ljava/lang/String;Ljava/lang/Throwable;)V  decreaseRefCount ?eLjava/lang/Exception;deleteZsnapshot9()Lorg/elasticsearch/index/translog/fs/FsChannelSnapshot;java/io/FileNotFoundExceptionincreaseRefCount()Z ?5org/elasticsearch/index/translog/fs/FsChannelSnapshot8(JLorg/elasticsearch/index/translog/fs/RafReference;JI)V  seekTo F failed to create snapshot7Lorg/elasticsearch/index/translog/fs/FsChannelSnapshot;Ljava/io/FileNotFoundException;success syncNeeded getStream3()Lorg/elasticsearch/index/translog/TranslogStream; java/nio/channels/FileChannelforce reuse7(Lorg/elasticsearch/index/translog/fs/FsTranslogFile;)Vother4Lorg/elasticsearch/index/translog/fs/FsTranslogFile;updateBufferSize(I)V bufferSizeCodeLocalVariableTableLineNumberTable Exceptions StackMapTable SourceFile InnerClasses!  BBBB  *%*'Y(**,Y-/*1* 3* 5* 7*+9* ;*=B H**=LRT**TX^`*Y3*`a3*Y5*`a5*Y7*`a7*ab F5)*.0$1)3.63788>9G:U;g<u=>?" c/*; abBde/*1 abFfc/*5 abJgh*/ns*3A+*=Xy**3+|a3**5+|a5**1`1 Y*; +|:*/n:*/n^ooqo \ab"NPQ R0S@TJU^Wo"B*/s*=X++M*/,N*/-!1121BabB\^!`q"?***MY*9,*=N*=- (3343 ?ab?. e f iknlm(q0r3q>s  JJ *=<*/nsY*;*=*5*1M,*`<,N*/n *=-:*/nMY*9,: *=?[[][ Mn[nn M~[~*2)o abBy z |~2;=?MQ[no~=YRO G*5*7 ab@/*T ab#L*͚*/ns**57*=X*/nL*/n+)::;: Lab& )7:Kq"5ab5ab