3(org/elasticsearch/gateway/GatewayServiceLorg/elasticsearch/common/component/AbstractLifecycleComponent;Lorg/elasticsearch/cluster/ClusterStateListener;=org/elasticsearch/common/component/AbstractLifecycleComponent.org/elasticsearch/cluster/ClusterStateListenerGatewayService.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/GatewayGatewayStateRecoveredListenerSTATE_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;recoverAfterTimerecoverAfterNodesI expectedNodesrecoverAfterDataNodesexpectedDataNodesrecoverAfterMasterNodesexpectedMasterNodes recovered+Ljava/util/concurrent/atomic/AtomicBoolean;scheduledRecovery(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/AtomicBoolean4()V .6 57 +, 9 -, ;  =  ?  A !" C  EcomponentSettings,Lorg/elasticsearch/common/settings/Settings; GH Iexpected_nodesKjava/lang/IntegerMvalueOf(I)Ljava/lang/Integer; OP NQ*org/elasticsearch/common/settings/SettingsSgetAsInt:(Ljava/lang/String;Ljava/lang/Integer;)Ljava/lang/Integer; UV TWintValue()I YZ N[ &% ]expected_data_nodes_ (% aexpected_master_nodesc *% e>org/elasticsearch/cluster/routing/allocation/AllocationServiceg(org/elasticsearch/cluster/ClusterServicei,org/elasticsearch/discovery/DiscoveryServicek'org/elasticsearch/threadpool/ThreadPoolm'org/elasticsearch/common/unit/TimeValueo  qrecover_after_times getAsTimef(Ljava/lang/String;Lorg/elasticsearch/common/unit/TimeValue;)Lorg/elasticsearch/common/unit/TimeValue; uv Tw # yrecover_after_nodes{ $% }recover_after_data_nodes '% recover_after_master_nodes"discovery.zen.minimum_master_nodes )%   addInitialStateBlock1(Lorg/elasticsearch/cluster/block/ClusterBlock;)V jthis*Lorg/elasticsearch/gateway/GatewayService;settingsdefaultRecoverAfterTimedoStart(org/elasticsearch/ElasticsearchExceptionstart()Ljava/lang/Object; initialStateReceived()Z lstate*()Lorg/elasticsearch/cluster/ClusterState; j&org/elasticsearch/cluster/ClusterStatenodes1()Lorg/elasticsearch/cluster/node/DiscoveryNodes; -org/elasticsearch/cluster/node/DiscoveryNodeslocalNodeMaster blocks1()Lorg/elasticsearch/cluster/block/ClusterBlocks; -org/elasticsearch/cluster/block/ClusterBlockshasGlobalBlock1(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 asynchronouslyjava/lang/Object)org/elasticsearch/common/logging/ESLoggerdebug((Ljava/lang/String;[Ljava/lang/Object;)V addLast3(Lorg/elasticsearch/cluster/ClusterStateListener;)V j clusterState(Lorg/elasticsearch/cluster/ClusterState;doStopremove jstop doCloseclose 6 clusterChanged2(Lorg/elasticsearch/cluster/ClusterChangedEvent;)V lifecycle.Lorg/elasticsearch/common/component/Lifecycle; ,org/elasticsearch/common/component/LifecyclestoppedOrClosed -org/elasticsearch/cluster/ClusterChangedEvent event/Lorg/elasticsearch/cluster/ClusterChangedEvent;getNoMasterBlock0()Lorg/elasticsearch/cluster/block/ClusterBlock; l2not recovering from gateway, no master elected yetmasterAndDataNodes5()Lorg/elasticsearch/common/collect/ImmutableOpenMap; 1org/elasticsearch/common/collect/ImmutableOpenMapsize Z java/lang/StringBuilder 77not 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 -. /enforceRecoverAfterTimeZreasonLjava/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 [{}]. {}Cinfo E FgenericHn(Lorg/elasticsearch/gateway/GatewayService;Lorg/elasticsearch/gateway/Gateway$GatewayStateRecoveredListener;)V .J Kschedulew(Lorg/elasticsearch/common/unit/TimeValue;Ljava/lang/String;Ljava/lang/Runnable;)Ljava/util/concurrent/ScheduledFuture; MN nO!()Ljava/util/concurrent/Executor; HQ nR Kjava/util/concurrent/ExecutorUexecute(Ljava/lang/Runnable;)V WX VYperforming state recovery...[trace ] ^D(Lorg/elasticsearch/gateway/Gateway$GatewayStateRecoveredListener;)V -` arecoveryListenerALorg/elasticsearch/gateway/Gateway$GatewayStateRecoveredListener;+()Lorg/elasticsearch/common/unit/TimeValue; access$000W(Lorg/elasticsearch/gateway/GatewayService;)Ljava/util/concurrent/atomic/AtomicBoolean;x0 access$100U(Lorg/elasticsearch/gateway/GatewayService;)Lorg/elasticsearch/common/unit/TimeValue; access$200W(Lorg/elasticsearch/gateway/GatewayService;)Lorg/elasticsearch/common/logging/ESLogger; access$300O(Lorg/elasticsearch/gateway/GatewayService;)Lorg/elasticsearch/gateway/Gateway; access$400 access$500l(Lorg/elasticsearch/gateway/GatewayService;)Lorg/elasticsearch/cluster/routing/allocation/AllocationService; access$600 access$700 access$900V(Lorg/elasticsearch/gateway/GatewayService;)Lorg/elasticsearch/cluster/ClusterService; access$1000 access$1100,org/elasticsearch/cluster/block/ClusterBlocky!state not recovered / initialized{!org/elasticsearch/rest/RestStatus}SERVICE_UNAVAILABLE#Lorg/elasticsearch/rest/RestStatus;  ~1org/elasticsearch/cluster/block/ClusterBlockLevelALLLjava/util/EnumSet;  N(ILjava/lang/String;ZZLorg/elasticsearch/rest/RestStatus;Ljava/util/EnumSet;)V . ztimeValueMinutes,(J)Lorg/elasticsearch/common/unit/TimeValue;  pCodeLocalVariableTableLineNumberTable StackMapTableRuntimeVisibleAnnotations Exceptions Signature SourceFile InnerClasses! !"#$%&%'%(%)%*%+,-,./*+3*5Y8:*5Y8<*,>*-@*B*D*F**JLRX\^**J`RX\b**JdRX\f:*^*b *fr:**Jtxz**J|RX\~**JRX\**J+RXX\*BRH !"|RNIJO P%Q+R1S7UMVcWyY|Z[^_`bef"Thjlnp06X*>W*D-*BL++ *+*¹*B*X& j mno5p;r>sMuWv;6G*B**>W z {|68 *>    z,*߶++ *+,, "+ EM+N+*D*¹'*~M-*~?*Y-*~  ¹*N-*@*Y-*  ¹*N-*@*Y-*  ¹/*^8*f0*b(6Y*z   :6":*^F-*^86Y$*^&-  :*bF-*b86Y$*b*-  :K*fC-*f56Y$*f,-  :*0R;"12Z34`12e34MMM52H6f(>z 8;]`e{~CL" (QRR<R(JG-./ Y*8Y;>:M*zF*<B~*DY*zSY-SG*F*zIY*LPWG*:B;*FS Y*TZ*\¹_*>b4521234cd. )D`lp `(#e/*z !fg/*: h0ij/*z h0kl/* h0mn/*> h0ol/* h0pq/*@ h0rl/* h0sl/* h0tu/*B h0vg/*< h0wl/* h0x6< zY|r 24"