public class io.netty.handler.traffic.GlobalChannelTrafficCounter extends io.netty.handler.traffic.TrafficCounter
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.netty.handler.traffic.GlobalChannelTrafficCounter
super_class: io.netty.handler.traffic.TrafficCounter
{
public void <init>(io.netty.handler.traffic.GlobalChannelTrafficShapingHandler, java.util.concurrent.ScheduledExecutorService, java.lang.String, long);
descriptor: (Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;Ljava/util/concurrent/ScheduledExecutorService;Ljava/lang/String;J)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
aload 3
lload 4
invokespecial io.netty.handler.traffic.TrafficCounter.<init>:(Lio/netty/handler/traffic/AbstractTrafficShapingHandler;Ljava/util/concurrent/ScheduledExecutorService;Ljava/lang/String;J)V
1: aload 2
ifnonnull 3
2: new java.lang.IllegalArgumentException
dup
ldc "Executor must not be null"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficCounter io.netty.handler.traffic.GlobalChannelTrafficShapingHandler java.util.concurrent.ScheduledExecutorService java.lang.String long
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/netty/handler/traffic/GlobalChannelTrafficCounter;
0 4 1 trafficShapingHandler Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
0 4 2 executor Ljava/util/concurrent/ScheduledExecutorService;
0 4 3 name Ljava/lang/String;
0 4 4 checkInterval J
MethodParameters:
Name Flags
trafficShapingHandler
executor
name
checkInterval
public synchronized void start();
descriptor: ()V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=6, locals=3, args_size=1
start local 0 0: aload 0
getfield io.netty.handler.traffic.GlobalChannelTrafficCounter.monitorActive:Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
getfield io.netty.handler.traffic.GlobalChannelTrafficCounter.lastTime:Ljava/util/concurrent/atomic/AtomicLong;
invokestatic io.netty.handler.traffic.GlobalChannelTrafficCounter.milliSecondFromNano:()J
invokevirtual java.util.concurrent.atomic.AtomicLong.set:(J)V
3: aload 0
getfield io.netty.handler.traffic.GlobalChannelTrafficCounter.checkInterval:Ljava/util/concurrent/atomic/AtomicLong;
invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
lstore 1
start local 1 4: lload 1
lconst_0
lcmp
ifle 10
5: aload 0
iconst_1
putfield io.netty.handler.traffic.GlobalChannelTrafficCounter.monitorActive:Z
6: aload 0
new io.netty.handler.traffic.GlobalChannelTrafficCounter$MixedTrafficMonitoringTask
dup
aload 0
getfield io.netty.handler.traffic.GlobalChannelTrafficCounter.trafficShapingHandler:Lio/netty/handler/traffic/AbstractTrafficShapingHandler;
checkcast io.netty.handler.traffic.GlobalChannelTrafficShapingHandler
aload 0
invokespecial io.netty.handler.traffic.GlobalChannelTrafficCounter$MixedTrafficMonitoringTask.<init>:(Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;Lio/netty/handler/traffic/TrafficCounter;)V
putfield io.netty.handler.traffic.GlobalChannelTrafficCounter.monitor:Ljava/lang/Runnable;
7: aload 0
8: aload 0
getfield io.netty.handler.traffic.GlobalChannelTrafficCounter.executor:Ljava/util/concurrent/ScheduledExecutorService;
aload 0
getfield io.netty.handler.traffic.GlobalChannelTrafficCounter.monitor:Ljava/lang/Runnable;
lload 1
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokeinterface java.util.concurrent.ScheduledExecutorService.schedule:(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
9: putfield io.netty.handler.traffic.GlobalChannelTrafficCounter.scheduledFuture:Ljava/util/concurrent/ScheduledFuture;
10: StackMap locals: long
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lio/netty/handler/traffic/GlobalChannelTrafficCounter;
4 11 1 localCheckInterval J
public synchronized void stop();
descriptor: ()V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield io.netty.handler.traffic.GlobalChannelTrafficCounter.monitorActive:Z
ifne 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
iconst_0
putfield io.netty.handler.traffic.GlobalChannelTrafficCounter.monitorActive:Z
3: aload 0
invokestatic io.netty.handler.traffic.GlobalChannelTrafficCounter.milliSecondFromNano:()J
invokevirtual io.netty.handler.traffic.GlobalChannelTrafficCounter.resetAccounting:(J)V
4: aload 0
getfield io.netty.handler.traffic.GlobalChannelTrafficCounter.trafficShapingHandler:Lio/netty/handler/traffic/AbstractTrafficShapingHandler;
aload 0
invokevirtual io.netty.handler.traffic.AbstractTrafficShapingHandler.doAccounting:(Lio/netty/handler/traffic/TrafficCounter;)V
5: aload 0
getfield io.netty.handler.traffic.GlobalChannelTrafficCounter.scheduledFuture:Ljava/util/concurrent/ScheduledFuture;
ifnull 7
6: aload 0
getfield io.netty.handler.traffic.GlobalChannelTrafficCounter.scheduledFuture:Ljava/util/concurrent/ScheduledFuture;
iconst_1
invokeinterface java.util.concurrent.ScheduledFuture.cancel:(Z)Z
pop
7: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/netty/handler/traffic/GlobalChannelTrafficCounter;
public void resetCumulativeTime();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=3, args_size=1
start local 0 0: aload 0
getfield io.netty.handler.traffic.GlobalChannelTrafficCounter.trafficShapingHandler:Lio/netty/handler/traffic/AbstractTrafficShapingHandler;
checkcast io.netty.handler.traffic.GlobalChannelTrafficShapingHandler
getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.channelQueues:Ljava/util/concurrent/ConcurrentMap;
invokeinterface java.util.concurrent.ConcurrentMap.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 2
goto 3
StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficCounter top java.util.Iterator
StackMap stack:
1: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel
astore 1
start local 1 2: aload 1
getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.channelTrafficCounter:Lio/netty/handler/traffic/TrafficCounter;
invokevirtual io.netty.handler.traffic.TrafficCounter.resetCumulativeTime:()V
end local 1 3: StackMap locals:
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
4: aload 0
invokespecial io.netty.handler.traffic.TrafficCounter.resetCumulativeTime:()V
5: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/netty/handler/traffic/GlobalChannelTrafficCounter;
2 3 1 perChannel Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$PerChannel;
}
SourceFile: "GlobalChannelTrafficCounter.java"
NestMembers:
io.netty.handler.traffic.GlobalChannelTrafficCounter$MixedTrafficMonitoringTask
InnerClasses:
private MixedTrafficMonitoringTask = io.netty.handler.traffic.GlobalChannelTrafficCounter$MixedTrafficMonitoringTask of io.netty.handler.traffic.GlobalChannelTrafficCounter
final PerChannel = io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel of io.netty.handler.traffic.GlobalChannelTrafficShapingHandler