Edit C:\dspace\webapps\solr\WEB-INF\lib\org\apache\zookeeper\server\quorum\QuorumPeer.class
???? 1 4` 4a 4b 4c defgfhi jk lm n op qr stu 4vfw 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 ?34t5 678 ?% v9 4: 4? % 79; <=> ?lf? =@A ?l ?BC?D ?E FG Hs ?IJCK ?LMCNOPQRSTU 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{ |} ~??? InnerClasses ResponderThread? LearnerType? ServerState QuorumServer LOG Lorg/slf4j/Logger; jmxQuorumBean /Lorg/apache/zookeeper/server/quorum/QuorumBean; jmxLocalPeerBean 2Lorg/apache/zookeeper/server/quorum/LocalPeerBean; jmxLeaderElectionBean 7Lorg/apache/zookeeper/server/quorum/LeaderElectionBean; qcm 5Lorg/apache/zookeeper/server/quorum/QuorumCnxManager; zkDb (Lorg/apache/zookeeper/server/ZKDatabase; OBSERVER_ID J ConstantValue??????? start_fle end_fle learnerType ;Lorg/apache/zookeeper/server/quorum/QuorumPeer$LearnerType; quorumPeers Ljava/util/Map; Signature ]Ljava/util/Map<Ljava/lang/Long;Lorg/apache/zookeeper/server/quorum/QuorumPeer$QuorumServer;>; quorumConfig <Lorg/apache/zookeeper/server/quorum/flexible/QuorumVerifier; myid currentVote )Lorg/apache/zookeeper/server/quorum/Vote; bcVote running Z tickTime I minSessionTimeout maxSessionTimeout initLimit syncLimit syncEnabled tick quorumListenOnAllIPs state ;Lorg/apache/zookeeper/server/quorum/QuorumPeer$ServerState; udpSocket Ljava/net/DatagramSocket; myQuorumAddr Ljava/net/InetSocketAddress; electionType electionAlg -Lorg/apache/zookeeper/server/quorum/Election; cnxnFactory /Lorg/apache/zookeeper/server/ServerCnxnFactory; logFactory 8Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog; quorumStats 0Lorg/apache/zookeeper/server/quorum/QuorumStats; responder ?Lorg/apache/zookeeper/server/quorum/QuorumPeer$ResponderThread; follower -Lorg/apache/zookeeper/server/quorum/Follower; leader +Lorg/apache/zookeeper/server/quorum/Leader; observer -Lorg/apache/zookeeper/server/quorum/Observer; SYNC_ENABLED Ljava/lang/String; acceptedEpoch currentEpoch CURRENT_EPOCH_FILENAME ACCEPTED_EPOCH_FILENAME UPDATING_EPOCH_FILENAME $assertionsDisabled getLearnerType =()Lorg/apache/zookeeper/server/quorum/QuorumPeer$LearnerType; Code LineNumberTable LocalVariableTable this /Lorg/apache/zookeeper/server/quorum/QuorumPeer; setLearnerType >(Lorg/apache/zookeeper/server/quorum/QuorumPeer$LearnerType;)V p getQuorumSize ()I getId ()J getCurrentVote +()Lorg/apache/zookeeper/server/quorum/Vote; setCurrentVote ,(Lorg/apache/zookeeper/server/quorum/Vote;)V v getBCVote setBCVote setPeerState >(Lorg/apache/zookeeper/server/quorum/QuorumPeer$ServerState;)V newState getPeerState =()Lorg/apache/zookeeper/server/quorum/QuorumPeer$ServerState; getQuorumAddress ()Ljava/net/InetSocketAddress; <init> ()V b(Ljava/util/Map;Ljava/io/File;Ljava/io/File;IJIIILorg/apache/zookeeper/server/ServerCnxnFactory;)V dataDir Ljava/io/File; dataLogDir LocalVariableTypeTable Exceptions ?(Ljava/util/Map<Ljava/lang/Long;Lorg/apache/zookeeper/server/quorum/QuorumPeer$QuorumServer;>;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/lang/Long;Lorg/apache/zookeeper/server/quorum/QuorumPeer$QuorumServer;>;Ljava/io/File;Ljava/io/File;IJIIIZLorg/apache/zookeeper/server/ServerCnxnFactory;Lorg/apache/zookeeper/server/quorum/flexible/QuorumVerifier;)V 2()Lorg/apache/zookeeper/server/quorum/QuorumStats; start loadDataBase e Ljava/io/FileNotFoundException; lastProcessedZxid epochOfZxid ie Ljava/io/IOException; updating stopLeaderElection startLeaderElection re Ljava/lang/RuntimeException; <Lorg/apache/zookeeper/server/quorum/QuorumPeer$QuorumServer; i$ Ljava/util/Iterator; Ljava/net/SocketException; countParticipants (Ljava/util/Map;)I q peers count `(Ljava/util/Map<Ljava/lang/Long;Lorg/apache/zookeeper/server/quorum/QuorumPeer$QuorumServer;>;)I 4(Ljava/util/Map;Ljava/io/File;Ljava/io/File;IIJIII)V snapDir logDir clientPort ?(Ljava/util/Map<Ljava/lang/Long;Lorg/apache/zookeeper/server/quorum/QuorumPeer$QuorumServer;>;Ljava/io/File;Ljava/io/File;IIJIII)V p(Ljava/util/Map;Ljava/io/File;Ljava/io/File;IIJIIILorg/apache/zookeeper/server/quorum/flexible/QuorumVerifier;)V ?(Ljava/util/Map<Ljava/lang/Long;Lorg/apache/zookeeper/server/quorum/QuorumPeer$QuorumServer;>;Ljava/io/File;Ljava/io/File;IIJIIILorg/apache/zookeeper/server/quorum/flexible/QuorumVerifier;)V getLastLoggedZxid makeFollower g(Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog;)Lorg/apache/zookeeper/server/quorum/Follower; makeLeader e(Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog;)Lorg/apache/zookeeper/server/quorum/Leader; makeObserver g(Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog;)Lorg/apache/zookeeper/server/quorum/Observer; createElectionAlgorithm 0(I)Lorg/apache/zookeeper/server/quorum/Election; listener? Listener >Lorg/apache/zookeeper/server/quorum/QuorumCnxManager$Listener; electionAlgorithm le makeLEStrategy /()Lorg/apache/zookeeper/server/quorum/Election; setLeader .(Lorg/apache/zookeeper/server/quorum/Leader;)V newLeader setFollower 0(Lorg/apache/zookeeper/server/quorum/Follower;)V newFollower setObserver 0(Lorg/apache/zookeeper/server/quorum/Observer;)V newObserver getActiveServer /()Lorg/apache/zookeeper/server/ZooKeeperServer; run Ljava/lang/Exception; &Lorg/apache/zookeeper/jmx/ZKMBeanInfo; s roZk <Lorg/apache/zookeeper/server/quorum/ReadOnlyZooKeeperServer; roZkMgr Ljava/lang/Thread; shutdown getView ()Ljava/util/Map; _()Ljava/util/Map<Ljava/lang/Long;Lorg/apache/zookeeper/server/quorum/QuorumPeer$QuorumServer;>; getVotingView server ret view getObservingView viewContains (Ljava/lang/Long;)Z sid Ljava/lang/Long; getQuorumPeers ()[Ljava/lang/String; fh 3Lorg/apache/zookeeper/server/quorum/LearnerHandler; l Ljava/util/List; $Ljava/util/List<Ljava/lang/String;>; getServerState ()Ljava/lang/String; getMyid setMyid (J)V getTickTime setTickTime (I)V getMaxClientCnxnsPerHost fac getMinSessionTimeout setMinSessionTimeout min getMaxSessionTimeout setMaxSessionTimeout max getInitLimit setInitLimit getTick getQuorumVerifier >()Lorg/apache/zookeeper/server/quorum/flexible/QuorumVerifier; setQuorumVerifier ?(Lorg/apache/zookeeper/server/quorum/flexible/QuorumVerifier;)V getElectionAlg getSyncLimit setSyncLimit getSyncEnabled ()Z setSyncEnabled (Z)V getElectionType setElectionType getQuorumListenOnAllIPs setQuorumListenOnAllIPs getCnxnFactory 1()Lorg/apache/zookeeper/server/ServerCnxnFactory; setCnxnFactory 2(Lorg/apache/zookeeper/server/ServerCnxnFactory;)V setQuorumPeers (Ljava/util/Map;)V `(Ljava/util/Map<Ljava/lang/Long;Lorg/apache/zookeeper/server/quorum/QuorumPeer$QuorumServer;>;)V getClientPort setClientPortAddress (Ljava/net/InetSocketAddress;)V addr setTxnFactory ;(Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog;)V factory getTxnFactory :()Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog; setZKDatabase +(Lorg/apache/zookeeper/server/ZKDatabase;)V database setRunning isRunning getQuorumCnxManager 7()Lorg/apache/zookeeper/server/quorum/QuorumCnxManager; readLongFromFile (Ljava/lang/String;)J !Ljava/lang/NumberFormatException; name file br Ljava/io/BufferedReader; line writeLongToFile (Ljava/lang/String;J)V value out 4Lorg/apache/zookeeper/common/AtomicFileOutputStream; bw Ljava/io/BufferedWriter; aborted getCurrentEpoch getAcceptedEpoch setCurrentEpoch setAcceptedEpoch updateElectionVote newEpoch access$000 ()Lorg/slf4j/Logger; access$100 2(Lorg/apache/zookeeper/server/quorum/QuorumPeer;)J x0 <clinit> SourceFile QuorumPeer.java]OBCUVWX???????? :org/apache/zookeeper/server/quorum/QuorumPeer$QuorumServer?V java/lang/StringBuilder?? Setting LearnerType to ???? but ?? not in QuorumPeers. ? ???????^_`_lmpq QuorumPeer???Vabedfdibkbmwx?O?O .org/apache/zookeeper/server/quorum/QuorumStats??yz 5org/apache/zookeeper/server/quorum/flexible/QuorumMaj?????uvrdcdgdhd 6org/apache/zookeeper/server/persistence/FileTxnSnapLog?? &org/apache/zookeeper/server/ZKDatabase?7LM[\??????? java/io/File9:?? updatingEpoch????????O???BC?$ {{} found. The server was terminated after taking a snapshot but before updating current epoch. Setting current epoch to {}.??T ?$ java/io/IOException Failed to delete java/io/FileNotFoundException ?currentEpoch not found! Creating with a reasonable default of {}. This should only happen when you are upgrading your installation??JK The 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/RuntimeException Unable to run quorum server ??{|?? 'org/apache/zookeeper/server/quorum/Vote??R???? ?????????????$???O5q My id not in the peer list java/net/DatagramSocket??no =org/apache/zookeeper/server/quorum/QuorumPeer$ResponderThread?? java/net/SocketException????st java/net/InetSocketAddress???$?? +org/apache/zookeeper/server/quorum/Follower :org/apache/zookeeper/server/quorum/FollowerZooKeeperServer? @org/apache/zookeeper/server/ZooKeeperServer$BasicDataTreeBuilder BasicDataTreeBuilder???? )org/apache/zookeeper/server/quorum/Leader 8org/apache/zookeeper/server/quorum/LeaderZooKeeperServer?? +org/apache/zookeeper/server/quorum/Observer :org/apache/zookeeper/server/quorum/ObserverZooKeeperServer?? 1org/apache/zookeeper/server/quorum/LeaderElection 9org/apache/zookeeper/server/quorum/AuthFastLeaderElection?? 3org/apache/zookeeper/server/quorum/QuorumCnxManagerJK?? 5org/apache/zookeeper/server/quorum/FastLeaderElection?? +Null listener when initializing cnx manager?b java/lang/AssertionError (Initializing leader election protocol...??'??}~?????? QuorumPeer[myid=?? ]???? Starting quorum peer -org/apache/zookeeper/server/quorum/QuorumBeanDE????? 0org/apache/zookeeper/server/quorum/LocalPeerBeanFG java/lang/Exception Failed 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 JMX quorum Peer shutdown?? ? Error closing logs ??? java/util/HashMap???V java/util/ArrayList??? 1org/apache/zookeeper/server/quorum/LearnerHandler???????? *???? java/lang/String?? [Ljava/lang/String; leaderelection leading following observing unknown tickTime set to ? +,? minSessionTimeout set to maxSessionTimeout set to initLimit set to jd zookeeper.observer.syncEnabled zookeeper.observer.syncEnabled=?? java/io/BufferedReader java/io/FileReader?? C java/lang/NumberFormatException Found in 2org/apache/zookeeper/common/AtomicFileOutputStream java/io/BufferedWriter java/io/OutputStreamWriter? ???? ? Failed to write new file ??????? -org/apache/zookeeper/server/quorum/QuorumPeer$ java/lang/Thread 7org/apache/zookeeper/server/quorum/QuorumStats$Provider Provider /org/apache/zookeeper/server/quorum/QuorumPeer$2 9org/apache/zookeeper/server/quorum/QuorumPeer$LearnerType 9org/apache/zookeeper/server/quorum/QuorumPeer$ServerState <org/apache/zookeeper/server/quorum/QuorumCnxManager$Listener java/lang/Long valueOf (J)Ljava/lang/Long; java/util/Map containsKey (Ljava/lang/Object;)Z get &(Ljava/lang/Object;)Ljava/lang/Object; type append -(Ljava/lang/String;)Ljava/lang/StringBuilder; -(Ljava/lang/Object;)Ljava/lang/StringBuilder; (J)Ljava/lang/StringBuilder; toString org/slf4j/Logger error (Ljava/lang/String;)V size PARTICIPANT <(Lorg/apache/zookeeper/server/quorum/QuorumStats$Provider;)V (Ljava/io/File;Ljava/io/File;)V -org/apache/zookeeper/server/ServerCnxnFactory getSnapDir ()Ljava/io/File; #(Ljava/io/File;Ljava/lang/String;)V getDataTree (()Lorg/apache/zookeeper/server/DataTree; $org/apache/zookeeper/server/DataTree *org/apache/zookeeper/server/util/ZxidUtils getEpochFromZxid (J)J exists info 9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V delete '(Ljava/lang/String;Ljava/lang/Object;)V zxidToString (J)Ljava/lang/String; *(Ljava/lang/String;Ljava/lang/Throwable;)V interrupt (JJJ)V getMessage getStackTrace ()[Ljava/lang/StackTraceElement; setStackTrace !([Ljava/lang/StackTraceElement;)V values ()Ljava/util/Collection; java/util/Collection iterator ()Ljava/util/Iterator; java/util/Iterator hasNext next ()Ljava/lang/Object; id getPort 2(Lorg/apache/zookeeper/server/quorum/QuorumPeer;)V (Ljava/lang/Throwable;)V createFactory N(Ljava/net/InetSocketAddress;I)Lorg/apache/zookeeper/server/ServerCnxnFactory; isInitialized getDataTreeLastProcessedZxid +org/apache/zookeeper/server/ZooKeeperServer DataTreeBuilder ?(Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog;Lorg/apache/zookeeper/server/quorum/QuorumPeer;Lorg/apache/zookeeper/server/ZooKeeperServer$DataTreeBuilder;Lorg/apache/zookeeper/server/ZKDatabase;)V n(Lorg/apache/zookeeper/server/quorum/QuorumPeer;Lorg/apache/zookeeper/server/quorum/FollowerZooKeeperServer;)V l(Lorg/apache/zookeeper/server/quorum/QuorumPeer;Lorg/apache/zookeeper/server/quorum/LeaderZooKeeperServer;)V n(Lorg/apache/zookeeper/server/quorum/QuorumPeer;Lorg/apache/zookeeper/server/quorum/ObserverZooKeeperServer;)V 3(Lorg/apache/zookeeper/server/quorum/QuorumPeer;Z)V g(Lorg/apache/zookeeper/server/quorum/QuorumPeer;Lorg/apache/zookeeper/server/quorum/QuorumCnxManager;)V debug zk :Lorg/apache/zookeeper/server/quorum/LeaderZooKeeperServer; ;Lorg/apache/zookeeper/server/quorum/LearnerZooKeeperServer; getLocalAddress setName &org/apache/zookeeper/jmx/MBeanRegistry getInstance *()Lorg/apache/zookeeper/jmx/MBeanRegistry; register O(Lorg/apache/zookeeper/jmx/ZKMBeanInfo;Lorg/apache/zookeeper/jmx/ZKMBeanInfo;)V warn ?(Lorg/apache/zookeeper/server/quorum/QuorumPeer$QuorumServer;)V D$SwitchMap$org$apache$zookeeper$server$quorum$QuorumPeer$ServerState [I ordinal java/lang/Boolean getBoolean (Ljava/lang/String;)Z n(Lorg/apache/zookeeper/server/quorum/QuorumPeer;Lorg/apache/zookeeper/server/quorum/ReadOnlyZooKeeperServer;)V +org/apache/zookeeper/server/quorum/Election lookForLeader observeLeader followLeader lead unregisterAll close java/util/Collections unmodifiableMap (Ljava/util/Map;)Ljava/util/Map; put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; OBSERVER getLearners ()Ljava/util/List; java/util/List getSocket ()Ljava/net/Socket; java/net/Socket getRemoteSocketAddress ()Ljava/net/SocketAddress; java/lang/Object isLearnerSynced 6(Lorg/apache/zookeeper/server/quorum/LearnerHandler;)Z add sock Ljava/net/Socket; toArray (([Ljava/lang/Object;)[Ljava/lang/Object; (I)Ljava/lang/StringBuilder; java/lang/System getProperty &(Ljava/lang/String;)Ljava/lang/String; (Z)Ljava/lang/StringBuilder; getLocalPort (Ljava/io/File;)V (Ljava/io/Reader;)V readLine parseLong (Ljava/io/OutputStream;)V (Ljava/io/Writer;)V write flush abort getZxid getElectionEpoch getState B(JJJJLorg/apache/zookeeper/server/quorum/QuorumPeer$ServerState;)V java/lang/Class desiredAssertionStatus org/slf4j/LoggerFactory getLogger %(Ljava/lang/Class;)Lorg/slf4j/Logger; ;org/apache/zookeeper/server/ZooKeeperServer$DataTreeBuilder !47 8 + BC DE FG HI JK LM NO P Q SO TO UV WX Y Z [\ ]O B^_ B`_ @ab cd ed fd gd hd ib Djd kb lm no pq rd st uv wx yz {| }~ ? ?? ?? P ?O ?O ?? P H ?? P Z ?? P B?b T ?? ? / *? ? ? ?? ?? ?? ? ? _*+? *? *? ? ? ? *? *? ? ? ? +? ? /? ? Y? ? +? ? *? ? ? ? ? ? ? ? ? ? 2 ? ^ ?? _?? _?V ?? ? 4 *? ? ? ? ?? ?? ?? ? / *? ? ? ?? ?? !?? ? / *? ? ? ?? ?? !?? ? >