3,org/elasticsearch/snapshots/SnapshotsServiceLorg/elasticsearch/common/component/AbstractLifecycleComponent;Lorg/elasticsearch/cluster/ClusterStateListener;=org/elasticsearch/common/component/AbstractLifecycleComponent.org/elasticsearch/cluster/ClusterStateListenerSnapshotsService.javaNorg/elasticsearch/snapshots/SnapshotsService$UpdateSnapshotStateRequestHandler !UpdateSnapshotStateRequestHandlerRorg/elasticsearch/snapshots/SnapshotsService$UpdateIndexShardSnapshotStatusRequest %UpdateIndexShardSnapshotStatusRequest;org/elasticsearch/snapshots/SnapshotsService$SnapshotShardsSnapshotShards5org/elasticsearch/common/collect/ImmutableMap$Builder@-org/elasticsearch/common/collect/ImmutableMapBGorg/elasticsearch/cluster/metadata/SnapshotMetaData$ShardSnapshotStatusDShardSnapshotStatusjava/util/Map$EntryG java/util/MapI2org/elasticsearch/cluster/metadata/MetaData$CustomKCustom@org/elasticsearch/index/snapshots/IndexShardSnapshotStatus$StageN:org/elasticsearch/index/snapshots/IndexShardSnapshotStatusPStage9org/elasticsearch/cluster/metadata/SnapshotMetaData$StateSState3org/elasticsearch/cluster/node/DiscoveryNodes$DeltaV-org/elasticsearch/cluster/node/DiscoveryNodesXDeltaUPDATE_SNAPSHOT_ACTION_NAMELjava/lang/String;)internal:cluster/snapshot/update_snapshot]clusterService*Lorg/elasticsearch/cluster/ClusterService;repositoriesService4Lorg/elasticsearch/repositories/RepositoriesService; threadPool)Lorg/elasticsearch/threadpool/ThreadPool;indicesService*Lorg/elasticsearch/indices/IndicesService;transportService.Lorg/elasticsearch/transport/TransportService;shardSnapshots/Lorg/elasticsearch/common/collect/ImmutableMap;Lorg/elasticsearch/common/collect/ImmutableMap; shutdownLock!Ljava/util/concurrent/locks/Lock;shutdownCondition&Ljava/util/concurrent/locks/Condition;snapshotCompletionListeners+Ljava/util/concurrent/CopyOnWriteArrayList;vLjava/util/concurrent/CopyOnWriteArrayList;(Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/cluster/ClusterService;Lorg/elasticsearch/repositories/RepositoriesService;Lorg/elasticsearch/threadpool/ThreadPool;Lorg/elasticsearch/indices/IndicesService;Lorg/elasticsearch/transport/TransportService;)V(Lorg/elasticsearch/common/inject/Inject;/(Lorg/elasticsearch/common/settings/Settings;)V sv wof1()Lorg/elasticsearch/common/collect/ImmutableMap; yz C{ ij }(java/util/concurrent/locks/ReentrantLock()V s lm java/util/concurrent/locks/Lock newCondition(()Ljava/util/concurrent/locks/Condition; no )java/util/concurrent/CopyOnWriteArrayList pq  _`  ab  cd  ef  gh a(Lorg/elasticsearch/snapshots/SnapshotsService;Lorg/elasticsearch/snapshots/SnapshotsService$1;)V s ,org/elasticsearch/transport/TransportServiceregisterHandlerJ(Ljava/lang/String;Lorg/elasticsearch/transport/TransportRequestHandler;)V (org/elasticsearch/cluster/ClusterServiceaddLast3(Lorg/elasticsearch/cluster/ClusterStateListener;)V this.Lorg/elasticsearch/snapshots/SnapshotsService;settings,Lorg/elasticsearch/common/settings/Settings;snapshotW(Lorg/elasticsearch/cluster/metadata/SnapshotId;)Lorg/elasticsearch/snapshots/Snapshot;-org/elasticsearch/cluster/metadata/SnapshotId getRepository()Ljava/lang/String; 2org/elasticsearch/repositories/RepositoriesService repository?(Ljava/lang/String;)Lorg/elasticsearch/repositories/Repository; )org/elasticsearch/repositories/Repository readSnapshot  snapshotId/Lorg/elasticsearch/cluster/metadata/SnapshotId; snapshotsD(Ljava/lang/String;)Lorg/elasticsearch/common/collect/ImmutableList;&org/elasticsearch/common/collect/Lists newArrayList()Ljava/util/ArrayList; 2()Lorg/elasticsearch/common/collect/ImmutableList; iterator()Ljava/util/Iterator; ?java/lang/Stringjava/util/ArrayListjava/util/IteratorhasNext()Z next()Ljava/lang/Object; add(Ljava/lang/Object;)Z %org/apache/lucene/util/CollectionUtiltimSort(Ljava/util/List;)V copyOfH(Ljava/util/Collection;)Lorg/elasticsearch/common/collect/ImmutableList; ?i$Ljava/util/Iterator;repositoryName snapshotList=Ljava/util/ArrayList;Ljava/util/ArrayList;+Lorg/elasticsearch/repositories/Repository; snapshotIdsaLorg/elasticsearch/common/collect/ImmutableList;0Lorg/elasticsearch/common/collect/ImmutableList;createSnapshot(Lorg/elasticsearch/snapshots/SnapshotsService$SnapshotRequest;Lorg/elasticsearch/snapshots/SnapshotsService$CreateSnapshotListener;)V name '(Ljava/lang/String;Ljava/lang/String;)V s cause  (Lorg/elasticsearch/snapshots/SnapshotsService;Lorg/elasticsearch/snapshots/SnapshotsService$SnapshotRequest;Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/snapshots/SnapshotsService$CreateSnapshotListener;)V s 1submitStateUpdateTaskG(Ljava/lang/String;Lorg/elasticsearch/cluster/ClusterStateUpdateTask;)V    request>Lorg/elasticsearch/snapshots/SnapshotsService$SnapshotRequest;listenerELorg/elasticsearch/snapshots/SnapshotsService$CreateSnapshotListener;validatei(Lorg/elasticsearch/snapshots/SnapshotsService$SnapshotRequest;Lorg/elasticsearch/cluster/ClusterState;)V(org/elasticsearch/ElasticsearchException&org/elasticsearch/cluster/ClusterState getMetaData/()Lorg/elasticsearch/cluster/metadata/MetaData;   repositoriescustomH(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/MetaData$Custom;  : 7org/elasticsearch/cluster/metadata/RepositoriesMetaData"K(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/RepositoryMetaData; $ #%9org/elasticsearch/repositories/RepositoryMissingException'(Ljava/lang/String;)V s) (* org/elasticsearch/common/Strings, hasLength(Ljava/lang/String;)Z ./ -08org/elasticsearch/snapshots/InvalidSnapshotNameException2cannot be empty4D(Lorg/elasticsearch/cluster/metadata/SnapshotId;Ljava/lang/String;)V s6 37 9contains(Ljava/lang/CharSequence;)Z ;< =must not contain whitespace?,Amust not contain ','C#Emust not contain '#'GcharAt(I)C IJ Kmust not start with '_'Mjava/util/LocaleOROOTLjava/util/Locale; QR PS toLowerCase&(Ljava/util/Locale;)Ljava/lang/String; UV Wequals Y Zmust be lowercase\ validFileName ^/ -_java/lang/StringBuildera b*must not contain the following characters dappend-(Ljava/lang/String;)Ljava/lang/StringBuilder; fg bhINVALID_FILENAME_CHARS/Lorg/elasticsearch/common/collect/ImmutableSet; jk -l-(Ljava/lang/Object;)Ljava/lang/StringBuilder; fn botoString q brstate(Lorg/elasticsearch/cluster/ClusterState;repositoriesMetaData9Lorg/elasticsearch/cluster/metadata/RepositoriesMetaData; beginSnapshot(Lorg/elasticsearch/cluster/ClusterState;Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$Entry;ZLorg/elasticsearch/snapshots/SnapshotsService$CreateSnapshotListener;)Vjava/lang/Throwablez1()Lorg/elasticsearch/cluster/metadata/SnapshotId; | 3}metaData  includeGlobalState  3builder7()Lorg/elasticsearch/cluster/metadata/MetaData$Builder;  :indices  3indexF(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/IndexMetaData;  :putj(Lorg/elasticsearch/cluster/metadata/IndexMetaData;Z)Lorg/elasticsearch/cluster/metadata/MetaData$Builder;  8build  8initializeSnapshot(Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/common/collect/ImmutableList;Lorg/elasticsearch/cluster/metadata/MetaData;)V  isEmpty  ? onResponse   endSnapshot>(Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$Entry;)V  update_snapshot [](Lorg/elasticsearch/snapshots/SnapshotsService;Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$Entry;ZLorg/elasticsearch/snapshots/SnapshotsService$CreateSnapshotListener;)V s /logger+Lorg/elasticsearch/common/logging/ESLogger;  failed to create snapshot [{}]java/lang/Object)org/elasticsearch/common/logging/ESLoggerwarn=(Ljava/lang/String;Ljava/lang/Throwable;[Ljava/lang/Object;)V  removeSnapshotFromClusterStateq(Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/snapshots/SnapshotInfo;Ljava/lang/Throwable;)V  "org/elasticsearch/ExceptionsHelperdetailedMessage)(Ljava/lang/Throwable;)Ljava/lang/String;   y ?finalizeSnapshot(Lorg/elasticsearch/cluster/metadata/SnapshotId;Ljava/lang/String;ILorg/elasticsearch/common/collect/ImmutableList;)Lorg/elasticsearch/snapshots/Snapshot;  +[{}] failed to close snapshot in repository((Ljava/lang/String;[Ljava/lang/Object;)V   onFailure(Ljava/lang/Throwable;)V  5Lorg/elasticsearch/cluster/metadata/MetaData$Builder;-Lorg/elasticsearch/cluster/metadata/MetaData;t2Ljava/lang/Throwable;t clusterState;Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$Entry;partialZuserCreateSnapshotListenersnapshotCreatedcurrentSnapshotsW(Ljava/lang/String;[Ljava/lang/String;)Lorg/elasticsearch/common/collect/ImmutableList;*()Lorg/elasticsearch/cluster/ClusterState; t entries  5_allsize()I  ?get(I)Ljava/lang/Object;  ?[Ljava/lang/String; getSnapshot  :()Lorg/elasticsearch/common/collect/ImmutableList$Builder;  ?L(Ljava/lang/Object;)Lorg/elasticsearch/common/collect/ImmutableList$Builder;  =  =arr$len$IentrysnapshotMetaData5Lorg/elasticsearch/cluster/metadata/SnapshotMetaData;uLorg/elasticsearch/common/collect/ImmutableList$Builder;8Lorg/elasticsearch/common/collect/ImmutableList$Builder;currentSnapshotShards`(Lorg/elasticsearch/cluster/metadata/SnapshotId;)Lorg/elasticsearch/common/collect/ImmutableMap;&(Ljava/lang/Object;)Ljava/lang/Object;  C  access$1600n(Lorg/elasticsearch/snapshots/SnapshotsService$SnapshotShards;)Lorg/elasticsearch/common/collect/ImmutableMap;    snapshotShards=Lorg/elasticsearch/snapshots/SnapshotsService$SnapshotShards;9()Lorg/elasticsearch/common/collect/ImmutableMap$Builder;  CindexShardRepositoryL(Ljava/lang/String;)Lorg/elasticsearch/index/snapshots/IndexShardRepository;  $org/elasticsearch/snapshots/Snapshot readSnapshotMetaData(Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/common/collect/ImmutableList;)Lorg/elasticsearch/cluster/metadata/MetaData;  6org/elasticsearch/index/snapshots/IndexShardRepository5()Lorg/elasticsearch/common/collect/ImmutableOpenMap; ! :"1org/elasticsearch/common/collect/ImmutableOpenMap$ % 0org/elasticsearch/cluster/metadata/IndexMetaData'getNumberOfShards ) (*%org/elasticsearch/index/shard/ShardId,(Ljava/lang/String;I)V s. -/ shardFailures 1 2findShardFailure(Lorg/elasticsearch/common/collect/ImmutableList;Lorg/elasticsearch/index/shard/ShardId;)Lorg/elasticsearch/snapshots/SnapshotShardFailure; 45 6 QFAILUREBLorg/elasticsearch/index/snapshots/IndexShardSnapshotStatus$Stage; 9: O; updateStageE(Lorg/elasticsearch/index/snapshots/IndexShardSnapshotStatus$Stage;)V => Q?0org/elasticsearch/snapshots/SnapshotShardFailureAreason C BDfailure F) QG](Ljava/lang/Object;Ljava/lang/Object;)Lorg/elasticsearch/common/collect/ImmutableMap$Builder; I AJsnapshotStatus(Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/index/shard/ShardId;)Lorg/elasticsearch/index/snapshots/IndexShardSnapshotStatus; LM  N z APshardSnapshotStatus;7Lorg/elasticsearch/common/collect/ImmutableMap$Builder;8Lorg/elasticsearch/index/snapshots/IndexShardRepository;&Lorg/elasticsearch/snapshots/Snapshot;getIndex a -b  BdgetId f -g T BidLorg/elasticsearch/common/collect/ImmutableList;clusterChanged2(Lorg/elasticsearch/cluster/ClusterChangedEvent;)V-org/elasticsearch/cluster/ClusterChangedEventnlocalNodeMaster p oq nodesRemoved s otprocessSnapshotsOnRemovedNodes vm wroutingTableChanged y ozprocessStartedShards |m } previousState  o oprocessIndexShardSnapshots8(Lorg/elasticsearch/cluster/metadata/SnapshotMetaData;)V   5Z Failed to update snapshot state prevcurrevent/Lorg/elasticsearch/cluster/ClusterChangedEvent;removedNodesCleanupNeeded2(Lorg/elasticsearch/cluster/ClusterChangedEvent;)Z  nodes1()Lorg/elasticsearch/cluster/node/DiscoveryNodes;   Yq(update snapshot state after node removal2(Lorg/elasticsearch/snapshots/SnapshotsService;Z)V s - newMaster waitingShardsStartedOrUnassigned  *update snapshot state after shards started1(Lorg/elasticsearch/snapshots/SnapshotsService;)V s +processWaitingShards(Lorg/elasticsearch/common/collect/ImmutableMap;Lorg/elasticsearch/cluster/routing/RoutingTable;)Lorg/elasticsearch/common/collect/ImmutableMap;entrySet1()Lorg/elasticsearch/common/collect/ImmutableSet;  C-org/elasticsearch/common/collect/ImmutableSet getValue  H=()Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$State; t EWAITING;Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$State;  TgetKey  H.org/elasticsearch/cluster/routing/RoutingTableI(Ljava/lang/String;)Lorg/elasticsearch/cluster/routing/IndexRoutingTable;  id  -3org/elasticsearch/cluster/routing/IndexRoutingTableshard=(I)Lorg/elasticsearch/cluster/routing/IndexShardRoutingTable;  8org/elasticsearch/cluster/routing/IndexShardRoutingTable primaryShard2()Lorg/elasticsearch/cluster/routing/ShardRouting;  .org/elasticsearch/cluster/routing/ShardRoutingstarted  9starting shard that we were waiting for [{}] on node [{}]nodeId  Etrace   currentNodeId   E* initializing   relocating  N(Ljava/util/Map$Entry;)Lorg/elasticsearch/common/collect/ImmutableMap$Builder;  A7failing snapshot of shard [{}] on unassigned shard [{}]FAILED  Tshard is unassignedb(Ljava/lang/String;Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$State;Ljava/lang/String;)V s E shardRouting:Lorg/elasticsearch/cluster/routing/IndexShardRoutingTable;indexShardRoutingTable5Lorg/elasticsearch/cluster/routing/IndexRoutingTable; shardStatusILorg/elasticsearch/cluster/metadata/SnapshotMetaData$ShardSnapshotStatus; shardEntryLjava/util/Map$Entry;Ljava/util/Map$Entry;Lorg/elasticsearch/common/collect/ImmutableMap; routingTable0Lorg/elasticsearch/cluster/routing/RoutingTable;snapshotChangedshardsLorg/elasticsearch/common/collect/ImmutableMap$Builder; 3STARTED  TwaitingIndices z 3 CkeySet   C indexRoutingTableChanged  / ogetRoutingTable2()Lorg/elasticsearch/cluster/routing/RoutingTable;   unassigned  0Lorg/elasticsearch/cluster/routing/ShardRouting;SUCCESS  TINIT  T nodesDelta7()Lorg/elasticsearch/cluster/node/DiscoveryNodes$Delta;  o  removedNodes " W#,org/elasticsearch/cluster/node/DiscoveryNode% z 3' completed ) T* f &,node.Lorg/elasticsearch/cluster/node/DiscoveryNode;%org/elasticsearch/common/collect/Maps0 newHashMap()Ljava/util/HashMap; 23 14l(Lorg/elasticsearch/cluster/metadata/SnapshotId;)Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$Entry; 6 578(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; 9 J: localNode0()Lorg/elasticsearch/cluster/node/DiscoveryNode; <= >  &@ containsKey B CC [{}] - Adding shard to the queueE JputAllH(Ljava/util/Map;)Lorg/elasticsearch/common/collect/ImmutableMap$Builder; HI AJb(Lorg/elasticsearch/common/collect/ImmutableMap;Lorg/elasticsearch/snapshots/SnapshotsService$1;)V sL M@(Ljava/util/Map;)Lorg/elasticsearch/common/collect/ImmutableMap; O CPABORTED R TSabort U QVlock X Y$java/util/concurrent/locks/Condition[ signalAll ] \^unlock ` a()Ljava/util/Set; c Jd java/util/Setf g(org/elasticsearch/indices/IndicesServiceiindexServiceSafeB(Ljava/lang/String;)Lorg/elasticsearch/index/service/IndexService; kl jm,org/elasticsearch/index/service/IndexServiceoshardInjectorSafe-(I)Lorg/elasticsearch/common/inject/Injector; qr psEorg/elasticsearch/index/snapshots/IndexShardSnapshotAndRestoreServiceu(org/elasticsearch/common/inject/Injectorw getInstance%(Ljava/lang/Class;)Ljava/lang/Object; yz x{'org/elasticsearch/threadpool/ThreadPool~executor3(Ljava/lang/String;)Ljava/util/concurrent/Executor;  (Lorg/elasticsearch/snapshots/SnapshotsService;Lorg/elasticsearch/index/snapshots/IndexShardSnapshotAndRestoreService;Ljava/util/Map$Entry;Ljava/util/Map$Entry;Ljava/lang/String;)V s )java/util/concurrent/Executorexecute(Ljava/lang/Runnable;)V  (Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$ShardSnapshotStatus;Lorg/elasticsearch/snapshots/SnapshotsService$1;)V s updateIndexShardSnapshotStatusW(Lorg/elasticsearch/snapshots/SnapshotsService$UpdateIndexShardSnapshotStatusRequest;)V  Ljava/util/Map$Entry; startedShardstLjava/util/Map;Ljava/util/Map;shardSnapshotServiceGLorg/elasticsearch/index/snapshots/IndexShardSnapshotAndRestoreService;zLjava/util/Map$Entry;Ljava/util/Map$Entry;>; survivors}Ljava/util/Map; newSnapshotsLjava/util/Map;>; localNodeIdinnerUpdateSnapshotState   masterNode = Y9org/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  )[{}] [{}] failed to update snapshot state }statusK()Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$ShardSnapshotStatus;  TLorg/elasticsearch/snapshots/SnapshotsService$UpdateIndexShardSnapshotStatusRequest;(Ljava/util/Collection;)Zjava/util/Collection aLjava/util/Collection;Ljava/util/Collection;indicesWithMissingShards@(Lorg/elasticsearch/common/collect/ImmutableMap;)Ljava/util/Set;MISSING  T%org/elasticsearch/common/collect/Sets newHashSet()Ljava/util/HashSet;   g#Ljava/util/Set;Ljava/util/Set;update snapshot state(Lorg/elasticsearch/snapshots/SnapshotsService;Lorg/elasticsearch/snapshots/SnapshotsService$UpdateIndexShardSnapshotStatusRequest;)V s 'P(Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$Entry;Ljava/lang/String;)V  ~(Lorg/elasticsearch/snapshots/SnapshotsService;Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$Entry;Ljava/lang/String;)V s %remove snapshot metadata(Lorg/elasticsearch/snapshots/SnapshotsService;Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/snapshots/SnapshotInfo;Ljava/lang/Throwable;)V s #*Lorg/elasticsearch/snapshots/SnapshotInfo;deleteSnapshotw(Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/snapshots/SnapshotsService$DeleteSnapshotListener;)Vdelete snapshot(Lorg/elasticsearch/snapshots/SnapshotsService;Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/snapshots/SnapshotsService$DeleteSnapshotListener;)V s !ELorg/elasticsearch/snapshots/SnapshotsService$DeleteSnapshotListener;isRepositoryInUse=(Lorg/elasticsearch/cluster/ClusterState;Ljava/lang/String;)ZdeleteSnapshotFromRepository (Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/cluster/ClusterState;Lorg/elasticsearch/common/collect/ImmutableList;)Lorg/elasticsearch/common/collect/ImmutableMap; Y (assignedToNode  primary shard is not allocatedgetNodes  smallestVersion()Lorg/elasticsearch/Version;  Yorg/elasticsearch/VersionV_1_2_0Lorg/elasticsearch/Version;   onOrAfter(Lorg/elasticsearch/Version;)Z  P(Ljava/lang/String;Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$State;)V s E%primary shard hasn't been started yetmissing routing tableprimaryindexRoutingTableDLorg/elasticsearch/common/collect/ImmutableList; addListenerL(Lorg/elasticsearch/snapshots/SnapshotsService$SnapshotCompletionListener;)V ILorg/elasticsearch/snapshots/SnapshotsService$SnapshotCompletionListener;removeListenerremove  doStartdoStopjava/lang/InterruptedExceptionjava/util/concurrent/TimeUnitSECONDSLjava/util/concurrent/TimeUnit;  await#(JLjava/util/concurrent/TimeUnit;)Z !" \#java/lang/Thread% currentThread()Ljava/lang/Thread; '( &) interrupt + &,ex Ljava/lang/InterruptedException;doClose access$100(Lorg/elasticsearch/snapshots/SnapshotsService;Lorg/elasticsearch/snapshots/SnapshotsService$SnapshotRequest;Lorg/elasticsearch/cluster/ClusterState;)V  3x0x1x2 access$200[(Lorg/elasticsearch/snapshots/SnapshotsService;)Lorg/elasticsearch/common/logging/ESLogger; access$300 access$600(Lorg/elasticsearch/snapshots/SnapshotsService;Lorg/elasticsearch/cluster/ClusterState;Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$Entry;ZLorg/elasticsearch/snapshots/SnapshotsService$CreateSnapshotListener;)V xy =x3x4 access$700Y(Lorg/elasticsearch/snapshots/SnapshotsService;)Lorg/elasticsearch/threadpool/ThreadPool; access$800(Lorg/elasticsearch/snapshots/SnapshotsService;Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/cluster/ClusterState;Lorg/elasticsearch/common/collect/ImmutableList;)Lorg/elasticsearch/common/collect/ImmutableMap;  E access$900n(Lorg/elasticsearch/snapshots/SnapshotsService;Lorg/elasticsearch/common/collect/ImmutableMap;)Ljava/util/Set;  I access$1000G(Lorg/elasticsearch/snapshots/SnapshotsService;Ljava/util/Collection;)Z ) M access$1100 access$1200 access$1300d(Lorg/elasticsearch/snapshots/SnapshotsService;)Lorg/elasticsearch/repositories/RepositoriesService; access$1400 access$1500 access$1700 access$1800l(Lorg/elasticsearch/snapshots/SnapshotsService;Lorg/elasticsearch/cluster/metadata/SnapshotMetaData$Entry;)V access$1900 access$2000 access$2100 access$2200(Lorg/elasticsearch/snapshots/SnapshotsService;Lorg/elasticsearch/common/collect/ImmutableMap;Lorg/elasticsearch/cluster/routing/RoutingTable;)Lorg/elasticsearch/common/collect/ImmutableMap;  ] access$2300 access$2600 access$2700 access$2800 access$2900 access$3000 access$3100 access$3200 access$3300 access$3400[(Lorg/elasticsearch/snapshots/SnapshotsService;)Ljava/util/concurrent/CopyOnWriteArrayList; access$3500 access$3600 access$3700 access$3800 access$3900  o access$4000 access$4100 access$4300 ConstantValue SignatureCodeLocalVariableTableLineNumberTableRuntimeVisibleAnnotationsLocalVariableTypeTable StackMapTablel(Ljava/lang/String;)Lorg/elasticsearch/common/collect/ImmutableList; Exceptions(Ljava/lang/String;[Ljava/lang/String;)Lorg/elasticsearch/common/collect/ImmutableList;(Lorg/elasticsearch/cluster/metadata/SnapshotId;)Lorg/elasticsearch/common/collect/ImmutableMap;(Lorg/elasticsearch/common/collect/ImmutableList;Lorg/elasticsearch/index/shard/ShardId;)Lorg/elasticsearch/snapshots/SnapshotShardFailure;t(Lorg/elasticsearch/common/collect/ImmutableMap;Lorg/elasticsearch/cluster/routing/RoutingTable;)Lorg/elasticsearch/common/collect/ImmutableMap;d(Ljava/util/Collection;)Z(Lorg/elasticsearch/common/collect/ImmutableMap;)Ljava/util/Set;>(Lorg/elasticsearch/cluster/metadata/SnapshotId;Lorg/elasticsearch/cluster/ClusterState;Lorg/elasticsearch/common/collect/ImmutableList;)Lorg/elasticsearch/common/collect/ImmutableMap; SourceFile InnerClasses! [\t^_`abcdefghBijuklmnopqurFstvc*+x*|~*Y***Y*,*-***^ Y*,*wHccc_`cabccdcefcghx6 rf hj$l/s4t9u?vEwKy[|b}yuvF*++wxv KM*+N-:::,-W,,wH2 &KK\G >6zG6x" 2?BF{?%u|vy)Y++N*+1Y*+-,  w*)))x(vO,!#N--+&(Y+++13YY++58+:>3YY++@8+B>3YY++D8+F>3YY++H8+L_3YY++N8+TX+[3YY++]8+`03YY++bYceimps8w*OOOtuAvwxJ)3MZt!N{ # #&&&&-6}xyv +6*,~:+:,?:,:    :  W:,~,6,*,*bYci,pis/Y*, t:*Y,~S*,~@*,~,~ŹW:*Y,~S{{{w D\ .' %7 o++u+++(xn   %DRU\mpzk`abcehf g!j*l{a. 3:8&*13{N3{{v @*N-!5:Ű+[ l3:~+[Ű,A,<,:66&2: ~ [ 氄ٸŰ永::r3:~+[,E,@,:6 6   + 2: ~ [W ԧ Ww\ v2{-~*W[ \ 72 / `y@@\@ 3'z xzy z{)|-~7=IWfjs #&/7:{E):5,3#='3(u~vo*~+ M,,w  x {uvM*+N*+:-+:-+:::#&(:  w +6 6   f-Y 0: *3 7:  *QY8:<@ EH, KW+ O:, KW b,QwRS RSPTU AVW vjX smY gyZ[ X\B\^_&`6z \]x^&6Xgls}{vBA :3 A :(N-BA :u45v<+N-/-B:,ce[,hjw4VW5<<1<TUz <1kx47:{ 1ulmv%t+r+u*+x+{*+~+!5M+!5N,-*-,-*-M*,^a{w40.AbttxB0AEIQY^abs{ 155 B{vmv1*+++=*-Y* w 11x   0V{@|mvb*+*+Y* wxYZ{v F>:+:#H:E:-:,c:   ¶:   z ιH>*YSYSEY ι߶KWO ι ιW*>*YSYSEYزKW W Qwp e ITUT 2&*FFjFD?^z &F?xn&2=ITYer ,/7:>D{@A CAHE- E uv +!5M,,N--3:  :~:+f+: ?:<-:  ¶ȶ:     ~Dwp  *TU CUjl\T1x>1Gjs{5563>=-v +=+!5N--:3:+!$:a&:(:;H:  E:  +- ض[Zwp  ) BO./qhI3$z ) xB$(*Ice{2 @5/3 "&>vA 75M*~N-;-H:+)+8,;W¸5N*?A:++:3:5:*~~ :(:   H:  Eض[] EJ D3*FY S QY8;W{Gc-~;W7:  KW KW,~Y QN;W,~YQN;WhT]*~~ :G(:0H:   Q:   W̧b*Z*,Q~*~ *_*b: *b -G-eh:H:Jeh:H:*-cn-¹tv|v: *})Y* 6: * Y-EY ÷`14@@B@{w#*Ao ],^  LS  7Io 1 zd773Tb\z\ #*o ],]  z3Tx6#8MPTbf"8;ESX]hp    !+!4$=%@$N(W)z*,.<:;0=3>6@{J=JC 5JJ3JTH/P-3#K{ +Hl 5JJHH{2vZ* *+**^+#M*,Y+SY+S69{w :ZZxIJL6Q9O:PYR{ B{)v++M,,EN-+w* "++z +x[\$]&_)`{ uvRM+N-@-H:Eæ,M,-cW,w4/ FRRjPz /RPx"jkl1m5n9pMrPs{ g.HuvN*λ'Y*+ѹ wx |v?*+Աwx v\*}%Y*+,׹w F\x vd*ٻ#Y*+,-ܹ w*x vY*!Y*+, w x r vI*M,!5N-6-:#3:+~[w>3*IuI\D9x"|}~3BDG{:5&v\*}Y*+,w x v 5:,:-:::,: 6  -Y 0:    ȶ:    EYKW,3    EY KWB " EY KW EY ߶KW EY KW Qw f  UTU >X 0Z[;  '\555u50^ *z5 0xV '0;HUZfu &,/{g A:, ?A:(6-#(?A:u vB *+Ww x  vB *+Ww x  v+w x}vT*Z*~ * $*b"L*-*bM*b, (4 (G4;GGHGw5./Tx*  (145;DGS{  KR{ }0v+w x}12vE*+,4w 567uxX}89v/*w 5xX:9v/*w 5xX;<v\ *+,>w4 5 6u 7 ? @xXABv/*w 5xXCDvP*+,-Fw*567u?xXGHv:*+Jw56jxXKLv:*+Nw56xXO9v/*w 5xXPvP*+,-w*567?xXQRv/*w 5xXS9v/*w 5xXTvE*+,Աw 567\xXU9v/*w 5xXVWv:*+w56xXX9v/*w 5xXY9v/*w 5xXZ9v/*w 5xX[\vE*+,^w 56j7xX_9v/*w 5xX`v:*+w56xXa9v/*w 5xXb9v/*w 5xXc9v/*w 5xXd9v/*w 5xXe9v/*w 5xXf9v/*w 5xXg9v/*w 5xXhiv/*w 5xXj9v/*w 5xXk9v/*w 5xXl9v/*w 5xXm9v/*w 5xXnvE*+,pw 567xXq9v/*w 5xXr9v/*w 5xXsv:*+w56xXu         !#%')+-/1356 8:; =?;AC; E5F HJ6 L:M OQR@T5U@WYZ