3-.org/elasticsearch/discovery/zen/ZenDiscovery$9Borg/elasticsearch/cluster/ProcessedClusterStateNonMasterUpdateTaskZenDiscovery.java,org/elasticsearch/discovery/zen/ZenDiscoveryhandleNewClusterStateFromMaster(Lorg/elasticsearch/cluster/ClusterState;Lorg/elasticsearch/discovery/zen/publish/PublishClusterStateAction$NewClusterStateListener$NewStateProcessed;)V  @org/elasticsearch/discovery/zen/ZenDiscovery$ProcessClusterState ProcessClusterStateYorg/elasticsearch/discovery/zen/publish/PublishClusterStateAction$NewClusterStateListenerAorg/elasticsearch/discovery/zen/publish/PublishClusterStateActionNewClusterStateListenerkorg/elasticsearch/discovery/zen/publish/PublishClusterStateAction$NewClusterStateListener$NewStateProcessedNewStateProcessed3org/elasticsearch/cluster/metadata/MetaData$Builder+org/elasticsearch/cluster/metadata/MetaDataBuilder.org/elasticsearch/cluster/ClusterState$Builder&org/elasticsearch/cluster/ClusterStateval$processClusterStateBLorg/elasticsearch/discovery/zen/ZenDiscovery$ProcessClusterState;val$newStateProcessedmLorg/elasticsearch/discovery/zen/publish/PublishClusterStateAction$NewClusterStateListener$NewStateProcessed;this$0.Lorg/elasticsearch/discovery/zen/ZenDiscovery;(Lorg/elasticsearch/discovery/zen/ZenDiscovery;Lorg/elasticsearch/discovery/zen/ZenDiscovery$ProcessClusterState;Lorg/elasticsearch/discovery/zen/publish/PublishClusterStateAction$NewClusterStateListener$NewStateProcessed;)V #$ '  ) !" +()V %- .this0Lorg/elasticsearch/discovery/zen/ZenDiscovery$9;executeR(Lorg/elasticsearch/cluster/ClusterState;)Lorg/elasticsearch/cluster/ClusterState; processedZ 45 6 access$2100T(Lorg/elasticsearch/discovery/zen/ZenDiscovery;)Ljava/util/concurrent/BlockingQueue; 89 :"java/util/concurrent/BlockingQueue<poll()Ljava/lang/Object; >? =@peek B? =C clusterState(Lorg/elasticsearch/cluster/ClusterState; EF Gnodes1()Lorg/elasticsearch/cluster/node/DiscoveryNodes; IJ K-org/elasticsearch/cluster/node/DiscoveryNodesM masterNodeId()Ljava/lang/String; OP NQ%org/elasticsearch/common/base/ObjectsSequal'(Ljava/lang/Object;Ljava/lang/Object;)Z UV TWversion()J YZ [ access$2600i(Lorg/elasticsearch/discovery/zen/ZenDiscovery;)Lorg/elasticsearch/discovery/zen/fd/MasterFaultDetection; ]^ _7org/elasticsearch/discovery/zen/fd/MasterFaultDetectiona masterNode0()Lorg/elasticsearch/cluster/node/DiscoveryNode; cd be Ne,org/elasticsearch/cluster/node/DiscoveryNodehequals(Ljava/lang/Object;)Z jk iljava/lang/StringBuildern o.Cnew cluster state received and we are monitoring the wrong master [qappend-(Ljava/lang/String;)Ljava/lang/StringBuilder; st ou-(Ljava/lang/Object;)Ljava/lang/StringBuilder; sw ox]ztoString |P o}restartC(Lorg/elasticsearch/cluster/node/DiscoveryNode;Ljava/lang/String;)V  bblocks1()Lorg/elasticsearch/cluster/block/ClusterBlocks;  access$700_(Lorg/elasticsearch/discovery/zen/ZenDiscovery;)Lorg/elasticsearch/discovery/DiscoverySettings; -org/elasticsearch/discovery/DiscoverySettingsgetNoMasterBlock0()Lorg/elasticsearch/cluster/block/ClusterBlock; -org/elasticsearch/cluster/block/ClusterBlockshasGlobalBlock1(Lorg/elasticsearch/cluster/block/ClusterBlock;)Z  access$3000[(Lorg/elasticsearch/discovery/zen/ZenDiscovery;)Lorg/elasticsearch/common/logging/ESLogger; &got first state from fresh master [{}]java/lang/Object)org/elasticsearch/common/logging/ESLoggerdebug((Ljava/lang/String;[Ljava/lang/Object;)V  access$1200X(Lorg/elasticsearch/discovery/zen/ZenDiscovery;)Ljava/util/concurrent/atomic/AtomicLong; &java/util/concurrent/atomic/AtomicLongincrementAndGet Z  access$3100 $updated cluster join cluster to [{}]java/lang/LongvalueOf(J)Ljava/lang/Long; trace builderZ(Lorg/elasticsearch/cluster/ClusterState;)Lorg/elasticsearch/cluster/ClusterState$Builder;  routingTable2()Lorg/elasticsearch/cluster/routing/RoutingTable; .org/elasticsearch/cluster/routing/RoutingTable [b(Lorg/elasticsearch/cluster/routing/RoutingTable;)Lorg/elasticsearch/cluster/ClusterState$Builder; metaData/()Lorg/elasticsearch/cluster/metadata/MetaData;  [_(Lorg/elasticsearch/cluster/metadata/MetaData;)Lorg/elasticsearch/cluster/ClusterState$Builder; d(Lorg/elasticsearch/cluster/metadata/MetaData;)Lorg/elasticsearch/cluster/metadata/MetaData$Builder; removeAllIndices7()Lorg/elasticsearch/cluster/metadata/MetaData$Builder; iterator()Ljava/util/Iterator; java/util/IteratorhasNext()Z next ? 0org/elasticsearch/cluster/metadata/IndexMetaDataindex P F(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/IndexMetaData;  [putj(Lorg/elasticsearch/cluster/metadata/IndexMetaData;Z)Lorg/elasticsearch/cluster/metadata/MetaData$Builder; g(Lorg/elasticsearch/cluster/metadata/MetaData$Builder;)Lorg/elasticsearch/cluster/ClusterState$Builder; build*()Lorg/elasticsearch/cluster/ClusterState; potentialStatecountJcurrentIndexMetaData2Lorg/elasticsearch/cluster/metadata/IndexMetaData; indexMetaDatai$Ljava/util/Iterator;metaDataBuilder5Lorg/elasticsearch/cluster/metadata/MetaData$Builder; currentStatestateToProcess updatedState0Lorg/elasticsearch/cluster/ClusterState$Builder; onFailure*(Ljava/lang/String;Ljava/lang/Throwable;)V access$3200   unexpected failure during [{}] error=(Ljava/lang/String;Ljava/lang/Throwable;[Ljava/lang/Object;)V  onNewClusterStateFailed(Ljava/lang/Throwable;)V  sourceLjava/lang/String;tLjava/lang/Throwable;clusterStateProcessede(Ljava/lang/String;Lorg/elasticsearch/cluster/ClusterState;Lorg/elasticsearch/cluster/ClusterState;)V access$11001(Lorg/elasticsearch/discovery/zen/ZenDiscovery;)V  onNewClusterStateProcessed !- "oldStatenewStateCodeLocalVariableTableLineNumberTable StackMapTable SourceFileEnclosingMethod InnerClasses  !"#$%&&>*+(*,**-,*/' 01(23& **7+*(;A M,+,7*(;D N-S,HLR-HLRX6*(;A N--7-H\,H\-M,HN-\+\-LR+LRX+*(`f*(`f-Lgm5*(`-LgoYprv*(`fy{v~+*(G*(Y-LRS*(7*(YS--:-ö+öƔ +öW-Ͷ+ͶΔ+ͶWo-͸Զ:-Ͷ:H: + :     W  WW'p 7T G( 6 O`01F Fi(*   "'7;>X[korw    ;Ga!c&i){*-.1234579:=)F   &#1W!6  &i#*( ,Y+S*,,' #01##(BC"D&a*( *,#'*01$F%F(HIJ*+ ,2