Edit C:\dspace\webapps\solr\WEB-INF\lib\org\apache\zookeeper\server\quorum\Leader.class
???? 1? ? ? ?? ? ? ? ? ? ? ? ???????? * * * * ! 3" 3# 3$ 3%&'( 3) * +, -. / 30&12 C3 4 56 7 589 : 5; I< => N? @ NA B C D EF 5G 5H IJ YK L YH ????M ?N O P ?Q RST U VW X YZ[Z\] n^ ?_ `abc&d e fg hi +j ?k???? lm +no pq r st u ?Y nv nw nxy 5z{ |}~ ??&? N? *???&? s? 5? YZ? n?&??&????Y??&???&??&??&????&?? ? ????&??? ? ?? ? ? 5? ?? ? ??? ? n? ? ? ?? Y? ? E??? ??? ? ?? ??? ?? ????? ??? ??????? ? ?? ? ?? Y?? ??? ?? ? ? ? ? ? ? ?? e? I: I??? I?? ????Y???&? 5? ? ? 5? ?????&??:>@BDFHJLNPRTVXZ\?? ????? 3?? XidRolloverException InnerClasses? ToBeAppliedRequestProcessor LearnerCnxAcceptor Proposal LOG Lorg/slf4j/Logger; nodelay Z zk :Lorg/apache/zookeeper/server/quorum/LeaderZooKeeperServer; self /Lorg/apache/zookeeper/server/quorum/QuorumPeer; quorumFormed cnxAcceptor >Lorg/apache/zookeeper/server/quorum/Leader$LearnerCnxAcceptor; learners Ljava/util/HashSet; Signature HLjava/util/HashSet<Lorg/apache/zookeeper/server/quorum/LearnerHandler;>; forwardingFollowers observingLearners pendingSyncs Ljava/util/HashMap; nLjava/util/HashMap<Ljava/lang/Long;Ljava/util/List<Lorg/apache/zookeeper/server/quorum/LearnerSyncRequest;>;>; followerCounter (Ljava/util/concurrent/atomic/AtomicLong; ss Ljava/net/ServerSocket; DIFF I ConstantValue TRUNC SNAP OBSERVERINFO NEWLEADER FOLLOWERINFO UPTODATE LEADERINFO ACKEPOCH REQUEST PROPOSAL ACK COMMIT PING REVALIDATE SYNC INFORM outstandingProposals $Ljava/util/concurrent/ConcurrentMap; jLjava/util/concurrent/ConcurrentMap<Ljava/lang/Long;Lorg/apache/zookeeper/server/quorum/Leader$Proposal;>; toBeApplied ,Ljava/util/concurrent/ConcurrentLinkedQueue; bLjava/util/concurrent/ConcurrentLinkedQueue<Lorg/apache/zookeeper/server/quorum/Leader$Proposal;>; newLeaderProposal 4Lorg/apache/zookeeper/server/quorum/Leader$Proposal; leaderStateSummary 1Lorg/apache/zookeeper/server/quorum/StateSummary; epoch J waitingForNewEpoch readyToStart isShutdown lastCommitted lastProposed connectingFollowers %Ljava/util/HashSet<Ljava/lang/Long;>; electingFollowers electionFinished getLearners ()Ljava/util/List; Code LineNumberTable LocalVariableTable this +Lorg/apache/zookeeper/server/quorum/Leader; G()Ljava/util/List<Lorg/apache/zookeeper/server/quorum/LearnerHandler;>; getForwardingFollowers addForwardingFollower 6(Lorg/apache/zookeeper/server/quorum/LearnerHandler;)V lh 3Lorg/apache/zookeeper/server/quorum/LearnerHandler; getObservingLearners addObserverLearnerHandler getNumPendingSyncs ()I addLearnerHandler learner removeLearnerHandler peer isLearnerSynced 6(Lorg/apache/zookeeper/server/quorum/LearnerHandler;)Z <init> l(Lorg/apache/zookeeper/server/quorum/QuorumPeer;Lorg/apache/zookeeper/server/quorum/LeaderZooKeeperServer;)V e Ljava/net/BindException; Exceptions lead ()V f i$ Ljava/util/Iterator; followerSet Ljava/lang/InterruptedException; zxid syncedSet initialZxid Ljava/lang/String; tickSkip LocalVariableTypeTable shutdown (Ljava/lang/String;)V Ljava/io/IOException; it reason ILjava/util/Iterator<Lorg/apache/zookeeper/server/quorum/LearnerHandler;>; processAck (JJLjava/net/SocketAddress;)V packetZxid p r 7Lorg/apache/zookeeper/server/quorum/LearnerSyncRequest; sid followerAddr Ljava/net/SocketAddress; sendPacket 4(Lorg/apache/zookeeper/server/quorum/QuorumPacket;)V qp 1Lorg/apache/zookeeper/server/quorum/QuorumPacket; sendObserverPacket commit (J)V inform 7(Lorg/apache/zookeeper/server/quorum/Leader$Proposal;)V proposal getEpoch ()J propose [(Lorg/apache/zookeeper/server/Request;)Lorg/apache/zookeeper/server/quorum/Leader$Proposal; msg request %Lorg/apache/zookeeper/server/Request; baos Ljava/io/ByteArrayOutputStream; boa %Lorg/apache/jute/BinaryOutputArchive; pp processSync :(Lorg/apache/zookeeper/server/quorum/LearnerSyncRequest;)V l Ljava/util/List; ILjava/util/List<Lorg/apache/zookeeper/server/quorum/LearnerSyncRequest;>; sendSync startForwarding 7(Lorg/apache/zookeeper/server/quorum/LearnerHandler;J)J Ljava/lang/Long; zxids handler lastSeenZxid "Ljava/util/List<Ljava/lang/Long;>; getEpochToPropose (JJ)J start cur end verifier <Lorg/apache/zookeeper/server/quorum/flexible/QuorumVerifier; lastAcceptedEpoch waitForEpochAck 5(JLorg/apache/zookeeper/server/quorum/StateSummary;)V id getSidSetString #(Ljava/util/Set;)Ljava/lang/String; sidSet Ljava/util/Set; sids Ljava/lang/StringBuilder; iter !Ljava/util/Set<Ljava/lang/Long;>; &Ljava/util/Iterator<Ljava/lang/Long;>; 5(Ljava/util/Set<Ljava/lang/Long;>;)Ljava/lang/String; startZkServer waitForNewLeaderAck? LearnerType @(JJLorg/apache/zookeeper/server/quorum/QuorumPeer$LearnerType;)V currentZxid learnerType ;Lorg/apache/zookeeper/server/quorum/QuorumPeer$LearnerType; getPacketType (I)Ljava/lang/String; packetType access$000 ()Z access$100 ()Lorg/slf4j/Logger; <clinit> SourceFile Leader.java"#$%-. java/util/ArrayList??1.??2.34????????*% java/util/HashSet java/util/HashMap &java/util/concurrent/atomic/AtomicLong??67 &java/util/concurrent/ConcurrentHashMap^_ *java/util/concurrent/ConcurrentLinkedQueueab 2org/apache/zookeeper/server/quorum/Leader$Proposaldehij%k%mio.q.r%()??? java/net/ServerSocket?? ??89 java/net/BindException java/lang/StringBuilder Couldn't bind to port Couldn't bind to &'?i !LEADING - LEADER ELECTION TOOK - i? -org/apache/zookeeper/server/quorum/LeaderBean?;? /org/apache/zookeeper/server/quorum/StateSummary??? fg <org/apache/zookeeper/server/quorum/Leader$LearnerCnxAcceptor?!+,??"?#???$%?&?'?ni /org/apache/zookeeper/server/quorum/QuorumPacket?()? NEWLEADER proposal has Zxid of *+??,?-??? java/lang/InterruptedException <Waiting for a quorum of followers, only synced with sids: [ ..?? ]??/012?34 1org/apache/zookeeper/server/quorum/LearnerHandler5?6789:;< EEnough followers present. Perhaps the initTicks need to be increased.=?>;?@??? !zookeeper.testingonly.initialZxidABCD zookeeper.leaderServes yesAE noFG?HIJKLstM?NOP? :Not sufficient followers synced, only synced with sids: [ Q! Shutting downl% Shutdown called java/lang/Exception shutdown Leader! reason: ??R?S? java/io/IOException *Ignoring unexpected exception during close=T?????U? Ack zxid: 0x{}VWXYZ[ outstanding proposal: 0x{} outstanding proposals allV?\? outstanding is 0]? ;proposal has already been committed, pzxid: 0x{} zxid: 0x{}]^_` 3Trying to commit future proposal: zxid 0x{} from {}=^ Count for zxid: 0x{} is {}a6b &Commiting zxid 0x{} from {} not first! First is 0x{}=W?`?? .Going to commmit null request for proposal: {}????cde?fg? java/util/List 5org/apache/zookeeper/server/quorum/LearnerSyncRequest??h??t??i?ijk??lm Wzxid lower 32 bits have rolled over, forcing re-election, and therefore new epoch start >org/apache/zookeeper/server/quorum/Leader$XidRolloverException?? java/io/ByteArrayOutputStreamnop?q hdrrst?u txnv This really should be impossiblewk Proposing:: xyz?{|}~? java/lang/Long??|}?}?????????? +Timeout while waiting for epoch from quorum?? 1Follower is ahead of the leader, leader summary: (current epoch), ?? (last zxid) 5Timeout while waiting for epoch to be acked by quorum? , #Have quorum of supporters, sids: [ 5 ]; starting up and setting last processed zxid: 0x{}W??????????? NEWLEADER ACK from sid: ' is from a different epoch - current 0x receieved 0x ? 9Timeout while waiting for NEWLEADER to be acked by quorum UNKNOWN )org/apache/zookeeper/server/quorum/Leader??? leader.nodelay true TCP NoDelay set to: ? java/lang/Object Eorg/apache/zookeeper/server/quorum/Leader$ToBeAppliedRequestProcessor 9org/apache/zookeeper/server/quorum/QuorumPeer$LearnerType (Ljava/util/Collection;)V add (Ljava/lang/Object;)Z size remove contains -org/apache/zookeeper/server/quorum/QuorumPeer getQuorumListenOnAllIPs getQuorumAddress ()Ljava/net/InetSocketAddress; java/net/InetSocketAddress getPort (I)V setReuseAddress (Z)V bind (Ljava/net/SocketAddress;)V append -(Ljava/lang/String;)Ljava/lang/StringBuilder; (I)Ljava/lang/StringBuilder; toString ()Ljava/lang/String; org/slf4j/Logger error *(Ljava/lang/String;Ljava/lang/Throwable;)V -(Ljava/lang/Object;)Ljava/lang/StringBuilder; java/lang/System currentTimeMillis end_fle start_fle (J)Ljava/lang/StringBuilder; info [(Lorg/apache/zookeeper/server/quorum/Leader;Lorg/apache/zookeeper/server/ZooKeeperServer;)V jmxLocalPeerBean 2Lorg/apache/zookeeper/server/quorum/LocalPeerBean; 8org/apache/zookeeper/server/quorum/LeaderZooKeeperServer registerJMX d(Lorg/apache/zookeeper/server/quorum/LeaderBean;Lorg/apache/zookeeper/server/quorum/LocalPeerBean;)V tick loadData getCurrentEpoch getLastProcessedZxid (JJ)V .(Lorg/apache/zookeeper/server/quorum/Leader;)V getId getAcceptedEpoch *org/apache/zookeeper/server/util/ZxidUtils makeZxid setZxid getZxid (IJ[BLjava/util/List;)V packet toHexString (J)Ljava/lang/String; setCurrentEpoch PARTICIPANT ackSet iterator ()Ljava/util/Iterator; java/util/Iterator hasNext next ()Ljava/lang/Object; getSid valueOf (J)Ljava/lang/Long; getQuorumVerifier >()Lorg/apache/zookeeper/server/quorum/flexible/QuorumVerifier; :org/apache/zookeeper/server/quorum/flexible/QuorumVerifier containsQuorum (Ljava/util/HashSet;)Z warn tickTime java/lang/Thread sleep getProperty &(Ljava/lang/String;)Ljava/lang/String; parseLong (Ljava/lang/String;)J 8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; java/lang/String equals cnxnFactory /Lorg/apache/zookeeper/server/ServerCnxnFactory; -org/apache/zookeeper/server/ServerCnxnFactory setZooKeeperServer 0(Lorg/apache/zookeeper/server/ZooKeeperServer;)V synced getLearnerType =()Lorg/apache/zookeeper/server/quorum/QuorumPeer$LearnerType; ping unregisterJMX halt close closeAll isTraceEnabled trace '(Ljava/lang/String;Ljava/lang/Object;)V "java/util/concurrent/ConcurrentMap values ()Ljava/util/Collection; java/util/Collection isDebugEnabled debug 9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V get &(Ljava/lang/Object;)Ljava/lang/Object; java/lang/Integer (I)Ljava/lang/Integer; commitProcessor 4Lorg/apache/zookeeper/server/quorum/CommitProcessor; 2org/apache/zookeeper/server/quorum/CommitProcessor ((Lorg/apache/zookeeper/server/Request;)V containsKey queuePacket #org/apache/zookeeper/server/Request getData ()[B getEpochFromZxid (J)J #org/apache/jute/BinaryOutputArchive getArchive =(Ljava/io/OutputStream;)Lorg/apache/jute/BinaryOutputArchive; $Lorg/apache/zookeeper/txn/TxnHeader; "org/apache/zookeeper/txn/TxnHeader serialize 4(Lorg/apache/jute/OutputArchive;Ljava/lang/String;)V Lorg/apache/jute/Record; org/apache/jute/Record toByteArray put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; isEmpty fh keySet ()Ljava/util/Set; java/util/Collections sort (Ljava/util/List;)V longValue setAcceptedEpoch notifyAll getInitLimit getTickTime wait isMoreRecentThan 4(Lorg/apache/zookeeper/server/quorum/StateSummary;)Z getLastZxid java/util/Set startup updateElectionVote getZKDatabase *()Lorg/apache/zookeeper/server/ZKDatabase; &org/apache/zookeeper/server/ZKDatabase setlastProcessedZxid org/slf4j/LoggerFactory getLogger %(Ljava/lang/Class;)Lorg/slf4j/Logger; (Z)Ljava/lang/StringBuilder; ! * "# $% &' () *% +, -. / 0 1. / 0 2. / 0 34 / 5 67 89 :; <