Edit C:\dspace\webapps\rest\WEB-INF\lib\org\elasticsearch\snapshots\RestoreService.class
???? 33 *org/elasticsearch/snapshots/RestoreService 4org/elasticsearch/common/component/AbstractComponent .org/elasticsearch/cluster/ClusterStateListener RestoreService.java Korg/elasticsearch/snapshots/RestoreService$UpdateRestoreStateRequestHandler UpdateRestoreStateRequestHandler Oorg/elasticsearch/snapshots/RestoreService$UpdateIndexShardRestoreStatusRequest $UpdateIndexShardRestoreStatusRequest Dorg/elasticsearch/snapshots/RestoreService$RestoreCompletionListener RestoreCompletionListener Borg/elasticsearch/snapshots/RestoreService$RestoreSnapshotListener RestoreSnapshotListener 9org/elasticsearch/snapshots/RestoreService$RestoreRequest RestoreRequest ,org/elasticsearch/snapshots/RestoreService$2 ,org/elasticsearch/snapshots/RestoreService$1 Eorg/elasticsearch/cluster/metadata/RestoreMetaData$ShardRestoreStatus 2org/elasticsearch/cluster/metadata/RestoreMetaData ShardRestoreStatus java/util/Map$Entry java/util/Map " Entry 8org/elasticsearch/cluster/metadata/RestoreMetaData$Entry % 8org/elasticsearch/cluster/metadata/RestoreMetaData$State ' State 2org/elasticsearch/cluster/metadata/MetaData$Custom * +org/elasticsearch/cluster/metadata/MetaData , Custom UPDATE_RESTORE_ACTION_NAME Ljava/lang/String; (internal:cluster/snapshot/update_restore 1 clusterService *Lorg/elasticsearch/cluster/ClusterService; repositoriesService 4Lorg/elasticsearch/repositories/RepositoriesService; transportService .Lorg/elasticsearch/transport/TransportService; allocationService @Lorg/elasticsearch/cluster/routing/allocation/AllocationService; createIndexService ?Lorg/elasticsearch/cluster/metadata/MetaDataCreateIndexService; listeners +Ljava/util/concurrent/CopyOnWriteArrayList; sLjava/util/concurrent/CopyOnWriteArrayList<Lorg/elasticsearch/snapshots/RestoreService$RestoreCompletionListener;>; <init>:(Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/cluster/ClusterService;Lorg/elasticsearch/repositories/RepositoriesService;Lorg/elasticsearch/transport/TransportService;Lorg/elasticsearch/cluster/routing/allocation/AllocationService;Lorg/elasticsearch/cluster/metadata/MetaDataCreateIndexService;)V (Lorg/elasticsearch/common/inject/Inject; /(Lorg/elasticsearch/common/settings/Settings;)V @ C D )java/util/concurrent/CopyOnWriteArrayList F ()V @ H G I = > K 3 4 M 5 6 O 7 8 Q 9 : S ; < U ](Lorg/elasticsearch/snapshots/RestoreService;Lorg/elasticsearch/snapshots/RestoreService$1;)V @ W X ,org/elasticsearch/transport/TransportService Z registerHandler J(Ljava/lang/String;Lorg/elasticsearch/transport/TransportRequestHandler;)V \ ] [ ^ (org/elasticsearch/cluster/ClusterService ` add 3(Lorg/elasticsearch/cluster/ClusterStateListener;)V b c a d this ,Lorg/elasticsearch/snapshots/RestoreService; settings ,Lorg/elasticsearch/common/settings/Settings; restoreSnapshot ?(Lorg/elasticsearch/snapshots/RestoreService$RestoreRequest;Lorg/elasticsearch/snapshots/RestoreService$RestoreSnapshotListener;)V java/lang/Throwable l repository ()Ljava/lang/String; n o p 2org/elasticsearch/repositories/RepositoriesService r ?(Ljava/lang/String;)Lorg/elasticsearch/repositories/Repository; n t s u -org/elasticsearch/cluster/metadata/SnapshotId w name y o z '(Ljava/lang/String;Ljava/lang/String;)V @ | x } )org/elasticsearch/repositories/Repository readSnapshot W(Lorg/elasticsearch/cluster/metadata/SnapshotId;)Lorg/elasticsearch/snapshots/Snapshot; ? ? ? ? $org/elasticsearch/snapshots/Snapshot ? indices 2()Lorg/elasticsearch/common/collect/ImmutableList; ? ? ? ? ()[Ljava/lang/String; ? ? ? indicesOptions 3()Lorg/elasticsearch/action/support/IndicesOptions; ? ? ? )org/elasticsearch/snapshots/SnapshotUtils ? filterIndices ?(Lorg/elasticsearch/common/collect/ImmutableList;[Ljava/lang/String;Lorg/elasticsearch/action/support/IndicesOptions;)Lorg/elasticsearch/common/collect/ImmutableList; ? ? ? ? readSnapshotMetaData ?(Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/common/collect/ImmutableList;)Lorg/elasticsearch/cluster/metadata/MetaData; ? ? ? ? validateSnapshotRestorable X(Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/snapshots/Snapshot;)V ? ? ? renamedIndices |(Lorg/elasticsearch/snapshots/RestoreService$RestoreRequest;Lorg/elasticsearch/common/collect/ImmutableList;)Ljava/util/Map; ? ? ? cause ? o ??(Lorg/elasticsearch/snapshots/RestoreService;Lorg/elasticsearch/cluster/metadata/SnapshotId;Ljava/util/Map;Lorg/elasticsearch/cluster/metadata/MetaData;Lorg/elasticsearch/snapshots/RestoreService$RestoreRequest;Lorg/elasticsearch/snapshots/Snapshot;Lorg/elasticsearch/snapshots/RestoreService$RestoreSnapshotListener;)V @ ? ? submitStateUpdateTask G(Ljava/lang/String;Lorg/elasticsearch/cluster/ClusterStateUpdateTask;)V ? ? a ? logger +Lorg/elasticsearch/common/logging/ESLogger; ? ? ? #[{}][{}] failed to restore snapshot ? java/lang/Object ? )org/elasticsearch/common/logging/ESLogger ? warn =(Ljava/lang/String;Ljava/lang/Throwable;[Ljava/lang/Object;)V ? ? ? ? onFailure (Ljava/lang/Throwable;)V ? ? ? +Lorg/elasticsearch/repositories/Repository; snapshotId /Lorg/elasticsearch/cluster/metadata/SnapshotId; snapshot &Lorg/elasticsearch/snapshots/Snapshot; filteredIndices DLorg/elasticsearch/common/collect/ImmutableList<Ljava/lang/String;>; 0Lorg/elasticsearch/common/collect/ImmutableList; metaData -Lorg/elasticsearch/cluster/metadata/MetaData; 5Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>; Ljava/util/Map; e Ljava/lang/Throwable; request ;Lorg/elasticsearch/snapshots/RestoreService$RestoreRequest; listener DLorg/elasticsearch/snapshots/RestoreService$RestoreSnapshotListener; indexShardRestoreCompleted Y(Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/index/shard/ShardId;)V &[{}] successfully restored shard [{}] ? trace ((Ljava/lang/String;[Ljava/lang/Object;)V ? ? ? ? state *()Lorg/elasticsearch/cluster/ClusterState; ? ? a ? &org/elasticsearch/cluster/ClusterState ? nodes 1()Lorg/elasticsearch/cluster/node/DiscoveryNodes; ? ? ? ? -org/elasticsearch/cluster/node/DiscoveryNodes ? localNodeId ? o ? ? SUCCESS :Lorg/elasticsearch/cluster/metadata/RestoreMetaData$State; ? ? ( ? O(Ljava/lang/String;Lorg/elasticsearch/cluster/metadata/RestoreMetaData$State;)V @ ? ? ?(Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/cluster/metadata/RestoreMetaData$ShardRestoreStatus;Lorg/elasticsearch/snapshots/RestoreService$1;)V @ ? ? localNodeMaster ()Z ? ? ? ? innerUpdateRestoreState T(Lorg/elasticsearch/snapshots/RestoreService$UpdateIndexShardRestoreStatusRequest;)V ? ? ? masterNode 0()Lorg/elasticsearch/cluster/node/DiscoveryNode; ? ? ? ? 9org/elasticsearch/transport/EmptyTransportResponseHandler ? INSTANCE_SAME ;Lorg/elasticsearch/transport/EmptyTransportResponseHandler; sendRequest ?(Lorg/elasticsearch/cluster/node/DiscoveryNode;Ljava/lang/String;Lorg/elasticsearch/transport/TransportRequest;Lorg/elasticsearch/transport/TransportResponseHandler;)V [ shardId 'Lorg/elasticsearch/index/shard/ShardId; QLorg/elasticsearch/snapshots/RestoreService$UpdateIndexShardRestoreStatusRequest; update snapshot state ?(Lorg/elasticsearch/snapshots/RestoreService;Lorg/elasticsearch/snapshots/RestoreService$UpdateIndexShardRestoreStatusRequest;)V @ completed (Ljava/util/Map;)Z values ()Ljava/util/Collection; # java/util/Collection iterator ()Ljava/util/Iterator; java/util/Iterator hasNext ? next ()Ljava/lang/Object; "# $ <()Lorg/elasticsearch/cluster/metadata/RestoreMetaData$State; ?& ' ? () status GLorg/elasticsearch/cluster/metadata/RestoreMetaData$ShardRestoreStatus; i$ Ljava/util/Iterator; shards Ljava/util/Map<Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/cluster/metadata/RestoreMetaData$ShardRestoreStatus;>; failedShards (Ljava/util/Map;)I FAILURE 3 ? (4 I %org/elasticsearch/common/collect/Maps7 newHashMap ()Ljava/util/HashMap; 9: 8; .org/elasticsearch/common/collect/ImmutableList= > java/lang/String@ renameReplacement B o C renamePattern E o F replaceAll 8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; HI AJ put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; LM #N 4org/elasticsearch/snapshots/SnapshotRestoreExceptionP java/lang/StringBuilderR S I indices [U append -(Ljava/lang/String;)Ljava/lang/StringBuilder; WX SY ] and [[ #] are renamed into the same index [] ]_ toString a o Sb D(Lorg/elasticsearch/cluster/metadata/SnapshotId;Ljava/lang/String;)V @d Qe renamedIndex previousIndex index -()Lorg/elasticsearch/snapshots/SnapshotState; ?j ?k )org/elasticsearch/snapshots/SnapshotStatem restorable o ? np unsupported snapshot state [r -(Ljava/lang/Object;)Ljava/lang/StringBuilder; Wt Su org/elasticsearch/Versionw CURRENT Lorg/elasticsearch/Version; yz x{ version ()Lorg/elasticsearch/Version; }~ ? before (Lorg/elasticsearch/Version;)Z ?? x? 5the snapshot was created with Elasticsearch version [? 1] which is higher than the version of this node [? processDeletedIndices 2(Lorg/elasticsearch/cluster/ClusterChangedEvent;)V -org/elasticsearch/cluster/ClusterChangedEvent? ? ? /()Lorg/elasticsearch/cluster/metadata/MetaData; ?? ?? restore? custom H(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/MetaData$Custom; ?? -? indicesDeleted ()Ljava/util/List; ?? ?? java/util/List? isEmpty ? ? ?? entries ? ? ? 1()Lorg/elasticsearch/common/collect/ImmutableMap; /? &? -org/elasticsearch/common/collect/ImmutableMap? entrySet 1()Lorg/elasticsearch/common/collect/ImmutableSet; ?? ?? -org/elasticsearch/common/collect/ImmutableSet? ? getValue ?# !? getKey ?# !? %org/elasticsearch/index/shard/ShardId? getIndex ? o ?? hasIndex (Ljava/lang/String;)Z ?? -? &org/elasticsearch/common/collect/Lists? newArrayList ()Ljava/util/ArrayList; ?? ?? (Ljava/lang/Object;)Z b? ?? ? '[{}] failing running shard restore [{}]? 1()Lorg/elasticsearch/cluster/metadata/SnapshotId; ?? &? index was deleted? a(Ljava/lang/String;Lorg/elasticsearch/cluster/metadata/RestoreMetaData$State;Ljava/lang/String;)V @? ? shard ?Ljava/util/Map$Entry<Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/cluster/metadata/RestoreMetaData$ShardRestoreStatus;>; Ljava/util/Map$Entry; shardsToFail 9Ljava/util/List<Lorg/elasticsearch/index/shard/ShardId;>; Ljava/util/List; entry :Lorg/elasticsearch/cluster/metadata/RestoreMetaData$Entry; event /Lorg/elasticsearch/cluster/ClusterChangedEvent; 4Lorg/elasticsearch/cluster/metadata/RestoreMetaData; failRestore "[{}] failed to restore shard [{}]? debug ? ? ?? failed ;(Lorg/elasticsearch/snapshots/Snapshot;Ljava/lang/String;)Z shardFailures ? ? ?? 0org/elasticsearch/snapshots/SnapshotShardFailure? i o ?? equals ?? A? failure 2Lorg/elasticsearch/snapshots/SnapshotShardFailure; addListener I(Lorg/elasticsearch/snapshots/RestoreService$RestoreCompletionListener;)V G? FLorg/elasticsearch/snapshots/RestoreService$RestoreCompletionListener; removeListener remove ?? G? clusterChanged ? ? ?? ? Failed to update restore state ? t isRepositoryInUse =(Lorg/elasticsearch/cluster/ClusterState;Ljava/lang/String;)Z getRepository o x clusterState (Lorg/elasticsearch/cluster/ClusterState; snapshots access$100 m(Lorg/elasticsearch/snapshots/RestoreService;)Lorg/elasticsearch/cluster/metadata/MetaDataCreateIndexService; x0 access$200 X(Lorg/elasticsearch/snapshots/RestoreService;)Lorg/elasticsearch/cluster/ClusterService; access$300 >(Lorg/elasticsearch/snapshots/RestoreService;Ljava/util/Map;)Z x1 access$400 >(Lorg/elasticsearch/snapshots/RestoreService;Ljava/util/Map;)I 12 access$500 n(Lorg/elasticsearch/snapshots/RestoreService;)Lorg/elasticsearch/cluster/routing/allocation/AllocationService; access$600 g(Lorg/elasticsearch/snapshots/RestoreService;Lorg/elasticsearch/snapshots/Snapshot;Ljava/lang/String;)Z ?? x2 access$700 Y(Lorg/elasticsearch/snapshots/RestoreService;)Lorg/elasticsearch/common/logging/ESLogger; access$900 access$1000 access$1100 access$1200 Y(Lorg/elasticsearch/snapshots/RestoreService;)Ljava/util/concurrent/CopyOnWriteArrayList; access$1400 access$1600 ConstantValue Signature Code LocalVariableTable LineNumberTable RuntimeVisibleAnnotations LocalVariableTypeTable StackMapTable ?(Ljava/util/Map<Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/cluster/metadata/RestoreMetaData$ShardRestoreStatus;>;)Z ?(Ljava/util/Map<Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/cluster/metadata/RestoreMetaData$ShardRestoreStatus;>;)I ?(Lorg/elasticsearch/snapshots/RestoreService$RestoreRequest;Lorg/elasticsearch/common/collect/ImmutableList<Ljava/lang/String;>;)Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>; SourceFile InnerClasses ! / 0 & 2 3 4 5 6 7 8 9 : ; < = > ' ? @ A ( ? D*+? E*? GY? J? L*,? N*-? P*? R*? T*? V2? Y*? Y? _,*? e ? ) H D f g D h i D 3 4 D 5 6 D 7 8 D 9 : D ; < * * a ] b c d e & f , g < h C i+ B j k ( ? ?*? P+? q? vN? xY+? q+? {? ~:-? ? :? ? +? ?+? ?? ?:-? ? :*? ?*+? ?:*? N+? ?? Y*+,? ?? ? ? )N*? ??-? ?Y+? qSY+? {S? ? ,-? ? ? w z m ) f k n ? Z ? ? ' P ? ? ; < ? ? G 0 ? ? X ? ? { % ? ? ? f g ? ? ? ? ? ? , ; < ? ? X ? ? * 6 t u v ' w ; x G { O ~ X ? wF zC {D ?E ?G- ? z m% ? ? ( ? r*? ??? ?Y+SY,S? ? ? Y+,? Y*? N? ? ? ? ? ? ?? ?N*? N? ? ? ? ?? *-? ? *? R*? N? ? ? ? ?2-??? ) * r f g r ? ? r ; 7 ? * Q R ;T MU UW qZ- ? U ? ? ( N *? N ? Y*+?? ? ? ) f g ? * b ? ( ? 0+? ? M,?! ? ,?% ? N-?(?*? ????? ) * +, "-. 0 f g 0/ ? , 0/0 * ? ? )? +? .?- ? ? ' . 12 ( ? 5=+? ? N-?! ? -?% ? :?(?5? ???? ? ) 4 " +, %-. 5 f g 5/ ? 316 , 5/0 * ? ? "? -? 0? 3?- ? !? ' / ? ? ( r ??<N,??:?! ? ??% ?A::+?D? +?G? +?G+?D?K:-?O ?A:? K?QY? xY+? q+? {? ~?SY?TV?Z?Z\?Z?Z^?Z?Z`?Z?c?f???m-? ) R $ yg 0 P Mh 0 }i 0 ?-. ? f g ? ? ? ? ? ? ? ? ? , ? ? ? ? ? ? * * ? ? ? $? 2? A? P? U? ?? ??- ? # ? 6AA? [? ' 0 ? ? ( ? x,?l ?q? +?QY+?SY?Ts?Z,?l ?v`?Z?c?f??|,?? ??? 7?QY+?SY?T??Z,?? ?v??Z?|?v`?Z?c?f?? ) x f g x ? ? x ? ? * ? ? 4? C? w?- 4? B ?? ( P +????M,???? N-? ?+???? ? ?-????:?! ? ??% ? &::??????:?! ? X?% ? !:?? ? ?(?*? 6+?????? ??????? ? ??:?? ?? W???? c?? :?! ? P?% ??:*? ??? ?Y??SYS? ? *? Y??? Y?5??? ? ?????? ) p i F?? S _-. ? > ? W-. F ??? C ??? - ?-. f g ?? ? ? ?? , i F?? F ??? * V ? ? ? ? ? $? C? F? i? |? ?? ?? ?? ?? ?? ?? ?? ?????- 5 ? - ? ? % &? ? L !? ? ? ? V? ? ? ( ? s*? ??? ?Y+SY,S?? ? Y+,? Y*? N? ? ? ? ?5? ?? ?N*? N? ? ? ? ?? *-? ? *? R*? N? ? ? ? ?2-??? ) * s f g s ? ? s < 7 ? * ? ? <? N? V? r - ? V ?? ( ? 1+?? ??N-?! ? -?% ??:,??? ????? ) 4 ?? %-. 1 f g 1 ? ? 1i 0 * * , /- ? !? ?? ( B *? L+??W? ) f g ?? * ?? ( B *? L+??W? ) f g ?? * ?? ( ? "+?? *+?? M*? ??,? ?? ? ? m ) ? ? " f g "?? * % & * ( ) !+- B m ( ? I*??M,???? N-? 6-????:?! ? #?% ? &:+???? ????? ) > 3 ?? *-. I I n 0 D ? ? 9? * " 5 6 7 8 39 B: D< G>- ? - &? ( / *? V? ) g * O ( / *? N? ) g * O ( : *+?? ) g ? * O ( : *+?? ) g ? * O ( / *? T? ) g * O ( E *+,?? ) g ? 0 * O ( / *? ?? ) g * O ( / *? ?? ) g * O ( / *? ?? ) g * O! ( / *? ?? ) g * O"# ( / *? L? ) g * O$ ( / *? ?? ) g * O% ( : *+? ? ) g * O 1 2 b ! # $ & $ ( )@ + - .
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de