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 YHM N O P Q RST U VW X Y Z[ Z\] n^ _ ` abc &d e fg hi +j klm +no pq r st u Y nv nw nxy 5z{ |}~  & N * & s 5 Y Z n & &  Y &  & & &  &   &      5     n    Y  E                 Y           e I: I I  Y & 5   5  &:>@BDFHJLNPRTVXZ\  3XidRolloverException InnerClassesToBeAppliedRequestProcessorLearnerCnxAcceptorProposalLOGLorg/slf4j/Logger;nodelayZzk:Lorg/apache/zookeeper/server/quorum/LeaderZooKeeperServer;self/Lorg/apache/zookeeper/server/quorum/QuorumPeer; quorumFormed cnxAcceptor>Lorg/apache/zookeeper/server/quorum/Leader$LearnerCnxAcceptor;learnersLjava/util/HashSet; SignatureHLjava/util/HashSet;forwardingFollowersobservingLearners pendingSyncsLjava/util/HashMap;nLjava/util/HashMap;>;followerCounter(Ljava/util/concurrent/atomic/AtomicLong;ssLjava/net/ServerSocket;DIFFI ConstantValue TRUNCSNAP OBSERVERINFO NEWLEADER  FOLLOWERINFO UPTODATE  LEADERINFOACKEPOCHREQUESTPROPOSALACKCOMMITPING REVALIDATESYNCINFORMoutstandingProposals$Ljava/util/concurrent/ConcurrentMap;jLjava/util/concurrent/ConcurrentMap; toBeApplied,Ljava/util/concurrent/ConcurrentLinkedQueue;bLjava/util/concurrent/ConcurrentLinkedQueue;newLeaderProposal4Lorg/apache/zookeeper/server/quorum/Leader$Proposal;leaderStateSummary1Lorg/apache/zookeeper/server/quorum/StateSummary;epochJwaitingForNewEpoch readyToStart isShutdown lastCommitted lastProposedconnectingFollowers%Ljava/util/HashSet;electingFollowerselectionFinished getLearners()Ljava/util/List;CodeLineNumberTableLocalVariableTablethis+Lorg/apache/zookeeper/server/quorum/Leader;G()Ljava/util/List;getForwardingFollowersaddForwardingFollower6(Lorg/apache/zookeeper/server/quorum/LearnerHandler;)Vlh3Lorg/apache/zookeeper/server/quorum/LearnerHandler;getObservingLearnersaddObserverLearnerHandlergetNumPendingSyncs()IaddLearnerHandlerlearnerremoveLearnerHandlerpeerisLearnerSynced6(Lorg/apache/zookeeper/server/quorum/LearnerHandler;)Zl(Lorg/apache/zookeeper/server/quorum/QuorumPeer;Lorg/apache/zookeeper/server/quorum/LeaderZooKeeperServer;)VeLjava/net/BindException; Exceptionslead()Vfi$Ljava/util/Iterator; followerSet Ljava/lang/InterruptedException;zxid syncedSet initialZxidLjava/lang/String;tickSkipLocalVariableTypeTableshutdown(Ljava/lang/String;)VLjava/io/IOException;itreasonILjava/util/Iterator; processAck(JJLjava/net/SocketAddress;)V packetZxidpr7Lorg/apache/zookeeper/server/quorum/LearnerSyncRequest;sid followerAddrLjava/net/SocketAddress; sendPacket4(Lorg/apache/zookeeper/server/quorum/QuorumPacket;)Vqp1Lorg/apache/zookeeper/server/quorum/QuorumPacket;sendObserverPacketcommit(J)Vinform7(Lorg/apache/zookeeper/server/quorum/Leader$Proposal;)VproposalgetEpoch()Jpropose[(Lorg/apache/zookeeper/server/Request;)Lorg/apache/zookeeper/server/quorum/Leader$Proposal;msgrequest%Lorg/apache/zookeeper/server/Request;baosLjava/io/ByteArrayOutputStream;boa%Lorg/apache/jute/BinaryOutputArchive;pp processSync:(Lorg/apache/zookeeper/server/quorum/LearnerSyncRequest;)VlLjava/util/List;ILjava/util/List;sendSyncstartForwarding7(Lorg/apache/zookeeper/server/quorum/LearnerHandler;J)JLjava/lang/Long;zxidshandler lastSeenZxid"Ljava/util/List;getEpochToPropose(JJ)Jstartcurendverifier;&Ljava/util/Iterator;5(Ljava/util/Set;)Ljava/lang/String; startZkServerwaitForNewLeaderAck 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; SourceFile Leader.java "# $% -.java/util/ArrayList  1.  2. 34     *%java/util/HashSetjava/util/HashMap&java/util/concurrent/atomic/AtomicLong  67&java/util/concurrent/ConcurrentHashMap ^_*java/util/concurrent/ConcurrentLinkedQueue ab2org/apache/zookeeper/server/quorum/Leader$Proposal de hi j% k% mi o. q. r% () java/net/ServerSocket    89  java/net/BindExceptionjava/lang/StringBuilderCouldn'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;? @ !zookeeper.testingonly.initialZxid AB CDzookeeper.leaderServesyes AEnoF G HIJ KL st M NO P:Not sufficient followers synced, only synced with sids: [ Q! Shutting down l%Shutdown calledjava/lang/Exceptionshutdown Leader! reason:   R Sjava/io/IOException*Ignoring unexpected exception during close = T   UAck zxid: 0x{} VWX YZ[outstanding proposal: 0x{}outstanding proposals all V \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 {}a 6b&Commiting zxid 0x{} from {} not first! First is 0x{} =W ` .Going to commmit null request for proposal: {}   cde f gjava/util/List5org/apache/zookeeper/server/quorum/LearnerSyncRequest  h t i i jk  lmWzxid lower 32 bits have rolled over, forcing re-election, and therefore new epoch start>org/apache/zookeeper/server/quorum/Leader$XidRolloverException java/io/ByteArrayOutputStreamn op qhdrr st utxnv This really should be impossible wk Proposing:: xy z { |}~ 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 quorumUNKNOWN)org/apache/zookeeper/server/quorum/Leader leader.nodelaytrueTCP NoDelay set to: java/lang/ObjectEorg/apache/zookeeper/server/quorum/Leader$ToBeAppliedRequestProcessor9org/apache/zookeeper/server/quorum/QuorumPeer$LearnerType(Ljava/util/Collection;)Vadd(Ljava/lang/Object;)Zsizeremovecontains-org/apache/zookeeper/server/quorum/QuorumPeergetQuorumListenOnAllIPsgetQuorumAddress()Ljava/net/InetSocketAddress;java/net/InetSocketAddressgetPort(I)VsetReuseAddress(Z)Vbind(Ljava/net/SocketAddress;)Vappend-(Ljava/lang/String;)Ljava/lang/StringBuilder;(I)Ljava/lang/StringBuilder;toString()Ljava/lang/String;org/slf4j/Loggererror*(Ljava/lang/String;Ljava/lang/Throwable;)V-(Ljava/lang/Object;)Ljava/lang/StringBuilder;java/lang/SystemcurrentTimeMillisend_fle start_fle(J)Ljava/lang/StringBuilder;info[(Lorg/apache/zookeeper/server/quorum/Leader;Lorg/apache/zookeeper/server/ZooKeeperServer;)VjmxLocalPeerBean2Lorg/apache/zookeeper/server/quorum/LocalPeerBean;8org/apache/zookeeper/server/quorum/LeaderZooKeeperServer registerJMXd(Lorg/apache/zookeeper/server/quorum/LeaderBean;Lorg/apache/zookeeper/server/quorum/LocalPeerBean;)VtickloadDatagetCurrentEpochgetLastProcessedZxid(JJ)V.(Lorg/apache/zookeeper/server/quorum/Leader;)VgetIdgetAcceptedEpoch*org/apache/zookeeper/server/util/ZxidUtilsmakeZxidsetZxidgetZxid(IJ[BLjava/util/List;)Vpacket toHexString(J)Ljava/lang/String;setCurrentEpoch PARTICIPANTackSetiterator()Ljava/util/Iterator;java/util/IteratorhasNextnext()Ljava/lang/Object;getSidvalueOf(J)Ljava/lang/Long;getQuorumVerifier>()Lorg/apache/zookeeper/server/quorum/flexible/QuorumVerifier;:org/apache/zookeeper/server/quorum/flexible/QuorumVerifiercontainsQuorum(Ljava/util/HashSet;)ZwarntickTimejava/lang/Threadsleep getProperty&(Ljava/lang/String;)Ljava/lang/String; parseLong(Ljava/lang/String;)J8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;java/lang/Stringequals cnxnFactory/Lorg/apache/zookeeper/server/ServerCnxnFactory;-org/apache/zookeeper/server/ServerCnxnFactorysetZooKeeperServer0(Lorg/apache/zookeeper/server/ZooKeeperServer;)VsyncedgetLearnerType=()Lorg/apache/zookeeper/server/quorum/QuorumPeer$LearnerType;ping unregisterJMXhaltclosecloseAllisTraceEnabledtrace'(Ljava/lang/String;Ljava/lang/Object;)V"java/util/concurrent/ConcurrentMapvalues()Ljava/util/Collection;java/util/CollectionisDebugEnableddebug9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)Vget&(Ljava/lang/Object;)Ljava/lang/Object;java/lang/Integer(I)Ljava/lang/Integer;commitProcessor4Lorg/apache/zookeeper/server/quorum/CommitProcessor;2org/apache/zookeeper/server/quorum/CommitProcessor((Lorg/apache/zookeeper/server/Request;)V containsKey queuePacket#org/apache/zookeeper/server/RequestgetData()[BgetEpochFromZxid(J)J#org/apache/jute/BinaryOutputArchive getArchive=(Ljava/io/OutputStream;)Lorg/apache/jute/BinaryOutputArchive;$Lorg/apache/zookeeper/txn/TxnHeader;"org/apache/zookeeper/txn/TxnHeader serialize4(Lorg/apache/jute/OutputArchive;Ljava/lang/String;)VLorg/apache/jute/Record;org/apache/jute/Record toByteArrayput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;isEmptyfhkeySet()Ljava/util/Set;java/util/Collectionssort(Ljava/util/List;)V longValuesetAcceptedEpoch notifyAll getInitLimit getTickTimewaitisMoreRecentThan4(Lorg/apache/zookeeper/server/quorum/StateSummary;)Z getLastZxid java/util/SetstartupupdateElectionVote getZKDatabase*()Lorg/apache/zookeeper/server/ZKDatabase;&org/apache/zookeeper/server/ZKDatabasesetlastProcessedZxidorg/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;(Z)Ljava/lang/StringBuilder;!*"#$%&'()*%+,-./01./02./034/56789:;<=>;<?@;<AB;<CD;<EF;<GH;<IJ;<KL;<MN;<OP;<QR;<ST;<UV;<WX;<YZ;<[\;<]^_/`ab/cdefghij%@k%l%minio./pq./pr%stu\*YL»Y*+ðM+,v]^_w xy/z{tu\*YL»Y*+ðM+,vjklw xy/z|}uk*YM*+W,çN,-vpqrswxy~tu\*YL»Y*+ðM+,v|}~w xy/z}uk*YM*+W,çN,-vwxy~!u2* vw xy}uk*YM*+W,çN,-vwxy}uS*YM*+ W,çN,-*YM*+ W,ç :,*YM*+ W,ç :,!,//3/=HKKOKv* !*6=FRwSxySuc*YM*+ ,ìN,-vwxyu4* **Y*Y*Y*Y *Y*Y*Y*Y *!*"*#*$*Y%*Y&*'*+(+)**Y++,-.**Y/.*.0+)*.++1QN+)(3Y456++,78-9"3Y4:6++;8-9-*,<2v P Vcu*5C+N-Y/dZk[p\u|Uuv ,.3w*M4xy4()4&'u *(=>3Y4?6*(>*(@eA8B*( @*( >*<CY**<D*(EF*(G*<H*IY*(J*<KLM*NY*OP*PQ*#**(R*(ST@*< UV*YN**<WX-ç :-* YY *<WZ[* [\] *3Y4_6* [\`68B**(R*Ma*(b**(R*<WcdN*3Y4f6** gh6i68jY:*k:l mn:opW*(qr st*(uv*(YG`G!*wxyN--z7*<*<W{V}~*(*<6*(ulv*(YG`GY:*(RpW*:l8mn:copW9*(qr(*3Y46*h6i68j67:: *<* AVYe] v9e f3h;iCk]neolquvxy{}~*9AVYZ(69FKXaqwz 'g.Zi&|?a.Uhi 9%xygpapeuB*Y3Y46+68*P *P*(*.M,*(*< *<*YM*N-l-mn:-,ç :,*OVYvb 6=DOVYZeov}     w4Z  "xy "!u  ]!`*:l+m:[\7`Ѳ!] * *$!$*$`!`*!p:!`gpW!`g*(qgr!*$ a&!`*$ a`*!pW *W*!**<* !p7* !p:lm:*v) ?IX!["e%o+p.|/02456:<=>@CDEH)I4JDLWNeOmPwSTVWXYZ[\_wf Ii?e)2xyiieu9*YM*kN-l-mn:+,ç :,.1151v#),8w*#9xy9uz&*M,l,mnN-+v"%w* &xy&u'*YN*$-ç :-YYZN*-± v !&w 'xy'i!ueYY++[ZM*,űvw xyeu2*Xƭvw xyu+]]M*,jY,ɿYM,N+-ζ++-ѹ,ӧ:YY+,Z:Y:[+*Y:²3Y4ֶ6+;8*[\X**XpW*ç :-NQvf (-7>JNQS_r{wRS xy(-rw{ne!uK* *+9* *XpM, YM,+W* *Xp,Wv" &*2:Jw &$KxyK &$u\YY ZM+,v% &'w xy !u*X *:lEm:[\ +[YY[\Z:++c^Y*::l4m: +*[+c *+*+*XvR4 5(65789A<U>[?^AhBzCDEFHILMORw\ U(3eL";zIxyi zIu*%Y:*" *!í!*! *! a!*%pW*(q:*%*(Rp +*%r*"*(*!*%U=77 *(*(ha7 *"  *%  e=7 *" eY*!í:  vVWXY[ \'^3_<`^bccndxf}ghijkmnqrwH}MiIi 4i <xyiieu *&Y:*'ñ-O-*M8Y3Y46*MA6*MA68*&pW*(q:*&*(Rp *&r*'*&U=77*(*(ha7 *' *& e=7*' eYç :  vVxyz|})~^jswHMiIi4i sxyi8geu>3Y4M+N-l$,-m;W-l ,6W,8v"#,/9w*>xy>6/>//"uc**<W$3Y46** gh668*<W`*<*(**<*<Wv ?FQbw cxyu* gY:*ñ* [\7!<3Y46A6`66!`68ñc* gpW*(q* gr** gY=7  7  *(*(ha7 *"  * g  e=7 *eYç : abvZ ")^bjywRQi Mi 8i "ixyiie u{gkoW[_csw     vNX\`dhlptx | w ;uv7uv7u^:3Y468Bv8 :<9=* N ! @