3.org/elasticsearch/index/translog/fs/FsTranslog9org/elasticsearch/index/shard/AbstractIndexShardComponent)org/elasticsearch/index/translog/TranslogFsTranslog.javaorg/elasticsearch/index/settings/IndexSettingsService$Listener5org/elasticsearch/index/settings/IndexSettingsServiceListenerINDEX_TRANSLOG_FS_TYPELjava/lang/String;index.translog.fs.type indexSettingsService7Lorg/elasticsearch/index/settings/IndexSettingsService; bigArrays)Lorg/elasticsearch/common/util/BigArrays;rwl*Ljava/util/concurrent/locks/ReadWriteLock; locations[Ljava/io/File;current4Lorg/elasticsearch/index/translog/fs/FsTranslogFile;transtype9Lorg/elasticsearch/index/translog/fs/FsTranslogFile$Type;syncOnEachOperationZ bufferSizeItransientBufferSize applySettings>Lorg/elasticsearch/index/translog/fs/FsTranslog$ApplySettings;$assertionsDisabled(Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/index/settings/IndexSettingsService;Lorg/elasticsearch/env/NodeEnvironment;Lorg/elasticsearch/common/util/BigArrays;)V(Lorg/elasticsearch/common/inject/Inject;0Lorg/elasticsearch/index/settings/IndexSettings;V(Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/common/settings/Settings;)V 7; <1java/util/concurrent/locks/ReentrantReadWriteLock>()V 7@ ?A &' C /0 E3(Lorg/elasticsearch/index/translog/fs/FsTranslog;)V 7G H 45 J "# L $% N%org/elasticsearch/env/NodeEnvironmentPshardLocations8(Lorg/elasticsearch/index/shard/ShardId;)[Ljava/io/File; RS QT java/io/FileV () X%org/elasticsearch/index/shard/ShardIdZ*org/elasticsearch/common/settings/Settings\'org/elasticsearch/common/util/BigArrays^)transloga#(Ljava/io/File;Ljava/lang/String;)V 7c Wd+org/elasticsearch/common/io/FileSystemUtilsfmkdirs(Ljava/io/File;)Z hi gjcomponentSettings,Lorg/elasticsearch/common/settings/Settings; lm n-BUFFERED q. rname()Ljava/lang/String; tu vget8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; xy ]z fromStringM(Ljava/lang/String;)Lorg/elasticsearch/index/translog/fs/FsTranslogFile$Type; |} ~ -.  buffer_size64k+org/elasticsearch/common/unit/ByteSizeValueparseBytesSizeValueA(Ljava/lang/String;)Lorg/elasticsearch/common/unit/ByteSizeValue; getAsBytesSizen(Ljava/lang/String;Lorg/elasticsearch/common/unit/ByteSizeValue;)Lorg/elasticsearch/common/unit/ByteSizeValue; ]bytes()J 12 transient_buffer_size8k 32  addListenerC(Lorg/elasticsearch/index/settings/IndexSettingsService$Listener;)V ithis0Lorg/elasticsearch/index/translog/fs/FsTranslog;shardId'Lorg/elasticsearch/index/shard/ShardId; indexSettingsnodeEnv'Lorg/elasticsearch/env/NodeEnvironment;d(Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/common/settings/Settings;Ljava/io/File;)VNON_RECYCLING_INSTANCE % _locationLjava/io/File;closeWithDeleteclose(Z)V (org/elasticsearch/ElasticsearchException updateBuffer0(Lorg/elasticsearch/common/unit/ByteSizeValue;)V bytesAsInt()I (java/util/concurrent/locks/ReadWriteLock writeLock#()Ljava/util/concurrent/locks/Lock; java/util/concurrent/locks/Locklock @ *+ updateBufferSize(I)V  ,+ unlock @ java/lang/Throwablecurrent1-Lorg/elasticsearch/common/unit/ByteSizeValue;removeListener  delete()[Ljava/io/File; currentIdid estimatedNumberOfOperations  ramBytesUsedtranslogSizeInBytes clearUnreferencedjava/lang/Exception listFiles WgetName u Wjava/lang/StringBuilder A translog-append-(Ljava/lang/String;)Ljava/lang/StringBuilder; (J)Ljava/lang/StringBuilder; toString u java/lang/Stringequals(Ljava/lang/Object;)Z  ()Z  WeLjava/lang/Exception;filearr$len$i$files newTranslog(J)V2org/elasticsearch/index/translog/TranslogExceptionjava/io/IOException getFreeSpace  W&java/util/concurrent/ThreadLocalRandom*()Ljava/util/concurrent/ThreadLocalRandom; *  nextBoolean   ! #0org/elasticsearch/index/translog/fs/RafReference%(Ljava/io/File;)V 7' &(create(Lorg/elasticsearch/index/shard/ShardId;JLorg/elasticsearch/index/translog/fs/RafReference;I)Lorg/elasticsearch/index/translog/fs/FsTranslogFile; *+ ,"failed to create new translog file.Q(Lorg/elasticsearch/index/shard/ShardId;Ljava/lang/String;Ljava/lang/Throwable;)V 70 1 currentFreeJLjava/io/IOException;newFilesizeoldnewTransientTranslog 60 :java/lang/AssertionError< =AmakeTransientCurrentreuse7(Lorg/elasticsearch/index/translog/fs/FsTranslogFile;)V @A BrevertTransient tmpTransienttranslogForLocationj(Lorg/elasticsearch/index/translog/Translog$Location;)Lorg/elasticsearch/index/translog/fs/FsTranslogFile; translogId H4 I4Lorg/elasticsearch/index/translog/Translog$Location;readk(Lorg/elasticsearch/index/translog/Translog$Location;)Lorg/elasticsearch/index/translog/Translog$Operation;readLock N O FG Q8(Lorg/elasticsearch/index/translog/Translog$Location;)[B LS T3org/elasticsearch/common/io/stream/BytesStreamInputV([BZ)V 7X WY getStream3()Lorg/elasticsearch/index/translog/TranslogStream; [\ ]/org/elasticsearch/index/translog/TranslogStream_g(Lorg/elasticsearch/common/io/stream/StreamInput;)Lorg/elasticsearch/index/translog/Translog$Operation; La `b @ Wd[Bf addSuppressed(Ljava/lang/Throwable;)V hi j,failed to read source from traslog location l-(Ljava/lang/Object;)Ljava/lang/StringBuilder; n o*(Ljava/lang/String;Ljava/lang/Throwable;)V 7q rx2Ljava/lang/Throwable;in5Lorg/elasticsearch/common/io/stream/BytesStreamInput;dataaddk(Lorg/elasticsearch/index/translog/Translog$Operation;)Lorg/elasticsearch/index/translog/Translog$Location;(java/nio/channels/ClosedChannelException{>org/elasticsearch/common/io/stream/ReleasableBytesStreamOutput},(Lorg/elasticsearch/common/util/BigArrays;)V 7 ~0org/elasticsearch/index/translog/TranslogStreamswriteTranslogOperationi(Lorg/elasticsearch/common/io/stream/StreamOutput;Lorg/elasticsearch/index/translog/Translog$Operation;)V  ;()Lorg/elasticsearch/common/bytes/ReleasableBytesReference;  ~e(Lorg/elasticsearch/common/bytes/BytesReference;)Lorg/elasticsearch/index/translog/Translog$Location; y sync @ 7org/elasticsearch/common/bytes/ReleasableBytesReference)org/elasticsearch/common/bytes/BytesArray([B)V 7  )org/elasticsearch/common/lease/Releasable*org/elasticsearch/common/lease/Releasables/([Lorg/elasticsearch/common/lease/Releasable;)V  Failed to write operation []*Ljava/nio/channels/ClosedChannelException;9Lorg/elasticsearch/common/bytes/ReleasableBytesReference; operation5Lorg/elasticsearch/index/translog/Translog$Operation;releasedout@Lorg/elasticsearch/common/io/stream/ReleasableBytesStreamOutput;snapshot9()Lorg/elasticsearch/index/translog/fs/FsChannelSnapshot;  5org/elasticsearch/index/translog/fs/FsChannelSnapshotjava/lang/Threadyield @ 7Lorg/elasticsearch/index/translog/fs/FsChannelSnapshot;j(Lorg/elasticsearch/index/translog/Translog$Snapshot;)Lorg/elasticsearch/index/translog/Translog$Snapshot;  H  position  seekTo  4Lorg/elasticsearch/index/translog/Translog$Snapshot;snap syncNeeded  SIMPLE . stats2()Lorg/elasticsearch/index/translog/TranslogStats;.org/elasticsearch/index/translog/TranslogStats  (IJ)V 7 6()Lorg/elasticsearch/index/translog/Translog$Snapshot; access$000k(Lorg/elasticsearch/index/translog/fs/FsTranslog;)Lorg/elasticsearch/index/translog/fs/FsTranslogFile$Type;x0 access$100](Lorg/elasticsearch/index/translog/fs/FsTranslog;)Lorg/elasticsearch/common/logging/ESLogger;logger+Lorg/elasticsearch/common/logging/ESLogger;   access$002(Lorg/elasticsearch/index/translog/fs/FsTranslog;Lorg/elasticsearch/index/translog/fs/FsTranslogFile$Type;)Lorg/elasticsearch/index/translog/fs/FsTranslogFile$Type;x1java/lang/ClassdesiredAssertionStatus   ConstantValueCodeLocalVariableTableLineNumberTable StackMapTableRuntimeVisibleAnnotations"RuntimeVisibleParameterAnnotations Exceptions SourceFile InnerClasses! !"#$%&'()B*+B,+-./0B12B32456078*+,=*?YBD*F* Y*IK*-M*O+U:*WY6)*YWY2beS*Y2kW**opsw{**o**o-*KRB.2m"#$%5R)FUDLQ"V'W-X5Y?ZJ[_\jZp_`acd"B[]Q_`-9:7p*+,=*?YBD*F* Y*IK*M*WY-SY-kW*O**opsw{**o*pppmp. gDLQ"h'i3j8k?mWnoo :@4*  st@4*  xy_*+*D*M, ,**M, ,**DN*D-<MMNM !+__12 }~).2<JM^)Pc*M*M*K*D*M, ,*M, ,*DN*D- @QQRQ %+cc06  %)059@NQbP(/*Y b*L+ܭ++  `*L++ +  ,  `*L+ + +  @ *D*YL+=>+2:::66t2:  Y*ǹ>*, Y*͹ W: c*D: *D p   Hd 2 )7{ 2:x2))" ) 22J").HnqI `! `W``6W/H`P *DB:*Y:66<2:  7  !  B : !" :**$&YWYYe)*-: :Y*$/2*:* 66*D: *D c 8%34 1, H ) C 2#@2 50B6+ 74&8+4j18?BIY]ci #W`%Ww W" WP9 *D;* =Y>B:*Y:66<2:  7  !  B : !" :***$&YWYYe)*-*D): Y*$/ 2: *D f M%34 F, 0H )5C 28@2'74* 5 4N#' * F M T W^nr x7#W`%WGR?@i*D;* =Y>*L**͵**DM*D,+*+C5FFGFi(A8+.  #!("0#5%C&F%W'^(h) #bD@F*D*L**DM*D,+ +))*)F3E+& .013&4)3:7>8E: i FG5**͹+J*Ͱ*ǹ+J*ǰ55KABD.E3GLMm *DP*+RM,,+UNWY-Z::,^c:!e:ke*DP:::!e:  keN*DP-MYYm+p,s: *DP GLO.=q.=zq|z`q`qRQtutu +wvw xfa+ 5K>PRST U.X=Y`_qUzY[_\]_ OgW gWH gW ]yz *DP=N~Y*ON-+-:*:*F *ǹ;%Y*U =Y>*:::YS=:*DP-Y-S:Y*$Y+p2:*DP-Y-Sy|\  )6KtN,+( u0jefgij#k)l6m=nFqnsttyvyw{|}~nF~'~|5~i% ~i*ǹL++   w*M,+ ,+, @*L++M*+,    5+&     H `*L+++  @/i*F *ɵ *s/0 :Y**ϷҰ A/* 2/* 2/*ܰ 2;*+Z.2@4;2 @2  D