1 s t u v wx yz { |} ~   y    y              F          |  |      | A   | F        Ry  R R            e      e     ^                    ^          |  ! "# $% & |' () *+  , - . /0 y1  2 3567 8 9: ; < = > ?@ A BC D E FGHIJKL M NOP Q R S TU VW XYZSyncLimitCheck InnerClassesLOGLorg/slf4j/Logger;sockLjava/net/Socket;leader+Lorg/apache/zookeeper/server/quorum/Leader;tickOfNextAckDeadlineJsidversionI queuedPackets*Ljava/util/concurrent/LinkedBlockingQueue; Signature]Ljava/util/concurrent/LinkedBlockingQueue;syncLimitCheckBLorg/apache/zookeeper/server/quorum/LearnerHandler$SyncLimitCheck;ia$Lorg/apache/jute/BinaryInputArchive;oa%Lorg/apache/jute/BinaryOutputArchive;bufferedOutputLjava/io/BufferedOutputStream;proposalOfDeath1Lorg/apache/zookeeper/server/quorum/QuorumPacket; learnerType[ LearnerType;Lorg/apache/zookeeper/server/quorum/QuorumPeer$LearnerType; getSocket()Ljava/net/Socket;CodeLineNumberTableLocalVariableTablethis3Lorg/apache/zookeeper/server/quorum/LearnerHandler;getSid()J getVersion()I?(Ljava/net/Socket;Lorg/apache/zookeeper/server/quorum/Leader;)V ExceptionstoString()Ljava/lang/String;sbLjava/lang/StringBuilder;getLearnerType=()Lorg/apache/zookeeper/server/quorum/QuorumPeer$LearnerType; sendPackets()VpieLjava/io/IOException;e traceMaskpacketToStringE(Lorg/apache/zookeeper/server/quorum/QuorumPacket;)Ljava/lang/String;runbbsidLjava/nio/ByteBuffer;li0Lorg/apache/zookeeper/server/quorum/LearnerInfo;epochver[BnewEpochPacketackEpochPacketbbepochqcommitproposeProposal4Lorg/apache/zookeeper/server/quorum/Leader$Proposal;i$Ljava/util/Iterator;prevProposalZxid firstPacketZmaxCommittedLogminCommittedLog proposalsLjava/util/LinkedList;sesstoSessionExpiredException>Lorg/apache/zookeeper/KeeperException$SessionExpiredException;si%Lorg/apache/zookeeper/server/Request;bisLjava/io/ByteArrayInputStream;disLjava/io/DataInputStream;idbosLjava/io/ByteArrayOutputStream;dosLjava/io/DataOutputStream;validbb sessionIdcxidtypeqplearnerInfoDatalastAcceptedEpoch peerLastZxidss1Lorg/apache/zookeeper/server/quorum/StateSummary;zxidnewEpoch packetToSend zxidToSendleaderLastZxidupdateslock3Ljava/util/concurrent/locks/ReentrantReadWriteLock;rl\ReadLock;shutdownping queuePacket4(Lorg/apache/zookeeper/server/quorum/QuorumPacket;)Vsynced()Z access$000()Lorg/slf4j/Logger; access$2006(Lorg/apache/zookeeper/server/quorum/LearnerHandler;)Vx0 SourceFileLearnerHandler.java  java/lang/StringBuilder LearnerHandler- ]^_ `a ]b  c(java/util/concurrent/LinkedBlockingQueue @org/apache/zookeeper/server/quorum/LearnerHandler$SyncLimitCheck d /org/apache/zookeeper/server/quorum/QuorumPacket  e  f gnLearnerHandler  tickOfNextAckDeadline:  ]h synced?: ij ]i queuedPacketLength: j ]k lm n om p qr s tuv wjx yz packet{ |}java/io/IOException ~jUnexpected exception at  !Error closing socket for handler     java/io/BufferedInputStream    java/io/BufferedOutputStream    } First packet % is not FOLLOWERINFO or OBSERVERINFO! c   .org/apache/zookeeper/server/quorum/LearnerInfo     Follower sid:  : info :    c      /org/apache/zookeeper/server/quorum/StateSummary u     is not ACKEPOCH       [  !Synchronizing with Follower sid:  maxCommittedLog=0x  minCommittedLog=0x peerLastZxid=0x proposal size is {}  Sending proposals to follower c  j m2org/apache/zookeeper/server/quorum/Leader$Proposal  gh6Sending TRUNC to follower zxidToSend=0x{} updates=0x{} Unhandled proposal scenario c DcommittedLog is empty but leader and follower are in sync, zxid=0x{}proposals is emptySending    (Sending snapshot last zxid of peer is 0x  zxid of leader is 0xsent zxid of db as 0x  BenWasHere signature 3org/apache/zookeeper/server/quorum/LearnerHandler$1 n %Next packet was supposed to be an ACK$Received NEWLEADER-ACK message from     j j  jReceived ACK from Observer  a java/io/ByteArrayInputStream java/io/DataInputStream    java/io/ByteArrayOutputStreamjava/io/DataOutputStream   ******** e  Ignoring unexpected exception1Ignoring unexpected exception during socket close    n  6Closing connection to peer due to transaction timeout. j1org/apache/zookeeper/server/quorum/LearnerHandler java/lang/Thread9org/apache/zookeeper/server/quorum/QuorumPeer$LearnerType:java/util/concurrent/locks/ReentrantReadWriteLock$ReadLockappend-(Ljava/lang/String;)Ljava/lang/StringBuilder;java/net/SocketgetRemoteSocketAddress()Ljava/net/SocketAddress;-(Ljava/lang/Object;)Ljava/lang/StringBuilder;(Ljava/lang/String;)Vk(Lorg/apache/zookeeper/server/quorum/LearnerHandler;Lorg/apache/zookeeper/server/quorum/LearnerHandler$1;)V PARTICIPANT)org/apache/zookeeper/server/quorum/LeaderaddLearnerHandler(J)Ljava/lang/StringBuilder;(Z)Ljava/lang/StringBuilder;size(I)Ljava/lang/StringBuilder;poll()Ljava/lang/Object;flushtakegetTypegetZxidjava/lang/SystemnanoTimeupdateProposal(JJ)Vorg/slf4j/LoggerisTraceEnabled$org/apache/zookeeper/server/ZooTracelogQuorumPacketH(Lorg/slf4j/Logger;JCLorg/apache/zookeeper/server/quorum/QuorumPacket;)V#org/apache/jute/BinaryOutputArchive writeRecord-(Lorg/apache/jute/Record;Ljava/lang/String;)VisClosedwarn*(Ljava/lang/String;Ljava/lang/Throwable;)Vcloseself/Lorg/apache/zookeeper/server/quorum/QuorumPeer;-org/apache/zookeeper/server/quorum/QuorumPeertick initLimit syncLimitgetInputStream()Ljava/io/InputStream;(Ljava/io/InputStream;)V"org/apache/jute/BinaryInputArchive getArchive;(Ljava/io/InputStream;)Lorg/apache/jute/BinaryInputArchive;getOutputStream()Ljava/io/OutputStream;(Ljava/io/OutputStream;)V=(Ljava/io/OutputStream;)Lorg/apache/jute/BinaryOutputArchive; readRecorderrorgetData()[Bjava/nio/ByteBufferwrap([B)Ljava/nio/ByteBuffer;getLong1org/apache/zookeeper/server/ByteBufferInputStreambyteBuffer2Record0(Ljava/nio/ByteBuffer;Lorg/apache/jute/Record;)V getServeridgetProtocolVersionfollowerCounter(Ljava/util/concurrent/atomic/AtomicLong;&java/util/concurrent/atomic/AtomicLonggetAndDecrement quorumPeersLjava/util/Map;java/lang/LongvalueOf(J)Ljava/lang/Long; java/util/Mapget&(Ljava/lang/Object;)Ljava/lang/Object;infoOBSERVER*org/apache/zookeeper/server/util/ZxidUtilsgetEpochFromZxid(J)JgetEpochToPropose(JJ)JwaitForEpochAck5(JLorg/apache/zookeeper/server/quorum/StateSummary;)VputInt(I)Ljava/nio/ByteBuffer;makeZxid(IJ[BLjava/util/List;)VgetInt getLastZxidzk:Lorg/apache/zookeeper/server/quorum/LeaderZooKeeperServer;8org/apache/zookeeper/server/quorum/LeaderZooKeeperServer getZKDatabase*()Lorg/apache/zookeeper/server/ZKDatabase;&org/apache/zookeeper/server/ZKDatabase getLogLock5()Ljava/util/concurrent/locks/ReentrantReadWriteLock;1java/util/concurrent/locks/ReentrantReadWriteLockreadLock>()Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;getmaxCommittedLoggetminCommittedLog toHexString(J)Ljava/lang/String;getCommittedLog()Ljava/util/LinkedList;java/util/LinkedListjava/lang/Integer(I)Ljava/lang/Integer;debug'(Ljava/lang/String;Ljava/lang/Object;)Viterator()Ljava/util/Iterator;java/util/IteratorhasNextnext9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)VgetDataTreeLastProcessedZxid getPacketType(I)Ljava/lang/String;startForwarding7(Lorg/apache/zookeeper/server/quorum/LearnerHandler;J)Junlockadd(Ljava/lang/Object;)ZserializeSnapshot"(Lorg/apache/jute/OutputArchive;)V writeString'(Ljava/lang/String;Ljava/lang/String;)VstartwaitForNewLeaderAck@(JJLorg/apache/zookeeper/server/quorum/QuorumPeer$LearnerType;)VtickTime setSoTimeout(I)V isRunning isInterruptedjava/lang/Objectwait(J)VisDebugEnabled updateAckgetLocalSocketAddress processAck(JJLjava/net/SocketAddress;)V([B)V availablereadLongreadInttouch(JI)Z writeLongsetOwner(JLjava/lang/Object;)V$org/apache/zookeeper/KeeperExceptionlogTraceMessage((Lorg/slf4j/Logger;JLjava/lang/String;)V writeBoolean(Z)V toByteArraysetDataslice()Ljava/nio/ByteBuffer; getAuthinfo()Ljava/util/List;^(Lorg/apache/zookeeper/server/quorum/LearnerHandler;JIILjava/nio/ByteBuffer;Ljava/util/List;)VS(Lorg/apache/zookeeper/server/ServerCnxn;JIILjava/nio/ByteBuffer;Ljava/util/List;)V(Ljava/lang/Object;)V submitRequest((Lorg/apache/zookeeper/server/Request;)Vput interruptremoveLearnerHandlercheck(J)Z lastProposedisAliveorg/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;! @/* >    /* O   /* U   ^*Y + * **Y*Y**Y**+*,,* . LR$[/<GNSX] ^  ^^6HYL+ * W+ *W+ * !W+" *#$W+  $2C H  @/*    %@*'N-*()**N-*-+,@-+*-./01 o-2*3-45N*7HY8 * -9*:":Y; * 9-t60qt66 b%-08<DR]gqtu 4buR    !",  # (**<=*<>`*<?`@*AY*BCDE*FY*GH(**(I3YL*E+4J++ 3++*YK +L M N+OM,=,,PN*-Q4RYSN,P-T*-U*-V**WXYY *Z *<[*\] ^++ *_+.`B:+.7**a!b7 *cd'`7 eY f:**ag:  PdhWY i j: *3 45*()Y:*E4J+&YL k NOP:eYl.f:**agm76 7 77*nop:q:r*nos7*not7Yu *v w x w y w ^*noz:{|{}~76 6 7 :l:..766 7  7*Y.j:*r&ww6 7  7G:*now~ 6 7 Y  ^**7:  :!!Y  ij:*cd*345 *W*() *no7 *3Y  j45*() ]Y w   w   w ^*no*3*3*()Y*YL*E+4J++N\Y *a ^**a+.****<*<?h*nY:*n**nç :""*Y jWYL*E+4J%7++,71i+2**<=*<?`@++(*_,!Y * *+.**+.*Y+O:Y:r76!*n!WۻY+O:Y:76!Y:"Y":##*n!6$$;*n*+:%Y w  %1-ûYŶ w ƶ $! #$+"ɶ*+Ws+OP:Q7l6l6: Y*+ͷ:%Y+ͷ:%%**n%ҧL*#*7+*:M WL+E:&&:'Yֶ * * ׶ ض *٩'X,//4/]jmY6Y6HY6IYY6v}6HIYHI ,%/:1L2W4_5i6{79;<=>?@ABCDEGJ/M8N?QGTJUPV^XgZn[{]^_`abcdefgik l m-o4r8s;t>vB{Q|X~]l{ /=GJORZ^bfo),/@S\jt{!)3;EI g z !"$%&()*+D3p5z67:;<?ABCDEFIJK&L-M6NAOHPXQ]VjYmWoX[\abcdfghij lm+oAqGrSsVvYwZxkyv~} 2$%&'n( )* ~+ c, !-%./Z/1s234 56l7{8Z9:;<!o&>%(?@%ABwCD&0E-)<!6 FG"AHI#XJ6$A?@%O gK%`LYMRN_OP*GQ4%RJSTP U^V 8!W ;X >YBZQ[\X]`SaZ' b  c Z9deN**ڧL+9**7 *:L+9***ޱ 256 2  +256AEM  b6 N  /*@    fK*/ߙ2*YN*@-ç :-YjN*-*ٱ!!%! *  (49<FJ 4f EK  ghB *+W      ijJ **<=*@     kl 8mn/* 8 o p"  9qr2@0 4= ^_