1# W  W W  ! "# W$%  W& W' W( W)*  0+ W, 0- . /0 /12 - 34 W56 7 8 9:; 3< = > ?@ ?AB CD ?EFG ,H IJ 0K LMN WO WP 3QR 3S T UV WW X WY Z[\] ?^ W_ `a `bc de Zf Zg Zh i. ,j Zkl Nm iX in ,o Wpq WI Wr s tu ?v Ww -x + y Uz {| {} W~  j   o o  o sH s s- o , ? ~I }  3 3 - W o- 3 "     C C CFileTxnIterator InnerClassesPositionInputStreamLOGLorg/slf4j/Logger; preAllocSizeJ TXNLOG_MAGICIVERSION ConstantValuefsyncWarningThresholdMS lastZxidSeen logStreamLjava/io/BufferedOutputStream;oaLorg/apache/jute/OutputArchive;fosLjava/io/FileOutputStream;logDirLjava/io/File; forceSyncZdbIdstreamsToFlushLjava/util/LinkedList; Signature2Ljava/util/LinkedList; currentSize logFileWrite(Ljava/io/File;)VCodeLineNumberTableLocalVariableTablethis4Lorg/apache/zookeeper/server/persistence/FileTxnLog;setPreallocSize(J)VsizemakeChecksumAlgorithm()Ljava/util/zip/Checksum;rollLog()V Exceptionscloselogi$Ljava/util/Iterator;append?(Lorg/apache/zookeeper/txn/TxnHeader;Lorg/apache/jute/Record;)Zfhdr4Lorg/apache/zookeeper/server/persistence/FileHeader;buf[BcrcLjava/util/zip/Checksum;hdr$Lorg/apache/zookeeper/txn/TxnHeader;txnLorg/apache/jute/Record;padFile(Ljava/io/FileOutputStream;)Vout getLogFiles!([Ljava/io/File;J)[Ljava/io/File;fzxidf logDirList[Ljava/io/File; snapshotZxidfilesLjava/util/List;logZxidvLocalVariableTypeTable Ljava/util/List;getLastLoggedZxid()JeLjava/io/IOException;maxLogzxiditr TxnIterator!Ljava/lang/NumberFormatException;Ljava/lang/String; SourceFileFileTxnLog.java zookeeper.forceSyncyes no  java/util/LinkedList java/util/zip/Adler32    java/io/FileOutputStream  java/lang/StringBuilder Current zxid   is <=  for     Creating new log file: log.   java/io/Filelog.  java/io/BufferedOutputStream  2org/apache/zookeeper/server/persistence/FileHeader  fileheader      java/io/IOException'Faulty serialization for header and txn     txnEntryCRC      java/util/ArrayList    2org/apache/zookeeper/server/persistence/FileTxnLog  Unexpected exception  Error closing file iterator     !fsync-ing the write ahead log in   took 2ms which will adversely effect operation latency. 'See the ZooKeeper troubleshooting guide  Borg/apache/zookeeper/server/persistence/FileTxnLog$FileTxnIterator   java/io/RandomAccessFile rw     Unable to truncate {}  java/io/BufferedInputStreamjava/io/FileInputStream    Ignoring exception during close Unsupported Format. ZKLG    zookeeper.preAllocSize  java/lang/NumberFormatException& is not a valid value for preAllocSizefsync.warningthresholdms  ! "java/lang/Object.org/apache/zookeeper/server/persistence/TxnLogForg/apache/zookeeper/server/persistence/FileTxnLog$PositionInputStream:org/apache/zookeeper/server/persistence/TxnLog$TxnIteratorjava/lang/System getProperty8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;java/lang/Stringequals(Ljava/lang/Object;)Zflushiterator()Ljava/util/Iterator;java/util/IteratorhasNextnext()Ljava/lang/Object;"org/apache/zookeeper/txn/TxnHeadergetZxid-(Ljava/lang/String;)Ljava/lang/StringBuilder;(J)Ljava/lang/StringBuilder;getType()I(I)Ljava/lang/StringBuilder;toString()Ljava/lang/String;org/slf4j/Loggerwarn(Ljava/lang/String;)V isInfoEnabledjava/lang/Long toHexString(J)Ljava/lang/String;info#(Ljava/io/File;Ljava/lang/String;)V(Ljava/io/OutputStream;)V#org/apache/jute/BinaryOutputArchive getArchive=(Ljava/io/OutputStream;)Lorg/apache/jute/BinaryOutputArchive;(IIJ)V serialize4(Lorg/apache/jute/OutputArchive;Ljava/lang/String;)V getChannel!()Ljava/nio/channels/FileChannel;java/nio/channels/FileChannelpositionadd,org/apache/zookeeper/server/persistence/UtilmarshallTxnEntry@(Lorg/apache/zookeeper/txn/TxnHeader;Lorg/apache/jute/Record;)[Bjava/util/zip/Checksumupdate([BII)VgetValueorg/apache/jute/OutputArchive writeLong(JLjava/lang/String;)V writeTxnBytes$(Lorg/apache/jute/OutputArchive;[B)V padLogFile(Ljava/io/FileOutputStream;JJ)J sortDataDir4([Ljava/io/File;Ljava/lang/String;Z)Ljava/util/List;java/util/ListgetNamegetZxidFromName'(Ljava/lang/String;Ljava/lang/String;)J(I)VtoArray(([Ljava/lang/Object;)[Ljava/lang/Object; listFiles()[Ljava/io/File; getHeader&()Lorg/apache/zookeeper/txn/TxnHeader;*(Ljava/lang/String;Ljava/lang/Throwable;)VnanoTimeforce(Z)Vjava/util/concurrent/TimeUnit NANOSECONDSLjava/util/concurrent/TimeUnit;toMillis(J)Jjava/lang/Thread currentThread()Ljava/lang/Thread; removeFirst(Ljava/io/File;J)V inputStream getPositionlogFile setLength access$000G(Lorg/apache/zookeeper/server/persistence/FileTxnLog$FileTxnIterator;)Zdelete'(Ljava/lang/String;Ljava/lang/Object;)V(Ljava/io/InputStream;)V"org/apache/jute/BinaryInputArchive;(Ljava/io/InputStream;)Lorg/apache/jute/BinaryInputArchive; deserialize3(Lorg/apache/jute/InputArchive;Ljava/lang/String;)Vjava/io/InputStreamgetDbidgetBytes()[Bjava/nio/ByteBufferwrap([B)Ljava/nio/ByteBuffer;getIntorg/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;&(Ljava/lang/String;)Ljava/lang/String; parseLong(Ljava/lang/String;)JgetLong%(Ljava/lang/String;J)Ljava/lang/Long; longValue!W@@@<****  * Y **+"v x{&}16;<< 3  2Y !S**** ?!1* ** L++M,)-0 )1?!U+R+*9Y +!" *!# +$%&'*($Y) +* &+*,Y*Y- +* &.*Y*/*0Y*1**23Y4*56N-*78***9:;* *N-- ?Y@A*B:--C*DEF*-GfFMXy &,7IQS>+@,'UUU?H*+*;H; ?  *IJN 7-K:4,:LIM77ȻNYO:-K:3,:LIM7  PW,QRF )5<?GKNX v   p 5)"; v!`: XQXQh *S TL+++d2LIMUA 7:WY*X: Y:Z[:7"):\]:  : *^ ,ag?,d{gx{{{N &) ,"9#A%K&N'W(^)a*d.g*i+u,x.{-/RW9(i  &j)g,dt++_M`,] ?35 8 67:  !/* ** L+q+M,a* YbB,9cdb!ee7f7Yg hi j !k l &'* m* n:ABD)E-F4G8I@KMMVNUVWY48RM=)aw?A oY*pb ? rNoY*pN-q:r7sY-tuv:wx-y-tz{-t|:: *-^ \__d_:kmnoq+r2s7t>uHvYy\{_zp|>D=+.rrp? TL}Y~Y*L+M3YN-,7-:::++:],//4/9AD?2 &/9ADFR4  F T R  ?~,oY* pL+tM+, ?YA, ' , ?/*  Z`4WK*-*iLY*  &'f'25. ]_hj#k'm2p5n6oQr_s6#<oW W