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 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
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: aload 0
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: aload 0
new java.util.LinkedList
dup
invokespecial java.util.LinkedList.<init>:()V
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
4: aload 0
iconst_0
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
5: aload 0
new java.lang.Object
dup
invokespecial java.lang.Object.<init>:()V
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
6: aload 0
iconst_0
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.readFrameCount:I
7: aload 0
ldc -1
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.maxStreamSize:J
8: aload 0
aconst_null
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeListeners:[Lorg/xnio/ChannelListener;
9: aload 0
aload 1
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.framedChannel:Lio/undertow/server/protocol/framed/AbstractFramedChannel;
10: aload 0
iconst_1
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waitingForFrame:Z
11: return
end local 1 end local 0 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 start local 1 start local 2 start local 3 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
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: aload 0
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: aload 0
new java.util.LinkedList
dup
invokespecial java.util.LinkedList.<init>:()V
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
4: aload 0
iconst_0
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
5: aload 0
new java.lang.Object
dup
invokespecial java.lang.Object.<init>:()V
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
6: aload 0
iconst_0
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.readFrameCount:I
7: aload 0
ldc -1
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.maxStreamSize:J
8: aload 0
aconst_null
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeListeners:[Lorg/xnio/ChannelListener;
9: aload 0
aload 1
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.framedChannel:Lio/undertow/server/protocol/framed/AbstractFramedChannel;
10: aload 0
aload 2
ifnonnull 11
lload 3
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: aload 0
lload 3
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
14: aload 0
lload 3
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.currentStreamSize:J
15: aload 2
ifnull 24
16: aload 2
invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
ifne 23
17: aload 2
invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
18: aload 0
aconst_null
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
19: aload 0
lload 3
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: goto 24
23: StackMap locals:
StackMap stack:
aload 0
aconst_null
aload 2
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.dataReady:(Lio/undertow/server/protocol/framed/FrameHeaderData;Lio/undertow/connector/PooledByteBuffer;)V
24: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 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 start local 1 start local 3 start local 5 0: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
iconst_2
invokestatic org.xnio.Bits.anyAreSet:(II)Z
ifeq 2
1: ldc -1
lreturn
2: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.beforeRead:()V
3: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waitingForFrame:Z
ifeq 5
4: lconst_0
lreturn
5: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
lconst_0
lcmp
ifne 13
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
bipush 16
invokestatic org.xnio.Bits.anyAreSet:(II)Z
ifeq 13
6: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
dup
astore 6
monitorenter
7: aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
sipush 128
ior
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
8: aload 6
monitorexit
9: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
10: ldc -1
lreturn
11: 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: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
ifnull 26
14: aload 0
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
start local 6 15: lload 3
aload 0
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: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
aload 0
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
ladd
l2i
invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
pop
17: StackMap locals: int
StackMap stack:
aload 5
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
lload 1
invokevirtual java.nio.channels.FileChannel.write:(Ljava/nio/ByteBuffer;J)I
i2l
lstore 8
18: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
iload 6
invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
pop
19: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.decrementFrameDataRemaining:()V
20: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
21: lload 8
lreturn
22: StackMap locals:
StackMap stack: java.lang.Throwable
astore 7
23: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
iload 6
invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
pop
24: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.decrementFrameDataRemaining:()V
25: aload 7
athrow
end local 6 26: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
27: lconst_0
lreturn
28: StackMap locals:
StackMap stack: java.lang.Throwable
astore 10
29: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
30: aload 10
athrow
end local 5 end local 3 end local 1 end local 0 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 0: aload 0
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: aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.currentDataOriginalSize:I
i2l
lsub
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
2: StackMap locals:
StackMap stack:
return
end local 0 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 start local 1 start local 3 start local 4 0: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
iconst_2
invokestatic org.xnio.Bits.anyAreSet:(II)Z
ifeq 2
1: ldc -1
lreturn
2: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.beforeRead:()V
3: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waitingForFrame:Z
ifeq 6
4: aload 3
aload 3
invokevirtual java.nio.ByteBuffer.limit:()I
invokevirtual java.nio.ByteBuffer.position:(I)Ljava/nio/Buffer;
pop
5: lconst_0
lreturn
6: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
lconst_0
lcmp
ifne 14
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
bipush 16
invokestatic org.xnio.Bits.anyAreSet:(II)Z
ifeq 14
7: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
dup
astore 5
monitorenter
8: aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
sipush 128
ior
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
9: aload 5
monitorexit
10: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
11: ldc -1
lreturn
12: 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: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
ifnull 34
aload 0
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: aload 0
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
start local 5 16: lload 1
aload 0
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: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
aload 0
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
ladd
l2i
invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
pop
18: StackMap locals: int
StackMap stack:
aload 4
aload 0
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
start local 6 19: aload 0
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: aload 3
invokevirtual java.nio.ByteBuffer.clear:()Ljava/nio/Buffer;
pop
21: aload 3
aload 0
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: aload 3
invokevirtual java.nio.ByteBuffer.flip:()Ljava/nio/Buffer;
pop
23: goto 25
24: StackMap locals: int
StackMap stack:
aload 3
aload 3
invokevirtual java.nio.ByteBuffer.limit:()I
invokevirtual java.nio.ByteBuffer.position:(I)Ljava/nio/Buffer;
pop
25: StackMap locals:
StackMap stack:
iload 6
i2l
lstore 8
26: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
iload 5
invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
pop
27: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.decrementFrameDataRemaining:()V
28: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
29: lload 8
lreturn
end local 6 30: 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: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
iload 5
invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
pop
32: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.decrementFrameDataRemaining:()V
33: aload 7
athrow
end local 5 34: StackMap locals:
StackMap stack:
aload 3
aload 3
invokevirtual java.nio.ByteBuffer.limit:()I
invokevirtual java.nio.ByteBuffer.position:(I)Ljava/nio/Buffer;
pop
35: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
36: lconst_0
lreturn
37: StackMap locals:
StackMap stack: java.lang.Throwable
astore 10
38: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
39: aload 10
athrow
end local 4 end local 3 end local 1 end local 0 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 0: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.maxStreamSize:J
lreturn
end local 0 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 start local 1 0: aload 0
lload 1
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.maxStreamSize:J
1: lload 1
lconst_0
lcmp
ifle 4
2: lload 1
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.currentStreamSize:J
lcmp
ifge 4
3: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.handleStreamTooLarge:()V
4: StackMap locals:
StackMap stack:
return
end local 1 end local 0 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 0: aload 0
invokestatic org.xnio.IoUtils.safeClose:(Ljava/io/Closeable;)V
1: return
end local 0 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 0: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
dup
astore 1
monitorenter
1: aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
bipush -5
iand
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
2: 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: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.close:()V
1: return
end local 0 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 0: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
iconst_2
invokestatic org.xnio.Bits.anyAreSet:(II)Z
ireturn
end local 0 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 0: aload 0
iconst_0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.resumeReadsInternal:(Z)V
1: return
end local 0 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 0: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
iconst_4
invokestatic org.xnio.Bits.anyAreSet:(II)Z
ireturn
end local 0 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 0: aload 0
iconst_1
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.resumeReadsInternal:(Z)V
1: return
end local 0 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 start local 1 0: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeListeners:[Lorg/xnio/ChannelListener;
ifnonnull 3
1: aload 0
iconst_1
anewarray org.xnio.ChannelListener
dup
iconst_0
aload 1
aastore
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeListeners:[Lorg/xnio/ChannelListener;
2: goto 7
3: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeListeners:[Lorg/xnio/ChannelListener;
astore 2
start local 2 4: aload 0
aload 2
arraylength
iconst_1
iadd
anewarray org.xnio.ChannelListener
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeListeners:[Lorg/xnio/ChannelListener;
5: aload 2
iconst_0
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeListeners:[Lorg/xnio/ChannelListener;
iconst_0
aload 2
arraylength
invokestatic java.lang.System.arraycopy:(Ljava/lang/Object;ILjava/lang/Object;II)V
6: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeListeners:[Lorg/xnio/ChannelListener;
aload 2
arraylength
aload 1
aastore
end local 2 7: StackMap locals:
StackMap stack:
return
end local 1 end local 0 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 start local 1 0: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
dup
astore 2
monitorenter
1: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
iconst_4
invokestatic org.xnio.Bits.anyAreSet:(II)Z
istore 3
start local 3 2: aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
iconst_4
ior
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
3: iload 3
ifeq 4
iload 1
ifeq 7
4: StackMap locals: java.lang.Object int
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
bipush 32
invokestatic org.xnio.Bits.anyAreSet:(II)Z
ifne 7
5: aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
bipush 32
ior
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
6: aload 0
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
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 7: StackMap locals:
StackMap stack:
aload 2
monitorexit
8: goto 11
StackMap locals:
StackMap stack: java.lang.Throwable
9: aload 2
monitorexit
10: athrow
11: StackMap locals:
StackMap stack:
return
end local 1 end local 0 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 0: aload 0
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 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 0: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.close:()V
1: return
end local 0 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 0: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
dup
astore 1
monitorenter
1: aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
bipush 16
ior
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
2: 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: StackMap locals:
StackMap stack:
aload 0
iconst_0
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waitingForFrame:Z
7: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
ifnonnull 11
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
invokeinterface java.util.Deque.isEmpty:()Z
ifeq 11
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
lconst_0
lcmp
ifne 11
8: aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
bipush 10
ior
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
9: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.getFramedChannel:()Lio/undertow/server/protocol/framed/AbstractFramedChannel;
aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedChannel.notifyFrameReadComplete:(Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel;)V
10: aload 0
invokestatic org.xnio.IoUtils.safeClose:(Ljava/io/Closeable;)V
11: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
bipush 16
invokestatic org.xnio.Bits.anyAreSet:(II)Z
ireturn
end local 0 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 0: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.getIoThread:()Lorg/xnio/XnioIoThread;
if_acmpne 2
1: getstatic io.undertow.UndertowMessages.MESSAGES:Lio/undertow/UndertowMessages;
invokeinterface io.undertow.UndertowMessages.awaitCalledFromIoThread:()Ljava/io/IOException;
athrow
2: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
ifnonnull 19
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
invokeinterface java.util.Deque.isEmpty:()Z
ifeq 19
3: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
dup
astore 1
monitorenter
4: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
ifnonnull 15
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
invokeinterface java.util.Deque.isEmpty:()Z
ifeq 15
5: aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
iconst_1
iadd
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
6: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
invokevirtual java.lang.Object.wait:()V
7: goto 14
StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel java.lang.Object
StackMap stack: java.lang.InterruptedException
8: pop
9: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
10: new java.io.InterruptedIOException
dup
invokespecial java.io.InterruptedIOException.<init>:()V
athrow
11: StackMap locals:
StackMap stack: java.lang.Throwable
astore 2
12: aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
iconst_1
isub
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
13: aload 2
athrow
14: StackMap locals:
StackMap stack:
aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
iconst_1
isub
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
15: StackMap locals:
StackMap stack:
aload 1
monitorexit
16: goto 19
StackMap locals:
StackMap stack: java.lang.Throwable
17: aload 1
monitorexit
18: athrow
19: StackMap locals:
StackMap stack:
return
end local 0 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 start local 1 start local 3 0: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.getIoThread:()Lorg/xnio/XnioIoThread;
if_acmpne 2
1: getstatic io.undertow.UndertowMessages.MESSAGES:Lio/undertow/UndertowMessages;
invokeinterface io.undertow.UndertowMessages.awaitCalledFromIoThread:()Ljava/io/IOException;
athrow
2: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
ifnonnull 19
3: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
dup
astore 4
monitorenter
4: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
ifnonnull 15
5: aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
iconst_1
iadd
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
6: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
aload 3
lload 1
invokevirtual java.util.concurrent.TimeUnit.toMillis:(J)J
invokevirtual java.lang.Object.wait:(J)V
7: 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: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
10: new java.io.InterruptedIOException
dup
invokespecial java.io.InterruptedIOException.<init>:()V
athrow
11: StackMap locals:
StackMap stack: java.lang.Throwable
astore 5
12: aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
iconst_1
isub
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
13: aload 5
athrow
14: StackMap locals:
StackMap stack:
aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
iconst_1
isub
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
15: StackMap locals:
StackMap stack:
aload 4
monitorexit
16: goto 19
StackMap locals:
StackMap stack: java.lang.Throwable
17: aload 4
monitorexit
18: athrow
19: StackMap locals:
StackMap stack:
return
end local 3 end local 1 end local 0 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 (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 start local 1 start local 2 0: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
bipush 72
invokestatic org.xnio.Bits.anyAreSet:(II)Z
ifeq 3
1: aload 2
invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
2: return
3: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
dup
astore 3
monitorenter
4: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
invokeinterface java.util.Deque.isEmpty:()Z
istore 4
start local 4 5: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
new io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData
dup
aload 0
aload 1
aload 2
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: iload 4
ifeq 9
7: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
ifle 9
8: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
invokevirtual java.lang.Object.notifyAll:()V
9: StackMap locals: java.lang.Object int
StackMap stack:
aload 0
iconst_0
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waitingForFrame:Z
end local 4 10: 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: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
iconst_4
invokestatic org.xnio.Bits.anyAreSet:(II)Z
ifeq 16
15: aload 0
iconst_1
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.resumeReadsInternal:(Z)V
16: StackMap locals:
StackMap stack:
aload 1
ifnull 20
17: aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.currentStreamSize:J
aload 1
invokeinterface io.undertow.server.protocol.framed.FrameHeaderData.getFrameLength:()J
ladd
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.currentStreamSize:J
18: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.maxStreamSize:J
lconst_0
lcmp
ifle 20
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.currentStreamSize:J
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.maxStreamSize:J
lcmp
ifle 20
19: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.handleStreamTooLarge:()V
20: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 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 start local 1 start local 2 0: lload 2
lreturn
end local 2 end local 1 end local 0 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 start local 1 start local 2 0: aload 1
areturn
end local 2 end local 1 end local 0 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 start local 1 0: return
end local 1 end local 0 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 0: aload 0
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 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 0: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.readSetter:Lorg/xnio/ChannelListener$SimpleSetter;
areturn
end local 0 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 0: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeSetter:Lorg/xnio/ChannelListener$SimpleSetter;
areturn
end local 0 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 0: aload 0
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 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 0: aload 0
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 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 start local 1 0: iconst_0
ireturn
end local 1 end local 0 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 start local 1 0: aconst_null
areturn
end local 1 end local 0 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 start local 1 start local 2 0: aconst_null
areturn
end local 2 end local 1 end local 0 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 start local 1 start local 2 start local 3 0: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
iconst_2
invokestatic org.xnio.Bits.anyAreSet:(II)Z
ifeq 2
1: ldc -1
lreturn
2: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.beforeRead:()V
3: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waitingForFrame:Z
ifeq 5
4: lconst_0
lreturn
5: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
lconst_0
lcmp
ifne 14
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
bipush 16
invokestatic org.xnio.Bits.anyAreSet:(II)Z
ifeq 14
6: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
dup
astore 4
monitorenter
7: aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
sipush 128
ior
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
8: 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: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
13: ldc -1
lreturn
14: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
ifnull 30
15: aload 0
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
start local 4 16: aload 1
iload 2
iload 3
invokestatic org.xnio.Buffers.remaining:([Ljava/nio/Buffer;II)J
lstore 5
start local 5 17: lload 5
aload 0
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: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
aload 0
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
ladd
l2i
invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
pop
19: goto 21
20: StackMap locals: int long
StackMap stack:
aload 0
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
21: StackMap locals:
StackMap stack:
lload 5
l2i
aload 1
iload 2
iload 3
aload 0
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: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
iload 4
invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
pop
23: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.decrementFrameDataRemaining:()V
24: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
25: lload 8
lreturn
end local 5 26: StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel java.nio.ByteBuffer[] int int int
StackMap stack: java.lang.Throwable
astore 7
27: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
iload 4
invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
pop
28: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.decrementFrameDataRemaining:()V
29: aload 7
athrow
end local 4 30: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
31: lconst_0
lreturn
32: StackMap locals:
StackMap stack: java.lang.Throwable
astore 10
33: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
34: aload 10
athrow
end local 3 end local 2 end local 1 end local 0 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 start local 1 0: aload 0
aload 1
iconst_0
aload 1
arraylength
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.read:([Ljava/nio/ByteBuffer;II)J
lreturn
end local 1 end local 0 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 start local 1 0: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
iconst_2
invokestatic org.xnio.Bits.anyAreSet:(II)Z
ifeq 2
1: iconst_m1
ireturn
2: StackMap locals:
StackMap stack:
aload 1
invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
ifne 4
3: iconst_0
ireturn
4: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.beforeRead:()V
5: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waitingForFrame:Z
ifeq 7
6: iconst_0
ireturn
7: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
lconst_0
lcmp
ifne 19
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
bipush 16
invokestatic org.xnio.Bits.anyAreSet:(II)Z
ifeq 19
8: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
dup
astore 2
monitorenter
9: aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
sipush 128
ior
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
10: 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: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
15: goto 18
StackMap locals:
StackMap stack: java.lang.Throwable
16: pop
17: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.markStreamBroken:()V
18: StackMap locals:
StackMap stack:
iconst_m1
ireturn
19: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
ifnull 38
20: aload 0
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
start local 2 21: aload 1
invokevirtual java.nio.ByteBuffer.remaining:()I
istore 3
start local 3 22: iload 3
aload 0
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: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
aload 0
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
iadd
invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
pop
24: goto 26
25: StackMap locals: int int
StackMap stack:
aload 0
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
26: StackMap locals:
StackMap stack:
iload 3
aload 1
aload 0
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: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
iload 2
invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
pop
28: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.decrementFrameDataRemaining:()V
29: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
30: 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: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.markStreamBroken:()V
33: StackMap locals:
StackMap stack:
iload 5
ireturn
end local 3 34: StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel java.nio.ByteBuffer int
StackMap stack: java.lang.Throwable
astore 4
35: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
iload 2
invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
pop
36: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.decrementFrameDataRemaining:()V
37: aload 4
athrow
end local 2 38: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
39: goto 42
StackMap locals:
StackMap stack: java.lang.Throwable
40: pop
41: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.markStreamBroken:()V
42: StackMap locals:
StackMap stack:
iconst_0
ireturn
43: StackMap locals:
StackMap stack: java.lang.Throwable
astore 6
44: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.exitRead:()V
45: 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: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.markStreamBroken:()V
48: StackMap locals:
StackMap stack:
aload 6
athrow
end local 1 end local 0 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 0: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
bipush 64
invokestatic org.xnio.Bits.anyAreSet:(II)Z
ifeq 2
1: getstatic io.undertow.UndertowMessages.MESSAGES:Lio/undertow/UndertowMessages;
invokeinterface io.undertow.UndertowMessages.channelIsClosed:()Ljava/nio/channels/ClosedChannelException;
athrow
2: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
ifnonnull 29
3: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
dup
astore 1
monitorenter
4: aload 0
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
start local 2 5: aload 2
ifnull 25
6: aload 2
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData.getFrameData:()Lio/undertow/connector/PooledByteBuffer;
astore 3
start local 3 7: iconst_1
istore 4
start local 4 8: aload 3
invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
ifne 11
9: aload 3
invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
10: iconst_0
istore 4
11: 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
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData.getFrameHeaderData:()Lio/undertow/server/protocol/framed/FrameHeaderData;
ifnull 14
12: aload 0
aload 2
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: aload 0
aload 2
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: StackMap locals:
StackMap stack:
iload 4
ifeq 25
15: aload 0
aload 0
aload 3
aload 0
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: aload 0
aload 3
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: aload 0
aload 0
aload 3
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
aload 0
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: goto 25
StackMap locals:
StackMap stack: java.lang.Throwable
21: astore 5
start local 5 22: aload 3
invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
23: getstatic io.undertow.UndertowLogger.REQUEST_IO_LOGGER:Lio/undertow/UndertowLogger;
new java.io.IOException
dup
aload 5
invokespecial java.io.IOException.<init>:(Ljava/lang/Throwable;)V
invokeinterface io.undertow.UndertowLogger.ioException:(Ljava/io/IOException;)V
24: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.markStreamBroken:()V
end local 5 end local 4 end local 3 end local 2 25: StackMap locals:
StackMap stack:
aload 1
monitorexit
26: goto 29
StackMap locals:
StackMap stack: java.lang.Throwable
27: aload 1
monitorexit
28: athrow
29: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
ifnull 3
aload 0
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: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
2: aload 0
aconst_null
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
3: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.frameDataRemaining:J
lconst_0
lcmp
ifne 26
4: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
dup
astore 1
monitorenter
5: aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.readFrameCount:I
iconst_1
iadd
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.readFrameCount:I
6: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
invokeinterface java.util.Deque.isEmpty:()Z
ifeq 16
7: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
sipush 128
invokestatic org.xnio.Bits.anyAreSet:(II)Z
ifeq 12
8: aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
iconst_2
ior
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
9: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.complete:()V
10: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.close:()V
11: goto 16
StackMap locals: java.lang.Object
StackMap stack:
12: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
bipush 16
invokestatic org.xnio.Bits.anyAreSet:(II)Z
ifeq 15
13: aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
sipush 256
ior
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
14: goto 16
15: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waitingForFrame:Z
16: StackMap locals:
StackMap stack:
aload 1
monitorexit
17: goto 24
StackMap locals:
StackMap stack: java.lang.Throwable
18: aload 1
monitorexit
19: athrow
20: StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel
StackMap stack: java.lang.Throwable
astore 2
21: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
invokeinterface java.util.Deque.isEmpty:()Z
ifeq 23
22: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.framedChannel:Lio/undertow/server/protocol/framed/AbstractFramedChannel;
aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedChannel.notifyFrameReadComplete:(Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel;)V
23: StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel top java.lang.Throwable
StackMap stack:
aload 2
athrow
24: StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
invokeinterface java.util.Deque.isEmpty:()Z
ifeq 26
25: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.framedChannel:Lio/undertow/server/protocol/framed/AbstractFramedChannel;
aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedChannel.notifyFrameReadComplete:(Lio/undertow/server/protocol/framed/AbstractFramedStreamSourceChannel;)V
26: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
bipush 8
invokestatic org.xnio.Bits.allAreClear:(II)Z
ireturn
end local 0 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 0: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
bipush 8
invokestatic org.xnio.Bits.anyAreSet:(II)Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
dup
astore 1
monitorenter
3: aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
bipush 8
ior
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
4: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
bipush 18
invokestatic org.xnio.Bits.allAreClear:(II)Z
ifeq 7
5: aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
bipush 64
ior
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
6: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.channelForciblyClosed:()V
7: StackMap locals: java.lang.Object
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
ifnull 12
8: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
9: aload 0
aconst_null
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
10: goto 12
11: StackMap locals:
StackMap stack:
aload 0
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: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
invokeinterface java.util.Deque.isEmpty:()Z
ifeq 11
13: aload 0
aload 0
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: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeListeners:[Lorg/xnio/ChannelListener;
ifnull 20
15: iconst_0
istore 2
start local 2 16: goto 19
17: StackMap locals: int
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeListeners:[Lorg/xnio/ChannelListener;
iload 2
aaload
aload 0
invokeinterface org.xnio.ChannelListener.handleEvent:(Ljava/nio/channels/Channel;)V
18: iinc 2 1
StackMap locals:
StackMap stack:
19: iload 2
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.closeListeners:[Lorg/xnio/ChannelListener;
arraylength
if_icmplt 17
end local 2 20: StackMap locals:
StackMap stack:
aload 1
monitorexit
21: goto 24
StackMap locals:
StackMap stack: java.lang.Throwable
22: aload 1
monitorexit
23: athrow
24: StackMap locals:
StackMap stack:
return
end local 0 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 0: return
end local 0 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 0: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.framedChannel:Lio/undertow/server/protocol/framed/AbstractFramedChannel;
areturn
end local 0 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 0: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.readFrameCount:I
ireturn
end local 0 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 0: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
bipush 64
invokestatic org.xnio.Bits.anyAreSet:(II)Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
dup
astore 1
monitorenter
3: aload 0
dup
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
bipush 64
ior
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.state:I
4: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
astore 2
start local 2 5: aload 2
ifnull 10
6: aload 2
invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
7: 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: StackMap locals:
StackMap stack:
aload 0
aconst_null
putfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.data:Lio/undertow/connector/PooledByteBuffer;
10: StackMap locals:
StackMap stack:
aload 0
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
start local 3 12: aload 3
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel$FrameData.frameData:Lio/undertow/connector/PooledByteBuffer;
invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
end local 3 13: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 11
14: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.pendingFrameData:Ljava/util/Deque;
invokeinterface java.util.Deque.clear:()V
15: aload 0
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.isReadResumed:()Z
ifeq 17
16: aload 0
iconst_1
invokevirtual io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.resumeReadsInternal:(Z)V
17: StackMap locals: io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel java.lang.Object io.undertow.connector.PooledByteBuffer
StackMap stack:
aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.waiters:I
ifle 19
18: aload 0
getfield io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.lock:Ljava/lang/Object;
invokevirtual java.lang.Object.notifyAll:()V
end local 2 19: StackMap locals:
StackMap stack:
aload 1
monitorexit
20: goto 23
StackMap locals:
StackMap stack: java.lang.Throwable
21: aload 1
monitorexit
22: athrow
23: StackMap locals:
StackMap stack:
return
end local 0 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