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 311
            getstatic org.glassfish.grizzly.Grizzly.DEFAULT_ATTRIBUTE_BUILDER:Lorg/glassfish/grizzly/attributes/AttributeBuilder;
         5: .line 312
            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;
            invokeinterface org.glassfish.grizzly.attributes.AttributeBuilder.createAttribute:(Ljava/lang/String;)Lorg/glassfish/grizzly/attributes/Attribute;
         6: .line 311
            putstatic org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter.COMPOSITE_BUFFER_ATTR:Lorg/glassfish/grizzly/attributes/Attribute;
         7: .line 312
            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 66
            aload 2 /* queueRecord */
            instanceof org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord
            ifeq 2
         1: .line 67
            aload 0 /* this */
            aload 1 /* connection */
            aload 2 /* queueRecord */
            checkcast org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord
            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
         2: .line 70
      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
         3: .line 72
            aload 2 /* queueRecord */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.remaining:()J
            lconst_0
            lcmp
            ifne 7
         4: .line 73
            aload 3 /* writeResult */
            lconst_0
            aload 2 /* queueRecord */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.isUncountable:()Z
            ifeq 5
            iconst_1
            goto 6
      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
         5: iconst_0
      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
         6: i2l
            invokevirtual org.glassfish.grizzly.asyncqueue.RecordWriteResult.lastWriteResult:(JJ)Lorg/glassfish/grizzly/asyncqueue/RecordWriteResult;
            areturn
         7: .line 77
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* connection */
            aload 2 /* queueRecord */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.getWritableMessage:()Lorg/glassfish/grizzly/asyncqueue/WritableMessage;
            aload 3 /* writeResult */
            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
         8: .line 79
            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    9     0         this  Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter;
            0    9     1   connection  Lorg/glassfish/grizzly/nio/NIOConnection;
            0    9     2  queueRecord  Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
            3    9     3  writeResult  Lorg/glassfish/grizzly/asyncqueue/RecordWriteResult;
            8    9     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 87
            aload 2 /* message */
            instanceof org.glassfish.grizzly.Buffer
            ifeq 14
         1: .line 88
            aload 2 /* message */
            checkcast org.glassfish.grizzly.Buffer
            astore 6 /* buffer */
        start local 6 // org.glassfish.grizzly.Buffer buffer
         2: .line 91
            aload 6 /* buffer */
            invokeinterface org.glassfish.grizzly.Buffer.hasRemaining:()Z
            ifne 5
         3: .line 92
            lconst_0
            lstore 4 /* written */
        start local 4 // long written
         4: .line 93
            goto 9
        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 8
         6: .line 94
            aload 1 /* connection */
            checkcast org.glassfish.grizzly.nio.transport.TCPNIOConnection
            aload 6 /* buffer */
            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
         7: .line 95
            goto 9
        end local 4 // long written
         8: .line 96
      StackMap locals:
      StackMap stack:
            aload 1 /* connection */
            checkcast org.glassfish.grizzly.nio.transport.TCPNIOConnection
            aload 6 /* buffer */
            checkcast org.glassfish.grizzly.memory.CompositeBuffer
            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
         9: .line 99
      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
        10: .line 100
            goto 19
        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
        11: astore 7 /* e */
        start local 7 // java.io.IOException e
        12: .line 102
            aload 1 /* connection */
            checkcast org.glassfish.grizzly.nio.transport.TCPNIOConnection
            aconst_null
            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
            invokevirtual org.glassfish.grizzly.nio.transport.TCPNIOConnection.terminate0:(Lorg/glassfish/grizzly/CompletionHandler;Lorg/glassfish/grizzly/CloseReason;)V
        13: .line 103
            aload 7 /* e */
            athrow
        end local 7 // java.io.IOException e
        end local 6 // org.glassfish.grizzly.Buffer buffer
        14: .line 105
      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 18
        15: .line 106
            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
        16: .line 107
            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
        17: .line 108
            goto 19
        end local 4 // long written
        18: .line 109
      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
        19: .line 112
      StackMap locals: long
      StackMap stack:
            aload 3 /* currentResult */
            ifnull 23
        20: .line 113
            aload 3 /* currentResult */
            aload 2 /* message */
            invokevirtual org.glassfish.grizzly.WriteResult.setMessage:(Ljava/lang/Object;)V
        21: .line 114
            aload 3 /* currentResult */
            aload 3 /* currentResult */
            invokevirtual org.glassfish.grizzly.WriteResult.getWrittenSize:()J
            lload 4 /* written */
            ladd
            invokevirtual org.glassfish.grizzly.WriteResult.setWrittenSize:(J)V
        22: .line 115
            aload 3 /* currentResult */
            aload 1 /* connection */
            checkcast org.glassfish.grizzly.nio.transport.TCPNIOConnection
            getfield org.glassfish.grizzly.nio.transport.TCPNIOConnection.peerSocketAddressHolder:Lorg/glassfish/grizzly/utils/Holder;
            invokevirtual org.glassfish.grizzly.WriteResult.setDstAddressHolder:(Lorg/glassfish/grizzly/utils/Holder;)V
        23: .line 118
      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   24     0           this  Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter;
            0   24     1     connection  Lorg/glassfish/grizzly/nio/NIOConnection;
            0   24     2        message  Lorg/glassfish/grizzly/asyncqueue/WritableMessage;
            0   24     3  currentResult  Lorg/glassfish/grizzly/WriteResult<Lorg/glassfish/grizzly/asyncqueue/WritableMessage;Ljava/net/SocketAddress;>;
            4    5     4        written  J
            7    8     4        written  J
            9   11     4        written  J
           16   18     4        written  J
           19   24     4        written  J
            2   14     6         buffer  Lorg/glassfish/grizzly/Buffer;
           12   14     7              e  Ljava/io/IOException;
      Exception table:
        from    to  target  type
           2    10      11  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 123
            iconst_0
            istore 3 /* written */
        start local 3 // int written
         1: .line 125
            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 5
         2: .line 126
            getstatic org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter.LOGGER:Ljava/util/logging/Logger;
            getstatic java.util.logging.Level.FINEST:Ljava/util/logging/Level;
            ldc "writeCompositeRecord connection={0}, queueRecord={1}, queueRecord.remaining={2}, queueRecord.queue.size()={3}"
         3: .line 127
            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
            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
         4: .line 126
            invokevirtual java.util.logging.Logger.log:(Ljava/util/logging/Level;Ljava/lang/String;[Ljava/lang/Object;)V
         5: .line 130
      StackMap locals: int
      StackMap stack:
            aload 2 /* queueRecord */
            getfield org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.size:I
            ifle 24
         6: .line 131
            aload 2 /* queueRecord */
            getfield org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.size:I
            aload 1 /* connection */
            invokevirtual org.glassfish.grizzly.nio.NIOConnection.getWriteBufferSize:()I
            iconst_3
            imul
            iconst_2
            idiv
            invokestatic java.lang.Math.min:(II)I
            istore 4 /* bufferSize */
        start local 4 // int bufferSize
         7: .line 133
            invokestatic org.glassfish.grizzly.nio.DirectByteBufferRecord.get:()Lorg/glassfish/grizzly/nio/DirectByteBufferRecord;
            astore 5 /* directByteBufferRecord */
        start local 5 // org.glassfish.grizzly.nio.DirectByteBufferRecord directByteBufferRecord
         8: .line 136
            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
         9: .line 138
            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
        10: .line 139
            aload 5 /* directByteBufferRecord */
            invokevirtual org.glassfish.grizzly.nio.DirectByteBufferRecord.finishBufferSlice:()V
        11: .line 141
            aload 5 /* directByteBufferRecord */
            invokevirtual org.glassfish.grizzly.nio.DirectByteBufferRecord.getArraySize:()I
            istore 7 /* arraySize */
        start local 7 // int arraySize
        12: .line 143
            iload 7 /* arraySize */
            iconst_1
            if_icmpne 14
        13: .line 145
            aload 6 /* socketChannel */
            aload 5 /* directByteBufferRecord */
            invokevirtual org.glassfish.grizzly.nio.DirectByteBufferRecord.getArray:()[Ljava/nio/ByteBuffer;
            iconst_0
            aaload
            invokestatic org.glassfish.grizzly.nio.transport.TCPNIOUtils.flushByteBuffer:(Ljava/nio/channels/SocketChannel;Ljava/nio/ByteBuffer;)I
            goto 15
        14: .line 147
      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 */
            invokestatic org.glassfish.grizzly.nio.transport.TCPNIOUtils.flushByteBuffers:(Ljava/nio/channels/SocketChannel;[Ljava/nio/ByteBuffer;II)I
        15: .line 143
      StackMap locals:
      StackMap stack: int
            istore 3 /* written */
        end local 7 // int arraySize
        end local 6 // java.nio.channels.SocketChannel socketChannel
        16: .line 149
            goto 23
      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
        17: astore 6 /* e */
        start local 6 // java.io.IOException e
        18: .line 151
            aload 1 /* connection */
            checkcast org.glassfish.grizzly.nio.transport.TCPNIOConnection
            aconst_null
            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
            invokevirtual org.glassfish.grizzly.nio.transport.TCPNIOConnection.terminate0:(Lorg/glassfish/grizzly/CompletionHandler;Lorg/glassfish/grizzly/CloseReason;)V
        19: .line 152
            aload 6 /* e */
            athrow
        end local 6 // java.io.IOException e
        20: .line 153
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 8
        21: .line 154
            aload 5 /* directByteBufferRecord */
            invokevirtual org.glassfish.grizzly.nio.DirectByteBufferRecord.release:()V
        22: .line 155
            aload 8
            athrow
        23: .line 154
      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
        24: .line 158
      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   25     0                    this  Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter;
            0   25     1              connection  Lorg/glassfish/grizzly/nio/NIOConnection;
            0   25     2             queueRecord  Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter$CompositeQueueRecord;
            1   25     3                 written  I
            7   24     4              bufferSize  I
            8   24     5  directByteBufferRecord  Lorg/glassfish/grizzly/nio/DirectByteBufferRecord;
            9   16     6           socketChannel  Ljava/nio/channels/SocketChannel;
           12   16     7               arraySize  I
           18   20     6                       e  Ljava/io/IOException;
      Exception table:
        from    to  target  type
           8    16      17  Class java.io.IOException
           8    20      20  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 167
            iload 1 /* totalBufferSize */
            istore 3 /* totalRemaining */
        start local 3 // int totalRemaining
         1: .line 168
            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 169
            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 171
            aload 4 /* queue */
            invokeinterface java.util.Deque.iterator:()Ljava/util/Iterator;
            astore 6 /* it */
        start local 6 // java.util.Iterator it
         4: goto 17
         5: .line 173
      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 175
            aload 7 /* record */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.isUncountable:()Z
            ifeq 8
         7: .line 176
            goto 17
         8: .line 179
      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 180
            aload 8 /* message */
            invokeinterface org.glassfish.grizzly.Buffer.position:()I
            istore 9 /* pos */
        start local 9 // int pos
        10: .line 182
            aload 8 /* message */
            invokeinterface org.glassfish.grizzly.Buffer.remaining:()I
            istore 10 /* messageRemaining */
        start local 10 // int messageRemaining
        11: .line 184
            iload 3 /* totalRemaining */
            iload 10 /* messageRemaining */
            if_icmplt 12
            aload 8 /* message */
            invokeinterface org.glassfish.grizzly.Buffer.toBufferArray:()Lorg/glassfish/grizzly/memory/BufferArray;
            goto 13
      StackMap locals: org.glassfish.grizzly.Buffer int int
      StackMap stack:
        12: 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;
      StackMap locals:
      StackMap stack: org.glassfish.grizzly.memory.BufferArray
        13: astore 11 /* bufferArray */
        start local 11 // org.glassfish.grizzly.memory.BufferArray bufferArray
        14: .line 186
            aload 5 /* savedBufferStates */
            aload 11 /* bufferArray */
            invokevirtual java.util.ArrayList.add:(Ljava/lang/Object;)Z
            pop
        15: .line 187
            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
        16: .line 189
            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
        17: .line 171
      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 18
            iload 3 /* totalRemaining */
            ifgt 5
        end local 6 // java.util.Iterator it
        18: .line 191
      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   19     0        queueRecord  Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter$CompositeQueueRecord;
            0   19     1    totalBufferSize  I
            0   19     2           ioRecord  Lorg/glassfish/grizzly/nio/DirectByteBufferRecord;
            1   19     3     totalRemaining  I
            2   19     4              queue  Ljava/util/Deque<Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;>;
            3   19     5  savedBufferStates  Ljava/util/ArrayList<Lorg/glassfish/grizzly/memory/BufferArray;>;
            4   18     6                 it  Ljava/util/Iterator<Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;>;
            6   17     7             record  Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
            9   17     8            message  Lorg/glassfish/grizzly/Buffer;
           10   17     9                pos  I
           11   17    10   messageRemaining  I
           14   17    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 196
            iconst_0
            istore 3 /* i */
        start local 3 // int i
         1: goto 7
         2: .line 197
      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 198
            aload 4 /* savedState */
            ifnull 6
         4: .line 199
            aload 4 /* savedState */
            invokevirtual org.glassfish.grizzly.memory.BufferArray.restore:()V
         5: .line 200
            aload 4 /* savedState */
            invokevirtual org.glassfish.grizzly.memory.BufferArray.recycle:()V
        end local 4 // org.glassfish.grizzly.memory.BufferArray savedState
         6: .line 196
      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 204
            iconst_0
            istore 3 /* extraBytesToRelease */
        start local 3 // int extraBytesToRelease
         9: .line 205
            aload 1 /* queueRecord */
            getfield org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.savedBufferStates:Ljava/util/ArrayList;
            invokevirtual java.util.ArrayList.clear:()V
        10: .line 207
            iload 2 /* written */
            istore 4 /* remainder */
        start local 4 // int remainder
        11: .line 208
            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 210
            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 211
            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 214
            goto 37
        15: .line 215
      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 217
            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 219
      StackMap locals: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord
      StackMap stack:
            aload 7 /* record */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.isUncountable:()Z
            ifeq 22
        18: .line 220
            aload 6 /* queue */
            invokeinterface java.util.Deque.removeFirst:()Ljava/lang/Object;
            pop
        19: .line 221
            aload 7 /* record */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.notifyCompleteAndRecycle:()V
        20: .line 222
            iinc 3 /* extraBytesToRelease */ 1
        21: .line 223
            goto 37
        22: .line 226
      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 227
            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 228
            aload 7 /* record */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.getInitialMessageSize:()J
            aload 8 /* firstResult */
            invokevirtual org.glassfish.grizzly.WriteResult.getWrittenSize:()J
            lsub
            lstore 10 /* firstMessageRemaining */
        start local 10 // long firstMessageRemaining
        25: .line 230
            iload 4 /* remainder */
            i2l
            lload 10 /* firstMessageRemaining */
            lcmp
            iflt 33
        26: .line 231
            iload 4 /* remainder */
            i2l
            lload 10 /* firstMessageRemaining */
            lsub
            l2i
            istore 4 /* remainder */
        27: .line 232
            aload 6 /* queue */
            invokeinterface java.util.Deque.removeFirst:()Ljava/lang/Object;
            pop
        28: .line 233
            aload 8 /* firstResult */
            aload 7 /* record */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.getInitialMessageSize:()J
            invokevirtual org.glassfish.grizzly.WriteResult.setWrittenSize:(J)V
        29: .line 234
            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
        30: .line 236
            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
        31: .line 238
            aload 7 /* record */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.notifyCompleteAndRecycle:()V
        32: .line 239
            goto 37
        33: .line 240
      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
        34: .line 241
            aload 8 /* firstResult */
            aload 8 /* firstResult */
            invokevirtual org.glassfish.grizzly.WriteResult.getWrittenSize:()J
            iload 4 /* remainder */
            i2l
            ladd
            invokevirtual org.glassfish.grizzly.WriteResult.setWrittenSize:(J)V
        35: .line 243
            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
        36: .line 244
            aload 1 /* queueRecord */
            invokevirtual org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.getCurrentResult:()Lorg/glassfish/grizzly/asyncqueue/RecordWriteResult;
            iload 2 /* written */
            i2l
            iload 2 /* written */
            iload 3 /* extraBytesToRelease */
            iadd
            i2l
            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
        37: .line 214
      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
        38: .line 248
            goto 42
        start local 7 // org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord record
        39: .line 249
      StackMap locals: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord
      StackMap stack:
            aload 6 /* queue */
            invokeinterface java.util.Deque.removeFirst:()Ljava/lang/Object;
            pop
        40: .line 250
            aload 7 /* record */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.notifyCompleteAndRecycle:()V
        41: .line 251
            iinc 3 /* extraBytesToRelease */ 1
        end local 7 // org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord record
        42: .line 248
      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
        43: ifnull 44
            aload 7 /* record */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.isUncountable:()Z
            ifne 39
        44: .line 254
      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
            iload 2 /* written */
            iload 3 /* extraBytesToRelease */
            iadd
            i2l
            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   45     0                   this  Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter;
            0   45     1            queueRecord  Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter$CompositeQueueRecord;
            0   45     2                written  I
            1    8     3                      i  I
            3    6     4             savedState  Lorg/glassfish/grizzly/memory/BufferArray;
            9   45     3    extraBytesToRelease  I
           11   45     4              remainder  I
           13   45     5             connection  Lorg/glassfish/grizzly/Connection;
           14   45     6                  queue  Ljava/util/Deque<Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;>;
           16   37     7                 record  Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
           39   42     7                 record  Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
           43   45     7                 record  Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
           23   37     8            firstResult  Lorg/glassfish/grizzly/WriteResult;
           24   37     9           firstMessage  Lorg/glassfish/grizzly/Buffer;
           25   37    10  firstMessageRemaining  J
    MethodParameters:
             Name  Flags
      queueRecord  final
      written      final

  protected void onReadyToWrite(org.glassfish.grizzly.nio.NIOConnection);
    descriptor: (Lorg/glassfish/grizzly/nio/NIOConnection;)V
    flags: (0x0004) ACC_PROTECTED
    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 259
            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 260
            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 267
            aload 1 /* writeTaskQueue */
            invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.size:()I
            istore 2 /* queueSize */
        start local 2 // int queueSize
         1: .line 269
            iload 2 /* queueSize */
            ifne 3
         2: .line 270
            aconst_null
            areturn
         3: .line 273
      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 275
            aload 3 /* currentRecord */
            ifnull 5
            aload 3 /* currentRecord */
            invokestatic org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter.canBeAggregated:(Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;)Z
            ifeq 5
            iload 2 /* queueSize */
            i2l
            aload 3 /* currentRecord */
            invokevirtual org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord.remaining:()J
            lcmp
            ifne 6
         5: .line 276
      StackMap locals: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord
      StackMap stack:
            aload 3 /* currentRecord */
            areturn
         6: .line 279
      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
         7: .line 281
            aload 4 /* nextRecord */
            ifnonnull 9
         8: .line 282
            aload 3 /* currentRecord */
            areturn
         9: .line 285
      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;
            astore 5 /* compositeQueueRecord */
        start local 5 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord compositeQueueRecord
        10: .line 288
      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
        11: .line 289
            aload 5 /* compositeQueueRecord */
            invokevirtual org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord.remaining:()J
            iload 2 /* queueSize */
            i2l
            lcmp
            ifge 12
            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 10
        12: .line 291
      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   13     0                  this  Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter;
            0   13     1        writeTaskQueue  Lorg/glassfish/grizzly/asyncqueue/TaskQueue<Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;>;
            1   13     2             queueSize  I
            4   13     3         currentRecord  Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
            7   13     4            nextRecord  Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
           10   13     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 296
            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 297
            aload 1 /* nextRecord */
            ifnonnull 3
         2: .line 298
            aconst_null
            areturn
         3: .line 299
      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 300
            aload 0 /* writeTaskQueue */
            aload 1 /* nextRecord */
            invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.setCurrentElement:(Lorg/glassfish/grizzly/asyncqueue/AsyncQueueRecord;)V
         5: .line 301
            aconst_null
            areturn
         6: .line 304
      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 308
            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 316
            aload 1 /* currentRecord */
            instanceof org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord
            ifne 8
         1: .line 317
            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 319
            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
            astore 3 /* compositeQueueRecord */
        start local 3 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord compositeQueueRecord
         3: .line 320
            aload 3 /* compositeQueueRecord */
            ifnonnull 6
         4: .line 321
            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 */
         5: .line 322
            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
         6: .line 325
      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
         7: .line 326
            aload 3 /* compositeQueueRecord */
            areturn
        end local 3 // org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter$CompositeQueueRecord compositeQueueRecord
        end local 2 // org.glassfish.grizzly.Connection connection
         8: .line 328
      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    9     0                  this  Lorg/glassfish/grizzly/nio/transport/TCPNIOAsyncQueueWriter;
            0    9     1         currentRecord  Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;
            2    8     2            connection  Lorg/glassfish/grizzly/Connection;
            3    8     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