Êþº¾ 4 ® ,chat/server/moquette/MqttBytesMetricsHandler %io/netty/channel/ChannelDuplexHandler logger Lorg/apache/log4j/Logger; ATTR_KEY_METRICS Lio/netty/util/AttributeKey; Signature <Lio/netty/util/AttributeKey<Lchat/server/moquette/Metrics;>; ATTR_KEY_USERNAME 0Lio/netty/util/AttributeKey<Ljava/lang/String;>; collector ,Lchat/server/moquette/BytesMetricsCollector; <clinit> ()V Code
|
org/apache/log4j/Logger getLogger ,(Ljava/lang/Class;)Lorg/apache/log4j/Logger; BytesMetrics
|
io/netty/util/AttributeKey ! valueOf 0(Ljava/lang/String;)Lio/netty/util/AttributeKey; # % username ' LineNumberTable LocalVariableTable <init> /(Lchat/server/moquette/BytesMetricsCollector;)V
|
- * / this .Lchat/server/moquette/MqttBytesMetricsHandler; channelActive +(Lio/netty/channel/ChannelHandlerContext;)V
|
Exceptions 6 java/lang/Exception 8 : 9 &io/netty/channel/ChannelHandlerContext ; < channel ()Lio/netty/channel/Channel; > @ ? io/netty/channel/Channel A B attr 7(Lio/netty/util/AttributeKey;)Lio/netty/util/Attribute; D chat/server/moquette/Metrics
|
C - G I H io/netty/util/Attribute J K set (Ljava/lang/Object;)V
|
M 2 3 ctx (Lio/netty/channel/ChannelHandlerContext; Lio/netty/util/Attribute; LocalVariableTypeTable 9Lio/netty/util/Attribute<Lchat/server/moquette/Metrics;>; channelRead =(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)V G V W X get ()Ljava/lang/Object; Z io/netty/buffer/ByteBuf
|
Y \ ] ^ readableBytes ()I
|
C ` a b incrementRead (J)V 8 d e f fireChannelRead <(Ljava/lang/Object;)Lio/netty/channel/ChannelHandlerContext; msg Ljava/lang/Object; metrics Lchat/server/moquette/Metrics; write ^(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)V
|
Y n o ^ writableBytes
|
C q r b incrementWrote 8 t k u U(Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture; promise !Lio/netty/channel/ChannelPromise; close L(Lio/netty/channel/ChannelHandlerContext;Lio/netty/channel/ChannelPromise;)V { java/lang/String } java/lang/StringBuilder channel<
|
~ * (Ljava/lang/String;)V
|
~ append -(Ljava/lang/String;)Ljava/lang/StringBuilder; > closing after
|
~ -(Ljava/lang/Object;)Ljava/lang/StringBuilder;
|
~ toString ()Ljava/lang/String;
|
K info
|
C
|
readLength ()J
|
*chat/server/moquette/BytesMetricsCollector b sumReadBytes
|
C wroteLength
|
¢ £ b sumWroteBytes
|
¥ x y userId Ljava/lang/String; StackMapTable getBytesMetrics :(Lio/netty/channel/Channel;)Lchat/server/moquette/Metrics; Lio/netty/channel/Channel;
|
SourceFile MqttBytesMetricsHandler.java !
|
|
|
|
E ¸ ³ ¸ ³ "$¸ ³ &± ( ) * + F
|
*· ,*+µ .± ( )
|
0 1
|
2 3 4 5 ~ "+¹ 7 ² "¹ = M,» CY· E¹ F *+· L± ( ! " $ ! % ) " 0 1 " N O A P Q A R S T 4 5 ,+¹ 7 ² "¹ = ¹ U À CN-,À Y¶ [
¶ _+,¹ c W± ( ) * # + + , ) * , 0 1 , N O , g h i j k l 4 5 /+¹ 7 ² "¹ = ¹ U À C:,À Y¶ m
¶ p+,-¹ s W± ( 0 1 % 2 . 3 ) 4 / 0 1 / N O / g h / v w i j x y 4 5 ø u+¹ 7 ² "¹ = ¹ U À CN+¹ 7 ² &¹ = ¹ U À z:Ç |:² » ~Y· ¶
¶
-¶ ¶ ¶ *´ .-¶ ¶ *´ .-¶ ¶ ¡*+,· ¤± ( & 7 8 / 9 4 : 8 = X ? c @ n B t C ) 4 u 0 1 u N O u v w ^ i j / F ¦ § ¨ ý 8 C z © ª < *² "¹ = ¹ U À C° ( F ) ; « ¬
|
