3;org/elasticsearch/index/translog/fs/BufferingFsTranslogFilejava/lang/Object2org/elasticsearch/index/translog/fs/FsTranslogFileBufferingFsTranslogFile.javaOorg/elasticsearch/index/translog/fs/BufferingFsTranslogFile$WrapperOutputStreamWrapperOutputStream2org/elasticsearch/index/translog/Translog$Location )org/elasticsearch/index/translog/Translog Location;java/util/concurrent/locks/ReentrantReadWriteLock$WriteLock1java/util/concurrent/locks/ReentrantReadWriteLock WriteLockidJshardId'Lorg/elasticsearch/index/shard/ShardId;raf2Lorg/elasticsearch/index/translog/fs/RafReference;translogStream1Lorg/elasticsearch/index/translog/TranslogStream; headerSizeIrwl*Ljava/util/concurrent/locks/ReadWriteLock;closed+Ljava/util/concurrent/atomic/AtomicBoolean;operationCounter lastPositionlastWrittenPositionlastSyncPositionbuffer[B bufferCountbufferOsQLorg/elasticsearch/index/translog/fs/BufferingFsTranslogFile$WrapperOutputStream;$assertionsDisabledZ^(Lorg/elasticsearch/index/shard/ShardId;JLorg/elasticsearch/index/translog/fs/RafReference;I)Vjava/io/IOException0()V .2 3 3  6)java/util/concurrent/atomic/AtomicBoolean8 93 !" ; & =@(Lorg/elasticsearch/index/translog/fs/BufferingFsTranslogFile;)V .? @ *+ B  D  F  H '( J0org/elasticsearch/index/translog/fs/RafReferenceL()Ljava/io/RandomAccessFile; N MOjava/io/RandomAccessFileQ setLength(J)V ST RUfile()Ljava/io/File; WX MY0org/elasticsearch/index/translog/TranslogStreams[translogStreamForA(Ljava/io/File;)Lorg/elasticsearch/index/translog/TranslogStream; ]^ \_  achannel!()Ljava/nio/channels/FileChannel; cd Me/org/elasticsearch/index/translog/TranslogStreamg writeHeader"(Ljava/nio/channels/FileChannel;)I ij hk  m $ o % qthis=Lorg/elasticsearch/index/translog/fs/BufferingFsTranslogFile; bufferSize()JestimatedNumberOfOperations()I # ytranslogSizeInBytesadde(Lorg/elasticsearch/common/bytes/BytesReference;)Lorg/elasticsearch/index/translog/Translog$Location;(java/util/concurrent/locks/ReadWriteLock~ writeLock#()Ljava/util/concurrent/locks/Lock; java/util/concurrent/locks/Locklock 2 -org/elasticsearch/common/bytes/BytesReferencelength x  flushBuffer 2 writeTo+(Ljava/nio/channels/GatheringByteChannel;)V (JJI)V . unlock 2 ) (Ljava/io/OutputStream;)V java/lang/Throwablepositiondata/Lorg/elasticsearch/common/bytes/BytesReference; ,- isHeldByCurrentThread()Z java/lang/AssertionError 3$org/elasticsearch/common/io/ChannelswriteToChannel.([BIILjava/nio/channels/WritableByteChannel;)V read8(Lorg/elasticsearch/index/translog/Translog$Location;)[BreadLock translogLocation  size  java/lang/System arraycopy*(Ljava/lang/Object;ILjava/lang/Object;II)V readFromFileChannel%(Ljava/nio/channels/FileChannel;JI)[B location4Lorg/elasticsearch/index/translog/Translog$Location;snapshot9()Lorg/elasticsearch/index/translog/fs/FsChannelSnapshot;2org/elasticsearch/index/translog/TranslogExceptionjava/lang/ExceptionincreaseRefCount M5org/elasticsearch/index/translog/fs/FsChannelSnapshot8(JLorg/elasticsearch/index/translog/fs/RafReference;JI)V . seekTo T decreaseRefCount(Z)V M!exception while creating snapshotQ(Lorg/elasticsearch/index/shard/ShardId;Ljava/lang/String;Ljava/lang/Throwable;)V . 7Lorg/elasticsearch/index/translog/fs/FsChannelSnapshot;eLjava/lang/Exception;success syncNeeded getStream3()Lorg/elasticsearch/index/translog/TranslogStream;sync java/nio/channels/FileChannelforce close compareAndSet(ZZ)Z 9 2 failed to sync on closedeletereuse7(Lorg/elasticsearch/index/translog/fs/FsTranslogFile;)Vfailed to flushLjava/io/IOException;other4Lorg/elasticsearch/index/translog/fs/FsTranslogFile;updateBufferSize(I)V access$000A(Lorg/elasticsearch/index/translog/fs/BufferingFsTranslogFile;)[Bx0 access$108@(Lorg/elasticsearch/index/translog/fs/BufferingFsTranslogFile;)I access$100 access$112A(Lorg/elasticsearch/index/translog/fs/BufferingFsTranslogFile;I)Ix1java/lang/ClassdesiredAssertionStatus  CodeLocalVariableTableLineNumberTable Exceptions StackMapTable SourceFile InnerClasses! !"B#B$B%B&'()*+,-./%*4*Y57*9Y:<* >* Y*AC*+E* G*I*KP V**IZ`b**bfln*Yp*nap*Yr*nar*Y>*na>4stuB<./6:+=0>5?;@CALBZClDzEFG1v/*G stJwx/*z stN{v/*r stR|}*7*Yz`z*pA+*KY*+*If*Yr+ar*Yp+ap Y*G +:*7+*K*d*+*C*Yp+ap Y*G +:*7:*7p stBWYZ[+\/_<`La\bpkdeghik>12N*7 Y*)*K**If*Yr*ar* Nstp q't:vHwMy ,1*7+*r3+M*K+*re,+,N*7-*7:*7*If++Ȱ:[[][ !)(st& }!8:X[n JP1*Iә<*7*Y*G*I*r*zM,*n<,N*7 *I-MY*E,:*7: *IC_Co_qo Q_*6)` -stF 6?ACQU_`o=]OR G*p*> st@/*b st2P**7***p>*7L*7+*If"3343 Pst* "03DOj1?*<*MY*E,*IߧN*I- (3343 ?st?-. (03>  JJ Y+*7**+KK*7%MY*E,N*7-%61%G6HG 7YstY. %367GX m1Pe*7*K*7**K*7%MY*E,N*7-B1&1B1S&1SBTS Cesteu. &*1?BCSd &[1P/*K  t&  6 *YZ`   t&  /*  t& @ *Y`Z  t &24& @