Źžŗ¾4µ  #io/moquette/broker/AutoFlushHandler channelIdle+(Lio/netty/channel/ChannelHandlerContext;)V  writerIdleTimeNanosJ  %io/netty/channel/ChannelDuplexHandler()Vjava/lang/NullPointerExceptionunit  (Ljava/lang/String;)V  java/util/concurrent/TimeUnittoNanos(J)J  MIN_TIMEOUT_NANOS "#$ %&java/lang/Mathmax(JJ)J ()* +,&io/netty/channel/ChannelHandlerContextchannel()Lio/netty/channel/Channel; ./0 12io/netty/channel/ChannelisActive()Z .4 52 isRegistered 7 8 initialize : ;destroy = >channelRegistered @ A channelActive C DchannelInactive F GHLOGLorg/slf4j/Logger; JKL M2org/slf4j/LoggerisDebugEnabledO4Initializing autoflush handler on channel {} Cid: {} QRS TUio/moquette/broker/NettyUtilsclientID.(Lio/netty/channel/Channel;)Ljava/lang/String; JW XYdebug9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V [ \]stateI (_ `aexecutor*()Lio/netty/util/concurrent/EventExecutor; cde fgjava/lang/SystemnanoTime()J i j  lastWriteTimel9io/moquette/broker/AutoFlushHandler$WriterIdleTimeoutTask kn oP(Lio/moquette/broker/AutoFlushHandler;Lio/netty/channel/ChannelHandlerContext;)V q rs NANOSECONDSLjava/util/concurrent/TimeUnit; uvw xy&io/netty/util/concurrent/EventExecutorschedule`(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lio/netty/util/concurrent/ScheduledFuture; { |}writerIdleTimeout&Ljava/util/concurrent/ScheduledFuture; € ‚ƒ$java/util/concurrent/ScheduledFuturecancel(Z)Z J… †2isTraceEnabledˆ&Flushing idle Netty channel {} Cid: {} JŠ ‹Ytrace . Ž,flush ‘’ “”org/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger; – —s MILLISECONDS Signature)Ljava/util/concurrent/ScheduledFuture<*>;#(JLjava/util/concurrent/TimeUnit;)VCodeLineNumberTableLocalVariableTablethis%Lio/moquette/broker/AutoFlushHandler;writerIdleTime StackMapTable handlerAddedctx(Lio/netty/channel/ChannelHandlerContext; Exceptions§java/lang/ExceptionhandlerRemovedloop(Lio/netty/util/concurrent/EventExecutor; access$000((Lio/moquette/broker/AutoFlushHandler;)Jx0 access$100x1 SourceFileAutoFlushHandler.java InnerClassesWriterIdleTimeoutTask! GH  @|}˜™@j B\] š›†"*· -Ē »Y·æ*-¶²ø!µ±œ-./1!2 "žŸ"  "s”’¢›g"+¹'¹-™+¹'¹3™*+·6±œ69!>"žŸ"£¤”!„¦Ø›=*·9±œ BCžŸ£¤>›>*+·<±œ KLžŸ£¤„¦A›>*+·?±œ TUžŸ£¤„¦D›F *·9*+·B±œYZ [ žŸ £¤„¦8›äs²E¹I™²EN+¹'+¹'øP¹V*“Z«±*µZ+¹^M*øbµh*,»kY*+·m*“²p¹tµz±œ. ` aba$dDgEjJlQnXorp sžŸs£¤Q"©Ŗ”$;›`*µZ*“zĘ*“z¹~W*µz±œsu vwy žŸ”›z1²E¹„™²E‡+¹'+¹'øP¹‰+¹'¹ŒW±œ‚ ƒ$…0†1žŸ1£¤”$«¬›/*“­œ! ­Ÿ®o›:*+·±œ!­ŸƤ°›/ø³E²• ¶³±œ #$±²³ k“