Edit C:\dspace\webapps\solr\WEB-INF\lib\org\apache\zookeeper\server\NIOServerCnxn.class
???? 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 IsroCommand MonitorCommand WatchCommand ConsCommand StatCommand DumpCommand CnxnStatResetCommand StatResetCommand ConfCommand EnvCommand SetTraceMaskCommand TraceMaskCommand RuokCommand? CommandThread SendBufferWriter LOG Lorg/slf4j/Logger; factory 2Lorg/apache/zookeeper/server/NIOServerCnxnFactory; sock !Ljava/nio/channels/SocketChannel; sk Ljava/nio/channels/SelectionKey; initialized Z lenBuffer Ljava/nio/ByteBuffer; incomingBuffer outgoingBuffers *Ljava/util/concurrent/LinkedBlockingQueue; Signature ALjava/util/concurrent/LinkedBlockingQueue<Ljava/nio/ByteBuffer;>; sessionTimeout I zkServer -Lorg/apache/zookeeper/server/ZooKeeperServer; outstandingRequests sessionId J nextSessionId outstandingLimit ZK_NOT_SERVING Ljava/lang/String; ConstantValue? fourBytes [B <init> ?(Lorg/apache/zookeeper/server/ZooKeeperServer;Ljava/nio/channels/SocketChannel;Ljava/nio/channels/SelectionKey;Lorg/apache/zookeeper/server/NIOServerCnxnFactory;)V Code LineNumberTable LocalVariableTable this +Lorg/apache/zookeeper/server/NIOServerCnxn; zk addr Ljava/net/InetAddress; Exceptions sendCloseSession ()V sendBufferSync (Ljava/nio/ByteBuffer;)V ie Ljava/io/IOException; bb sendBuffer e Ljava/lang/Exception; readPayload rc? isSocketOpen ()Z doIO #(Ljava/nio/channels/SelectionKey;)V isPayload p b i$ Ljava/util/Iterator; left directBuffer sent )Ljava/nio/channels/CancelledKeyException; CloseRequestException >Lorg/apache/zookeeper/server/ServerCnxn$CloseRequestException; EndOfStreamException =Lorg/apache/zookeeper/server/ServerCnxn$EndOfStreamException; k readRequest incrOutstandingRequests -(Lorg/apache/zookeeper/proto/RequestHeader;)V h *Lorg/apache/zookeeper/proto/RequestHeader; disableRecv enableRecv interest readConnectRequest cleanupWriterSocket (Ljava/io/PrintWriter;)V pwriter Ljava/io/PrintWriter; checkFourLetterWord $(Ljava/nio/channels/SelectionKey;I)Z ruok 7Lorg/apache/zookeeper/server/NIOServerCnxn$RuokCommand; tmask <Lorg/apache/zookeeper/server/NIOServerCnxn$TraceMaskCommand; traceMask setMask ?Lorg/apache/zookeeper/server/NIOServerCnxn$SetTraceMaskCommand; env 6Lorg/apache/zookeeper/server/NIOServerCnxn$EnvCommand; ccmd 7Lorg/apache/zookeeper/server/NIOServerCnxn$ConfCommand; strst <Lorg/apache/zookeeper/server/NIOServerCnxn$StatResetCommand; crst @Lorg/apache/zookeeper/server/NIOServerCnxn$CnxnStatResetCommand; dump 7Lorg/apache/zookeeper/server/NIOServerCnxn$DumpCommand; stat 7Lorg/apache/zookeeper/server/NIOServerCnxn$StatCommand; cons 7Lorg/apache/zookeeper/server/NIOServerCnxn$ConsCommand; wcmd 8Lorg/apache/zookeeper/server/NIOServerCnxn$WatchCommand; mntr :Lorg/apache/zookeeper/server/NIOServerCnxn$MonitorCommand; isro 7Lorg/apache/zookeeper/server/NIOServerCnxn$IsroCommand; len cmd readLength #(Ljava/nio/channels/SelectionKey;)Z getOutstandingRequests ()J getSessionTimeout ()I toString ()Ljava/lang/String; close s Ljava/util/Set; LocalVariableTypeTable <Ljava/util/Set<Lorg/apache/zookeeper/server/NIOServerCnxn;>; closeSock sendResponse U(Lorg/apache/zookeeper/proto/ReplyHeader;Lorg/apache/jute/Record;Ljava/lang/String;)V baos Ljava/io/ByteArrayOutputStream; bos %Lorg/apache/jute/BinaryOutputArchive; (Lorg/apache/zookeeper/proto/ReplyHeader; r Lorg/apache/jute/Record; tag process &(Lorg/apache/zookeeper/WatchedEvent;)V event #Lorg/apache/zookeeper/WatchedEvent; )Lorg/apache/zookeeper/proto/WatcherEvent; getSessionId setSessionId (J)V setSessionTimeout (I)V getInterestOps getRemoteSocketAddress ()Ljava/net/InetSocketAddress; serverStats +()Lorg/apache/zookeeper/server/ServerStats; access$000 C(Lorg/apache/zookeeper/server/NIOServerCnxn;Ljava/io/PrintWriter;)V x0 x1 access$100 Z(Lorg/apache/zookeeper/server/NIOServerCnxn;)Lorg/apache/zookeeper/server/ZooKeeperServer; <clinit> SourceFile NIOServerCnxn.java )* ij 6B ?? ! "! (java/util/concurrent/LinkedBlockingQueue #$ /( ? ?? /org/apache/zookeeper/server/ZooKeeperSaslServer 6? ??? ??? ??? ?? ?? ?? java/net/InetSocketAddress ?? ?? org/apache/zookeeper/data/Id ip? ?? 6?? ??? ??? ?! HD ?? ?O ?? ?B java/io/IOException !Error sending data synchronously ? ?? ?? ?? ??? ?? ?O java/lang/StringBuilder $Add a buffer to outgoingBuffers, sk ?? ?? is valid: ?O ?? ?? ?? java/lang/Exception Unexpected Exception: ?? ;org/apache/zookeeper/server/ServerCnxn$EndOfStreamException 7Unable to read additional data from client sessionid 0x ,-? ?? !, likely client has closed socket 6? ?B ?? hB `B ?? NO 0trying to do i/o on a null socket for session:0x ?? ?O ?? KB ?O ?? X! ??? ?O ?? java/nio/ByteBuffer ?? ?? ?? ?? ? <org/apache/zookeeper/server/ServerCnxn$CloseRequestException close requested ? responded to info probe 'java/nio/channels/CancelledKeyException %Exception causing close of session 0x due to O !CancelledKeyException stack trace ? ?B caught end of stream exception ?? IOException stack trace ? +( ? Throttling recv ? ? eB ZooKeeperServer not running 6? B Error closing PrintWriter ? Error closing a command socket java/lang/String Processing command from ? B 'Error cancelling command selection key java/io/PrintWriter java/io/BufferedWriter :org/apache/zookeeper/server/NIOServerCnxn$SendBufferWriter 6 6 ( 5org/apache/zookeeper/server/NIOServerCnxn$RuokCommand 6? B ( :org/apache/zookeeper/server/NIOServerCnxn$TraceMaskCommand ( Read error ? ? =org/apache/zookeeper/server/NIOServerCnxn$SetTraceMaskCommand 6! "( 4org/apache/zookeeper/server/NIOServerCnxn$EnvCommand #( 5org/apache/zookeeper/server/NIOServerCnxn$ConfCommand $( :org/apache/zookeeper/server/NIOServerCnxn$StatResetCommand %( >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 close java/io/ByteArrayOutputStream= >? 45 ?@ header AB Error serializing response ?? CD EF G? H? fB *Unexpected exception. Destruction averted. &org/apache/zookeeper/proto/ReplyHeader 6I Deliver event to 0x through JKL MN notification ?? ?? )org/apache/zookeeper/server/NIOServerCnxnO PQ .- &org/apache/zookeeper/server/ServerCnxn +org/apache/zookeeper/server/NIOServerCnxn$1 7org/apache/zookeeper/server/NIOServerCnxn$CommandThread 9This ZooKeeper instance is not currently serving requests java/lang/InterruptedException allocate (I)Ljava/nio/ByteBuffer; 0org/apache/zookeeper/server/NIOServerCnxnFactory login Lorg/apache/zookeeper/Login; (Lorg/apache/zookeeper/Login;)V zooKeeperSaslServer 1Lorg/apache/zookeeper/server/ZooKeeperSaslServer; +org/apache/zookeeper/server/ZooKeeperServer getGlobalOutstandingLimit java/nio/channels/SocketChannel socket ()Ljava/net/Socket; java/net/Socket setTcpNoDelay (Z)V setSoLinger (ZI)V ()Ljava/net/SocketAddress; getAddress ()Ljava/net/InetAddress; authInfo Ljava/util/ArrayList; java/net/InetAddress getHostAddress '(Ljava/lang/String;Ljava/lang/String;)V java/util/ArrayList add (Ljava/lang/Object;)Z java/nio/channels/SelectionKey interestOps #(I)Ljava/nio/channels/SelectionKey; -org/apache/zookeeper/server/ServerCnxnFactory closeConn configureBlocking ((Z)Ljava/nio/channels/SelectableChannel; isOpen write (Ljava/nio/ByteBuffer;)I packetSent org/slf4j/Logger error *(Ljava/lang/String;Ljava/lang/Throwable;)V remaining selector ()Ljava/nio/channels/Selector; java/nio/channels/Selector wakeup isTraceEnabled append -(Ljava/lang/String;)Ljava/lang/StringBuilder; -(Ljava/lang/Object;)Ljava/lang/StringBuilder; isValid (Z)Ljava/lang/StringBuilder; trace (Ljava/lang/String;)V read java/lang/Long toHexString (J)Ljava/lang/String; packetReceived flip ()Ljava/nio/Buffer; clear warn isReadable isWritable size iterator ()Ljava/util/Iterator; java/util/Iterator hasNext next ()Ljava/lang/Object; slice ()Ljava/nio/ByteBuffer; limit (I)Ljava/nio/Buffer; position put ,(Ljava/nio/ByteBuffer;)Ljava/nio/ByteBuffer; peek remove isDebugEnabled debug processPacket @(Lorg/apache/zookeeper/server/ServerCnxn;Ljava/nio/ByteBuffer;)V (org/apache/zookeeper/proto/RequestHeader getXid getInProcess (I)Ljava/lang/StringBuilder; processConnectRequest flush info cmd2String Ljava/util/HashMap; java/lang/Integer valueOf (I)Ljava/lang/Integer; java/util/HashMap get &(Ljava/lang/Object;)Ljava/lang/Object; cancel [(Lorg/apache/zookeeper/server/NIOServerCnxn;Lorg/apache/zookeeper/server/NIOServerCnxn$1;)V (Ljava/io/Writer;)V ruokCmd start getTraceMaskCmd setTraceMaskCmd getLong $org/apache/zookeeper/server/ZooTrace setTextTraceLevel D(Lorg/apache/zookeeper/server/NIOServerCnxn;Ljava/io/PrintWriter;J)V enviCmd confCmd srstCmd crstCmd dumpCmd statCmd srvrCmd D(Lorg/apache/zookeeper/server/NIOServerCnxn;Ljava/io/PrintWriter;I)V consCmd wchpCmd wchcCmd wchsCmd mntrCmd isroCmd getInt "org/apache/jute/BinaryInputArchive maxBuffer cnxns Ljava/util/HashSet; java/util/HashSet ipMap getInetAddress unregisterConnection +(Lorg/apache/zookeeper/server/ServerCnxn;)V removeCnxn shutdownOutput 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 ()[B wrap ([B)Ljava/nio/ByteBuffer; putInt rewind (IJI)V logTraceMessage ((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; ! ? ! "! #$ % & '( )* +( ,- .- /( 01 2 3 45 67 8 @ ?*? *? ? **? ? *? Y? ? *? *+? *,? *-? *? *? ? ? *? Y? ? ? +? *+? ? ,? ? ,? ? ,? ? ? ? :*? ? Y? ? ? W-? W? 9 N ^ E G I [ $ _ ) ` . a 3 b 9 c C d S f W g _ i g l p m o ? p ? q: > ?;< ?=* ? ? ? >? @ & AB 8 6 *? ? !? 9 w x: ;< CD 8 ? 7*? ? "W+? ? *? ? #? *? +? $W*? %? M? '(,? ) ? ' * & 9 & ? ? ? ? # ? ' ? * ? + ? 6 ?: + EF 7;< 7G! HD 8 p ?+? ? (*? ? *~? *? +? $W? M+? +? *? %?*? YM?*? ? ,? -W? '? . ? 0? '? /Y? 01? 2*? ? 34? 2*? ? 5? 6? 7? 8 *? +? 9W*? ? 5? *? *? ? *?? W,ç N,?-?? M? ';,? ) ? & 3 ? ? ? ? ? + ? : , ? ? : 9 R ? ? ? ? ? ? ' ? + ? , ? 3 ? > ? I ? v ? ? ? ? ? ? ? ? ? ? ? ? ? ?: * IF ? IJ ?;< ?G! KB 8 ? y*? ? +? 9*? *? ? <<? )? =Y? /Y? 0>? 2*? ?? @? 2A? 2? 7? B?*? ? +? 1*? C*? ? DW*? E? *? F? *? G*? ? HW**? ? ? 9 6 ? ? ? ? @ ? J ? N ? V ? ] ? d ? h ? p ? x ?: *L( y;< @ &M NO 8 2 *? ? #? 9 ?: ;< PQ 8 ? ?*? I? %? '? /Y? 0J? 2*? ?? @? 2? 7? K ?+? L? u*? *? ? <= ? )? =Y? /Y? 0>? 2*? ?? @? 2A? 2? 7? B?*? ? +? 5*? *? ? *? ? DW*+? M>*? ? HW? > ? *? N? ?+? O?A*? ? P? ?*? ? QM,? HW*? ? RN-? S ? N-? T ? U:,? +? +? ? V,? +? W? U:? X6,? YW? ZW,? +? ? ???,? DW*? ,? $>*? ? P? V*? ? [? U:? ? ? \Y]? ^?? + d6? ? X `? ZW? *? % ? +d>*? ? _W???*? YM?*? ? P? 5*? E? *? ? *~? ? \Y`? ^?*? *? ? *?~? W? *? *? ? *?? W,ç :,??? ?M? '? /Y? 0b? 2*? ?? @? 2c? 2,? 3? 7? K ? '? d ? ? 'e,? f *? g? cM*? g? [M? 'h,? i *? g? HM? '? /Y? 0b? 2*? ?? @? 2c? 2,? 3? 7? K ? '? d ? ? 'j,? f *? g? ??? ??? (? a ) ?? a ??? a (2 \ ) ?2 \ ??2 \ (: = ) ?: = ??: = (M & ) ?M & ??M & 9 F ? ? ( ? ) ? 0 ? < ? @ ? f ? p ? { ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?" #$%&( -!/*344@5H6R8[9`>m?pAtC|D?E?K?L?M?O?Q?T?W?q?Y?Z] ^+`/q2a3c7q:d;eFhJqMiNjxm?n?p?r: ? ? R ? R < fL( S( ? =T! ? TUV [ )W( ? ?X! * ]Y( @ GG! ? DIZ 3 I\ ; I^ N DIF ?;< ?_ @ M `B 8 ; *? **? ? k? 9 u v: ;< @ & ab 8 ? q+? l? l*YM?*Y? m`? m,ç N,?-?*? YM?*? ? n*? ? 3? '? d ? $? '? /Y? 0o? 2*? ? n? p? 7? q *? r,ç :,??? & f i i m i 9 . y z { | } & 4? ?? `? d? p?: q;< qcd eB 8 A *? *? ? *?~? W? 9 ? ?: ;< fB 8 ? @*? YL?*? ? ,? -W*? ? 5? *? ? *= ~? *? ?? W+ç N+?-?? 7 : : = : 9 " ? ? ? ? $? *? 5? ??: $ g( @;< hB 8 ] #*? ? ? &Ys? t?*? **? ? u*? E? 9 ? ? ? ? "?: #;< @ &M ij 8 ? D+? +? v+? w? ? 4M? 'x,? y ? ? "N? -?:*? g? :? 'z? ) ?? : $ ! $ $ ( $ , 0 3 : 9 B ? ? ? ? ? ? ? ? !? $? ,? 0? 3? 5? A? C?: * IJ 5 IJ D;< Dkl mn 8 $ ? { ? |? }? ~N-? ?? '? /Y? 0? 2-? 2?? 2*? ? ? ? 3? 7? ? *? C+? +? ?? :? '?? ) ? ?Y? ?Y? ?Y*? ?? ?? ?: ? ?? ? ?Y*? ?:? ?? ? ?? ? ?Y*? ?:? ?? ? ?? J*? *? ? <6? ? &Y?? t?*? ? DW*? ? ?7? ?? ?Y*? ?:? ?? ? ?? ? ?Y*? ?:? ?? ? ?? ? ?Y*? ?:? ?? ? ?? ? ?Y*? ?:? ?? ? ?? ? ?Y*? ?:? ?? ? ?? ? ?Y*? ?:? ?? ? ?? ? ?? ? ?Y* ? ?:? ?? ? ?? ? ?Y*? ?:? ?? ? ?? ? ?? ? ?? ? ?Y* ? ?:? ?? ? ?? ? ?Y*? ?:? ?? ? ?? ? ?Y*? ?:? ??? I M P : 9 F 7 8 9 ; A= EH IJ MM PK RL ^P wR ~S ?T ?U ?V ?W ?X ?Y ?Z ?[ ?\ ?] ?` ?a ?b ?c ?d ?e ?f g hijk&l+m-n4o@pEqGrNsZt_uavhwtxyy{z?{?|?}?~???????????????????????? ???: ? R IJ ? op ? qr ? :L( ? s- ? tu vw & xy @ z{ Z |} t ~ ? ?? ? ?? ? ?? ? ?? ?? ;< _ ?( ?1 w?kl @ & ?? 8 ? ^*? ? ?=*? E? **? ? ? ? ? ? ? ? &Y? /Y? 0? 2 ? p? 7? t?*? ? ? &Ys? t?* ? ? ? 9 & ? ? ? ? (? C? J? T? \?: ^;< ^_ V?( @ & ?? 8 { !*YL?*? YM?*? m?,?+íN,?-?:+?? 9 ? ? ? ? ?: !;< ?? 8 / *? ? 9 ?: ;< ?? 8 M #? /Y? 0? 2*? ? 3? 2*? ? 3? 7? 9 ?: #;< ?B 8 i ?*? ? ?YL?*? ? ?*? ? +ñ*? ? ?YM?*? ? ?*? ? ? ? }? ?N-*? ? W,ç :,??*? *? ?*? ? *? *? ?*? ?*? ? $*? ? ?? M? '? d ? ? '?,? f +ç :+??? % G J J N J s z } : ? ? ? ? ? ? 9 N ? ? ? ? %? =? E? Q? Y? `? h? l? s? z? }? ~? ?? ?? ??: = ?? ~ IJ ?;< ? = ?? ?B 8 ? ?*? ? #? ?? '? /Y? 0? 2*? ? ? ? 3*? ? ?? ? /Y? 0? 2*? ?? @? 2? 7? ? 2? 7? ? *? ? ? ? L? '? d ? ? '?+? f *? ? ? ? L? '? d ? ? '?+? f *? ? ? ? L? '? d ? ? '?+? f *? ? ? L? '? d ? ? '?+? f ? Y c f & } ? ? & ? ? ? & ? ? ? & 9 b ? ? ? Y? c f? g? r? } ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? : 4 g IF ? IF ? IF ? IF ?;< !?? 8 ? ? ?Y? ?:? ?:? ? ?+? ?,? ,-? ?? ? :? '? ? ? ?:? ?:?d? ? ?W*? !+? ? [*Y:?*Y? md? mç : ? ?*? Y:?*? ? n*? ? *? m? *? ? ,? -W*? ?ç : ? ?? :? '?? i ? 0 3 & m z } } ? } ? ? ? ? ? ? ? ? : 9 n ) + - . / $0 +2 05 33 54 ?6 F7 M8 [9 a: h; m< w= ?? ?@ ?B ?C ?E ?I ?G ?H ?J: f 5 IF ??? ??? F zT5 M sG! ? IJ ?;< ?c? ??? ??1 !?? 8 ? Z? ?Y ?? ?M? '? . ? 7? ' ?? /Y? 0?? 2+? 3? 2*? ?? @? 2? 2*? 3? 7? ?+? ?N*,-? ? 9 S T U L\ Q^ Y_: * Z;< Z?? Mc? Q I? ?? 8 / *? ?? 9 h: ;< ?? 8 > * ? ?? 9 m n: ;< ,- ?? 8 > *? ? 9 r s: ;< '( ?? 8 @ *? ? 5? *? ? *? ? 9 w: ;< ?? 8 L *? ? #? ?*? ? ? ? ? 9 | } : ;< ?? 8 C *? ? ?*? ? ?? 9 ? ? ?: ;< ?? 8 : *+? ? 9 :: ?< ?l ?? 8 / *? ? 9 :: ?< ?B 8 4 ?? ? ' ??? ? 9 ; Z ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? \[ =]
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de