Edit C:\dspace\webapps\rest\WEB-INF\lib\org\elasticsearch\repositories\RepositoriesService.class
???? 3 2org/elasticsearch/repositories/RepositoriesService 4org/elasticsearch/common/component/AbstractComponent .org/elasticsearch/cluster/ClusterStateListener RepositoriesService.java Aorg/elasticsearch/repositories/RepositoriesService$VerifyResponse VerifyResponse Norg/elasticsearch/repositories/RepositoriesService$UnregisterRepositoryRequest UnregisterRepositoryRequest Lorg/elasticsearch/repositories/RepositoriesService$RegisterRepositoryRequest RegisterRepositoryRequest Corg/elasticsearch/repositories/RepositoriesService$RepositoryHolder RepositoryHolder Vorg/elasticsearch/repositories/RepositoriesService$VerifyingRegisterRepositoryListener #VerifyingRegisterRepositoryListener 4org/elasticsearch/repositories/RepositoriesService$3 4org/elasticsearch/repositories/RepositoriesService$2 4org/elasticsearch/repositories/RepositoriesService$1 java/util/Map$Entry java/util/Map Entry 5org/elasticsearch/common/collect/ImmutableMap$Builder " -org/elasticsearch/common/collect/ImmutableMap $ Builder 2org/elasticsearch/cluster/metadata/MetaData$Custom ' +org/elasticsearch/cluster/metadata/MetaData ) Custom typesRegistry 8Lorg/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<Ljava/lang/String;Lorg/elasticsearch/repositories/RepositoriesService$RepositoryHolder;>; <init> ?(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 : ; of 1()Lorg/elasticsearch/common/collect/ImmutableMap; = > % ? 4 5 A , - C . / E 0 1 G ,org/elasticsearch/cluster/node/DiscoveryNode I dataNode /(Lorg/elasticsearch/common/settings/Settings;)Z K L J M masterNode O L J P *org/elasticsearch/common/settings/Settings R (org/elasticsearch/cluster/ClusterService T ,org/elasticsearch/transport/TransportService V 6org/elasticsearch/repositories/RepositoryTypesRegistry X (org/elasticsearch/common/inject/Injector Z add 3(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 7 b a c 2 3 e this 4Lorg/elasticsearch/repositories/RepositoriesService; settings ,Lorg/elasticsearch/common/settings/Settings; transportService .Lorg/elasticsearch/transport/TransportService; registerRepository z(Lorg/elasticsearch/repositories/RepositoriesService$RegisterRepositoryRequest;Lorg/elasticsearch/action/ActionListener;)V 5org/elasticsearch/cluster/metadata/RepositoryMetaData o name Ljava/lang/String; q r s type u r v i j x S(Ljava/lang/String;Ljava/lang/String;Lorg/elasticsearch/common/settings/Settings;)V 7 z p { verify Z } ~ r(Lorg/elasticsearch/repositories/RepositoriesService;Ljava/lang/String;Lorg/elasticsearch/action/ActionListener;)V 7 ? ? 'org/elasticsearch/action/ActionListener ? cause ? 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 ? ? submitStateUpdateTask G(Ljava/lang/String;Lorg/elasticsearch/cluster/ClusterStateUpdateTask;)V ? ? U ? registrationListener eLorg/elasticsearch/action/ActionListener<Lorg/elasticsearch/cluster/ack/ClusterStateUpdateResponse;>; )Lorg/elasticsearch/action/ActionListener; request NLorg/elasticsearch/repositories/RepositoriesService$RegisterRepositoryRequest; listener newRepositoryMetaData 7Lorg/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;)V java/lang/Throwable ? repository ?(Ljava/lang/String;)Lorg/elasticsearch/repositories/Repository; ? ? ? )org/elasticsearch/repositories/Repository ? startVerification ()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 } ? a ? java/lang/String ? endVerification (Ljava/lang/String;)V ? ? ? ? logger +Lorg/elasticsearch/common/logging/ESLogger; ? ? ? -[{}] failed to finish repository verification ? java/lang/Object ? )org/elasticsearch/common/logging/ESLogger ? warn ((Ljava/lang/String;[Ljava/lang/Object;)V ? ? ? ? onFailure (Ljava/lang/Throwable;)V ? ? ? ? 2org/elasticsearch/repositories/VerificationFailure ? g([Lorg/elasticsearch/cluster/node/DiscoveryNode;[Lorg/elasticsearch/repositories/VerificationFailure;)V 7 ? ? onResponse (Ljava/lang/Object;)V ? ? ? ? t1 Ljava/lang/Throwable; t verificationToken repositoryName nLorg/elasticsearch/action/ActionListener<Lorg/elasticsearch/repositories/RepositoriesService$VerifyResponse;>; +Lorg/elasticsearch/repositories/Repository; clusterChanged 2(Lorg/elasticsearch/cluster/ClusterChangedEvent;)V -org/elasticsearch/cluster/ClusterChangedEvent ? previousState *()Lorg/elasticsearch/cluster/ClusterState; ? ? ? ? &org/elasticsearch/cluster/ClusterState ? getMetaData /()Lorg/elasticsearch/cluster/metadata/MetaData; ? ? ? ? 4 custom H(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/MetaData$Custom; ? ? * ? 7org/elasticsearch/cluster/metadata/RepositoriesMetaData ? state ? ? ? ? equals (Ljava/lang/Object;)Z ? ? ? ? 8processing new index repositories for state version [{}] ? version ()J ? ? ? ? java/lang/Long ? valueOf (J)Ljava/lang/Long; ? ? trace ? ? %org/elasticsearch/common/collect/Maps newHashMap ()Ljava/util/HashMap; entrySet 1()Lorg/elasticsearch/common/collect/ImmutableSet; % -org/elasticsearch/common/collect/ImmutableSet iterator ()Ljava/util/Iterator; java/util/Iterator hasNext ()Z next ()Ljava/lang/Object; getKey ! K(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/RepositoryMetaData; ?# ?$ unregistering repository [{}]& debug ( ? ?) getValue + , closeRepository Z(Ljava/lang/String;Lorg/elasticsearch/repositories/RepositoriesService$RepositoryHolder;)V ./ 0 put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; 23 4 builder 9()Lorg/elasticsearch/common/collect/ImmutableMap$Builder; 67 %8 2()Lorg/elasticsearch/common/collect/ImmutableList; 4: ?; .org/elasticsearch/common/collect/ImmutableList= > q ? p@ get &(Ljava/lang/Object;)Ljava/lang/Object; BC D access$800 Y(Lorg/elasticsearch/repositories/RepositoriesService$RepositoryHolder;)Ljava/lang/String; FG H u ? pJ ? ? access$900 s(Lorg/elasticsearch/repositories/RepositoriesService$RepositoryHolder;)Lorg/elasticsearch/common/settings/Settings; MN O .()Lorg/elasticsearch/common/settings/Settings; iQ pR updating repository [{}]T createRepositoryHolder ~(Lorg/elasticsearch/cluster/metadata/RepositoryMetaData;)Lorg/elasticsearch/repositories/RepositoriesService$RepositoryHolder; VW X registering 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 ?e entry nLjava/util/Map$Entry<Ljava/lang/String;Lorg/elasticsearch/repositories/RepositoriesService$RepositoryHolder;>; Ljava/util/Map$Entry; i$ Ljava/util/Iterator; holder ELorg/elasticsearch/repositories/RepositoriesService$RepositoryHolder; repositoryMetaData oldMetaData 9Lorg/elasticsearch/cluster/metadata/RepositoriesMetaData; newMetaData survivors hLjava/util/Map<Ljava/lang/String;Lorg/elasticsearch/repositories/RepositoriesService$RepositoryHolder;>; Ljava/util/Map; ?Lorg/elasticsearch/common/collect/ImmutableMap$Builder<Ljava/lang/String;Lorg/elasticsearch/repositories/RepositoriesService$RepositoryHolder;>; 7Lorg/elasticsearch/common/collect/ImmutableMap$Builder; ex event /Lorg/elasticsearch/cluster/ClusterChangedEvent; %D access$1000 r(Lorg/elasticsearch/repositories/RepositoriesService$RepositoryHolder;)Lorg/elasticsearch/repositories/Repository; {| } 9org/elasticsearch/repositories/RepositoryMissingException 7 ? ?? indexShardRepository L(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; ?? %? previous newRepositories closing repository [{}][{}]? access$1200 q(Lorg/elasticsearch/repositories/RepositoriesService$RepositoryHolder;)Lorg/elasticsearch/common/inject/Injector; ?? ? )org/elasticsearch/common/inject/Injectors? close -(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/RepositoryNameModule? 2(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? ?? createChildInjector V(Lorg/elasticsearch/common/inject/Injector;)Lorg/elasticsearch/common/inject/Injector; ?? ?? getInstance %(Ljava/lang/Class;)Ljava/lang/Object; ?? [? 6org/elasticsearch/index/snapshots/IndexShardRepository? start ? ?? ?(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/RepositoryException? failed to create repository? <(Ljava/lang/String;Ljava/lang/String;Ljava/lang/Throwable;)V 7? ?? modules 0Lorg/elasticsearch/common/inject/ModulesBuilder; /Lorg/elasticsearch/repositories/RepositoryName; 8Lorg/elasticsearch/index/snapshots/IndexShardRepository; repositoryInjector ensureRepositoryNotInUse =(Lorg/elasticsearch/cluster/ClusterState;Ljava/lang/String;)V ,org/elasticsearch/snapshots/SnapshotsService? isRepositoryInUse =(Lorg/elasticsearch/cluster/ClusterState;Ljava/lang/String;)Z ?? ?? *org/elasticsearch/snapshots/RestoreService? ?? 4org/elasticsearch/ElasticsearchIllegalStateException? Atrying to modify or unregister repository that is currently used ? ?? clusterState (Lorg/elasticsearch/cluster/ClusterState; access$000 q(Lorg/elasticsearch/repositories/RepositoriesService;Lorg/elasticsearch/cluster/ClusterState;Ljava/lang/String;)V ?? ? x0 x1 x2 access$100 n(Lorg/elasticsearch/repositories/RepositoriesService;Lorg/elasticsearch/cluster/metadata/RepositoryMetaData;)Z m? ? access$200 a(Lorg/elasticsearch/repositories/RepositoriesService;)Lorg/elasticsearch/common/logging/ESLogger; access$300 access$400 access$500 access$600 access$700 Signature Code LocalVariableTable LineNumberTable StackMapTable RuntimeVisibleAnnotations LocalVariableTypeTable ?(Lorg/elasticsearch/repositories/RepositoriesService$RegisterRepositoryRequest;Lorg/elasticsearch/action/ActionListener<Lorg/elasticsearch/cluster/ack/ClusterStateUpdateResponse;>;)V ?(Lorg/elasticsearch/repositories/RepositoriesService$UnregisterRepositoryRequest;Lorg/elasticsearch/action/ActionListener<Lorg/elasticsearch/cluster/ack/ClusterStateUpdateResponse;>;)V ?(Ljava/lang/String;Lorg/elasticsearch/action/ActionListener<Lorg/elasticsearch/repositories/RepositoriesService$VerifyResponse;>;)V SourceFile InnerClasses ! , - . / 0 1 2 3 B 4 5 ? 6 7 8 ? ? B*+? <*? @? B*? D*? F*,? H+? N? +? Q? ,*? _ *? aY+-,*? d? f? ? > B g h B i j B 0 1 B k l B , - B . / & E A F G H K + L 2 N A O ? + S U W Y [ 9 m n ? ? K? pY+? t+? w+? y? |N+? ?? ? Y*+? t,? ?:? ,:*? H+? ?? Y*++-? ?? ? ? ? > * ? ? K g h K ? ? K ? ? 7 ? ? 0 ? ? * ? ? K ? ? 0 ? ? [ ^ _ - a 0 d J ? ? - p? ?? ? ? ? m *? H+? ?? Y*+,+? ?? ? ? ? g h ? ? ? ? ? ? ? ?? ? ? ? ? ?*+? ?N-? ? :? O*? f+? Y*-+,? ?? ?? J:-? ? ? :*? ??? ?Y+SYS? ? ,? ? ? ,? Y? J? ? ? ? ? :,? ? ? * - ? / 7 : ? t w ? ? R < ? ? / - ? ? f ? r y ? ? ? g h ? ? r ? ? ? | ? ? ? ? ? F ? ? ? ? * ? - ? / ? 7 ? : ? < ? T ? \ ? _ ? t ? w ? y ? ? ? C ? - ? ? ? ? ?? ? ? ? ? ? ?? ? B ? ? ? ? ? U ?+? ? ?? ?? ?M+? ? ?? ?? ?N,? -? ,? ,-? ?? ?*? ??? ?Y+? ? ?S? ? :*? B??:? ? r? ? :-? -?" ? ??%? 8*? ?'? ?Y?" S?* *?" ? ??- ? ?1? ?" ?- ?5 W????9:-? ?-?<??:? ? ?? ? p:?A?E ? :? Q?I?K?L? ?P?S? ?? 9*? ?U? ?Y?AS?* *?A?1*?Y:? *?Y:? (*? ?[? ?Y?AS?* ?A?^W??T*?a? B? M*? ?c,? ??f ? 4? ? 5?? ? ? z x `gi b yjk ?lm ?n ? ? ?jk ?op ?qp VOrt ? ?6v ? w ? ? g h ?xy x `gh VOrs ? ?6u ~ ? 4 5 Q V x ? ? ? ? ? ? ?9 Q \ g"o$t%?&?(?*?-?+?,?. N ? ( ? ? ? , ? * 4? ? ? #? K p -? )? ? ? ? ? ? ? v *? B+?z? M,? ,?~???Y+??? ? g h ? r lm : ; < > ? ?? ? v *? B+?z? M,? ,?????Y+??? ? g h ? r lm K L M O ? m? ? e*? B+?A?z? M,? !,?I+?K?L? ,?P+?S? ?? ?*+?YN,? *+?A,?1*? B??:+?A-?5 W*??? B? ? 4 e g h en ? V?m 7 .lm M ?t M ?s . ] ^ _ /a 1d 7e ;g Di Mj Zk cl ? 1 ? ./ ? ? :*? ??? ?Y,?ISY+S?* ,??? ,????,?~? ,?~?? ? ? : g h : q r :lm v w "x )z 0{ 9} ) VW ? ? ?*? ??? ?Y+?KSY+?AS?* M??Y??N??Y+?K+?A??:-??Y????W-??Y+?S*??*? D????W-*? F??M,??? ? ?:,?? ??:?? W? Y+?K+?S,??N,? ,??*? ??-? ?Y+?KSY+?AS?f ??Y+?A?-?? ? ? ? ? R ( z?? 9 i q? w + ? ? ? ?? ? 7 ? ? ? g h ?n ? ?? / B ? ? ? (? 9? G? a? j? w? ?? ?? ?? ?? ?? ?? ?? ? ? p [ ?? ? ?? ? l +,??? +,?? ??Y?? ? g h ?? ? r ? ? ? ?? ? E *+,?? ? ? h ?? ? r 7?? ? : *+??? ? ? h ? ? 7?? ? / *? ?? ? ? h 7?? ? / *? ?? ? ? h 7?? ? / *? ?? ? ? h 7?? ? / *? ?? ? ? h 7?? ? / *? ?? ? ? h 7?? ? / *? ?? ? ? h 7 Z ! # % & ( * +
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de