3*,org/elasticsearch/snapshots/RestoreService$29org/elasticsearch/cluster/ProcessedClusterStateUpdateTaskRestoreService.java*org/elasticsearch/snapshots/RestoreServiceinnerUpdateRestoreStateT(Lorg/elasticsearch/snapshots/RestoreService$UpdateIndexShardRestoreStatusRequest;)V  Oorg/elasticsearch/snapshots/RestoreService$UpdateIndexShardRestoreStatusRequest $UpdateIndexShardRestoreStatusRequest8org/elasticsearch/cluster/metadata/RestoreMetaData$Entry2org/elasticsearch/cluster/metadata/RestoreMetaDataEntry3org/elasticsearch/cluster/metadata/MetaData$Builder+org/elasticsearch/cluster/metadata/MetaDataBuilderEorg/elasticsearch/cluster/metadata/RestoreMetaData$ShardRestoreStatusShardRestoreStatusDorg/elasticsearch/snapshots/RestoreService$RestoreCompletionListenerRestoreCompletionListener2org/elasticsearch/cluster/metadata/MetaData$CustomCustom8org/elasticsearch/cluster/metadata/RestoreMetaData$State!State.org/elasticsearch/cluster/ClusterState$Builder$&org/elasticsearch/cluster/ClusterState& restoreInfo)Lorg/elasticsearch/snapshots/RestoreInfo; val$requestQLorg/elasticsearch/snapshots/RestoreService$UpdateIndexShardRestoreStatusRequest;this$0,Lorg/elasticsearch/snapshots/RestoreService;(Lorg/elasticsearch/snapshots/RestoreService;Lorg/elasticsearch/snapshots/RestoreService$UpdateIndexShardRestoreStatusRequest;)V ,- 0 *+ 2()V .4 5 () 7this.Lorg/elasticsearch/snapshots/RestoreService$2;executeR(Lorg/elasticsearch/cluster/ClusterState;)Lorg/elasticsearch/cluster/ClusterState;metaData/()Lorg/elasticsearch/cluster/metadata/MetaData; => '?builderd(Lorg/elasticsearch/cluster/metadata/MetaData;)Lorg/elasticsearch/cluster/metadata/MetaData$Builder; AB CrestoreEcustomH(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/MetaData$Custom; GH I&org/elasticsearch/common/collect/ListsK newArrayList()Ljava/util/ArrayList; MN LOentries2()Lorg/elasticsearch/common/collect/ImmutableList; QR S.org/elasticsearch/common/collect/ImmutableListUiterator()Ljava/util/Iterator; WX VYjava/util/ArrayList[java/util/Iterator]hasNext()Z _` ^anext()Ljava/lang/Object; cd ^e snapshotId1()Lorg/elasticsearch/cluster/metadata/SnapshotId; gh i i-org/elasticsearch/cluster/metadata/SnapshotIdlequals(Ljava/lang/Object;)Z no mpshards1()Lorg/elasticsearch/common/collect/ImmutableMap; rs t%org/elasticsearch/common/collect/Mapsv newHashMap$(Ljava/util/Map;)Ljava/util/HashMap; xy wz access$900Y(Lorg/elasticsearch/snapshots/RestoreService;)Lorg/elasticsearch/common/logging/ESLogger; |} ~)[{}] Updating shard [{}] with status [{}]java/lang/ObjectshardId)()Lorg/elasticsearch/index/shard/ShardId; statusI()Lorg/elasticsearch/cluster/metadata/RestoreMetaData$ShardRestoreStatus; state<()Lorg/elasticsearch/cluster/metadata/RestoreMetaData$State; )org/elasticsearch/common/logging/ESLoggertrace((Ljava/lang/String;[Ljava/lang/Object;)V java/util/HashMapput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;  access$300>(Lorg/elasticsearch/snapshots/RestoreService;Ljava/util/Map;)Z STARTED:Lorg/elasticsearch/cluster/metadata/RestoreMetaData$State; "indices R -org/elasticsearch/common/collect/ImmutableMapcopyOf@(Ljava/util/Map;)Lorg/elasticsearch/common/collect/ImmutableMap; (Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/cluster/metadata/RestoreMetaData$State;Lorg/elasticsearch/common/collect/ImmutableList;Lorg/elasticsearch/common/collect/ImmutableMap;)V . add o \ access$1000 } restore [{}] is doneinfo 'org/elasticsearch/snapshots/RestoreInfo getSnapshot()Ljava/lang/String; msize()I  access$400>(Lorg/elasticsearch/snapshots/RestoreService;Ljava/util/Map;)I G(Ljava/lang/String;Lorg/elasticsearch/common/collect/ImmutableList;II)V . \toArray(([Ljava/lang/Object;)[Ljava/lang/Object; \;[Lorg/elasticsearch/cluster/metadata/RestoreMetaData$Entry;>([Lorg/elasticsearch/cluster/metadata/RestoreMetaData$Entry;)V .  putCustom}(Ljava/lang/String;Lorg/elasticsearch/cluster/metadata/MetaData$Custom;)Lorg/elasticsearch/cluster/metadata/MetaData$Builder; Z(Lorg/elasticsearch/cluster/ClusterState;)Lorg/elasticsearch/cluster/ClusterState$Builder; A 'g(Lorg/elasticsearch/cluster/metadata/MetaData$Builder;)Lorg/elasticsearch/cluster/ClusterState$Builder; = %build*()Lorg/elasticsearch/cluster/ClusterState; %Ljava/util/HashMap;Ljava/util/HashMap;entry:Lorg/elasticsearch/cluster/metadata/RestoreMetaData$Entry;i$Ljava/util/Iterator;changedZQLjava/util/ArrayList;Ljava/util/ArrayList; currentState(Lorg/elasticsearch/cluster/ClusterState;-Lorg/elasticsearch/cluster/metadata/MetaData; mdBuilder5Lorg/elasticsearch/cluster/metadata/MetaData$Builder;4Lorg/elasticsearch/cluster/metadata/RestoreMetaData; onFailure*(Ljava/lang/String;Ljava/lang/Throwable;)V access$1100 } 1[{}][{}] failed to update snapshot status to [{}]warn=(Ljava/lang/String;Ljava/lang/Throwable;[Ljava/lang/Object;)V sourceLjava/lang/String;tLjava/lang/Throwable;clusterStateProcessede(Ljava/lang/String;Lorg/elasticsearch/cluster/ClusterState;Lorg/elasticsearch/cluster/ClusterState;)Vjava/lang/Throwable access$1200Y(Lorg/elasticsearch/snapshots/RestoreService;)Ljava/util/concurrent/CopyOnWriteArrayList;   )java/util/concurrent/CopyOnWriteArrayList  Y access$1300(Lorg/elasticsearch/snapshots/RestoreService$UpdateIndexShardRestoreStatusRequest;)Lorg/elasticsearch/cluster/metadata/SnapshotId;  onRestoreCompletion[(Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/snapshots/RestoreInfo;)V  java/lang/String access$1400 } )failed to update snapshot status for [{}]elistenerFLorg/elasticsearch/snapshots/RestoreService$RestoreCompletionListener;oldStatenewStateCodeLocalVariableTableLineNumberTableLocalVariableTypeTable StackMapTable SourceFileEnclosingMethod InnerClasses ()*+,-./"B*+1*,3*6*8# 9:$ bd;<" d+@M+@DN,FJ:H6P:TZ:bf:j*3kqu{: *1Y*3kSY*3SY*3S *3*3W*1 %Yj WK*1Y*3kS*Yj  *1 d˵86 W1Y̽ҷ:-FW+-߶+#f ar E/ B%=Qd9:d_= WLE%ar %=Q$bhi jkl m%nEoWpaqrstvwy!z${,}/~4MVb&7/'\^G2"t2*1,Y*3kSY*3SY*3S# 29:22$ 1"^*8Y*1  :bCf:*3*8:*1YS);>#H@)1J^9:^^ ^!$");>@Z]&*^*''^'( )J        "#@%'