3 2org/elasticsearch/repositories/RepositoriesService4org/elasticsearch/common/component/AbstractComponent.org/elasticsearch/cluster/ClusterStateListenerRepositoriesService.javaAorg/elasticsearch/repositories/RepositoriesService$VerifyResponseVerifyResponseNorg/elasticsearch/repositories/RepositoriesService$UnregisterRepositoryRequest UnregisterRepositoryRequestLorg/elasticsearch/repositories/RepositoriesService$RegisterRepositoryRequestRegisterRepositoryRequestCorg/elasticsearch/repositories/RepositoriesService$RepositoryHolderRepositoryHolderVorg/elasticsearch/repositories/RepositoriesService$VerifyingRegisterRepositoryListener#VerifyingRegisterRepositoryListener4org/elasticsearch/repositories/RepositoriesService$34org/elasticsearch/repositories/RepositoriesService$24org/elasticsearch/repositories/RepositoriesService$1java/util/Map$Entry java/util/MapEntry5org/elasticsearch/common/collect/ImmutableMap$Builder"-org/elasticsearch/common/collect/ImmutableMap$Builder2org/elasticsearch/cluster/metadata/MetaData$Custom'+org/elasticsearch/cluster/metadata/MetaData)Custom typesRegistry8Lorg/elasticsearch/repositories/RepositoryTypesRegistry;injector*Lorg/elasticsearch/common/inject/Injector;clusterService*Lorg/elasticsearch/cluster/ClusterService; verifyAction;Lorg/elasticsearch/repositories/VerifyNodeRepositoryAction; repositories/Lorg/elasticsearch/common/collect/ImmutableMap;Lorg/elasticsearch/common/collect/ImmutableMap;(Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/cluster/ClusterService;Lorg/elasticsearch/transport/TransportService;Lorg/elasticsearch/repositories/RepositoryTypesRegistry;Lorg/elasticsearch/common/inject/Injector;)V(Lorg/elasticsearch/common/inject/Inject;/(Lorg/elasticsearch/common/settings/Settings;)V 7: ;of1()Lorg/elasticsearch/common/collect/ImmutableMap; => %? 45 A ,- C ./ E 01 G,org/elasticsearch/cluster/node/DiscoveryNodeIdataNode/(Lorg/elasticsearch/common/settings/Settings;)Z KL JM masterNode OL JP*org/elasticsearch/common/settings/SettingsR(org/elasticsearch/cluster/ClusterServiceT,org/elasticsearch/transport/TransportServiceV6org/elasticsearch/repositories/RepositoryTypesRegistryX(org/elasticsearch/common/inject/InjectorZadd3(Lorg/elasticsearch/cluster/ClusterStateListener;)V \] U^9org/elasticsearch/repositories/VerifyNodeRepositoryAction`(Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/transport/TransportService;Lorg/elasticsearch/cluster/ClusterService;Lorg/elasticsearch/repositories/RepositoriesService;)V 7b ac 23 ethis4Lorg/elasticsearch/repositories/RepositoriesService;settings,Lorg/elasticsearch/common/settings/Settings;transportService.Lorg/elasticsearch/transport/TransportService;registerRepositoryz(Lorg/elasticsearch/repositories/RepositoriesService$RegisterRepositoryRequest;Lorg/elasticsearch/action/ActionListener;)V5org/elasticsearch/cluster/metadata/RepositoryMetaDataonameLjava/lang/String; qr stype ur v ij xS(Ljava/lang/String;Ljava/lang/String;Lorg/elasticsearch/common/settings/Settings;)V 7z p{verifyZ }~ r(Lorg/elasticsearch/repositories/RepositoriesService;Ljava/lang/String;Lorg/elasticsearch/action/ActionListener;)V 7 'org/elasticsearch/action/ActionListenercause r (Lorg/elasticsearch/repositories/RepositoriesService;Lorg/elasticsearch/cluster/ack/AckedRequest;Lorg/elasticsearch/action/ActionListener;Lorg/elasticsearch/repositories/RepositoriesService$RegisterRepositoryRequest;Lorg/elasticsearch/cluster/metadata/RepositoryMetaData;)V 7 submitStateUpdateTaskG(Ljava/lang/String;Lorg/elasticsearch/cluster/ClusterStateUpdateTask;)V UregistrationListenereLorg/elasticsearch/action/ActionListener;)Lorg/elasticsearch/action/ActionListener;requestNLorg/elasticsearch/repositories/RepositoriesService$RegisterRepositoryRequest;listenernewRepositoryMetaData7Lorg/elasticsearch/cluster/metadata/RepositoryMetaData;unregisterRepository|(Lorg/elasticsearch/repositories/RepositoriesService$UnregisterRepositoryRequest;Lorg/elasticsearch/action/ActionListener;)V (Lorg/elasticsearch/repositories/RepositoriesService;Lorg/elasticsearch/cluster/ack/AckedRequest;Lorg/elasticsearch/action/ActionListener;Lorg/elasticsearch/repositories/RepositoriesService$UnregisterRepositoryRequest;)V 7 PLorg/elasticsearch/repositories/RepositoriesService$UnregisterRepositoryRequest;verifyRepository>(Ljava/lang/String;Lorg/elasticsearch/action/ActionListener;)Vjava/lang/Throwable repository?(Ljava/lang/String;)Lorg/elasticsearch/repositories/Repository; )org/elasticsearch/repositories/RepositorystartVerification()Ljava/lang/String; (Lorg/elasticsearch/repositories/RepositoriesService;Lorg/elasticsearch/repositories/Repository;Ljava/lang/String;Ljava/lang/String;Lorg/elasticsearch/action/ActionListener;)V 7 P(Ljava/lang/String;Ljava/lang/String;Lorg/elasticsearch/action/ActionListener;)V } ajava/lang/StringendVerification(Ljava/lang/String;)V logger+Lorg/elasticsearch/common/logging/ESLogger; -[{}] failed to finish repository verificationjava/lang/Object)org/elasticsearch/common/logging/ESLoggerwarn((Ljava/lang/String;[Ljava/lang/Object;)V  onFailure(Ljava/lang/Throwable;)V 2org/elasticsearch/repositories/VerificationFailureg([Lorg/elasticsearch/cluster/node/DiscoveryNode;[Lorg/elasticsearch/repositories/VerificationFailure;)V 7  onResponse(Ljava/lang/Object;)V t1Ljava/lang/Throwable;tverificationTokenrepositoryNamenLorg/elasticsearch/action/ActionListener;+Lorg/elasticsearch/repositories/Repository;clusterChanged2(Lorg/elasticsearch/cluster/ClusterChangedEvent;)V-org/elasticsearch/cluster/ClusterChangedEvent previousState*()Lorg/elasticsearch/cluster/ClusterState; &org/elasticsearch/cluster/ClusterState getMetaData/()Lorg/elasticsearch/cluster/metadata/MetaData; 4customH(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/MetaData$Custom; *7org/elasticsearch/cluster/metadata/RepositoriesMetaDatastate equals(Ljava/lang/Object;)Z 8processing new index repositories for state version [{}]version()J java/lang/LongvalueOf(J)Ljava/lang/Long;  trace  %org/elasticsearch/common/collect/Maps newHashMap()Ljava/util/HashMap;   entrySet1()Lorg/elasticsearch/common/collect/ImmutableSet;   %-org/elasticsearch/common/collect/ImmutableSetiterator()Ljava/util/Iterator;  java/util/IteratorhasNext()Z  next()Ljava/lang/Object;  getKey   !K(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/RepositoryMetaData; # $unregistering repository [{}]&debug ( )getValue + ,closeRepositoryZ(Ljava/lang/String;Lorg/elasticsearch/repositories/RepositoriesService$RepositoryHolder;)V ./ 0put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; 23 4builder9()Lorg/elasticsearch/common/collect/ImmutableMap$Builder; 67 %82()Lorg/elasticsearch/common/collect/ImmutableList; 4: ;.org/elasticsearch/common/collect/ImmutableList= > q p@get&(Ljava/lang/Object;)Ljava/lang/Object; BC D access$800Y(Lorg/elasticsearch/repositories/RepositoriesService$RepositoryHolder;)Ljava/lang/String; FG H u pJ  access$900s(Lorg/elasticsearch/repositories/RepositoriesService$RepositoryHolder;)Lorg/elasticsearch/common/settings/Settings; MN O.()Lorg/elasticsearch/common/settings/Settings; iQ pRupdating repository [{}]TcreateRepositoryHolder~(Lorg/elasticsearch/cluster/metadata/RepositoryMetaData;)Lorg/elasticsearch/repositories/RepositoriesService$RepositoryHolder; VW Xregistering repository [{}]Z](Ljava/lang/Object;Ljava/lang/Object;)Lorg/elasticsearch/common/collect/ImmutableMap$Builder; 2\ #]build _> #`failure updating cluster state b=(Ljava/lang/String;Ljava/lang/Throwable;[Ljava/lang/Object;)V d eentrynLjava/util/Map$Entry;Ljava/util/Map$Entry;i$Ljava/util/Iterator;holderELorg/elasticsearch/repositories/RepositoriesService$RepositoryHolder;repositoryMetaData oldMetaData9Lorg/elasticsearch/cluster/metadata/RepositoriesMetaData; newMetaData survivorshLjava/util/Map;Ljava/util/Map;Lorg/elasticsearch/common/collect/ImmutableMap$Builder;7Lorg/elasticsearch/common/collect/ImmutableMap$Builder;exevent/Lorg/elasticsearch/cluster/ClusterChangedEvent; %D access$1000r(Lorg/elasticsearch/repositories/RepositoriesService$RepositoryHolder;)Lorg/elasticsearch/repositories/Repository; {| }9org/elasticsearch/repositories/RepositoryMissingException 7 indexShardRepositoryL(Ljava/lang/String;)Lorg/elasticsearch/index/snapshots/IndexShardRepository; access$1100(Lorg/elasticsearch/repositories/RepositoriesService$RepositoryHolder;)Lorg/elasticsearch/index/snapshots/IndexShardRepository;  :(Lorg/elasticsearch/cluster/metadata/RepositoryMetaData;)Z$(Ljava/util/Map;)Ljava/util/HashMap;  copyOf@(Ljava/util/Map;)Lorg/elasticsearch/common/collect/ImmutableMap;  %previousnewRepositoriesclosing repository [{}][{}] access$1200q(Lorg/elasticsearch/repositories/RepositoriesService$RepositoryHolder;)Lorg/elasticsearch/common/inject/Injector;  )org/elasticsearch/common/inject/Injectorsclose-(Lorg/elasticsearch/common/inject/Injector;)V  ()V  creating repository [{}][{}].org/elasticsearch/common/inject/ModulesBuilder 7 -org/elasticsearch/repositories/RepositoryName'(Ljava/lang/String;Ljava/lang/String;)V 7 3org/elasticsearch/repositories/RepositoryNameModule2(Lorg/elasticsearch/repositories/RepositoryName;)V 7 Z(Lorg/elasticsearch/common/inject/Module;)Lorg/elasticsearch/common/inject/ModulesBuilder; \ /org/elasticsearch/repositories/RepositoryModule x(Lorg/elasticsearch/repositories/RepositoryName;Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/repositories/RepositoryTypesRegistry;)V 7 createChildInjectorV(Lorg/elasticsearch/common/inject/Injector;)Lorg/elasticsearch/common/inject/Injector;   getInstance%(Ljava/lang/Class;)Ljava/lang/Object;  [6org/elasticsearch/index/snapshots/IndexShardRepositorystart  (Ljava/lang/String;Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/common/inject/Injector;Lorg/elasticsearch/repositories/Repository;Lorg/elasticsearch/index/snapshots/IndexShardRepository;)V 7 $failed to create repository [{}][{}]2org/elasticsearch/repositories/RepositoryExceptionfailed to create repository<(Ljava/lang/String;Ljava/lang/String;Ljava/lang/Throwable;)V 7 modules0Lorg/elasticsearch/common/inject/ModulesBuilder;/Lorg/elasticsearch/repositories/RepositoryName;8Lorg/elasticsearch/index/snapshots/IndexShardRepository;repositoryInjectorensureRepositoryNotInUse=(Lorg/elasticsearch/cluster/ClusterState;Ljava/lang/String;)V,org/elasticsearch/snapshots/SnapshotsServiceisRepositoryInUse=(Lorg/elasticsearch/cluster/ClusterState;Ljava/lang/String;)Z  *org/elasticsearch/snapshots/RestoreService 4org/elasticsearch/ElasticsearchIllegalStateExceptionAtrying to modify or unregister repository that is currently used   clusterState(Lorg/elasticsearch/cluster/ClusterState; access$000q(Lorg/elasticsearch/repositories/RepositoriesService;Lorg/elasticsearch/cluster/ClusterState;Ljava/lang/String;)V  x0x1x2 access$100n(Lorg/elasticsearch/repositories/RepositoriesService;Lorg/elasticsearch/cluster/metadata/RepositoryMetaData;)Z m  access$200a(Lorg/elasticsearch/repositories/RepositoriesService;)Lorg/elasticsearch/common/logging/ESLogger; access$300 access$400 access$500 access$600 access$700 SignatureCodeLocalVariableTableLineNumberTable StackMapTableRuntimeVisibleAnnotationsLocalVariableTypeTable(Lorg/elasticsearch/repositories/RepositoriesService$RegisterRepositoryRequest;Lorg/elasticsearch/action/ActionListener;)V(Lorg/elasticsearch/repositories/RepositoriesService$UnregisterRepositoryRequest;Lorg/elasticsearch/action/ActionListener;)V(Ljava/lang/String;Lorg/elasticsearch/action/ActionListener;)V SourceFile InnerClasses!,-./0123B45678B*+<*@B*D*F*,H+N +Q ,*_*aY+-,*df>BghBijB01BklB,-B./& EA FGHK+L2NAO+SUWY[9mn KpY+t+w+y|N+Y*+t,:,:*H+Y*++->*KghKK70 *K0[^_-a0dJ-pm*H+Y*+,+ gh   *+N-:O*f+Y*-+,J:-:*Y+SYS,, YJ̷Ϲ :,*-/7:twR</-fryghr| F*-/7:<T\_twyC-  B U +M+N,-, ,-*Y+S :*B:r:--"%8*'Y"S**"-1"-5W9:--<?:p:AE:QIKLPS9*UYAS**A1*Y: *Y:(*[YAS*A^WT*aBM*c,f45z x`gibyjklmnjkop qpVOrt6vwghxy x`ghVOrs6u~ 45Q V x  9Q\g"o$t%&(*-+,.N( , *4#Kp-) v*B+zM,,~Y+ ghr lm: ;<>v*B+zM,,Y+ ghr lmK LMOme*B+AzM,!,I+KL,P+S*+YN, *+A,1*B:+A-5W*B4eghenVm7.lmMt Ms. ]^_/a1d7e;gDiMjZkcl1./:*Y,ISY+S*, ,,~ ,~ :gh:qr:lmvw"x)z0{9})VW*Y+KSY+AS*MYNY+K+A:-YW-Y+S**DW-*FM,:,Ĺ:WY+K+S,ʰN,,*-Y+KSY+ASfY+A-ӿ R(z9iqw+7ghn /B (9Gajwp[l+, +,Y迱 ghr E*+, hr7:*+h7/* h7/* h7/* h7/* h7/* h7/* h7Z      ! #%& (*+