Edit C:\dspace\webapps\jspui\WEB-INF\lib\org\elasticsearch\gateway\GatewayService.class
???? 3? (org/elasticsearch/gateway/GatewayService ?Lorg/elasticsearch/common/component/AbstractLifecycleComponent<Lorg/elasticsearch/gateway/GatewayService;>;Lorg/elasticsearch/cluster/ClusterStateListener; =org/elasticsearch/common/component/AbstractLifecycleComponent .org/elasticsearch/cluster/ClusterStateListener GatewayService.java @org/elasticsearch/gateway/GatewayService$GatewayRecoveryListener GatewayRecoveryListener *org/elasticsearch/gateway/GatewayService$2 *org/elasticsearch/gateway/GatewayService$1 ?org/elasticsearch/gateway/Gateway$GatewayStateRecoveredListener !org/elasticsearch/gateway/Gateway GatewayStateRecoveredListener STATE_NOT_RECOVERED_BLOCK .Lorg/elasticsearch/cluster/block/ClusterBlock; 3DEFAULT_RECOVER_AFTER_TIME_IF_EXPECTED_NODES_IS_SET )Lorg/elasticsearch/common/unit/TimeValue; gateway #Lorg/elasticsearch/gateway/Gateway; threadPool )Lorg/elasticsearch/threadpool/ThreadPool; allocationService @Lorg/elasticsearch/cluster/routing/allocation/AllocationService; clusterService *Lorg/elasticsearch/cluster/ClusterService; discoveryService .Lorg/elasticsearch/discovery/DiscoveryService; recoverAfterTime recoverAfterNodes I expectedNodes recoverAfterDataNodes expectedDataNodes recoverAfterMasterNodes expectedMasterNodes recovered +Ljava/util/concurrent/atomic/AtomicBoolean; scheduledRecovery <init>(Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/gateway/Gateway;Lorg/elasticsearch/cluster/routing/allocation/AllocationService;Lorg/elasticsearch/cluster/ClusterService;Lorg/elasticsearch/discovery/DiscoveryService;Lorg/elasticsearch/threadpool/ThreadPool;)V (Lorg/elasticsearch/common/inject/Inject; /(Lorg/elasticsearch/common/settings/Settings;)V . 1 2 )java/util/concurrent/atomic/AtomicBoolean 4 ()V . 6 5 7 + , 9 - , ; = ? A ! " C E componentSettings ,Lorg/elasticsearch/common/settings/Settings; G H I expected_nodes K java/lang/Integer M valueOf (I)Ljava/lang/Integer; O P N Q *org/elasticsearch/common/settings/Settings S getAsInt :(Ljava/lang/String;Ljava/lang/Integer;)Ljava/lang/Integer; U V T W intValue ()I Y Z N [ & % ] expected_data_nodes _ ( % a expected_master_nodes c * % e >org/elasticsearch/cluster/routing/allocation/AllocationService g (org/elasticsearch/cluster/ClusterService i ,org/elasticsearch/discovery/DiscoveryService k 'org/elasticsearch/threadpool/ThreadPool m 'org/elasticsearch/common/unit/TimeValue o q recover_after_time s getAsTime f(Ljava/lang/String;Lorg/elasticsearch/common/unit/TimeValue;)Lorg/elasticsearch/common/unit/TimeValue; u v T w # y recover_after_nodes { $ % } recover_after_data_nodes ' % ? recover_after_master_nodes ? "discovery.zen.minimum_master_nodes ? ) % ? ? addInitialStateBlock 1(Lorg/elasticsearch/cluster/block/ClusterBlock;)V ? ? j ? this *Lorg/elasticsearch/gateway/GatewayService; settings defaultRecoverAfterTime doStart (org/elasticsearch/ElasticsearchException ? start ()Ljava/lang/Object; ? ? ? initialStateReceived ()Z ? ? l ? state *()Lorg/elasticsearch/cluster/ClusterState; ? ? j ? &org/elasticsearch/cluster/ClusterState ? nodes 1()Lorg/elasticsearch/cluster/node/DiscoveryNodes; ? ? ? ? -org/elasticsearch/cluster/node/DiscoveryNodes ? localNodeMaster ? ? ? ? blocks 1()Lorg/elasticsearch/cluster/block/ClusterBlocks; ? ? ? ? -org/elasticsearch/cluster/block/ClusterBlocks ? hasGlobalBlock 1(Lorg/elasticsearch/cluster/block/ClusterBlock;)Z ? ? ? ? &checkStateMeetsSettingsAndMaybeRecover ,(Lorg/elasticsearch/cluster/ClusterState;Z)V ? ? ? logger +Lorg/elasticsearch/common/logging/ESLogger; ? ? ? Xcan't wait on start for (possibly) reading state from gateway, will do it asynchronously ? java/lang/Object ? )org/elasticsearch/common/logging/ESLogger ? debug ((Ljava/lang/String;[Ljava/lang/Object;)V ? ? ? ? addLast 3(Lorg/elasticsearch/cluster/ClusterStateListener;)V ? ? j ? clusterState (Lorg/elasticsearch/cluster/ClusterState; doStop remove ? ? j ? stop ? ? ? doClose close ? 6 ? clusterChanged 2(Lorg/elasticsearch/cluster/ClusterChangedEvent;)V lifecycle .Lorg/elasticsearch/common/component/Lifecycle; ? ? ? ,org/elasticsearch/common/component/Lifecycle ? stoppedOrClosed ? ? ? ? -org/elasticsearch/cluster/ClusterChangedEvent ? ? ? ? ? event /Lorg/elasticsearch/cluster/ClusterChangedEvent; getNoMasterBlock 0()Lorg/elasticsearch/cluster/block/ClusterBlock; ? ? l ? 2not recovering from gateway, no master elected yet ? masterAndDataNodes 5()Lorg/elasticsearch/common/collect/ImmutableOpenMap; ? ? ? ? 1org/elasticsearch/common/collect/ImmutableOpenMap ? size ? Z ? ? java/lang/StringBuilder ? ? 7 7not recovering from gateway, nodes_size (data+master) [ ? append -(Ljava/lang/String;)Ljava/lang/StringBuilder; ? ? (I)Ljava/lang/StringBuilder; ? ? ] < recover_after_nodes [ ] toString ()Ljava/lang/String; ? dataNodes ? ? 0not recovering from gateway, nodes_size (data) [ ] < recover_after_data_nodes [ masterNodes ? ? 2not recovering from gateway, nodes_size (master) [ ] < recover_after_master_nodes [ recovery_after_time was set to [ -(Ljava/lang/Object;)Ljava/lang/StringBuilder; ? ? ! expecting [# ] nodes, but only have [% java/lang/String' ] data nodes, but only have [) ] master nodes, but only have [+ performStateRecovery (ZZLjava/lang/String;)V -. / enforceRecoverAfterTime Z reason Ljava/lang/String; asyncRecovery /Lorg/elasticsearch/cluster/node/DiscoveryNodes; #java/util/concurrent/CountDownLatch7 (I)V .9 8: R(Lorg/elasticsearch/gateway/GatewayService;Ljava/util/concurrent/CountDownLatch;)V .< = compareAndSet (ZZ)Z ?@ 5A ,delaying initial state recovery for [{}]. {}C info E ? ?F genericH n(Lorg/elasticsearch/gateway/GatewayService;Lorg/elasticsearch/gateway/Gateway$GatewayStateRecoveredListener;)V .J K schedule w(Lorg/elasticsearch/common/unit/TimeValue;Ljava/lang/String;Ljava/lang/Runnable;)Ljava/util/concurrent/ScheduledFuture; MN nO !()Ljava/util/concurrent/Executor; HQ nR K java/util/concurrent/ExecutorU execute (Ljava/lang/Runnable;)V WX VY performing state recovery...[ trace ] ? ?^ D(Lorg/elasticsearch/gateway/Gateway$GatewayStateRecoveredListener;)V -` a recoveryListener ALorg/elasticsearch/gateway/Gateway$GatewayStateRecoveredListener; +()Lorg/elasticsearch/common/unit/TimeValue; access$000 W(Lorg/elasticsearch/gateway/GatewayService;)Ljava/util/concurrent/atomic/AtomicBoolean; x0 access$100 U(Lorg/elasticsearch/gateway/GatewayService;)Lorg/elasticsearch/common/unit/TimeValue; access$200 W(Lorg/elasticsearch/gateway/GatewayService;)Lorg/elasticsearch/common/logging/ESLogger; access$300 O(Lorg/elasticsearch/gateway/GatewayService;)Lorg/elasticsearch/gateway/Gateway; access$400 access$500 l(Lorg/elasticsearch/gateway/GatewayService;)Lorg/elasticsearch/cluster/routing/allocation/AllocationService; access$600 access$700 access$900 V(Lorg/elasticsearch/gateway/GatewayService;)Lorg/elasticsearch/cluster/ClusterService; access$1000 access$1100 <clinit> ,org/elasticsearch/cluster/block/ClusterBlocky !state not recovered / initialized{ !org/elasticsearch/rest/RestStatus} SERVICE_UNAVAILABLE #Lorg/elasticsearch/rest/RestStatus; ? ~? 1org/elasticsearch/cluster/block/ClusterBlockLevel? ALL Ljava/util/EnumSet; ?? ?? N(ILjava/lang/String;ZZLorg/elasticsearch/rest/RestStatus;Ljava/util/EnumSet;)V .? z? timeValueMinutes ,(J)Lorg/elasticsearch/common/unit/TimeValue; ?? p? Code LocalVariableTable LineNumberTable StackMapTable RuntimeVisibleAnnotations Exceptions Signature SourceFile InnerClasses ! ! " # $ % & % ' % ( % ) % * % + , - , . / ? ? ?*+? 3*? 5Y? 8? :*? 5Y? 8? <*,? >*-? @*? B*? D*? F**? JL? R? X ? \? ^**? J`? R? X ? \? b**? Jd? R? X ? \? f:*? ^? *? b? *? f? ? r:**? Jt? x ? z**? J|? R? X ? \? ~**? J?? R? X ? \? ?**? J?+?? R? X ? X ? \? ?*? B? ?? ? ? ? R ? ? ? ? ? H ? ? ? ? ! " ? | ? ? ? R N I J O P % Q + R 1 S 7 U M V c W y Y | Z ? [ ? ^ ? _ ? ` ? b ? e ? f? " ? ? T h j l n p ? 0 ? 6 ? ? X*? >? ? W*? D? ?? -*? B? ? L+? ?? ?? +? ?? ?? ?? *+? ?? *? ??? ¹ ? *? B*? ? ? ? ? ? X ? ? ? & j m n o 5 p ; r > s M u W v? ;? ? ? 6 ? G *? B*? ? *? >? ? W? ? ? ? ? z { |? ? ? 6 ? 8 *? >? ? ? ? ? ? ? ? ?? ? ? ? ? z ,*? ? ? ?+? ? +? ? ?? ?? ?? *+? ?? ?? ? , ? ? , ? ? ? ? ? ? " ? + ?? ? ? ? E M+? ?N+? ?*? D? ? ?? *? ??? ¹ ? ?'*? ~? M-? ?? ?*? ~? ?*? ?? ?Y? ???-? ?? ??*? ~? ?? ? ¹ ? ??*? ?? N-?? ?*? ?? @*? ?? ?Y? ??-?? ??*? ?? ?? ? ¹ ? ??*? ?? N-?? ?*? ?? @*? ?? ?Y? ??-?? ??*? ?? ?? ? ¹ ? ?/*? ^? 8*? f? 0*? b? (6? ?Y? ? ?*? z? ?? :? ?6":*? ^? F-? ?? ?*? ^? 86? ?Y? ?$?*? ^?&?-? ?? ? ?? :? ?*? b? F-?? ?*? b? 86? ?Y? ?$?*? b?*?-?? ? ?? :? K*? f? C-?? ?*? f? 56? ?Y? ?$?*? f?,?-?? ? ?? :* ?0? ? R ; "12 Z 34 ` ?12 e ?34 M ? ? M ? ? M52 H ?6 ? f ? ? ? ( ? > ? z ? ? ? ? ? ? ? ?8 ?; ?] ?` ?e ?{ ?~ ?? ?? ?? ?? ? ? ?C ?L ?? " ? ( ?? Q? R? R<? R(? J? G? -. ? / ?? Y*?8Y?;?>: ? M*? z? F*? <?B? ~*? ?D? ?Y*? zSY-S?G *? F*? zI? Y*?L?PW? G*? :?B? ;? *? F?S? Y*?T?Z ? *? ?\? ¹_ *? >?b ? ? 4 ? ? ? ?52 ?12 ?34 ?cd ? . ? ? ? ) ? D ? ` ? l ? p ? ? ? ? ? ? ?? ? ` ( #e ? / *? z? ? ? ? ? !fg ? / *? :? ? h ? ? 0ij ? / *? z? ? h ? ? 0kl ? / *? ?? ? h ? ? 0mn ? / *? >? ? h ? ? 0ol ? / *? ?? ? h ? ? 0pq ? / *? @? ? h ? ? 0rl ? / *? ?? ? h ? ? 0sl ? / *? ?? ? h ? ? 0tu ? / *? B? ? h ? ? 0vg ? / *? <? ? h ? ? 0wl ? / *? ?? ? h ? ? 0 x 6 ? < ?zY|??????? ????? r? ? 2 4 ? ? ? "
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de