public final class org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter extends org.glassfish.grizzly.nio.AbstractNIOAsyncQueueWriter
  minor version: 0
  major version: 59
  flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
  this_class: org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter
  super_class: org.glassfish.grizzly.nio.AbstractNIOAsyncQueueWriter
{
  private static final java.util.logging.Logger LOGGER;
    descriptor: Ljava/util/logging/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private static final org.glassfish.grizzly.attributes.Attribute<org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord> COMPOSITE_BUFFER_ATTR;
    descriptor: Lorg/glassfish/grizzly/attributes/Attribute;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    Signature: Lorg/glassfish/grizzly/attributes/Attribute<Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter$CompositeQueueRecord;>;

  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=4, locals=0, args_size=0
         0: .line 55
            ldc Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter;
            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 org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter.$assertionsDisabled:Z
         3: .line 56
            ldc Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter;
            invokestatic org.glassfish.grizzly.Grizzly.logger:(Ljava/lang/Class;)Ljava/util/logging/Logger;
            putstatic org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter.LOGGER:Ljava/util/logging/Logger;
         4: .line 352
            getstatic org.glassfish.grizzly.Grizzly.DEFAULT_ATTRIBUTE_BUILDER:Lorg/glassfish/grizzly/attributes/AttributeBuilder;
         5: .line 353
            new java.lang.StringBuilder
            dup
            ldc Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter;
            invokevirtual java.lang.Class.getName:()Ljava/lang/String;
            invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            ldc ".compositeBuffer"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         6: .line 352
            invokeinterface org.glassfish.grizzly.attributes.AttributeBuilder.createAttribute:(Ljava/lang/String;)Lorg/glassfish/grizzly/attributes/Attribute;
         7: .line 351
            putstatic org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter.COMPOSITE_BUFFER_ATTR:Lorg/glassfish/grizzly/attributes/Attribute;
         8: .line 353
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(org.glassfish.grizzly.nio.NIOTransport);
    descriptor: (Lorg/glassfish/grizzly/nio/NIOTransport;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter this
        start local 1 // org.glassfish.grizzly.nio.NIOTransport transport
         0: .line 59
            aload 0 /* this */
            aload 1 /* transport */
            invokespecial org.glassfish.grizzly.nio.AbstractNIOAsyncQueueWriter.<init>:(Lorg/glassfish/grizzly/nio/NIOTransport;)V
         1: .line 60
            return
        end local 1 // org.glassfish.grizzly.nio.NIOTransport transport
        end local 0 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    2     0       this  Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter;
            0    2     1  transport  Lorg/glassfish/grizzly/nio/NIOTransport;
    MethodParameters:
           Name  Flags
      transport  final

  protected org.glassfish.grizzly.asyncqueue.RecordWriteResult write0(org.glassfish.grizzly.nio.NIOConnection, org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord);
    descriptor: (Lorg/glassfish/grizzly/nio/NIOConnection;Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;)Lorg/glassfish/grizzly/asyncqueue/RecordWriteResult;
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=5, locals=6, args_size=3
        start local 0 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter this
        start local 1 // org.glassfish.grizzly.nio.NIOConnection connection
        start local 2 // org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord queueRecord
         0: .line 67
            aload 2 /* queueRecord */
            instanceof org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord
            ifeq 4
         1: .line 68
            aload 0 /* this */
            aload 1 /* connection */
         2: .line 69
            aload 2 /* queueRecord */
            checkcast org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord
         3: .line 68
            invokevirtual org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter.writeCompositeRecord:(Lorg/glassfish/grizzly/nio/NIOConnection;Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter$CompositeQueueRecord;)Lorg/glassfish/grizzly/asyncqueue/RecordWriteResult;
            areturn
         4: .line 72
      StackMap locals:
      StackMap stack:
            aload 2 /* queueRecord */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.getCurrentResult:()Lorg/glassfish/grizzly/asyncqueue/RecordWriteResult;
            astore 3 /* writeResult */
        start local 3 // org.glassfish.grizzly.asyncqueue.RecordWriteResult writeResult
         5: .line 74
            aload 2 /* queueRecord */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.remaining:()J
            lconst_0
            lcmp
            ifne 12
         6: .line 75
            aload 3 /* writeResult */
            lconst_0
         7: .line 76
            aload 2 /* queueRecord */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.isUncountable:()Z
            ifeq 9
         8: .line 77
            iconst_1
            goto 10
         9: .line 78
      StackMap locals: org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter org.glassfish.grizzly.nio.NIOConnection org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord org.glassfish.grizzly.asyncqueue.RecordWriteResult
      StackMap stack: org.glassfish.grizzly.asyncqueue.RecordWriteResult long
            iconst_0
        10: .line 76
      StackMap locals: org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter org.glassfish.grizzly.nio.NIOConnection org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord org.glassfish.grizzly.asyncqueue.RecordWriteResult
      StackMap stack: org.glassfish.grizzly.asyncqueue.RecordWriteResult long int
            i2l
        11: .line 75
            invokevirtual org.glassfish.grizzly.asyncqueue.RecordWriteResult.lastWriteResult:(JJ)Lorg/glassfish/grizzly/asyncqueue/RecordWriteResult;
            areturn
        12: .line 82
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* connection */
        13: .line 83
            aload 2 /* queueRecord */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.getWritableMessage:()Lorg/glassfish/grizzly/asyncqueue/WritableMessage;
            aload 3 /* writeResult */
        14: .line 82
            invokevirtual org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter.write0:(Lorg/glassfish/grizzly/nio/NIOConnection;Lorg/glassfish/grizzly/asyncqueue/WritableMessage;Lorg/glassfish/grizzly/WriteResult;)J
            lstore 4 /* written */
        start local 4 // long written
        15: .line 85
            aload 3 /* writeResult */
            lload 4 /* written */
            lload 4 /* written */
            invokevirtual org.glassfish.grizzly.asyncqueue.RecordWriteResult.lastWriteResult:(JJ)Lorg/glassfish/grizzly/asyncqueue/RecordWriteResult;
            areturn
        end local 4 // long written
        end local 3 // org.glassfish.grizzly.asyncqueue.RecordWriteResult writeResult
        end local 2 // org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord queueRecord
        end local 1 // org.glassfish.grizzly.nio.NIOConnection connection
        end local 0 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0   16     0         this  Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter;
            0   16     1   connection  Lorg/glassfish/grizzly/nio/NIOConnection;
            0   16     2  queueRecord  Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
            5   16     3  writeResult  Lorg/glassfish/grizzly/asyncqueue/RecordWriteResult;
           15   16     4      written  J
    Exceptions:
      throws java.io.IOException
    MethodParameters:
             Name  Flags
      connection   final
      queueRecord  final

  protected long write0(org.glassfish.grizzly.nio.NIOConnection, org.glassfish.grizzly.asyncqueue.WritableMessage, org.glassfish.grizzly.WriteResult<org.glassfish.grizzly.asyncqueue.WritableMessage, java.net.SocketAddress>);
    descriptor: (Lorg/glassfish/grizzly/nio/NIOConnection;Lorg/glassfish/grizzly/asyncqueue/WritableMessage;Lorg/glassfish/grizzly/WriteResult;)J
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=6, locals=8, args_size=4
        start local 0 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter this
        start local 1 // org.glassfish.grizzly.nio.NIOConnection connection
        start local 2 // org.glassfish.grizzly.asyncqueue.WritableMessage message
        start local 3 // org.glassfish.grizzly.WriteResult currentResult
         0: .line 95
            aload 2 /* message */
            instanceof org.glassfish.grizzly.Buffer
            ifeq 18
         1: .line 96
            aload 2 /* message */
            checkcast org.glassfish.grizzly.Buffer
            astore 6 /* buffer */
        start local 6 // org.glassfish.grizzly.Buffer buffer
         2: .line 99
            aload 6 /* buffer */
            invokeinterface org.glassfish.grizzly.Buffer.hasRemaining:()Z
            ifne 5
         3: .line 100
            lconst_0
            lstore 4 /* written */
        start local 4 // long written
         4: .line 101
            goto 11
        end local 4 // long written
      StackMap locals: org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter org.glassfish.grizzly.nio.NIOConnection org.glassfish.grizzly.asyncqueue.WritableMessage org.glassfish.grizzly.WriteResult top top org.glassfish.grizzly.Buffer
      StackMap stack:
         5: aload 6 /* buffer */
            invokeinterface org.glassfish.grizzly.Buffer.isComposite:()Z
            ifne 9
         6: .line 103
            aload 1 /* connection */
            checkcast org.glassfish.grizzly.nio.transport.TCPNIOConnection
            aload 6 /* buffer */
         7: .line 102
            invokestatic org.glassfish.grizzly.nio.transport.TCPNIOUtils.writeSimpleBuffer:(Lorg/glassfish/grizzly/nio/transport/TCPNIOConnection;Lorg/glassfish/grizzly/Buffer;)I
            i2l
            lstore 4 /* written */
        start local 4 // long written
         8: .line 104
            goto 11
        end local 4 // long written
         9: .line 106
      StackMap locals:
      StackMap stack:
            aload 1 /* connection */
            checkcast org.glassfish.grizzly.nio.transport.TCPNIOConnection
            aload 6 /* buffer */
            checkcast org.glassfish.grizzly.memory.CompositeBuffer
        10: .line 105
            invokestatic org.glassfish.grizzly.nio.transport.TCPNIOUtils.writeCompositeBuffer:(Lorg/glassfish/grizzly/nio/transport/TCPNIOConnection;Lorg/glassfish/grizzly/memory/CompositeBuffer;)I
            i2l
            lstore 4 /* written */
        start local 4 // long written
        11: .line 109
      StackMap locals: org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter org.glassfish.grizzly.nio.NIOConnection org.glassfish.grizzly.asyncqueue.WritableMessage org.glassfish.grizzly.WriteResult long org.glassfish.grizzly.Buffer
      StackMap stack:
            aload 1 /* connection */
            checkcast org.glassfish.grizzly.nio.transport.TCPNIOConnection
            aload 6 /* buffer */
            lload 4 /* written */
            invokevirtual org.glassfish.grizzly.nio.transport.TCPNIOConnection.onWrite:(Lorg/glassfish/grizzly/Buffer;J)V
        12: .line 110
            goto 23
        end local 4 // long written
      StackMap locals: org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter org.glassfish.grizzly.nio.NIOConnection org.glassfish.grizzly.asyncqueue.WritableMessage org.glassfish.grizzly.WriteResult top top org.glassfish.grizzly.Buffer
      StackMap stack: java.io.IOException
        13: astore 7 /* e */
        start local 7 // java.io.IOException e
        14: .line 112
            aload 1 /* connection */
            checkcast org.glassfish.grizzly.nio.transport.TCPNIOConnection
            aconst_null
        15: .line 113
            new org.glassfish.grizzly.CloseReason
            dup
            getstatic org.glassfish.grizzly.CloseType.REMOTELY:Lorg/glassfish/grizzly/CloseType;
            aload 7 /* e */
            invokespecial org.glassfish.grizzly.CloseReason.<init>:(Lorg/glassfish/grizzly/CloseType;Ljava/io/IOException;)V
        16: .line 112
            invokevirtual org.glassfish.grizzly.nio.transport.TCPNIOConnection.terminate0:(Lorg/glassfish/grizzly/CompletionHandler;Lorg/glassfish/grizzly/CloseReason;)V
        17: .line 114
            aload 7 /* e */
            athrow
        end local 7 // java.io.IOException e
        end local 6 // org.glassfish.grizzly.Buffer buffer
        18: .line 116
      StackMap locals: org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter org.glassfish.grizzly.nio.NIOConnection org.glassfish.grizzly.asyncqueue.WritableMessage org.glassfish.grizzly.WriteResult
      StackMap stack:
            aload 2 /* message */
            instanceof org.glassfish.grizzly.FileTransfer
            ifeq 22
        19: .line 117
            aload 2 /* message */
            checkcast org.glassfish.grizzly.FileTransfer
            aload 1 /* connection */
            invokevirtual org.glassfish.grizzly.nio.NIOConnection.getChannel:()Ljava/nio/channels/SelectableChannel;
            checkcast java.nio.channels.SocketChannel
            invokevirtual org.glassfish.grizzly.FileTransfer.writeTo:(Ljava/nio/channels/WritableByteChannel;)J
            lstore 4 /* written */
        start local 4 // long written
        20: .line 118
            aload 1 /* connection */
            checkcast org.glassfish.grizzly.nio.transport.TCPNIOConnection
            aconst_null
            lload 4 /* written */
            invokevirtual org.glassfish.grizzly.nio.transport.TCPNIOConnection.onWrite:(Lorg/glassfish/grizzly/Buffer;J)V
        21: .line 119
            goto 23
        end local 4 // long written
        22: .line 120
      StackMap locals:
      StackMap stack:
            new java.lang.IllegalStateException
            dup
            ldc "Unhandled message type"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
        start local 4 // long written
        23: .line 123
      StackMap locals: long
      StackMap stack:
            aload 3 /* currentResult */
            ifnull 31
        24: .line 124
            aload 3 /* currentResult */
            aload 2 /* message */
            invokevirtual org.glassfish.grizzly.WriteResult.setMessage:(Ljava/lang/Object;)V
        25: .line 125
            aload 3 /* currentResult */
            aload 3 /* currentResult */
            invokevirtual org.glassfish.grizzly.WriteResult.getWrittenSize:()J
        26: .line 126
            lload 4 /* written */
            ladd
        27: .line 125
            invokevirtual org.glassfish.grizzly.WriteResult.setWrittenSize:(J)V
        28: .line 127
            aload 3 /* currentResult */
        29: .line 128
            aload 1 /* connection */
            checkcast org.glassfish.grizzly.nio.transport.TCPNIOConnection
            getfield org.glassfish.grizzly.nio.transport.TCPNIOConnection.peerSocketAddressHolder:Lorg/glassfish/grizzly/utils/Holder;
        30: .line 127
            invokevirtual org.glassfish.grizzly.WriteResult.setDstAddressHolder:(Lorg/glassfish/grizzly/utils/Holder;)V
        31: .line 131
      StackMap locals:
      StackMap stack:
            lload 4 /* written */
            lreturn
        end local 4 // long written
        end local 3 // org.glassfish.grizzly.WriteResult currentResult
        end local 2 // org.glassfish.grizzly.asyncqueue.WritableMessage message
        end local 1 // org.glassfish.grizzly.nio.NIOConnection connection
        end local 0 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0   32     0           this  Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter;
            0   32     1     connection  Lorg/glassfish/grizzly/nio/NIOConnection;
            0   32     2        message  Lorg/glassfish/grizzly/asyncqueue/WritableMessage;
            0   32     3  currentResult  Lorg/glassfish/grizzly/WriteResult<Lorg/glassfish/grizzly/asyncqueue/WritableMessage;Ljava/net/SocketAddress;>;
            4    5     4        written  J
            8    9     4        written  J
           11   13     4        written  J
           20   22     4        written  J
           23   32     4        written  J
            2   18     6         buffer  Lorg/glassfish/grizzly/Buffer;
           14   18     7              e  Ljava/io/IOException;
      Exception table:
        from    to  target  type
           2    12      13  Class java.io.IOException
    Exceptions:
      throws java.io.IOException
    Signature: (Lorg/glassfish/grizzly/nio/NIOConnection;Lorg/glassfish/grizzly/asyncqueue/WritableMessage;Lorg/glassfish/grizzly/WriteResult<Lorg/glassfish/grizzly/asyncqueue/WritableMessage;Ljava/net/SocketAddress;>;)J
    MethodParameters:
               Name  Flags
      connection     final
      message        final
      currentResult  final

  private org.glassfish.grizzly.asyncqueue.RecordWriteResult writeCompositeRecord(org.glassfish.grizzly.nio.NIOConnection, org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord);
    descriptor: (Lorg/glassfish/grizzly/nio/NIOConnection;Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter$CompositeQueueRecord;)Lorg/glassfish/grizzly/asyncqueue/RecordWriteResult;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=8, locals=9, args_size=3
        start local 0 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter this
        start local 1 // org.glassfish.grizzly.nio.NIOConnection connection
        start local 2 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord queueRecord
         0: .line 137
            iconst_0
            istore 3 /* written */
        start local 3 // int written
         1: .line 139
            getstatic org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter.LOGGER:Ljava/util/logging/Logger;
            getstatic java.util.logging.Level.FINEST:Ljava/util/logging/Level;
            invokevirtual java.util.logging.Logger.isLoggable:(Ljava/util/logging/Level;)Z
            ifeq 7
         2: .line 140
            getstatic org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter.LOGGER:Ljava/util/logging/Logger;
            getstatic java.util.logging.Level.FINEST:Ljava/util/logging/Level;
         3: .line 141
            ldc "writeCompositeRecord connection={0}, queueRecord={1}, queueRecord.remaining={2}, queueRecord.queue.size()={3}"
         4: .line 144
            iconst_4
            anewarray java.lang.Object
            dup
            iconst_0
            aload 1 /* connection */
            aastore
            dup
            iconst_1
            aload 2 /* queueRecord */
            aastore
            dup
            iconst_2
            aload 2 /* queueRecord */
            invokevirtual org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.remaining:()J
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            aastore
            dup
            iconst_3
         5: .line 145
            aload 2 /* queueRecord */
            getfield org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.queue:Ljava/util/Deque;
            invokeinterface java.util.Deque.size:()I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
         6: .line 140
            invokevirtual java.util.logging.Logger.log:(Ljava/util/logging/Level;Ljava/lang/String;[Ljava/lang/Object;)V
         7: .line 148
      StackMap locals: int
      StackMap stack:
            aload 2 /* queueRecord */
            getfield org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.size:I
            ifle 34
         8: .line 149
            aload 2 /* queueRecord */
            getfield org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.size:I
         9: .line 150
            aload 1 /* connection */
            invokevirtual org.glassfish.grizzly.nio.NIOConnection.getWriteBufferSize:()I
            iconst_3
            imul
            iconst_2
            idiv
        10: .line 149
            invokestatic java.lang.Math.min:(II)I
            istore 4 /* bufferSize */
        start local 4 // int bufferSize
        11: .line 153
            invokestatic org.glassfish.grizzly.nio.DirectByteBufferRecord.get:()Lorg/glassfish/grizzly/nio/DirectByteBufferRecord;
        12: .line 152
            astore 5 /* directByteBufferRecord */
        start local 5 // org.glassfish.grizzly.nio.DirectByteBufferRecord directByteBufferRecord
        13: .line 156
            aload 1 /* connection */
            invokevirtual org.glassfish.grizzly.nio.NIOConnection.getChannel:()Ljava/nio/channels/SelectableChannel;
            checkcast java.nio.channels.SocketChannel
            astore 6 /* socketChannel */
        start local 6 // java.nio.channels.SocketChannel socketChannel
        14: .line 158
            aload 2 /* queueRecord */
            iload 4 /* bufferSize */
            aload 5 /* directByteBufferRecord */
            invokestatic org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter.fill:(Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter$CompositeQueueRecord;ILorg/glassfish/grizzly/nio/DirectByteBufferRecord;)V
        15: .line 159
            aload 5 /* directByteBufferRecord */
            invokevirtual org.glassfish.grizzly.nio.DirectByteBufferRecord.finishBufferSlice:()V
        16: .line 161
            aload 5 /* directByteBufferRecord */
            invokevirtual org.glassfish.grizzly.nio.DirectByteBufferRecord.getArraySize:()I
            istore 7 /* arraySize */
        start local 7 // int arraySize
        17: .line 163
            iload 7 /* arraySize */
            iconst_1
            if_icmpne 21
        18: .line 166
            aload 6 /* socketChannel */
            aload 5 /* directByteBufferRecord */
            invokevirtual org.glassfish.grizzly.nio.DirectByteBufferRecord.getArray:()[Ljava/nio/ByteBuffer;
            iconst_0
            aaload
        19: .line 165
            invokestatic org.glassfish.grizzly.nio.transport.TCPNIOUtils.flushByteBuffer:(Ljava/nio/channels/SocketChannel;Ljava/nio/ByteBuffer;)I
        20: .line 166
            goto 23
        21: .line 169
      StackMap locals: org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter org.glassfish.grizzly.nio.NIOConnection org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord int int org.glassfish.grizzly.nio.DirectByteBufferRecord java.nio.channels.SocketChannel int
      StackMap stack:
            aload 6 /* socketChannel */
            aload 5 /* directByteBufferRecord */
            invokevirtual org.glassfish.grizzly.nio.DirectByteBufferRecord.getArray:()[Ljava/nio/ByteBuffer;
            iconst_0
            iload 7 /* arraySize */
        22: .line 168
            invokestatic org.glassfish.grizzly.nio.transport.TCPNIOUtils.flushByteBuffers:(Ljava/nio/channels/SocketChannel;[Ljava/nio/ByteBuffer;II)I
        23: .line 163
      StackMap locals:
      StackMap stack: int
            istore 3 /* written */
        end local 7 // int arraySize
        end local 6 // java.nio.channels.SocketChannel socketChannel
        24: .line 171
            goto 33
      StackMap locals: org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter org.glassfish.grizzly.nio.NIOConnection org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord int int org.glassfish.grizzly.nio.DirectByteBufferRecord
      StackMap stack: java.io.IOException
        25: astore 6 /* e */
        start local 6 // java.io.IOException e
        26: .line 173
            aload 1 /* connection */
            checkcast org.glassfish.grizzly.nio.transport.TCPNIOConnection
            aconst_null
        27: .line 174
            new org.glassfish.grizzly.CloseReason
            dup
            getstatic org.glassfish.grizzly.CloseType.REMOTELY:Lorg/glassfish/grizzly/CloseType;
            aload 6 /* e */
            invokespecial org.glassfish.grizzly.CloseReason.<init>:(Lorg/glassfish/grizzly/CloseType;Ljava/io/IOException;)V
        28: .line 173
            invokevirtual org.glassfish.grizzly.nio.transport.TCPNIOConnection.terminate0:(Lorg/glassfish/grizzly/CompletionHandler;Lorg/glassfish/grizzly/CloseReason;)V
        29: .line 175
            aload 6 /* e */
            athrow
        end local 6 // java.io.IOException e
        30: .line 176
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 8
        31: .line 177
            aload 5 /* directByteBufferRecord */
            invokevirtual org.glassfish.grizzly.nio.DirectByteBufferRecord.release:()V
        32: .line 178
            aload 8
            athrow
        33: .line 177
      StackMap locals:
      StackMap stack:
            aload 5 /* directByteBufferRecord */
            invokevirtual org.glassfish.grizzly.nio.DirectByteBufferRecord.release:()V
        end local 5 // org.glassfish.grizzly.nio.DirectByteBufferRecord directByteBufferRecord
        end local 4 // int bufferSize
        34: .line 181
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 2 /* queueRecord */
            iload 3 /* written */
            invokevirtual org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter.update:(Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter$CompositeQueueRecord;I)Lorg/glassfish/grizzly/asyncqueue/RecordWriteResult;
            areturn
        end local 3 // int written
        end local 2 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord queueRecord
        end local 1 // org.glassfish.grizzly.nio.NIOConnection connection
        end local 0 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter this
      LocalVariableTable:
        Start  End  Slot                    Name  Signature
            0   35     0                    this  Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter;
            0   35     1              connection  Lorg/glassfish/grizzly/nio/NIOConnection;
            0   35     2             queueRecord  Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter$CompositeQueueRecord;
            1   35     3                 written  I
           11   34     4              bufferSize  I
           13   34     5  directByteBufferRecord  Lorg/glassfish/grizzly/nio/DirectByteBufferRecord;
           14   24     6           socketChannel  Ljava/nio/channels/SocketChannel;
           17   24     7               arraySize  I
           26   30     6                       e  Ljava/io/IOException;
      Exception table:
        from    to  target  type
          13    24      25  Class java.io.IOException
          13    30      30  any
    Exceptions:
      throws java.io.IOException
    MethodParameters:
             Name  Flags
      connection   final
      queueRecord  final

  private static void fill(org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord, int, org.glassfish.grizzly.nio.DirectByteBufferRecord);
    descriptor: (Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter$CompositeQueueRecord;ILorg/glassfish/grizzly/nio/DirectByteBufferRecord;)V
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=4, locals=12, args_size=3
        start local 0 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord queueRecord
        start local 1 // int totalBufferSize
        start local 2 // org.glassfish.grizzly.nio.DirectByteBufferRecord ioRecord
         0: .line 192
            iload 1 /* totalBufferSize */
            istore 3 /* totalRemaining */
        start local 3 // int totalRemaining
         1: .line 193
            aload 0 /* queueRecord */
            getfield org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.queue:Ljava/util/Deque;
            astore 4 /* queue */
        start local 4 // java.util.Deque queue
         2: .line 194
            aload 0 /* queueRecord */
            getfield org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.savedBufferStates:Ljava/util/ArrayList;
            astore 5 /* savedBufferStates */
        start local 5 // java.util.ArrayList savedBufferStates
         3: .line 196
            aload 4 /* queue */
            invokeinterface java.util.Deque.iterator:()Ljava/util/Iterator;
            astore 6 /* it */
        start local 6 // java.util.Iterator it
         4: .line 197
            goto 18
         5: .line 199
      StackMap locals: org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord int org.glassfish.grizzly.nio.DirectByteBufferRecord int java.util.Deque java.util.ArrayList java.util.Iterator
      StackMap stack:
            aload 6 /* it */
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord
            astore 7 /* record */
        start local 7 // org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord record
         6: .line 201
            aload 7 /* record */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.isUncountable:()Z
            ifeq 8
         7: .line 202
            goto 18
         8: .line 205
      StackMap locals: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord
      StackMap stack:
            aload 7 /* record */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.getMessage:()Ljava/lang/Object;
            checkcast org.glassfish.grizzly.Buffer
            astore 8 /* message */
        start local 8 // org.glassfish.grizzly.Buffer message
         9: .line 206
            aload 8 /* message */
            invokeinterface org.glassfish.grizzly.Buffer.position:()I
            istore 9 /* pos */
        start local 9 // int pos
        10: .line 208
            aload 8 /* message */
            invokeinterface org.glassfish.grizzly.Buffer.remaining:()I
            istore 10 /* messageRemaining */
        start local 10 // int messageRemaining
        11: .line 211
            iload 3 /* totalRemaining */
            iload 10 /* messageRemaining */
            if_icmplt 13
        12: .line 212
            aload 8 /* message */
            invokeinterface org.glassfish.grizzly.Buffer.toBufferArray:()Lorg/glassfish/grizzly/memory/BufferArray;
            goto 14
        13: .line 213
      StackMap locals: org.glassfish.grizzly.Buffer int int
      StackMap stack:
            aload 8 /* message */
            iload 9 /* pos */
            iload 9 /* pos */
            iload 3 /* totalRemaining */
            iadd
            invokeinterface org.glassfish.grizzly.Buffer.toBufferArray:(II)Lorg/glassfish/grizzly/memory/BufferArray;
        14: .line 210
      StackMap locals:
      StackMap stack: org.glassfish.grizzly.memory.BufferArray
            astore 11 /* bufferArray */
        start local 11 // org.glassfish.grizzly.memory.BufferArray bufferArray
        15: .line 215
            aload 5 /* savedBufferStates */
            aload 11 /* bufferArray */
            invokevirtual java.util.ArrayList.add:(Ljava/lang/Object;)Z
            pop
        16: .line 216
            aload 11 /* bufferArray */
            iload 3 /* totalRemaining */
            aload 2 /* ioRecord */
            invokestatic org.glassfish.grizzly.nio.transport.TCPNIOUtils.fill:(Lorg/glassfish/grizzly/memory/BufferArray;ILorg/glassfish/grizzly/nio/DirectByteBufferRecord;)V
        17: .line 218
            iload 3 /* totalRemaining */
            iload 10 /* messageRemaining */
            isub
            istore 3 /* totalRemaining */
        end local 11 // org.glassfish.grizzly.memory.BufferArray bufferArray
        end local 10 // int messageRemaining
        end local 9 // int pos
        end local 8 // org.glassfish.grizzly.Buffer message
        end local 7 // org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord record
        18: .line 197
      StackMap locals: org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord int org.glassfish.grizzly.nio.DirectByteBufferRecord int java.util.Deque java.util.ArrayList java.util.Iterator
      StackMap stack:
            aload 6 /* it */
            invokeinterface java.util.Iterator.hasNext:()Z
            ifeq 20
            iload 3 /* totalRemaining */
        19: .line 196
            ifgt 5
        end local 6 // java.util.Iterator it
        20: .line 220
      StackMap locals:
      StackMap stack:
            return
        end local 5 // java.util.ArrayList savedBufferStates
        end local 4 // java.util.Deque queue
        end local 3 // int totalRemaining
        end local 2 // org.glassfish.grizzly.nio.DirectByteBufferRecord ioRecord
        end local 1 // int totalBufferSize
        end local 0 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord queueRecord
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0   21     0        queueRecord  Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter$CompositeQueueRecord;
            0   21     1    totalBufferSize  I
            0   21     2           ioRecord  Lorg/glassfish/grizzly/nio/DirectByteBufferRecord;
            1   21     3     totalRemaining  I
            2   21     4              queue  Ljava/util/Deque<Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;>;
            3   21     5  savedBufferStates  Ljava/util/ArrayList<Lorg/glassfish/grizzly/memory/BufferArray;>;
            4   20     6                 it  Ljava/util/Iterator<Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;>;
            6   18     7             record  Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
            9   18     8            message  Lorg/glassfish/grizzly/Buffer;
           10   18     9                pos  I
           11   18    10   messageRemaining  I
           15   18    11        bufferArray  Lorg/glassfish/grizzly/memory/BufferArray;
    MethodParameters:
                 Name  Flags
      queueRecord      final
      totalBufferSize  final
      ioRecord         final

  private org.glassfish.grizzly.asyncqueue.RecordWriteResult update(org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord, int);
    descriptor: (Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter$CompositeQueueRecord;I)Lorg/glassfish/grizzly/asyncqueue/RecordWriteResult;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=12, args_size=3
        start local 0 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter this
        start local 1 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord queueRecord
        start local 2 // int written
         0: .line 226
            iconst_0
            istore 3 /* i */
        start local 3 // int i
         1: goto 7
         2: .line 227
      StackMap locals: int
      StackMap stack:
            aload 1 /* queueRecord */
            getfield org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.savedBufferStates:Ljava/util/ArrayList;
            iload 3 /* i */
            invokevirtual java.util.ArrayList.get:(I)Ljava/lang/Object;
            checkcast org.glassfish.grizzly.memory.BufferArray
            astore 4 /* savedState */
        start local 4 // org.glassfish.grizzly.memory.BufferArray savedState
         3: .line 228
            aload 4 /* savedState */
            ifnull 6
         4: .line 229
            aload 4 /* savedState */
            invokevirtual org.glassfish.grizzly.memory.BufferArray.restore:()V
         5: .line 230
            aload 4 /* savedState */
            invokevirtual org.glassfish.grizzly.memory.BufferArray.recycle:()V
        end local 4 // org.glassfish.grizzly.memory.BufferArray savedState
         6: .line 226
      StackMap locals:
      StackMap stack:
            iinc 3 /* i */ 1
      StackMap locals:
      StackMap stack:
         7: iload 3 /* i */
            aload 1 /* queueRecord */
            getfield org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.savedBufferStates:Ljava/util/ArrayList;
            invokevirtual java.util.ArrayList.size:()I
            if_icmplt 2
        end local 3 // int i
         8: .line 234
            iconst_0
            istore 3 /* extraBytesToRelease */
        start local 3 // int extraBytesToRelease
         9: .line 235
            aload 1 /* queueRecord */
            getfield org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.savedBufferStates:Ljava/util/ArrayList;
            invokevirtual java.util.ArrayList.clear:()V
        10: .line 237
            iload 2 /* written */
            istore 4 /* remainder */
        start local 4 // int remainder
        11: .line 238
            aload 1 /* queueRecord */
            dup
            getfield org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.size:I
            iload 2 /* written */
            isub
            putfield org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.size:I
        12: .line 240
            aload 1 /* queueRecord */
            invokevirtual org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.getConnection:()Lorg/glassfish/grizzly/Connection;
            astore 5 /* connection */
        start local 5 // org.glassfish.grizzly.Connection connection
        13: .line 241
            aload 1 /* queueRecord */
            getfield org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.queue:Ljava/util/Deque;
            astore 6 /* queue */
        start local 6 // java.util.Deque queue
        14: .line 244
            goto 42
        15: .line 245
      StackMap locals: int org.glassfish.grizzly.Connection java.util.Deque
      StackMap stack:
            aload 6 /* queue */
            invokeinterface java.util.Deque.peekFirst:()Ljava/lang/Object;
            checkcast org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord
            astore 7 /* record */
        start local 7 // org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord record
        16: .line 247
            getstatic org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter.$assertionsDisabled:Z
            ifne 17
            aload 7 /* record */
            ifnonnull 17
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        17: .line 249
      StackMap locals: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord
      StackMap stack:
            aload 7 /* record */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.isUncountable:()Z
            ifeq 22
        18: .line 250
            aload 6 /* queue */
            invokeinterface java.util.Deque.removeFirst:()Ljava/lang/Object;
            pop
        19: .line 251
            aload 7 /* record */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.notifyCompleteAndRecycle:()V
        20: .line 252
            iinc 3 /* extraBytesToRelease */ 1
        21: .line 253
            goto 42
        22: .line 256
      StackMap locals:
      StackMap stack:
            aload 7 /* record */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.getCurrentResult:()Lorg/glassfish/grizzly/asyncqueue/RecordWriteResult;
            astore 8 /* firstResult */
        start local 8 // org.glassfish.grizzly.WriteResult firstResult
        23: .line 257
            aload 7 /* record */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.getMessage:()Ljava/lang/Object;
            checkcast org.glassfish.grizzly.Buffer
            astore 9 /* firstMessage */
        start local 9 // org.glassfish.grizzly.Buffer firstMessage
        24: .line 259
            aload 7 /* record */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.getInitialMessageSize:()J
            aload 8 /* firstResult */
            invokevirtual org.glassfish.grizzly.WriteResult.getWrittenSize:()J
            lsub
        25: .line 258
            lstore 10 /* firstMessageRemaining */
        start local 10 // long firstMessageRemaining
        26: .line 261
            iload 4 /* remainder */
            i2l
            lload 10 /* firstMessageRemaining */
            lcmp
            iflt 34
        27: .line 262
            iload 4 /* remainder */
            i2l
            lload 10 /* firstMessageRemaining */
            lsub
            l2i
            istore 4 /* remainder */
        28: .line 263
            aload 6 /* queue */
            invokeinterface java.util.Deque.removeFirst:()Ljava/lang/Object;
            pop
        29: .line 264
            aload 8 /* firstResult */
            aload 7 /* record */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.getInitialMessageSize:()J
            invokevirtual org.glassfish.grizzly.WriteResult.setWrittenSize:(J)V
        30: .line 265
            aload 9 /* firstMessage */
            aload 9 /* firstMessage */
            invokeinterface org.glassfish.grizzly.Buffer.limit:()I
            invokeinterface org.glassfish.grizzly.Buffer.position:(I)Lorg/glassfish/grizzly/Buffer;
            pop
        31: .line 267
            aload 5 /* connection */
            checkcast org.glassfish.grizzly.nio.transport.TCPNIOConnection
            aload 9 /* firstMessage */
            lload 10 /* firstMessageRemaining */
            invokevirtual org.glassfish.grizzly.nio.transport.TCPNIOConnection.onWrite:(Lorg/glassfish/grizzly/Buffer;J)V
        32: .line 269
            aload 7 /* record */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.notifyCompleteAndRecycle:()V
        33: .line 270
            goto 42
        34: .line 271
      StackMap locals: org.glassfish.grizzly.WriteResult org.glassfish.grizzly.Buffer long
      StackMap stack:
            aload 9 /* firstMessage */
            aload 9 /* firstMessage */
            invokeinterface org.glassfish.grizzly.Buffer.position:()I
            iload 4 /* remainder */
            iadd
            invokeinterface org.glassfish.grizzly.Buffer.position:(I)Lorg/glassfish/grizzly/Buffer;
            pop
        35: .line 272
            aload 8 /* firstResult */
        36: .line 273
            aload 8 /* firstResult */
            invokevirtual org.glassfish.grizzly.WriteResult.getWrittenSize:()J
            iload 4 /* remainder */
            i2l
            ladd
        37: .line 272
            invokevirtual org.glassfish.grizzly.WriteResult.setWrittenSize:(J)V
        38: .line 275
            aload 5 /* connection */
            checkcast org.glassfish.grizzly.nio.transport.TCPNIOConnection
            aload 9 /* firstMessage */
            iload 4 /* remainder */
            i2l
            invokevirtual org.glassfish.grizzly.nio.transport.TCPNIOConnection.onWrite:(Lorg/glassfish/grizzly/Buffer;J)V
        39: .line 276
            aload 1 /* queueRecord */
            invokevirtual org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.getCurrentResult:()Lorg/glassfish/grizzly/asyncqueue/RecordWriteResult;
            iload 2 /* written */
            i2l
        40: .line 277
            iload 2 /* written */
            iload 3 /* extraBytesToRelease */
            iadd
            i2l
        41: .line 276
            invokevirtual org.glassfish.grizzly.asyncqueue.RecordWriteResult.lastWriteResult:(JJ)Lorg/glassfish/grizzly/asyncqueue/RecordWriteResult;
            areturn
        end local 10 // long firstMessageRemaining
        end local 9 // org.glassfish.grizzly.Buffer firstMessage
        end local 8 // org.glassfish.grizzly.WriteResult firstResult
        end local 7 // org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord record
        42: .line 244
      StackMap locals: org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord int int int org.glassfish.grizzly.Connection java.util.Deque
      StackMap stack:
            iload 4 /* remainder */
            ifgt 15
        43: .line 281
            goto 47
        start local 7 // org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord record
        44: .line 282
      StackMap locals: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord
      StackMap stack:
            aload 6 /* queue */
            invokeinterface java.util.Deque.removeFirst:()Ljava/lang/Object;
            pop
        45: .line 283
            aload 7 /* record */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.notifyCompleteAndRecycle:()V
        46: .line 284
            iinc 3 /* extraBytesToRelease */ 1
        end local 7 // org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord record
        47: .line 281
      StackMap locals:
      StackMap stack:
            aload 6 /* queue */
            invokeinterface java.util.Deque.peekFirst:()Ljava/lang/Object;
            checkcast org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord
            dup
            astore 7 /* record */
        start local 7 // org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord record
        48: ifnull 49
            aload 7 /* record */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.isUncountable:()Z
            ifne 44
        49: .line 287
      StackMap locals: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord
      StackMap stack:
            aload 1 /* queueRecord */
            invokevirtual org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.getCurrentResult:()Lorg/glassfish/grizzly/asyncqueue/RecordWriteResult;
            iload 2 /* written */
            i2l
        50: .line 288
            iload 2 /* written */
            iload 3 /* extraBytesToRelease */
            iadd
            i2l
        51: .line 287
            invokevirtual org.glassfish.grizzly.asyncqueue.RecordWriteResult.lastWriteResult:(JJ)Lorg/glassfish/grizzly/asyncqueue/RecordWriteResult;
            areturn
        end local 7 // org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord record
        end local 6 // java.util.Deque queue
        end local 5 // org.glassfish.grizzly.Connection connection
        end local 4 // int remainder
        end local 3 // int extraBytesToRelease
        end local 2 // int written
        end local 1 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord queueRecord
        end local 0 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter this
      LocalVariableTable:
        Start  End  Slot                   Name  Signature
            0   52     0                   this  Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter;
            0   52     1            queueRecord  Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter$CompositeQueueRecord;
            0   52     2                written  I
            1    8     3                      i  I
            3    6     4             savedState  Lorg/glassfish/grizzly/memory/BufferArray;
            9   52     3    extraBytesToRelease  I
           11   52     4              remainder  I
           13   52     5             connection  Lorg/glassfish/grizzly/Connection;
           14   52     6                  queue  Ljava/util/Deque<Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;>;
           16   42     7                 record  Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
           44   47     7                 record  Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
           48   52     7                 record  Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
           23   42     8            firstResult  Lorg/glassfish/grizzly/WriteResult;
           24   42     9           firstMessage  Lorg/glassfish/grizzly/Buffer;
           26   42    10  firstMessageRemaining  J
    MethodParameters:
             Name  Flags
      queueRecord  final
      written      final

  protected final void onReadyToWrite(org.glassfish.grizzly.nio.NIOConnection);
    descriptor: (Lorg/glassfish/grizzly/nio/NIOConnection;)V
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter this
        start local 1 // org.glassfish.grizzly.nio.NIOConnection connection
         0: .line 293
            aload 1 /* connection */
            getstatic org.glassfish.grizzly.IOEvent.WRITE:Lorg/glassfish/grizzly/IOEvent;
            invokevirtual org.glassfish.grizzly.nio.NIOConnection.enableIOEvent:(Lorg/glassfish/grizzly/IOEvent;)V
         1: .line 294
            return
        end local 1 // org.glassfish.grizzly.nio.NIOConnection connection
        end local 0 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    2     0        this  Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter;
            0    2     1  connection  Lorg/glassfish/grizzly/nio/NIOConnection;
    Exceptions:
      throws java.io.IOException
    MethodParameters:
            Name  Flags
      connection  final

  protected org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord aggregate(org.glassfish.grizzly.asyncqueue.TaskQueue<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord>);
    descriptor: (Lorg/glassfish/grizzly/asyncqueue/TaskQueue;)Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=4, locals=6, args_size=2
        start local 0 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter this
        start local 1 // org.glassfish.grizzly.asyncqueue.TaskQueue writeTaskQueue
         0: .line 302
            aload 1 /* writeTaskQueue */
            invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.size:()I
            istore 2 /* queueSize */
        start local 2 // int queueSize
         1: .line 304
            iload 2 /* queueSize */
            ifne 3
         2: .line 305
            aconst_null
            areturn
         3: .line 308
      StackMap locals: int
      StackMap stack:
            aload 1 /* writeTaskQueue */
            invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.poll:()Lorg/glassfish/grizzly/asyncqueue/AsyncQueueRecord;
            checkcast org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord
            astore 3 /* currentRecord */
        start local 3 // org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord currentRecord
         4: .line 310
            aload 3 /* currentRecord */
            ifnull 7
         5: .line 311
            aload 3 /* currentRecord */
            invokestatic org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter.canBeAggregated:(Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;)Z
            ifeq 7
         6: .line 312
            iload 2 /* queueSize */
            i2l
            aload 3 /* currentRecord */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.remaining:()J
            lcmp
            ifne 8
         7: .line 313
      StackMap locals: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord
      StackMap stack:
            aload 3 /* currentRecord */
            areturn
         8: .line 316
      StackMap locals:
      StackMap stack:
            aload 1 /* writeTaskQueue */
            invokestatic org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter.checkAndGetNextRecord:(Lorg/glassfish/grizzly/asyncqueue/TaskQueue;)Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
            astore 4 /* nextRecord */
        start local 4 // org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord nextRecord
         9: .line 318
            aload 4 /* nextRecord */
            ifnonnull 11
        10: .line 319
            aload 3 /* currentRecord */
            areturn
        11: .line 323
      StackMap locals: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord
      StackMap stack:
            aload 0 /* this */
            aload 3 /* currentRecord */
            invokevirtual org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter.createCompositeQueueRecord:(Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;)Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter$CompositeQueueRecord;
        12: .line 322
            astore 5 /* compositeQueueRecord */
        start local 5 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord compositeQueueRecord
        13: .line 326
      StackMap locals: org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord
      StackMap stack:
            aload 5 /* compositeQueueRecord */
            aload 4 /* nextRecord */
            invokevirtual org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.append:(Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;)V
        14: .line 327
            aload 5 /* compositeQueueRecord */
            invokevirtual org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.remaining:()J
            iload 2 /* queueSize */
            i2l
            lcmp
            ifge 16
        15: .line 328
            aload 1 /* writeTaskQueue */
            invokestatic org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter.checkAndGetNextRecord:(Lorg/glassfish/grizzly/asyncqueue/TaskQueue;)Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
            dup
            astore 4 /* nextRecord */
            ifnonnull 13
        16: .line 330
      StackMap locals:
      StackMap stack:
            aload 5 /* compositeQueueRecord */
            areturn
        end local 5 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord compositeQueueRecord
        end local 4 // org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord nextRecord
        end local 3 // org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord currentRecord
        end local 2 // int queueSize
        end local 1 // org.glassfish.grizzly.asyncqueue.TaskQueue writeTaskQueue
        end local 0 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter this
      LocalVariableTable:
        Start  End  Slot                  Name  Signature
            0   17     0                  this  Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter;
            0   17     1        writeTaskQueue  Lorg/glassfish/grizzly/asyncqueue/TaskQueue<Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;>;
            1   17     2             queueSize  I
            4   17     3         currentRecord  Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
            9   17     4            nextRecord  Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
           13   17     5  compositeQueueRecord  Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter$CompositeQueueRecord;
    Signature: (Lorg/glassfish/grizzly/asyncqueue/TaskQueue<Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;>;)Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
    MethodParameters:
                Name  Flags
      writeTaskQueue  final

  private static org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord checkAndGetNextRecord(org.glassfish.grizzly.asyncqueue.TaskQueue<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord>);
    descriptor: (Lorg/glassfish/grizzly/asyncqueue/TaskQueue;)Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // org.glassfish.grizzly.asyncqueue.TaskQueue writeTaskQueue
         0: .line 336
            aload 0 /* writeTaskQueue */
            invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.getQueue:()Ljava/util/Queue;
            invokeinterface java.util.Queue.poll:()Ljava/lang/Object;
            checkcast org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord
            astore 1 /* nextRecord */
        start local 1 // org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord nextRecord
         1: .line 337
            aload 1 /* nextRecord */
            ifnonnull 3
         2: .line 338
            aconst_null
            areturn
         3: .line 339
      StackMap locals: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord
      StackMap stack:
            aload 1 /* nextRecord */
            invokestatic org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter.canBeAggregated:(Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;)Z
            ifne 6
         4: .line 340
            aload 0 /* writeTaskQueue */
            aload 1 /* nextRecord */
            invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.setCurrentElement:(Lorg/glassfish/grizzly/asyncqueue/AsyncQueueRecord;)V
         5: .line 341
            aconst_null
            areturn
         6: .line 344
      StackMap locals:
      StackMap stack:
            aload 1 /* nextRecord */
            areturn
        end local 1 // org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord nextRecord
        end local 0 // org.glassfish.grizzly.asyncqueue.TaskQueue writeTaskQueue
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    7     0  writeTaskQueue  Lorg/glassfish/grizzly/asyncqueue/TaskQueue<Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;>;
            1    7     1      nextRecord  Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
    Signature: (Lorg/glassfish/grizzly/asyncqueue/TaskQueue<Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;>;)Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
    MethodParameters:
                Name  Flags
      writeTaskQueue  final

  private static boolean canBeAggregated(org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord);
    descriptor: (Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;)Z
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord record
         0: .line 348
            aload 0 /* record */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.canBeAggregated:()Z
            ireturn
        end local 0 // org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord record
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  record  Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
    MethodParameters:
        Name  Flags
      record  final

  private org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord createCompositeQueueRecord(org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord);
    descriptor: (Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;)Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter$CompositeQueueRecord;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=4, args_size=2
        start local 0 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter this
        start local 1 // org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord currentRecord
         0: .line 358
            aload 1 /* currentRecord */
            instanceof org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord
            ifne 9
         1: .line 359
            aload 1 /* currentRecord */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.getConnection:()Lorg/glassfish/grizzly/Connection;
            astore 2 /* connection */
        start local 2 // org.glassfish.grizzly.Connection connection
         2: .line 362
            getstatic org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter.COMPOSITE_BUFFER_ATTR:Lorg/glassfish/grizzly/attributes/Attribute;
            aload 2 /* connection */
            invokevirtual org.glassfish.grizzly.attributes.Attribute.get:(Lorg/glassfish/grizzly/attributes/AttributeStorage;)Ljava/lang/Object;
            checkcast org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord
         3: .line 361
            astore 3 /* compositeQueueRecord */
        start local 3 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord compositeQueueRecord
         4: .line 363
            aload 3 /* compositeQueueRecord */
            ifnonnull 7
         5: .line 364
            aload 2 /* connection */
            invokestatic org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.create:(Lorg/glassfish/grizzly/Connection;)Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter$CompositeQueueRecord;
            astore 3 /* compositeQueueRecord */
         6: .line 365
            getstatic org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter.COMPOSITE_BUFFER_ATTR:Lorg/glassfish/grizzly/attributes/Attribute;
            aload 2 /* connection */
            aload 3 /* compositeQueueRecord */
            invokevirtual org.glassfish.grizzly.attributes.Attribute.set:(Lorg/glassfish/grizzly/attributes/AttributeStorage;Ljava/lang/Object;)V
         7: .line 368
      StackMap locals: org.glassfish.grizzly.Connection org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord
      StackMap stack:
            aload 3 /* compositeQueueRecord */
            aload 1 /* currentRecord */
            invokevirtual org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.append:(Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;)V
         8: .line 369
            aload 3 /* compositeQueueRecord */
            areturn
        end local 3 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord compositeQueueRecord
        end local 2 // org.glassfish.grizzly.Connection connection
         9: .line 371
      StackMap locals:
      StackMap stack:
            aload 1 /* currentRecord */
            checkcast org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord
            areturn
        end local 1 // org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord currentRecord
        end local 0 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter this
      LocalVariableTable:
        Start  End  Slot                  Name  Signature
            0   10     0                  this  Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter;
            0   10     1         currentRecord  Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
            2    9     2            connection  Lorg/glassfish/grizzly/Connection;
            4    9     3  compositeQueueRecord  Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter$CompositeQueueRecord;
    MethodParameters:
               Name  Flags
      currentRecord  final
}
SourceFile: "TCPNIOAsyncQueueWriter.java"
NestMembers:
  org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord
InnerClasses:
  private final CompositeQueueRecord = org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord of org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter