Edit C:\dspace\webapps\oai\WEB-INF\lib\org\elasticsearch\indices\recovery\RecoveryTarget.class
???? 3? 1org/elasticsearch/indices/recovery/RecoveryTarget 4org/elasticsearch/common/component/AbstractComponent RecoveryTarget.java Rorg/elasticsearch/indices/recovery/RecoveryTarget$FileChunkTransportRequestHandler FileChunkTransportRequestHandler Jorg/elasticsearch/indices/recovery/RecoveryTarget$CleanFilesRequestHandler CleanFilesRequestHandler Iorg/elasticsearch/indices/recovery/RecoveryTarget$FilesInfoRequestHandler FilesInfoRequestHandler Rorg/elasticsearch/indices/recovery/RecoveryTarget$TranslogOperationsRequestHandler TranslogOperationsRequestHandler Porg/elasticsearch/indices/recovery/RecoveryTarget$FinalizeRecoveryRequestHandler FinalizeRecoveryRequestHandler \org/elasticsearch/indices/recovery/RecoveryTarget$PrepareForTranslogOperationsRequestHandler *PrepareForTranslogOperationsRequestHandler Borg/elasticsearch/indices/recovery/RecoveryTarget$RecoveryListener RecoveryListener 9org/elasticsearch/indices/recovery/RecoveryTarget$Actions Actions 3org/elasticsearch/indices/recovery/RecoveryTarget$4 3org/elasticsearch/indices/recovery/RecoveryTarget$3 3org/elasticsearch/indices/recovery/RecoveryTarget$2 " 3org/elasticsearch/indices/recovery/RecoveryTarget$1 $ java/util/Map$Entry & java/util/Map ( Entry 3org/elasticsearch/indices/IndicesLifecycle$Listener + *org/elasticsearch/indices/IndicesLifecycle - Listener 6org/elasticsearch/indices/recovery/RecoveryState$Timer 0 0org/elasticsearch/indices/recovery/RecoveryState 2 Timer 6org/elasticsearch/indices/recovery/RecoveryState$Stage 5 Stage 5org/elasticsearch/indices/recovery/RecoveryState$Type 8 Type 3org/elasticsearch/index/store/Store$LegacyChecksums ; #org/elasticsearch/index/store/Store = LegacyChecksums threadPool )Lorg/elasticsearch/threadpool/ThreadPool; transportService .Lorg/elasticsearch/transport/TransportService; indicesService *Lorg/elasticsearch/indices/IndicesService; recoverySettings 5Lorg/elasticsearch/indices/recovery/RecoverySettings; onGoingRecoveries <Lorg/elasticsearch/common/util/concurrent/ConcurrentMapLong; qLorg/elasticsearch/common/util/concurrent/ConcurrentMapLong<Lorg/elasticsearch/indices/recovery/RecoveryStatus;>; $assertionsDisabled Z <init>(Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/threadpool/ThreadPool;Lorg/elasticsearch/transport/TransportService;Lorg/elasticsearch/indices/IndicesService;Lorg/elasticsearch/indices/IndicesLifecycle;Lorg/elasticsearch/indices/recovery/RecoverySettings;)V (Lorg/elasticsearch/common/inject/Inject; /(Lorg/elasticsearch/common/settings/Settings;)V M P Q >org/elasticsearch/common/util/concurrent/ConcurrentCollections S newConcurrentMapLong >()Lorg/elasticsearch/common/util/concurrent/ConcurrentMapLong; U V T W H I Y @ A [ B C ] D E _ F G a 'internal:index/shard/recovery/filesInfo c 6(Lorg/elasticsearch/indices/recovery/RecoveryTarget;)V M e f ,org/elasticsearch/transport/TransportService h registerHandler J(Ljava/lang/String;Lorg/elasticsearch/transport/TransportRequestHandler;)V j k i l (internal:index/shard/recovery/file_chunk n f )internal:index/shard/recovery/clean_files q f .internal:index/shard/recovery/prepare_translog t f *internal:index/shard/recovery/translog_ops w f &internal:index/shard/recovery/finalize z f % f addListener 8(Lorg/elasticsearch/indices/IndicesLifecycle$Listener;)V ~ . ? this 3Lorg/elasticsearch/indices/recovery/RecoveryTarget; settings ,Lorg/elasticsearch/common/settings/Settings; indicesLifecycle ,Lorg/elasticsearch/indices/IndicesLifecycle; recoveryStatus g(Lorg/elasticsearch/index/shard/service/IndexShard;)Lorg/elasticsearch/indices/recovery/RecoveryStatus; findRecoveryByShard ? ? ? 1org/elasticsearch/indices/recovery/RecoveryStatus ? recoveryState 4()Lorg/elasticsearch/indices/recovery/RecoveryState; ? ? ? ? getTimer :()Lorg/elasticsearch/indices/recovery/RecoveryState$Timer; ? ? 3 ? startTime ()J ? ? 1 ? stage :()Lorg/elasticsearch/indices/recovery/RecoveryState$Stage; ? ? ? ? DONE 8Lorg/elasticsearch/indices/recovery/RecoveryState$Stage; ? ? 6 ? java/lang/System ? currentTimeMillis ? ? ? ? time (J)V ? ? 1 ? indexShard 2Lorg/elasticsearch/index/shard/service/IndexShard; 3Lorg/elasticsearch/indices/recovery/RecoveryStatus; cancelRecovery 5(Lorg/elasticsearch/index/shard/service/IndexShard;)V java/lang/InterruptedException ? sentCanceledToSource ? L ? ? cancel ()V ? ? ? ? recoveryThread Ljava/lang/Thread; ? ? ? ? java/lang/Thread ? interrupt ? ? ? ? d 'B? java/lang/Math ? round (F)I ? ? ? ? sourceNode .Lorg/elasticsearch/cluster/node/DiscoveryNode; ? ? ? ? nodeConnected 1(Lorg/elasticsearch/cluster/node/DiscoveryNode;)Z ? ? i ? sleep ? ? ? ? currentThread ()Ljava/lang/Thread; ? ? ? ? removeAndCleanOnGoingRecovery 6(Lorg/elasticsearch/indices/recovery/RecoveryStatus;)V ? ? ? java/lang/Throwable ? e Ljava/lang/InterruptedException; sleepTime J maxSleepTime rounds startRecovery ?(Lorg/elasticsearch/indices/recovery/StartRecoveryRequest;Lorg/elasticsearch/index/shard/service/InternalIndexShard;Lorg/elasticsearch/indices/recovery/RecoveryTarget$RecoveryListener;)V =org/elasticsearch/index/shard/IllegalIndexShardStateException ? java/lang/StringBuilder ? M ? ? ? from ? append -(Ljava/lang/String;)Ljava/lang/StringBuilder; ? ? ? ? 7org/elasticsearch/indices/recovery/StartRecoveryRequest ? 0()Lorg/elasticsearch/cluster/node/DiscoveryNode; ? ? ? ? -(Ljava/lang/Object;)Ljava/lang/StringBuilder; ? ? ? ? toString ()Ljava/lang/String; ? ? 8org/elasticsearch/index/shard/service/InternalIndexShard recovering C(Ljava/lang/String;)Lorg/elasticsearch/index/shard/IndexShardState; already in recovering process, getMessage ? onIgnoreRecovery (ZLjava/lang/String;)V recoveryId ? ? l(JLorg/elasticsearch/index/shard/service/InternalIndexShard;Lorg/elasticsearch/cluster/node/DiscoveryNode;)V M ? 2Lorg/elasticsearch/indices/recovery/RecoveryState; ? ? recoveryType 9()Lorg/elasticsearch/indices/recovery/RecoveryState$Type; ? setType :(Lorg/elasticsearch/indices/recovery/RecoveryState$Type;)V 3! setSourceNode 1(Lorg/elasticsearch/cluster/node/DiscoveryNode;)V #$ 3% targetNode ' ? ?( setTargetNode *$ 3+ routingEntry 2()Lorg/elasticsearch/cluster/routing/ShardRouting; -. / .org/elasticsearch/cluster/routing/ShardRouting1 primary ()Z 34 25 setPrimary (Z)V 78 39 ? ?; :org/elasticsearch/common/util/concurrent/ConcurrentMapLong= put '(JLjava/lang/Object;)Ljava/lang/Object; ?@ >A 'org/elasticsearch/threadpool/ThreadPoolC generic !()Ljava/util/concurrent/Executor; EF DG ?(Lorg/elasticsearch/indices/recovery/RecoveryTarget;Lorg/elasticsearch/indices/recovery/StartRecoveryRequest;Lorg/elasticsearch/indices/recovery/RecoveryStatus;Lorg/elasticsearch/indices/recovery/RecoveryTarget$RecoveryListener;)V MI #J java/util/concurrent/ExecutorL execute (Ljava/lang/Runnable;)V NO MP ?Lorg/elasticsearch/index/shard/IllegalIndexShardStateException; request 9Lorg/elasticsearch/indices/recovery/StartRecoveryRequest; :Lorg/elasticsearch/index/shard/service/InternalIndexShard; listener DLorg/elasticsearch/indices/recovery/RecoveryTarget$RecoveryListener; retryRecovery ?(Lorg/elasticsearch/indices/recovery/StartRecoveryRequest;Lorg/elasticsearch/common/unit/TimeValue;Lorg/elasticsearch/indices/recovery/RecoveryStatus;Lorg/elasticsearch/indices/recovery/RecoveryTarget$RecoveryListener;)VE !J schedule w(Lorg/elasticsearch/common/unit/TimeValue;Ljava/lang/String;Ljava/lang/Runnable;)Ljava/util/concurrent/ScheduledFuture; \] D^ retryAfter )Lorg/elasticsearch/common/unit/TimeValue; status doRecovery ?(Lorg/elasticsearch/indices/recovery/StartRecoveryRequest;Lorg/elasticsearch/indices/recovery/RecoveryStatus;Lorg/elasticsearch/indices/recovery/RecoveryTarget$RecoveryListener;)V K L e java/lang/AssertionErrorg )can't do a recovery without a source nodei (Ljava/lang/Object;)V Mk hl ?U ?n $shard missing locally, stop recoveryp state 1()Lorg/elasticsearch/index/shard/IndexShardState; rs t -org/elasticsearch/index/shard/IndexShardStatev CLOSED /Lorg/elasticsearch/index/shard/IndexShardState; xy wz !local shard closed, stop recovery| isCanceled ~4 ? canceled recovery? store '()Lorg/elasticsearch/index/store/Store; ?? ? tryIncRef ?4 >? logger +Lorg/elasticsearch/common/logging/ESLogger; ?? ? "[{}][{}] starting recovery from {}? java/lang/Object? shardId )()Lorg/elasticsearch/index/shard/ShardId; ?? ?? %org/elasticsearch/index/shard/ShardId? index !()Lorg/elasticsearch/index/Index; ?? ?? org/elasticsearch/index/Index? name ? ?? id ()I ?? ?? java/lang/Integer? valueOf (I)Ljava/lang/Integer; ?? ?? )org/elasticsearch/common/logging/ESLogger? trace ((Ljava/lang/String;[Ljava/lang/Object;)V ?? ?? "org/elasticsearch/common/StopWatch? ? ? start &()Lorg/elasticsearch/common/StopWatch; ?? ?? ,internal:index/shard/recovery/start_recovery? f submitRequest ?(Lorg/elasticsearch/cluster/node/DiscoveryNode;Ljava/lang/String;Lorg/elasticsearch/transport/TransportRequest;Lorg/elasticsearch/transport/TransportResponseHandler;)Lorg/elasticsearch/transport/TransportFuture; ?? i? +org/elasticsearch/transport/TransportFuture? txGet ()Ljava/lang/Object; ?? ?? 3org/elasticsearch/indices/recovery/RecoveryResponse? decRef ? ? >? stop ?? ?? isTraceEnabled ?4 ?? (C)Ljava/lang/StringBuilder; ?? ?? (I)Ljava/lang/StringBuilder; ?? ?? ] ? recovery completed from ? , took[? totalTime +()Lorg/elasticsearch/common/unit/TimeValue; ?? ?? ] ? phase1: recovered_files [? phase1FileNames Ljava/util/List; ?? ?? java/util/List? size ?? ?? ]? with total_size of [? +org/elasticsearch/common/unit/ByteSizeValue? phase1TotalSize ? ? ?? M ? ?? , took [? phase1Time ? ? ?? 'org/elasticsearch/common/unit/TimeValue? timeValueMillis ,(J)Lorg/elasticsearch/common/unit/TimeValue; ? ? ], throttling_wait [ phase1ThrottlingWaitTime ? ? : reusing_files [ phase1ExistingFileNames ? ? ] with total_size of [ phase1ExistingTotalSize ? ? phase2: start took [ ? ? ? : recovered [ phase2Operations I ? transaction log operations phase2Time ? ?! phase3: recovered [# phase3Operations % ?& phase3Time ( ? ?) isDebugEnabled +4 ?, *{} recovery completed from [{}], took [{}]. debug 0? ?1 onRecoveryDone 3 ? 4 "[{}][{}] Got exception on recovery6 =(Ljava/lang/String;Ljava/lang/Throwable;[Ljava/lang/Object;)V ?8 ?9 "org/elasticsearch/ExceptionsHelper; unwrapCause ,(Ljava/lang/Throwable;)Ljava/lang/Throwable; => <? 6org/elasticsearch/index/engine/RecoveryEngineExceptionA getCause ()Ljava/lang/Throwable; CD ?E ;org/elasticsearch/index/shard/IndexShardNotStartedExceptionG /org/elasticsearch/indices/IndexMissingExceptionI 2org/elasticsearch/index/IndexShardMissingExceptionK ? onRetryRecovery _(Lorg/elasticsearch/common/unit/TimeValue;Lorg/elasticsearch/indices/recovery/RecoveryStatus;)V OP Q 9org/elasticsearch/indices/recovery/DelayRecoveryExceptionS 5org/elasticsearch/transport/ConnectTransportExceptionU source node disconnected (W )Y 7org/elasticsearch/index/shard/IndexShardClosedException[ source shard is closed (] .org/apache/lucene/store/AlreadyClosedException_ "[{}][{}] recovery from [{}] faileda warn c8 ?d :org/elasticsearch/indices/recovery/RecoveryFailedExceptionf Q(Lorg/elasticsearch/indices/recovery/StartRecoveryRequest;Ljava/lang/Throwable;)V Mh gi onRecoveryFailure @(Lorg/elasticsearch/indices/recovery/RecoveryFailedException;Z)V kl m !local store closed, stop recoveryo sb Ljava/lang/StringBuilder; stopWatch $Lorg/elasticsearch/common/StopWatch; recoveryResponse 5Lorg/elasticsearch/indices/recovery/RecoveryResponse; cause Ljava/lang/Throwable; shard #Lorg/elasticsearch/common/Nullable; values ()Ljava/util/Collection; {| >} java/util/Collection iterator ()Ljava/util/Iterator; ?? ?? java/util/Iterator? hasNext ?4 ?? next ?? ?? i$ Ljava/util/Iterator; remove (J)Ljava/lang/Object; ?? >? cancelAndClearOpenIndexInputs ()Ljava/util/Set; ?? ?? java/util/Set? ?? getValue ?? '? #org/apache/lucene/store/IndexOutput? java/io/Closeable? org/apache/lucene/util/IOUtils? closeWhileHandlingException ([Ljava/io/Closeable;)V ?? ?? ? ? ?? legacyChecksums 5Lorg/elasticsearch/index/store/Store$LegacyChecksums; ?? ?? clear ? ? <? entry NLjava/util/Map$Entry<Ljava/lang/String;Lorg/apache/lucene/store/IndexOutput;>; Ljava/util/Map$Entry; entrySet _Ljava/util/Set<Ljava/util/Map$Entry<Ljava/lang/String;Lorg/apache/lucene/store/IndexOutput;>;>; Ljava/util/Set; dLjava/util/Iterator<Ljava/util/Map$Entry<Ljava/lang/String;Lorg/apache/lucene/store/IndexOutput;>;>; validateRecoveryStatus ](Lorg/elasticsearch/indices/recovery/RecoveryStatus;Lorg/elasticsearch/index/shard/ShardId;)V *(Lorg/elasticsearch/index/shard/ShardId;)V M? \? onGoingRecovery 'Lorg/elasticsearch/index/shard/ShardId; access$000 ?(Lorg/elasticsearch/indices/recovery/RecoveryTarget;Lorg/elasticsearch/index/shard/service/IndexShard;)Lorg/elasticsearch/indices/recovery/RecoveryStatus; x0 x1 access$100 i(Lorg/elasticsearch/indices/recovery/RecoveryTarget;Lorg/elasticsearch/indices/recovery/RecoveryStatus;)V access$200 cd ? x2 x3 access$300 q(Lorg/elasticsearch/indices/recovery/RecoveryTarget;)Lorg/elasticsearch/common/util/concurrent/ConcurrentMapLong; access$400 ?(Lorg/elasticsearch/indices/recovery/RecoveryTarget;Lorg/elasticsearch/indices/recovery/RecoveryStatus;Lorg/elasticsearch/index/shard/ShardId;)V ?? ? access$500 _(Lorg/elasticsearch/indices/recovery/RecoveryTarget;)Lorg/elasticsearch/indices/IndicesService; access$600 `(Lorg/elasticsearch/indices/recovery/RecoveryTarget;)Lorg/elasticsearch/common/logging/ESLogger; access$700 j(Lorg/elasticsearch/indices/recovery/RecoveryTarget;)Lorg/elasticsearch/indices/recovery/RecoverySettings; <clinit> java/lang/Class? desiredAssertionStatus ?4 ?? Signature Code LocalVariableTable LineNumberTable RuntimeVisibleAnnotations StackMapTable LocalVariableTypeTable "RuntimeVisibleParameterAnnotations SourceFile InnerClasses ! @ A B C D E F G H I ? J K L M N ? ?*+? R*? X? Z*,? \*-? ^*? `*? b-d? Y*? g? m-o? Y*? p? m-r? Y*? s? m-u? Y*? v? m-x? Y*? y? m-{? Y*? |? m? %Y*? }? ? ? ? H ? ? ? ? ? ? ? @ A ? B C ? D E ? ? ? ? F G ? : Y T Z [ \ ] " _ 0 ` > a L b Z c h d v f ? n? O ? ? ? ? ?*+? ?M,? ?,? ?? ?? ? ?? %,? ?? ?? ,? ?? ?? ?,? ?? ?? ?e? ?,? ? ? ? ? ? ? ? 9 ? ? ? q r s u % v = x? ? ?0 ? ? ? s *+? ?M,? ?,? ?? ?,? ?,? ?? ,? ?? ? ?B ?7? ?7,? ?? 2*? ^,? ? ? $ ?? e7 ø ???: ? ? § *,? ? : *,? ? ?? X ^ a ? l t t v t ? H c ? ? ) C ? ? . > ? ? 6 6 ? ? ? ? ? ? y ? ? ? Z | ~ ? ? ? ? ? % ? ) ? . ? 6 ? R ? X ? ^ ? a ? c ? i ? l ? q ? t ? ~ ?? ? ?? j ?? G ? ? ? ? R ?,? ?Y? ?? ?+? ? ???W? %:-? ?Y? ? ? ?? ? ??? ?? ?Y+?,+? ?:?+? ?"?+? ?&?+?)?,?,?0?6 ?:*? Z?<?B W*? \?H? #Y*+-?K?Q ? ? ? > ?R ? ? ? ?ST ? ?U ?VW R _ ? ? ? 6 ? ? ? ? ? ? @ ? R ? ^ ? j ? v ? ? ? ? ? ? ?? ^ ?! XY ? o *? \,Z? !Y*+-?[?_W? ? 4 ? ? ST `a b ? VW ? ? ? cd ? N ?f? +? ?? ?hYj?m?,?o:? -q? ??u?{? -}? ?,??? -?? ?,? ? ??????^*?????Y+??????SY+??????SY+? ?S?? ??Y????:*? ^+? ??+? Y*?????? ??:?u?{? *,? ?-}? ??????W*???? ??? ?Y? ?:[??+??????? ?]??[??+??????? ?W? ?+? ? ?? ??? ?? ?W? ???? ??? ?? ???Y????? ?? ?? ???? ?? ???? ?]?? ? ?W ? ???? ??? ???Y???? ?? ?W? ???? ?? ?W? ?? ??? ? ? ?? ??"?? ?? ? ? ?W$? ??'??? ? ? ?? ??*?? ?? ?W*??????? ? 5*???- ? )*??/??Y+??SY+? ?SY??S?2 *,? ?-?5 ?????:*???? ? /*??7??Y+??????SY+??????S?: ,??? -?? ?????u?{? *,? ?-}? ?????@:?B? ?F:?@:?B? ?F:?H? ?J? ?L? -M?,?R ?????T? -M?,?R ????*,? ??V? 0-? ?Y? ?X? ?+? ? ?Z? ??? ?????\? 0-? ?Y? ?^? ?+? ? ?Z? ??? ?????`? 0-? ?Y? ?^? ?+? ? ?Z? ??? ????*??b??Y+??????SY+??????SY+? ?S?e -?gY+?j?n ???? :?????? -p? ? h ?? ? ??? ? h ?? ??? ? ? %?? H?? ??? ??? ?&? /[? d?? ??? ? f ?qr ?!st ? uv OYwx ?? ?x ? ? ? ?ST ? ? ? ?VW ?yU ? 2 L ? ? ? # ? - ? . ? 9 ? C ? D ? K ? U ? V ? ] ? h ? ? ? ? ? ? ? ? ? ? ? ?6 ? ? ? ? ? ? ?3 ?W ?? ?? ? ?@ ?t ?? ?? ?? ?? ??6?7? ?? ?? ? ? ? 6% ?0 5?6HOW^ e m t??6???6?"?$?%?6?)*&6/.7/[6d3?4?6?7?6?9?;? b ? ? ?????1? ? ? ?? 9 ?"? ? 944? N ? ? ? ? ? ? ? 1*? Z?~ ?? M,?? ? ,?? ? ?N-?o+? -????? ? * " ? ? ?? 1 ? ? 1 ? ? ? I "J *K ,M /N? ? ? ? ? z ? ? ? } ?+? ?*? Z+?<?? ? ?L+? ?+? ?+??M,?? N-?? ? G-?? ? ':?? ??Y:???Y?? ??S??ç :??-?? ???+????? M d g g l g ? 4 ? 6?? ? ? ? ?b ? $ \?? + U?? ? ? 6?? $ \?? + U?? ? F R S V W X \ ^ $_ +` 4a ?b Mc ad oe ug xh i? / ? ??? ; ??? '? ?? ? ? z ?? ? ? C+? ?\Y,???+?o?u?{? *+? ?+? ??\Y,???+??? +? ??\Y,???? ? C ? ? C? ? C?? ? * z | ~ ? $? -? 4? 9? B?? ?? ? : *+? ?? ? ? ? ? ? ? A?? ? : *+? ? ? ? ? ? ? ? A?I ? P *+,-?? ? * ? ? ?T ? ? ?W ? A?? ? / *? Z? ? ? ? ? A?? ? E *+,?? ? ? ? ? ? ?? ? A?? ? / *? `? ? ? ? ? A?? ? / *??? ? ? ? ? A?? ? / *? b? ? ? ? ? A ? ? ? 4 ?? ? ?f? ? A? @ ? ? ? ! # % ' ) * , . / 1 3 4 6 3 7@ 9 3 :@ < > ?
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de