33*org/elasticsearch/snapshots/RestoreService4org/elasticsearch/common/component/AbstractComponent.org/elasticsearch/cluster/ClusterStateListenerRestoreService.javaKorg/elasticsearch/snapshots/RestoreService$UpdateRestoreStateRequestHandler UpdateRestoreStateRequestHandlerOorg/elasticsearch/snapshots/RestoreService$UpdateIndexShardRestoreStatusRequest $UpdateIndexShardRestoreStatusRequestDorg/elasticsearch/snapshots/RestoreService$RestoreCompletionListenerRestoreCompletionListenerBorg/elasticsearch/snapshots/RestoreService$RestoreSnapshotListenerRestoreSnapshotListener9org/elasticsearch/snapshots/RestoreService$RestoreRequestRestoreRequest,org/elasticsearch/snapshots/RestoreService$2,org/elasticsearch/snapshots/RestoreService$1Eorg/elasticsearch/cluster/metadata/RestoreMetaData$ShardRestoreStatus2org/elasticsearch/cluster/metadata/RestoreMetaDataShardRestoreStatusjava/util/Map$Entry  java/util/Map"Entry8org/elasticsearch/cluster/metadata/RestoreMetaData$Entry%8org/elasticsearch/cluster/metadata/RestoreMetaData$State'State2org/elasticsearch/cluster/metadata/MetaData$Custom*+org/elasticsearch/cluster/metadata/MetaData,CustomUPDATE_RESTORE_ACTION_NAMELjava/lang/String;(internal:cluster/snapshot/update_restore1clusterService*Lorg/elasticsearch/cluster/ClusterService;repositoriesService4Lorg/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/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/CopyOnWriteArrayListF()V @H GI => K 34 M 56 O 78 Q 9: S ;< U](Lorg/elasticsearch/snapshots/RestoreService;Lorg/elasticsearch/snapshots/RestoreService$1;)V @W X,org/elasticsearch/transport/TransportServiceZregisterHandlerJ(Ljava/lang/String;Lorg/elasticsearch/transport/TransportRequestHandler;)V \] [^(org/elasticsearch/cluster/ClusterService`add3(Lorg/elasticsearch/cluster/ClusterStateListener;)V bc adthis,Lorg/elasticsearch/snapshots/RestoreService;settings,Lorg/elasticsearch/common/settings/Settings;restoreSnapshot(Lorg/elasticsearch/snapshots/RestoreService$RestoreRequest;Lorg/elasticsearch/snapshots/RestoreService$RestoreSnapshotListener;)Vjava/lang/Throwablel repository()Ljava/lang/String; no p2org/elasticsearch/repositories/RepositoriesServicer?(Ljava/lang/String;)Lorg/elasticsearch/repositories/Repository; nt su-org/elasticsearch/cluster/metadata/SnapshotIdwname yo z'(Ljava/lang/String;Ljava/lang/String;)V @| x})org/elasticsearch/repositories/Repository readSnapshotW(Lorg/elasticsearch/cluster/metadata/SnapshotId;)Lorg/elasticsearch/snapshots/Snapshot; $org/elasticsearch/snapshots/Snapshotindices2()Lorg/elasticsearch/common/collect/ImmutableList; ()[Ljava/lang/String; indicesOptions3()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; validateSnapshotRestorableX(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 @ submitStateUpdateTaskG(Ljava/lang/String;Lorg/elasticsearch/cluster/ClusterStateUpdateTask;)V alogger+Lorg/elasticsearch/common/logging/ESLogger; #[{}][{}] failed to restore snapshotjava/lang/Object)org/elasticsearch/common/logging/ESLoggerwarn=(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;filteredIndicesDLorg/elasticsearch/common/collect/ImmutableList;0Lorg/elasticsearch/common/collect/ImmutableList;metaData-Lorg/elasticsearch/cluster/metadata/MetaData;5Ljava/util/Map;Ljava/util/Map;eLjava/lang/Throwable;request;Lorg/elasticsearch/snapshots/RestoreService$RestoreRequest;listenerDLorg/elasticsearch/snapshots/RestoreService$RestoreSnapshotListener;indexShardRestoreCompletedY(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/ClusterStatenodes1()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 innerUpdateRestoreStateT(Lorg/elasticsearch/snapshots/RestoreService$UpdateIndexShardRestoreStatusRequest;)V  masterNode0()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;)Zvalues()Ljava/util/Collection;  #java/util/Collectioniterator()Ljava/util/Iterator;  java/util/IteratorhasNext   next()Ljava/lang/Object; "# $<()Lorg/elasticsearch/cluster/metadata/RestoreMetaData$State; & '  ()statusGLorg/elasticsearch/cluster/metadata/RestoreMetaData$ShardRestoreStatus;i$Ljava/util/Iterator;shardsLjava/util/Map; failedShards(Ljava/util/Map;)IFAILURE 3 (4I%org/elasticsearch/common/collect/Maps7 newHashMap()Ljava/util/HashMap; 9: 8;.org/elasticsearch/common/collect/ImmutableList= >java/lang/String@renameReplacement Bo C renamePattern Eo F replaceAll8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; HI AJput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; LM #N4org/elasticsearch/snapshots/SnapshotRestoreExceptionPjava/lang/StringBuilderR SI indices [Uappend-(Ljava/lang/String;)Ljava/lang/StringBuilder; WX SY] and [[#] are renamed into the same index []]_toString ao SbD(Lorg/elasticsearch/cluster/metadata/SnapshotId;Ljava/lang/String;)V @d Qe renamedIndex previousIndexindex-()Lorg/elasticsearch/snapshots/SnapshotState; j k)org/elasticsearch/snapshots/SnapshotStatem restorable o npunsupported snapshot state [r-(Ljava/lang/Object;)Ljava/lang/StringBuilder; Wt Suorg/elasticsearch/VersionwCURRENTLorg/elasticsearch/Version; yz x{version()Lorg/elasticsearch/Version; }~ before(Lorg/elasticsearch/Version;)Z  x5the snapshot was created with Elasticsearch version [1] which is higher than the version of this node [processDeletedIndices2(Lorg/elasticsearch/cluster/ClusterChangedEvent;)V-org/elasticsearch/cluster/ClusterChangedEvent /()Lorg/elasticsearch/cluster/metadata/MetaData;  restorecustomH(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/MetaData$Custom;  -indicesDeleted()Ljava/util/List;  java/util/ListisEmpty  entries  1()Lorg/elasticsearch/common/collect/ImmutableMap; / &-org/elasticsearch/common/collect/ImmutableMapentrySet1()Lorg/elasticsearch/common/collect/ImmutableSet;  -org/elasticsearch/common/collect/ImmutableSet getValue # !getKey # !%org/elasticsearch/index/shard/ShardIdgetIndex 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 deleteda(Ljava/lang/String;Lorg/elasticsearch/cluster/metadata/RestoreMetaData$State;Ljava/lang/String;)V @ shardLjava/util/Map$Entry;Ljava/util/Map$Entry; shardsToFail9Ljava/util/List;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 io equals  Afailure2Lorg/elasticsearch/snapshots/SnapshotShardFailure; addListenerI(Lorg/elasticsearch/snapshots/RestoreService$RestoreCompletionListener;)V GFLorg/elasticsearch/snapshots/RestoreService$RestoreCompletionListener;removeListenerremove  GclusterChanged   Failed to update restore state tisRepositoryInUse=(Lorg/elasticsearch/cluster/ClusterState;Ljava/lang/String;)Z getRepository o x clusterState(Lorg/elasticsearch/cluster/ClusterState; snapshots access$100m(Lorg/elasticsearch/snapshots/RestoreService;)Lorg/elasticsearch/cluster/metadata/MetaDataCreateIndexService;x0 access$200X(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$500n(Lorg/elasticsearch/snapshots/RestoreService;)Lorg/elasticsearch/cluster/routing/allocation/AllocationService; access$600g(Lorg/elasticsearch/snapshots/RestoreService;Lorg/elasticsearch/snapshots/Snapshot;Ljava/lang/String;)Z  x2 access$700Y(Lorg/elasticsearch/snapshots/RestoreService;)Lorg/elasticsearch/common/logging/ESLogger; access$900 access$1000 access$1100 access$1200Y(Lorg/elasticsearch/snapshots/RestoreService;)Ljava/util/concurrent/CopyOnWriteArrayList; access$1400 access$1600 ConstantValue SignatureCodeLocalVariableTableLineNumberTableRuntimeVisibleAnnotationsLocalVariableTypeTable StackMapTable(Ljava/util/Map;)Z(Ljava/util/Map;)I(Lorg/elasticsearch/snapshots/RestoreService$RestoreRequest;Lorg/elasticsearch/common/collect/ImmutableList;)Ljava/util/Map; SourceFile InnerClasses!/0&23456789:;<=>'?@A(D*+E*GYJL*,N*-P*R*T*V2 Y*Y_,*e)HDfgDhiD34D56D78D9:D;<** a]bcd e&f,g<hCi+Bjk( *P+qvNxY+q+{~:-:++:-:**+:*N+Y*+,)N*-Y+qSY+{S,-wzm)f knZ'P;<G0X{%fg,;<X*6 t uv'w;xG{O~XwFzC{DEG- zm%(r*Y+SY,S Y+,Y*NN*N *-*R*N2-)*rfgrr  ;7 *QR;TMUUWqZ- U (N*N Y*+)fg * b(0+M,!,%N-(*)* +, "-.0fg0/, 0/0*)+.-  '.12(5=+N-!-%:(5)4"+,%-.5fg5/316, 5/0*"-03- !'/(r  W-.FC--.fg,iFF*V$CFi|-5 -%&L! V(s*Y+SY,S Y+,Y*N5N*N *-*R*N2-)*sfgss  <7 *<NVr- V (1+?N-!-%:,)4 %-.1fg11i0**,/-  !(B *L+W) fg *  (B *L+W) fg *   ("+*+M*, m) "fg"*%& *()!+- Bm (I*M,N-6-?:!#%&:+̶)>3*-.IIn0D9*"567839B:D<G>--& (/*V)  g*O  (/*N)  g*O (:*+) g*O(:*+) g*O(/*T)  g*O(E*+,)  g0*O(/*)  g*O(/*)  g*O (/*)  g*O!(/*)  g*O"#(/*L)  g*O$(/*)  g*O%(:*+) g *O12b        !#$ &$ ()@+-.