3,org/elasticsearch/snapshots/RestoreService$17org/elasticsearch/cluster/TimeoutClusterStateUpdateTaskRestoreService.java*org/elasticsearch/snapshots/RestoreServicerestoreSnapshot(Lorg/elasticsearch/snapshots/RestoreService$RestoreRequest;Lorg/elasticsearch/snapshots/RestoreService$RestoreSnapshotListener;)V  9org/elasticsearch/snapshots/RestoreService$RestoreRequest RestoreRequestBorg/elasticsearch/snapshots/RestoreService$RestoreSnapshotListenerRestoreSnapshotListener8org/elasticsearch/cluster/metadata/IndexMetaData$Builder0org/elasticsearch/cluster/metadata/IndexMetaDataBuilderjava/util/Map$Entry java/util/MapEntry5org/elasticsearch/common/collect/ImmutableMap$Builder-org/elasticsearch/common/collect/ImmutableMap8org/elasticsearch/cluster/metadata/RestoreMetaData$Entry2org/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/RoutingAllocation1ResultEorg/elasticsearch/cluster/metadata/RestoreMetaData$ShardRestoreStatus4ShardRestoreStatus2org/elasticsearch/cluster/metadata/MetaData$Custom7Custom6org/elasticsearch/cluster/metadata/IndexMetaData$State:State8org/elasticsearch/cluster/metadata/RestoreMetaData$State=.org/elasticsearch/cluster/ClusterState$Builder?&org/elasticsearch/cluster/ClusterStateA restoreInfo)Lorg/elasticsearch/snapshots/RestoreInfo;val$snapshotId/Lorg/elasticsearch/cluster/metadata/SnapshotId;val$renamedIndicesLjava/util/Map; val$metaData-Lorg/elasticsearch/cluster/metadata/MetaData; val$request;Lorg/elasticsearch/snapshots/RestoreService$RestoreRequest; val$snapshot&Lorg/elasticsearch/snapshots/Snapshot; val$listenerDLorg/elasticsearch/snapshots/RestoreService$RestoreSnapshotListener;this$0,Lorg/elasticsearch/snapshots/RestoreService;?(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 QR U EF W GH Y IJ [ KL ] MN _ OP a()V Sc d CD fthis.Lorg/elasticsearch/snapshots/RestoreService$1;executeR(Lorg/elasticsearch/cluster/ClusterState;)Lorg/elasticsearch/cluster/ClusterState;metaData/()Lorg/elasticsearch/cluster/metadata/MetaData; lm BnrestorepcustomH(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/MetaData$Custom; rs &tentries2()Lorg/elasticsearch/common/collect/ImmutableList; vw "x.org/elasticsearch/common/collect/ImmutableListzisEmpty()Z |} {~@org/elasticsearch/snapshots/ConcurrentSnapshotExecutionException2Restore process is already running in this clusterD(Lorg/elasticsearch/cluster/metadata/SnapshotId;Ljava/lang/String;)V S builderd(Lorg/elasticsearch/cluster/metadata/MetaData;)Lorg/elasticsearch/cluster/metadata/MetaData$Builder; &9()Lorg/elasticsearch/cluster/block/ClusterBlocks$Builder; *blocks1()Lorg/elasticsearch/cluster/block/ClusterBlocks; Bh(Lorg/elasticsearch/cluster/block/ClusterBlocks;)Lorg/elasticsearch/cluster/block/ClusterBlocks$Builder; ( routingTable2()Lorg/elasticsearch/cluster/routing/RoutingTable; Bj(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/Setiterator()Ljava/util/Iterator; java/util/IteratorhasNext } next()Ljava/lang/Object; getValue java/lang/String checkPartial(Ljava/lang/String;)Z /org/elasticsearch/cluster/routing/RestoreSource getKey indexF(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/IndexMetaData; &,org/elasticsearch/common/hppc/IntOpenHashSet d access$100m(Lorg/elasticsearch/snapshots/RestoreService;)Lorg/elasticsearch/cluster/metadata/MetaDataCreateIndexService; =org/elasticsearch/cluster/metadata/MetaDataCreateIndexServicevalidateIndexName=(Ljava/lang/String;Lorg/elasticsearch/cluster/ClusterState;)V n(Lorg/elasticsearch/cluster/metadata/IndexMetaData;)Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder; OPEN8Lorg/elasticsearch/cluster/metadata/IndexMetaData$State; ;statet(Lorg/elasticsearch/cluster/metadata/IndexMetaData$State;)Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder; N(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder; includeAliases } aliases5()Lorg/elasticsearch/common/collect/ImmutableOpenMap; 1org/elasticsearch/common/collect/ImmutableOpenMap ~removeAllAliases<()Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder; $org/elasticsearch/common/hppc/IntSetkeys7()Lorg/elasticsearch/common/hppc/ObjectLookupContainer; 3org/elasticsearch/common/hppc/ObjectLookupContainer 2org/elasticsearch/common/hppc/cursors/ObjectCursorvalueLjava/lang/Object;  add(Ljava/lang/Object;)Z  build4()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;  ,putj(Lorg/elasticsearch/cluster/metadata/IndexMetaData;Z)Lorg/elasticsearch/cluster/metadata/MetaData$Builder;  $validateExistingIndexz(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; & 'values1()Lorg/elasticsearch/common/hppc/ObjectContainer; )* +-org/elasticsearch/common/hppc/ObjectContainer- .0org/elasticsearch/cluster/metadata/AliasMetaData0putAliasn(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 ,8removeIndexBlocky(Ljava/lang/String;Lorg/elasticsearch/cluster/block/ClusterBlock;)Lorg/elasticsearch/cluster/block/ClusterBlocks$Builder; @A (BgetNumberOfShards()I DE Fcontains(I)Z HI J%org/elasticsearch/index/shard/ShardIdL(Ljava/lang/String;I)V SN MO access$200X(Lorg/elasticsearch/snapshots/RestoreService;)Lorg/elasticsearch/cluster/ClusterService; QR S(org/elasticsearch/cluster/ClusterServiceU*()Lorg/elasticsearch/cluster/ClusterState; W VXnodes1()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 hFAILURE:Lorg/elasticsearch/cluster/metadata/RestoreMetaData$State; jk >lO(Ljava/lang/String;Lorg/elasticsearch/cluster/metadata/RestoreMetaData$State;)V Sn 5o1()Lorg/elasticsearch/common/collect/ImmutableMap; q rINIT tk >ukeySet w xcopyOfH(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  restoreGlobalStateIfRequested8(Lorg/elasticsearch/cluster/metadata/MetaData$Builder;)V   access$300>(Lorg/elasticsearch/snapshots/RestoreService;Ljava/util/Map;)Z  'org/elasticsearch/snapshots/RestoreInfoname 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;  Bg(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$500n(Lorg/elasticsearch/snapshots/RestoreService;)Lorg/elasticsearch/cluster/routing/allocation/AllocationService;  >org/elasticsearch/cluster/routing/allocation/AllocationServicererouteq(Lorg/elasticsearch/cluster/ClusterState;)Lorg/elasticsearch/cluster/routing/allocation/RoutingAllocation$Result;   routingResulty(Lorg/elasticsearch/cluster/routing/allocation/RoutingAllocation$Result;)Lorg/elasticsearch/cluster/ClusterState$Builder;  @aliasHLorg/elasticsearch/common/hppc/cursors/ObjectCursor;4Lorg/elasticsearch/common/hppc/cursors/ObjectCursor;i$Ljava/util/Iterator;indexMdBuilder:Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder;updatedIndexMetaData2Lorg/elasticsearch/cluster/metadata/IndexMetaData;hLorg/elasticsearch/common/hppc/cursors/ObjectCursor;shardILjava/lang/String;partialZ restoreSource1Lorg/elasticsearch/cluster/routing/RestoreSource; renamedIndexsnapshotIndexMetaDatacurrentIndexMetaData ignoreShards&Lorg/elasticsearch/common/hppc/IntSet; indexEntry;Ljava/util/Map$Entry;Ljava/util/Map$Entry; shardsBuilderLorg/elasticsearch/common/collect/ImmutableMap$Builder;7Lorg/elasticsearch/common/collect/ImmutableMap$Builder; restoreEntry:Lorg/elasticsearch/cluster/metadata/RestoreMetaData$Entry;shardsLorg/elasticsearch/common/collect/ImmutableMap;/Lorg/elasticsearch/common/collect/ImmutableMap; currentState(Lorg/elasticsearch/cluster/ClusterState;restoreMetaData4Lorg/elasticsearch/cluster/metadata/RestoreMetaData; mdBuilder5Lorg/elasticsearch/cluster/metadata/MetaData$Builder;7Lorg/elasticsearch/cluster/block/ClusterBlocks$Builder; rtBuilder8Lorg/elasticsearch/cluster/routing/RoutingTable$Builder;#Ljava/util/Set;Ljava/util/Set; updatedStateGLorg/elasticsearch/cluster/routing/allocation/RoutingAllocation$Result; H 4org/elasticsearch/snapshots/SnapshotRestoreExceptionjava/lang/StringBuilder dcannot rename index [append-(Ljava/lang/String;)Ljava/lang/StringBuilder;  ] into [6] because of conflict with an alias with the same nametoString a  renamedIndices5Ljava/util/Map;$org/elasticsearch/snapshots/Snapshot shardFailures  w  {0org/elasticsearch/snapshots/SnapshotShardFailure a equals  shardId E  I failure2Lorg/elasticsearch/snapshots/SnapshotShardFailure; access$600g(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; ?@ &Ac(Lorg/elasticsearch/common/settings/Settings;)Lorg/elasticsearch/cluster/metadata/MetaData$Builder; ?C $D templates F &G8org/elasticsearch/cluster/metadata/IndexTemplateMetaDataIq(Lorg/elasticsearch/cluster/metadata/IndexTemplateMetaData;)Lorg/elasticsearch/cluster/metadata/MetaData$Builder; K $Lcustoms N &O 8org/elasticsearch/common/hppc/cursors/ObjectObjectCursorR repositoriesTkey V SW ScursorpLorg/elasticsearch/common/hppc/cursors/ObjectCursor;Lorg/elasticsearch/common/hppc/cursors/ObjectObjectCursor;:Lorg/elasticsearch/common/hppc/cursors/ObjectObjectCursor; onFailure*(Ljava/lang/String;Ljava/lang/Throwable;)V access$700Y(Lorg/elasticsearch/snapshots/RestoreService;)Lorg/elasticsearch/common/logging/ESLogger; `a b[{}] failed to restore snapshotdjava/lang/Objectf)org/elasticsearch/common/logging/ESLoggerhwarn=(Ljava/lang/String;Ljava/lang/Throwable;[Ljava/lang/Object;)V jk il(Ljava/lang/Throwable;)V ^n osourcetLjava/lang/Throwable;timeout+()Lorg/elasticsearch/common/unit/TimeValue;masterNodeTimeout vu wclusterStateProcessede(Ljava/lang/String;Lorg/elasticsearch/cluster/ClusterState;Lorg/elasticsearch/cluster/ClusterState;)V onResponse,(Lorg/elasticsearch/snapshots/RestoreInfo;)V {| }oldStatenewStateCodeLocalVariableTableLineNumberTableLocalVariableTypeTable StackMapTable Signature[(Ljava/util/Map;Ljava/util/Set;)V SourceFileEnclosingMethod InnerClasses CDEFGHIJKLMNOPQR ST_1*+V*,X*-Z*\*^*`*b*e*g 1hi +jkW +oqu"M,,yY*X+oN+:+::*Z:*Z:[:  : * 6 Y*X :  : *\ :+o :Y:*V +۲߶ :*^ W8::W : *  W-W*  ۲߶: a%(W*^M W,/: :15Wܧ8::W  : 9W ?CW-W6GoK0MY P5Y*VTY]cfiW0MY P5Y*VTY]cmpiWs: Y*Xv*Zy}:-q"Y YSW:**Z*-*V5*Y*^*Zy}*Vdg+-:*V:L!7 !&{N!' &5Uv= 5 &  I lb\8hi 1l=`FWKRv'R7  I \8KRA )1=FKW\ 7DGNS[gor~&)5?JR_k  !-_v)"B B"$(,B"$(,%H&%(B, B"$(,>B"$(,Lv+N-c-:,EY*XY4 R ivhivHv  Rvv 0ru e  =*`  N-)-:+,WԱ4! /=hi==!-9<  +C*V*`+5*^ Y*XY"+$ChiCA%+'*)Y*XY,-.)Y*XY0-2+G,GCY*XY,-4+G79,G7;4hi  05[f0*Jl*^>*\B+*\BEW*\H5*\H,/M,,N+-JMW*\PD*\PQM,0,SNU-X+-X-Y8Wͱ>M Z:" Z]q6hiM Z[ Z\6   * M!Y"\$f%&)+. !2^_l&*Vce,gY*XSm*b,p &hi&q&rs34%5tu2*^x hi9yzZ*b*g~*hiq > ?       " $& (* ,. 023 5"6 8&9 ;<@>"<@@B