Edit C:\dspace\webapps\jspui\WEB-INF\lib\org\elasticsearch\discovery\local\LocalDiscovery$4.class
???? 3 ? 2org/elasticsearch/discovery/local/LocalDiscovery$4 9org/elasticsearch/cluster/ClusterStateNonMasterUpdateTask LocalDiscovery.java 0org/elasticsearch/discovery/local/LocalDiscovery doStop ()V 3org/elasticsearch/cluster/node/DiscoveryNodes$Delta -org/elasticsearch/cluster/node/DiscoveryNodes Delta Eorg/elasticsearch/cluster/routing/allocation/RoutingAllocation$Result >org/elasticsearch/cluster/routing/allocation/RoutingAllocation Result .org/elasticsearch/cluster/ClusterState$Builder &org/elasticsearch/cluster/ClusterState Builder val$newMembers Ljava/util/Set; val$master 2Lorg/elasticsearch/discovery/local/LocalDiscovery; this$0 <init> v(Lorg/elasticsearch/discovery/local/LocalDiscovery;Ljava/util/Set;Lorg/elasticsearch/discovery/local/LocalDiscovery;)V ! # % ' this 4Lorg/elasticsearch/discovery/local/LocalDiscovery$4; execute R(Lorg/elasticsearch/cluster/ClusterState;)Lorg/elasticsearch/cluster/ClusterState; nodes 1()Lorg/elasticsearch/cluster/node/DiscoveryNodes; - . / access$300 b(Lorg/elasticsearch/discovery/local/LocalDiscovery;)Lorg/elasticsearch/cluster/node/DiscoveryNode; 1 2 3 ,org/elasticsearch/cluster/node/DiscoveryNode 5 id ()Ljava/lang/String; 7 8 6 9 removeDeadMembers R(Ljava/util/Set;Ljava/lang/String;)Lorg/elasticsearch/cluster/node/DiscoveryNodes; ; < = delta f(Lorg/elasticsearch/cluster/node/DiscoveryNodes;)Lorg/elasticsearch/cluster/node/DiscoveryNodes$Delta; ? @ A added ()Z C D E access$900 _(Lorg/elasticsearch/discovery/local/LocalDiscovery;)Lorg/elasticsearch/common/logging/ESLogger; G H I DNo new nodes should be created when a new discovery view is accepted K java/lang/Object M )org/elasticsearch/common/logging/ESLogger O warn ((Ljava/lang/String;[Ljava/lang/Object;)V Q R P S builder Z(Lorg/elasticsearch/cluster/ClusterState;)Lorg/elasticsearch/cluster/ClusterState$Builder; U V W a(Lorg/elasticsearch/cluster/node/DiscoveryNodes;)Lorg/elasticsearch/cluster/ClusterState$Builder; - Y Z build *()Lorg/elasticsearch/cluster/ClusterState; \ ] ^ access$1000 t(Lorg/elasticsearch/discovery/local/LocalDiscovery;)Lorg/elasticsearch/cluster/routing/allocation/AllocationService; ` a b >org/elasticsearch/cluster/routing/allocation/AllocationService d reroute q(Lorg/elasticsearch/cluster/ClusterState;)Lorg/elasticsearch/cluster/routing/allocation/RoutingAllocation$Result; f g e h routingResult y(Lorg/elasticsearch/cluster/routing/allocation/RoutingAllocation$Result;)Lorg/elasticsearch/cluster/ClusterState$Builder; j k l currentState (Lorg/elasticsearch/cluster/ClusterState; newNodes /Lorg/elasticsearch/cluster/node/DiscoveryNodes; 5Lorg/elasticsearch/cluster/node/DiscoveryNodes$Delta; updatedState GLorg/elasticsearch/cluster/routing/allocation/RoutingAllocation$Result; onFailure *(Ljava/lang/String;Ljava/lang/Throwable;)V access$1100 w H x unexpected failure during [{}] z error =(Ljava/lang/String;Ljava/lang/Throwable;[Ljava/lang/Object;)V | } P ~ source Ljava/lang/String; t Ljava/lang/Throwable; Code LocalVariableTable LineNumberTable StackMapTable SourceFile EnclosingMethod InnerClasses ? >