Edit C:\dspace\webapps\swordv2\WEB-INF\lib\org\elasticsearch\snapshots\RestoreService$1.class
???? 3? ,org/elasticsearch/snapshots/RestoreService$1 7org/elasticsearch/cluster/TimeoutClusterStateUpdateTask RestoreService.java *org/elasticsearch/snapshots/RestoreService restoreSnapshot ?(Lorg/elasticsearch/snapshots/RestoreService$RestoreRequest;Lorg/elasticsearch/snapshots/RestoreService$RestoreSnapshotListener;)V 9org/elasticsearch/snapshots/RestoreService$RestoreRequest RestoreRequest Borg/elasticsearch/snapshots/RestoreService$RestoreSnapshotListener RestoreSnapshotListener 8org/elasticsearch/cluster/metadata/IndexMetaData$Builder 0org/elasticsearch/cluster/metadata/IndexMetaData Builder java/util/Map$Entry java/util/Map Entry 5org/elasticsearch/common/collect/ImmutableMap$Builder -org/elasticsearch/common/collect/ImmutableMap 8org/elasticsearch/cluster/metadata/RestoreMetaData$Entry 2org/elasticsearch/cluster/metadata/RestoreMetaData ! 3org/elasticsearch/cluster/metadata/MetaData$Builder # +org/elasticsearch/cluster/metadata/MetaData % 5org/elasticsearch/cluster/block/ClusterBlocks$Builder ' -org/elasticsearch/cluster/block/ClusterBlocks ) 6org/elasticsearch/cluster/routing/RoutingTable$Builder + .org/elasticsearch/cluster/routing/RoutingTable - Eorg/elasticsearch/cluster/routing/allocation/RoutingAllocation$Result / >org/elasticsearch/cluster/routing/allocation/RoutingAllocation 1 Result Eorg/elasticsearch/cluster/metadata/RestoreMetaData$ShardRestoreStatus 4 ShardRestoreStatus 2org/elasticsearch/cluster/metadata/MetaData$Custom 7 Custom 6org/elasticsearch/cluster/metadata/IndexMetaData$State : State 8org/elasticsearch/cluster/metadata/RestoreMetaData$State = .org/elasticsearch/cluster/ClusterState$Builder ? &org/elasticsearch/cluster/ClusterState A restoreInfo )Lorg/elasticsearch/snapshots/RestoreInfo; val$snapshotId /Lorg/elasticsearch/cluster/metadata/SnapshotId; val$renamedIndices Ljava/util/Map; val$metaData -Lorg/elasticsearch/cluster/metadata/MetaData; val$request ;Lorg/elasticsearch/snapshots/RestoreService$RestoreRequest; val$snapshot &Lorg/elasticsearch/snapshots/Snapshot; val$listener DLorg/elasticsearch/snapshots/RestoreService$RestoreSnapshotListener; this$0 ,Lorg/elasticsearch/snapshots/RestoreService; <init>?(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 Q R U E F W G H Y I J [ K L ] M N _ O P a ()V S c d C D f this .Lorg/elasticsearch/snapshots/RestoreService$1; execute R(Lorg/elasticsearch/cluster/ClusterState;)Lorg/elasticsearch/cluster/ClusterState; metaData /()Lorg/elasticsearch/cluster/metadata/MetaData; l m B n restore p custom H(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/MetaData$Custom; r s & t entries 2()Lorg/elasticsearch/common/collect/ImmutableList; v w " x .org/elasticsearch/common/collect/ImmutableList z isEmpty ()Z | } { ~ @org/elasticsearch/snapshots/ConcurrentSnapshotExecutionException ? 2Restore process is already running in this cluster ? D(Lorg/elasticsearch/cluster/metadata/SnapshotId;Ljava/lang/String;)V S ? ? ? builder d(Lorg/elasticsearch/cluster/metadata/MetaData;)Lorg/elasticsearch/cluster/metadata/MetaData$Builder; ? ? & ? 9()Lorg/elasticsearch/cluster/block/ClusterBlocks$Builder; ? ? * ? blocks 1()Lorg/elasticsearch/cluster/block/ClusterBlocks; ? ? B ? h(Lorg/elasticsearch/cluster/block/ClusterBlocks;)Lorg/elasticsearch/cluster/block/ClusterBlocks$Builder; ? ? ( ? routingTable 2()Lorg/elasticsearch/cluster/routing/RoutingTable; ? ? B ? j(Lorg/elasticsearch/cluster/routing/RoutingTable;)Lorg/elasticsearch/cluster/routing/RoutingTable$Builder; ? ? . ? %org/elasticsearch/common/collect/Sets ? newHashSet ()Ljava/util/HashSet; ? ? ? ? ~ 9()Lorg/elasticsearch/common/collect/ImmutableMap$Builder; ? ? ? entrySet ()Ljava/util/Set; ? ? ? java/util/Set ? iterator ()Ljava/util/Iterator; ? ? ? ? java/util/Iterator ? hasNext ? } ? ? next ()Ljava/lang/Object; ? ? ? ? getValue ? ? ? java/lang/String ? checkPartial (Ljava/lang/String;)Z ? ? ? /org/elasticsearch/cluster/routing/RestoreSource ? ? ? getKey ? ? ? index F(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/IndexMetaData; ? ? & ? ,org/elasticsearch/common/hppc/IntOpenHashSet ? ? d access$100 m(Lorg/elasticsearch/snapshots/RestoreService;)Lorg/elasticsearch/cluster/metadata/MetaDataCreateIndexService; ? ? ? =org/elasticsearch/cluster/metadata/MetaDataCreateIndexService ? validateIndexName =(Ljava/lang/String;Lorg/elasticsearch/cluster/ClusterState;)V ? ? ? ? n(Lorg/elasticsearch/cluster/metadata/IndexMetaData;)Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder; ? ? ? OPEN 8Lorg/elasticsearch/cluster/metadata/IndexMetaData$State; ? ? ; ? state t(Lorg/elasticsearch/cluster/metadata/IndexMetaData$State;)Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder; ? ? ? N(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder; ? ? ? includeAliases ? } ? aliases 5()Lorg/elasticsearch/common/collect/ImmutableOpenMap; ? ? ? 1org/elasticsearch/common/collect/ImmutableOpenMap ? ? ~ removeAllAliases <()Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder; ? ? ? $org/elasticsearch/common/hppc/IntSet ? keys 7()Lorg/elasticsearch/common/hppc/ObjectLookupContainer; ? ? ? ? 3org/elasticsearch/common/hppc/ObjectLookupContainer ? ? ? 2org/elasticsearch/common/hppc/cursors/ObjectCursor ? value Ljava/lang/Object; ? add (Ljava/lang/Object;)Z ? build 4()Lorg/elasticsearch/cluster/metadata/IndexMetaData; populateIgnoredShards ;(Ljava/lang/String;Lorg/elasticsearch/common/hppc/IntSet;)V addAsNewRestore ?(Lorg/elasticsearch/cluster/metadata/IndexMetaData;Lorg/elasticsearch/cluster/routing/RestoreSource;Lorg/elasticsearch/common/hppc/IntSet;)Lorg/elasticsearch/cluster/routing/RoutingTable$Builder; , put j(Lorg/elasticsearch/cluster/metadata/IndexMetaData;Z)Lorg/elasticsearch/cluster/metadata/MetaData$Builder; $ validateExistingIndex z(Lorg/elasticsearch/cluster/metadata/IndexMetaData;Lorg/elasticsearch/cluster/metadata/IndexMetaData;Ljava/lang/String;Z)V version ()J java/lang/Math max (JJ)J "# !$ =(J)Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder; & ' values 1()Lorg/elasticsearch/common/hppc/ObjectContainer; )* ?+ -org/elasticsearch/common/hppc/ObjectContainer- . ? 0org/elasticsearch/cluster/metadata/AliasMetaData0 putAlias n(Lorg/elasticsearch/cluster/metadata/AliasMetaData;)Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder; 23 4 addAsRestore ?(Lorg/elasticsearch/cluster/metadata/IndexMetaData;Lorg/elasticsearch/cluster/routing/RestoreSource;)Lorg/elasticsearch/cluster/routing/RoutingTable$Builder; 67 ,8 <org/elasticsearch/cluster/metadata/MetaDataIndexStateService: INDEX_CLOSED_BLOCK .Lorg/elasticsearch/cluster/block/ClusterBlock; <= ;> removeIndexBlock y(Ljava/lang/String;Lorg/elasticsearch/cluster/block/ClusterBlock;)Lorg/elasticsearch/cluster/block/ClusterBlocks$Builder; @A (B getNumberOfShards ()I DE F contains (I)Z HI ?J %org/elasticsearch/index/shard/ShardIdL (Ljava/lang/String;I)V SN MO access$200 X(Lorg/elasticsearch/snapshots/RestoreService;)Lorg/elasticsearch/cluster/ClusterService; QR S (org/elasticsearch/cluster/ClusterServiceU *()Lorg/elasticsearch/cluster/ClusterState; ?W VX nodes 1()Lorg/elasticsearch/cluster/node/DiscoveryNodes; Z[ B\ -org/elasticsearch/cluster/node/DiscoveryNodes^ localNodeId ()Ljava/lang/String; `a _b (Ljava/lang/String;)V Sd 5e ](Ljava/lang/Object;Ljava/lang/Object;)Lorg/elasticsearch/common/collect/ImmutableMap$Builder; g h FAILURE :Lorg/elasticsearch/cluster/metadata/RestoreMetaData$State; jk >l O(Ljava/lang/String;Lorg/elasticsearch/cluster/metadata/RestoreMetaData$State;)V Sn 5o 1()Lorg/elasticsearch/common/collect/ImmutableMap; q r INIT tk >u keySet w ? x copyOf H(Ljava/util/Collection;)Lorg/elasticsearch/common/collect/ImmutableList; z{ {| ?(Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/cluster/metadata/RestoreMetaData$State;Lorg/elasticsearch/common/collect/ImmutableList;Lorg/elasticsearch/common/collect/ImmutableMap;)V S~ >([Lorg/elasticsearch/cluster/metadata/RestoreMetaData$Entry;)V S? "? putCustom }(Ljava/lang/String;Lorg/elasticsearch/cluster/metadata/MetaData$Custom;)Lorg/elasticsearch/cluster/metadata/MetaData$Builder; ?? $? of ?q ? checkAliasNameConflicts !(Ljava/util/Map;Ljava/util/Set;)V ?? ? restoreGlobalStateIfRequested 8(Lorg/elasticsearch/cluster/metadata/MetaData$Builder;)V ?? ? access$300 >(Lorg/elasticsearch/snapshots/RestoreService;Ljava/util/Map;)Z ?? ? 'org/elasticsearch/snapshots/RestoreInfo? name ?a ? size ?E ? access$400 >(Lorg/elasticsearch/snapshots/RestoreService;Ljava/util/Map;)I ?? ? G(Ljava/lang/String;Lorg/elasticsearch/common/collect/ImmutableList;II)V S? ?? Z(Lorg/elasticsearch/cluster/ClusterState;)Lorg/elasticsearch/cluster/ClusterState$Builder; ?? B? g(Lorg/elasticsearch/cluster/metadata/MetaData$Builder;)Lorg/elasticsearch/cluster/ClusterState$Builder; l? @? i(Lorg/elasticsearch/cluster/block/ClusterBlocks$Builder;)Lorg/elasticsearch/cluster/ClusterState$Builder; ?? @? j(Lorg/elasticsearch/cluster/routing/RoutingTable$Builder;)Lorg/elasticsearch/cluster/ClusterState$Builder; ?? @? W @? access$500 n(Lorg/elasticsearch/snapshots/RestoreService;)Lorg/elasticsearch/cluster/routing/allocation/AllocationService; ?? ? >org/elasticsearch/cluster/routing/allocation/AllocationService? reroute q(Lorg/elasticsearch/cluster/ClusterState;)Lorg/elasticsearch/cluster/routing/allocation/RoutingAllocation$Result; ?? ?? routingResult y(Lorg/elasticsearch/cluster/routing/allocation/RoutingAllocation$Result;)Lorg/elasticsearch/cluster/ClusterState$Builder; ?? @? alias HLorg/elasticsearch/common/hppc/cursors/ObjectCursor<Ljava/lang/String;>; 4Lorg/elasticsearch/common/hppc/cursors/ObjectCursor; i$ Ljava/util/Iterator; indexMdBuilder :Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder; updatedIndexMetaData 2Lorg/elasticsearch/cluster/metadata/IndexMetaData; hLorg/elasticsearch/common/hppc/cursors/ObjectCursor<Lorg/elasticsearch/cluster/metadata/AliasMetaData;>; shard I Ljava/lang/String; partial Z restoreSource 1Lorg/elasticsearch/cluster/routing/RestoreSource; renamedIndex snapshotIndexMetaData currentIndexMetaData ignoreShards &Lorg/elasticsearch/common/hppc/IntSet; indexEntry ;Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/String;>; Ljava/util/Map$Entry; shardsBuilder ?Lorg/elasticsearch/common/collect/ImmutableMap$Builder<Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/cluster/metadata/RestoreMetaData$ShardRestoreStatus;>; 7Lorg/elasticsearch/common/collect/ImmutableMap$Builder; restoreEntry :Lorg/elasticsearch/cluster/metadata/RestoreMetaData$Entry; shards ?Lorg/elasticsearch/common/collect/ImmutableMap<Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/cluster/metadata/RestoreMetaData$ShardRestoreStatus;>; /Lorg/elasticsearch/common/collect/ImmutableMap; currentState (Lorg/elasticsearch/cluster/ClusterState; restoreMetaData 4Lorg/elasticsearch/cluster/metadata/RestoreMetaData; mdBuilder 5Lorg/elasticsearch/cluster/metadata/MetaData$Builder; 7Lorg/elasticsearch/cluster/block/ClusterBlocks$Builder; rtBuilder 8Lorg/elasticsearch/cluster/routing/RoutingTable$Builder; #Ljava/util/Set<Ljava/lang/String;>; Ljava/util/Set; updatedState GLorg/elasticsearch/cluster/routing/allocation/RoutingAllocation$Result; H ?? 4org/elasticsearch/snapshots/SnapshotRestoreException? java/lang/StringBuilder? ? d cannot rename index [? append -(Ljava/lang/String;)Ljava/lang/StringBuilder; ?? ?? ] into [? 6] because of conflict with an alias with the same name? toString a ? ? ? renamedIndices 5Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>; $org/elasticsearch/snapshots/Snapshot shardFailures w { ? 0org/elasticsearch/snapshots/SnapshotShardFailure ?a equals ? shardId E I ? failure 2Lorg/elasticsearch/snapshots/SnapshotShardFailure; access$600 g(Lorg/elasticsearch/snapshots/RestoreService;Lorg/elasticsearch/snapshots/Snapshot;Ljava/lang/String;)Z ? } index [! +] wasn't fully snapshotted - cannot restore# :()Lorg/elasticsearch/cluster/metadata/IndexMetaData$State; ?% & CLOSE ( ? ;) cannot restore index [+ ] because it's open- cannot restore partial index [/ #] because such index already exists1 ] with [3 (I)Ljava/lang/StringBuilder; ?5 ?6 ] shard from snapshot with [8 ] shards: includeGlobalState < } = persistentSettings .()Lorg/elasticsearch/common/settings/Settings; ?@ &A c(Lorg/elasticsearch/common/settings/Settings;)Lorg/elasticsearch/cluster/metadata/MetaData$Builder; ?C $D templates F ? &G 8org/elasticsearch/cluster/metadata/IndexTemplateMetaDataI q(Lorg/elasticsearch/cluster/metadata/IndexTemplateMetaData;)Lorg/elasticsearch/cluster/metadata/MetaData$Builder; K $L customs N ? &O ? ? 8org/elasticsearch/common/hppc/cursors/ObjectObjectCursorR repositoriesT key V SW S cursor pLorg/elasticsearch/common/hppc/cursors/ObjectCursor<Lorg/elasticsearch/cluster/metadata/IndexTemplateMetaData;>; ?Lorg/elasticsearch/common/hppc/cursors/ObjectObjectCursor<Ljava/lang/String;Lorg/elasticsearch/cluster/metadata/MetaData$Custom;>; :Lorg/elasticsearch/common/hppc/cursors/ObjectObjectCursor; onFailure *(Ljava/lang/String;Ljava/lang/Throwable;)V access$700 Y(Lorg/elasticsearch/snapshots/RestoreService;)Lorg/elasticsearch/common/logging/ESLogger; `a b [{}] failed to restore snapshotd java/lang/Objectf )org/elasticsearch/common/logging/ESLoggerh warn =(Ljava/lang/String;Ljava/lang/Throwable;[Ljava/lang/Object;)V jk il (Ljava/lang/Throwable;)V ^n o source t Ljava/lang/Throwable; timeout +()Lorg/elasticsearch/common/unit/TimeValue; masterNodeTimeout vu w clusterStateProcessed e(Ljava/lang/String;Lorg/elasticsearch/cluster/ClusterState;Lorg/elasticsearch/cluster/ClusterState;)V onResponse ,(Lorg/elasticsearch/snapshots/RestoreInfo;)V {| } oldState newState Code LocalVariableTable LineNumberTable LocalVariableTypeTable StackMapTable Signature [(Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Ljava/util/Set<Ljava/lang/String;>;)V SourceFile EnclosingMethod InnerClasses C D E F G H I J K L M N O P Q R S T ? _ 1*+? V*,? X*-? Z*? \*? ^*? `*? b*? e*? g? ? 1 h i ? ? + ? j k ? W ?+? oq? u? "M,? ,? y? ? ? ?Y*? X?? ??+? o? ?N? ?+? ?? ?:+? ?? ?:? ?:*? Z? ? ??? ?:*? Z? ? ? ? :? ? ?[? ? ? : ? ? ? ?: * ? ?6 ? ?Y*? X ? ?: ? ? ? ?: *? \ ? ?:+? o ? ?:? ?Y? ?:? ?*? V? ? +? ?? ? ? ? ? ?:*? ^? ? ? ? ? ? ?W? 8? ? ? ? :? ? ? ? ? ? ?:?? W???? : ? * ? ?W-?W? ?* ?? ? ? ?:? ? a?%?(W*? ^? ? M? ? ? ? ?W? ?,?/ :? ? ? ? ? ? ?:??1?5W??? 8? ? ? ? :? ? ? ? ? ? ?:?? W??? ? ? : ?9W ???CW-?W6?G? o?K ? 0?MY ?P? 5Y*? V?T?Y ?]?c?f?iW? 0?MY ?P? 5Y*? V?T?Y ?]?c?m?p?iW???????s:? Y*? X?v*? Z?y ?}??:-q? "Y? YS????W? ??:**? Z??*-??*? V??? 5*??Y*? ^??*? Z?y ?}????*? V??d??? g+??-????????:*? V??????????:??????? ? L !7 ?? ! &?? ? {?? N !?? ? ?? ? '?? ?? &?? ? ??? 5 ?? U v?? ?= ?? ?5?? ?&?? ??? ??? ??? ???? ?I?? lb?? \??? ? ?? ? 8?? ? h i ??? ??? 1l?? =` ?? FW?? ??? KR ?? v '?? ? ?? ? R 7 ?? ? ?? ?? ?I?? \??? ? 8?? ??? KR ?? ? A ? ? ? ) ? 1 ? = ? F ? K ? W ? \ ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?7 ?D ?G ?N ?S ?[ ?g ?o ?r ?~ ?? ?? ?? ?? ?? ?? ?? ?? ? ?& ?) ?5 ?? ?J ?R ?_ ?k ?? ?? ?? ?? ?? ?? ? ? ? ? ?! ?- ?_ ?v ?? ?? ? ? ) "? B B " $ ( , ? ? ? ? B " $ ( , ? ? ? ? ? ? ? ?? %? ? ? H ? ?? &? ?? %? (? ? B,? B " $ ( , ? ? ? ? >? B " $ ( , ? ? L ?? ? v+? ? ? ? N-? ? ? c-? ? ? :,? ? ?? ? E??Y*? X??Y????? ? ? ??????? ? ? ??? ???????? ? 4 R?? i?? v h i v H v ?? ? R?? v v ?? ? ? ? 0 ? r ? u ?? ? ?? e? ? ? ? ? =*? `? ? N-? ? ? )-? ? ?:+??? ,?? W??? ? 4 ! /?? = h i = ?? =?? ? ? ! ? - ? 9 ? < ?? ? ?+? ? ? ? ? C*? V*? `+? ? 5*? ^? ? ???Y*? X??Y??"??+??$????? ? C h i C ?? ? ? ? ? A? % ? ?+?'?*? )??Y*? X??Y??,??-??.????? )??Y*? X??Y??0??-??2????+?G,?G? C??Y*? X??Y??,??-??4??+?G?79??,?G?7;????? ? 4 ? h i ??? ??? ??? ??? ? 0 5 [ f ?? 0*? J ?? ? l ?*? ^?>? ?*? \?B? +*? \?B?EW*? \?H? 5*? \?H?,?/ M,? ? ? ,? ? ? ?N+-??J?MW???*? \?P? D*? \?P?QM,? ? ? 0,? ? ?SNU-?X?? +-?X? ?-?Y? 8??W??? ? > M Z? : "?? ? Z] q 6?? ? h i ??? ? M Z[ ? Z\ ? 6 * M! Y" \$ f% ?& ?) ?+ ?.? ? ?? !? ?2? ^_ ? l &*? V?ce,?gY*? XS?m *? b,?p ? ? & h i &q? &rs ? 3 4 %5 tu ? 2 *? ^?x? ? h i ? 9 yz ? Z *? b*? g?~ ? ? * h i q? ? ?? ? > ? ? ? ? ? " $ & ( * , . 0 2 3 5 " 6 8 & 9 ; <@ > " <@ @ B
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de