final class io.undertow.server.HttpServerExchange$ReadDispatchChannel extends io.undertow.channels.DetachableStreamSourceChannel implements org.xnio.channels.StreamSourceChannel
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: io.undertow.server.HttpServerExchange$ReadDispatchChannel
super_class: io.undertow.channels.DetachableStreamSourceChannel
{
private boolean wakeup;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private boolean readsResumed;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
final io.undertow.server.HttpServerExchange this$0;
descriptor: Lio/undertow/server/HttpServerExchange;
flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC
void <init>(io.undertow.server.HttpServerExchange, org.xnio.conduits.ConduitStreamSourceChannel);
descriptor: (Lio/undertow/server/HttpServerExchange;Lorg/xnio/conduits/ConduitStreamSourceChannel;)V
flags: (0x0000)
Code:
stack=2, locals=3, args_size=3
start local 0 start local 2 0: aload 0
aload 1
putfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
1: aload 0
aload 2
invokespecial io.undertow.channels.DetachableStreamSourceChannel.<init>:(Lorg/xnio/channels/StreamSourceChannel;)V
2: aload 0
iconst_1
putfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.wakeup:Z
3: aload 0
iconst_0
putfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.readsResumed:Z
4: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/undertow/server/HttpServerExchange$ReadDispatchChannel;
0 5 2 delegate Lorg/xnio/conduits/ConduitStreamSourceChannel;
MethodParameters:
Name Flags
this$0 final
delegate final
protected boolean isFinished();
descriptor: ()Z
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
getfield io.undertow.server.HttpServerExchange.state:I
sipush 4096
invokestatic org.xnio.Bits.allAreSet:(II)Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/undertow/server/HttpServerExchange$ReadDispatchChannel;
public void resumeReads();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
iconst_1
putfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.readsResumed:Z
1: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
invokevirtual io.undertow.server.HttpServerExchange.isInCall:()Z
ifeq 5
2: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
dup
getfield io.undertow.server.HttpServerExchange.state:I
ldc 262144
ior
putfield io.undertow.server.HttpServerExchange.state:I
3: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
getfield io.undertow.server.HttpServerExchange.state:I
ldc 32768
invokestatic org.xnio.Bits.anyAreSet:(II)Z
ifeq 7
4: getstatic io.undertow.UndertowMessages.MESSAGES:Lio/undertow/UndertowMessages;
invokeinterface io.undertow.UndertowMessages.resumedAndDispatched:()Ljava/lang/IllegalStateException;
athrow
5: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.undertow.server.HttpServerExchange$ReadDispatchChannel.isFinished:()Z
ifne 7
6: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.delegate:Lorg/xnio/channels/StreamSourceChannel;
invokeinterface org.xnio.channels.StreamSourceChannel.resumeReads:()V
7: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/undertow/server/HttpServerExchange$ReadDispatchChannel;
public void wakeupReads();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
invokevirtual io.undertow.server.HttpServerExchange.isInCall:()Z
ifeq 5
1: aload 0
iconst_1
putfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.wakeup:Z
2: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
dup
getfield io.undertow.server.HttpServerExchange.state:I
ldc 262144
ior
putfield io.undertow.server.HttpServerExchange.state:I
3: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
getfield io.undertow.server.HttpServerExchange.state:I
ldc 32768
invokestatic org.xnio.Bits.anyAreSet:(II)Z
ifeq 9
4: getstatic io.undertow.UndertowMessages.MESSAGES:Lio/undertow/UndertowMessages;
invokeinterface io.undertow.UndertowMessages.resumedAndDispatched:()Ljava/lang/IllegalStateException;
athrow
5: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.undertow.server.HttpServerExchange$ReadDispatchChannel.isFinished:()Z
ifeq 8
6: aload 0
invokevirtual io.undertow.server.HttpServerExchange$ReadDispatchChannel.invokeListener:()V
7: goto 9
8: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.delegate:Lorg/xnio/channels/StreamSourceChannel;
invokeinterface org.xnio.channels.StreamSourceChannel.wakeupReads:()V
9: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/undertow/server/HttpServerExchange$ReadDispatchChannel;
private void invokeListener();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.readSetter:Lorg/xnio/ChannelListener$SimpleSetter;
ifnull 2
1: aload 0
invokespecial io.undertow.channels.DetachableStreamSourceChannel.getIoThread:()Lorg/xnio/XnioIoThread;
new io.undertow.server.HttpServerExchange$ReadDispatchChannel$1
dup
aload 0
invokespecial io.undertow.server.HttpServerExchange$ReadDispatchChannel$1.<init>:(Lio/undertow/server/HttpServerExchange$ReadDispatchChannel;)V
invokevirtual org.xnio.XnioIoThread.execute:(Ljava/lang/Runnable;)V
2: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/undertow/server/HttpServerExchange$ReadDispatchChannel;
public void requestDone();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.delegate:Lorg/xnio/channels/StreamSourceChannel;
instanceof org.xnio.conduits.ConduitStreamSourceChannel
ifeq 4
1: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.delegate:Lorg/xnio/channels/StreamSourceChannel;
checkcast org.xnio.conduits.ConduitStreamSourceChannel
aconst_null
invokevirtual org.xnio.conduits.ConduitStreamSourceChannel.setReadListener:(Lorg/xnio/ChannelListener;)V
2: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.delegate:Lorg/xnio/channels/StreamSourceChannel;
checkcast org.xnio.conduits.ConduitStreamSourceChannel
aconst_null
invokevirtual org.xnio.conduits.ConduitStreamSourceChannel.setCloseListener:(Lorg/xnio/ChannelListener;)V
3: goto 6
4: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.delegate:Lorg/xnio/channels/StreamSourceChannel;
invokeinterface org.xnio.channels.StreamSourceChannel.getReadSetter:()Lorg/xnio/ChannelListener$Setter;
aconst_null
invokeinterface org.xnio.ChannelListener$Setter.set:(Lorg/xnio/ChannelListener;)V
5: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.delegate:Lorg/xnio/channels/StreamSourceChannel;
invokeinterface org.xnio.channels.StreamSourceChannel.getCloseSetter:()Lorg/xnio/ChannelListener$Setter;
aconst_null
invokeinterface org.xnio.ChannelListener$Setter.set:(Lorg/xnio/ChannelListener;)V
6: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/undertow/server/HttpServerExchange$ReadDispatchChannel;
public long transferTo(long, long, java.nio.channels.FileChannel);
descriptor: (JJLjava/nio/channels/FileChannel;)J
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=7, args_size=4
start local 0 start local 1 start local 3 start local 5 0: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
getstatic io.undertow.server.HttpServerExchange.BUFFERED_REQUEST_DATA:Lio/undertow/util/AttachmentKey;
invokevirtual io.undertow.server.HttpServerExchange.getAttachment:(Lio/undertow/util/AttachmentKey;)Ljava/lang/Object;
checkcast io.undertow.connector.PooledByteBuffer[]
astore 6
start local 6 1: aload 6
ifnonnull 3
2: aload 0
lload 1
lload 3
aload 5
invokespecial io.undertow.channels.DetachableStreamSourceChannel.transferTo:(JJLjava/nio/channels/FileChannel;)J
lreturn
3: StackMap locals: io.undertow.connector.PooledByteBuffer[]
StackMap stack:
aload 5
aload 0
lload 1
lload 3
invokevirtual java.nio.channels.FileChannel.transferFrom:(Ljava/nio/channels/ReadableByteChannel;JJ)J
lreturn
end local 6 end local 5 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/undertow/server/HttpServerExchange$ReadDispatchChannel;
0 4 1 position J
0 4 3 count J
0 4 5 target Ljava/nio/channels/FileChannel;
1 4 6 buffered [Lio/undertow/connector/PooledByteBuffer;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
position
count
target
public void awaitReadable();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
aload 0
invokespecial io.undertow.channels.DetachableStreamSourceChannel.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.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
getstatic io.undertow.server.HttpServerExchange.BUFFERED_REQUEST_DATA:Lio/undertow/util/AttachmentKey;
invokevirtual io.undertow.server.HttpServerExchange.getAttachment:(Lio/undertow/util/AttachmentKey;)Ljava/lang/Object;
checkcast io.undertow.connector.PooledByteBuffer[]
astore 1
start local 1 3: aload 1
ifnonnull 5
4: aload 0
invokespecial io.undertow.channels.DetachableStreamSourceChannel.awaitReadable:()V
5: StackMap locals: io.undertow.connector.PooledByteBuffer[]
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/undertow/server/HttpServerExchange$ReadDispatchChannel;
3 6 1 buffered [Lio/undertow/connector/PooledByteBuffer;
Exceptions:
throws java.io.IOException
public void suspendReads();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
iconst_0
putfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.readsResumed:Z
1: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
dup
getfield io.undertow.server.HttpServerExchange.state:I
ldc -262145
iand
putfield io.undertow.server.HttpServerExchange.state:I
2: aload 0
invokespecial io.undertow.channels.DetachableStreamSourceChannel.suspendReads:()V
3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/undertow/server/HttpServerExchange$ReadDispatchChannel;
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=12, args_size=4
start local 0 start local 1 start local 3 start local 4 0: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
getstatic io.undertow.server.HttpServerExchange.BUFFERED_REQUEST_DATA:Lio/undertow/util/AttachmentKey;
invokevirtual io.undertow.server.HttpServerExchange.getAttachment:(Lio/undertow/util/AttachmentKey;)Ljava/lang/Object;
checkcast io.undertow.connector.PooledByteBuffer[]
astore 5
start local 5 1: aload 5
ifnonnull 3
2: aload 0
lload 1
aload 3
aload 4
invokespecial io.undertow.channels.DetachableStreamSourceChannel.transferTo:(JLjava/nio/ByteBuffer;Lorg/xnio/channels/StreamSinkChannel;)J
lreturn
3: StackMap locals: io.undertow.connector.PooledByteBuffer[]
StackMap stack:
aload 3
iconst_0
invokevirtual java.nio.ByteBuffer.position:(I)Ljava/nio/Buffer;
pop
4: aload 3
iconst_0
invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
pop
5: lconst_0
lstore 6
start local 6 6: iconst_0
istore 8
start local 8 7: goto 23
8: StackMap locals: long int
StackMap stack:
aload 5
iload 8
aaload
astore 9
start local 9 9: aload 9
ifnull 22
10: aload 9
invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
astore 10
start local 10 11: aload 10
invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
ifeq 20
12: aload 4
aload 10
invokeinterface org.xnio.channels.StreamSinkChannel.write:(Ljava/nio/ByteBuffer;)I
istore 11
start local 11 13: aload 10
invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
ifne 16
14: aload 9
invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
15: aload 5
iload 8
aconst_null
aastore
16: StackMap locals: io.undertow.connector.PooledByteBuffer java.nio.ByteBuffer int
StackMap stack:
iload 11
ifne 18
17: lload 6
lreturn
18: StackMap locals:
StackMap stack:
lload 6
iload 11
i2l
ladd
lstore 6
end local 11 19: goto 22
20: StackMap locals:
StackMap stack:
aload 9
invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
21: aload 5
iload 8
aconst_null
aastore
end local 10 end local 9 22: StackMap locals:
StackMap stack:
iinc 8 1
StackMap locals:
StackMap stack:
23: iload 8
aload 5
arraylength
if_icmplt 8
end local 8 24: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
getstatic io.undertow.server.HttpServerExchange.BUFFERED_REQUEST_DATA:Lio/undertow/util/AttachmentKey;
invokevirtual io.undertow.server.HttpServerExchange.removeAttachment:(Lio/undertow/util/AttachmentKey;)Ljava/lang/Object;
pop
25: lload 6
lconst_0
lcmp
ifne 27
26: aload 0
lload 1
aload 3
aload 4
invokespecial io.undertow.channels.DetachableStreamSourceChannel.transferTo:(JLjava/nio/ByteBuffer;Lorg/xnio/channels/StreamSinkChannel;)J
lreturn
27: StackMap locals:
StackMap stack:
lload 6
lreturn
end local 6 end local 5 end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 28 0 this Lio/undertow/server/HttpServerExchange$ReadDispatchChannel;
0 28 1 count J
0 28 3 throughBuffer Ljava/nio/ByteBuffer;
0 28 4 target Lorg/xnio/channels/StreamSinkChannel;
1 28 5 buffered [Lio/undertow/connector/PooledByteBuffer;
6 28 6 copied J
7 24 8 i I
9 22 9 pooled Lio/undertow/connector/PooledByteBuffer;
11 22 10 buf Ljava/nio/ByteBuffer;
13 19 11 res I
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
count
throughBuffer
target
public void awaitReadable(long, java.util.concurrent.TimeUnit);
descriptor: (JLjava/util/concurrent/TimeUnit;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=3
start local 0 start local 1 start local 3 0: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
aload 0
invokespecial io.undertow.channels.DetachableStreamSourceChannel.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.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
getstatic io.undertow.server.HttpServerExchange.BUFFERED_REQUEST_DATA:Lio/undertow/util/AttachmentKey;
invokevirtual io.undertow.server.HttpServerExchange.getAttachment:(Lio/undertow/util/AttachmentKey;)Ljava/lang/Object;
checkcast io.undertow.connector.PooledByteBuffer[]
astore 4
start local 4 3: aload 4
ifnonnull 5
4: aload 0
lload 1
aload 3
invokespecial io.undertow.channels.DetachableStreamSourceChannel.awaitReadable:(JLjava/util/concurrent/TimeUnit;)V
5: StackMap locals: io.undertow.connector.PooledByteBuffer[]
StackMap stack:
return
end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/undertow/server/HttpServerExchange$ReadDispatchChannel;
0 6 1 time J
0 6 3 timeUnit Ljava/util/concurrent/TimeUnit;
3 6 4 buffered [Lio/undertow/connector/PooledByteBuffer;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
time
timeUnit
public long read(java.nio.ByteBuffer[], int, int);
descriptor: ([Ljava/nio/ByteBuffer;II)J
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=10, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
getstatic io.undertow.server.HttpServerExchange.BUFFERED_REQUEST_DATA:Lio/undertow/util/AttachmentKey;
invokevirtual io.undertow.server.HttpServerExchange.getAttachment:(Lio/undertow/util/AttachmentKey;)Ljava/lang/Object;
checkcast io.undertow.connector.PooledByteBuffer[]
astore 4
start local 4 1: aload 4
ifnonnull 3
2: aload 0
aload 1
iload 2
iload 3
invokespecial io.undertow.channels.DetachableStreamSourceChannel.read:([Ljava/nio/ByteBuffer;II)J
lreturn
3: StackMap locals: io.undertow.connector.PooledByteBuffer[]
StackMap stack:
lconst_0
lstore 5
start local 5 4: iconst_0
istore 7
start local 7 5: goto 19
6: StackMap locals: long int
StackMap stack:
aload 4
iload 7
aaload
astore 8
start local 8 7: aload 8
ifnull 18
8: aload 8
invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
astore 9
start local 9 9: aload 9
invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
ifeq 16
10: lload 5
aload 1
iload 2
iload 3
aload 9
invokestatic org.xnio.Buffers.copy:([Ljava/nio/ByteBuffer;IILjava/nio/ByteBuffer;)I
i2l
ladd
lstore 5
11: aload 9
invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
ifne 14
12: aload 8
invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
13: aload 4
iload 7
aconst_null
aastore
14: StackMap locals: io.undertow.connector.PooledByteBuffer java.nio.ByteBuffer
StackMap stack:
aload 1
iload 2
iload 3
invokestatic org.xnio.Buffers.hasRemaining:([Ljava/nio/Buffer;II)Z
ifne 18
15: lload 5
lreturn
16: StackMap locals:
StackMap stack:
aload 8
invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
17: aload 4
iload 7
aconst_null
aastore
end local 9 end local 8 18: StackMap locals:
StackMap stack:
iinc 7 1
StackMap locals:
StackMap stack:
19: iload 7
aload 4
arraylength
if_icmplt 6
end local 7 20: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
getstatic io.undertow.server.HttpServerExchange.BUFFERED_REQUEST_DATA:Lio/undertow/util/AttachmentKey;
invokevirtual io.undertow.server.HttpServerExchange.removeAttachment:(Lio/undertow/util/AttachmentKey;)Ljava/lang/Object;
pop
21: lload 5
lconst_0
lcmp
ifne 23
22: aload 0
aload 1
iload 2
iload 3
invokespecial io.undertow.channels.DetachableStreamSourceChannel.read:([Ljava/nio/ByteBuffer;II)J
lreturn
23: StackMap locals:
StackMap stack:
lload 5
lreturn
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 24 0 this Lio/undertow/server/HttpServerExchange$ReadDispatchChannel;
0 24 1 dsts [Ljava/nio/ByteBuffer;
0 24 2 offset I
0 24 3 length I
1 24 4 buffered [Lio/undertow/connector/PooledByteBuffer;
4 24 5 copied J
5 20 7 i I
7 18 8 pooled Lio/undertow/connector/PooledByteBuffer;
9 18 9 buf Ljava/nio/ByteBuffer;
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.HttpServerExchange$ReadDispatchChannel.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/HttpServerExchange$ReadDispatchChannel;
0 1 1 dsts [Ljava/nio/ByteBuffer;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
dsts
public boolean isOpen();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
getstatic io.undertow.server.HttpServerExchange.BUFFERED_REQUEST_DATA:Lio/undertow/util/AttachmentKey;
invokevirtual io.undertow.server.HttpServerExchange.getAttachment:(Lio/undertow/util/AttachmentKey;)Ljava/lang/Object;
checkcast io.undertow.connector.PooledByteBuffer[]
astore 1
start local 1 1: aload 1
ifnull 3
2: iconst_1
ireturn
3: StackMap locals: io.undertow.connector.PooledByteBuffer[]
StackMap stack:
aload 0
invokespecial io.undertow.channels.DetachableStreamSourceChannel.isOpen:()Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/undertow/server/HttpServerExchange$ReadDispatchChannel;
1 4 1 buffered [Lio/undertow/connector/PooledByteBuffer;
public void close();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=6, args_size=1
start local 0 0: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
getstatic io.undertow.server.HttpServerExchange.BUFFERED_REQUEST_DATA:Lio/undertow/util/AttachmentKey;
invokevirtual io.undertow.server.HttpServerExchange.getAttachment:(Lio/undertow/util/AttachmentKey;)Ljava/lang/Object;
checkcast io.undertow.connector.PooledByteBuffer[]
astore 1
start local 1 1: aload 1
ifnull 8
2: aload 1
dup
astore 5
arraylength
istore 4
iconst_0
istore 3
goto 7
StackMap locals: io.undertow.server.HttpServerExchange$ReadDispatchChannel io.undertow.connector.PooledByteBuffer[] top int int io.undertow.connector.PooledByteBuffer[]
StackMap stack:
3: aload 5
iload 3
aaload
astore 2
start local 2 4: aload 2
ifnull 6
5: aload 2
invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
end local 2 6: StackMap locals:
StackMap stack:
iinc 3 1
StackMap locals:
StackMap stack:
7: iload 3
iload 4
if_icmplt 3
8: StackMap locals: io.undertow.server.HttpServerExchange$ReadDispatchChannel io.undertow.connector.PooledByteBuffer[]
StackMap stack:
aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
getstatic io.undertow.server.HttpServerExchange.BUFFERED_REQUEST_DATA:Lio/undertow/util/AttachmentKey;
invokevirtual io.undertow.server.HttpServerExchange.removeAttachment:(Lio/undertow/util/AttachmentKey;)Ljava/lang/Object;
pop
9: aload 0
invokespecial io.undertow.channels.DetachableStreamSourceChannel.close:()V
10: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lio/undertow/server/HttpServerExchange$ReadDispatchChannel;
1 11 1 buffered [Lio/undertow/connector/PooledByteBuffer;
4 6 2 pooled Lio/undertow/connector/PooledByteBuffer;
Exceptions:
throws java.io.IOException
public boolean isReadResumed();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
getstatic io.undertow.server.HttpServerExchange.BUFFERED_REQUEST_DATA:Lio/undertow/util/AttachmentKey;
invokevirtual io.undertow.server.HttpServerExchange.getAttachment:(Lio/undertow/util/AttachmentKey;)Ljava/lang/Object;
checkcast io.undertow.connector.PooledByteBuffer[]
astore 1
start local 1 1: aload 1
ifnull 3
2: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.readsResumed:Z
ireturn
3: StackMap locals: io.undertow.connector.PooledByteBuffer[]
StackMap stack:
aload 0
invokevirtual io.undertow.server.HttpServerExchange$ReadDispatchChannel.isFinished:()Z
ifeq 5
4: iconst_0
ireturn
5: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
getfield io.undertow.server.HttpServerExchange.state:I
ldc 262144
invokestatic org.xnio.Bits.anyAreSet:(II)Z
ifne 6
aload 0
invokespecial io.undertow.channels.DetachableStreamSourceChannel.isReadResumed:()Z
ifne 6
iconst_0
ireturn
StackMap locals:
StackMap stack:
6: iconst_1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/undertow/server/HttpServerExchange$ReadDispatchChannel;
1 7 1 buffered [Lio/undertow/connector/PooledByteBuffer;
public int read(java.nio.ByteBuffer);
descriptor: (Ljava/nio/ByteBuffer;)I
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=7, args_size=2
start local 0 start local 1 0: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
getstatic io.undertow.server.HttpServerExchange.BUFFERED_REQUEST_DATA:Lio/undertow/util/AttachmentKey;
invokevirtual io.undertow.server.HttpServerExchange.getAttachment:(Lio/undertow/util/AttachmentKey;)Ljava/lang/Object;
checkcast io.undertow.connector.PooledByteBuffer[]
astore 2
start local 2 1: aload 2
ifnonnull 3
2: aload 0
aload 1
invokespecial io.undertow.channels.DetachableStreamSourceChannel.read:(Ljava/nio/ByteBuffer;)I
ireturn
3: StackMap locals: io.undertow.connector.PooledByteBuffer[]
StackMap stack:
iconst_0
istore 3
start local 3 4: iconst_0
istore 4
start local 4 5: goto 19
6: StackMap locals: int int
StackMap stack:
aload 2
iload 4
aaload
astore 5
start local 5 7: aload 5
ifnull 18
8: aload 5
invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
astore 6
start local 6 9: aload 6
invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
ifeq 16
10: iload 3
aload 1
aload 6
invokestatic org.xnio.Buffers.copy:(Ljava/nio/ByteBuffer;Ljava/nio/ByteBuffer;)I
iadd
istore 3
11: aload 6
invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
ifne 14
12: aload 5
invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
13: aload 2
iload 4
aconst_null
aastore
14: StackMap locals: io.undertow.connector.PooledByteBuffer java.nio.ByteBuffer
StackMap stack:
aload 1
invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
ifne 18
15: iload 3
ireturn
16: StackMap locals:
StackMap stack:
aload 5
invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
17: aload 2
iload 4
aconst_null
aastore
end local 6 end local 5 18: StackMap locals:
StackMap stack:
iinc 4 1
StackMap locals:
StackMap stack:
19: iload 4
aload 2
arraylength
if_icmplt 6
end local 4 20: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
getstatic io.undertow.server.HttpServerExchange.BUFFERED_REQUEST_DATA:Lio/undertow/util/AttachmentKey;
invokevirtual io.undertow.server.HttpServerExchange.removeAttachment:(Lio/undertow/util/AttachmentKey;)Ljava/lang/Object;
pop
21: iload 3
ifne 23
22: aload 0
aload 1
invokespecial io.undertow.channels.DetachableStreamSourceChannel.read:(Ljava/nio/ByteBuffer;)I
ireturn
23: StackMap locals:
StackMap stack:
iload 3
ireturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 24 0 this Lio/undertow/server/HttpServerExchange$ReadDispatchChannel;
0 24 1 dst Ljava/nio/ByteBuffer;
1 24 2 buffered [Lio/undertow/connector/PooledByteBuffer;
4 24 3 copied I
5 20 4 i I
7 18 5 pooled Lio/undertow/connector/PooledByteBuffer;
9 18 6 buf Ljava/nio/ByteBuffer;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
dst
public void runResume();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.undertow.server.HttpServerExchange$ReadDispatchChannel.isReadResumed:()Z
ifeq 12
1: aload 0
invokevirtual io.undertow.server.HttpServerExchange$ReadDispatchChannel.isFinished:()Z
ifeq 4
2: aload 0
invokevirtual io.undertow.server.HttpServerExchange$ReadDispatchChannel.invokeListener:()V
3: goto 15
4: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.wakeup:Z
ifeq 9
5: aload 0
iconst_0
putfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.wakeup:Z
6: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
dup
getfield io.undertow.server.HttpServerExchange.state:I
ldc -262145
iand
putfield io.undertow.server.HttpServerExchange.state:I
7: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.delegate:Lorg/xnio/channels/StreamSourceChannel;
invokeinterface org.xnio.channels.StreamSourceChannel.wakeupReads:()V
8: goto 15
9: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.this$0:Lio/undertow/server/HttpServerExchange;
dup
getfield io.undertow.server.HttpServerExchange.state:I
ldc -262145
iand
putfield io.undertow.server.HttpServerExchange.state:I
10: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.delegate:Lorg/xnio/channels/StreamSourceChannel;
invokeinterface org.xnio.channels.StreamSourceChannel.resumeReads:()V
11: goto 15
StackMap locals:
StackMap stack:
12: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.wakeup:Z
ifeq 15
13: aload 0
iconst_0
putfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.wakeup:Z
14: aload 0
invokevirtual io.undertow.server.HttpServerExchange$ReadDispatchChannel.invokeListener:()V
15: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lio/undertow/server/HttpServerExchange$ReadDispatchChannel;
static org.xnio.ChannelListener$SimpleSetter access$0(io.undertow.server.HttpServerExchange$ReadDispatchChannel);
descriptor: (Lio/undertow/server/HttpServerExchange$ReadDispatchChannel;)Lorg/xnio/ChannelListener$SimpleSetter;
flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
getfield io.undertow.server.HttpServerExchange$ReadDispatchChannel.readSetter:Lorg/xnio/ChannelListener$SimpleSetter;
areturn
LocalVariableTable:
Start End Slot Name Signature
}
SourceFile: "HttpServerExchange.java"
NestHost: io.undertow.server.HttpServerExchange
InnerClasses:
private final ReadDispatchChannel = io.undertow.server.HttpServerExchange$ReadDispatchChannel of io.undertow.server.HttpServerExchange
io.undertow.server.HttpServerExchange$ReadDispatchChannel$1
public abstract Setter = org.xnio.ChannelListener$Setter of org.xnio.ChannelListener
public SimpleSetter = org.xnio.ChannelListener$SimpleSetter of org.xnio.ChannelListener