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 final class io.netty.channel.ChannelOutboundBuffer
  minor version: 0
  major version: 59
  flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
  this_class: io.netty.channel.ChannelOutboundBuffer
  super_class: java.lang.Object
{
  static final int CHANNEL_OUTBOUND_BUFFER_ENTRY_OVERHEAD;
    descriptor: I
    flags: (0x0018) ACC_STATIC, ACC_FINAL

  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

  private static final io.netty.util.concurrent.FastThreadLocal<java.nio.ByteBuffer[]> NIO_BUFFERS;
    descriptor: Lio/netty/util/concurrent/FastThreadLocal;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    Signature: Lio/netty/util/concurrent/FastThreadLocal<[Ljava/nio/ByteBuffer;>;

  private final io.netty.channel.Channel channel;
    descriptor: Lio/netty/channel/Channel;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private io.netty.channel.ChannelOutboundBuffer$Entry flushedEntry;
    descriptor: Lio/netty/channel/ChannelOutboundBuffer$Entry;
    flags: (0x0002) ACC_PRIVATE

  private io.netty.channel.ChannelOutboundBuffer$Entry unflushedEntry;
    descriptor: Lio/netty/channel/ChannelOutboundBuffer$Entry;
    flags: (0x0002) ACC_PRIVATE

  private io.netty.channel.ChannelOutboundBuffer$Entry tailEntry;
    descriptor: Lio/netty/channel/ChannelOutboundBuffer$Entry;
    flags: (0x0002) ACC_PRIVATE

  private int flushed;
    descriptor: I
    flags: (0x0002) ACC_PRIVATE

  private int nioBufferCount;
    descriptor: I
    flags: (0x0002) ACC_PRIVATE

  private long nioBufferSize;
    descriptor: J
    flags: (0x0002) ACC_PRIVATE

  private boolean inFail;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  private static final java.util.concurrent.atomic.AtomicLongFieldUpdater<io.netty.channel.ChannelOutboundBuffer> TOTAL_PENDING_SIZE_UPDATER;
    descriptor: Ljava/util/concurrent/atomic/AtomicLongFieldUpdater;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    Signature: Ljava/util/concurrent/atomic/AtomicLongFieldUpdater<Lio/netty/channel/ChannelOutboundBuffer;>;

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

  private static final java.util.concurrent.atomic.AtomicIntegerFieldUpdater<io.netty.channel.ChannelOutboundBuffer> UNWRITABLE_UPDATER;
    descriptor: Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    Signature: Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater<Lio/netty/channel/ChannelOutboundBuffer;>;

  private volatile int unwritable;
    descriptor: I
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private volatile java.lang.Runnable fireChannelWritabilityChangedTask;
    descriptor: Ljava/lang/Runnable;
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  static final boolean $assertionsDisabled;
    descriptor: Z
    flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=2, locals=0, args_size=0
         0: .line 52
            ldc Lio/netty/channel/ChannelOutboundBuffer;
            invokevirtual java.lang.Class.desiredAssertionStatus:()Z
            ifne 1
            iconst_1
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
      StackMap locals:
      StackMap stack: int
         2: putstatic io.netty.channel.ChannelOutboundBuffer.$assertionsDisabled:Z
         3: .line 61
            ldc "io.netty.transport.outboundBufferEntrySizeOverhead"
            bipush 96
            invokestatic io.netty.util.internal.SystemPropertyUtil.getInt:(Ljava/lang/String;I)I
         4: .line 60
            putstatic io.netty.channel.ChannelOutboundBuffer.CHANNEL_OUTBOUND_BUFFER_ENTRY_OVERHEAD:I
         5: .line 63
            ldc Lio/netty/channel/ChannelOutboundBuffer;
            invokestatic io.netty.util.internal.logging.InternalLoggerFactory.getInstance:(Ljava/lang/Class;)Lio/netty/util/internal/logging/InternalLogger;
            putstatic io.netty.channel.ChannelOutboundBuffer.logger:Lio/netty/util/internal/logging/InternalLogger;
         6: .line 65
            new io.netty.channel.ChannelOutboundBuffer$1
            dup
            invokespecial io.netty.channel.ChannelOutboundBuffer$1.<init>:()V
            putstatic io.netty.channel.ChannelOutboundBuffer.NIO_BUFFERS:Lio/netty/util/concurrent/FastThreadLocal;
         7: .line 91
            ldc Lio/netty/channel/ChannelOutboundBuffer;
            ldc "totalPendingSize"
            invokestatic java.util.concurrent.atomic.AtomicLongFieldUpdater.newUpdater:(Ljava/lang/Class;Ljava/lang/String;)Ljava/util/concurrent/atomic/AtomicLongFieldUpdater;
         8: .line 90
            putstatic io.netty.channel.ChannelOutboundBuffer.TOTAL_PENDING_SIZE_UPDATER:Ljava/util/concurrent/atomic/AtomicLongFieldUpdater;
         9: .line 97
            ldc Lio/netty/channel/ChannelOutboundBuffer;
            ldc "unwritable"
            invokestatic java.util.concurrent.atomic.AtomicIntegerFieldUpdater.newUpdater:(Ljava/lang/Class;Ljava/lang/String;)Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
        10: .line 96
            putstatic io.netty.channel.ChannelOutboundBuffer.UNWRITABLE_UPDATER:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
        11: .line 97
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  void <init>(io.netty.channel.AbstractChannel);
    descriptor: (Lio/netty/channel/AbstractChannel;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // io.netty.channel.AbstractChannel channel
         0: .line 104
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 105
            aload 0 /* this */
            aload 1 /* channel */
            putfield io.netty.channel.ChannelOutboundBuffer.channel:Lio/netty/channel/Channel;
         2: .line 106
            return
        end local 1 // io.netty.channel.AbstractChannel channel
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/netty/channel/ChannelOutboundBuffer;
            0    3     1  channel  Lio/netty/channel/AbstractChannel;
    MethodParameters:
         Name  Flags
      channel  

  public void addMessage(java.lang.Object, int, io.netty.channel.ChannelPromise);
    descriptor: (Ljava/lang/Object;ILio/netty/channel/ChannelPromise;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=6, args_size=4
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // java.lang.Object msg
        start local 2 // int size
        start local 3 // io.netty.channel.ChannelPromise promise
         0: .line 113
            aload 1 /* msg */
            iload 2 /* size */
            aload 1 /* msg */
            invokestatic io.netty.channel.ChannelOutboundBuffer.total:(Ljava/lang/Object;)J
            aload 3 /* promise */
            invokestatic io.netty.channel.ChannelOutboundBuffer$Entry.newInstance:(Ljava/lang/Object;IJLio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelOutboundBuffer$Entry;
            astore 4 /* entry */
        start local 4 // io.netty.channel.ChannelOutboundBuffer$Entry entry
         1: .line 114
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.tailEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
            ifnonnull 4
         2: .line 115
            aload 0 /* this */
            aconst_null
            putfield io.netty.channel.ChannelOutboundBuffer.flushedEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
         3: .line 116
            goto 6
         4: .line 117
      StackMap locals: io.netty.channel.ChannelOutboundBuffer$Entry
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.tailEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
            astore 5 /* tail */
        start local 5 // io.netty.channel.ChannelOutboundBuffer$Entry tail
         5: .line 118
            aload 5 /* tail */
            aload 4 /* entry */
            putfield io.netty.channel.ChannelOutboundBuffer$Entry.next:Lio/netty/channel/ChannelOutboundBuffer$Entry;
        end local 5 // io.netty.channel.ChannelOutboundBuffer$Entry tail
         6: .line 120
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 4 /* entry */
            putfield io.netty.channel.ChannelOutboundBuffer.tailEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
         7: .line 121
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.unflushedEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
            ifnonnull 9
         8: .line 122
            aload 0 /* this */
            aload 4 /* entry */
            putfield io.netty.channel.ChannelOutboundBuffer.unflushedEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
         9: .line 127
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 4 /* entry */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.pendingSize:I
            i2l
            iconst_0
            invokevirtual io.netty.channel.ChannelOutboundBuffer.incrementPendingOutboundBytes:(JZ)V
        10: .line 128
            return
        end local 4 // io.netty.channel.ChannelOutboundBuffer$Entry entry
        end local 3 // io.netty.channel.ChannelPromise promise
        end local 2 // int size
        end local 1 // java.lang.Object msg
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   11     0     this  Lio/netty/channel/ChannelOutboundBuffer;
            0   11     1      msg  Ljava/lang/Object;
            0   11     2     size  I
            0   11     3  promise  Lio/netty/channel/ChannelPromise;
            1   11     4    entry  Lio/netty/channel/ChannelOutboundBuffer$Entry;
            5    6     5     tail  Lio/netty/channel/ChannelOutboundBuffer$Entry;
    MethodParameters:
         Name  Flags
      msg      
      size     
      promise  

  public void addFlush();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=3, args_size=1
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
         0: .line 139
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.unflushedEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
            astore 1 /* entry */
        start local 1 // io.netty.channel.ChannelOutboundBuffer$Entry entry
         1: .line 140
            aload 1 /* entry */
            ifnull 11
         2: .line 141
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.flushedEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
            ifnonnull 4
         3: .line 143
            aload 0 /* this */
            aload 1 /* entry */
            putfield io.netty.channel.ChannelOutboundBuffer.flushedEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
         4: .line 146
      StackMap locals: io.netty.channel.ChannelOutboundBuffer$Entry
      StackMap stack:
            aload 0 /* this */
            dup
            getfield io.netty.channel.ChannelOutboundBuffer.flushed:I
            iconst_1
            iadd
            putfield io.netty.channel.ChannelOutboundBuffer.flushed:I
         5: .line 147
            aload 1 /* entry */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.promise:Lio/netty/channel/ChannelPromise;
            invokeinterface io.netty.channel.ChannelPromise.setUncancellable:()Z
            ifne 8
         6: .line 149
            aload 1 /* entry */
            invokevirtual io.netty.channel.ChannelOutboundBuffer$Entry.cancel:()I
            istore 2 /* pending */
        start local 2 // int pending
         7: .line 150
            aload 0 /* this */
            iload 2 /* pending */
            i2l
            iconst_0
            iconst_1
            invokevirtual io.netty.channel.ChannelOutboundBuffer.decrementPendingOutboundBytes:(JZZ)V
        end local 2 // int pending
         8: .line 152
      StackMap locals:
      StackMap stack:
            aload 1 /* entry */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.next:Lio/netty/channel/ChannelOutboundBuffer$Entry;
            astore 1 /* entry */
         9: .line 153
            aload 1 /* entry */
            ifnonnull 4
        10: .line 156
            aload 0 /* this */
            aconst_null
            putfield io.netty.channel.ChannelOutboundBuffer.unflushedEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
        11: .line 158
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.netty.channel.ChannelOutboundBuffer$Entry entry
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   12     0     this  Lio/netty/channel/ChannelOutboundBuffer;
            1   12     1    entry  Lio/netty/channel/ChannelOutboundBuffer$Entry;
            7    8     2  pending  I

  void incrementPendingOutboundBytes(long);
    descriptor: (J)V
    flags: (0x0000) 
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // long size
         0: .line 165
            aload 0 /* this */
            lload 1 /* size */
            iconst_1
            invokevirtual io.netty.channel.ChannelOutboundBuffer.incrementPendingOutboundBytes:(JZ)V
         1: .line 166
            return
        end local 1 // long size
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/netty/channel/ChannelOutboundBuffer;
            0    2     1  size  J
    MethodParameters:
      Name  Flags
      size  

  private void incrementPendingOutboundBytes(long, boolean);
    descriptor: (JZ)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=6, args_size=3
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // long size
        start local 3 // boolean invokeLater
         0: .line 169
            lload 1 /* size */
            lconst_0
            lcmp
            ifne 2
         1: .line 170
            return
         2: .line 173
      StackMap locals:
      StackMap stack:
            getstatic io.netty.channel.ChannelOutboundBuffer.TOTAL_PENDING_SIZE_UPDATER:Ljava/util/concurrent/atomic/AtomicLongFieldUpdater;
            aload 0 /* this */
            lload 1 /* size */
            invokevirtual java.util.concurrent.atomic.AtomicLongFieldUpdater.addAndGet:(Ljava/lang/Object;J)J
            lstore 4 /* newWriteBufferSize */
        start local 4 // long newWriteBufferSize
         3: .line 174
            lload 4 /* newWriteBufferSize */
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.channel:Lio/netty/channel/Channel;
            invokeinterface io.netty.channel.Channel.config:()Lio/netty/channel/ChannelConfig;
            invokeinterface io.netty.channel.ChannelConfig.getWriteBufferHighWaterMark:()I
            i2l
            lcmp
            ifle 5
         4: .line 175
            aload 0 /* this */
            iload 3 /* invokeLater */
            invokevirtual io.netty.channel.ChannelOutboundBuffer.setUnwritable:(Z)V
         5: .line 177
      StackMap locals: long
      StackMap stack:
            return
        end local 4 // long newWriteBufferSize
        end local 3 // boolean invokeLater
        end local 1 // long size
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    6     0                this  Lio/netty/channel/ChannelOutboundBuffer;
            0    6     1                size  J
            0    6     3         invokeLater  Z
            3    6     4  newWriteBufferSize  J
    MethodParameters:
             Name  Flags
      size         
      invokeLater  

  void decrementPendingOutboundBytes(long);
    descriptor: (J)V
    flags: (0x0000) 
    Code:
      stack=5, locals=3, args_size=2
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // long size
         0: .line 184
            aload 0 /* this */
            lload 1 /* size */
            iconst_1
            iconst_1
            invokevirtual io.netty.channel.ChannelOutboundBuffer.decrementPendingOutboundBytes:(JZZ)V
         1: .line 185
            return
        end local 1 // long size
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/netty/channel/ChannelOutboundBuffer;
            0    2     1  size  J
    MethodParameters:
      Name  Flags
      size  

  private void decrementPendingOutboundBytes(long, boolean, boolean);
    descriptor: (JZZ)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=7, args_size=4
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // long size
        start local 3 // boolean invokeLater
        start local 4 // boolean notifyWritability
         0: .line 188
            lload 1 /* size */
            lconst_0
            lcmp
            ifne 2
         1: .line 189
            return
         2: .line 192
      StackMap locals:
      StackMap stack:
            getstatic io.netty.channel.ChannelOutboundBuffer.TOTAL_PENDING_SIZE_UPDATER:Ljava/util/concurrent/atomic/AtomicLongFieldUpdater;
            aload 0 /* this */
            lload 1 /* size */
            lneg
            invokevirtual java.util.concurrent.atomic.AtomicLongFieldUpdater.addAndGet:(Ljava/lang/Object;J)J
            lstore 5 /* newWriteBufferSize */
        start local 5 // long newWriteBufferSize
         3: .line 193
            iload 4 /* notifyWritability */
            ifeq 5
            lload 5 /* newWriteBufferSize */
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.channel:Lio/netty/channel/Channel;
            invokeinterface io.netty.channel.Channel.config:()Lio/netty/channel/ChannelConfig;
            invokeinterface io.netty.channel.ChannelConfig.getWriteBufferLowWaterMark:()I
            i2l
            lcmp
            ifge 5
         4: .line 194
            aload 0 /* this */
            iload 3 /* invokeLater */
            invokevirtual io.netty.channel.ChannelOutboundBuffer.setWritable:(Z)V
         5: .line 196
      StackMap locals: long
      StackMap stack:
            return
        end local 5 // long newWriteBufferSize
        end local 4 // boolean notifyWritability
        end local 3 // boolean invokeLater
        end local 1 // long size
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    6     0                this  Lio/netty/channel/ChannelOutboundBuffer;
            0    6     1                size  J
            0    6     3         invokeLater  Z
            0    6     4   notifyWritability  Z
            3    6     5  newWriteBufferSize  J
    MethodParameters:
                   Name  Flags
      size               
      invokeLater        
      notifyWritability  

  private static long total(java.lang.Object);
    descriptor: (Ljava/lang/Object;)J
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.lang.Object msg
         0: .line 199
            aload 0 /* msg */
            instanceof io.netty.buffer.ByteBuf
            ifeq 2
         1: .line 200
            aload 0 /* msg */
            checkcast io.netty.buffer.ByteBuf
            invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
            i2l
            lreturn
         2: .line 202
      StackMap locals:
      StackMap stack:
            aload 0 /* msg */
            instanceof io.netty.channel.FileRegion
            ifeq 4
         3: .line 203
            aload 0 /* msg */
            checkcast io.netty.channel.FileRegion
            invokeinterface io.netty.channel.FileRegion.count:()J
            lreturn
         4: .line 205
      StackMap locals:
      StackMap stack:
            aload 0 /* msg */
            instanceof io.netty.buffer.ByteBufHolder
            ifeq 6
         5: .line 206
            aload 0 /* msg */
            checkcast io.netty.buffer.ByteBufHolder
            invokeinterface io.netty.buffer.ByteBufHolder.content:()Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
            i2l
            lreturn
         6: .line 208
      StackMap locals:
      StackMap stack:
            ldc -1
            lreturn
        end local 0 // java.lang.Object msg
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0   msg  Ljava/lang/Object;
    MethodParameters:
      Name  Flags
      msg   

  public java.lang.Object current();
    descriptor: ()Ljava/lang/Object;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=2, args_size=1
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
         0: .line 215
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.flushedEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
            astore 1 /* entry */
        start local 1 // io.netty.channel.ChannelOutboundBuffer$Entry entry
         1: .line 216
            aload 1 /* entry */
            ifnonnull 3
         2: .line 217
            aconst_null
            areturn
         3: .line 220
      StackMap locals: io.netty.channel.ChannelOutboundBuffer$Entry
      StackMap stack:
            aload 1 /* entry */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.msg:Ljava/lang/Object;
            areturn
        end local 1 // io.netty.channel.ChannelOutboundBuffer$Entry entry
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    4     0   this  Lio/netty/channel/ChannelOutboundBuffer;
            1    4     1  entry  Lio/netty/channel/ChannelOutboundBuffer$Entry;

  public void progress(long);
    descriptor: (J)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=7, args_size=2
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // long amount
         0: .line 227
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.flushedEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
            astore 3 /* e */
        start local 3 // io.netty.channel.ChannelOutboundBuffer$Entry e
         1: .line 228
            getstatic io.netty.channel.ChannelOutboundBuffer.$assertionsDisabled:Z
            ifne 2
            aload 3 /* e */
            ifnonnull 2
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         2: .line 229
      StackMap locals: io.netty.channel.ChannelOutboundBuffer$Entry
      StackMap stack:
            aload 3 /* e */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.promise:Lio/netty/channel/ChannelPromise;
            astore 4 /* p */
        start local 4 // io.netty.channel.ChannelPromise p
         3: .line 230
            aload 4 /* p */
            instanceof io.netty.channel.ChannelProgressivePromise
            ifeq 7
         4: .line 231
            aload 3 /* e */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.progress:J
            lload 1 /* amount */
            ladd
            lstore 5 /* progress */
        start local 5 // long progress
         5: .line 232
            aload 3 /* e */
            lload 5 /* progress */
            putfield io.netty.channel.ChannelOutboundBuffer$Entry.progress:J
         6: .line 233
            aload 4 /* p */
            checkcast io.netty.channel.ChannelProgressivePromise
            lload 5 /* progress */
            aload 3 /* e */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.total:J
            invokeinterface io.netty.channel.ChannelProgressivePromise.tryProgress:(JJ)Z
            pop
        end local 5 // long progress
         7: .line 235
      StackMap locals: io.netty.channel.ChannelPromise
      StackMap stack:
            return
        end local 4 // io.netty.channel.ChannelPromise p
        end local 3 // io.netty.channel.ChannelOutboundBuffer$Entry e
        end local 1 // long amount
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    8     0      this  Lio/netty/channel/ChannelOutboundBuffer;
            0    8     1    amount  J
            1    8     3         e  Lio/netty/channel/ChannelOutboundBuffer$Entry;
            3    8     4         p  Lio/netty/channel/ChannelPromise;
            5    7     5  progress  J
    MethodParameters:
        Name  Flags
      amount  

  public boolean remove();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=1
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
         0: .line 243
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.flushedEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
            astore 1 /* e */
        start local 1 // io.netty.channel.ChannelOutboundBuffer$Entry e
         1: .line 244
            aload 1 /* e */
            ifnonnull 4
         2: .line 245
            aload 0 /* this */
            invokevirtual io.netty.channel.ChannelOutboundBuffer.clearNioBuffers:()V
         3: .line 246
            iconst_0
            ireturn
         4: .line 248
      StackMap locals: io.netty.channel.ChannelOutboundBuffer$Entry
      StackMap stack:
            aload 1 /* e */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.msg:Ljava/lang/Object;
            astore 2 /* msg */
        start local 2 // java.lang.Object msg
         5: .line 250
            aload 1 /* e */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.promise:Lio/netty/channel/ChannelPromise;
            astore 3 /* promise */
        start local 3 // io.netty.channel.ChannelPromise promise
         6: .line 251
            aload 1 /* e */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.pendingSize:I
            istore 4 /* size */
        start local 4 // int size
         7: .line 253
            aload 0 /* this */
            aload 1 /* e */
            invokevirtual io.netty.channel.ChannelOutboundBuffer.removeEntry:(Lio/netty/channel/ChannelOutboundBuffer$Entry;)V
         8: .line 255
            aload 1 /* e */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.cancelled:Z
            ifne 12
         9: .line 257
            aload 2 /* msg */
            invokestatic io.netty.util.ReferenceCountUtil.safeRelease:(Ljava/lang/Object;)V
        10: .line 258
            aload 3 /* promise */
            invokestatic io.netty.channel.ChannelOutboundBuffer.safeSuccess:(Lio/netty/channel/ChannelPromise;)V
        11: .line 259
            aload 0 /* this */
            iload 4 /* size */
            i2l
            iconst_0
            iconst_1
            invokevirtual io.netty.channel.ChannelOutboundBuffer.decrementPendingOutboundBytes:(JZZ)V
        12: .line 263
      StackMap locals: java.lang.Object io.netty.channel.ChannelPromise int
      StackMap stack:
            aload 1 /* e */
            invokevirtual io.netty.channel.ChannelOutboundBuffer$Entry.recycle:()V
        13: .line 265
            iconst_1
            ireturn
        end local 4 // int size
        end local 3 // io.netty.channel.ChannelPromise promise
        end local 2 // java.lang.Object msg
        end local 1 // io.netty.channel.ChannelOutboundBuffer$Entry e
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   14     0     this  Lio/netty/channel/ChannelOutboundBuffer;
            1   14     1        e  Lio/netty/channel/ChannelOutboundBuffer$Entry;
            5   14     2      msg  Ljava/lang/Object;
            6   14     3  promise  Lio/netty/channel/ChannelPromise;
            7   14     4     size  I

  public boolean remove(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // java.lang.Throwable cause
         0: .line 274
            aload 0 /* this */
            aload 1 /* cause */
            iconst_1
            invokevirtual io.netty.channel.ChannelOutboundBuffer.remove0:(Ljava/lang/Throwable;Z)Z
            ireturn
        end local 1 // java.lang.Throwable cause
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0   this  Lio/netty/channel/ChannelOutboundBuffer;
            0    1     1  cause  Ljava/lang/Throwable;
    MethodParameters:
       Name  Flags
      cause  

  private boolean remove0(java.lang.Throwable, boolean);
    descriptor: (Ljava/lang/Throwable;Z)Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=7, args_size=3
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // java.lang.Throwable cause
        start local 2 // boolean notifyWritability
         0: .line 278
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.flushedEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
            astore 3 /* e */
        start local 3 // io.netty.channel.ChannelOutboundBuffer$Entry e
         1: .line 279
            aload 3 /* e */
            ifnonnull 4
         2: .line 280
            aload 0 /* this */
            invokevirtual io.netty.channel.ChannelOutboundBuffer.clearNioBuffers:()V
         3: .line 281
            iconst_0
            ireturn
         4: .line 283
      StackMap locals: io.netty.channel.ChannelOutboundBuffer$Entry
      StackMap stack:
            aload 3 /* e */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.msg:Ljava/lang/Object;
            astore 4 /* msg */
        start local 4 // java.lang.Object msg
         5: .line 285
            aload 3 /* e */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.promise:Lio/netty/channel/ChannelPromise;
            astore 5 /* promise */
        start local 5 // io.netty.channel.ChannelPromise promise
         6: .line 286
            aload 3 /* e */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.pendingSize:I
            istore 6 /* size */
        start local 6 // int size
         7: .line 288
            aload 0 /* this */
            aload 3 /* e */
            invokevirtual io.netty.channel.ChannelOutboundBuffer.removeEntry:(Lio/netty/channel/ChannelOutboundBuffer$Entry;)V
         8: .line 290
            aload 3 /* e */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.cancelled:Z
            ifne 12
         9: .line 292
            aload 4 /* msg */
            invokestatic io.netty.util.ReferenceCountUtil.safeRelease:(Ljava/lang/Object;)V
        10: .line 294
            aload 5 /* promise */
            aload 1 /* cause */
            invokestatic io.netty.channel.ChannelOutboundBuffer.safeFail:(Lio/netty/channel/ChannelPromise;Ljava/lang/Throwable;)V
        11: .line 295
            aload 0 /* this */
            iload 6 /* size */
            i2l
            iconst_0
            iload 2 /* notifyWritability */
            invokevirtual io.netty.channel.ChannelOutboundBuffer.decrementPendingOutboundBytes:(JZZ)V
        12: .line 299
      StackMap locals: java.lang.Object io.netty.channel.ChannelPromise int
      StackMap stack:
            aload 3 /* e */
            invokevirtual io.netty.channel.ChannelOutboundBuffer$Entry.recycle:()V
        13: .line 301
            iconst_1
            ireturn
        end local 6 // int size
        end local 5 // io.netty.channel.ChannelPromise promise
        end local 4 // java.lang.Object msg
        end local 3 // io.netty.channel.ChannelOutboundBuffer$Entry e
        end local 2 // boolean notifyWritability
        end local 1 // java.lang.Throwable cause
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0   14     0               this  Lio/netty/channel/ChannelOutboundBuffer;
            0   14     1              cause  Ljava/lang/Throwable;
            0   14     2  notifyWritability  Z
            1   14     3                  e  Lio/netty/channel/ChannelOutboundBuffer$Entry;
            5   14     4                msg  Ljava/lang/Object;
            6   14     5            promise  Lio/netty/channel/ChannelPromise;
            7   14     6               size  I
    MethodParameters:
                   Name  Flags
      cause              
      notifyWritability  

  private void removeEntry(io.netty.channel.ChannelOutboundBuffer$Entry);
    descriptor: (Lio/netty/channel/ChannelOutboundBuffer$Entry;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // io.netty.channel.ChannelOutboundBuffer$Entry e
         0: .line 305
            aload 0 /* this */
            dup
            getfield io.netty.channel.ChannelOutboundBuffer.flushed:I
            iconst_1
            isub
            dup_x1
            putfield io.netty.channel.ChannelOutboundBuffer.flushed:I
            ifne 6
         1: .line 307
            aload 0 /* this */
            aconst_null
            putfield io.netty.channel.ChannelOutboundBuffer.flushedEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
         2: .line 308
            aload 1 /* e */
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.tailEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
            if_acmpne 7
         3: .line 309
            aload 0 /* this */
            aconst_null
            putfield io.netty.channel.ChannelOutboundBuffer.tailEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
         4: .line 310
            aload 0 /* this */
            aconst_null
            putfield io.netty.channel.ChannelOutboundBuffer.unflushedEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
         5: .line 312
            goto 7
         6: .line 313
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* e */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.next:Lio/netty/channel/ChannelOutboundBuffer$Entry;
            putfield io.netty.channel.ChannelOutboundBuffer.flushedEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
         7: .line 315
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.netty.channel.ChannelOutboundBuffer$Entry e
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    8     0  this  Lio/netty/channel/ChannelOutboundBuffer;
            0    8     1     e  Lio/netty/channel/ChannelOutboundBuffer$Entry;
    MethodParameters:
      Name  Flags
      e     

  public void removeBytes(long);
    descriptor: (J)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=7, args_size=2
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // long writtenBytes
         0: .line 323
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.netty.channel.ChannelOutboundBuffer.current:()Ljava/lang/Object;
            astore 3 /* msg */
        start local 3 // java.lang.Object msg
         1: .line 324
            aload 3 /* msg */
            instanceof io.netty.buffer.ByteBuf
            ifne 3
         2: .line 325
            getstatic io.netty.channel.ChannelOutboundBuffer.$assertionsDisabled:Z
            ifne 15
            lload 1 /* writtenBytes */
            lconst_0
            lcmp
            ifeq 15
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         3: .line 329
      StackMap locals: java.lang.Object
      StackMap stack:
            aload 3 /* msg */
            checkcast io.netty.buffer.ByteBuf
            astore 4 /* buf */
        start local 4 // io.netty.buffer.ByteBuf buf
         4: .line 330
            aload 4 /* buf */
            invokevirtual io.netty.buffer.ByteBuf.readerIndex:()I
            istore 5 /* readerIndex */
        start local 5 // int readerIndex
         5: .line 331
            aload 4 /* buf */
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            iload 5 /* readerIndex */
            isub
            istore 6 /* readableBytes */
        start local 6 // int readableBytes
         6: .line 333
            iload 6 /* readableBytes */
            i2l
            lload 1 /* writtenBytes */
            lcmp
            ifgt 12
         7: .line 334
            lload 1 /* writtenBytes */
            lconst_0
            lcmp
            ifeq 10
         8: .line 335
            aload 0 /* this */
            iload 6 /* readableBytes */
            i2l
            invokevirtual io.netty.channel.ChannelOutboundBuffer.progress:(J)V
         9: .line 336
            lload 1 /* writtenBytes */
            iload 6 /* readableBytes */
            i2l
            lsub
            lstore 1 /* writtenBytes */
        10: .line 338
      StackMap locals: io.netty.buffer.ByteBuf int int
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.netty.channel.ChannelOutboundBuffer.remove:()Z
            pop
        11: .line 339
            goto 0
        12: .line 340
      StackMap locals:
      StackMap stack:
            lload 1 /* writtenBytes */
            lconst_0
            lcmp
            ifeq 15
        13: .line 341
            aload 4 /* buf */
            iload 5 /* readerIndex */
            lload 1 /* writtenBytes */
            l2i
            iadd
            invokevirtual io.netty.buffer.ByteBuf.readerIndex:(I)Lio/netty/buffer/ByteBuf;
            pop
        14: .line 342
            aload 0 /* this */
            lload 1 /* writtenBytes */
            invokevirtual io.netty.channel.ChannelOutboundBuffer.progress:(J)V
        end local 6 // int readableBytes
        end local 5 // int readerIndex
        end local 4 // io.netty.buffer.ByteBuf buf
        end local 3 // java.lang.Object msg
        15: .line 347
      StackMap locals: io.netty.channel.ChannelOutboundBuffer long
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.netty.channel.ChannelOutboundBuffer.clearNioBuffers:()V
        16: .line 348
            return
        end local 1 // long writtenBytes
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0   17     0           this  Lio/netty/channel/ChannelOutboundBuffer;
            0   17     1   writtenBytes  J
            1   15     3            msg  Ljava/lang/Object;
            4   15     4            buf  Lio/netty/buffer/ByteBuf;
            5   15     5    readerIndex  I
            6   15     6  readableBytes  I
    MethodParameters:
              Name  Flags
      writtenBytes  

  private void clearNioBuffers();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=2, args_size=1
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
         0: .line 353
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.nioBufferCount:I
            istore 1 /* count */
        start local 1 // int count
         1: .line 354
            iload 1 /* count */
            ifle 4
         2: .line 355
            aload 0 /* this */
            iconst_0
            putfield io.netty.channel.ChannelOutboundBuffer.nioBufferCount:I
         3: .line 356
            getstatic io.netty.channel.ChannelOutboundBuffer.NIO_BUFFERS:Lio/netty/util/concurrent/FastThreadLocal;
            invokevirtual io.netty.util.concurrent.FastThreadLocal.get:()Ljava/lang/Object;
            checkcast java.lang.Object[]
            iconst_0
            iload 1 /* count */
            aconst_null
            invokestatic java.util.Arrays.fill:([Ljava/lang/Object;IILjava/lang/Object;)V
         4: .line 358
      StackMap locals: int
      StackMap stack:
            return
        end local 1 // int count
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    5     0   this  Lio/netty/channel/ChannelOutboundBuffer;
            1    5     1  count  I

  public java.nio.ByteBuffer[] nioBuffers();
    descriptor: ()[Ljava/nio/ByteBuffer;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
         0: .line 371
            aload 0 /* this */
            ldc 2147483647
            ldc 2147483647
            invokevirtual io.netty.channel.ChannelOutboundBuffer.nioBuffers:(IJ)[Ljava/nio/ByteBuffer;
            areturn
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/channel/ChannelOutboundBuffer;

  public java.nio.ByteBuffer[] nioBuffers(int, long);
    descriptor: (IJ)[Ljava/nio/ByteBuffer;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=18, args_size=3
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // int maxCount
        start local 2 // long maxBytes
         0: .line 389
            getstatic io.netty.channel.ChannelOutboundBuffer.$assertionsDisabled:Z
            ifne 1
            iload 1 /* maxCount */
            ifgt 1
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         1: .line 390
      StackMap locals:
      StackMap stack:
            getstatic io.netty.channel.ChannelOutboundBuffer.$assertionsDisabled:Z
            ifne 2
            lload 2 /* maxBytes */
            lconst_0
            lcmp
            ifgt 2
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         2: .line 391
      StackMap locals:
      StackMap stack:
            lconst_0
            lstore 4 /* nioBufferSize */
        start local 4 // long nioBufferSize
         3: .line 392
            iconst_0
            istore 6 /* nioBufferCount */
        start local 6 // int nioBufferCount
         4: .line 393
            invokestatic io.netty.util.internal.InternalThreadLocalMap.get:()Lio/netty/util/internal/InternalThreadLocalMap;
            astore 7 /* threadLocalMap */
        start local 7 // io.netty.util.internal.InternalThreadLocalMap threadLocalMap
         5: .line 394
            getstatic io.netty.channel.ChannelOutboundBuffer.NIO_BUFFERS:Lio/netty/util/concurrent/FastThreadLocal;
            aload 7 /* threadLocalMap */
            invokevirtual io.netty.util.concurrent.FastThreadLocal.get:(Lio/netty/util/internal/InternalThreadLocalMap;)Ljava/lang/Object;
            checkcast java.nio.ByteBuffer[]
            astore 8 /* nioBuffers */
        start local 8 // java.nio.ByteBuffer[] nioBuffers
         6: .line 395
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.flushedEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
            astore 9 /* entry */
        start local 9 // io.netty.channel.ChannelOutboundBuffer$Entry entry
         7: .line 396
            goto 45
         8: .line 397
      StackMap locals: io.netty.channel.ChannelOutboundBuffer int long long int io.netty.util.internal.InternalThreadLocalMap java.nio.ByteBuffer[] io.netty.channel.ChannelOutboundBuffer$Entry
      StackMap stack:
            aload 9 /* entry */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.cancelled:Z
            ifne 44
         9: .line 398
            aload 9 /* entry */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.msg:Ljava/lang/Object;
            checkcast io.netty.buffer.ByteBuf
            astore 10 /* buf */
        start local 10 // io.netty.buffer.ByteBuf buf
        10: .line 399
            aload 10 /* buf */
            invokevirtual io.netty.buffer.ByteBuf.readerIndex:()I
            istore 11 /* readerIndex */
        start local 11 // int readerIndex
        11: .line 400
            aload 10 /* buf */
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            iload 11 /* readerIndex */
            isub
            istore 12 /* readableBytes */
        start local 12 // int readableBytes
        12: .line 402
            iload 12 /* readableBytes */
            ifle 44
        13: .line 403
            lload 2 /* maxBytes */
            iload 12 /* readableBytes */
            i2l
            lsub
            lload 4 /* nioBufferSize */
            lcmp
            ifge 15
            iload 6 /* nioBufferCount */
            ifeq 15
        14: .line 415
            goto 46
        15: .line 417
      StackMap locals: io.netty.buffer.ByteBuf int int
      StackMap stack:
            lload 4 /* nioBufferSize */
            iload 12 /* readableBytes */
            i2l
            ladd
            lstore 4 /* nioBufferSize */
        16: .line 418
            aload 9 /* entry */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.count:I
            istore 13 /* count */
        start local 13 // int count
        17: .line 419
            iload 13 /* count */
            iconst_m1
            if_icmpne 19
        18: .line 421
            aload 9 /* entry */
            aload 10 /* buf */
            invokevirtual io.netty.buffer.ByteBuf.nioBufferCount:()I
            dup
            istore 13 /* count */
            putfield io.netty.channel.ChannelOutboundBuffer$Entry.count:I
        19: .line 423
      StackMap locals: int
      StackMap stack:
            iload 1 /* maxCount */
            iload 6 /* nioBufferCount */
            iload 13 /* count */
            iadd
            invokestatic java.lang.Math.min:(II)I
            istore 14 /* neededSpace */
        start local 14 // int neededSpace
        20: .line 424
            iload 14 /* neededSpace */
            aload 8 /* nioBuffers */
            arraylength
            if_icmple 23
        21: .line 425
            aload 8 /* nioBuffers */
            iload 14 /* neededSpace */
            iload 6 /* nioBufferCount */
            invokestatic io.netty.channel.ChannelOutboundBuffer.expandNioBufferArray:([Ljava/nio/ByteBuffer;II)[Ljava/nio/ByteBuffer;
            astore 8 /* nioBuffers */
        22: .line 426
            getstatic io.netty.channel.ChannelOutboundBuffer.NIO_BUFFERS:Lio/netty/util/concurrent/FastThreadLocal;
            aload 7 /* threadLocalMap */
            aload 8 /* nioBuffers */
            invokevirtual io.netty.util.concurrent.FastThreadLocal.set:(Lio/netty/util/internal/InternalThreadLocalMap;Ljava/lang/Object;)V
        23: .line 428
      StackMap locals: int
      StackMap stack:
            iload 13 /* count */
            iconst_1
            if_icmpne 29
        24: .line 429
            aload 9 /* entry */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.buf:Ljava/nio/ByteBuffer;
            astore 15 /* nioBuf */
        start local 15 // java.nio.ByteBuffer nioBuf
        25: .line 430
            aload 15 /* nioBuf */
            ifnonnull 27
        26: .line 433
            aload 9 /* entry */
            aload 10 /* buf */
            iload 11 /* readerIndex */
            iload 12 /* readableBytes */
            invokevirtual io.netty.buffer.ByteBuf.internalNioBuffer:(II)Ljava/nio/ByteBuffer;
            dup
            astore 15 /* nioBuf */
            putfield io.netty.channel.ChannelOutboundBuffer$Entry.buf:Ljava/nio/ByteBuffer;
        27: .line 435
      StackMap locals: java.nio.ByteBuffer
      StackMap stack:
            aload 8 /* nioBuffers */
            iload 6 /* nioBufferCount */
            iinc 6 /* nioBufferCount */ 1
            aload 15 /* nioBuf */
            aastore
        end local 15 // java.nio.ByteBuffer nioBuf
        28: .line 436
            goto 42
        29: .line 437
      StackMap locals:
      StackMap stack:
            aload 9 /* entry */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.bufs:[Ljava/nio/ByteBuffer;
            astore 15 /* nioBufs */
        start local 15 // java.nio.ByteBuffer[] nioBufs
        30: .line 438
            aload 15 /* nioBufs */
            ifnonnull 32
        31: .line 441
            aload 9 /* entry */
            aload 10 /* buf */
            invokevirtual io.netty.buffer.ByteBuf.nioBuffers:()[Ljava/nio/ByteBuffer;
            dup
            astore 15 /* nioBufs */
            putfield io.netty.channel.ChannelOutboundBuffer$Entry.bufs:[Ljava/nio/ByteBuffer;
        32: .line 443
      StackMap locals: java.nio.ByteBuffer[]
      StackMap stack:
            iconst_0
            istore 16 /* i */
        start local 16 // int i
        33: goto 41
        34: .line 444
      StackMap locals: int
      StackMap stack:
            aload 15 /* nioBufs */
            iload 16 /* i */
            aaload
            astore 17 /* nioBuf */
        start local 17 // java.nio.ByteBuffer nioBuf
        35: .line 445
            aload 17 /* nioBuf */
            ifnonnull 37
        36: .line 446
            goto 42
        37: .line 447
      StackMap locals: java.nio.ByteBuffer
      StackMap stack:
            aload 17 /* nioBuf */
            invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
            ifne 39
        38: .line 448
            goto 40
        39: .line 450
      StackMap locals:
      StackMap stack:
            aload 8 /* nioBuffers */
            iload 6 /* nioBufferCount */
            iinc 6 /* nioBufferCount */ 1
            aload 17 /* nioBuf */
            aastore
        end local 17 // java.nio.ByteBuffer nioBuf
        40: .line 443
      StackMap locals:
      StackMap stack:
            iinc 16 /* i */ 1
      StackMap locals:
      StackMap stack:
        41: iload 16 /* i */
            aload 15 /* nioBufs */
            arraylength
            if_icmpge 42
            iload 6 /* nioBufferCount */
            iload 1 /* maxCount */
            if_icmplt 34
        end local 16 // int i
        end local 15 // java.nio.ByteBuffer[] nioBufs
        42: .line 453
      StackMap locals:
      StackMap stack:
            iload 6 /* nioBufferCount */
            iload 1 /* maxCount */
            if_icmpne 44
        43: .line 454
            goto 46
        end local 14 // int neededSpace
        end local 13 // int count
        end local 12 // int readableBytes
        end local 11 // int readerIndex
        end local 10 // io.netty.buffer.ByteBuf buf
        44: .line 458
      StackMap locals: io.netty.channel.ChannelOutboundBuffer int long long int io.netty.util.internal.InternalThreadLocalMap java.nio.ByteBuffer[] io.netty.channel.ChannelOutboundBuffer$Entry
      StackMap stack:
            aload 9 /* entry */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.next:Lio/netty/channel/ChannelOutboundBuffer$Entry;
            astore 9 /* entry */
        45: .line 396
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 9 /* entry */
            invokevirtual io.netty.channel.ChannelOutboundBuffer.isFlushedEntry:(Lio/netty/channel/ChannelOutboundBuffer$Entry;)Z
            ifeq 46
            aload 9 /* entry */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.msg:Ljava/lang/Object;
            instanceof io.netty.buffer.ByteBuf
            ifne 8
        46: .line 460
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iload 6 /* nioBufferCount */
            putfield io.netty.channel.ChannelOutboundBuffer.nioBufferCount:I
        47: .line 461
            aload 0 /* this */
            lload 4 /* nioBufferSize */
            putfield io.netty.channel.ChannelOutboundBuffer.nioBufferSize:J
        48: .line 463
            aload 8 /* nioBuffers */
            areturn
        end local 9 // io.netty.channel.ChannelOutboundBuffer$Entry entry
        end local 8 // java.nio.ByteBuffer[] nioBuffers
        end local 7 // io.netty.util.internal.InternalThreadLocalMap threadLocalMap
        end local 6 // int nioBufferCount
        end local 4 // long nioBufferSize
        end local 2 // long maxBytes
        end local 1 // int maxCount
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0   49     0            this  Lio/netty/channel/ChannelOutboundBuffer;
            0   49     1        maxCount  I
            0   49     2        maxBytes  J
            3   49     4   nioBufferSize  J
            4   49     6  nioBufferCount  I
            5   49     7  threadLocalMap  Lio/netty/util/internal/InternalThreadLocalMap;
            6   49     8      nioBuffers  [Ljava/nio/ByteBuffer;
            7   49     9           entry  Lio/netty/channel/ChannelOutboundBuffer$Entry;
           10   44    10             buf  Lio/netty/buffer/ByteBuf;
           11   44    11     readerIndex  I
           12   44    12   readableBytes  I
           17   44    13           count  I
           20   44    14     neededSpace  I
           25   28    15          nioBuf  Ljava/nio/ByteBuffer;
           30   42    15         nioBufs  [Ljava/nio/ByteBuffer;
           33   42    16               i  I
           35   40    17          nioBuf  Ljava/nio/ByteBuffer;
    MethodParameters:
          Name  Flags
      maxCount  
      maxBytes  

  private static java.nio.ByteBuffer[] expandNioBufferArray(java.nio.ByteBuffer[], int, int);
    descriptor: ([Ljava/nio/ByteBuffer;II)[Ljava/nio/ByteBuffer;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=5, locals=5, args_size=3
        start local 0 // java.nio.ByteBuffer[] array
        start local 1 // int neededSpace
        start local 2 // int size
         0: .line 467
            aload 0 /* array */
            arraylength
            istore 3 /* newCapacity */
        start local 3 // int newCapacity
         1: .line 471
      StackMap locals: int
      StackMap stack:
            iload 3 /* newCapacity */
            iconst_1
            ishl
            istore 3 /* newCapacity */
         2: .line 473
            iload 3 /* newCapacity */
            ifge 4
         3: .line 474
            new java.lang.IllegalStateException
            dup
            invokespecial java.lang.IllegalStateException.<init>:()V
            athrow
         4: .line 477
      StackMap locals:
      StackMap stack:
            iload 1 /* neededSpace */
            iload 3 /* newCapacity */
         5: .line 468
            if_icmpgt 1
         6: .line 479
            iload 3 /* newCapacity */
            anewarray java.nio.ByteBuffer
            astore 4 /* newArray */
        start local 4 // java.nio.ByteBuffer[] newArray
         7: .line 480
            aload 0 /* array */
            iconst_0
            aload 4 /* newArray */
            iconst_0
            iload 2 /* size */
            invokestatic java.lang.System.arraycopy:(Ljava/lang/Object;ILjava/lang/Object;II)V
         8: .line 482
            aload 4 /* newArray */
            areturn
        end local 4 // java.nio.ByteBuffer[] newArray
        end local 3 // int newCapacity
        end local 2 // int size
        end local 1 // int neededSpace
        end local 0 // java.nio.ByteBuffer[] array
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    9     0        array  [Ljava/nio/ByteBuffer;
            0    9     1  neededSpace  I
            0    9     2         size  I
            1    9     3  newCapacity  I
            7    9     4     newArray  [Ljava/nio/ByteBuffer;
    MethodParameters:
             Name  Flags
      array        
      neededSpace  
      size         

  public int nioBufferCount();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
         0: .line 491
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.nioBufferCount:I
            ireturn
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/channel/ChannelOutboundBuffer;

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

  public boolean isWritable();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
         0: .line 510
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.unwritable:I
            ifne 1
            iconst_1
            ireturn
      StackMap locals:
      StackMap stack:
         1: iconst_0
            ireturn
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/netty/channel/ChannelOutboundBuffer;

  public boolean getUserDefinedWritability(int);
    descriptor: (I)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // int index
         0: .line 518
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.unwritable:I
            iload 1 /* index */
            invokestatic io.netty.channel.ChannelOutboundBuffer.writabilityMask:(I)I
            iand
            ifne 1
            iconst_1
            ireturn
      StackMap locals:
      StackMap stack:
         1: iconst_0
            ireturn
        end local 1 // int index
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0   this  Lio/netty/channel/ChannelOutboundBuffer;
            0    2     1  index  I
    MethodParameters:
       Name  Flags
      index  

  public void setUserDefinedWritability(int, boolean);
    descriptor: (IZ)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // int index
        start local 2 // boolean writable
         0: .line 525
            iload 2 /* writable */
            ifeq 3
         1: .line 526
            aload 0 /* this */
            iload 1 /* index */
            invokevirtual io.netty.channel.ChannelOutboundBuffer.setUserDefinedWritability:(I)V
         2: .line 527
            goto 4
         3: .line 528
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iload 1 /* index */
            invokevirtual io.netty.channel.ChannelOutboundBuffer.clearUserDefinedWritability:(I)V
         4: .line 530
      StackMap locals:
      StackMap stack:
            return
        end local 2 // boolean writable
        end local 1 // int index
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    5     0      this  Lio/netty/channel/ChannelOutboundBuffer;
            0    5     1     index  I
            0    5     2  writable  Z
    MethodParameters:
          Name  Flags
      index     
      writable  

  private void setUserDefinedWritability(int);
    descriptor: (I)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=5, args_size=2
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // int index
         0: .line 533
            iload 1 /* index */
            invokestatic io.netty.channel.ChannelOutboundBuffer.writabilityMask:(I)I
            iconst_m1
            ixor
            istore 2 /* mask */
        start local 2 // int mask
         1: .line 535
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.unwritable:I
            istore 3 /* oldValue */
        start local 3 // int oldValue
         2: .line 536
            iload 3 /* oldValue */
            iload 2 /* mask */
            iand
            istore 4 /* newValue */
        start local 4 // int newValue
         3: .line 537
            getstatic io.netty.channel.ChannelOutboundBuffer.UNWRITABLE_UPDATER:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
            aload 0 /* this */
            iload 3 /* oldValue */
            iload 4 /* newValue */
            invokevirtual java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet:(Ljava/lang/Object;II)Z
            ifeq 1
         4: .line 538
            iload 3 /* oldValue */
            ifeq 6
            iload 4 /* newValue */
            ifne 6
         5: .line 539
            aload 0 /* this */
            iconst_1
            invokevirtual io.netty.channel.ChannelOutboundBuffer.fireChannelWritabilityChanged:(Z)V
        end local 4 // int newValue
        end local 3 // int oldValue
         6: .line 544
      StackMap locals:
      StackMap stack:
            return
        end local 2 // int mask
        end local 1 // int index
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    7     0      this  Lio/netty/channel/ChannelOutboundBuffer;
            0    7     1     index  I
            1    7     2      mask  I
            2    6     3  oldValue  I
            3    6     4  newValue  I
    MethodParameters:
       Name  Flags
      index  

  private void clearUserDefinedWritability(int);
    descriptor: (I)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=5, args_size=2
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // int index
         0: .line 547
            iload 1 /* index */
            invokestatic io.netty.channel.ChannelOutboundBuffer.writabilityMask:(I)I
            istore 2 /* mask */
        start local 2 // int mask
         1: .line 549
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.unwritable:I
            istore 3 /* oldValue */
        start local 3 // int oldValue
         2: .line 550
            iload 3 /* oldValue */
            iload 2 /* mask */
            ior
            istore 4 /* newValue */
        start local 4 // int newValue
         3: .line 551
            getstatic io.netty.channel.ChannelOutboundBuffer.UNWRITABLE_UPDATER:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
            aload 0 /* this */
            iload 3 /* oldValue */
            iload 4 /* newValue */
            invokevirtual java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet:(Ljava/lang/Object;II)Z
            ifeq 1
         4: .line 552
            iload 3 /* oldValue */
            ifne 6
            iload 4 /* newValue */
            ifeq 6
         5: .line 553
            aload 0 /* this */
            iconst_1
            invokevirtual io.netty.channel.ChannelOutboundBuffer.fireChannelWritabilityChanged:(Z)V
        end local 4 // int newValue
        end local 3 // int oldValue
         6: .line 558
      StackMap locals:
      StackMap stack:
            return
        end local 2 // int mask
        end local 1 // int index
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    7     0      this  Lio/netty/channel/ChannelOutboundBuffer;
            0    7     1     index  I
            1    7     2      mask  I
            2    6     3  oldValue  I
            3    6     4  newValue  I
    MethodParameters:
       Name  Flags
      index  

  private static int writabilityMask(int);
    descriptor: (I)I
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=5, locals=1, args_size=1
        start local 0 // int index
         0: .line 561
            iload 0 /* index */
            iconst_1
            if_icmplt 1
            iload 0 /* index */
            bipush 31
            if_icmple 2
         1: .line 562
      StackMap locals:
      StackMap stack:
            new java.lang.IllegalArgumentException
            dup
            new java.lang.StringBuilder
            dup
            ldc "index: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            iload 0 /* index */
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc " (expected: 1~31)"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 564
      StackMap locals:
      StackMap stack:
            iconst_1
            iload 0 /* index */
            ishl
            ireturn
        end local 0 // int index
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    3     0  index  I
    MethodParameters:
       Name  Flags
      index  

  private void setWritable(boolean);
    descriptor: (Z)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=4, args_size=2
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // boolean invokeLater
         0: .line 569
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.unwritable:I
            istore 2 /* oldValue */
        start local 2 // int oldValue
         1: .line 570
            iload 2 /* oldValue */
            bipush -2
            iand
            istore 3 /* newValue */
        start local 3 // int newValue
         2: .line 571
            getstatic io.netty.channel.ChannelOutboundBuffer.UNWRITABLE_UPDATER:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
            aload 0 /* this */
            iload 2 /* oldValue */
            iload 3 /* newValue */
            invokevirtual java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet:(Ljava/lang/Object;II)Z
            ifeq 0
         3: .line 572
            iload 2 /* oldValue */
            ifeq 5
            iload 3 /* newValue */
            ifne 5
         4: .line 573
            aload 0 /* this */
            iload 1 /* invokeLater */
            invokevirtual io.netty.channel.ChannelOutboundBuffer.fireChannelWritabilityChanged:(Z)V
        end local 3 // int newValue
        end local 2 // int oldValue
         5: .line 578
      StackMap locals:
      StackMap stack:
            return
        end local 1 // boolean invokeLater
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    6     0         this  Lio/netty/channel/ChannelOutboundBuffer;
            0    6     1  invokeLater  Z
            1    5     2     oldValue  I
            2    5     3     newValue  I
    MethodParameters:
             Name  Flags
      invokeLater  

  private void setUnwritable(boolean);
    descriptor: (Z)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=4, args_size=2
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // boolean invokeLater
         0: .line 582
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.unwritable:I
            istore 2 /* oldValue */
        start local 2 // int oldValue
         1: .line 583
            iload 2 /* oldValue */
            iconst_1
            ior
            istore 3 /* newValue */
        start local 3 // int newValue
         2: .line 584
            getstatic io.netty.channel.ChannelOutboundBuffer.UNWRITABLE_UPDATER:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
            aload 0 /* this */
            iload 2 /* oldValue */
            iload 3 /* newValue */
            invokevirtual java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet:(Ljava/lang/Object;II)Z
            ifeq 0
         3: .line 585
            iload 2 /* oldValue */
            ifne 5
            iload 3 /* newValue */
            ifeq 5
         4: .line 586
            aload 0 /* this */
            iload 1 /* invokeLater */
            invokevirtual io.netty.channel.ChannelOutboundBuffer.fireChannelWritabilityChanged:(Z)V
        end local 3 // int newValue
        end local 2 // int oldValue
         5: .line 591
      StackMap locals:
      StackMap stack:
            return
        end local 1 // boolean invokeLater
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    6     0         this  Lio/netty/channel/ChannelOutboundBuffer;
            0    6     1  invokeLater  Z
            1    5     2     oldValue  I
            2    5     3     newValue  I
    MethodParameters:
             Name  Flags
      invokeLater  

  private void fireChannelWritabilityChanged(boolean);
    descriptor: (Z)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=4, args_size=2
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // boolean invokeLater
         0: .line 594
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.channel:Lio/netty/channel/Channel;
            invokeinterface io.netty.channel.Channel.pipeline:()Lio/netty/channel/ChannelPipeline;
            astore 2 /* pipeline */
        start local 2 // io.netty.channel.ChannelPipeline pipeline
         1: .line 595
            iload 1 /* invokeLater */
            ifeq 7
         2: .line 596
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.fireChannelWritabilityChangedTask:Ljava/lang/Runnable;
            astore 3 /* task */
        start local 3 // java.lang.Runnable task
         3: .line 597
            aload 3 /* task */
            ifnonnull 5
         4: .line 598
            aload 0 /* this */
            new io.netty.channel.ChannelOutboundBuffer$2
            dup
            aload 0 /* this */
            aload 2 /* pipeline */
            invokespecial io.netty.channel.ChannelOutboundBuffer$2.<init>:(Lio/netty/channel/ChannelOutboundBuffer;Lio/netty/channel/ChannelPipeline;)V
            dup
            astore 3 /* task */
            putfield io.netty.channel.ChannelOutboundBuffer.fireChannelWritabilityChangedTask:Ljava/lang/Runnable;
         5: .line 605
      StackMap locals: io.netty.channel.ChannelPipeline java.lang.Runnable
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.channel:Lio/netty/channel/Channel;
            invokeinterface io.netty.channel.Channel.eventLoop:()Lio/netty/channel/EventLoop;
            aload 3 /* task */
            invokeinterface io.netty.channel.EventLoop.execute:(Ljava/lang/Runnable;)V
        end local 3 // java.lang.Runnable task
         6: .line 606
            goto 8
         7: .line 607
      StackMap locals:
      StackMap stack:
            aload 2 /* pipeline */
            invokeinterface io.netty.channel.ChannelPipeline.fireChannelWritabilityChanged:()Lio/netty/channel/ChannelPipeline;
            pop
         8: .line 609
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.netty.channel.ChannelPipeline pipeline
        end local 1 // boolean invokeLater
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    9     0         this  Lio/netty/channel/ChannelOutboundBuffer;
            0    9     1  invokeLater  Z
            1    9     2     pipeline  Lio/netty/channel/ChannelPipeline;
            3    6     3         task  Ljava/lang/Runnable;
    MethodParameters:
             Name  Flags
      invokeLater  

  public int size();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
         0: .line 615
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.flushed:I
            ireturn
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/channel/ChannelOutboundBuffer;

  public boolean isEmpty();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
         0: .line 623
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.flushed:I
            ifne 1
            iconst_1
            ireturn
      StackMap locals:
      StackMap stack:
         1: iconst_0
            ireturn
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/netty/channel/ChannelOutboundBuffer;

  void failFlushed(java.lang.Throwable, boolean);
    descriptor: (Ljava/lang/Throwable;Z)V
    flags: (0x0000) 
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // java.lang.Throwable cause
        start local 2 // boolean notify
         0: .line 632
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.inFail:Z
            ifeq 2
         1: .line 633
            return
         2: .line 637
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_1
            putfield io.netty.channel.ChannelOutboundBuffer.inFail:Z
         3: .line 639
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* cause */
            iload 2 /* notify */
            invokevirtual io.netty.channel.ChannelOutboundBuffer.remove0:(Ljava/lang/Throwable;Z)Z
            ifne 3
         4: .line 643
            goto 8
      StackMap locals:
      StackMap stack: java.lang.Throwable
         5: astore 3
         6: .line 644
            aload 0 /* this */
            iconst_0
            putfield io.netty.channel.ChannelOutboundBuffer.inFail:Z
         7: .line 645
            aload 3
            athrow
         8: .line 644
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_0
            putfield io.netty.channel.ChannelOutboundBuffer.inFail:Z
         9: .line 646
            return
        end local 2 // boolean notify
        end local 1 // java.lang.Throwable cause
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   10     0    this  Lio/netty/channel/ChannelOutboundBuffer;
            0   10     1   cause  Ljava/lang/Throwable;
            0   10     2  notify  Z
      Exception table:
        from    to  target  type
           2     5       5  any
    MethodParameters:
        Name  Flags
      cause   
      notify  

  void close(java.lang.Throwable, boolean);
    descriptor: (Ljava/lang/Throwable;Z)V
    flags: (0x0000) 
    Code:
      stack=6, locals=6, args_size=3
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // java.lang.Throwable cause
        start local 2 // boolean allowChannelOpen
         0: .line 649
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.inFail:Z
            ifeq 3
         1: .line 650
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.channel:Lio/netty/channel/Channel;
            invokeinterface io.netty.channel.Channel.eventLoop:()Lio/netty/channel/EventLoop;
            new io.netty.channel.ChannelOutboundBuffer$3
            dup
            aload 0 /* this */
            aload 1 /* cause */
            iload 2 /* allowChannelOpen */
            invokespecial io.netty.channel.ChannelOutboundBuffer$3.<init>:(Lio/netty/channel/ChannelOutboundBuffer;Ljava/lang/Throwable;Z)V
            invokeinterface io.netty.channel.EventLoop.execute:(Ljava/lang/Runnable;)V
         2: .line 656
            return
         3: .line 659
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_1
            putfield io.netty.channel.ChannelOutboundBuffer.inFail:Z
         4: .line 661
            iload 2 /* allowChannelOpen */
            ifne 6
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.channel:Lio/netty/channel/Channel;
            invokeinterface io.netty.channel.Channel.isOpen:()Z
            ifeq 6
         5: .line 662
            new java.lang.IllegalStateException
            dup
            ldc "close() must be invoked after the channel is closed."
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         6: .line 665
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.netty.channel.ChannelOutboundBuffer.isEmpty:()Z
            ifne 8
         7: .line 666
            new java.lang.IllegalStateException
            dup
            ldc "close() must be invoked after all flushed writes are handled."
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         8: .line 671
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.unflushedEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
            astore 3 /* e */
        start local 3 // io.netty.channel.ChannelOutboundBuffer$Entry e
         9: .line 672
            goto 16
        10: .line 674
      StackMap locals: io.netty.channel.ChannelOutboundBuffer$Entry
      StackMap stack:
            aload 3 /* e */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.pendingSize:I
            istore 4 /* size */
        start local 4 // int size
        11: .line 675
            getstatic io.netty.channel.ChannelOutboundBuffer.TOTAL_PENDING_SIZE_UPDATER:Ljava/util/concurrent/atomic/AtomicLongFieldUpdater;
            aload 0 /* this */
            iload 4 /* size */
            ineg
            i2l
            invokevirtual java.util.concurrent.atomic.AtomicLongFieldUpdater.addAndGet:(Ljava/lang/Object;J)J
            pop2
        12: .line 677
            aload 3 /* e */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.cancelled:Z
            ifne 15
        13: .line 678
            aload 3 /* e */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.msg:Ljava/lang/Object;
            invokestatic io.netty.util.ReferenceCountUtil.safeRelease:(Ljava/lang/Object;)V
        14: .line 679
            aload 3 /* e */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.promise:Lio/netty/channel/ChannelPromise;
            aload 1 /* cause */
            invokestatic io.netty.channel.ChannelOutboundBuffer.safeFail:(Lio/netty/channel/ChannelPromise;Ljava/lang/Throwable;)V
        15: .line 681
      StackMap locals: int
      StackMap stack:
            aload 3 /* e */
            invokevirtual io.netty.channel.ChannelOutboundBuffer$Entry.recycleAndGetNext:()Lio/netty/channel/ChannelOutboundBuffer$Entry;
            astore 3 /* e */
        end local 4 // int size
        16: .line 672
      StackMap locals:
      StackMap stack:
            aload 3 /* e */
            ifnonnull 10
        end local 3 // io.netty.channel.ChannelOutboundBuffer$Entry e
        17: .line 683
            goto 21
      StackMap locals: io.netty.channel.ChannelOutboundBuffer java.lang.Throwable int
      StackMap stack: java.lang.Throwable
        18: astore 5
        19: .line 684
            aload 0 /* this */
            iconst_0
            putfield io.netty.channel.ChannelOutboundBuffer.inFail:Z
        20: .line 685
            aload 5
            athrow
        21: .line 684
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_0
            putfield io.netty.channel.ChannelOutboundBuffer.inFail:Z
        22: .line 686
            aload 0 /* this */
            invokevirtual io.netty.channel.ChannelOutboundBuffer.clearNioBuffers:()V
        23: .line 687
            return
        end local 2 // boolean allowChannelOpen
        end local 1 // java.lang.Throwable cause
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0   24     0              this  Lio/netty/channel/ChannelOutboundBuffer;
            0   24     1             cause  Ljava/lang/Throwable;
            0   24     2  allowChannelOpen  Z
            9   17     3                 e  Lio/netty/channel/ChannelOutboundBuffer$Entry;
           11   16     4              size  I
      Exception table:
        from    to  target  type
           8    18      18  any
    MethodParameters:
                  Name  Flags
      cause             final
      allowChannelOpen  final

  void close(java.nio.channels.ClosedChannelException);
    descriptor: (Ljava/nio/channels/ClosedChannelException;)V
    flags: (0x0000) 
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // java.nio.channels.ClosedChannelException cause
         0: .line 690
            aload 0 /* this */
            aload 1 /* cause */
            iconst_0
            invokevirtual io.netty.channel.ChannelOutboundBuffer.close:(Ljava/lang/Throwable;Z)V
         1: .line 691
            return
        end local 1 // java.nio.channels.ClosedChannelException cause
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0   this  Lio/netty/channel/ChannelOutboundBuffer;
            0    2     1  cause  Ljava/nio/channels/ClosedChannelException;
    MethodParameters:
       Name  Flags
      cause  

  private static void safeSuccess(io.netty.channel.ChannelPromise);
    descriptor: (Lio/netty/channel/ChannelPromise;)V
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.netty.channel.ChannelPromise promise
         0: .line 696
            aload 0 /* promise */
            aconst_null
            aload 0 /* promise */
            instanceof io.netty.channel.VoidChannelPromise
            ifeq 1
            aconst_null
            goto 2
      StackMap locals: io.netty.channel.ChannelPromise
      StackMap stack: io.netty.channel.ChannelPromise null
         1: getstatic io.netty.channel.ChannelOutboundBuffer.logger:Lio/netty/util/internal/logging/InternalLogger;
      StackMap locals: io.netty.channel.ChannelPromise
      StackMap stack: io.netty.channel.ChannelPromise null io.netty.util.internal.logging.InternalLogger
         2: invokestatic io.netty.util.internal.PromiseNotificationUtil.trySuccess:(Lio/netty/util/concurrent/Promise;Ljava/lang/Object;Lio/netty/util/internal/logging/InternalLogger;)V
         3: .line 697
            return
        end local 0 // io.netty.channel.ChannelPromise promise
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0  promise  Lio/netty/channel/ChannelPromise;
    MethodParameters:
         Name  Flags
      promise  

  private static void safeFail(io.netty.channel.ChannelPromise, java.lang.Throwable);
    descriptor: (Lio/netty/channel/ChannelPromise;Ljava/lang/Throwable;)V
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.netty.channel.ChannelPromise promise
        start local 1 // java.lang.Throwable cause
         0: .line 702
            aload 0 /* promise */
            aload 1 /* cause */
            aload 0 /* promise */
            instanceof io.netty.channel.VoidChannelPromise
            ifeq 1
            aconst_null
            goto 2
      StackMap locals: io.netty.channel.ChannelPromise java.lang.Throwable
      StackMap stack: io.netty.channel.ChannelPromise java.lang.Throwable
         1: getstatic io.netty.channel.ChannelOutboundBuffer.logger:Lio/netty/util/internal/logging/InternalLogger;
      StackMap locals: io.netty.channel.ChannelPromise java.lang.Throwable
      StackMap stack: io.netty.channel.ChannelPromise java.lang.Throwable io.netty.util.internal.logging.InternalLogger
         2: invokestatic io.netty.util.internal.PromiseNotificationUtil.tryFailure:(Lio/netty/util/concurrent/Promise;Ljava/lang/Throwable;Lio/netty/util/internal/logging/InternalLogger;)V
         3: .line 703
            return
        end local 1 // java.lang.Throwable cause
        end local 0 // io.netty.channel.ChannelPromise promise
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0  promise  Lio/netty/channel/ChannelPromise;
            0    4     1    cause  Ljava/lang/Throwable;
    MethodParameters:
         Name  Flags
      promise  
      cause    

  public void recycle();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
         0: .line 708
            return
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/channel/ChannelOutboundBuffer;
    RuntimeVisibleAnnotations: 
      java.lang.Deprecated()

  public long totalPendingWriteBytes();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
         0: .line 711
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.totalPendingSize:J
            lreturn
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/channel/ChannelOutboundBuffer;

  public long bytesBeforeUnwritable();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=1
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
         0: .line 719
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.channel:Lio/netty/channel/Channel;
            invokeinterface io.netty.channel.Channel.config:()Lio/netty/channel/ChannelConfig;
            invokeinterface io.netty.channel.ChannelConfig.getWriteBufferHighWaterMark:()I
            i2l
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.totalPendingSize:J
            lsub
            lstore 1 /* bytes */
        start local 1 // long bytes
         1: .line 723
            lload 1 /* bytes */
            lconst_0
            lcmp
            ifle 5
         2: .line 724
            aload 0 /* this */
            invokevirtual io.netty.channel.ChannelOutboundBuffer.isWritable:()Z
            ifeq 3
            lload 1 /* bytes */
            goto 4
      StackMap locals: long
      StackMap stack:
         3: lconst_0
      StackMap locals:
      StackMap stack: long
         4: lreturn
         5: .line 726
      StackMap locals:
      StackMap stack:
            lconst_0
            lreturn
        end local 1 // long bytes
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    6     0   this  Lio/netty/channel/ChannelOutboundBuffer;
            1    6     1  bytes  J

  public long bytesBeforeWritable();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=1
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
         0: .line 734
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.totalPendingSize:J
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.channel:Lio/netty/channel/Channel;
            invokeinterface io.netty.channel.Channel.config:()Lio/netty/channel/ChannelConfig;
            invokeinterface io.netty.channel.ChannelConfig.getWriteBufferLowWaterMark:()I
            i2l
            lsub
            lstore 1 /* bytes */
        start local 1 // long bytes
         1: .line 738
            lload 1 /* bytes */
            lconst_0
            lcmp
            ifle 5
         2: .line 739
            aload 0 /* this */
            invokevirtual io.netty.channel.ChannelOutboundBuffer.isWritable:()Z
            ifeq 3
            lconst_0
            goto 4
      StackMap locals: long
      StackMap stack:
         3: lload 1 /* bytes */
      StackMap locals:
      StackMap stack: long
         4: lreturn
         5: .line 741
      StackMap locals:
      StackMap stack:
            lconst_0
            lreturn
        end local 1 // long bytes
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    6     0   this  Lio/netty/channel/ChannelOutboundBuffer;
            1    6     1  bytes  J

  public void forEachFlushedMessage(io.netty.channel.ChannelOutboundBuffer$MessageProcessor);
    descriptor: (Lio/netty/channel/ChannelOutboundBuffer$MessageProcessor;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // io.netty.channel.ChannelOutboundBuffer$MessageProcessor processor
         0: .line 750
            aload 1 /* processor */
            ifnonnull 2
         1: .line 751
            new java.lang.NullPointerException
            dup
            ldc "processor"
            invokespecial java.lang.NullPointerException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 754
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.flushedEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
            astore 2 /* entry */
        start local 2 // io.netty.channel.ChannelOutboundBuffer$Entry entry
         3: .line 755
            aload 2 /* entry */
            ifnonnull 5
         4: .line 756
            return
         5: .line 760
      StackMap locals: io.netty.channel.ChannelOutboundBuffer$Entry
      StackMap stack:
            aload 2 /* entry */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.cancelled:Z
            ifne 8
         6: .line 761
            aload 1 /* processor */
            aload 2 /* entry */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.msg:Ljava/lang/Object;
            invokeinterface io.netty.channel.ChannelOutboundBuffer$MessageProcessor.processMessage:(Ljava/lang/Object;)Z
            ifne 8
         7: .line 762
            return
         8: .line 765
      StackMap locals:
      StackMap stack:
            aload 2 /* entry */
            getfield io.netty.channel.ChannelOutboundBuffer$Entry.next:Lio/netty/channel/ChannelOutboundBuffer$Entry;
            astore 2 /* entry */
         9: .line 766
            aload 0 /* this */
            aload 2 /* entry */
            invokevirtual io.netty.channel.ChannelOutboundBuffer.isFlushedEntry:(Lio/netty/channel/ChannelOutboundBuffer$Entry;)Z
            ifne 5
        10: .line 767
            return
        end local 2 // io.netty.channel.ChannelOutboundBuffer$Entry entry
        end local 1 // io.netty.channel.ChannelOutboundBuffer$MessageProcessor processor
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0   11     0       this  Lio/netty/channel/ChannelOutboundBuffer;
            0   11     1  processor  Lio/netty/channel/ChannelOutboundBuffer$MessageProcessor;
            3   11     2      entry  Lio/netty/channel/ChannelOutboundBuffer$Entry;
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
           Name  Flags
      processor  

  private boolean isFlushedEntry(io.netty.channel.ChannelOutboundBuffer$Entry);
    descriptor: (Lio/netty/channel/ChannelOutboundBuffer$Entry;)Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.netty.channel.ChannelOutboundBuffer this
        start local 1 // io.netty.channel.ChannelOutboundBuffer$Entry e
         0: .line 770
            aload 1 /* e */
            ifnull 1
            aload 1 /* e */
            aload 0 /* this */
            getfield io.netty.channel.ChannelOutboundBuffer.unflushedEntry:Lio/netty/channel/ChannelOutboundBuffer$Entry;
            if_acmpeq 1
            iconst_1
            ireturn
      StackMap locals:
      StackMap stack:
         1: iconst_0
            ireturn
        end local 1 // io.netty.channel.ChannelOutboundBuffer$Entry e
        end local 0 // io.netty.channel.ChannelOutboundBuffer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/netty/channel/ChannelOutboundBuffer;
            0    2     1     e  Lio/netty/channel/ChannelOutboundBuffer$Entry;
    MethodParameters:
      Name  Flags
      e     
}
SourceFile: "ChannelOutboundBuffer.java"
NestMembers:
  io.netty.channel.ChannelOutboundBuffer$1  io.netty.channel.ChannelOutboundBuffer$2  io.netty.channel.ChannelOutboundBuffer$3  io.netty.channel.ChannelOutboundBuffer$Entry  io.netty.channel.ChannelOutboundBuffer$Entry$1  io.netty.channel.ChannelOutboundBuffer$MessageProcessor
InnerClasses:
  io.netty.channel.ChannelOutboundBuffer$1
  io.netty.channel.ChannelOutboundBuffer$2
  io.netty.channel.ChannelOutboundBuffer$3
  final Entry = io.netty.channel.ChannelOutboundBuffer$Entry of io.netty.channel.ChannelOutboundBuffer
  public abstract MessageProcessor = io.netty.channel.ChannelOutboundBuffer$MessageProcessor of io.netty.channel.ChannelOutboundBuffer