public abstract class io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel<C extends io.undertow.server.protocol.framed.AbstractFramedChannel<C, R, S>, R extends io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel<C, R, S>, S extends io.undertow.server.protocol.framed.AbstractFramedStreamSinkChannel<C, R, S>> implements org.xnio.channels.StreamSourceChannel
  minor version: 0
  major version: 59
  flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
  this_class: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel
  super_class: java.lang.Object
{
  private final org.xnio.ChannelListener$SimpleSetter<? extends R> readSetter;
    descriptor: Lorg/xnio/ChannelListener$SimpleSetter;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Lorg/xnio/ChannelListener$SimpleSetter<+TR;>;

  private final org.xnio.ChannelListener$SimpleSetter<? extends R> closeSetter;
    descriptor: Lorg/xnio/ChannelListener$SimpleSetter;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Lorg/xnio/ChannelListener$SimpleSetter<+TR;>;

  private final C framedChannel;
    descriptor: Lio/undertow/server/protocol/framed/AbstractFramedChannel;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: TC;

  private final java.util.Deque<io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel<C, R, S>.FrameData> pendingFrameData;
    descriptor: Ljava/util/Deque;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Deque<Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>.FrameData;>;

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

  private static final int STATE_DONE;
    descriptor: I
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 2

  private static final int STATE_READS_RESUMED;
    descriptor: I
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 4

  private static final int STATE_CLOSED;
    descriptor: I
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 8

  private static final int STATE_LAST_FRAME;
    descriptor: I
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 16

  private static final int STATE_IN_LISTENER_LOOP;
    descriptor: I
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 32

  private static final int STATE_STREAM_BROKEN;
    descriptor: I
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 64

  private static final int STATE_RETURNED_MINUS_ONE;
    descriptor: I
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 128

  private static final int STATE_WAITNG_MINUS_ONE;
    descriptor: I
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 256

  private volatile io.undertow.connector.PooledByteBuffer data;
    descriptor: Lio/undertow/connector/PooledByteBuffer;
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

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

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

  private final java.lang.Object lock;
    descriptor: Ljava/lang/Object;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

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

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

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

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

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

  private org.xnio.ChannelListener[] closeListeners;
    descriptor: [Lorg/xnio/ChannelListener;
    flags: (0x0002) ACC_PRIVATE

  public void <init>();
    descriptor: (Lio/undertow/server/protocol/framed/AbstractFramedChannel;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
        start local 1 // io.undertow.server.protocol.framed.AbstractFramedChannel framedChannel
         0: .line 92
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 55
            aload 0 /* this */
            new org.xnio.ChannelListener$SimpleSetter
            dup
            invokespecial org.xnio.ChannelListener$SimpleSetter.<init>:()V
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.readSetter:Lorg/xnio/ChannelListener$SimpleSetter;
         2: .line 56
            aload 0 /* this */
            new org.xnio.ChannelListener$SimpleSetter
            dup
            invokespecial org.xnio.ChannelListener$SimpleSetter.<init>:()V
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeSetter:Lorg/xnio/ChannelListener$SimpleSetter;
         3: .line 59
            aload 0 /* this */
            new java.util.LinkedList
            dup
            invokespecial java.util.LinkedList.<init>:()V
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
         4: .line 61
            aload 0 /* this */
            iconst_0
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
         5: .line 84
            aload 0 /* this */
            new java.lang.Object
            dup
            invokespecial java.lang.Object.<init>:()V
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
         6: .line 87
            aload 0 /* this */
            iconst_0
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.readFrameCount:I
         7: .line 88
            aload 0 /* this */
            ldc -1
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.maxStreamSize:J
         8: .line 90
            aload 0 /* this */
            aconst_null
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeListeners:[Lorg/xnio/ChannelListener;
         9: .line 93
            aload 0 /* this */
            aload 1 /* framedChannel */
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.framedChannel:Lio/undertow/server/protocol/framed/AbstractFramedChannel;
        10: .line 94
            aload 0 /* this */
            iconst_1
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waitingForFrame:Z
        11: .line 95
            return
        end local 1 // io.undertow.server.protocol.framed.AbstractFramedChannel framedChannel
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0   12     0           this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
            0   12     1  framedChannel  TC;
    Signature: (TC;)V
    MethodParameters:
               Name  Flags
      framedChannel  

  public void <init>(C, io.undertow.connector.PooledByteBuffer, );
    descriptor: (Lio/undertow/server/protocol/framed/AbstractFramedChannel;Lio/undertow/connector/PooledByteBuffer;J)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=4
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
        start local 1 // io.undertow.server.protocol.framed.AbstractFramedChannel framedChannel
        start local 2 // io.undertow.connector.PooledByteBuffer data
        start local 3 // long frameDataRemaining
         0: .line 97
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 55
            aload 0 /* this */
            new org.xnio.ChannelListener$SimpleSetter
            dup
            invokespecial org.xnio.ChannelListener$SimpleSetter.<init>:()V
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.readSetter:Lorg/xnio/ChannelListener$SimpleSetter;
         2: .line 56
            aload 0 /* this */
            new org.xnio.ChannelListener$SimpleSetter
            dup
            invokespecial org.xnio.ChannelListener$SimpleSetter.<init>:()V
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeSetter:Lorg/xnio/ChannelListener$SimpleSetter;
         3: .line 59
            aload 0 /* this */
            new java.util.LinkedList
            dup
            invokespecial java.util.LinkedList.<init>:()V
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
         4: .line 61
            aload 0 /* this */
            iconst_0
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
         5: .line 84
            aload 0 /* this */
            new java.lang.Object
            dup
            invokespecial java.lang.Object.<init>:()V
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
         6: .line 87
            aload 0 /* this */
            iconst_0
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.readFrameCount:I
         7: .line 88
            aload 0 /* this */
            ldc -1
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.maxStreamSize:J
         8: .line 90
            aload 0 /* this */
            aconst_null
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeListeners:[Lorg/xnio/ChannelListener;
         9: .line 98
            aload 0 /* this */
            aload 1 /* framedChannel */
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.framedChannel:Lio/undertow/server/protocol/framed/AbstractFramedChannel;
        10: .line 99
            aload 0 /* this */
            aload 2 /* data */
            ifnonnull 11
            lload 3 /* frameDataRemaining */
            lconst_0
            lcmp
            ifgt 11
            iconst_1
            goto 12
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel io.undertow.server.protocol.framed.AbstractFramedChannel io.undertow.connector.PooledByteBuffer long
      StackMap stack: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel
        11: iconst_0
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel io.undertow.server.protocol.framed.AbstractFramedChannel io.undertow.connector.PooledByteBuffer long
      StackMap stack: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel int
        12: putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waitingForFrame:Z
        13: .line 100
            aload 0 /* this */
            lload 3 /* frameDataRemaining */
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
        14: .line 101
            aload 0 /* this */
            lload 3 /* frameDataRemaining */
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.currentStreamSize:J
        15: .line 102
            aload 2 /* data */
            ifnull 24
        16: .line 103
            aload 2 /* data */
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
            ifne 23
        17: .line 104
            aload 2 /* data */
            invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
        18: .line 105
            aload 0 /* this */
            aconst_null
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
        19: .line 106
            aload 0 /* this */
            lload 3 /* frameDataRemaining */
            lconst_0
            lcmp
            ifgt 20
            iconst_1
            goto 21
      StackMap locals:
      StackMap stack: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel
        20: iconst_0
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel io.undertow.server.protocol.framed.AbstractFramedChannel io.undertow.connector.PooledByteBuffer long
      StackMap stack: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel int
        21: putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waitingForFrame:Z
        22: .line 107
            goto 24
        23: .line 108
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aconst_null
            aload 2 /* data */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.dataReady:(Lio/undertow/server/protocol/framed/FrameHeaderData;Lio/undertow/connector/PooledByteBuffer;)V
        24: .line 111
      StackMap locals:
      StackMap stack:
            return
        end local 3 // long frameDataRemaining
        end local 2 // io.undertow.connector.PooledByteBuffer data
        end local 1 // io.undertow.server.protocol.framed.AbstractFramedChannel framedChannel
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0   25     0                this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
            0   25     1       framedChannel  TC;
            0   25     2                data  Lio/undertow/connector/PooledByteBuffer;
            0   25     3  frameDataRemaining  J
    Signature: (TC;Lio/undertow/connector/PooledByteBuffer;J)V
    MethodParameters:
                    Name  Flags
      framedChannel       
      data                
      frameDataRemaining  

  public long transferTo(long, long, java.nio.channels.FileChannel);
    descriptor: (JJLjava/nio/channels/FileChannel;)J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=11, args_size=4
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
        start local 1 // long position
        start local 3 // long count
        start local 5 // java.nio.channels.FileChannel target
         0: .line 115
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            iconst_2
            invokestatic org.xnio.Bits.anyAreSet:(II)Z
            ifeq 2
         1: .line 116
            ldc -1
            lreturn
         2: .line 118
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.beforeRead:()V
         3: .line 119
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waitingForFrame:Z
            ifeq 5
         4: .line 120
            lconst_0
            lreturn
         5: .line 123
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
            lconst_0
            lcmp
            ifne 13
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            bipush 16
            invokestatic org.xnio.Bits.anyAreSet:(II)Z
            ifeq 13
         6: .line 124
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
            dup
            astore 6
            monitorenter
         7: .line 125
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            sipush 128
            ior
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
         8: .line 126
            aload 6
            monitorexit
         9: .line 142
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
        10: .line 126
            ldc -1
            lreturn
        11: .line 124
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel long long java.nio.channels.FileChannel java.lang.Object
      StackMap stack: java.lang.Throwable
            aload 6
            monitorexit
        12: athrow
        13: .line 128
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            ifnull 26
        14: .line 129
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.limit:()I
            istore 6 /* old */
        start local 6 // int old
        15: .line 131
            lload 3 /* count */
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.remaining:()I
            i2l
            lcmp
            ifge 17
        16: .line 132
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.position:()I
            i2l
            lload 3 /* count */
            ladd
            l2i
            invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
            pop
        17: .line 134
      StackMap locals: int
      StackMap stack:
            aload 5 /* target */
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            lload 1 /* position */
            invokevirtual java.nio.channels.FileChannel.write:(Ljava/nio/ByteBuffer;J)I
            i2l
            lstore 8
        18: .line 136
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            iload 6 /* old */
            invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
            pop
        19: .line 137
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.decrementFrameDataRemaining:()V
        20: .line 142
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
        21: .line 134
            lload 8
            lreturn
        22: .line 135
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 7
        23: .line 136
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            iload 6 /* old */
            invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
            pop
        24: .line 137
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.decrementFrameDataRemaining:()V
        25: .line 138
            aload 7
            athrow
        end local 6 // int old
        26: .line 142
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
        27: .line 140
            lconst_0
            lreturn
        28: .line 141
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 10
        29: .line 142
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
        30: .line 143
            aload 10
            athrow
        end local 5 // java.nio.channels.FileChannel target
        end local 3 // long count
        end local 1 // long position
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   31     0      this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
            0   31     1  position  J
            0   31     3     count  J
            0   31     5    target  Ljava/nio/channels/FileChannel;
           15   26     6       old  I
      Exception table:
        from    to  target  type
           7     9      11  any
          11    12      11  any
          15    18      22  any
           5     9      28  any
          11    20      28  any
          22    26      28  any
    Exceptions:
      throws java.io.IOException
    MethodParameters:
          Name  Flags
      position  
      count     
      target    

  private void decrementFrameDataRemaining();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=1, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 147
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
            ifne 2
         1: .line 148
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.currentDataOriginalSize:I
            i2l
            lsub
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
         2: .line 150
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;

  public long transferTo(long, java.nio.ByteBuffer, org.xnio.channels.StreamSinkChannel);
    descriptor: (JLjava/nio/ByteBuffer;Lorg/xnio/channels/StreamSinkChannel;)J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=11, args_size=4
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
        start local 1 // long count
        start local 3 // java.nio.ByteBuffer throughBuffer
        start local 4 // org.xnio.channels.StreamSinkChannel streamSinkChannel
         0: .line 154
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            iconst_2
            invokestatic org.xnio.Bits.anyAreSet:(II)Z
            ifeq 2
         1: .line 155
            ldc -1
            lreturn
         2: .line 157
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.beforeRead:()V
         3: .line 158
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waitingForFrame:Z
            ifeq 6
         4: .line 159
            aload 3 /* throughBuffer */
            aload 3 /* throughBuffer */
            invokevirtual java.nio.ByteBuffer.limit:()I
            invokevirtual java.nio.ByteBuffer.position:(I)Ljava/nio/Buffer;
            pop
         5: .line 160
            lconst_0
            lreturn
         6: .line 163
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
            lconst_0
            lcmp
            ifne 14
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            bipush 16
            invokestatic org.xnio.Bits.anyAreSet:(II)Z
            ifeq 14
         7: .line 164
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
            dup
            astore 5
            monitorenter
         8: .line 165
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            sipush 128
            ior
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
         9: .line 166
            aload 5
            monitorexit
        10: .line 194
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
        11: .line 166
            ldc -1
            lreturn
        12: .line 164
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel long java.nio.ByteBuffer org.xnio.channels.StreamSinkChannel java.lang.Object
      StackMap stack: java.lang.Throwable
            aload 5
            monitorexit
        13: athrow
        14: .line 168
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            ifnull 34
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
            ifeq 34
        15: .line 169
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.limit:()I
            istore 5 /* old */
        start local 5 // int old
        16: .line 171
            lload 1 /* count */
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.remaining:()I
            i2l
            lcmp
            ifge 18
        17: .line 172
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.position:()I
            i2l
            lload 1 /* count */
            ladd
            l2i
            invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
            pop
        18: .line 174
      StackMap locals: int
      StackMap stack:
            aload 4 /* streamSinkChannel */
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokeinterface org.xnio.channels.StreamSinkChannel.write:(Ljava/nio/ByteBuffer;)I
            istore 6 /* written */
        start local 6 // int written
        19: .line 175
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
            ifeq 24
        20: .line 178
            aload 3 /* throughBuffer */
            invokevirtual java.nio.ByteBuffer.clear:()Ljava/nio/Buffer;
            pop
        21: .line 179
            aload 3 /* throughBuffer */
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokestatic org.xnio.Buffers.copy:(Ljava/nio/ByteBuffer;Ljava/nio/ByteBuffer;)I
            pop
        22: .line 180
            aload 3 /* throughBuffer */
            invokevirtual java.nio.ByteBuffer.flip:()Ljava/nio/Buffer;
            pop
        23: .line 181
            goto 25
        24: .line 182
      StackMap locals: int
      StackMap stack:
            aload 3 /* throughBuffer */
            aload 3 /* throughBuffer */
            invokevirtual java.nio.ByteBuffer.limit:()I
            invokevirtual java.nio.ByteBuffer.position:(I)Ljava/nio/Buffer;
            pop
        25: .line 184
      StackMap locals:
      StackMap stack:
            iload 6 /* written */
            i2l
            lstore 8
        26: .line 186
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            iload 5 /* old */
            invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
            pop
        27: .line 187
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.decrementFrameDataRemaining:()V
        28: .line 194
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
        29: .line 184
            lload 8
            lreturn
        end local 6 // int written
        30: .line 185
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel long java.nio.ByteBuffer org.xnio.channels.StreamSinkChannel int
      StackMap stack: java.lang.Throwable
            astore 7
        31: .line 186
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            iload 5 /* old */
            invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
            pop
        32: .line 187
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.decrementFrameDataRemaining:()V
        33: .line 188
            aload 7
            athrow
        end local 5 // int old
        34: .line 190
      StackMap locals:
      StackMap stack:
            aload 3 /* throughBuffer */
            aload 3 /* throughBuffer */
            invokevirtual java.nio.ByteBuffer.limit:()I
            invokevirtual java.nio.ByteBuffer.position:(I)Ljava/nio/Buffer;
            pop
        35: .line 194
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
        36: .line 192
            lconst_0
            lreturn
        37: .line 193
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 10
        38: .line 194
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
        39: .line 195
            aload 10
            athrow
        end local 4 // org.xnio.channels.StreamSinkChannel streamSinkChannel
        end local 3 // java.nio.ByteBuffer throughBuffer
        end local 1 // long count
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0   40     0               this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
            0   40     1              count  J
            0   40     3      throughBuffer  Ljava/nio/ByteBuffer;
            0   40     4  streamSinkChannel  Lorg/xnio/channels/StreamSinkChannel;
           16   34     5                old  I
           19   30     6            written  I
      Exception table:
        from    to  target  type
           8    10      12  any
          12    13      12  any
          16    26      30  any
           6    10      37  any
          12    28      37  any
          30    35      37  any
    Exceptions:
      throws java.io.IOException
    MethodParameters:
                   Name  Flags
      count              
      throughBuffer      
      streamSinkChannel  

  public long getMaxStreamSize();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 199
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.maxStreamSize:J
            lreturn
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;

  public void setMaxStreamSize(long);
    descriptor: (J)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
        start local 1 // long maxStreamSize
         0: .line 203
            aload 0 /* this */
            lload 1 /* maxStreamSize */
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.maxStreamSize:J
         1: .line 204
            lload 1 /* maxStreamSize */
            lconst_0
            lcmp
            ifle 4
         2: .line 205
            lload 1 /* maxStreamSize */
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.currentStreamSize:J
            lcmp
            ifge 4
         3: .line 206
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.handleStreamTooLarge:()V
         4: .line 209
      StackMap locals:
      StackMap stack:
            return
        end local 1 // long maxStreamSize
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    5     0           this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
            0    5     1  maxStreamSize  J
    MethodParameters:
               Name  Flags
      maxStreamSize  

  private void handleStreamTooLarge();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 212
            aload 0 /* this */
            invokestatic org.xnio.IoUtils.safeClose:(Ljava/io/Closeable;)V
         1: .line 213
            return
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;

  public void suspendReads();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 217
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
            dup
            astore 1
            monitorenter
         1: .line 218
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            bipush -5
            iand
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
         2: .line 217
            aload 1
            monitorexit
         3: goto 6
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel java.lang.Object
      StackMap stack: java.lang.Throwable
         4: aload 1
            monitorexit
         5: athrow
         6: .line 220
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
      Exception table:
        from    to  target  type
           1     3       4  any
           4     5       4  any

  protected void complete();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 228
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.close:()V
         1: .line 229
            return
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
    Exceptions:
      throws java.io.IOException

  protected boolean isComplete();
    descriptor: ()Z
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 232
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            iconst_2
            invokestatic org.xnio.Bits.anyAreSet:(II)Z
            ireturn
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;

  public void resumeReads();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 237
            aload 0 /* this */
            iconst_0
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.resumeReadsInternal:(Z)V
         1: .line 238
            return
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;

  public boolean isReadResumed();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 242
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            iconst_4
            invokestatic org.xnio.Bits.anyAreSet:(II)Z
            ireturn
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;

  public void wakeupReads();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 247
            aload 0 /* this */
            iconst_1
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.resumeReadsInternal:(Z)V
         1: .line 248
            return
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;

  public void addCloseTask(org.xnio.ChannelListener<R>);
    descriptor: (Lorg/xnio/ChannelListener;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=3, args_size=2
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
        start local 1 // org.xnio.ChannelListener channelListener
         0: .line 251
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeListeners:[Lorg/xnio/ChannelListener;
            ifnonnull 3
         1: .line 252
            aload 0 /* this */
            iconst_1
            anewarray org.xnio.ChannelListener
            dup
            iconst_0
            aload 1 /* channelListener */
            aastore
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeListeners:[Lorg/xnio/ChannelListener;
         2: .line 253
            goto 7
         3: .line 254
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeListeners:[Lorg/xnio/ChannelListener;
            astore 2 /* old */
        start local 2 // org.xnio.ChannelListener[] old
         4: .line 255
            aload 0 /* this */
            aload 2 /* old */
            arraylength
            iconst_1
            iadd
            anewarray org.xnio.ChannelListener
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeListeners:[Lorg/xnio/ChannelListener;
         5: .line 256
            aload 2 /* old */
            iconst_0
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeListeners:[Lorg/xnio/ChannelListener;
            iconst_0
            aload 2 /* old */
            arraylength
            invokestatic java.lang.System.arraycopy:(Ljava/lang/Object;ILjava/lang/Object;II)V
         6: .line 257
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeListeners:[Lorg/xnio/ChannelListener;
            aload 2 /* old */
            arraylength
            aload 1 /* channelListener */
            aastore
        end local 2 // org.xnio.ChannelListener[] old
         7: .line 259
      StackMap locals:
      StackMap stack:
            return
        end local 1 // org.xnio.ChannelListener channelListener
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    8     0             this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
            0    8     1  channelListener  Lorg/xnio/ChannelListener<TR;>;
            4    7     2              old  [Lorg/xnio/ChannelListener;
    Signature: (Lorg/xnio/ChannelListener<TR;>;)V
    MethodParameters:
                 Name  Flags
      channelListener  

  void resumeReadsInternal(boolean);
    descriptor: (Z)V
    flags: (0x0000) 
    Code:
      stack=4, locals=4, args_size=2
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
        start local 1 // boolean wakeup
         0: .line 265
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
            dup
            astore 2
            monitorenter
         1: .line 266
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            iconst_4
            invokestatic org.xnio.Bits.anyAreSet:(II)Z
            istore 3 /* alreadyResumed */
        start local 3 // boolean alreadyResumed
         2: .line 267
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            iconst_4
            ior
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
         3: .line 268
            iload 3 /* alreadyResumed */
            ifeq 4
            iload 1 /* wakeup */
            ifeq 7
         4: .line 269
      StackMap locals: java.lang.Object int
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            bipush 32
            invokestatic org.xnio.Bits.anyAreSet:(II)Z
            ifne 7
         5: .line 270
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            bipush 32
            ior
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
         6: .line 271
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.getFramedChannel:()Lio/undertow/server/protocol/framed/AbstractFramedChannel;
            new io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$1
            dup
            aload 0 /* this */
            invokespecial io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$1.<init>:(Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel;)V
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedChannel.runInIoThread:(Ljava/lang/Runnable;)V
        end local 3 // boolean alreadyResumed
         7: .line 265
      StackMap locals:
      StackMap stack:
            aload 2
            monitorexit
         8: goto 11
      StackMap locals:
      StackMap stack: java.lang.Throwable
         9: aload 2
            monitorexit
        10: athrow
        11: .line 297
      StackMap locals:
      StackMap stack:
            return
        end local 1 // boolean wakeup
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0   12     0            this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
            0   12     1          wakeup  Z
            2    7     3  alreadyResumed  Z
      Exception table:
        from    to  target  type
           1     8       9  any
           9    10       9  any
    MethodParameters:
        Name  Flags
      wakeup  

  private org.xnio.ChannelListener<? super R> getReadListener();
    descriptor: ()Lorg/xnio/ChannelListener;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 300
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.readSetter:Lorg/xnio/ChannelListener$SimpleSetter;
            invokevirtual org.xnio.ChannelListener$SimpleSetter.get:()Lorg/xnio/ChannelListener;
            areturn
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
    Signature: ()Lorg/xnio/ChannelListener<-TR;>;

  public void shutdownReads();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 305
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.close:()V
         1: .line 306
            return
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
    Exceptions:
      throws java.io.IOException

  protected void lastFrame();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=4, locals=2, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 309
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
            dup
            astore 1
            monitorenter
         1: .line 310
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            bipush 16
            ior
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
         2: .line 309
            aload 1
            monitorexit
         3: goto 6
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel java.lang.Object
      StackMap stack: java.lang.Throwable
         4: aload 1
            monitorexit
         5: athrow
         6: .line 312
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_0
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waitingForFrame:Z
         7: .line 313
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            ifnonnull 11
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
            invokeinterface java.util.Deque.isEmpty:()Z
            ifeq 11
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
            lconst_0
            lcmp
            ifne 11
         8: .line 314
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            bipush 10
            ior
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
         9: .line 315
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.getFramedChannel:()Lio/undertow/server/protocol/framed/AbstractFramedChannel;
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedChannel.notifyFrameReadComplete:(Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel;)V
        10: .line 316
            aload 0 /* this */
            invokestatic org.xnio.IoUtils.safeClose:(Ljava/io/Closeable;)V
        11: .line 318
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   12     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
      Exception table:
        from    to  target  type
           1     3       4  any
           4     5       4  any

  protected boolean isLastFrame();
    descriptor: ()Z
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 321
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            bipush 16
            invokestatic org.xnio.Bits.anyAreSet:(II)Z
            ireturn
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;

  public void awaitReadable();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 326
            invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.getIoThread:()Lorg/xnio/XnioIoThread;
            if_acmpne 2
         1: .line 327
            getstatic io.undertow.UndertowMessages.MESSAGES:Lio/undertow/UndertowMessages;
            invokeinterface io.undertow.UndertowMessages.awaitCalledFromIoThread:()Ljava/io/IOException;
            athrow
         2: .line 329
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            ifnonnull 19
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
            invokeinterface java.util.Deque.isEmpty:()Z
            ifeq 19
         3: .line 330
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
            dup
            astore 1
            monitorenter
         4: .line 331
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            ifnonnull 15
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
            invokeinterface java.util.Deque.isEmpty:()Z
            ifeq 15
         5: .line 333
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
            iconst_1
            iadd
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
         6: .line 334
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
            invokevirtual java.lang.Object.wait:()V
         7: .line 335
            goto 14
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel java.lang.Object
      StackMap stack: java.lang.InterruptedException
         8: pop
         9: .line 336
            invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
            invokevirtual java.lang.Thread.interrupt:()V
        10: .line 337
            new java.io.InterruptedIOException
            dup
            invokespecial java.io.InterruptedIOException.<init>:()V
            athrow
        11: .line 338
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 2
        12: .line 339
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
            iconst_1
            isub
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
        13: .line 340
            aload 2
            athrow
        14: .line 339
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
            iconst_1
            isub
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
        15: .line 330
      StackMap locals:
      StackMap stack:
            aload 1
            monitorexit
        16: goto 19
      StackMap locals:
      StackMap stack: java.lang.Throwable
        17: aload 1
            monitorexit
        18: athrow
        19: .line 344
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   20     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
      Exception table:
        from    to  target  type
           5     7       8  Class java.lang.InterruptedException
           5    11      11  any
           4    16      17  any
          17    18      17  any
    Exceptions:
      throws java.io.IOException

  public void awaitReadable(long, java.util.concurrent.TimeUnit);
    descriptor: (JLjava/util/concurrent/TimeUnit;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=6, args_size=3
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
        start local 1 // long l
        start local 3 // java.util.concurrent.TimeUnit timeUnit
         0: .line 348
            invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.getIoThread:()Lorg/xnio/XnioIoThread;
            if_acmpne 2
         1: .line 349
            getstatic io.undertow.UndertowMessages.MESSAGES:Lio/undertow/UndertowMessages;
            invokeinterface io.undertow.UndertowMessages.awaitCalledFromIoThread:()Ljava/io/IOException;
            athrow
         2: .line 351
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            ifnonnull 19
         3: .line 352
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
            dup
            astore 4
            monitorenter
         4: .line 353
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            ifnonnull 15
         5: .line 355
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
            iconst_1
            iadd
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
         6: .line 356
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
            aload 3 /* timeUnit */
            lload 1 /* l */
            invokevirtual java.util.concurrent.TimeUnit.toMillis:(J)J
            invokevirtual java.lang.Object.wait:(J)V
         7: .line 357
            goto 14
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel long java.util.concurrent.TimeUnit java.lang.Object
      StackMap stack: java.lang.InterruptedException
         8: pop
         9: .line 358
            invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
            invokevirtual java.lang.Thread.interrupt:()V
        10: .line 359
            new java.io.InterruptedIOException
            dup
            invokespecial java.io.InterruptedIOException.<init>:()V
            athrow
        11: .line 360
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 5
        12: .line 361
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
            iconst_1
            isub
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
        13: .line 362
            aload 5
            athrow
        14: .line 361
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
            iconst_1
            isub
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
        15: .line 352
      StackMap locals:
      StackMap stack:
            aload 4
            monitorexit
        16: goto 19
      StackMap locals:
      StackMap stack: java.lang.Throwable
        17: aload 4
            monitorexit
        18: athrow
        19: .line 366
      StackMap locals:
      StackMap stack:
            return
        end local 3 // java.util.concurrent.TimeUnit timeUnit
        end local 1 // long l
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   20     0      this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
            0   20     1         l  J
            0   20     3  timeUnit  Ljava/util/concurrent/TimeUnit;
      Exception table:
        from    to  target  type
           5     7       8  Class java.lang.InterruptedException
           5    11      11  any
           4    16      17  any
          17    18      17  any
    Exceptions:
      throws java.io.IOException
    MethodParameters:
          Name  Flags
      l         
      timeUnit  

  protected void dataReady(io.undertow.server.protocol.framed.FrameHeaderData, io.undertow.connector.PooledByteBuffer);
    descriptor: (Lio/undertow/server/protocol/framed/FrameHeaderData;Lio/undertow/connector/PooledByteBuffer;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=6, locals=5, args_size=3
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
        start local 1 // io.undertow.server.protocol.framed.FrameHeaderData headerData
        start local 2 // io.undertow.connector.PooledByteBuffer frameData
         0: .line 375
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            bipush 72
            invokestatic org.xnio.Bits.anyAreSet:(II)Z
            ifeq 3
         1: .line 376
            aload 2 /* frameData */
            invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
         2: .line 377
            return
         3: .line 379
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
            dup
            astore 3
            monitorenter
         4: .line 380
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
            invokeinterface java.util.Deque.isEmpty:()Z
            istore 4 /* newData */
        start local 4 // boolean newData
         5: .line 381
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
            new io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData
            dup
            aload 0 /* this */
            aload 1 /* headerData */
            aload 2 /* frameData */
            invokespecial io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData.<init>:(Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel;Lio/undertow/server/protocol/framed/FrameHeaderData;Lio/undertow/connector/PooledByteBuffer;)V
            invokeinterface java.util.Deque.add:(Ljava/lang/Object;)Z
            pop
         6: .line 382
            iload 4 /* newData */
            ifeq 9
         7: .line 383
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
            ifle 9
         8: .line 384
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
            invokevirtual java.lang.Object.notifyAll:()V
         9: .line 387
      StackMap locals: java.lang.Object int
      StackMap stack:
            aload 0 /* this */
            iconst_0
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waitingForFrame:Z
        end local 4 // boolean newData
        10: .line 379
            aload 3
            monitorexit
        11: goto 14
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel io.undertow.server.protocol.framed.FrameHeaderData io.undertow.connector.PooledByteBuffer java.lang.Object
      StackMap stack: java.lang.Throwable
        12: aload 3
            monitorexit
        13: athrow
        14: .line 389
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            iconst_4
            invokestatic org.xnio.Bits.anyAreSet:(II)Z
            ifeq 16
        15: .line 390
            aload 0 /* this */
            iconst_1
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.resumeReadsInternal:(Z)V
        16: .line 392
      StackMap locals:
      StackMap stack:
            aload 1 /* headerData */
            ifnull 20
        17: .line 393
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.currentStreamSize:J
            aload 1 /* headerData */
            invokeinterface io.undertow.server.protocol.framed.FrameHeaderData.getFrameLength:()J
            ladd
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.currentStreamSize:J
        18: .line 394
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.maxStreamSize:J
            lconst_0
            lcmp
            ifle 20
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.currentStreamSize:J
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.maxStreamSize:J
            lcmp
            ifle 20
        19: .line 395
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.handleStreamTooLarge:()V
        20: .line 398
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.undertow.connector.PooledByteBuffer frameData
        end local 1 // io.undertow.server.protocol.framed.FrameHeaderData headerData
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   21     0        this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
            0   21     1  headerData  Lio/undertow/server/protocol/framed/FrameHeaderData;
            0   21     2   frameData  Lio/undertow/connector/PooledByteBuffer;
            5   10     4     newData  Z
      Exception table:
        from    to  target  type
           4    11      12  any
          12    13      12  any
    MethodParameters:
            Name  Flags
      headerData  
      frameData   

  protected long updateFrameDataRemaining(io.undertow.connector.PooledByteBuffer, long);
    descriptor: (Lio/undertow/connector/PooledByteBuffer;J)J
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=2, locals=4, args_size=3
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
        start local 1 // io.undertow.connector.PooledByteBuffer frameData
        start local 2 // long frameDataRemaining
         0: .line 401
            lload 2 /* frameDataRemaining */
            lreturn
        end local 2 // long frameDataRemaining
        end local 1 // io.undertow.connector.PooledByteBuffer frameData
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    1     0                this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
            0    1     1           frameData  Lio/undertow/connector/PooledByteBuffer;
            0    1     2  frameDataRemaining  J
    MethodParameters:
                    Name  Flags
      frameData           
      frameDataRemaining  

  protected io.undertow.connector.PooledByteBuffer processFrameData(io.undertow.connector.PooledByteBuffer, boolean);
    descriptor: (Lio/undertow/connector/PooledByteBuffer;Z)Lio/undertow/connector/PooledByteBuffer;
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=3, args_size=3
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
        start local 1 // io.undertow.connector.PooledByteBuffer data
        start local 2 // boolean lastFragmentOfFrame
         0: .line 406
            aload 1 /* data */
            areturn
        end local 2 // boolean lastFragmentOfFrame
        end local 1 // io.undertow.connector.PooledByteBuffer data
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot                 Name  Signature
            0    1     0                 this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
            0    1     1                 data  Lio/undertow/connector/PooledByteBuffer;
            0    1     2  lastFragmentOfFrame  Z
    Exceptions:
      throws java.io.IOException
    MethodParameters:
                     Name  Flags
      data                 
      lastFragmentOfFrame  

  protected void handleHeaderData(io.undertow.server.protocol.framed.FrameHeaderData);
    descriptor: (Lio/undertow/server/protocol/framed/FrameHeaderData;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=0, locals=2, args_size=2
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
        start local 1 // io.undertow.server.protocol.framed.FrameHeaderData headerData
         0: .line 411
            return
        end local 1 // io.undertow.server.protocol.framed.FrameHeaderData headerData
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    1     0        this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
            0    1     1  headerData  Lio/undertow/server/protocol/framed/FrameHeaderData;
    MethodParameters:
            Name  Flags
      headerData  

  public org.xnio.XnioExecutor getReadThread();
    descriptor: ()Lorg/xnio/XnioExecutor;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 415
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.framedChannel:Lio/undertow/server/protocol/framed/AbstractFramedChannel;
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedChannel.getIoThread:()Lorg/xnio/XnioIoThread;
            areturn
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;

  public org.xnio.ChannelListener$Setter<? extends R> getReadSetter();
    descriptor: ()Lorg/xnio/ChannelListener$Setter;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 420
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.readSetter:Lorg/xnio/ChannelListener$SimpleSetter;
            areturn
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
    Signature: ()Lorg/xnio/ChannelListener$Setter<+TR;>;

  public org.xnio.ChannelListener$Setter<? extends R> getCloseSetter();
    descriptor: ()Lorg/xnio/ChannelListener$Setter;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 425
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeSetter:Lorg/xnio/ChannelListener$SimpleSetter;
            areturn
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
    Signature: ()Lorg/xnio/ChannelListener$Setter<+TR;>;

  public org.xnio.XnioWorker getWorker();
    descriptor: ()Lorg/xnio/XnioWorker;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 430
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.framedChannel:Lio/undertow/server/protocol/framed/AbstractFramedChannel;
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedChannel.getWorker:()Lorg/xnio/XnioWorker;
            areturn
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;

  public org.xnio.XnioIoThread getIoThread();
    descriptor: ()Lorg/xnio/XnioIoThread;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 435
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.framedChannel:Lio/undertow/server/protocol/framed/AbstractFramedChannel;
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedChannel.getIoThread:()Lorg/xnio/XnioIoThread;
            areturn
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;

  public boolean supportsOption(org.xnio.Option<?>);
    descriptor: (Lorg/xnio/Option;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=2, args_size=2
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
        start local 1 // org.xnio.Option option
         0: .line 440
            iconst_0
            ireturn
        end local 1 // org.xnio.Option option
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0    this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
            0    1     1  option  Lorg/xnio/Option<*>;
    Signature: (Lorg/xnio/Option<*>;)Z
    MethodParameters:
        Name  Flags
      option  

  public <T> T getOption(org.xnio.Option<T>);
    descriptor: (Lorg/xnio/Option;)Ljava/lang/Object;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=2, args_size=2
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
        start local 1 // org.xnio.Option tOption
         0: .line 445
            aconst_null
            areturn
        end local 1 // org.xnio.Option tOption
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0     this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
            0    1     1  tOption  Lorg/xnio/Option<TT;>;
    Exceptions:
      throws java.io.IOException
    Signature: <T:Ljava/lang/Object;>(Lorg/xnio/Option<TT;>;)TT;
    MethodParameters:
         Name  Flags
      tOption  

  public <T> T setOption(org.xnio.Option<T>, );
    descriptor: (Lorg/xnio/Option;Ljava/lang/Object;)Ljava/lang/Object;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=3, args_size=3
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
        start local 1 // org.xnio.Option tOption
        start local 2 // java.lang.Object t
         0: .line 450
            aconst_null
            areturn
        end local 2 // java.lang.Object t
        end local 1 // org.xnio.Option tOption
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0     this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
            0    1     1  tOption  Lorg/xnio/Option<TT;>;
            0    1     2        t  TT;
    Exceptions:
      throws java.lang.IllegalArgumentException, java.io.IOException
    Signature: <T:Ljava/lang/Object;>(Lorg/xnio/Option<TT;>;TT;)TT;
    MethodParameters:
         Name  Flags
      tOption  
      t        

  public long read(java.nio.ByteBuffer[], int, int);
    descriptor: ([Ljava/nio/ByteBuffer;II)J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=11, args_size=4
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
        start local 1 // java.nio.ByteBuffer[] dsts
        start local 2 // int offset
        start local 3 // int length
         0: .line 455
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            iconst_2
            invokestatic org.xnio.Bits.anyAreSet:(II)Z
            ifeq 2
         1: .line 456
            ldc -1
            lreturn
         2: .line 458
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.beforeRead:()V
         3: .line 459
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waitingForFrame:Z
            ifeq 5
         4: .line 460
            lconst_0
            lreturn
         5: .line 463
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
            lconst_0
            lcmp
            ifne 14
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            bipush 16
            invokestatic org.xnio.Bits.anyAreSet:(II)Z
            ifeq 14
         6: .line 464
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
            dup
            astore 4
            monitorenter
         7: .line 465
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            sipush 128
            ior
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
         8: .line 464
            aload 4
            monitorexit
         9: goto 12
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel java.nio.ByteBuffer[] int int java.lang.Object
      StackMap stack: java.lang.Throwable
        10: aload 4
            monitorexit
        11: athrow
        12: .line 485
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
        13: .line 467
            ldc -1
            lreturn
        14: .line 468
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            ifnull 30
        15: .line 469
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.limit:()I
            istore 4 /* old */
        start local 4 // int old
        16: .line 471
            aload 1 /* dsts */
            iload 2 /* offset */
            iload 3 /* length */
            invokestatic org.xnio.Buffers.remaining:([Ljava/nio/Buffer;II)J
            lstore 5 /* count */
        start local 5 // long count
        17: .line 472
            lload 5 /* count */
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.remaining:()I
            i2l
            lcmp
            ifge 20
        18: .line 473
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.position:()I
            i2l
            lload 5 /* count */
            ladd
            l2i
            invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
            pop
        19: .line 474
            goto 21
        20: .line 475
      StackMap locals: int long
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.remaining:()I
            i2l
            lstore 5 /* count */
        21: .line 477
      StackMap locals:
      StackMap stack:
            lload 5 /* count */
            l2i
            aload 1 /* dsts */
            iload 2 /* offset */
            iload 3 /* length */
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokestatic org.xnio.Buffers.copy:(I[Ljava/nio/ByteBuffer;IILjava/nio/ByteBuffer;)I
            i2l
            lstore 8
        22: .line 479
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            iload 4 /* old */
            invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
            pop
        23: .line 480
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.decrementFrameDataRemaining:()V
        24: .line 485
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
        25: .line 477
            lload 8
            lreturn
        end local 5 // long count
        26: .line 478
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel java.nio.ByteBuffer[] int int int
      StackMap stack: java.lang.Throwable
            astore 7
        27: .line 479
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            iload 4 /* old */
            invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
            pop
        28: .line 480
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.decrementFrameDataRemaining:()V
        29: .line 481
            aload 7
            athrow
        end local 4 // int old
        30: .line 485
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
        31: .line 483
            lconst_0
            lreturn
        32: .line 484
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 10
        33: .line 485
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
        34: .line 486
            aload 10
            athrow
        end local 3 // int length
        end local 2 // int offset
        end local 1 // java.nio.ByteBuffer[] dsts
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   35     0    this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
            0   35     1    dsts  [Ljava/nio/ByteBuffer;
            0   35     2  offset  I
            0   35     3  length  I
           16   30     4     old  I
           17   26     5   count  J
      Exception table:
        from    to  target  type
           7     9      10  any
          10    11      10  any
          16    22      26  any
           5    12      32  any
          14    24      32  any
          26    30      32  any
    Exceptions:
      throws java.io.IOException
    MethodParameters:
        Name  Flags
      dsts    
      offset  
      length  

  public long read(java.nio.ByteBuffer[]);
    descriptor: ([Ljava/nio/ByteBuffer;)J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
        start local 1 // java.nio.ByteBuffer[] dsts
         0: .line 491
            aload 0 /* this */
            aload 1 /* dsts */
            iconst_0
            aload 1 /* dsts */
            arraylength
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.read:([Ljava/nio/ByteBuffer;II)J
            lreturn
        end local 1 // java.nio.ByteBuffer[] dsts
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
            0    1     1  dsts  [Ljava/nio/ByteBuffer;
    Exceptions:
      throws java.io.IOException
    MethodParameters:
      Name  Flags
      dsts  

  public int read(java.nio.ByteBuffer);
    descriptor: (Ljava/nio/ByteBuffer;)I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=7, args_size=2
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
        start local 1 // java.nio.ByteBuffer dst
         0: .line 496
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            iconst_2
            invokestatic org.xnio.Bits.anyAreSet:(II)Z
            ifeq 2
         1: .line 497
            iconst_m1
            ireturn
         2: .line 499
      StackMap locals:
      StackMap stack:
            aload 1 /* dst */
            invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
            ifne 4
         3: .line 500
            iconst_0
            ireturn
         4: .line 502
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.beforeRead:()V
         5: .line 503
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waitingForFrame:Z
            ifeq 7
         6: .line 504
            iconst_0
            ireturn
         7: .line 507
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
            lconst_0
            lcmp
            ifne 19
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            bipush 16
            invokestatic org.xnio.Bits.anyAreSet:(II)Z
            ifeq 19
         8: .line 508
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
            dup
            astore 2
            monitorenter
         9: .line 509
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            sipush 128
            ior
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
        10: .line 508
            aload 2
            monitorexit
        11: goto 14
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel java.nio.ByteBuffer java.lang.Object
      StackMap stack: java.lang.Throwable
        12: aload 2
            monitorexit
        13: athrow
        14: .line 530
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
        15: .line 531
            goto 18
      StackMap locals:
      StackMap stack: java.lang.Throwable
        16: pop
        17: .line 532
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.markStreamBroken:()V
        18: .line 511
      StackMap locals:
      StackMap stack:
            iconst_m1
            ireturn
        19: .line 512
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            ifnull 38
        20: .line 513
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.limit:()I
            istore 2 /* old */
        start local 2 // int old
        21: .line 515
            aload 1 /* dst */
            invokevirtual java.nio.ByteBuffer.remaining:()I
            istore 3 /* count */
        start local 3 // int count
        22: .line 516
            iload 3 /* count */
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.remaining:()I
            if_icmpge 25
        23: .line 517
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.position:()I
            iload 3 /* count */
            iadd
            invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
            pop
        24: .line 518
            goto 26
        25: .line 519
      StackMap locals: int int
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.remaining:()I
            istore 3 /* count */
        26: .line 521
      StackMap locals:
      StackMap stack:
            iload 3 /* count */
            aload 1 /* dst */
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokestatic org.xnio.Buffers.copy:(ILjava/nio/ByteBuffer;Ljava/nio/ByteBuffer;)I
            istore 5
        27: .line 523
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            iload 2 /* old */
            invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
            pop
        28: .line 524
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.decrementFrameDataRemaining:()V
        29: .line 530
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
        30: .line 531
            goto 33
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel java.nio.ByteBuffer int int top int
      StackMap stack: java.lang.Throwable
        31: pop
        32: .line 532
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.markStreamBroken:()V
        33: .line 521
      StackMap locals:
      StackMap stack:
            iload 5
            ireturn
        end local 3 // int count
        34: .line 522
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel java.nio.ByteBuffer int
      StackMap stack: java.lang.Throwable
            astore 4
        35: .line 523
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            iload 2 /* old */
            invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
            pop
        36: .line 524
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.decrementFrameDataRemaining:()V
        37: .line 525
            aload 4
            athrow
        end local 2 // int old
        38: .line 530
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
        39: .line 531
            goto 42
      StackMap locals:
      StackMap stack: java.lang.Throwable
        40: pop
        41: .line 532
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.markStreamBroken:()V
        42: .line 527
      StackMap locals:
      StackMap stack:
            iconst_0
            ireturn
        43: .line 528
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 6
        44: .line 530
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
        45: .line 531
            goto 48
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel java.nio.ByteBuffer top top top top java.lang.Throwable
      StackMap stack: java.lang.Throwable
        46: pop
        47: .line 532
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.markStreamBroken:()V
        48: .line 534
      StackMap locals:
      StackMap stack:
            aload 6
            athrow
        end local 1 // java.nio.ByteBuffer dst
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0   49     0   this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
            0   49     1    dst  Ljava/nio/ByteBuffer;
           21   38     2    old  I
           22   34     3  count  I
      Exception table:
        from    to  target  type
           9    11      12  any
          12    13      12  any
          14    15      16  Class java.lang.Throwable
          29    30      31  Class java.lang.Throwable
          21    27      34  any
          38    39      40  Class java.lang.Throwable
           7    14      43  any
          19    29      43  any
          34    38      43  any
          44    45      46  Class java.lang.Throwable
    Exceptions:
      throws java.io.IOException
    MethodParameters:
      Name  Flags
      dst   

  private void beforeRead();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=7, locals=6, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 538
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            bipush 64
            invokestatic org.xnio.Bits.anyAreSet:(II)Z
            ifeq 2
         1: .line 539
            getstatic io.undertow.UndertowMessages.MESSAGES:Lio/undertow/UndertowMessages;
            invokeinterface io.undertow.UndertowMessages.channelIsClosed:()Ljava/nio/channels/ClosedChannelException;
            athrow
         2: .line 541
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            ifnonnull 29
         3: .line 542
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
            dup
            astore 1
            monitorenter
         4: .line 543
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
            invokeinterface java.util.Deque.poll:()Ljava/lang/Object;
            checkcast io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData
            astore 2 /* pending */
        start local 2 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData pending
         5: .line 544
            aload 2 /* pending */
            ifnull 25
         6: .line 545
            aload 2 /* pending */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData.getFrameData:()Lio/undertow/connector/PooledByteBuffer;
            astore 3 /* frameData */
        start local 3 // io.undertow.connector.PooledByteBuffer frameData
         7: .line 546
            iconst_1
            istore 4 /* hasData */
        start local 4 // boolean hasData
         8: .line 547
            aload 3 /* frameData */
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
            ifne 11
         9: .line 548
            aload 3 /* frameData */
            invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
        10: .line 549
            iconst_0
            istore 4 /* hasData */
        11: .line 551
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel java.lang.Object io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData io.undertow.connector.PooledByteBuffer int
      StackMap stack:
            aload 2 /* pending */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData.getFrameHeaderData:()Lio/undertow/server/protocol/framed/FrameHeaderData;
            ifnull 14
        12: .line 552
            aload 0 /* this */
            aload 2 /* pending */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData.getFrameHeaderData:()Lio/undertow/server/protocol/framed/FrameHeaderData;
            invokeinterface io.undertow.server.protocol.framed.FrameHeaderData.getFrameLength:()J
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
        13: .line 553
            aload 0 /* this */
            aload 2 /* pending */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData.getFrameHeaderData:()Lio/undertow/server/protocol/framed/FrameHeaderData;
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.handleHeaderData:(Lio/undertow/server/protocol/framed/FrameHeaderData;)V
        14: .line 555
      StackMap locals:
      StackMap stack:
            iload 4 /* hasData */
            ifeq 25
        15: .line 556
            aload 0 /* this */
            aload 0 /* this */
            aload 3 /* frameData */
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.updateFrameDataRemaining:(Lio/undertow/connector/PooledByteBuffer;J)J
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
        16: .line 557
            aload 0 /* this */
            aload 3 /* frameData */
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.remaining:()I
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.currentDataOriginalSize:I
        17: .line 559
            aload 0 /* this */
            aload 0 /* this */
            aload 3 /* frameData */
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.currentDataOriginalSize:I
            i2l
            lsub
            lconst_0
            lcmp
            ifne 18
            iconst_1
            goto 19
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel java.lang.Object io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData io.undertow.connector.PooledByteBuffer int
      StackMap stack: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel io.undertow.connector.PooledByteBuffer
        18: iconst_0
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel java.lang.Object io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData io.undertow.connector.PooledByteBuffer int
      StackMap stack: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel io.undertow.connector.PooledByteBuffer int
        19: invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.processFrameData:(Lio/undertow/connector/PooledByteBuffer;Z)Lio/undertow/connector/PooledByteBuffer;
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
        20: .line 560
            goto 25
      StackMap locals:
      StackMap stack: java.lang.Throwable
        21: astore 5 /* e */
        start local 5 // java.lang.Throwable e
        22: .line 561
            aload 3 /* frameData */
            invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
        23: .line 562
            getstatic io.undertow.UndertowLogger.REQUEST_IO_LOGGER:Lio/undertow/UndertowLogger;
            new java.io.IOException
            dup
            aload 5 /* e */
            invokespecial java.io.IOException.<init>:(Ljava/lang/Throwable;)V
            invokeinterface io.undertow.UndertowLogger.ioException:(Ljava/io/IOException;)V
        24: .line 563
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.markStreamBroken:()V
        end local 5 // java.lang.Throwable e
        end local 4 // boolean hasData
        end local 3 // io.undertow.connector.PooledByteBuffer frameData
        end local 2 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData pending
        25: .line 542
      StackMap locals:
      StackMap stack:
            aload 1
            monitorexit
        26: goto 29
      StackMap locals:
      StackMap stack: java.lang.Throwable
        27: aload 1
            monitorexit
        28: athrow
        29: .line 569
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0   30     0       this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
            5   25     2    pending  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>.FrameData;
            7   25     3  frameData  Lio/undertow/connector/PooledByteBuffer;
            8   25     4    hasData  Z
           22   25     5          e  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
          17    20      21  Class java.lang.Throwable
           4    26      27  any
          27    28      27  any
    Exceptions:
      throws java.io.IOException

  private void exitRead();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=3, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 572
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            ifnull 3
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
            ifne 3
         1: .line 573
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
         2: .line 574
            aload 0 /* this */
            aconst_null
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
         3: .line 576
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
            lconst_0
            lcmp
            ifne 26
         4: .line 578
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
            dup
            astore 1
            monitorenter
         5: .line 579
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.readFrameCount:I
            iconst_1
            iadd
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.readFrameCount:I
         6: .line 580
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
            invokeinterface java.util.Deque.isEmpty:()Z
            ifeq 16
         7: .line 581
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            sipush 128
            invokestatic org.xnio.Bits.anyAreSet:(II)Z
            ifeq 12
         8: .line 582
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            iconst_2
            ior
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
         9: .line 583
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.complete:()V
        10: .line 584
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.close:()V
        11: .line 585
            goto 16
      StackMap locals: java.lang.Object
      StackMap stack:
        12: aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            bipush 16
            invokestatic org.xnio.Bits.anyAreSet:(II)Z
            ifeq 15
        13: .line 586
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            sipush 256
            ior
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
        14: .line 587
            goto 16
        15: .line 588
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_1
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waitingForFrame:Z
        16: .line 578
      StackMap locals:
      StackMap stack:
            aload 1
            monitorexit
        17: goto 24
      StackMap locals:
      StackMap stack: java.lang.Throwable
        18: aload 1
            monitorexit
        19: athrow
        20: .line 592
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel
      StackMap stack: java.lang.Throwable
            astore 2
        21: .line 593
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
            invokeinterface java.util.Deque.isEmpty:()Z
            ifeq 23
        22: .line 594
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.framedChannel:Lio/undertow/server/protocol/framed/AbstractFramedChannel;
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedChannel.notifyFrameReadComplete:(Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel;)V
        23: .line 596
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel top java.lang.Throwable
      StackMap stack:
            aload 2
            athrow
        24: .line 593
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
            invokeinterface java.util.Deque.isEmpty:()Z
            ifeq 26
        25: .line 594
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.framedChannel:Lio/undertow/server/protocol/framed/AbstractFramedChannel;
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedChannel.notifyFrameReadComplete:(Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel;)V
        26: .line 598
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   27     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
      Exception table:
        from    to  target  type
           5    17      18  any
          18    19      18  any
           4    20      20  any
    Exceptions:
      throws java.io.IOException

  public boolean isOpen();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 602
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            bipush 8
            invokestatic org.xnio.Bits.allAreClear:(II)Z
            ireturn
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;

  public void close();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 607
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            bipush 8
            invokestatic org.xnio.Bits.anyAreSet:(II)Z
            ifeq 2
         1: .line 608
            return
         2: .line 610
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
            dup
            astore 1
            monitorenter
         3: .line 611
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            bipush 8
            ior
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
         4: .line 612
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            bipush 18
            invokestatic org.xnio.Bits.allAreClear:(II)Z
            ifeq 7
         5: .line 613
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            bipush 64
            ior
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
         6: .line 614
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.channelForciblyClosed:()V
         7: .line 616
      StackMap locals: java.lang.Object
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            ifnull 12
         8: .line 617
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
         9: .line 618
            aload 0 /* this */
            aconst_null
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
        10: .line 620
            goto 12
        11: .line 621
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
            invokeinterface java.util.Deque.poll:()Ljava/lang/Object;
            checkcast io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData.frameData:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
        12: .line 620
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
            invokeinterface java.util.Deque.isEmpty:()Z
            ifeq 11
        13: .line 624
            aload 0 /* this */
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeSetter:Lorg/xnio/ChannelListener$SimpleSetter;
            invokevirtual org.xnio.ChannelListener$SimpleSetter.get:()Lorg/xnio/ChannelListener;
            invokestatic org.xnio.ChannelListeners.invokeChannelListener:(Ljava/nio/channels/Channel;Lorg/xnio/ChannelListener;)Z
            pop
        14: .line 625
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeListeners:[Lorg/xnio/ChannelListener;
            ifnull 20
        15: .line 626
            iconst_0
            istore 2 /* i */
        start local 2 // int i
        16: goto 19
        17: .line 627
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeListeners:[Lorg/xnio/ChannelListener;
            iload 2 /* i */
            aaload
            aload 0 /* this */
            invokeinterface org.xnio.ChannelListener.handleEvent:(Ljava/nio/channels/Channel;)V
        18: .line 626
            iinc 2 /* i */ 1
      StackMap locals:
      StackMap stack:
        19: iload 2 /* i */
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeListeners:[Lorg/xnio/ChannelListener;
            arraylength
            if_icmplt 17
        end local 2 // int i
        20: .line 610
      StackMap locals:
      StackMap stack:
            aload 1
            monitorexit
        21: goto 24
      StackMap locals:
      StackMap stack: java.lang.Throwable
        22: aload 1
            monitorexit
        23: athrow
        24: .line 631
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   25     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
           16   20     2     i  I
      Exception table:
        from    to  target  type
           3    21      22  any
          22    23      22  any

  protected void channelForciblyClosed();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 636
            return
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;

  protected C getFramedChannel();
    descriptor: ()Lio/undertow/server/protocol/framed/AbstractFramedChannel;
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 639
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.framedChannel:Lio/undertow/server/protocol/framed/AbstractFramedChannel;
            areturn
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
    Signature: ()TC;

  protected int getReadFrameCount();
    descriptor: ()I
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 643
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.readFrameCount:I
            ireturn
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;

  protected void markStreamBroken();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=3, locals=5, args_size=1
        start local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
         0: .line 651
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            bipush 64
            invokestatic org.xnio.Bits.anyAreSet:(II)Z
            ifeq 2
         1: .line 652
            return
         2: .line 654
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
            dup
            astore 1
            monitorenter
         3: .line 655
            aload 0 /* this */
            dup
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
            bipush 64
            ior
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
         4: .line 656
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
            astore 2 /* data */
        start local 2 // io.undertow.connector.PooledByteBuffer data
         5: .line 657
            aload 2 /* data */
            ifnull 10
         6: .line 659
            aload 2 /* data */
            invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
         7: .line 660
            goto 9
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel java.lang.Object io.undertow.connector.PooledByteBuffer
      StackMap stack: java.lang.Throwable
         8: pop
         9: .line 663
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aconst_null
            putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
        10: .line 665
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
            invokeinterface java.util.Deque.iterator:()Ljava/util/Iterator;
            astore 4
            goto 13
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel java.lang.Object io.undertow.connector.PooledByteBuffer top java.util.Iterator
      StackMap stack:
        11: aload 4
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData
            astore 3 /* frame */
        start local 3 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData frame
        12: .line 666
            aload 3 /* frame */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData.frameData:Lio/undertow/connector/PooledByteBuffer;
            invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
        end local 3 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData frame
        13: .line 665
      StackMap locals:
      StackMap stack:
            aload 4
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 11
        14: .line 668
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
            invokeinterface java.util.Deque.clear:()V
        15: .line 669
            aload 0 /* this */
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.isReadResumed:()Z
            ifeq 17
        16: .line 670
            aload 0 /* this */
            iconst_1
            invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.resumeReadsInternal:(Z)V
        17: .line 672
      StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel java.lang.Object io.undertow.connector.PooledByteBuffer
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
            ifle 19
        18: .line 673
            aload 0 /* this */
            getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
            invokevirtual java.lang.Object.notifyAll:()V
        end local 2 // io.undertow.connector.PooledByteBuffer data
        19: .line 654
      StackMap locals:
      StackMap stack:
            aload 1
            monitorexit
        20: goto 23
      StackMap locals:
      StackMap stack: java.lang.Throwable
        21: aload 1
            monitorexit
        22: athrow
        23: .line 676
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0   24     0   this  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;
            5   19     2   data  Lio/undertow/connector/PooledByteBuffer;
           12   13     3  frame  Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>.FrameData;
      Exception table:
        from    to  target  type
           6     7       8  Class java.lang.Throwable
           3    20      21  any
          21    22      21  any
}
Signature: <C:Lio/undertow/server/protocol/framed/AbstractFramedChannel<TC;TR;TS;>;R:Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel<TC;TR;TS;>;S:Lio/undertow/server/protocol/framed/AbstractFramedStreamSinkChannel<TC;TR;TS;>;>Ljava/lang/Object;Lorg/xnio/channels/StreamSourceChannel;
SourceFile: "AbstractFramedStreamSourceChannel.java"
NestMembers:
  io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$1  io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData
InnerClasses:
  io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$1
  private FrameData = io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData of io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel
  public abstract Setter = org.xnio.ChannelListener$Setter of org.xnio.ChannelListener
  public SimpleSetter = org.xnio.ChannelListener$SimpleSetter of org.xnio.ChannelListener