Edit C:\dspace\webapps\solr\WEB-INF\lib\org\apache\zookeeper\server\quorum\LearnerHandler.class
???? 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 XYZ SyncLimitCheck InnerClasses LOG Lorg/slf4j/Logger; sock Ljava/net/Socket; leader +Lorg/apache/zookeeper/server/quorum/Leader; tickOfNextAckDeadline J sid version I queuedPackets *Ljava/util/concurrent/LinkedBlockingQueue; Signature ]Ljava/util/concurrent/LinkedBlockingQueue<Lorg/apache/zookeeper/server/quorum/QuorumPacket;>; syncLimitCheck BLorg/apache/zookeeper/server/quorum/LearnerHandler$SyncLimitCheck; ia $Lorg/apache/jute/BinaryInputArchive; oa %Lorg/apache/jute/BinaryOutputArchive; bufferedOutput Ljava/io/BufferedOutputStream; proposalOfDeath 1Lorg/apache/zookeeper/server/quorum/QuorumPacket; learnerType[ LearnerType ;Lorg/apache/zookeeper/server/quorum/QuorumPeer$LearnerType; getSocket ()Ljava/net/Socket; Code LineNumberTable LocalVariableTable this 3Lorg/apache/zookeeper/server/quorum/LearnerHandler; getSid ()J getVersion ()I <init> ?(Ljava/net/Socket;Lorg/apache/zookeeper/server/quorum/Leader;)V Exceptions toString ()Ljava/lang/String; sb Ljava/lang/StringBuilder; getLearnerType =()Lorg/apache/zookeeper/server/quorum/QuorumPeer$LearnerType; sendPackets ()V p ie Ljava/io/IOException; e traceMask packetToString E(Lorg/apache/zookeeper/server/quorum/QuorumPacket;)Ljava/lang/String; run bbsid Ljava/nio/ByteBuffer; li 0Lorg/apache/zookeeper/server/quorum/LearnerInfo; epoch ver [B newEpochPacket ackEpochPacket bbepoch qcommit propose Proposal 4Lorg/apache/zookeeper/server/quorum/Leader$Proposal; i$ Ljava/util/Iterator; prevProposalZxid firstPacket Z maxCommittedLog minCommittedLog proposals Ljava/util/LinkedList; sess to SessionExpiredException >Lorg/apache/zookeeper/KeeperException$SessionExpiredException; si %Lorg/apache/zookeeper/server/Request; bis Ljava/io/ByteArrayInputStream; dis Ljava/io/DataInputStream; id bos Ljava/io/ByteArrayOutputStream; dos Ljava/io/DataOutputStream; valid bb sessionId cxid type qp learnerInfoData lastAcceptedEpoch peerLastZxid ss 1Lorg/apache/zookeeper/server/quorum/StateSummary; zxid newEpoch packetToSend zxidToSend leaderLastZxid updates lock 3Ljava/util/concurrent/locks/ReentrantReadWriteLock; rl\ ReadLock <Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock; newLeaderQP Ljava/lang/InterruptedException; LocalVariableTypeTable LLjava/util/LinkedList<Lorg/apache/zookeeper/server/quorum/Leader$Proposal;>; shutdown ping queuePacket 4(Lorg/apache/zookeeper/server/quorum/QuorumPacket;)V synced ()Z access$000 ()Lorg/slf4j/Logger; access$200 6(Lorg/apache/zookeeper/server/quorum/LearnerHandler;)V x0 <clinit> SourceFile LearnerHandler.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 gn LearnerHandler tickOfNextAckDeadline: ? ]h synced?: ij ]i queuedPacketLength: j ]k lm ? ? n om p qr s tuv wjx yz ? ? packet{ |} java/io/IOException ~j Unexpected 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 ?m 2org/apache/zookeeper/server/quorum/Leader$Proposal ? gh 6Sending 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 empty Sending ?? ?? ? ?? (Sending snapshot last zxid of peer is 0x zxid of leader is 0x sent 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? ?? ?j Received ACK from Observer ?? ?a ?? java/io/ByteArrayInputStream ? java/io/DataInputStream ? ? ? ?? java/io/ByteArrayOutputStream java/io/DataOutputStream ?? ??? <org/apache/zookeeper/KeeperException$SessionExpiredException Somehow session 0 expired right after being renewed! (impossible) ?? Session 0x is valid: ?? ?? ? ? 5org/apache/zookeeper/server/quorum/LearnerSyncRequest #org/apache/zookeeper/server/Request ? ;Unexpected exception causing shutdown while sock still open java/lang/InterruptedException %Unexpected exception causing shutdown ******* GOODBYE <null> ******** e Ignoring unexpected exception 1Ignoring unexpected exception during socket close n ? 6Closing connection to peer due to transaction timeout. j 1org/apache/zookeeper/server/quorum/LearnerHandler java/lang/Thread 9org/apache/zookeeper/server/quorum/QuorumPeer$LearnerType :java/util/concurrent/locks/ReentrantReadWriteLock$ReadLock append -(Ljava/lang/String;)Ljava/lang/StringBuilder; java/net/Socket getRemoteSocketAddress ()Ljava/net/SocketAddress; -(Ljava/lang/Object;)Ljava/lang/StringBuilder; (Ljava/lang/String;)V k(Lorg/apache/zookeeper/server/quorum/LearnerHandler;Lorg/apache/zookeeper/server/quorum/LearnerHandler$1;)V PARTICIPANT )org/apache/zookeeper/server/quorum/Leader addLearnerHandler (J)Ljava/lang/StringBuilder; (Z)Ljava/lang/StringBuilder; size (I)Ljava/lang/StringBuilder; poll ()Ljava/lang/Object; flush take getType getZxid java/lang/System nanoTime updateProposal (JJ)V org/slf4j/Logger isTraceEnabled $org/apache/zookeeper/server/ZooTrace logQuorumPacket H(Lorg/slf4j/Logger;JCLorg/apache/zookeeper/server/quorum/QuorumPacket;)V #org/apache/jute/BinaryOutputArchive writeRecord -(Lorg/apache/jute/Record;Ljava/lang/String;)V isClosed warn *(Ljava/lang/String;Ljava/lang/Throwable;)V close self /Lorg/apache/zookeeper/server/quorum/QuorumPeer; -org/apache/zookeeper/server/quorum/QuorumPeer tick initLimit syncLimit getInputStream ()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; readRecord error getData ()[B java/nio/ByteBuffer wrap ([B)Ljava/nio/ByteBuffer; getLong 1org/apache/zookeeper/server/ByteBufferInputStream byteBuffer2Record 0(Ljava/nio/ByteBuffer;Lorg/apache/jute/Record;)V getServerid getProtocolVersion followerCounter (Ljava/util/concurrent/atomic/AtomicLong; &java/util/concurrent/atomic/AtomicLong getAndDecrement quorumPeers Ljava/util/Map; java/lang/Long valueOf (J)Ljava/lang/Long; java/util/Map get &(Ljava/lang/Object;)Ljava/lang/Object; info OBSERVER *org/apache/zookeeper/server/util/ZxidUtils getEpochFromZxid (J)J getEpochToPropose (JJ)J waitForEpochAck 5(JLorg/apache/zookeeper/server/quorum/StateSummary;)V putInt (I)Ljava/nio/ByteBuffer; makeZxid (IJ[BLjava/util/List;)V getInt getLastZxid zk :Lorg/apache/zookeeper/server/quorum/LeaderZooKeeperServer; 8org/apache/zookeeper/server/quorum/LeaderZooKeeperServer getZKDatabase *()Lorg/apache/zookeeper/server/ZKDatabase; &org/apache/zookeeper/server/ZKDatabase getLogLock 5()Ljava/util/concurrent/locks/ReentrantReadWriteLock; 1java/util/concurrent/locks/ReentrantReadWriteLock readLock >()Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock; getmaxCommittedLog getminCommittedLog toHexString (J)Ljava/lang/String; getCommittedLog ()Ljava/util/LinkedList; java/util/LinkedList java/lang/Integer (I)Ljava/lang/Integer; debug '(Ljava/lang/String;Ljava/lang/Object;)V iterator ()Ljava/util/Iterator; java/util/Iterator hasNext next 9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V getDataTreeLastProcessedZxid getPacketType (I)Ljava/lang/String; startForwarding 7(Lorg/apache/zookeeper/server/quorum/LearnerHandler;J)J unlock add (Ljava/lang/Object;)Z serializeSnapshot "(Lorg/apache/jute/OutputArchive;)V writeString '(Ljava/lang/String;Ljava/lang/String;)V start waitForNewLeaderAck @(JJLorg/apache/zookeeper/server/quorum/QuorumPeer$LearnerType;)V tickTime setSoTimeout (I)V isRunning isInterrupted java/lang/Object wait (J)V isDebugEnabled updateAck getLocalSocketAddress processAck (JJLjava/net/SocketAddress;)V ([B)V available readLong readInt touch (JI)Z writeLong setOwner (JLjava/lang/Object;)V $org/apache/zookeeper/KeeperException logTraceMessage ((Lorg/slf4j/Logger;JLjava/lang/String;)V writeBoolean (Z)V toByteArray setData slice ()Ljava/nio/ByteBuffer; getAuthinfo ()Ljava/util/List; ^(Lorg/apache/zookeeper/server/quorum/LearnerHandler;JIILjava/nio/ByteBuffer;Ljava/util/List;)V S(Lorg/apache/zookeeper/server/ServerCnxn;JIILjava/nio/ByteBuffer;Ljava/util/List;)V (Ljava/lang/Object;)V submitRequest ((Lorg/apache/zookeeper/server/Request;)V put interrupt removeLearnerHandler check (J)Z lastProposed isAlive org/slf4j/LoggerFactory getLogger %(Ljava/lang/Class;)Lorg/slf4j/Logger; ! ? ? ? ? ? ? ? ? @ ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? / *? ? > / *? ? O / *? ? U ? ^*? Y? ? +? ? ? ? * ? *? *? Y? ? *? Y*? ? *? Y? ? *? ? *+? *,? ,*? ? . ? L R $ [ / ? < ? G ? N ? S ? X ? ] ? ^ ^ ? ? ^ ? ? 6 ? H? Y? L+? *? ? W+ ? *? ? W+ ? *? ? !W+"? *? ? #? $W+? ? ? ? ? $ ? 2 ? C ? H @ / *? ? ? ? ? %@*? ? '? N-? *? (? )*? ? *? N-*? ? ? ?-? +? ,@-? +? *? -? .? /? 0? ? 1 ? ? o-? 2*? 3-4? 5???N*? ? 7? H? ? Y? 8? *? ? -? 9 *? ? :? ":? ? Y? ;? *? ? ? 9 ? ? - t 6 0 q t 6 ? ? ? 6 b ? ? ? ? ? % ? - ? 0 ? 8 ? < ? D ? R ? ] ? g ? q ? t ? u ? ? ? ? ? ? ? ? ? ? ? ? ? ? 4 b ? u R ? ? ? ? !" , ? ? # ? ( ?**? ? <? =*? ? <? >`*? ? <? ?`?? @*? AY*? ? B? C? D? E*? FY*? ? G? H? (**? (? I? 3? Y? L*? E+4? J+? + ? 3+? +? *? ? Y? K? +? L? M? ? ? N ??+? OM,? =,?? ,? PN*-? Q? ? 4? RY? SN,? P-? T*-? U? *-? V? ? **? ? W? X? ? ? Y? Y? *? ? Z? *? ? <? [*? ? \? ] ? ? ? ^ +? +? *? _? +? .? `B:+? .7*? *? a!? b7 *? cd? '? `7 ? eY ? f:*? *? a? g? ??: ? Pd? hW? Y ? i ? j: *? 3 4? 5*? (? )? Y? :*? E4? J? +? &? ? Y? ? L? k? ? ? N ???? O? P:? eY? l?? .? f:*? *? a? g? m76 7 77*? ? n? o? p:? q:? r*? ? n? o? s7*? ? n? o? t7? ? Y? u? *? ? v? ? w? x? ? w? y? ? w? ? ? ^ *? ? n? o? z:? {? ? |? {? }? ~ ?? ??? ?? ? ? 76 6 7 ? ?: ? ? ? l ? ? ? ?: ? ?? .?? ? ?? .7??? ? 6 ?? 6 7 7* ? ?? ?? Y ? ?? .? j: * ? ????? r?? &? ?? w? w? ? 6 7 7? G? ?? ? ? :*? ? n? o? ??? ? ?? w? ~ 6 7 ? ? ?? ? ? ? Y? ?? ? ?? ? ? ^ *? *? ?7? ? : ? ?:!? ??!? Y ? i? j:*? cd? *? 34? 5? *? ? ?W*? (? ) ? *? ? n? o? ?7 *? 3? Y ? j4? 5*? (? ) ? ]? ? Y? ?? ? w? ?? ?? ? w? ?? ? w? ? ? ^ *? ? n? o*? 3? ?*? 3??? ?*? (? )? ?Y*? ?? ?? Y? L*? E+4? J+? +? ? ?? N ?\?? ? Y? ?? *? a? ? ? ^ *? *? a+? .*? ?? ?*? ? ?*? *? ? <? ?*? ? <? ?h? ?*? ? nY:?*? ? n? ?? *? ?? *? ? n ?? ????ç :"?"?*? ? Y ?? j? ?W? Y? L*? E+4? J %7+? +? ,7? ? 1 ? ? i+? 2**? ? <? =*? ? <? ?`?? @+? +? ? ( ?*? ? _? ,? ? ? ? !? ? Y? ?? *? ? ? ? ? *? +? .? ?*? *? +? .*? ? ?? ???? ?Y+? O? ?: ? ?Y ? ?: ? ??r ? ?7 ? ?6!*? ? n !? ?W??? ?Y+? O? ?: ? ?Y ? ?: ? ?7 ? ?6!? ?Y? ?:"? ?Y"? ?:## ? ?*? ? n !? ?6$$? ;*? ? n *? ?? +:%? ? Y? ?? ? w? ?? ? %? ? ? ? 1 ? -? û Y? ? ? w? ? $? !? ? ?#$? ?+"? ? ?*? +? ?W? s+? O? P:? Q7? l6? l6 ? ?: ? ? ?Y* +? ? ?:%? ? ?Y +? ? ?:%%*? ?*? ? n%? ? ??L*? ? #*? ? 7? ? ?+? ? *? ? :? M? ? WL? ?+? ? ? ? E:&? &?:'? ? Y? ? *? ? *? ? ? ? ? ? ? ? *? ?'? X,/ /4/ ??? ??? ]jm ? ?Y 6 ?Y 6HY 6IYY 6v}? 6 ?? ? ?? ?H? ?IY? ? ?? ?? H? I?? ??? ??? ? , %/ :1 L2 W4 _5 i6 {7 ?9 ?; ?< ?= ?> ?? ?@ ?A ?B ?C ?D ?E ?G ?J/M8N?QGTJUPV^XgZn[{]?^?_?`?a?b?c?d?e?f?g?ik l m-o4r8s;t>vB{Q|X~]l?{????????????? ???/?=?G?J?O?R?Z?^?b?f?o????????????????????????????? ?)?,?/?@?S?\?j?t?{????????????????!)3;EI g z ?????? ?!?"$%&( )*+D3p5z6?7?:?;?<???A?B?C?D?EFIJ K&L-M6NAOHPXQ]VjYmWoX?[?\?a?b?c?d?f?g?h?ij lm+oAqGrSsVvYwZxkyv~}???????????????????? ? 2 ? $% ? &' n ( ? ? ?)* ? ~+ ? c, !-% ? . / Z/1 s23 ?4 ? ?56 l?7 ? {?8 ? ?Z9: ? ; ? ? < ? !o & > %( ?@ %??AB ?wCD &0E ? -)< ? !6 FG "AHI #X ?J6 $A ?@ %O ? ? gK% ? `L ? ? YM ? RN ? _?O ??P* GQ ? 4%R ? JST P U ? ^?V ? 8!W ? ; X ? >Y ? BZ ? Q[\ X]` Sa ? Z ' ? b ? c ?Z9d e ? N*? *? ? ? L? ?+? 9 *? ? *? ? 7? *? ? :? L? ?+? 9 *? ?*? *? ? ? 2 5 6 2 ? ? ? ? ? +? 2? 5? 6? A? E? M? b 6 N ? / *? @? ? f ? K*? ? /? ? 2*? YN?*? ? ?@-ç :-??? Y ? jN*-? ?? ? ? ? *? ? ! ! % ! * ? ? ? ? (? 4? 9? <? F? J? 4 f E ? K gh B *? +? ?W? ? ? ij J *? ? *? ? <? =?*? @?? ? ? ? kl ? ? 8mn / *? ? 8 o ? p " ? ? ? 9 q r ? 2 ? ? ? ?@ ??0 ?4= ^?_
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de