Edit C:\dspace\webapps\swordv2\WEB-INF\lib\org\elasticsearch\discovery\zen\ZenDiscovery$7.class
???? 3 .org/elasticsearch/discovery/zen/ZenDiscovery$7 Borg/elasticsearch/cluster/ProcessedClusterStateNonMasterUpdateTask ZenDiscovery.java ,org/elasticsearch/discovery/zen/ZenDiscovery handleMasterGone C(Lorg/elasticsearch/cluster/node/DiscoveryNode;Ljava/lang/String;)V @org/elasticsearch/discovery/zen/ZenDiscovery$ProcessClusterState ProcessClusterState 5org/elasticsearch/cluster/node/DiscoveryNodes$Builder -org/elasticsearch/cluster/node/DiscoveryNodes Builder .org/elasticsearch/cluster/ClusterState$Builder &org/elasticsearch/cluster/ClusterState val$masterNode .Lorg/elasticsearch/cluster/node/DiscoveryNode; val$reason Ljava/lang/String; this$0 .Lorg/elasticsearch/discovery/zen/ZenDiscovery; <init> q(Lorg/elasticsearch/discovery/zen/ZenDiscovery;Lorg/elasticsearch/cluster/node/DiscoveryNode;Ljava/lang/String;)V ! # ()V % & this 0Lorg/elasticsearch/discovery/zen/ZenDiscovery$7; execute R(Lorg/elasticsearch/cluster/ClusterState;)Lorg/elasticsearch/cluster/ClusterState; ,org/elasticsearch/cluster/node/DiscoveryNode , id ()Ljava/lang/String; . / - 0 nodes 1()Lorg/elasticsearch/cluster/node/DiscoveryNodes; 2 3 4 masterNodeId 6 / 7 java/lang/String 9 equals (Ljava/lang/Object;)Z ; < : = builder h(Lorg/elasticsearch/cluster/node/DiscoveryNodes;)Lorg/elasticsearch/cluster/node/DiscoveryNodes$Builder; ? @ A remove K(Ljava/lang/String;)Lorg/elasticsearch/cluster/node/DiscoveryNodes$Builder; C D E 6 D G build I 3 J java/util/ArrayList L M & access$2100 T(Lorg/elasticsearch/discovery/zen/ZenDiscovery;)Ljava/util/concurrent/BlockingQueue; O P Q "java/util/concurrent/BlockingQueue S drainTo (Ljava/util/Collection;)I U V T W access$2200 [(Lorg/elasticsearch/discovery/zen/ZenDiscovery;)Lorg/elasticsearch/common/logging/ESLogger; Y Z [ #removed [{}] pending cluster states ] java/lang/Object _ size ()I a b M c java/lang/Integer e valueOf (I)Ljava/lang/Integer; g h f i )org/elasticsearch/common/logging/ESLogger k trace ((Ljava/lang/String;[Ljava/lang/Object;)V m n l o access$2300 1(Lorg/elasticsearch/discovery/zen/ZenDiscovery;)Z q r s access$2400 u Z v 4not rejoining cluster due to rejoinOnMasterGone [{}] x java/lang/Boolean z (Z)Ljava/lang/Boolean; g | { } debug n l ? smallestNonClientNodeVersion ()Lorg/elasticsearch/Version; ? ? ? org/elasticsearch/Version ? V_1_4_0_Beta1 Lorg/elasticsearch/Version; ? ? ? ? before (Lorg/elasticsearch/Version;)Z ? ? ? ? access$2500 ? Z ? 8not rejoining cluster due a minimum node version of [{}] ? Z(Lorg/elasticsearch/cluster/ClusterState;)Lorg/elasticsearch/cluster/ClusterState$Builder; ? ? ? a(Lorg/elasticsearch/cluster/node/DiscoveryNodes;)Lorg/elasticsearch/cluster/ClusterState$Builder; 2 ? ? *()Lorg/elasticsearch/cluster/ClusterState; I ? ? java/lang/StringBuilder ? ? & master left (reason = ? append -(Ljava/lang/String;)Ljava/lang/StringBuilder; ? ? ? ? ) ? toString ? / ? ? access$1700 ?(Lorg/elasticsearch/discovery/zen/ZenDiscovery;Lorg/elasticsearch/cluster/ClusterState;Ljava/lang/String;)Lorg/elasticsearch/cluster/ClusterState; ? ? ? access$1600 j(Lorg/elasticsearch/discovery/zen/ZenDiscovery;)Lorg/elasticsearch/discovery/zen/elect/ElectMasterService; ? ? ? 8org/elasticsearch/discovery/zen/elect/ElectMasterService ? hasEnoughMasterNodes (Ljava/lang/Iterable;)Z ? ? ? ? 4not enough master nodes after master left (reason = ? electMaster D(Ljava/lang/Iterable;)Lorg/elasticsearch/cluster/node/DiscoveryNode; ? ? ? ? localNode 0()Lorg/elasticsearch/cluster/node/DiscoveryNode; ? ? ? - = access$2600 i(Lorg/elasticsearch/discovery/zen/ZenDiscovery;)Lorg/elasticsearch/discovery/zen/fd/MasterFaultDetection; ? ? ? 6got elected as new master since master left (reason = ? 7org/elasticsearch/discovery/zen/fd/MasterFaultDetection ? stop (Ljava/lang/String;)V ? ? ? ? access$1000 h(Lorg/elasticsearch/discovery/zen/ZenDiscovery;)Lorg/elasticsearch/discovery/zen/fd/NodesFaultDetection; ? ? ? 6org/elasticsearch/discovery/zen/fd/NodesFaultDetection ? updateNodesAndPing +(Lorg/elasticsearch/cluster/ClusterState;)V ? ? ? ? :()Lorg/elasticsearch/discovery/zen/fd/NodesFaultDetection; ? ? ? ? 4possible elected master since master left (reason = ? restart ? ? ? 6master_left and no other node elected to become master ? newState (Lorg/elasticsearch/cluster/ClusterState; currentState discoveryNodes /Lorg/elasticsearch/cluster/node/DiscoveryNodes; pendingNewClusterStates YLjava/util/ArrayList<Lorg/elasticsearch/discovery/zen/ZenDiscovery$ProcessClusterState;>; Ljava/util/ArrayList; rejoin Z electedMaster onFailure *(Ljava/lang/String;Ljava/lang/Throwable;)V access$2700 ? Z ? unexpected failure during [{}] ? error =(Ljava/lang/String;Ljava/lang/Throwable;[Ljava/lang/Object;)V ? ? l ? source t Ljava/lang/Throwable; clusterStateProcessed e(Ljava/lang/String;Lorg/elasticsearch/cluster/ClusterState;Lorg/elasticsearch/cluster/ClusterState;)V access$1100 1(Lorg/elasticsearch/discovery/zen/ZenDiscovery;)V oldState Code LocalVariableTable LineNumberTable LocalVariableTypeTable StackMapTable SourceFile EnclosingMethod InnerClasses >