1W 7 89 : ; < = > ? @ AB C D E FG HIJ dropCountI burstSizecurrentBurstCount msgTimeoutisLIFOZmsgQueueLphex/utils/CircularQueue;(IIIZ)VCodeLineNumberTableLocalVariableTablethis"Lphex/connection/FlowControlQueue;maxSize addMessage(Lphex/msg/Message;)VmessageLphex/msg/Message;dropObjLjava/lang/Object; removeMessage()Lphex/msg/Message;expiredCreationTimeJinitNewMessageBurst()VgetAndResetDropCount()I tmpDropCountremoveNextMessage SourceFileFlowControlQueue.java 0 phex/utils/CircularQueue K     LM N OP 4, QP RS TUphex/msg/Message VU phex/connection/FlowControlQueuejava/lang/Object(I)V addToTail&(Ljava/lang/Object;)Ljava/lang/Object;java/lang/SystemcurrentTimeMillis()JgetCreationTimeisEmpty()ZremoveFromTail()Ljava/lang/Object;removeFromHead!&***Y*** BC DEFG%H!4&"#&&&$&%&b*+ M, *Y` L M QS! "#'( )*+,D* * *e@* N-- *Y`*Y ` - . W Y \_` c"f+k5l8pBq! ('(D"#--./04*  wx! "#12H *<* |} ~! "#34,c)****  ! )"#56