Edit C:\dspace\webapps\solr\WEB-INF\lib\org\apache\zookeeper\server\quorum\LeaderElection.class
???? 1? ? ? ? ? ? ? ?? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? U ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ' ' ? / ? / / / / 6 ? ? !" C ? C#$%& '() J* ?+ ?, - . ? / 0 1 J23 U ? ?45 X6 J789 \:; \< C= C> J?@ /AB CDE F UG JHIJK ?L CM NO P QRS d TU VW X VY VZ [ ? \]^ _`a ? ?bc ElectionResult InnerClasses LOG Lorg/slf4j/Logger; epochGen Ljava/util/Random; self /Lorg/apache/zookeeper/server/quorum/QuorumPeer; <init> 2(Lorg/apache/zookeeper/server/quorum/QuorumPeer;)V Code LineNumberTable LocalVariableTable this 3Lorg/apache/zookeeper/server/quorum/LeaderElection; countVotes j(Ljava/util/HashMap;Ljava/util/HashSet;)Lorg/apache/zookeeper/server/quorum/LeaderElection$ElectionResult; val Ljava/lang/Long; v )Lorg/apache/zookeeper/server/quorum/Vote; e Entry Ljava/util/Map$Entry; i$ Ljava/util/Iterator; zxid count Ljava/lang/Integer; entry votes Ljava/util/HashMap; heardFrom Ljava/util/HashSet; result BLorg/apache/zookeeper/server/quorum/LeaderElection$ElectionResult; validVotes maxZxids Ljava/util/Map; countTable LocalVariableTypeTable \Ljava/util/Map$Entry<Ljava/net/InetSocketAddress;Lorg/apache/zookeeper/server/quorum/Vote;>; SLjava/util/Map$Entry<Lorg/apache/zookeeper/server/quorum/Vote;Ljava/lang/Integer;>; ZLjava/util/HashMap<Ljava/net/InetSocketAddress;Lorg/apache/zookeeper/server/quorum/Vote;>; %Ljava/util/HashSet<Ljava/lang/Long;>; 1Ljava/util/Map<Ljava/lang/Long;Ljava/lang/Long;>; QLjava/util/HashMap<Lorg/apache/zookeeper/server/quorum/Vote;Ljava/lang/Integer;>; Signature ?(Ljava/util/HashMap<Ljava/net/InetSocketAddress;Lorg/apache/zookeeper/server/quorum/Vote;>;Ljava/util/HashSet<Ljava/lang/Long;>;)Lorg/apache/zookeeper/server/quorum/LeaderElection$ElectionResult; shutdown ()V lookForLeader +()Lorg/apache/zookeeper/server/quorum/Vote; Ljava/lang/Exception; e1 Ljava/net/SocketException; $Ljava/lang/IllegalArgumentException; recvedXid I peerId J vote addr Ljava/net/InetSocketAddress; Ljava/io/IOException; server QuorumServer <Lorg/apache/zookeeper/server/quorum/QuorumPeer$QuorumServer; current requestBytes [B requestBuffer Ljava/nio/ByteBuffer; responseBytes responseBuffer s Ljava/net/DatagramSocket; requestPacket Ljava/net/DatagramPacket; responsePacket xid Exceptionsd <clinit> SourceFile LeaderElection.java Deprecated RuntimeVisibleAnnotations Ljava/lang/Deprecated; ? ? ? ? @org/apache/zookeeper/server/quorum/LeaderElection$ElectionResult 'org/apache/zookeeper/server/quorum/Vote ?e ? ?f ? java/util/HashMapghijklmnopq java/util/Map$Entryrpstuvwxypz{|} java/lang/Long~tt?t?t?? ???}??? ???? java/lang/Integeru??? ? ?? ? ? ? Election tally: ??? java/lang/StringBuilder?? -> ?????? 5org/apache/zookeeper/server/quorum/LeaderElectionBean?????????? java/lang/Exception Failed to register with JMX???t????? java/net/DatagramSocket?? java/net/SocketException 9Socket exception when creating socket for leader election????? java/net/DatagramPacket ?? ? ????n?? ???????? java/util/HashSet :org/apache/zookeeper/server/quorum/QuorumPeer$QuorumServer Server address: ? ??? "java/lang/IllegalArgumentException ,Unable to set socket address on packet, msg:?? with addr: ???????? Got a short response: ?????? Got bad xid: expected got ?t?x?? java/net/InetSocketAddress java/io/IOException +Ignoring exception while looking for leader ? ?? ?? ? Found leader: my type is: ????? OBSERVER elected as leader!???????????????? Failed to unregister with JMX 1org/apache/zookeeper/server/quorum/LeaderElection??? java/util/Random java/lang/Object +org/apache/zookeeper/server/quorum/Election java/lang/InterruptedException (JJ)V winner entrySet ()Ljava/util/Set; java/util/Set iterator ()Ljava/util/Iterator; java/util/Iterator hasNext ()Z next ()Ljava/lang/Object; java/util/Map getValue getId ()J valueOf (J)Ljava/lang/Long; contains (Ljava/lang/Object;)Z getKey put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; get &(Ljava/lang/Object;)Ljava/lang/Object; longValue getZxid getElectionEpoch getPeerEpoch getState ServerState =()Lorg/apache/zookeeper/server/quorum/QuorumPeer$ServerState; B(JJJJLorg/apache/zookeeper/server/quorum/QuorumPeer$ServerState;)V setValue size ()I numValidVotes values ()Ljava/util/Collection; java/util/Collection (I)Ljava/lang/Integer; intValue winningCount org/slf4j/Logger info (Ljava/lang/String;)V append (J)Ljava/lang/StringBuilder; -(Ljava/lang/String;)Ljava/lang/StringBuilder; -(Ljava/lang/Object;)Ljava/lang/StringBuilder; toString ()Ljava/lang/String; -org/apache/zookeeper/server/quorum/QuorumPeer jmxLeaderElectionBean 7Lorg/apache/zookeeper/server/quorum/LeaderElectionBean; &org/apache/zookeeper/jmx/MBeanRegistry getInstance *()Lorg/apache/zookeeper/jmx/MBeanRegistry; jmxLocalPeerBean 2Lorg/apache/zookeeper/server/quorum/LocalPeerBean; register O(Lorg/apache/zookeeper/jmx/ZKMBeanInfo;Lorg/apache/zookeeper/jmx/ZKMBeanInfo;)V warn *(Ljava/lang/String;Ljava/lang/Throwable;)V getLastLoggedZxid setCurrentVote ,(Lorg/apache/zookeeper/server/quorum/Vote;)V java/nio/ByteBuffer wrap ([B)Ljava/nio/ByteBuffer; setSoTimeout (I)V error java/lang/System exit ([BI)V nextInt isRunning getVotingView ()Ljava/util/Map; clear ()Ljava/nio/Buffer; putInt (I)Ljava/nio/ByteBuffer; setLength setSocketAddress (Ljava/net/SocketAddress;)V getMessage send (Ljava/net/DatagramPacket;)V receive getLength (I)Ljava/lang/StringBuilder; getInt getLong add getSocketAddress ()Ljava/net/SocketAddress; close getCurrentVote getLearnerType LearnerType =()Lorg/apache/zookeeper/server/quorum/QuorumPeer$LearnerType; 9org/apache/zookeeper/server/quorum/QuorumPeer$LearnerType OBSERVER ;Lorg/apache/zookeeper/server/quorum/QuorumPeer$LearnerType; java/lang/Thread sleep (J)V 9org/apache/zookeeper/server/quorum/QuorumPeer$ServerState OBSERVING ;Lorg/apache/zookeeper/server/quorum/QuorumPeer$ServerState; setPeerState >(Lorg/apache/zookeeper/server/quorum/QuorumPeer$ServerState;)V LEADING FOLLOWING getPeerState unregister )(Lorg/apache/zookeeper/jmx/ZKMBeanInfo;)V org/slf4j/LoggerFactory getLogger %(Ljava/lang/Class;)Lorg/slf4j/Logger; ! ? ? ? ? ? ? ? ? ? ? ? ? F *? *+? ? ? 6 7 8 ? ? ? ? ? ? ? ? v ?? Y? N-? Y ? ? -? Y ? ? ? Y? :? Y? :+? ? :? ? {? ? :? ? :,? ? ? ? Q? ? W? ? ? ? : ? ? ? ?? ? ? ? ? ? W???? ? :? ? h? ? :? ? :? ? ? ? : ? ? ?? +? Y? ? ? ? ? ? ? ! W???-? "? #? Y? :? $? % :? ? ?? ? :? &? ': ? ? (: ? )`? (? W? -? ? ?? -Y? *`? *? >? -? ? ?? #? -? ? ?? ? -? ? ?? -? -? *??i-? +? ,-? . ? ? :? ? v? ? :? ? '? )-? +? "-? ? '? )? +-? ? ? ? ,? /Y? 0? ? ? ? 12? 3? ? 4? 5? . ???-? ? ? ) G I J * O 3 P <