1 v wx v y z { |} v~     v             P   `                     A  A   Hv   H  H  H      H \  H `   v      j            Q  v    I        v v                   !"  #$ % &'  () * +,- . /  0 1  234 5 67  8 9 :;<= >?@ A B CD EF G HI J K LM NOPQ RSTPacketInFlight InnerClassesself/Lorg/apache/zookeeper/server/quorum/QuorumPeer;zk;Lorg/apache/zookeeper/server/quorum/LearnerZooKeeperServer;bufferedOutputLjava/io/BufferedOutputStream;sockLjava/net/Socket;leaderIsLorg/apache/jute/InputArchive;leaderOsLorg/apache/jute/OutputArchive;leaderProtocolVersionILOGLorg/slf4j/Logger;nodelayZpendingRevalidations(Ljava/util/concurrent/ConcurrentHashMap; SignaturebLjava/util/concurrent/ConcurrentHashMap;()VCodeLineNumberTableLocalVariableTablethis,Lorg/apache/zookeeper/server/quorum/Learner; getSocket()Ljava/net/Socket;getPendingRevalidationsCount()IvalidateSession-(Lorg/apache/zookeeper/server/ServerCnxn;JI)Vcnxn(Lorg/apache/zookeeper/server/ServerCnxn;clientIdJtimeoutbaosLjava/io/ByteArrayOutputStream;dosLjava/io/DataOutputStream;qp1Lorg/apache/zookeeper/server/quorum/QuorumPacket; Exceptions writePacket5(Lorg/apache/zookeeper/server/quorum/QuorumPacket;Z)Vppflush readPacket4(Lorg/apache/zookeeper/server/quorum/QuorumPacket;)V traceMaskrequest((Lorg/apache/zookeeper/server/Request;)Vlenb[B%Lorg/apache/zookeeper/server/Request;oa findLeader()Ljava/net/InetSocketAddress;s QuorumServer;SLjava/util/LinkedList; revalidatebisLjava/io/ByteArrayInputStream;disLjava/io/DataInputStream; sessionIdvalidpingentryEntryLjava/util/Map$Entry;bos touchTableLjava/util/HashMap;:Ljava/util/Map$Entry;8Ljava/util/HashMap;shutdown SourceFile Learner.java  &java/util/concurrent/ConcurrentHashMap W java/lang/StringBuilderRevalidating client: 0x XY Z[ \]^ _`java/io/ByteArrayOutputStreamjava/io/DataOutputStream a bH cd e/org/apache/zookeeper/server/quorum/QuorumPacket fg h ij kl mnTo validate session 0xo pq  r st  u vt w xy g z {  =| }~          n :org/apache/zookeeper/server/quorum/QuorumPeer$QuorumServer   ./#Couldn't find the leader with id = X `java/net/Socket   d   java/io/IOExceptionUnexpected exception Unexpected exception, tries= X, connecting to X  Hjava/io/BufferedInputStream   java/io/BufferedOutputStream    d   H.org/apache/zookeeper/server/quorum/LearnerInfo  LearnerInfo     g     HLeaders epoch,  is less than accepted epoch, `'First packet should have been NEWLEADER `java/util/LinkedList !Getting a diff from the leader 0xGetting a snapshot from leader     BenWasHere Missing signature. Got Missing signature0Truncating log to get in sync with the leader 0x Not able to truncate the log  d"Got unexpected packet from leader  exiting ... H  n9org/apache/zookeeper/server/quorum/Learner$PacketInFlight"org/apache/zookeeper/txn/TxnHeader    Got zxid 0x expected 0x   Committing , but next proposal is    H   java/io/File   updatingEpoch  n nFailed to create nFailed to delete  H:org/apache/zookeeper/server/quorum/FollowerZooKeeperServer java/lang/Long  H:org/apache/zookeeper/server/quorum/ObserverZooKeeperServer#org/apache/zookeeper/server/Request     !'java/lang/UnsupportedOperationExceptionUnknown server typejava/io/ByteArrayInputStream java/io/DataInputStream  n &org/apache/zookeeper/server/ServerCnxnMissing session 0x for validation  Session 0x is valid: X      java/util/Map$Entry  java/lang/Integer   r*org/apache/zookeeper/server/quorum/Learner follower.nodelaytrue TCP NoDelay set to: java/lang/Objectjava/net/ConnectExceptionjava/lang/InterruptedExceptionsizeappend-(Ljava/lang/String;)Ljava/lang/StringBuilder; toHexString(J)Ljava/lang/String;toString()Ljava/lang/String;org/slf4j/Loggerinfo(Ljava/lang/String;)V(Ljava/io/OutputStream;)V writeLongwriteInt(I)Vclose toByteArray()[B(IJ[BLjava/util/List;)VvalueOf(J)Ljava/lang/Long;put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;isTraceEnabled()Z$org/apache/zookeeper/server/ZooTracelogTraceMessage((Lorg/slf4j/Logger;JLjava/lang/String;)Vorg/apache/jute/OutputArchive writeRecord-(Lorg/apache/jute/Record;Ljava/lang/String;)Vorg/apache/jute/InputArchive readRecordgetTypelogQuorumPacketH(Lorg/slf4j/Logger;JCLorg/apache/zookeeper/server/quorum/QuorumPacket;)Vcxidtypejava/nio/ByteBufferrewind()Ljava/nio/Buffer; remainingget([B)Ljava/nio/ByteBuffer;write([B)VauthInfoLjava/util/List;-org/apache/zookeeper/server/quorum/QuorumPeergetCurrentVote+()Lorg/apache/zookeeper/server/quorum/Vote;getView()Ljava/util/Map; java/util/Mapvalues()Ljava/util/Collection;java/util/Collectioniterator()Ljava/util/Iterator;java/util/IteratorhasNextnext()Ljava/lang/Object;id'org/apache/zookeeper/server/quorum/VotegetId()J(J)Ljava/lang/StringBuilder;warntickTime initLimit setSoTimeout syncLimitconnect(Ljava/net/SocketAddress;I)V setTcpNoDelay(Z)Verror*(Ljava/lang/String;Ljava/lang/Throwable;)V(I)Ljava/lang/StringBuilder;-(Ljava/lang/Object;)Ljava/lang/StringBuilder;java/lang/ThreadsleepgetInputStream()Ljava/io/InputStream;(Ljava/io/InputStream;)V"org/apache/jute/BinaryInputArchive getArchive;(Ljava/io/InputStream;)Lorg/apache/jute/BinaryInputArchive;getOutputStream()Ljava/io/OutputStream;#org/apache/jute/BinaryOutputArchive=(Ljava/io/OutputStream;)Lorg/apache/jute/BinaryOutputArchive;getLastLoggedZxidsetTypegetAcceptedEpoch*org/apache/zookeeper/server/util/ZxidUtilsmakeZxid(JJ)JsetZxid(JI)VsetDatagetZxidgetEpochFromZxid(J)JgetDatawrapgetIntgetCurrentEpochputInt(I)Ljava/nio/ByteBuffer;setAcceptedEpoch9org/apache/zookeeper/server/quorum/LearnerZooKeeperServer getZKDatabase*()Lorg/apache/zookeeper/server/ZKDatabase;&org/apache/zookeeper/server/ZKDatabasecleardeserializeSnapshot!(Lorg/apache/jute/InputArchive;)V readString&(Ljava/lang/String;)Ljava/lang/String;java/lang/Stringequals(Ljava/lang/Object;)Z truncateLog(J)Zjava/lang/SystemexitsetlastProcessedZxidcreateSessionTracker isRunninghdr$Lorg/apache/zookeeper/txn/TxnHeader;/org/apache/zookeeper/server/util/SerializeUtilsdeserializeTxn@([BLorg/apache/zookeeper/txn/TxnHeader;)Lorg/apache/jute/Record;recLorg/apache/jute/Record;add peekFirst processTxnProcessTxnResultu(Lorg/apache/zookeeper/txn/TxnHeader;Lorg/apache/jute/Record;)Lorg/apache/zookeeper/server/DataTree$ProcessTxnResult;remove takeSnapshotsetCurrentEpoch cnxnFactory/Lorg/apache/zookeeper/server/ServerCnxnFactory;-org/apache/zookeeper/server/ServerCnxnFactorysetZooKeeperServer0(Lorg/apache/zookeeper/server/ZooKeeperServer;)V getTxnFactory:()Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog;6org/apache/zookeeper/server/persistence/FileTxnSnapLog getSnapDir()Ljava/io/File;#(Ljava/io/File;Ljava/lang/String;)Vexists createNewFiledeletestartupupdateElectionVote logRequest?(Lorg/apache/zookeeper/txn/TxnHeader;Lorg/apache/jute/Record;)V longValuecommit getClientIdgetCxidS(Lorg/apache/zookeeper/server/ServerCnxn;JIILjava/nio/ByteBuffer;Ljava/util/List;)Vtxn commitRequestreadLong readBoolean&(Ljava/lang/Object;)Ljava/lang/Object;finishSessionInit,(Lorg/apache/zookeeper/server/ServerCnxn;Z)V(Z)Ljava/lang/StringBuilder;getTouchSnapshot()Ljava/util/HashMap;java/util/HashMapentrySet()Ljava/util/Set; java/util/SetgetKeygetValueintValuecloseAllorg/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger; getProperty8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;5org/apache/zookeeper/server/DataTree$ProcessTxnResult$org/apache/zookeeper/server/DataTree! G***Y9P Y /*J   2*]   ) Y  Y:Y: Y:* +W" Y ! "*#2 lm'n2o8p?qDrXteupv{|H 'p2eX?Q/*$YN+*$+%& *'(-ç :-$''+' ". ///QC*)YM*)+%*,çN,-+A+-.A  i+0& !)-8B CC!"Q !"YMY,N-+1-+2-+3+42+45W+466:+47W+45W-8-Y,+9:*#B!)08AGQY_cxHA"G#$ %xo&xQ'(mL*:;M*:<=>N-?'-@A:B,C DL+! Y E ,CFG+*  0=CFIMk40)+-,-mk./ c0123|*HYI**:J*:KhL=*+*:J*:MhN*OPhNR-S- Y T UV +W-X*HYI**:J*:KhLY[u*\Y*]^_)*`Y*ab'**'c$(ILQN !(?ILMR]_*MX45#6./Q789:^ X*:dAYe:f*:g hijY*:klm:Y:c:nop*#*qrs7-*tuv:  u: *:g *:wxW*:yE*:g  xW.QY Y z F{ *:gF|Y  : * # h*:g *:y- }~QY}|r~' 9 B I R\cis} "$%&(+)4+>,H-R/p ;$ <= > XX?P@G9ABBCIDEsFQGH Y NYe:s7*qY:Y:*Y: - ( Y  r -e***)*):  ) Y   ~QY|-e Y  r G*r6  * Y  r ~ , Y  -U ~ *r* 7 6 *:*q- <:Y:  Y t   a7 Y     a G 7  W k:  r5 Y  rF  FG*  WWprW_Y:Yt a7 Y     a G7  *WWrW **:*:*Y*::*"QY Y   |**:"QY Y   |6 *Y#U ç : - hi*-#**:J*:MhL**:*h*: :  ?! @:    :  ? @:   **: :  ? @: :   ; Y     GWY   :       ŧR YǷȿ;8;;@;i: ;<>!?*@3A;BECjEtF~IJKLMNPRTUW:Y?\B^f`kczdfknoprstuvC{M|U}X]gx AKPem{~"25CMSipy"3hkq0IJ ,K LM yNOSPMQ R SM (,-  TU #,- YVW "TU  % SM ,- XY Z [F*\]3^]_*\`3^aQ8b-Y+tMY,N-7-6*:* Y Ѷ  Ҷ G*Ӳ- Y Զ  ն ֶ".  !27^itH cdefg!~h2m QipYMY,N*:ع:?4@:--ݶ޶+,p*+#*    <M^aioH<"jl&;,-pphm_Vno_<"jpVnqQr^$*:*:* * !"#$ $sZ6O Y  OֶR TV5Wtu"A* k