Edit C:\dspace\webapps\solr\WEB-INF\lib\org\apache\zookeeper\ClientCnxn$SendThread.class
???? 1?? ? ??? ?? ? ? ????? ?? ? (? ?? ??? ?? (? B@ ?? ??? ? ?? ?? ^? ?? ??? ?? ?? !? ????? (?? (? ?? (? ??? (? ?? ?????? !?? ?? (?? ;?? ;? ?? ;? ?? ?? ???? ? D? ??? I? ?? I? ?? ? I ? ? ? )? _ ( ( ( ( ( ^ ( ? ( ( ? ?! ?"# ?$ ?% ?& q' ?( ?) ?* +, +- +./01 (2 }34 ?? ?5 ? I6 ?7 ?8 9:;<;=> ??@ ?A ?B ?C ?D IE FG/?/HI/J ?K ?L ?MN (OPQ RST RUV ?W (X ?YZ[ ?\] ?^_`ab (c def ?g h i j ?k ^l m _n )opq?r ?s (t ^m ?u vw ?xyz?{ ?| ?} ?~ ???? ?^ ? (? ? ^? ?` ?? (? ??? ??? ?????????? (? ?? ? ??? ?????? ?? ?? ?? ?? ??? ?? ?? ?? ???? ?? ?? ?? ?? ?? ???? D?? ??? ?^ ? ?: ?? ?? ?? ?? ^? ?? ???? ?^? ??M? ??M? ?? ?? ^?????? ?? ?? ? ? ?? ??? lastPingSentNs J clientCnxnSocket 'Lorg/apache/zookeeper/ClientCnxnSocket; r Ljava/util/Random; isFirstConnect Z rwServerAddress Ljava/net/InetSocketAddress; minPingRwTimeout I ConstantValue d maxPingRwTimeout pingRwTimeout saslLoginFailed RETRY_CONN_MSG Ljava/lang/String; this$0 !Lorg/apache/zookeeper/ClientCnxn; readResponse (Ljava/nio/ByteBuffer;)V Code LineNumberTable LocalVariableTable serverPath event )Lorg/apache/zookeeper/proto/WatcherEvent; we #Lorg/apache/zookeeper/WatchedEvent; request +Lorg/apache/zookeeper/proto/GetSASLRequest; this SendThread InnerClasses ,Lorg/apache/zookeeper/ClientCnxn$SendThread; incomingBuffer Ljava/nio/ByteBuffer; bbis 3Lorg/apache/zookeeper/server/ByteBufferInputStream; bbia $Lorg/apache/jute/BinaryInputArchive; replyHdr (Lorg/apache/zookeeper/proto/ReplyHeader; packet Packet (Lorg/apache/zookeeper/ClientCnxn$Packet; Exceptions <init> K(Lorg/apache/zookeeper/ClientCnxn;Lorg/apache/zookeeper/ClientCnxnSocket;)V getZkState? States )()Lorg/apache/zookeeper/ZooKeeper$States; getClientCnxnSocket )()Lorg/apache/zookeeper/ClientCnxnSocket; primeConnection ()V sw 'Lorg/apache/zookeeper/proto/SetWatches; h *Lorg/apache/zookeeper/proto/RequestHeader; dataWatches Ljava/util/List; existWatches childWatches id AuthData *Lorg/apache/zookeeper/ClientCnxn$AuthData; i$ Ljava/util/Iterator; sessId conReq +Lorg/apache/zookeeper/proto/ConnectRequest; LocalVariableTypeTable $Ljava/util/List<Ljava/lang/String;>; prependChroot "(Ljava/util/List;)Ljava/util/List; clientPath i paths Signature J(Ljava/util/List<Ljava/lang/String;>;)Ljava/util/List<Ljava/lang/String;>; sendPing startConnect addr principalUserName e *Ljavax/security/auth/login/LoginException; logStartConnect (Ljava/net/InetSocketAddress;)V msg run Ljava/lang/InterruptedException; #Ljavax/security/sasl/SaslException; sendAuthEvent authState? Event? KeeperState 0Lorg/apache/zookeeper/Watcher$Event$KeeperState; to timeToNextPing now idlePingRwServer Ljava/lang/Throwable; lastPingRwServer MAX_SEND_PING_INTERVAL pingRwServer Ljava/io/IOException; Ljava/net/ConnectException; result sock Ljava/net/Socket; br Ljava/io/BufferedReader; cleanup p onConnected (IJ[BZ)V _negotiatedSessionTimeout _sessionId _sessionPasswd [B isRO eventState close testableCloseSocket &clientTunneledAuthenticationInProgress ()Z sendPacket +(Lorg/apache/zookeeper/ClientCnxn$Packet;)V SourceFile ClientCnxn.java 1org/apache/zookeeper/server/ByteBufferInputStream[@??? &org/apache/zookeeper/proto/ReplyHeader[d header?????????? java/lang/StringBuilder #Got ping response for sessionid: 0x??=>????? after ???*+?? ms????????????? !org/apache/zookeeper/WatchedEvent ?[ Got auth sessionid:0x Got notification sessionid:0x 'org/apache/zookeeper/proto/WatcherEvent response<? /?? Got server path $ which is too short for chroot path ?[ Got ? for sessionid 0x?? )org/apache/zookeeper/proto/GetSASLRequest token !"? java/io/IOException Nothing in the queue, but got ?#[?$% &org/apache/zookeeper/ClientCnxn$Packet&h'V(?)* Xid out of order. Got Xid with err expected Xid for a packet with details: +*,?-./0?12 Reading reply sessionid:0x , packet:: 34 -SendThread()56 java/util/Random[../012395:17?,-8;<=>?@A !Socket connection established to BCD , initiating sessionE?F1 )org/apache/zookeeper/proto/ConnectRequestG?HIJK[LM N?OPQRSTSUSVW? %org/apache/zookeeper/proto/SetWatcheswx[X (org/apache/zookeeper/proto/RequestHeaderY*[\]^_`abcde?f% (org/apache/zookeeper/ClientCnxn$AuthData[g %org/apache/zookeeper/proto/AuthPacketh<i?[jkl[mnd &Session establishment request sent on op java/lang/Stringqrstuvwfxy? \(.*\) (z{? :|? )}~??? zookeeper.sasl.client.username zookeeper?~ /org/apache/zookeeper/client/ZooKeeperSaslClient[? (javax/security/auth/login/LoginException SASL configuration failed: 6 Will continue connection to Zookeeper server without 3SASL authentication, if Zookeeper server allows it.???? $Opening socket connection to server . ?????d?d?????????. java/lang/InterruptedException Unexpected exception??ld??????? !javax/security/sasl/SaslException 9SASL authentication with Zookeeper Quorum member failed: ???????I???I 7org/apache/zookeeper/ClientCnxn$SessionTimeoutException SessionTimeoutException 8Client session timed out, have not heard from server in ??~d?d??????d?? java/lang/Throwable @An exception was thrown while closing send thread for session 0x?? : ?? 7org/apache/zookeeper/ClientCnxn$SessionExpiredException SessionExpiredException , closing socket connection 4, closing socket connection and attempting reconnect 4org/apache/zookeeper/ClientCnxn$EndOfStreamException EndOfStreamException 6org/apache/zookeeper/ClientCnxn$RWServerFoundException RWServerFoundException Session 0x for server , unexpected error?d???d??? SendThread exitedloop.?? Checking server for being r/w. Timeout java/net/Socket[????*???? isro?????d?d java/io/BufferedReader java/io/InputStreamReader??[?[??? java/net/ConnectException 'Exception while seeking for r/w server rw?? Majority server found at ?4?d???I?????d 4Unable to reconnect to ZooKeeper service, session 0x has expired 3Read/write client got connected to read-only server?????d?0???? )Session establishment complete on server , sessionid = 0x , negotiated timeout = (READ-ONLY mode) ?????d?d?? *org/apache/zookeeper/ClientCnxn$SendThread java/lang/Thread %org/apache/zookeeper/ZooKeeper$States? "org/apache/zookeeper/Watcher$Event .org/apache/zookeeper/Watcher$Event$KeeperState "org/apache/jute/BinaryInputArchive getArchive ;(Ljava/io/InputStream;)Lorg/apache/jute/BinaryInputArchive; deserialize 3(Lorg/apache/jute/InputArchive;Ljava/lang/String;)V getXid ()I org/apache/zookeeper/ClientCnxn access$100 ()Lorg/slf4j/Logger; org/slf4j/Logger isDebugEnabled append -(Ljava/lang/String;)Ljava/lang/StringBuilder; access$800 $(Lorg/apache/zookeeper/ClientCnxn;)J java/lang/Long toHexString (J)Ljava/lang/String; java/lang/System nanoTime ()J (J)Ljava/lang/StringBuilder; toString ()Ljava/lang/String; debug (Ljava/lang/String;)V getErr? )org/apache/zookeeper/KeeperException$Code AUTHFAILED +Lorg/apache/zookeeper/KeeperException$Code; intValue AUTH_FAILED 'Lorg/apache/zookeeper/ZooKeeper$States; access$902 q(Lorg/apache/zookeeper/ClientCnxn;Lorg/apache/zookeeper/ZooKeeper$States;)Lorg/apache/zookeeper/ZooKeeper$States; eventThread EventThread -Lorg/apache/zookeeper/ClientCnxn$EventThread; ,org/apache/zookeeper/Watcher$Event$EventType EventType None .Lorg/apache/zookeeper/Watcher$Event$EventType; AuthFailed s(Lorg/apache/zookeeper/Watcher$Event$EventType;Lorg/apache/zookeeper/Watcher$Event$KeeperState;Ljava/lang/String;)V +org/apache/zookeeper/ClientCnxn$EventThread queueEvent &(Lorg/apache/zookeeper/WatchedEvent;)V chrootPath getPath compareTo (Ljava/lang/String;)I setPath length substring (I)Ljava/lang/String; warn ,(Lorg/apache/zookeeper/proto/WatcherEvent;)V -(Ljava/lang/Object;)Ljava/lang/StringBuilder; zooKeeperSaslClient 1Lorg/apache/zookeeper/client/ZooKeeperSaslClient; getToken ()[B respondToServer &([BLorg/apache/zookeeper/ClientCnxn;)V access$1000 9(Lorg/apache/zookeeper/ClientCnxn;)Ljava/util/LinkedList; java/util/LinkedList size (I)Ljava/lang/StringBuilder; remove ()Ljava/lang/Object; requestHeader replyHeader CONNECTIONLOSS setErr (I)V setXid getZxid setZxid (J)V access$1102 %(Lorg/apache/zookeeper/ClientCnxn;J)J Lorg/apache/jute/Record; org/apache/jute/Record access$1200 L(Lorg/apache/zookeeper/ClientCnxn;Lorg/apache/zookeeper/ClientCnxn$Packet;)V access$200 &(Ljava/lang/String;)Ljava/lang/String; CONNECTING access$300? UncaughtExceptionHandler -()Ljava/lang/Thread$UncaughtExceptionHandler; setUncaughtExceptionHandler .(Ljava/lang/Thread$UncaughtExceptionHandler;)V setDaemon (Z)V access$900 J(Lorg/apache/zookeeper/ClientCnxn;)Lorg/apache/zookeeper/ZooKeeper$States; %org/apache/zookeeper/ClientCnxnSocket getRemoteSocketAddress ()Ljava/net/SocketAddress; info seenRwServerBefore access$1100 access$1300 $(Lorg/apache/zookeeper/ClientCnxn;)I access$1400 %(Lorg/apache/zookeeper/ClientCnxn;)[B (IJIJ[B)V access$1500 access$1600 access$1700 C(Lorg/apache/zookeeper/ClientCnxn;)Lorg/apache/zookeeper/ZooKeeper; org/apache/zookeeper/ZooKeeper getDataWatches ()Ljava/util/List; getExistWatches getChildWatches java/util/List isEmpty 4(JLjava/util/List;Ljava/util/List;Ljava/util/List;)V setType? WatchRegistration ?(Lorg/apache/zookeeper/proto/RequestHeader;Lorg/apache/zookeeper/proto/ReplyHeader;Lorg/apache/jute/Record;Lorg/apache/jute/Record;Lorg/apache/zookeeper/ZooKeeper$WatchRegistration;)V addFirst (Ljava/lang/Object;)V access$1800 M(Lorg/apache/zookeeper/ClientCnxn;)Ljava/util/concurrent/CopyOnWriteArraySet; (java/util/concurrent/CopyOnWriteArraySet iterator ()Ljava/util/Iterator; java/util/Iterator hasNext next (II)V scheme data (ILjava/lang/String;[B)V access$1900 $(Lorg/apache/zookeeper/ClientCnxn;)Z ?(Lorg/apache/zookeeper/proto/RequestHeader;Lorg/apache/zookeeper/proto/ReplyHeader;Lorg/apache/jute/Record;Lorg/apache/jute/Record;Lorg/apache/zookeeper/ZooKeeper$WatchRegistration;Z)V enableReadWriteOnly get (I)Ljava/lang/Object; set '(ILjava/lang/Object;)Ljava/lang/Object; queuePacket8(Lorg/apache/zookeeper/proto/RequestHeader;Lorg/apache/zookeeper/proto/ReplyHeader;Lorg/apache/jute/Record;Lorg/apache/jute/Record;Lorg/apache/zookeeper/AsyncCallback;Ljava/lang/String;Ljava/lang/String;Ljava/lang/Object;Lorg/apache/zookeeper/ZooKeeper$WatchRegistration;)Lorg/apache/zookeeper/ClientCnxn$Packet; access$2000 M(Lorg/apache/zookeeper/ClientCnxn;)Lorg/apache/zookeeper/client/HostProvider; (org/apache/zookeeper/client/HostProvider (J)Ljava/net/InetSocketAddress; getName java/net/InetSocketAddress getHostName getPort replaceAll 8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; setName isEnabled getProperty connect getConfigStatus introduce 0(Lorg/apache/zookeeper/ClientCnxn$SendThread;J)V updateNow updateLastSendAndHeard currentTimeMillis isAlive isConnected nextInt (I)I sleep *(Ljava/lang/String;Ljava/lang/Throwable;)V access$2100 getSaslState SaslState =()Lorg/apache/zookeeper/client/ZooKeeperSaslClient$SaslState; 9org/apache/zookeeper/client/ZooKeeperSaslClient$SaslState INITIAL ;Lorg/apache/zookeeper/client/ZooKeeperSaslClient$SaslState; initialize $(Lorg/apache/zookeeper/ClientCnxn;)V error getKeeperState 2()Lorg/apache/zookeeper/Watcher$Event$KeeperState; SaslAuthenticated access$2200 getIdleRecv access$2300 getIdleSend updateLastSend CONNECTEDREADONLY java/lang/Math min (II)I doTransport K(ILjava/util/List;Ljava/util/LinkedList;Lorg/apache/zookeeper/ClientCnxn;)V getSessionId getMessage Disconnected $org/apache/zookeeper/server/ZooTrace getTextTraceLevel logTraceMessage ((Lorg/slf4j/Logger;JLjava/lang/String;)V (Ljava/lang/String;I)V setSoLinger (ZI)V setSoTimeout setTcpNoDelay getOutputStream ()Ljava/io/OutputStream; getBytes java/io/OutputStream write ([B)V flush shutdownOutput getInputStream ()Ljava/io/InputStream; (Ljava/io/InputStream;)V (Ljava/io/Reader;)V readLine equals (Ljava/lang/Object;)Z access$2400 clear access$2502 %(Lorg/apache/zookeeper/ClientCnxn;I)I access$2500 CLOSED Expired queueEventOfDeath access$2202 access$2302 access$802 access$1402 '(Lorg/apache/zookeeper/ClientCnxn;[B)[B CONNECTED ConnectedReadOnly SyncConnected wakeupCnxn org/apache/zookeeper/Watcher $org/apache/zookeeper/KeeperException )java/lang/Thread$UncaughtExceptionHandler 0org/apache/zookeeper/ZooKeeper$WatchRegistration () *+ ,- ./ 01 23 45 6 7 85 6 ? 95 :1 ;<