Edit C:\Users\Administrator\Desktop\Back\galaxie - Copy\cti\C3T\fr\c3t\net\AbstractConnectionHandler.class
Êþº¾ 2? o ð ñ ð d ò d ó d ô d õ d ö ÷ ø ù ð ú û ü ý þ ÿ ú N ý N ý d d d ú d ! d d ÷ ! ! d d d ! d" d#$%&' 6( ÷) d* ÷ d+ d, d- ÷./ .(0102 ÷- d3 U4 567890:;<;=>? I@ABC PDEF UG dH UI dJ dK dL dMN úO dP dQR STU VW f ðXY hZ7[\]^_` logger Lorg/apache/log4j/Logger; transport Lfr/c3t/net/Transport; serverSide Z connectionHandlerListeners Ljava/util/Set; Signature 7Ljava/util/Set<Lfr/c3t/net/ConnectionHandlerListener;>; HANDSHAKE_NONE I ConstantValue HANDSHAKE_REQUEST HANDSHAKE_ACK handshakeType handshakeTimeout NO_ACTIVITY_TIMEOUT ' noActivityTimeout noActivityDuration Lfr/c3t/util/Duration; eventMethodMap Ljava/util/Map; >Ljava/util/Map<Ljava/lang/Integer;Ljava/lang/reflect/Method;>; <init> ()V Code LineNumberTable LocalVariableTable this &Lfr/c3t/net/AbstractConnectionHandler; toString ()Ljava/lang/String; socket Ljava/net/Socket; StackMapTable run e Ljava/net/SocketException; Ljava/io/InterruptedIOException; Ljava/io/IOException; Ljava/lang/Exception; data Ljava/lang/Object; U ?$ initialize Exceptions dispose setTransport (Lfr/c3t/net/Transport;Z)V getTransport ()Lfr/c3t/net/Transport; send (Ljava/lang/Object;)V encodedDataa addListener )(Lfr/c3t/net/ConnectionHandlerListener;)V listener &Lfr/c3t/net/ConnectionHandlerListener; removeListener disconnect isConnected ()Zb fireConnectionHandlerEvent &(Lfr/c3t/net/ConnectionHandlerEvent;)V -Ljava/lang/reflect/InvocationTargetException; i$ Ljava/util/Iterator; event #Lfr/c3t/net/ConnectionHandlerEvent; method Ljava/lang/reflect/Method;9cF>A fireConnectionHandlerCreated (I)V cause fireConnectionHandlerClosed !fireConnectionHandlerDataReceived handshake handshakeRequest handshakeAck oldSoTimeout result decode &(Ljava/lang/Object;)Ljava/lang/Object; encode getHandshakeType ()I getHandshakeRequest ()Ljava/lang/Object; checkHandshakeAck (Ljava/lang/Object;)Z getHandshakeTimeout setHandshakeTimeout getNoActivityTimeout setNoActivityTimeout manageNoActivity <clinit> !Ljava/lang/NoSuchMethodException; clazz Ljava/lang/Class; types [Ljava/lang/Class; LocalVariableTypeTable 9Ljava/lang/Class<Lfr/c3t/net/ConnectionHandlerListener;>;X è^ SourceFile AbstractConnectionHandler.java ? ? fr/c3t/util/FastHashSet w x ? | ? | ? | s tbde java/lang/StringBuilderfghi ? ?jk :l Ùjm /n Ù Ð » Ë Ì à Ùopqr Ì java/net/SocketException q r #cannot change so timeout on socket js ?!tuv fr/c3t/util/Duration ?w ? ?x »y Ûz{ java/io/InterruptedIOException| » â ? connection with client lost ( ) ?! « ? Î Ì java/io/IOException cannot read socket end of stream reached on socket } ± Õ Ö Ï ± java/lang/Exception cannot decode data java/lang/IllegalStateException <setTransport() must be called before calling initialize() ?! ?~ © ? ? u v × Ö º »? ± #connection handler is not connected?? Ý? Ý ? ?? Ù????? Ö java/lang/reflect/Method??c? »? Û $fr/c3t/net/ConnectionHandlerListener java/lang/Object?? +java/lang/reflect/InvocationTargetException listener generates exception ?!?? cannot call listener !fr/c3t/net/ConnectionHandlerEvent ?? ½ ¾ ?? Ø Ù Ñ » Ò » Ú Û *cannot write hand shake request on socket ? Ù Þ Ù Ü Ý handshake timeout expired ?!u ± %cannot check handshake ack on socket $fr/c3t/net/AbstractConnectionHandler?? java/util/HashMap java/lang/Class connectionHandlerCreated???? connectionHandlerClosed connectionHandlerDataReceived java/lang/NoSuchMethodException &fr/c3t/lang/AbstractCancelableRunnable fr/c3t/net/ConnectionHandler java/lang/Throwable fr/c3t/net/Transport java/util/Iterator getSocket ()Ljava/net/Socket; java/net/Socket getInetAddress ()Ljava/net/InetAddress; java/net/InetAddress append -(Ljava/lang/String;)Ljava/lang/StringBuilder; getPort (I)Ljava/lang/StringBuilder; hashCode java/lang/Math min (II)I setSoTimeout -(Ljava/lang/Object;)Ljava/lang/StringBuilder; org/apache/log4j/Logger error *(Ljava/lang/Object;Ljava/lang/Throwable;)V (J)V isAlive read reset ()J isElapsed warn (Ljava/lang/String;)V cancel write java/util/Set add remove getId java/lang/Integer valueOf (I)Ljava/lang/Integer; java/util/Map get iterator ()Ljava/util/Iterator; hasNext next invoke 9(Ljava/lang/Object;[Ljava/lang/Object;)Ljava/lang/Object; getTargetException ()Ljava/lang/Throwable; #(Lfr/c3t/net/ConnectionHandler;II)V 5(Lfr/c3t/net/ConnectionHandler;IILjava/lang/Object;)V getSoTimeout getLogger ,(Ljava/lang/Class;)Lorg/apache/log4j/Logger; getMethod @(Ljava/lang/String;[Ljava/lang/Class;)Ljava/lang/reflect/Method; put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;! d o p q r s t u v w x y z { | } ~ | } ? ? | } ? ? | ? | ? | } ? ? | ? ? ? ? y ? ? ? ? a #*· *» Y· µ *µ *'µ *'µ ± ? ? G \ _ e "