1R    U                                U    / / /  / /      =  U    U             U U U U U  ! \ "#$%& '( ) *+ ,- . /0 1 23 /4 5 67 &8 9 : *; <= > ?@ ABCDE F GHIJK L M M NO P Q RS P Q TU UV WXY Z Q [\ P Q ]^ P Q _` P Q ab P Q cd P Q e fg h Q ij P Q k l mn h Q op P Q qr P Q Us t uvw xyz { |} ~  }      * *      *   U U U 0  @ W      InnerClasses IsroCommandMonitorCommand WatchCommand ConsCommand StatCommand DumpCommandCnxnStatResetCommandStatResetCommand ConfCommand EnvCommandSetTraceMaskCommandTraceMaskCommand RuokCommand CommandThreadSendBufferWriterLOGLorg/slf4j/Logger;factory2Lorg/apache/zookeeper/server/NIOServerCnxnFactory;sock!Ljava/nio/channels/SocketChannel;sk Ljava/nio/channels/SelectionKey; initializedZ lenBufferLjava/nio/ByteBuffer;incomingBufferoutgoingBuffers*Ljava/util/concurrent/LinkedBlockingQueue; SignatureALjava/util/concurrent/LinkedBlockingQueue;sessionTimeoutIzkServer-Lorg/apache/zookeeper/server/ZooKeeperServer;outstandingRequests sessionIdJ nextSessionIdoutstandingLimitZK_NOT_SERVINGLjava/lang/String; ConstantValue fourBytes[B(Lorg/apache/zookeeper/server/ZooKeeperServer;Ljava/nio/channels/SocketChannel;Ljava/nio/channels/SelectionKey;Lorg/apache/zookeeper/server/NIOServerCnxnFactory;)VCodeLineNumberTableLocalVariableTablethis+Lorg/apache/zookeeper/server/NIOServerCnxn;zkaddrLjava/net/InetAddress; ExceptionssendCloseSession()VsendBufferSync(Ljava/nio/ByteBuffer;)VieLjava/io/IOException;bb sendBuffereLjava/lang/Exception; readPayloadrc isSocketOpen()ZdoIO#(Ljava/nio/channels/SelectionKey;)V isPayloadpbi$Ljava/util/Iterator;left directBuffersent)Ljava/nio/channels/CancelledKeyException;CloseRequestException>Lorg/apache/zookeeper/server/ServerCnxn$CloseRequestException;EndOfStreamException=Lorg/apache/zookeeper/server/ServerCnxn$EndOfStreamException;k readRequestincrOutstandingRequests-(Lorg/apache/zookeeper/proto/RequestHeader;)Vh*Lorg/apache/zookeeper/proto/RequestHeader; disableRecv enableRecvinterestreadConnectRequestcleanupWriterSocket(Ljava/io/PrintWriter;)VpwriterLjava/io/PrintWriter;checkFourLetterWord$(Ljava/nio/channels/SelectionKey;I)Zruok7Lorg/apache/zookeeper/server/NIOServerCnxn$RuokCommand;tmask; closeSock sendResponseU(Lorg/apache/zookeeper/proto/ReplyHeader;Lorg/apache/jute/Record;Ljava/lang/String;)VbaosLjava/io/ByteArrayOutputStream;bos%Lorg/apache/jute/BinaryOutputArchive;(Lorg/apache/zookeeper/proto/ReplyHeader;rLorg/apache/jute/Record;tagprocess&(Lorg/apache/zookeeper/WatchedEvent;)Vevent#Lorg/apache/zookeeper/WatchedEvent;)Lorg/apache/zookeeper/proto/WatcherEvent; getSessionId setSessionId(J)VsetSessionTimeout(I)VgetInterestOpsgetRemoteSocketAddress()Ljava/net/InetSocketAddress; serverStats+()Lorg/apache/zookeeper/server/ServerStats; access$000C(Lorg/apache/zookeeper/server/NIOServerCnxn;Ljava/io/PrintWriter;)Vx0x1 access$100Z(Lorg/apache/zookeeper/server/NIOServerCnxn;)Lorg/apache/zookeeper/server/ZooKeeperServer; SourceFileNIOServerCnxn.java )* ij 6B   ! "!(java/util/concurrent/LinkedBlockingQueue #$ /(    /org/apache/zookeeper/server/ZooKeeperSaslServer 6      java/net/InetSocketAddress  org/apache/zookeeper/data/Idip  6   ! HD  O  Bjava/io/IOException !Error sending data synchronously       Ojava/lang/StringBuilder$Add a buffer to outgoingBuffers, sk   is valid: O   java/lang/ExceptionUnexpected Exception: ;org/apache/zookeeper/server/ServerCnxn$EndOfStreamException7Unable to read additional data from client sessionid 0x ,- !, likely client has closed socket 6 B   hB `B  NO0trying to do i/o on a null socket for session:0x  O  KB O  X!  O java/nio/ByteBuffer      org/apache/zookeeper/server/NIOServerCnxn$CnxnStatResetCommand &(5org/apache/zookeeper/server/NIOServerCnxn$DumpCommand '( ((5org/apache/zookeeper/server/NIOServerCnxn$StatCommand 6) *(5org/apache/zookeeper/server/NIOServerCnxn$ConsCommand +( ,( -(6org/apache/zookeeper/server/NIOServerCnxn$WatchCommand .(8org/apache/zookeeper/server/NIOServerCnxn$MonitorCommand /(5org/apache/zookeeper/server/NIOServerCnxn$IsroCommand 0 mn1 2( Len error '(!NIOServerCnxn object with sock =  and sk = 345  6 7 java/util/Set 89 :9 B-ignoring exception during selectionkey cancel$Closed socket connection for client  which had sessionid 0x$ (no session established for client) ;B)ignoring exception during output shutdown <B(ignoring exception during input shutdown&ignoring exception during socket close-ignoring exception during socketchannel closejava/io/ByteArrayOutputStream= >? 45 @header ABError serializing response  CD EF G H fB*Unexpected exception. Destruction averted.&org/apache/zookeeper/proto/ReplyHeader 6IDeliver event  to 0x through JKL MN notification  )org/apache/zookeeper/server/NIOServerCnxnO PQ .-&org/apache/zookeeper/server/ServerCnxn+org/apache/zookeeper/server/NIOServerCnxn$17org/apache/zookeeper/server/NIOServerCnxn$CommandThread9This ZooKeeper instance is not currently serving requestsjava/lang/InterruptedExceptionallocate(I)Ljava/nio/ByteBuffer;0org/apache/zookeeper/server/NIOServerCnxnFactoryloginLorg/apache/zookeeper/Login;(Lorg/apache/zookeeper/Login;)VzooKeeperSaslServer1Lorg/apache/zookeeper/server/ZooKeeperSaslServer;+org/apache/zookeeper/server/ZooKeeperServergetGlobalOutstandingLimitjava/nio/channels/SocketChannelsocket()Ljava/net/Socket;java/net/Socket setTcpNoDelay(Z)V setSoLinger(ZI)V()Ljava/net/SocketAddress; getAddress()Ljava/net/InetAddress;authInfoLjava/util/ArrayList;java/net/InetAddressgetHostAddress'(Ljava/lang/String;Ljava/lang/String;)Vjava/util/ArrayListadd(Ljava/lang/Object;)Zjava/nio/channels/SelectionKey interestOps#(I)Ljava/nio/channels/SelectionKey;-org/apache/zookeeper/server/ServerCnxnFactory closeConnconfigureBlocking((Z)Ljava/nio/channels/SelectableChannel;isOpenwrite(Ljava/nio/ByteBuffer;)I packetSentorg/slf4j/Loggererror*(Ljava/lang/String;Ljava/lang/Throwable;)V remainingselector()Ljava/nio/channels/Selector;java/nio/channels/SelectorwakeupisTraceEnabledappend-(Ljava/lang/String;)Ljava/lang/StringBuilder;-(Ljava/lang/Object;)Ljava/lang/StringBuilder;isValid(Z)Ljava/lang/StringBuilder;trace(Ljava/lang/String;)Vreadjava/lang/Long toHexString(J)Ljava/lang/String;packetReceivedflip()Ljava/nio/Buffer;clearwarn isReadable isWritablesizeiterator()Ljava/util/Iterator;java/util/IteratorhasNextnext()Ljava/lang/Object;slice()Ljava/nio/ByteBuffer;limit(I)Ljava/nio/Buffer;positionput,(Ljava/nio/ByteBuffer;)Ljava/nio/ByteBuffer;peekremoveisDebugEnableddebug processPacket@(Lorg/apache/zookeeper/server/ServerCnxn;Ljava/nio/ByteBuffer;)V(org/apache/zookeeper/proto/RequestHeadergetXid getInProcess(I)Ljava/lang/StringBuilder;processConnectRequestflushinfo cmd2StringLjava/util/HashMap;java/lang/IntegervalueOf(I)Ljava/lang/Integer;java/util/HashMapget&(Ljava/lang/Object;)Ljava/lang/Object;cancel[(Lorg/apache/zookeeper/server/NIOServerCnxn;Lorg/apache/zookeeper/server/NIOServerCnxn$1;)V(Ljava/io/Writer;)VruokCmdstartgetTraceMaskCmdsetTraceMaskCmdgetLong$org/apache/zookeeper/server/ZooTracesetTextTraceLevelD(Lorg/apache/zookeeper/server/NIOServerCnxn;Ljava/io/PrintWriter;J)VenviCmdconfCmdsrstCmdcrstCmddumpCmdstatCmdsrvrCmdD(Lorg/apache/zookeeper/server/NIOServerCnxn;Ljava/io/PrintWriter;I)VconsCmdwchpCmdwchcCmdwchsCmdmntrCmdisroCmdgetInt"org/apache/jute/BinaryInputArchive maxBuffercnxnsLjava/util/HashSet;java/util/HashSetipMapgetInetAddressunregisterConnection+(Lorg/apache/zookeeper/server/ServerCnxn;)V removeCnxnshutdownOutput shutdownInput#org/apache/jute/BinaryOutputArchive getArchive=(Ljava/io/OutputStream;)Lorg/apache/jute/BinaryOutputArchive;([B)V writeRecord-(Lorg/apache/jute/Record;Ljava/lang/String;)V toByteArray()[Bwrap([B)Ljava/nio/ByteBuffer;putIntrewind(IJI)VlogTraceMessage((Lorg/slf4j/Logger;JLjava/lang/String;)V!org/apache/zookeeper/WatchedEvent getWrapper+()Lorg/apache/zookeeper/proto/WatcherEvent;org/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;! !"!#$%&'()*+(,-.-/(012345678@*****Y * *+*, *- * * *Y+ *+ ,,,:*YW-W9N^E GI[$_)`.a3b9cCdSfWg_iglpmopq:>;<=*>?@&AB86* !9 wx: ;<CD87* "W+ * # * +$W*%M'(,)'*&9& #'*+6: + EF7;<7G!HD8p+ (* *~* +$WM++*%* YM* ,-W'.0'/Y012* 342* 5678* +9W* 5* * *W,çN,-M';,)&3+:,:9R '+,3>Iv:* IF IJ;<G!KB8y*+9* *<<)=Y/Y0>2*?@2A27B*+1*C*DW*E *F*G*HW**96 @JNV]dhpx:*L(y;<@&MNO82* #9: ;<PQ8*I%'/Y0J2*?@27K+Lu* *<=)=Y/Y0>2*?@2A27B*+5***DW*+M>*HW> *N+OA* P* QM,HW* RN-SN-TU:,++V,+WU:X6,YWZW,+,DW* ,$>* PV* [U: \Y]^+d6X`ZW*%+d>* _W* YM* P5*E* *~ \Y`^* * *~W* * *W,ç :,M'/Y0b2*?@2c2,37K'd'e,f*gcM*g[M'h,i*gHM'/Y0b2*?@2c2,37K'd'j,f*g(a)aa(2\)2\2\(:=):=:=(M&)M&M&9F()0<@fp{"#$%&(-!/*344@5H6R8[9`>m?pAtC|DEKLMOQTWqYZ] ^+`/q2a3c7q:d;eFhJqMiNjxmnpr: R R<fL(S(=T!TUV[)W(X!*]Y(@GG!DIZ3I\;I^NDIF;<_@M`B8; ***k9 u v:  ;<@&ab8q+ll*YM*Ym`m,çN,-* YM*n* 3'd$'/Y0o2*np7q*r,ç :, &fiimi9. yz {|}&4?`dp:q;<qcdeB8A* * *~W9 : ;<fB8@* YL* ,-W* 5* *=~* W+çN+-7::=:9"$*5?:$g(@;<hB8]#* &Yst***u*E9": #;<@&Mij8D+ +v+w4M'x,y "N-:*g:'z) :$!$$($,03:9B !$,035AC:* IJ5 IJD;<Dklmn8$ {|}~N-'/Y02-22* 37*C++:')YYY*:Y*:Y*:J* *<6 &Yt*DW*7Y*:Y*:Y*:Y*:Y*:Y*: Y*:Y*: Y*:Y*:Y*:IMP:9F789;A=EHIJMMPKRL^PwR~STUVWXYZ[\]`abcdefg hijk&l+m-n4o@pEqGrNsZt_uavhwtxyy{z{|}~ :R IJopqr:L(s-tu vw&xy@z{Z|}t~ ;<_(1wkl@&8^*=*E** ř Ƥ&Y/Y0Ƕ2p7t* &Yst*9& (CJT\: ^;<^_V(@&8{!*YL* YM*m,+íN,-:+ 9 : !;<8/*Ȭ9: ;<8M#/Y0ɶ2* 3ʶ2* 379: #;<B8i* YL* *̚+ñ* YM* * ζ}N-*W,ç :,* ** **** $* M'd',f+ç :+%GJJNJsz}: 9N %=EQY`hlsz}~: =~IJ;< =B8* #'/Y0ն2* 3*? /Y0ֶ2*?@27׶27* اL'd'+f* ڧL'd'+f* ܧL'd'+f* ާL'd'+fYcf&}&&&9b  Ycfgr}    :4gIFIFIFIF;<!8 һY::+, ,-:'::dW*!+[*Y:*Ymdmç :  * Y:*n* *m* ,-W*ç :  :'i03&mz}}}:9n) +-. /$0+2053354?6F7M8[9a:h;m<w=?@BCEIGHJ:f 5 IF FzT5MsG! IJ;<c1!8ZYM'.7'/Y02+32*?@22*37+N*,-9S TUL\Q^Y_:*Z;<Z McQ I8/*?9h: ;<8>*?9 mn:;<,-8>*ȱ9 rs:;<'(8@* 5 * *9w: ;<8L* #* 9| } : ;<8C**9 : ;<8:*+9::<l8/*9:: <B84' 9; Z      \[ =]