1 4` 4a 4b 4c de fg fhi jk lm n op qr s tu 4v fw 4x 4y 4z 4{| 7} =~ 4 4 4 4 4 ? 4 4 4 ( 4 4 + 4 4l 4 4 4 4 4 5 7 4 4 4  4 7 4 5 ? 7 7   4 ? t 4 ? ?s O} t 4  t _ 4 z z 4 4 e O _} O _ 4 f       v 4 z z _ 4 4   7 7 l           4    4 l t 4 4 4 4    4  4  4     4   t  9 4 ? t    4 4  ! 4"# 4$ 7 %& 4' 4( ) %* 4+ 4, - %. 4/ 40 12 34 t5 678 % v9 4: 4  % 79; <=> l f? =@A l B CD E FG Hs IJ CK LM CNOPQRSTU V 4W XYZ[ 4\] ^_` a bcd e f: g dhijk 9l !emn $o #p dq #r #s !st !u !9 4v e ew ex ey ez{ |} ~ InnerClassesResponderThread LearnerType ServerState QuorumServerLOGLorg/slf4j/Logger; jmxQuorumBean/Lorg/apache/zookeeper/server/quorum/QuorumBean;jmxLocalPeerBean2Lorg/apache/zookeeper/server/quorum/LocalPeerBean;jmxLeaderElectionBean7Lorg/apache/zookeeper/server/quorum/LeaderElectionBean;qcm5Lorg/apache/zookeeper/server/quorum/QuorumCnxManager;zkDb(Lorg/apache/zookeeper/server/ZKDatabase; OBSERVER_IDJ ConstantValue start_fleend_fle learnerType;Lorg/apache/zookeeper/server/quorum/QuorumPeer$LearnerType; quorumPeersLjava/util/Map; Signature]Ljava/util/Map; quorumConfig(Lorg/apache/zookeeper/server/quorum/QuorumPeer$LearnerType;)Vp getQuorumSize()IgetId()JgetCurrentVote+()Lorg/apache/zookeeper/server/quorum/Vote;setCurrentVote,(Lorg/apache/zookeeper/server/quorum/Vote;)Vv getBCVote setBCVote setPeerState>(Lorg/apache/zookeeper/server/quorum/QuorumPeer$ServerState;)VnewState getPeerState=()Lorg/apache/zookeeper/server/quorum/QuorumPeer$ServerState;getQuorumAddress()Ljava/net/InetSocketAddress;()Vb(Ljava/util/Map;Ljava/io/File;Ljava/io/File;IJIIILorg/apache/zookeeper/server/ServerCnxnFactory;)VdataDirLjava/io/File; dataLogDirLocalVariableTypeTable Exceptions(Ljava/util/Map;Ljava/io/File;Ljava/io/File;IJIIILorg/apache/zookeeper/server/ServerCnxnFactory;)V(Ljava/util/Map;Ljava/io/File;Ljava/io/File;IJIIIZLorg/apache/zookeeper/server/ServerCnxnFactory;Lorg/apache/zookeeper/server/quorum/flexible/QuorumVerifier;)V(Ljava/util/Map;Ljava/io/File;Ljava/io/File;IJIIIZLorg/apache/zookeeper/server/ServerCnxnFactory;Lorg/apache/zookeeper/server/quorum/flexible/QuorumVerifier;)V2()Lorg/apache/zookeeper/server/quorum/QuorumStats;start loadDataBaseeLjava/io/FileNotFoundException;lastProcessedZxid epochOfZxidieLjava/io/IOException;updatingstopLeaderElectionstartLeaderElectionreLjava/lang/RuntimeException;;)I4(Ljava/util/Map;Ljava/io/File;Ljava/io/File;IIJIII)VsnapDirlogDir clientPort(Ljava/util/Map;Ljava/io/File;Ljava/io/File;IIJIII)Vp(Ljava/util/Map;Ljava/io/File;Ljava/io/File;IIJIIILorg/apache/zookeeper/server/quorum/flexible/QuorumVerifier;)V(Ljava/util/Map;Ljava/io/File;Ljava/io/File;IIJIIILorg/apache/zookeeper/server/quorum/flexible/QuorumVerifier;)VgetLastLoggedZxid makeFollowerg(Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog;)Lorg/apache/zookeeper/server/quorum/Follower; makeLeadere(Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog;)Lorg/apache/zookeeper/server/quorum/Leader; makeObserverg(Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog;)Lorg/apache/zookeeper/server/quorum/Observer;createElectionAlgorithm0(I)Lorg/apache/zookeeper/server/quorum/Election;listenerListener>Lorg/apache/zookeeper/server/quorum/QuorumCnxManager$Listener;electionAlgorithmlemakeLEStrategy/()Lorg/apache/zookeeper/server/quorum/Election; setLeader.(Lorg/apache/zookeeper/server/quorum/Leader;)V newLeader setFollower0(Lorg/apache/zookeeper/server/quorum/Follower;)V newFollower setObserver0(Lorg/apache/zookeeper/server/quorum/Observer;)V newObservergetActiveServer/()Lorg/apache/zookeeper/server/ZooKeeperServer;runLjava/lang/Exception;&Lorg/apache/zookeeper/jmx/ZKMBeanInfo;sroZk; getVotingViewserverretviewgetObservingView viewContains(Ljava/lang/Long;)ZsidLjava/lang/Long;getQuorumPeers()[Ljava/lang/String;fh3Lorg/apache/zookeeper/server/quorum/LearnerHandler;lLjava/util/List;$Ljava/util/List;getServerState()Ljava/lang/String;getMyidsetMyid(J)V getTickTime setTickTime(I)VgetMaxClientCnxnsPerHostfacgetMinSessionTimeoutsetMinSessionTimeoutmingetMaxSessionTimeoutsetMaxSessionTimeoutmax getInitLimit setInitLimitgetTickgetQuorumVerifier>()Lorg/apache/zookeeper/server/quorum/flexible/QuorumVerifier;setQuorumVerifier?(Lorg/apache/zookeeper/server/quorum/flexible/QuorumVerifier;)VgetElectionAlg getSyncLimit setSyncLimitgetSyncEnabled()ZsetSyncEnabled(Z)VgetElectionTypesetElectionTypegetQuorumListenOnAllIPssetQuorumListenOnAllIPsgetCnxnFactory1()Lorg/apache/zookeeper/server/ServerCnxnFactory;setCnxnFactory2(Lorg/apache/zookeeper/server/ServerCnxnFactory;)VsetQuorumPeers(Ljava/util/Map;)V`(Ljava/util/Map;)V getClientPortsetClientPortAddress(Ljava/net/InetSocketAddress;)Vaddr setTxnFactory;(Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog;)Vfactory getTxnFactory:()Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog; setZKDatabase+(Lorg/apache/zookeeper/server/ZKDatabase;)Vdatabase setRunning isRunninggetQuorumCnxManager7()Lorg/apache/zookeeper/server/quorum/QuorumCnxManager;readLongFromFile(Ljava/lang/String;)J!Ljava/lang/NumberFormatException;namefilebrLjava/io/BufferedReader;linewriteLongToFile(Ljava/lang/String;J)Vvalueout4Lorg/apache/zookeeper/common/AtomicFileOutputStream;bwLjava/io/BufferedWriter;abortedgetCurrentEpochgetAcceptedEpochsetCurrentEpochsetAcceptedEpochupdateElectionVotenewEpoch access$000()Lorg/slf4j/Logger; access$1002(Lorg/apache/zookeeper/server/quorum/QuorumPeer;)Jx0 SourceFileQuorumPeer.java ]O BC UV WX   :org/apache/zookeeper/server/quorum/QuorumPeer$QuorumServer Vjava/lang/StringBuilder Setting LearnerType to   but  not in QuorumPeers.      ^_ `_ lm pq QuorumPeer  V ab ed fd ib kb m wx O O.org/apache/zookeeper/server/quorum/QuorumStats  yz5org/apache/zookeeper/server/quorum/flexible/QuorumMaj    uv rd cd gd hd6org/apache/zookeeper/server/persistence/FileTxnSnapLog &org/apache/zookeeper/server/ZKDatabase 7 LM [\    java/io/File 9:  updatingEpoch    O  BC ${{} found. The server was terminated after taking a snapshot but before updating current epoch. Setting current epoch to {}.  T $java/io/IOExceptionFailed to delete java/io/FileNotFoundExceptioncurrentEpoch not found! Creating with a reasonable default of {}. This should only happen when you are upgrading your installation  JKThe current epoch, , is older than the last zxid, acceptedEpoch not found! Creating with a reasonable default of {}. This should only happen when you are upgrading your installation" is less than the accepted epoch, Unable to load database on disk java/lang/RuntimeExceptionUnable to run quorum server  {| 'org/apache/zookeeper/server/quorum/Vote  R        $  O 5qMy id  not in the peer listjava/net/DatagramSocket  no=org/apache/zookeeper/server/quorum/QuorumPeer$ResponderThread java/net/SocketException   stjava/net/InetSocketAddress  $ +org/apache/zookeeper/server/quorum/Follower:org/apache/zookeeper/server/quorum/FollowerZooKeeperServer@org/apache/zookeeper/server/ZooKeeperServer$BasicDataTreeBuilderBasicDataTreeBuilder  )org/apache/zookeeper/server/quorum/Leader8org/apache/zookeeper/server/quorum/LeaderZooKeeperServer +org/apache/zookeeper/server/quorum/Observer:org/apache/zookeeper/server/quorum/ObserverZooKeeperServer 1org/apache/zookeeper/server/quorum/LeaderElection9org/apache/zookeeper/server/quorum/AuthFastLeaderElection 3org/apache/zookeeper/server/quorum/QuorumCnxManager JK 5org/apache/zookeeper/server/quorum/FastLeaderElection +Null listener when initializing cnx manager bjava/lang/AssertionError(Initializing leader election protocol...  '  }~   QuorumPeer[myid= ]  Starting quorum peer-org/apache/zookeeper/server/quorum/QuorumBean DE  0org/apache/zookeeper/server/quorum/LocalPeerBean FGjava/lang/ExceptionFailed to register with JMX 1org/apache/zookeeper/server/quorum/RemotePeerBean    LOOKING readonlymode.enabled +Attempting to start ReadOnlyZooKeeperServer:org/apache/zookeeper/server/quorum/ReadOnlyZooKeeperServer/org/apache/zookeeper/server/quorum/QuorumPeer$1     Unexpected exception   OBSERVING    FOLLOWING   LEADING   Forcing shutdown QuorumPeer main thread exited  Failed to unregister with JMXquorum Peer shutdown   Error closing logs  java/util/HashMap  Vjava/util/ArrayList 1org/apache/zookeeper/server/quorum/LearnerHandler   *  java/lang/String [Ljava/lang/String;leaderelectionleading following observingunknowntickTime set to  +, minSessionTimeout set to maxSessionTimeout set to initLimit set to jdzookeeper.observer.syncEnabled zookeeper.observer.syncEnabled=  java/io/BufferedReaderjava/io/FileReader     Cjava/lang/NumberFormatExceptionFound  in 2org/apache/zookeeper/common/AtomicFileOutputStreamjava/io/BufferedWriterjava/io/OutputStreamWriter       Failed to write new file      -org/apache/zookeeper/server/quorum/QuorumPeer $ java/lang/Thread7org/apache/zookeeper/server/quorum/QuorumStats$ProviderProvider/org/apache/zookeeper/server/quorum/QuorumPeer$29org/apache/zookeeper/server/quorum/QuorumPeer$LearnerType9org/apache/zookeeper/server/quorum/QuorumPeer$ServerState*+ _ C***   >*+ _!>*+ qrm!/*u /*} M****** *!*"*#*$&*$'*(Y*)*6   !&n-29@L M *+,-  +Y+,-. f  WX   rd ]O cd gd hd uv   WZOYO m*/* 0*+*1**2*3* 4* !*5Y-,6#*7Y*#89 *+Y+,-: * :> !'-3@OTflz mmWXmmmrdm]Omcdmgdmhd mkb muv m[\  mWZOYy/** !N*;*0<*=*>  Tb?Y*@ABCL*9DX*9EFA G7**HI'*'F+J?KBL*M+N!OY Y P +Q R&:*'T*'U*H*'V*'-OY Y W *'X Y R**ZI&&:*&[*&U*Z*&V*&*'3OY Y W *'X \ *&X RM],^_Y`,a*SSGJOz$*4EV\c GJKVaH!!$#O*OKbQ!B*bc*bd ! *eY**f*ghL_Y+ijM,+kl,*mnoL+p'+qM,r**,s*&_Y Y t *u j*15*vY*wxy*zY*{b*b| L_Y+~***1O}Z'/1S_gj m t  >' S@-  3<*noM,p,qN-  !!+".$1%*! #3X1d 3ZY +*+,-  Y+Y+,-. 1*5f ++WX+++d+sd+]O+cd+gd +hd  +WZOY "*+,-  Y . A!Ep ""WX"""d"sd"]O"cd"gd "hd "[\  "WZOYH*9*;*9M NP Q Y*Y+*Y*9XwxOQ Y*Y+*Y*9]wxOQ Y*Y+*Y*9bwxOM{)5BY*McY*MWY*MJ*Y**N--Y**M Y,Fgj l)m,o5p8rBsEuQvYw]xayq{{}~*Y3dtX"**Y**  "$>*+ $>*+ ~$>*+ !q/* ** ** *%- /&* Y  * *0*Y***mnoL+ps+qM*,r5*Y*ZN-*>:*(Y,N-*:L+***. ,ղùŸƙ{ǹY*#*Y*9LY*+M,>***͹Ϩ'0N-*"Ѩ::,+ө>***͹ϧ)L+*"ѧԹ***#ն*ר 4L+"::***"ѩٹ***#ڶ*ܨ 4L+":  : ***"ѩ e޹***#߶** =L++:  : ****"ѩ ::  ::**3VlrVor$AG$DYGVYY^Ye)3?Jlx"*4LVZ_lors~     ! $.:ADGHSVYjox{ !)!"#)$%&(*-6.0312457$ lcYysLSVI H   c** ** **0*y *y****9L+LSVOB:; <>?#A*B1C8F?GCHLKSNVLWMbOW c2*V YNYL*mM,noN-p--q: +rW+^` a-b8cIeLf4-3NFX AXFZ AZYNYL*mM,noN-p--q: +rW+mo p-q8rItLu4-3NFX AXFZ AZY? *+~  WYL*YM*j*N-pQ-q:;:* Y   :+W*+*W,ç :,+ : 4<IUktz4I+4@ W   z<*.-!%)(,048 < /*   >* ]O/*2 ^" Y   *2!""cdP* L++    v@* *2h* ^" Y   *!""dA* *2h* ^" Y   *!""d/*3 ^" Y   *3!""gd/* /*: >*+: [\ /*  !/*4 ">*4 hd#$l6+ Y  ƶƬ* ' (*)1+ 6%&>*  56ib'/*1< (>*1 CDrd)$/*!G *&>*! KLkb+,/*0O -.>*+0 STuv/0P*+ WXWX WZY122*0[ 345_5q67>*+# bc8x9:/*#f ;<>*+9 no=M>&>* rsab?$/*v @A/*} BC q?Y*#A+CMYY,N:-:77:OY Y    ,R::- %58%5a8fa" %+8:a>:'DqqEaF QGH%LIOJKU ?Y*#A+C:!Y":#Y$Y%&:6 '()*:E: Y + ^6,:  : - 1DJO1GvJ{vF.1:?DGJLknsvRL*ELO|FqMN._OP1\QbORL*'$ **HI'*'  OSL*&$ **ZI&*&  OT I *'*HV   OOU I *&*ZV   OOV y +*.N*--*eY-/-0-1-23ϱ * ++WO&^_XYNZ[/*N \]74546 NO^_;R 94z4<=4>@?4@@4A  8(