http://netty.io/netty-all/: Netty is an asynchronous event-driven network application framework for rapid development of maintainable high performance protocol servers and clients. (The Netty Project) 
public class io.netty.handler.traffic.GlobalChannelTrafficShapingHandler extends io.netty.handler.traffic.AbstractTrafficShapingHandler
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler
  super_class: io.netty.handler.traffic.AbstractTrafficShapingHandler
{
  private static final io.netty.util.internal.logging.InternalLogger logger;
    descriptor: Lio/netty/util/internal/logging/InternalLogger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  final java.util.concurrent.ConcurrentMap<java.lang.Integer, io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel> channelQueues;
    descriptor: Ljava/util/concurrent/ConcurrentMap;
    flags: (0x0010) ACC_FINAL
    Signature: Ljava/util/concurrent/ConcurrentMap<Ljava/lang/Integer;Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$PerChannel;>;

  private final java.util.concurrent.atomic.AtomicLong queuesSize;
    descriptor: Ljava/util/concurrent/atomic/AtomicLong;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.concurrent.atomic.AtomicLong cumulativeWrittenBytes;
    descriptor: Ljava/util/concurrent/atomic/AtomicLong;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.concurrent.atomic.AtomicLong cumulativeReadBytes;
    descriptor: Ljava/util/concurrent/atomic/AtomicLong;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  volatile long maxGlobalWriteSize;
    descriptor: J
    flags: (0x0040) ACC_VOLATILE

  private volatile long writeChannelLimit;
    descriptor: J
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private volatile long readChannelLimit;
    descriptor: J
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private static final float DEFAULT_DEVIATION;
    descriptor: F
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 0.1

  private static final float MAX_DEVIATION;
    descriptor: F
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 0.4

  private static final float DEFAULT_SLOWDOWN;
    descriptor: F
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 0.4

  private static final float DEFAULT_ACCELERATION;
    descriptor: F
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: -0.1

  private volatile float maxDeviation;
    descriptor: F
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private volatile float accelerationFactor;
    descriptor: F
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private volatile float slowDownFactor;
    descriptor: F
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private volatile boolean readDeviationActive;
    descriptor: Z
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private volatile boolean writeDeviationActive;
    descriptor: Z
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 89
            ldc Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            invokestatic io.netty.util.internal.logging.InternalLoggerFactory.getInstance:(Ljava/lang/Class;)Lio/netty/util/internal/logging/InternalLogger;
         1: .line 88
            putstatic io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.logger:Lio/netty/util/internal/logging/InternalLogger;
         2: .line 129
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  void createGlobalTrafficCounter(java.util.concurrent.ScheduledExecutorService);
    descriptor: (Ljava/util/concurrent/ScheduledExecutorService;)V
    flags: (0x0000) 
    Code:
      stack=7, locals=3, args_size=2
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
        start local 1 // java.util.concurrent.ScheduledExecutorService executor
         0: .line 149
            aload 0 /* this */
            ldc 0.1
            ldc 0.4
            ldc -0.1
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.setMaxDeviation:(FFF)V
         1: .line 150
            aload 1 /* executor */
            ifnonnull 3
         2: .line 151
            new java.lang.IllegalArgumentException
            dup
            ldc "Executor must not be null"
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
         3: .line 153
      StackMap locals:
      StackMap stack:
            new io.netty.handler.traffic.GlobalChannelTrafficCounter
            dup
            aload 0 /* this */
            aload 1 /* executor */
            ldc "GlobalChannelTC"
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.checkInterval:J
            invokespecial io.netty.handler.traffic.GlobalChannelTrafficCounter.<init>:(Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;Ljava/util/concurrent/ScheduledExecutorService;Ljava/lang/String;J)V
            astore 2 /* tc */
        start local 2 // io.netty.handler.traffic.TrafficCounter tc
         4: .line 154
            aload 0 /* this */
            aload 2 /* tc */
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.setTrafficCounter:(Lio/netty/handler/traffic/TrafficCounter;)V
         5: .line 155
            aload 2 /* tc */
            invokevirtual io.netty.handler.traffic.TrafficCounter.start:()V
         6: .line 156
            return
        end local 2 // io.netty.handler.traffic.TrafficCounter tc
        end local 1 // java.util.concurrent.ScheduledExecutorService executor
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    7     0      this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            0    7     1  executor  Ljava/util/concurrent/ScheduledExecutorService;
            4    7     2        tc  Lio/netty/handler/traffic/TrafficCounter;
    MethodParameters:
          Name  Flags
      executor  

  protected int userDefinedWritabilityIndex();
    descriptor: ()I
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
         0: .line 160
            iconst_3
            ireturn
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;

  public void <init>(java.util.concurrent.ScheduledExecutorService, long, long, long, long, long, long);
    descriptor: (Ljava/util/concurrent/ScheduledExecutorService;JJJJJJ)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=9, locals=14, args_size=8
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
        start local 1 // java.util.concurrent.ScheduledExecutorService executor
        start local 2 // long writeGlobalLimit
        start local 4 // long readGlobalLimit
        start local 6 // long writeChannelLimit
        start local 8 // long readChannelLimit
        start local 10 // long checkInterval
        start local 12 // long maxTime
         0: .line 186
            aload 0 /* this */
            lload 2 /* writeGlobalLimit */
            lload 4 /* readGlobalLimit */
            lload 10 /* checkInterval */
            lload 12 /* maxTime */
            invokespecial io.netty.handler.traffic.AbstractTrafficShapingHandler.<init>:(JJJJ)V
         1: .line 93
            aload 0 /* this */
            invokestatic io.netty.util.internal.PlatformDependent.newConcurrentHashMap:()Ljava/util/concurrent/ConcurrentMap;
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.channelQueues:Ljava/util/concurrent/ConcurrentMap;
         2: .line 98
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicLong
            dup
            invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.queuesSize:Ljava/util/concurrent/atomic/AtomicLong;
         3: .line 103
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicLong
            dup
            invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.cumulativeWrittenBytes:Ljava/util/concurrent/atomic/AtomicLong;
         4: .line 108
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicLong
            dup
            invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.cumulativeReadBytes:Ljava/util/concurrent/atomic/AtomicLong;
         5: .line 114
            aload 0 /* this */
            ldc 419430400
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.maxGlobalWriteSize:J
         6: .line 187
            aload 0 /* this */
            aload 1 /* executor */
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.createGlobalTrafficCounter:(Ljava/util/concurrent/ScheduledExecutorService;)V
         7: .line 188
            aload 0 /* this */
            lload 6 /* writeChannelLimit */
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.writeChannelLimit:J
         8: .line 189
            aload 0 /* this */
            lload 8 /* readChannelLimit */
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.readChannelLimit:J
         9: .line 190
            return
        end local 12 // long maxTime
        end local 10 // long checkInterval
        end local 8 // long readChannelLimit
        end local 6 // long writeChannelLimit
        end local 4 // long readGlobalLimit
        end local 2 // long writeGlobalLimit
        end local 1 // java.util.concurrent.ScheduledExecutorService executor
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0   10     0               this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            0   10     1           executor  Ljava/util/concurrent/ScheduledExecutorService;
            0   10     2   writeGlobalLimit  J
            0   10     4    readGlobalLimit  J
            0   10     6  writeChannelLimit  J
            0   10     8   readChannelLimit  J
            0   10    10      checkInterval  J
            0   10    12            maxTime  J
    MethodParameters:
                   Name  Flags
      executor           
      writeGlobalLimit   
      readGlobalLimit    
      writeChannelLimit  
      readChannelLimit   
      checkInterval      
      maxTime            

  public void <init>(java.util.concurrent.ScheduledExecutorService, long, long, long, long, long);
    descriptor: (Ljava/util/concurrent/ScheduledExecutorService;JJJJJ)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=12, args_size=7
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
        start local 1 // java.util.concurrent.ScheduledExecutorService executor
        start local 2 // long writeGlobalLimit
        start local 4 // long readGlobalLimit
        start local 6 // long writeChannelLimit
        start local 8 // long readChannelLimit
        start local 10 // long checkInterval
         0: .line 213
            aload 0 /* this */
            lload 2 /* writeGlobalLimit */
            lload 4 /* readGlobalLimit */
            lload 10 /* checkInterval */
            invokespecial io.netty.handler.traffic.AbstractTrafficShapingHandler.<init>:(JJJ)V
         1: .line 93
            aload 0 /* this */
            invokestatic io.netty.util.internal.PlatformDependent.newConcurrentHashMap:()Ljava/util/concurrent/ConcurrentMap;
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.channelQueues:Ljava/util/concurrent/ConcurrentMap;
         2: .line 98
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicLong
            dup
            invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.queuesSize:Ljava/util/concurrent/atomic/AtomicLong;
         3: .line 103
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicLong
            dup
            invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.cumulativeWrittenBytes:Ljava/util/concurrent/atomic/AtomicLong;
         4: .line 108
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicLong
            dup
            invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.cumulativeReadBytes:Ljava/util/concurrent/atomic/AtomicLong;
         5: .line 114
            aload 0 /* this */
            ldc 419430400
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.maxGlobalWriteSize:J
         6: .line 214
            aload 0 /* this */
            lload 6 /* writeChannelLimit */
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.writeChannelLimit:J
         7: .line 215
            aload 0 /* this */
            lload 8 /* readChannelLimit */
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.readChannelLimit:J
         8: .line 216
            aload 0 /* this */
            aload 1 /* executor */
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.createGlobalTrafficCounter:(Ljava/util/concurrent/ScheduledExecutorService;)V
         9: .line 217
            return
        end local 10 // long checkInterval
        end local 8 // long readChannelLimit
        end local 6 // long writeChannelLimit
        end local 4 // long readGlobalLimit
        end local 2 // long writeGlobalLimit
        end local 1 // java.util.concurrent.ScheduledExecutorService executor
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0   10     0               this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            0   10     1           executor  Ljava/util/concurrent/ScheduledExecutorService;
            0   10     2   writeGlobalLimit  J
            0   10     4    readGlobalLimit  J
            0   10     6  writeChannelLimit  J
            0   10     8   readChannelLimit  J
            0   10    10      checkInterval  J
    MethodParameters:
                   Name  Flags
      executor           
      writeGlobalLimit   
      readGlobalLimit    
      writeChannelLimit  
      readChannelLimit   
      checkInterval      

  public void <init>(java.util.concurrent.ScheduledExecutorService, long, long, long, long);
    descriptor: (Ljava/util/concurrent/ScheduledExecutorService;JJJJ)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=10, args_size=6
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
        start local 1 // java.util.concurrent.ScheduledExecutorService executor
        start local 2 // long writeGlobalLimit
        start local 4 // long readGlobalLimit
        start local 6 // long writeChannelLimit
        start local 8 // long readChannelLimit
         0: .line 236
            aload 0 /* this */
            lload 2 /* writeGlobalLimit */
            lload 4 /* readGlobalLimit */
            invokespecial io.netty.handler.traffic.AbstractTrafficShapingHandler.<init>:(JJ)V
         1: .line 93
            aload 0 /* this */
            invokestatic io.netty.util.internal.PlatformDependent.newConcurrentHashMap:()Ljava/util/concurrent/ConcurrentMap;
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.channelQueues:Ljava/util/concurrent/ConcurrentMap;
         2: .line 98
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicLong
            dup
            invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.queuesSize:Ljava/util/concurrent/atomic/AtomicLong;
         3: .line 103
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicLong
            dup
            invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.cumulativeWrittenBytes:Ljava/util/concurrent/atomic/AtomicLong;
         4: .line 108
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicLong
            dup
            invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.cumulativeReadBytes:Ljava/util/concurrent/atomic/AtomicLong;
         5: .line 114
            aload 0 /* this */
            ldc 419430400
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.maxGlobalWriteSize:J
         6: .line 237
            aload 0 /* this */
            lload 6 /* writeChannelLimit */
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.writeChannelLimit:J
         7: .line 238
            aload 0 /* this */
            lload 8 /* readChannelLimit */
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.readChannelLimit:J
         8: .line 239
            aload 0 /* this */
            aload 1 /* executor */
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.createGlobalTrafficCounter:(Ljava/util/concurrent/ScheduledExecutorService;)V
         9: .line 240
            return
        end local 8 // long readChannelLimit
        end local 6 // long writeChannelLimit
        end local 4 // long readGlobalLimit
        end local 2 // long writeGlobalLimit
        end local 1 // java.util.concurrent.ScheduledExecutorService executor
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0   10     0               this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            0   10     1           executor  Ljava/util/concurrent/ScheduledExecutorService;
            0   10     2   writeGlobalLimit  J
            0   10     4    readGlobalLimit  J
            0   10     6  writeChannelLimit  J
            0   10     8   readChannelLimit  J
    MethodParameters:
                   Name  Flags
      executor           
      writeGlobalLimit   
      readGlobalLimit    
      writeChannelLimit  
      readChannelLimit   

  public void <init>(java.util.concurrent.ScheduledExecutorService, long);
    descriptor: (Ljava/util/concurrent/ScheduledExecutorService;J)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
        start local 1 // java.util.concurrent.ScheduledExecutorService executor
        start local 2 // long checkInterval
         0: .line 252
            aload 0 /* this */
            lload 2 /* checkInterval */
            invokespecial io.netty.handler.traffic.AbstractTrafficShapingHandler.<init>:(J)V
         1: .line 93
            aload 0 /* this */
            invokestatic io.netty.util.internal.PlatformDependent.newConcurrentHashMap:()Ljava/util/concurrent/ConcurrentMap;
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.channelQueues:Ljava/util/concurrent/ConcurrentMap;
         2: .line 98
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicLong
            dup
            invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.queuesSize:Ljava/util/concurrent/atomic/AtomicLong;
         3: .line 103
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicLong
            dup
            invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.cumulativeWrittenBytes:Ljava/util/concurrent/atomic/AtomicLong;
         4: .line 108
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicLong
            dup
            invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.cumulativeReadBytes:Ljava/util/concurrent/atomic/AtomicLong;
         5: .line 114
            aload 0 /* this */
            ldc 419430400
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.maxGlobalWriteSize:J
         6: .line 253
            aload 0 /* this */
            aload 1 /* executor */
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.createGlobalTrafficCounter:(Ljava/util/concurrent/ScheduledExecutorService;)V
         7: .line 254
            return
        end local 2 // long checkInterval
        end local 1 // java.util.concurrent.ScheduledExecutorService executor
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    8     0           this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            0    8     1       executor  Ljava/util/concurrent/ScheduledExecutorService;
            0    8     2  checkInterval  J
    MethodParameters:
               Name  Flags
      executor       
      checkInterval  

  public void <init>(java.util.concurrent.ScheduledExecutorService);
    descriptor: (Ljava/util/concurrent/ScheduledExecutorService;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
        start local 1 // java.util.concurrent.ScheduledExecutorService executor
         0: .line 262
            aload 0 /* this */
            invokespecial io.netty.handler.traffic.AbstractTrafficShapingHandler.<init>:()V
         1: .line 93
            aload 0 /* this */
            invokestatic io.netty.util.internal.PlatformDependent.newConcurrentHashMap:()Ljava/util/concurrent/ConcurrentMap;
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.channelQueues:Ljava/util/concurrent/ConcurrentMap;
         2: .line 98
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicLong
            dup
            invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.queuesSize:Ljava/util/concurrent/atomic/AtomicLong;
         3: .line 103
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicLong
            dup
            invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.cumulativeWrittenBytes:Ljava/util/concurrent/atomic/AtomicLong;
         4: .line 108
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicLong
            dup
            invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.cumulativeReadBytes:Ljava/util/concurrent/atomic/AtomicLong;
         5: .line 114
            aload 0 /* this */
            ldc 419430400
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.maxGlobalWriteSize:J
         6: .line 263
            aload 0 /* this */
            aload 1 /* executor */
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.createGlobalTrafficCounter:(Ljava/util/concurrent/ScheduledExecutorService;)V
         7: .line 264
            return
        end local 1 // java.util.concurrent.ScheduledExecutorService executor
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    8     0      this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            0    8     1  executor  Ljava/util/concurrent/ScheduledExecutorService;
    MethodParameters:
          Name  Flags
      executor  

  public float maxDeviation();
    descriptor: ()F
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
         0: .line 270
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.maxDeviation:F
            freturn
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;

  public float accelerationFactor();
    descriptor: ()F
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
         0: .line 277
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.accelerationFactor:F
            freturn
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;

  public float slowDownFactor();
    descriptor: ()F
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
         0: .line 284
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.slowDownFactor:F
            freturn
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;

  public void setMaxDeviation(float, float, float);
    descriptor: (FFF)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=4
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
        start local 1 // float maxDeviation
        start local 2 // float slowDownFactor
        start local 3 // float accelerationFactor
         0: .line 299
            fload 1 /* maxDeviation */
            ldc 0.4
            fcmpl
            ifle 2
         1: .line 300
            new java.lang.IllegalArgumentException
            dup
            ldc "maxDeviation must be <= 0.4"
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 302
      StackMap locals:
      StackMap stack:
            fload 2 /* slowDownFactor */
            fconst_0
            fcmpg
            ifge 4
         3: .line 303
            new java.lang.IllegalArgumentException
            dup
            ldc "slowDownFactor must be >= 0"
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
         4: .line 305
      StackMap locals:
      StackMap stack:
            fload 3 /* accelerationFactor */
            fconst_0
            fcmpl
            ifle 6
         5: .line 306
            new java.lang.IllegalArgumentException
            dup
            ldc "accelerationFactor must be <= 0"
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
         6: .line 308
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            fload 1 /* maxDeviation */
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.maxDeviation:F
         7: .line 309
            aload 0 /* this */
            fconst_1
            fload 3 /* accelerationFactor */
            fadd
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.accelerationFactor:F
         8: .line 310
            aload 0 /* this */
            fconst_1
            fload 2 /* slowDownFactor */
            fadd
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.slowDownFactor:F
         9: .line 311
            return
        end local 3 // float accelerationFactor
        end local 2 // float slowDownFactor
        end local 1 // float maxDeviation
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0   10     0                this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            0   10     1        maxDeviation  F
            0   10     2      slowDownFactor  F
            0   10     3  accelerationFactor  F
    MethodParameters:
                    Name  Flags
      maxDeviation        
      slowDownFactor      
      accelerationFactor  

  private void computeDeviationCumulativeBytes();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=7, locals=13, args_size=1
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
         0: .line 315
            lconst_0
            lstore 1 /* maxWrittenBytes */
        start local 1 // long maxWrittenBytes
         1: .line 316
            lconst_0
            lstore 3 /* maxReadBytes */
        start local 3 // long maxReadBytes
         2: .line 317
            ldc 9223372036854775807
            lstore 5 /* minWrittenBytes */
        start local 5 // long minWrittenBytes
         3: .line 318
            ldc 9223372036854775807
            lstore 7 /* minReadBytes */
        start local 7 // long minReadBytes
         4: .line 319
            aload 0 /* this */
            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 10
            goto 16
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler long long long long top java.util.Iterator
      StackMap stack:
         5: aload 10
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel
            astore 9 /* perChannel */
        start local 9 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
         6: .line 320
            aload 9 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.channelTrafficCounter:Lio/netty/handler/traffic/TrafficCounter;
            invokevirtual io.netty.handler.traffic.TrafficCounter.cumulativeWrittenBytes:()J
            lstore 11 /* value */
        start local 11 // long value
         7: .line 321
            lload 1 /* maxWrittenBytes */
            lload 11 /* value */
            lcmp
            ifge 9
         8: .line 322
            lload 11 /* value */
            lstore 1 /* maxWrittenBytes */
         9: .line 324
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler long long long long io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel java.util.Iterator long
      StackMap stack:
            lload 5 /* minWrittenBytes */
            lload 11 /* value */
            lcmp
            ifle 11
        10: .line 325
            lload 11 /* value */
            lstore 5 /* minWrittenBytes */
        11: .line 327
      StackMap locals:
      StackMap stack:
            aload 9 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.channelTrafficCounter:Lio/netty/handler/traffic/TrafficCounter;
            invokevirtual io.netty.handler.traffic.TrafficCounter.cumulativeReadBytes:()J
            lstore 11 /* value */
        12: .line 328
            lload 3 /* maxReadBytes */
            lload 11 /* value */
            lcmp
            ifge 14
        13: .line 329
            lload 11 /* value */
            lstore 3 /* maxReadBytes */
        14: .line 331
      StackMap locals:
      StackMap stack:
            lload 7 /* minReadBytes */
            lload 11 /* value */
            lcmp
            ifle 16
        15: .line 332
            lload 11 /* value */
            lstore 7 /* minReadBytes */
        end local 11 // long value
        end local 9 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
        16: .line 319
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler long long long long top java.util.Iterator
      StackMap stack:
            aload 10
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 5
        17: .line 335
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.channelQueues:Ljava/util/concurrent/ConcurrentMap;
            invokeinterface java.util.concurrent.ConcurrentMap.size:()I
            iconst_1
            if_icmple 18
            iconst_1
            goto 19
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler long long long long
      StackMap stack:
        18: iconst_0
      StackMap locals:
      StackMap stack: int
        19: istore 9 /* multiple */
        start local 9 // boolean multiple
        20: .line 336
            aload 0 /* this */
            iload 9 /* multiple */
            ifeq 21
            lload 7 /* minReadBytes */
            lload 3 /* maxReadBytes */
            ldc 2
            ldiv
            lcmp
            ifge 21
            iconst_1
            goto 22
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler long long long long int
      StackMap stack: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler
        21: iconst_0
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler long long long long int
      StackMap stack: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler int
        22: putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.readDeviationActive:Z
        23: .line 337
            aload 0 /* this */
            iload 9 /* multiple */
            ifeq 24
            lload 5 /* minWrittenBytes */
            lload 1 /* maxWrittenBytes */
            ldc 2
            ldiv
            lcmp
            ifge 24
            iconst_1
            goto 25
      StackMap locals:
      StackMap stack: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler
        24: iconst_0
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler long long long long int
      StackMap stack: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler int
        25: putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.writeDeviationActive:Z
        26: .line 338
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.cumulativeWrittenBytes:Ljava/util/concurrent/atomic/AtomicLong;
            lload 1 /* maxWrittenBytes */
            invokevirtual java.util.concurrent.atomic.AtomicLong.set:(J)V
        27: .line 339
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.cumulativeReadBytes:Ljava/util/concurrent/atomic/AtomicLong;
            lload 3 /* maxReadBytes */
            invokevirtual java.util.concurrent.atomic.AtomicLong.set:(J)V
        28: .line 340
            return
        end local 9 // boolean multiple
        end local 7 // long minReadBytes
        end local 5 // long minWrittenBytes
        end local 3 // long maxReadBytes
        end local 1 // long maxWrittenBytes
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   29     0             this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            1   29     1  maxWrittenBytes  J
            2   29     3     maxReadBytes  J
            3   29     5  minWrittenBytes  J
            4   29     7     minReadBytes  J
            6   16     9       perChannel  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$PerChannel;
            7   16    11            value  J
           20   29     9         multiple  Z

  protected void doAccounting(io.netty.handler.traffic.TrafficCounter);
    descriptor: (Lio/netty/handler/traffic/TrafficCounter;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
        start local 1 // io.netty.handler.traffic.TrafficCounter counter
         0: .line 344
            aload 0 /* this */
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.computeDeviationCumulativeBytes:()V
         1: .line 345
            aload 0 /* this */
            aload 1 /* counter */
            invokespecial io.netty.handler.traffic.AbstractTrafficShapingHandler.doAccounting:(Lio/netty/handler/traffic/TrafficCounter;)V
         2: .line 346
            return
        end local 1 // io.netty.handler.traffic.TrafficCounter counter
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            0    3     1  counter  Lio/netty/handler/traffic/TrafficCounter;
    MethodParameters:
         Name  Flags
      counter  

  private long computeBalancedWait(float, float, long);
    descriptor: (FFJ)J
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=6, args_size=4
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
        start local 1 // float maxLocal
        start local 2 // float maxGlobal
        start local 3 // long wait
         0: .line 349
            fload 2 /* maxGlobal */
            fconst_0
            fcmpl
            ifne 2
         1: .line 351
            lload 3 /* wait */
            lreturn
         2: .line 353
      StackMap locals:
      StackMap stack:
            fload 1 /* maxLocal */
            fload 2 /* maxGlobal */
            fdiv
            fstore 5 /* ratio */
        start local 5 // float ratio
         3: .line 355
            fload 5 /* ratio */
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.maxDeviation:F
            fcmpl
            ifle 10
         4: .line 356
            fload 5 /* ratio */
            fconst_1
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.maxDeviation:F
            fsub
            fcmpg
            ifge 6
         5: .line 357
            lload 3 /* wait */
            lreturn
         6: .line 359
      StackMap locals: float
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.slowDownFactor:F
            fstore 5 /* ratio */
         7: .line 360
            lload 3 /* wait */
            ldc 10
            lcmp
            ifge 11
         8: .line 361
            ldc 10
            lstore 3 /* wait */
         9: .line 364
            goto 11
        10: .line 365
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.accelerationFactor:F
            fstore 5 /* ratio */
        11: .line 367
      StackMap locals:
      StackMap stack:
            lload 3 /* wait */
            l2f
            fload 5 /* ratio */
            fmul
            f2l
            lreturn
        end local 5 // float ratio
        end local 3 // long wait
        end local 2 // float maxGlobal
        end local 1 // float maxLocal
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0   12     0       this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            0   12     1   maxLocal  F
            0   12     2  maxGlobal  F
            0   12     3       wait  J
            3   12     5      ratio  F
    MethodParameters:
           Name  Flags
      maxLocal   
      maxGlobal  
      wait       

  public long getMaxGlobalWriteSize();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
         0: .line 374
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.maxGlobalWriteSize:J
            lreturn
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;

  public void setMaxGlobalWriteSize(long);
    descriptor: (J)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
        start local 1 // long maxGlobalWriteSize
         0: .line 388
            lload 1 /* maxGlobalWriteSize */
            lconst_0
            lcmp
            ifgt 2
         1: .line 389
            new java.lang.IllegalArgumentException
            dup
            ldc "maxGlobalWriteSize must be positive"
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 391
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            lload 1 /* maxGlobalWriteSize */
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.maxGlobalWriteSize:J
         3: .line 392
            return
        end local 1 // long maxGlobalWriteSize
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    4     0                this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            0    4     1  maxGlobalWriteSize  J
    MethodParameters:
                    Name  Flags
      maxGlobalWriteSize  

  public long queuesSize();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
         0: .line 398
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.queuesSize:Ljava/util/concurrent/atomic/AtomicLong;
            invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
            lreturn
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;

  public void configureChannel(long, long);
    descriptor: (JJ)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=9, args_size=3
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
        start local 1 // long newWriteLimit
        start local 3 // long newReadLimit
         0: .line 406
            aload 0 /* this */
            lload 1 /* newWriteLimit */
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.writeChannelLimit:J
         1: .line 407
            aload 0 /* this */
            lload 3 /* newReadLimit */
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.readChannelLimit:J
         2: .line 408
            invokestatic io.netty.handler.traffic.TrafficCounter.milliSecondFromNano:()J
            lstore 5 /* now */
        start local 5 // long now
         3: .line 409
            aload 0 /* this */
            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 8
            goto 6
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler long long long top java.util.Iterator
      StackMap stack:
         4: aload 8
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel
            astore 7 /* perChannel */
        start local 7 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
         5: .line 410
            aload 7 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.channelTrafficCounter:Lio/netty/handler/traffic/TrafficCounter;
            lload 5 /* now */
            invokevirtual io.netty.handler.traffic.TrafficCounter.resetAccounting:(J)V
        end local 7 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
         6: .line 409
      StackMap locals:
      StackMap stack:
            aload 8
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 4
         7: .line 412
            return
        end local 5 // long now
        end local 3 // long newReadLimit
        end local 1 // long newWriteLimit
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    8     0           this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            0    8     1  newWriteLimit  J
            0    8     3   newReadLimit  J
            3    8     5            now  J
            5    6     7     perChannel  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$PerChannel;
    MethodParameters:
               Name  Flags
      newWriteLimit  
      newReadLimit   

  public long getWriteChannelLimit();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
         0: .line 418
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.writeChannelLimit:J
            lreturn
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;

  public void setWriteChannelLimit(long);
    descriptor: (J)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=7, args_size=2
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
        start local 1 // long writeLimit
         0: .line 425
            aload 0 /* this */
            lload 1 /* writeLimit */
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.writeChannelLimit:J
         1: .line 426
            invokestatic io.netty.handler.traffic.TrafficCounter.milliSecondFromNano:()J
            lstore 3 /* now */
        start local 3 // long now
         2: .line 427
            aload 0 /* this */
            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 6
            goto 5
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler long long top java.util.Iterator
      StackMap stack:
         3: aload 6
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel
            astore 5 /* perChannel */
        start local 5 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
         4: .line 428
            aload 5 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.channelTrafficCounter:Lio/netty/handler/traffic/TrafficCounter;
            lload 3 /* now */
            invokevirtual io.netty.handler.traffic.TrafficCounter.resetAccounting:(J)V
        end local 5 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
         5: .line 427
      StackMap locals:
      StackMap stack:
            aload 6
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 3
         6: .line 430
            return
        end local 3 // long now
        end local 1 // long writeLimit
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    7     0        this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            0    7     1  writeLimit  J
            2    7     3         now  J
            4    5     5  perChannel  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$PerChannel;
    MethodParameters:
            Name  Flags
      writeLimit  

  public long getReadChannelLimit();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
         0: .line 436
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.readChannelLimit:J
            lreturn
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;

  public void setReadChannelLimit(long);
    descriptor: (J)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=7, args_size=2
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
        start local 1 // long readLimit
         0: .line 443
            aload 0 /* this */
            lload 1 /* readLimit */
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.readChannelLimit:J
         1: .line 444
            invokestatic io.netty.handler.traffic.TrafficCounter.milliSecondFromNano:()J
            lstore 3 /* now */
        start local 3 // long now
         2: .line 445
            aload 0 /* this */
            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 6
            goto 5
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler long long top java.util.Iterator
      StackMap stack:
         3: aload 6
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel
            astore 5 /* perChannel */
        start local 5 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
         4: .line 446
            aload 5 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.channelTrafficCounter:Lio/netty/handler/traffic/TrafficCounter;
            lload 3 /* now */
            invokevirtual io.netty.handler.traffic.TrafficCounter.resetAccounting:(J)V
        end local 5 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
         5: .line 445
      StackMap locals:
      StackMap stack:
            aload 6
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 3
         6: .line 448
            return
        end local 3 // long now
        end local 1 // long readLimit
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    7     0        this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            0    7     1   readLimit  J
            2    7     3         now  J
            4    5     5  perChannel  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$PerChannel;
    MethodParameters:
           Name  Flags
      readLimit  

  public final void release();
    descriptor: ()V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
         0: .line 454
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.trafficCounter:Lio/netty/handler/traffic/TrafficCounter;
            invokevirtual io.netty.handler.traffic.TrafficCounter.stop:()V
         1: .line 455
            return
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;

  private io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel getOrSetPerChannel(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$PerChannel;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=8, locals=5, args_size=2
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
         0: .line 459
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
            astore 2 /* channel */
        start local 2 // io.netty.channel.Channel channel
         1: .line 460
            aload 2 /* channel */
            invokevirtual java.lang.Object.hashCode:()I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            astore 3 /* key */
        start local 3 // java.lang.Integer key
         2: .line 461
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.channelQueues:Ljava/util/concurrent/ConcurrentMap;
            aload 3 /* key */
            invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel
            astore 4 /* perChannel */
        start local 4 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
         3: .line 462
            aload 4 /* perChannel */
            ifnonnull 13
         4: .line 463
            new io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel
            dup
            invokespecial io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.<init>:()V
            astore 4 /* perChannel */
         5: .line 464
            aload 4 /* perChannel */
            new java.util.ArrayDeque
            dup
            invokespecial java.util.ArrayDeque.<init>:()V
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.messagesQueue:Ljava/util/ArrayDeque;
         6: .line 466
            aload 4 /* perChannel */
            new io.netty.handler.traffic.TrafficCounter
            dup
            aload 0 /* this */
            aconst_null
            new java.lang.StringBuilder
            dup
            ldc "ChannelTC"
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
         7: .line 467
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
            invokevirtual java.lang.Object.hashCode:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.checkInterval:J
            invokespecial io.netty.handler.traffic.TrafficCounter.<init>:(Lio/netty/handler/traffic/AbstractTrafficShapingHandler;Ljava/util/concurrent/ScheduledExecutorService;Ljava/lang/String;J)V
         8: .line 466
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.channelTrafficCounter:Lio/netty/handler/traffic/TrafficCounter;
         9: .line 468
            aload 4 /* perChannel */
            lconst_0
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.queueSize:J
        10: .line 469
            aload 4 /* perChannel */
            invokestatic io.netty.handler.traffic.TrafficCounter.milliSecondFromNano:()J
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.lastReadTimestamp:J
        11: .line 470
            aload 4 /* perChannel */
            aload 4 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.lastReadTimestamp:J
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.lastWriteTimestamp:J
        12: .line 471
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.channelQueues:Ljava/util/concurrent/ConcurrentMap;
            aload 3 /* key */
            aload 4 /* perChannel */
            invokeinterface java.util.concurrent.ConcurrentMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        13: .line 473
      StackMap locals: io.netty.channel.Channel java.lang.Integer io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel
      StackMap stack:
            aload 4 /* perChannel */
            areturn
        end local 4 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
        end local 3 // java.lang.Integer key
        end local 2 // io.netty.channel.Channel channel
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   14     0        this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            0   14     1         ctx  Lio/netty/channel/ChannelHandlerContext;
            1   14     2     channel  Lio/netty/channel/Channel;
            2   14     3         key  Ljava/lang/Integer;
            3   14     4  perChannel  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$PerChannel;
    MethodParameters:
      Name  Flags
      ctx   

  public void handlerAdded(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
         0: .line 478
            aload 0 /* this */
            aload 1 /* ctx */
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.getOrSetPerChannel:(Lio/netty/channel/ChannelHandlerContext;)Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$PerChannel;
            pop
         1: .line 479
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.trafficCounter:Lio/netty/handler/traffic/TrafficCounter;
            invokevirtual io.netty.handler.traffic.TrafficCounter.resetCumulativeTime:()V
         2: .line 480
            aload 0 /* this */
            aload 1 /* ctx */
            invokespecial io.netty.handler.traffic.AbstractTrafficShapingHandler.handlerAdded:(Lio/netty/channel/ChannelHandlerContext;)V
         3: .line 481
            return
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            0    4     1   ctx  Lio/netty/channel/ChannelHandlerContext;
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
      Name  Flags
      ctx   

  public void handlerRemoved(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=10, args_size=2
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
         0: .line 485
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.trafficCounter:Lio/netty/handler/traffic/TrafficCounter;
            invokevirtual io.netty.handler.traffic.TrafficCounter.resetCumulativeTime:()V
         1: .line 486
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
            astore 2 /* channel */
        start local 2 // io.netty.channel.Channel channel
         2: .line 487
            aload 2 /* channel */
            invokevirtual java.lang.Object.hashCode:()I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            astore 3 /* key */
        start local 3 // java.lang.Integer key
         3: .line 488
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.channelQueues:Ljava/util/concurrent/ConcurrentMap;
            aload 3 /* key */
            invokeinterface java.util.concurrent.ConcurrentMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel
            astore 4 /* perChannel */
        start local 4 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
         4: .line 489
            aload 4 /* perChannel */
            ifnull 28
         5: .line 491
            aload 4 /* perChannel */
            dup
            astore 5
            monitorenter
         6: .line 492
            aload 2 /* channel */
            invokeinterface io.netty.channel.Channel.isActive:()Z
            ifeq 17
         7: .line 493
            aload 4 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.messagesQueue:Ljava/util/ArrayDeque;
            invokevirtual java.util.ArrayDeque.iterator:()Ljava/util/Iterator;
            astore 7
            goto 15
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler io.netty.channel.ChannelHandlerContext io.netty.channel.Channel java.lang.Integer io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel top java.util.Iterator
      StackMap stack:
         8: aload 7
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend
            astore 6 /* toSend */
        start local 6 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend toSend
         9: .line 494
            aload 0 /* this */
            aload 6 /* toSend */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend.toSend:Ljava/lang/Object;
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.calculateSize:(Ljava/lang/Object;)J
            lstore 8 /* size */
        start local 8 // long size
        10: .line 495
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.trafficCounter:Lio/netty/handler/traffic/TrafficCounter;
            lload 8 /* size */
            invokevirtual io.netty.handler.traffic.TrafficCounter.bytesRealWriteFlowControl:(J)V
        11: .line 496
            aload 4 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.channelTrafficCounter:Lio/netty/handler/traffic/TrafficCounter;
            lload 8 /* size */
            invokevirtual io.netty.handler.traffic.TrafficCounter.bytesRealWriteFlowControl:(J)V
        12: .line 497
            aload 4 /* perChannel */
            dup
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.queueSize:J
            lload 8 /* size */
            lsub
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.queueSize:J
        13: .line 498
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.queuesSize:Ljava/util/concurrent/atomic/AtomicLong;
            lload 8 /* size */
            lneg
            invokevirtual java.util.concurrent.atomic.AtomicLong.addAndGet:(J)J
            pop2
        14: .line 499
            aload 1 /* ctx */
            aload 6 /* toSend */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend.toSend:Ljava/lang/Object;
            aload 6 /* toSend */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend.promise:Lio/netty/channel/ChannelPromise;
            invokeinterface io.netty.channel.ChannelHandlerContext.write:(Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
            pop
        end local 8 // long size
        end local 6 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend toSend
        15: .line 493
      StackMap locals:
      StackMap stack:
            aload 7
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 8
        16: .line 501
            goto 23
        17: .line 502
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler io.netty.channel.ChannelHandlerContext io.netty.channel.Channel java.lang.Integer io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.queuesSize:Ljava/util/concurrent/atomic/AtomicLong;
            aload 4 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.queueSize:J
            lneg
            invokevirtual java.util.concurrent.atomic.AtomicLong.addAndGet:(J)J
            pop2
        18: .line 503
            aload 4 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.messagesQueue:Ljava/util/ArrayDeque;
            invokevirtual java.util.ArrayDeque.iterator:()Ljava/util/Iterator;
            astore 7
            goto 22
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler io.netty.channel.ChannelHandlerContext io.netty.channel.Channel java.lang.Integer io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel top java.util.Iterator
      StackMap stack:
        19: aload 7
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend
            astore 6 /* toSend */
        start local 6 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend toSend
        20: .line 504
            aload 6 /* toSend */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend.toSend:Ljava/lang/Object;
            instanceof io.netty.buffer.ByteBuf
            ifeq 22
        21: .line 505
            aload 6 /* toSend */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend.toSend:Ljava/lang/Object;
            checkcast io.netty.buffer.ByteBuf
            invokevirtual io.netty.buffer.ByteBuf.release:()Z
            pop
        end local 6 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend toSend
        22: .line 503
      StackMap locals:
      StackMap stack:
            aload 7
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 19
        23: .line 509
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler io.netty.channel.ChannelHandlerContext io.netty.channel.Channel java.lang.Integer io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel
      StackMap stack:
            aload 4 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.messagesQueue:Ljava/util/ArrayDeque;
            invokevirtual java.util.ArrayDeque.clear:()V
        24: .line 491
            aload 5
            monitorexit
        25: goto 28
      StackMap locals:
      StackMap stack: java.lang.Throwable
        26: aload 5
            monitorexit
        27: athrow
        28: .line 512
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* ctx */
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.releaseWriteSuspended:(Lio/netty/channel/ChannelHandlerContext;)V
        29: .line 513
            aload 0 /* this */
            aload 1 /* ctx */
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.releaseReadSuspended:(Lio/netty/channel/ChannelHandlerContext;)V
        30: .line 514
            aload 0 /* this */
            aload 1 /* ctx */
            invokespecial io.netty.handler.traffic.AbstractTrafficShapingHandler.handlerRemoved:(Lio/netty/channel/ChannelHandlerContext;)V
        31: .line 515
            return
        end local 4 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
        end local 3 // java.lang.Integer key
        end local 2 // io.netty.channel.Channel channel
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   32     0        this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            0   32     1         ctx  Lio/netty/channel/ChannelHandlerContext;
            2   32     2     channel  Lio/netty/channel/Channel;
            3   32     3         key  Ljava/lang/Integer;
            4   32     4  perChannel  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$PerChannel;
            9   15     6      toSend  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$ToSend;
           10   15     8        size  J
           20   22     6      toSend  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$ToSend;
      Exception table:
        from    to  target  type
           6    25      26  any
          26    27      26  any
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
      Name  Flags
      ctx   

  public void channelRead(io.netty.channel.ChannelHandlerContext, java.lang.Object);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=9, locals=17, args_size=3
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // java.lang.Object msg
         0: .line 519
            aload 0 /* this */
            aload 2 /* msg */
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.calculateSize:(Ljava/lang/Object;)J
            lstore 3 /* size */
        start local 3 // long size
         1: .line 520
            invokestatic io.netty.handler.traffic.TrafficCounter.milliSecondFromNano:()J
            lstore 5 /* now */
        start local 5 // long now
         2: .line 521
            lload 3 /* size */
            lconst_0
            lcmp
            ifle 40
         3: .line 523
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.trafficCounter:Lio/netty/handler/traffic/TrafficCounter;
            lload 3 /* size */
            aload 0 /* this */
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.getReadLimit:()J
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.maxTime:J
            lload 5 /* now */
            invokevirtual io.netty.handler.traffic.TrafficCounter.readTimeToWait:(JJJJ)J
            lstore 7 /* waitGlobal */
        start local 7 // long waitGlobal
         4: .line 524
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
            invokevirtual java.lang.Object.hashCode:()I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            astore 9 /* key */
        start local 9 // java.lang.Integer key
         5: .line 525
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.channelQueues:Ljava/util/concurrent/ConcurrentMap;
            aload 9 /* key */
            invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel
            astore 10 /* perChannel */
        start local 10 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
         6: .line 526
            lconst_0
            lstore 11 /* wait */
        start local 11 // long wait
         7: .line 527
            aload 10 /* perChannel */
            ifnull 17
         8: .line 528
            aload 10 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.channelTrafficCounter:Lio/netty/handler/traffic/TrafficCounter;
            lload 3 /* size */
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.readChannelLimit:J
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.maxTime:J
            lload 5 /* now */
            invokevirtual io.netty.handler.traffic.TrafficCounter.readTimeToWait:(JJJJ)J
            lstore 11 /* wait */
         9: .line 529
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.readDeviationActive:Z
            ifeq 17
        10: .line 532
            aload 10 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.channelTrafficCounter:Lio/netty/handler/traffic/TrafficCounter;
            invokevirtual io.netty.handler.traffic.TrafficCounter.cumulativeReadBytes:()J
            lstore 13 /* maxLocalRead */
        start local 13 // long maxLocalRead
        11: .line 533
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.cumulativeReadBytes:Ljava/util/concurrent/atomic/AtomicLong;
            invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
            lstore 15 /* maxGlobalRead */
        start local 15 // long maxGlobalRead
        12: .line 534
            lload 13 /* maxLocalRead */
            lconst_0
            lcmp
            ifgt 14
        13: .line 535
            lconst_0
            lstore 13 /* maxLocalRead */
        14: .line 537
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler io.netty.channel.ChannelHandlerContext java.lang.Object long long long java.lang.Integer io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel long long long
      StackMap stack:
            lload 15 /* maxGlobalRead */
            lload 13 /* maxLocalRead */
            lcmp
            ifge 16
        15: .line 538
            lload 13 /* maxLocalRead */
            lstore 15 /* maxGlobalRead */
        16: .line 540
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            lload 13 /* maxLocalRead */
            l2f
            lload 15 /* maxGlobalRead */
            l2f
            lload 11 /* wait */
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.computeBalancedWait:(FFJ)J
            lstore 11 /* wait */
        end local 15 // long maxGlobalRead
        end local 13 // long maxLocalRead
        17: .line 543
      StackMap locals:
      StackMap stack:
            lload 11 /* wait */
            lload 7 /* waitGlobal */
            lcmp
            ifge 19
        18: .line 544
            lload 7 /* waitGlobal */
            lstore 11 /* wait */
        19: .line 546
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* ctx */
            lload 11 /* wait */
            lload 5 /* now */
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.checkWaitReadTime:(Lio/netty/channel/ChannelHandlerContext;JJ)J
            lstore 11 /* wait */
        20: .line 547
            lload 11 /* wait */
            ldc 10
            lcmp
            iflt 40
        21: .line 550
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
            astore 13 /* channel */
        start local 13 // io.netty.channel.Channel channel
        22: .line 551
            aload 13 /* channel */
            invokeinterface io.netty.channel.Channel.config:()Lio/netty/channel/ChannelConfig;
            astore 14 /* config */
        start local 14 // io.netty.channel.ChannelConfig config
        23: .line 552
            getstatic io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.logger:Lio/netty/util/internal/logging/InternalLogger;
            invokeinterface io.netty.util.internal.logging.InternalLogger.isDebugEnabled:()Z
            ifeq 27
        24: .line 553
            getstatic io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.logger:Lio/netty/util/internal/logging/InternalLogger;
            new java.lang.StringBuilder
            dup
            ldc "Read Suspend: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            lload 11 /* wait */
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
            bipush 58
            invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
            aload 14 /* config */
            invokeinterface io.netty.channel.ChannelConfig.isAutoRead:()Z
            invokevirtual java.lang.StringBuilder.append:(Z)Ljava/lang/StringBuilder;
            bipush 58
            invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
        25: .line 554
            aload 1 /* ctx */
            invokestatic io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.isHandlerActive:(Lio/netty/channel/ChannelHandlerContext;)Z
            invokevirtual java.lang.StringBuilder.append:(Z)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
        26: .line 553
            invokeinterface io.netty.util.internal.logging.InternalLogger.debug:(Ljava/lang/String;)V
        27: .line 556
      StackMap locals: io.netty.channel.Channel io.netty.channel.ChannelConfig
      StackMap stack:
            aload 14 /* config */
            invokeinterface io.netty.channel.ChannelConfig.isAutoRead:()Z
            ifeq 40
            aload 1 /* ctx */
            invokestatic io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.isHandlerActive:(Lio/netty/channel/ChannelHandlerContext;)Z
            ifeq 40
        28: .line 557
            aload 14 /* config */
            iconst_0
            invokeinterface io.netty.channel.ChannelConfig.setAutoRead:(Z)Lio/netty/channel/ChannelConfig;
            pop
        29: .line 558
            aload 13 /* channel */
            getstatic io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.READ_SUSPENDED:Lio/netty/util/AttributeKey;
            invokeinterface io.netty.channel.Channel.attr:(Lio/netty/util/AttributeKey;)Lio/netty/util/Attribute;
            iconst_1
            invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
            invokeinterface io.netty.util.Attribute.set:(Ljava/lang/Object;)V
        30: .line 561
            aload 13 /* channel */
            getstatic io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.REOPEN_TASK:Lio/netty/util/AttributeKey;
            invokeinterface io.netty.channel.Channel.attr:(Lio/netty/util/AttributeKey;)Lio/netty/util/Attribute;
            astore 15 /* attr */
        start local 15 // io.netty.util.Attribute attr
        31: .line 562
            aload 15 /* attr */
            invokeinterface io.netty.util.Attribute.get:()Ljava/lang/Object;
            checkcast java.lang.Runnable
            astore 16 /* reopenTask */
        start local 16 // java.lang.Runnable reopenTask
        32: .line 563
            aload 16 /* reopenTask */
            ifnonnull 35
        33: .line 564
            new io.netty.handler.traffic.AbstractTrafficShapingHandler$ReopenReadTimerTask
            dup
            aload 1 /* ctx */
            invokespecial io.netty.handler.traffic.AbstractTrafficShapingHandler$ReopenReadTimerTask.<init>:(Lio/netty/channel/ChannelHandlerContext;)V
            astore 16 /* reopenTask */
        34: .line 565
            aload 15 /* attr */
            aload 16 /* reopenTask */
            invokeinterface io.netty.util.Attribute.set:(Ljava/lang/Object;)V
        35: .line 567
      StackMap locals: io.netty.util.Attribute java.lang.Runnable
      StackMap stack:
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.executor:()Lio/netty/util/concurrent/EventExecutor;
            aload 16 /* reopenTask */
            lload 11 /* wait */
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
            invokeinterface io.netty.util.concurrent.EventExecutor.schedule:(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lio/netty/util/concurrent/ScheduledFuture;
            pop
        36: .line 568
            getstatic io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.logger:Lio/netty/util/internal/logging/InternalLogger;
            invokeinterface io.netty.util.internal.logging.InternalLogger.isDebugEnabled:()Z
            ifeq 40
        37: .line 569
            getstatic io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.logger:Lio/netty/util/internal/logging/InternalLogger;
            new java.lang.StringBuilder
            dup
            ldc "Suspend final status => "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 14 /* config */
            invokeinterface io.netty.channel.ChannelConfig.isAutoRead:()Z
            invokevirtual java.lang.StringBuilder.append:(Z)Ljava/lang/StringBuilder;
            bipush 58
            invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
        38: .line 570
            aload 1 /* ctx */
            invokestatic io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.isHandlerActive:(Lio/netty/channel/ChannelHandlerContext;)Z
            invokevirtual java.lang.StringBuilder.append:(Z)Ljava/lang/StringBuilder;
            ldc " will reopened at: "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            lload 11 /* wait */
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
        39: .line 569
            invokeinterface io.netty.util.internal.logging.InternalLogger.debug:(Ljava/lang/String;)V
        end local 16 // java.lang.Runnable reopenTask
        end local 15 // io.netty.util.Attribute attr
        end local 14 // io.netty.channel.ChannelConfig config
        end local 13 // io.netty.channel.Channel channel
        end local 11 // long wait
        end local 10 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
        end local 9 // java.lang.Integer key
        end local 7 // long waitGlobal
        40: .line 575
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler io.netty.channel.ChannelHandlerContext java.lang.Object long long
      StackMap stack:
            aload 0 /* this */
            aload 1 /* ctx */
            lload 5 /* now */
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.informReadOperation:(Lio/netty/channel/ChannelHandlerContext;J)V
        41: .line 576
            aload 1 /* ctx */
            aload 2 /* msg */
            invokeinterface io.netty.channel.ChannelHandlerContext.fireChannelRead:(Ljava/lang/Object;)Lio/netty/channel/ChannelHandlerContext;
            pop
        42: .line 577
            return
        end local 5 // long now
        end local 3 // long size
        end local 2 // java.lang.Object msg
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0   43     0           this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            0   43     1            ctx  Lio/netty/channel/ChannelHandlerContext;
            0   43     2            msg  Ljava/lang/Object;
            1   43     3           size  J
            2   43     5            now  J
            4   40     7     waitGlobal  J
            5   40     9            key  Ljava/lang/Integer;
            6   40    10     perChannel  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$PerChannel;
            7   40    11           wait  J
           11   17    13   maxLocalRead  J
           12   17    15  maxGlobalRead  J
           22   40    13        channel  Lio/netty/channel/Channel;
           23   40    14         config  Lio/netty/channel/ChannelConfig;
           31   40    15           attr  Lio/netty/util/Attribute<Ljava/lang/Runnable;>;
           32   40    16     reopenTask  Ljava/lang/Runnable;
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
      Name  Flags
      ctx   final
      msg   final

  protected long checkWaitReadTime(io.netty.channel.ChannelHandlerContext, long, long);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;JJ)J
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=4, locals=8, args_size=4
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // long wait
        start local 4 // long now
         0: .line 581
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
            invokevirtual java.lang.Object.hashCode:()I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            astore 6 /* key */
        start local 6 // java.lang.Integer key
         1: .line 582
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.channelQueues:Ljava/util/concurrent/ConcurrentMap;
            aload 6 /* key */
            invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel
            astore 7 /* perChannel */
        start local 7 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
         2: .line 583
            aload 7 /* perChannel */
            ifnull 5
         3: .line 584
            lload 2 /* wait */
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.maxTime:J
            lcmp
            ifle 5
            lload 4 /* now */
            lload 2 /* wait */
            ladd
            aload 7 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.lastReadTimestamp:J
            lsub
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.maxTime:J
            lcmp
            ifle 5
         4: .line 585
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.maxTime:J
            lstore 2 /* wait */
         5: .line 588
      StackMap locals: java.lang.Integer io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel
      StackMap stack:
            lload 2 /* wait */
            lreturn
        end local 7 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
        end local 6 // java.lang.Integer key
        end local 4 // long now
        end local 2 // long wait
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    6     0        this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            0    6     1         ctx  Lio/netty/channel/ChannelHandlerContext;
            0    6     2        wait  J
            0    6     4         now  J
            1    6     6         key  Ljava/lang/Integer;
            2    6     7  perChannel  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$PerChannel;
    MethodParameters:
      Name  Flags
      ctx   final
      wait  
      now   final

  protected void informReadOperation(io.netty.channel.ChannelHandlerContext, long);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;J)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=3, locals=6, args_size=3
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // long now
         0: .line 593
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
            invokevirtual java.lang.Object.hashCode:()I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            astore 4 /* key */
        start local 4 // java.lang.Integer key
         1: .line 594
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.channelQueues:Ljava/util/concurrent/ConcurrentMap;
            aload 4 /* key */
            invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel
            astore 5 /* perChannel */
        start local 5 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
         2: .line 595
            aload 5 /* perChannel */
            ifnull 4
         3: .line 596
            aload 5 /* perChannel */
            lload 2 /* now */
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.lastReadTimestamp:J
         4: .line 598
      StackMap locals: java.lang.Integer io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel
      StackMap stack:
            return
        end local 5 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
        end local 4 // java.lang.Integer key
        end local 2 // long now
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    5     0        this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            0    5     1         ctx  Lio/netty/channel/ChannelHandlerContext;
            0    5     2         now  J
            1    5     4         key  Ljava/lang/Integer;
            2    5     5  perChannel  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$PerChannel;
    MethodParameters:
      Name  Flags
      ctx   final
      now   final

  protected long maximumCumulativeWrittenBytes();
    descriptor: ()J
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
         0: .line 615
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.cumulativeWrittenBytes:Ljava/util/concurrent/atomic/AtomicLong;
            invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
            lreturn
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;

  protected long maximumCumulativeReadBytes();
    descriptor: ()J
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
         0: .line 619
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.cumulativeReadBytes:Ljava/util/concurrent/atomic/AtomicLong;
            invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
            lreturn
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;

  public java.util.Collection<io.netty.handler.traffic.TrafficCounter> channelTrafficCounters();
    descriptor: ()Ljava/util/Collection;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
         0: .line 627
            new io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$1
            dup
            aload 0 /* this */
            invokespecial io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$1.<init>:(Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;)V
            areturn
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
    Signature: ()Ljava/util/Collection<Lio/netty/handler/traffic/TrafficCounter;>;

  public void write(io.netty.channel.ChannelHandlerContext, java.lang.Object, io.netty.channel.ChannelPromise);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=10, locals=18, args_size=4
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // java.lang.Object msg
        start local 3 // io.netty.channel.ChannelPromise promise
         0: .line 656
            aload 0 /* this */
            aload 2 /* msg */
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.calculateSize:(Ljava/lang/Object;)J
            lstore 4 /* size */
        start local 4 // long size
         1: .line 657
            invokestatic io.netty.handler.traffic.TrafficCounter.milliSecondFromNano:()J
            lstore 6 /* now */
        start local 6 // long now
         2: .line 658
            lload 4 /* size */
            lconst_0
            lcmp
            ifle 26
         3: .line 660
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.trafficCounter:Lio/netty/handler/traffic/TrafficCounter;
            lload 4 /* size */
            aload 0 /* this */
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.getWriteLimit:()J
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.maxTime:J
            lload 6 /* now */
            invokevirtual io.netty.handler.traffic.TrafficCounter.writeTimeToWait:(JJJJ)J
            lstore 8 /* waitGlobal */
        start local 8 // long waitGlobal
         4: .line 661
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
            invokevirtual java.lang.Object.hashCode:()I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            astore 10 /* key */
        start local 10 // java.lang.Integer key
         5: .line 662
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.channelQueues:Ljava/util/concurrent/ConcurrentMap;
            aload 10 /* key */
            invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel
            astore 11 /* perChannel */
        start local 11 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
         6: .line 663
            lconst_0
            lstore 12 /* wait */
        start local 12 // long wait
         7: .line 664
            aload 11 /* perChannel */
            ifnull 17
         8: .line 665
            aload 11 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.channelTrafficCounter:Lio/netty/handler/traffic/TrafficCounter;
            lload 4 /* size */
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.writeChannelLimit:J
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.maxTime:J
            lload 6 /* now */
            invokevirtual io.netty.handler.traffic.TrafficCounter.writeTimeToWait:(JJJJ)J
            lstore 12 /* wait */
         9: .line 666
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.writeDeviationActive:Z
            ifeq 17
        10: .line 669
            aload 11 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.channelTrafficCounter:Lio/netty/handler/traffic/TrafficCounter;
            invokevirtual io.netty.handler.traffic.TrafficCounter.cumulativeWrittenBytes:()J
            lstore 14 /* maxLocalWrite */
        start local 14 // long maxLocalWrite
        11: .line 670
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.cumulativeWrittenBytes:Ljava/util/concurrent/atomic/AtomicLong;
            invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
            lstore 16 /* maxGlobalWrite */
        start local 16 // long maxGlobalWrite
        12: .line 671
            lload 14 /* maxLocalWrite */
            lconst_0
            lcmp
            ifgt 14
        13: .line 672
            lconst_0
            lstore 14 /* maxLocalWrite */
        14: .line 674
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler io.netty.channel.ChannelHandlerContext java.lang.Object io.netty.channel.ChannelPromise long long long java.lang.Integer io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel long long long
      StackMap stack:
            lload 16 /* maxGlobalWrite */
            lload 14 /* maxLocalWrite */
            lcmp
            ifge 16
        15: .line 675
            lload 14 /* maxLocalWrite */
            lstore 16 /* maxGlobalWrite */
        16: .line 677
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            lload 14 /* maxLocalWrite */
            l2f
            lload 16 /* maxGlobalWrite */
            l2f
            lload 12 /* wait */
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.computeBalancedWait:(FFJ)J
            lstore 12 /* wait */
        end local 16 // long maxGlobalWrite
        end local 14 // long maxLocalWrite
        17: .line 680
      StackMap locals:
      StackMap stack:
            lload 12 /* wait */
            lload 8 /* waitGlobal */
            lcmp
            ifge 19
        18: .line 681
            lload 8 /* waitGlobal */
            lstore 12 /* wait */
        19: .line 683
      StackMap locals:
      StackMap stack:
            lload 12 /* wait */
            ldc 10
            lcmp
            iflt 26
        20: .line 684
            getstatic io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.logger:Lio/netty/util/internal/logging/InternalLogger;
            invokeinterface io.netty.util.internal.logging.InternalLogger.isDebugEnabled:()Z
            ifeq 24
        21: .line 685
            getstatic io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.logger:Lio/netty/util/internal/logging/InternalLogger;
            new java.lang.StringBuilder
            dup
            ldc "Write suspend: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            lload 12 /* wait */
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
            bipush 58
            invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
            invokeinterface io.netty.channel.Channel.config:()Lio/netty/channel/ChannelConfig;
            invokeinterface io.netty.channel.ChannelConfig.isAutoRead:()Z
            invokevirtual java.lang.StringBuilder.append:(Z)Ljava/lang/StringBuilder;
            bipush 58
            invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
        22: .line 686
            aload 1 /* ctx */
            invokestatic io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.isHandlerActive:(Lio/netty/channel/ChannelHandlerContext;)Z
            invokevirtual java.lang.StringBuilder.append:(Z)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
        23: .line 685
            invokeinterface io.netty.util.internal.logging.InternalLogger.debug:(Ljava/lang/String;)V
        24: .line 688
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* ctx */
            aload 2 /* msg */
            lload 4 /* size */
            lload 12 /* wait */
            lload 6 /* now */
            aload 3 /* promise */
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.submitWrite:(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;JJJLio/netty/channel/ChannelPromise;)V
        25: .line 689
            return
        end local 12 // long wait
        end local 11 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
        end local 10 // java.lang.Integer key
        end local 8 // long waitGlobal
        26: .line 693
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler io.netty.channel.ChannelHandlerContext java.lang.Object io.netty.channel.ChannelPromise long long
      StackMap stack:
            aload 0 /* this */
            aload 1 /* ctx */
            aload 2 /* msg */
            lload 4 /* size */
            lconst_0
            lload 6 /* now */
            aload 3 /* promise */
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.submitWrite:(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;JJJLio/netty/channel/ChannelPromise;)V
        27: .line 694
            return
        end local 6 // long now
        end local 4 // long size
        end local 3 // io.netty.channel.ChannelPromise promise
        end local 2 // java.lang.Object msg
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0   28     0            this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            0   28     1             ctx  Lio/netty/channel/ChannelHandlerContext;
            0   28     2             msg  Ljava/lang/Object;
            0   28     3         promise  Lio/netty/channel/ChannelPromise;
            1   28     4            size  J
            2   28     6             now  J
            4   26     8      waitGlobal  J
            5   26    10             key  Ljava/lang/Integer;
            6   26    11      perChannel  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$PerChannel;
            7   26    12            wait  J
           11   17    14   maxLocalWrite  J
           12   17    16  maxGlobalWrite  J
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
         Name  Flags
      ctx      final
      msg      final
      promise  final

  protected void submitWrite(io.netty.channel.ChannelHandlerContext, java.lang.Object, long, long, long, io.netty.channel.ChannelPromise);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;JJJLio/netty/channel/ChannelPromise;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=8, locals=20, args_size=7
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // java.lang.Object msg
        start local 3 // long size
        start local 5 // long writedelay
        start local 7 // long now
        start local 9 // io.netty.channel.ChannelPromise promise
         0: .line 700
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
            astore 10 /* channel */
        start local 10 // io.netty.channel.Channel channel
         1: .line 701
            aload 10 /* channel */
            invokevirtual java.lang.Object.hashCode:()I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            astore 11 /* key */
        start local 11 // java.lang.Integer key
         2: .line 702
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.channelQueues:Ljava/util/concurrent/ConcurrentMap;
            aload 11 /* key */
            invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel
            astore 12 /* perChannel */
        start local 12 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
         3: .line 703
            aload 12 /* perChannel */
            ifnonnull 5
         4: .line 706
            aload 0 /* this */
            aload 1 /* ctx */
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.getOrSetPerChannel:(Lio/netty/channel/ChannelHandlerContext;)Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$PerChannel;
            astore 12 /* perChannel */
         5: .line 709
      StackMap locals: io.netty.channel.Channel java.lang.Integer io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel
      StackMap stack:
            lload 5 /* writedelay */
            lstore 14 /* delay */
        start local 14 // long delay
         6: .line 710
            iconst_0
            istore 16 /* globalSizeExceeded */
        start local 16 // boolean globalSizeExceeded
         7: .line 712
            aload 12 /* perChannel */
            dup
            astore 17
            monitorenter
         8: .line 713
            lload 5 /* writedelay */
            lconst_0
            lcmp
            ifne 15
            aload 12 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.messagesQueue:Ljava/util/ArrayDeque;
            invokevirtual java.util.ArrayDeque.isEmpty:()Z
            ifeq 15
         9: .line 714
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.trafficCounter:Lio/netty/handler/traffic/TrafficCounter;
            lload 3 /* size */
            invokevirtual io.netty.handler.traffic.TrafficCounter.bytesRealWriteFlowControl:(J)V
        10: .line 715
            aload 12 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.channelTrafficCounter:Lio/netty/handler/traffic/TrafficCounter;
            lload 3 /* size */
            invokevirtual io.netty.handler.traffic.TrafficCounter.bytesRealWriteFlowControl:(J)V
        11: .line 716
            aload 1 /* ctx */
            aload 2 /* msg */
            aload 9 /* promise */
            invokeinterface io.netty.channel.ChannelHandlerContext.write:(Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
            pop
        12: .line 717
            aload 12 /* perChannel */
            lload 7 /* now */
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.lastWriteTimestamp:J
        13: .line 718
            aload 17
            monitorexit
        14: return
        15: .line 720
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler io.netty.channel.ChannelHandlerContext java.lang.Object long long long io.netty.channel.ChannelPromise io.netty.channel.Channel java.lang.Integer io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel top long int io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel
      StackMap stack:
            lload 14 /* delay */
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.maxTime:J
            lcmp
            ifle 17
            lload 7 /* now */
            lload 14 /* delay */
            ladd
            aload 12 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.lastWriteTimestamp:J
            lsub
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.maxTime:J
            lcmp
            ifle 17
        16: .line 721
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.maxTime:J
            lstore 14 /* delay */
        17: .line 723
      StackMap locals:
      StackMap stack:
            new io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend
            dup
            lload 14 /* delay */
            lload 7 /* now */
            ladd
            aload 2 /* msg */
            lload 3 /* size */
            aload 9 /* promise */
            invokespecial io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend.<init>:(JLjava/lang/Object;JLio/netty/channel/ChannelPromise;)V
            astore 13 /* newToSend */
        start local 13 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend newToSend
        18: .line 724
            aload 12 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.messagesQueue:Ljava/util/ArrayDeque;
            aload 13 /* newToSend */
            invokevirtual java.util.ArrayDeque.addLast:(Ljava/lang/Object;)V
        19: .line 725
            aload 12 /* perChannel */
            dup
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.queueSize:J
            lload 3 /* size */
            ladd
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.queueSize:J
        20: .line 726
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.queuesSize:Ljava/util/concurrent/atomic/AtomicLong;
            lload 3 /* size */
            invokevirtual java.util.concurrent.atomic.AtomicLong.addAndGet:(J)J
            pop2
        21: .line 727
            aload 0 /* this */
            aload 1 /* ctx */
            lload 14 /* delay */
            aload 12 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.queueSize:J
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.checkWriteSuspend:(Lio/netty/channel/ChannelHandlerContext;JJ)V
        22: .line 728
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.queuesSize:Ljava/util/concurrent/atomic/AtomicLong;
            invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.maxGlobalWriteSize:J
            lcmp
            ifle 24
        23: .line 729
            iconst_1
            istore 16 /* globalSizeExceeded */
        24: .line 712
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler io.netty.channel.ChannelHandlerContext java.lang.Object long long long io.netty.channel.ChannelPromise io.netty.channel.Channel java.lang.Integer io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend long int io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel
      StackMap stack:
            aload 17
            monitorexit
        25: goto 28
        end local 13 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend newToSend
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler io.netty.channel.ChannelHandlerContext java.lang.Object long long long io.netty.channel.ChannelPromise io.netty.channel.Channel java.lang.Integer io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel top long int io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel
      StackMap stack: java.lang.Throwable
        26: aload 17
            monitorexit
        27: athrow
        start local 13 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend newToSend
        28: .line 732
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler io.netty.channel.ChannelHandlerContext java.lang.Object long long long io.netty.channel.ChannelPromise io.netty.channel.Channel java.lang.Integer io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend long int
      StackMap stack:
            iload 16 /* globalSizeExceeded */
            ifeq 30
        29: .line 733
            aload 0 /* this */
            aload 1 /* ctx */
            iconst_0
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.setUserDefinedWritability:(Lio/netty/channel/ChannelHandlerContext;Z)V
        30: .line 735
      StackMap locals:
      StackMap stack:
            aload 13 /* newToSend */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend.relativeTimeAction:J
            lstore 17 /* futureNow */
        start local 17 // long futureNow
        31: .line 736
            aload 12 /* perChannel */
            astore 19 /* forSchedule */
        start local 19 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel forSchedule
        32: .line 737
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.executor:()Lio/netty/util/concurrent/EventExecutor;
            new io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$2
            dup
            aload 0 /* this */
            aload 1 /* ctx */
            aload 19 /* forSchedule */
            lload 17 /* futureNow */
            invokespecial io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$2.<init>:(Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;Lio/netty/channel/ChannelHandlerContext;Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$PerChannel;J)V
        33: .line 742
            lload 14 /* delay */
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
        34: .line 737
            invokeinterface io.netty.util.concurrent.EventExecutor.schedule:(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lio/netty/util/concurrent/ScheduledFuture;
            pop
        35: .line 743
            return
        end local 19 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel forSchedule
        end local 17 // long futureNow
        end local 16 // boolean globalSizeExceeded
        end local 14 // long delay
        end local 13 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend newToSend
        end local 12 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
        end local 11 // java.lang.Integer key
        end local 10 // io.netty.channel.Channel channel
        end local 9 // io.netty.channel.ChannelPromise promise
        end local 7 // long now
        end local 5 // long writedelay
        end local 3 // long size
        end local 2 // java.lang.Object msg
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0   36     0                this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            0   36     1                 ctx  Lio/netty/channel/ChannelHandlerContext;
            0   36     2                 msg  Ljava/lang/Object;
            0   36     3                size  J
            0   36     5          writedelay  J
            0   36     7                 now  J
            0   36     9             promise  Lio/netty/channel/ChannelPromise;
            1   36    10             channel  Lio/netty/channel/Channel;
            2   36    11                 key  Ljava/lang/Integer;
            3   36    12          perChannel  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$PerChannel;
           18   26    13           newToSend  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$ToSend;
           28   36    13           newToSend  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$ToSend;
            6   36    14               delay  J
            7   36    16  globalSizeExceeded  Z
           31   36    17           futureNow  J
           32   36    19         forSchedule  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$PerChannel;
      Exception table:
        from    to  target  type
           8    14      26  any
          15    25      26  any
          26    27      26  any
    MethodParameters:
            Name  Flags
      ctx         final
      msg         final
      size        final
      writedelay  final
      now         final
      promise     final

  private void sendAllValid(io.netty.channel.ChannelHandlerContext, io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel, long);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$PerChannel;J)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=9, args_size=4
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
        start local 3 // long now
         0: .line 747
            aload 2 /* perChannel */
            dup
            astore 5
            monitorenter
         1: .line 748
            aload 2 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.messagesQueue:Ljava/util/ArrayDeque;
            invokevirtual java.util.ArrayDeque.pollFirst:()Ljava/lang/Object;
            checkcast io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend
            astore 6 /* newToSend */
        start local 6 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend newToSend
         2: .line 749
            goto 15
         3: .line 750
      StackMap locals: io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend
      StackMap stack:
            aload 6 /* newToSend */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend.relativeTimeAction:J
            lload 3 /* now */
            lcmp
            ifgt 12
         4: .line 751
            aload 6 /* newToSend */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend.size:J
            lstore 7 /* size */
        start local 7 // long size
         5: .line 752
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.trafficCounter:Lio/netty/handler/traffic/TrafficCounter;
            lload 7 /* size */
            invokevirtual io.netty.handler.traffic.TrafficCounter.bytesRealWriteFlowControl:(J)V
         6: .line 753
            aload 2 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.channelTrafficCounter:Lio/netty/handler/traffic/TrafficCounter;
            lload 7 /* size */
            invokevirtual io.netty.handler.traffic.TrafficCounter.bytesRealWriteFlowControl:(J)V
         7: .line 754
            aload 2 /* perChannel */
            dup
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.queueSize:J
            lload 7 /* size */
            lsub
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.queueSize:J
         8: .line 755
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.queuesSize:Ljava/util/concurrent/atomic/AtomicLong;
            lload 7 /* size */
            lneg
            invokevirtual java.util.concurrent.atomic.AtomicLong.addAndGet:(J)J
            pop2
         9: .line 756
            aload 1 /* ctx */
            aload 6 /* newToSend */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend.toSend:Ljava/lang/Object;
            aload 6 /* newToSend */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend.promise:Lio/netty/channel/ChannelPromise;
            invokeinterface io.netty.channel.ChannelHandlerContext.write:(Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
            pop
        10: .line 757
            aload 2 /* perChannel */
            lload 3 /* now */
            putfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.lastWriteTimestamp:J
        end local 7 // long size
        11: .line 758
            goto 14
        12: .line 759
      StackMap locals:
      StackMap stack:
            aload 2 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.messagesQueue:Ljava/util/ArrayDeque;
            aload 6 /* newToSend */
            invokevirtual java.util.ArrayDeque.addFirst:(Ljava/lang/Object;)V
        13: .line 760
            goto 16
        14: .line 749
      StackMap locals:
      StackMap stack:
            aload 2 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.messagesQueue:Ljava/util/ArrayDeque;
            invokevirtual java.util.ArrayDeque.pollFirst:()Ljava/lang/Object;
            checkcast io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend
            astore 6 /* newToSend */
      StackMap locals:
      StackMap stack:
        15: aload 6 /* newToSend */
            ifnonnull 3
        16: .line 763
      StackMap locals:
      StackMap stack:
            aload 2 /* perChannel */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel.messagesQueue:Ljava/util/ArrayDeque;
            invokevirtual java.util.ArrayDeque.isEmpty:()Z
            ifeq 18
        17: .line 764
            aload 0 /* this */
            aload 1 /* ctx */
            invokevirtual io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.releaseWriteSuspended:(Lio/netty/channel/ChannelHandlerContext;)V
        end local 6 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend newToSend
        18: .line 747
      StackMap locals:
      StackMap stack:
            aload 5
            monitorexit
        19: goto 22
      StackMap locals:
      StackMap stack: java.lang.Throwable
        20: aload 5
            monitorexit
        21: athrow
        22: .line 767
      StackMap locals:
      StackMap stack:
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.flush:()Lio/netty/channel/ChannelHandlerContext;
            pop
        23: .line 768
            return
        end local 3 // long now
        end local 2 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel perChannel
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   24     0        this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
            0   24     1         ctx  Lio/netty/channel/ChannelHandlerContext;
            0   24     2  perChannel  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$PerChannel;
            0   24     3         now  J
            2   18     6   newToSend  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler$ToSend;
            5   11     7        size  J
      Exception table:
        from    to  target  type
           1    19      20  any
          20    21      20  any
    MethodParameters:
            Name  Flags
      ctx         final
      perChannel  final
      now         final

  public java.lang.String toString();
    descriptor: ()Ljava/lang/String;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
         0: .line 772
            new java.lang.StringBuilder
            dup
            sipush 340
            invokespecial java.lang.StringBuilder.<init>:(I)V
            aload 0 /* this */
            invokespecial io.netty.handler.traffic.AbstractTrafficShapingHandler.toString:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         1: .line 773
            ldc " Write Channel Limit: "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.writeChannelLimit:J
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
         2: .line 774
            ldc " Read Channel Limit: "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* this */
            getfield io.netty.handler.traffic.GlobalChannelTrafficShapingHandler.readChannelLimit:J
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         3: .line 772
            areturn
        end local 0 // io.netty.handler.traffic.GlobalChannelTrafficShapingHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lio/netty/handler/traffic/GlobalChannelTrafficShapingHandler;
}
SourceFile: "GlobalChannelTrafficShapingHandler.java"
NestMembers:
  io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$1  io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$1$1  io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$2  io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel  io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend
InnerClasses:
  public abstract Sharable = io.netty.channel.ChannelHandler$Sharable of io.netty.channel.ChannelHandler
  final ReopenReadTimerTask = io.netty.handler.traffic.AbstractTrafficShapingHandler$ReopenReadTimerTask of io.netty.handler.traffic.AbstractTrafficShapingHandler
  io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$1
  io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$2
  final PerChannel = io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$PerChannel of io.netty.handler.traffic.GlobalChannelTrafficShapingHandler
  private final ToSend = io.netty.handler.traffic.GlobalChannelTrafficShapingHandler$ToSend of io.netty.handler.traffic.GlobalChannelTrafficShapingHandler
    RuntimeVisibleAnnotations: 
      io.netty.channel.ChannelHandler$Sharable()