public class org.eclipse.jetty.server.HttpInput extends javax.servlet.ServletInputStream implements java.lang.Runnable
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.eclipse.jetty.server.HttpInput
super_class: javax.servlet.ServletInputStream
{
private static final org.eclipse.jetty.util.log.Logger LOG;
descriptor: Lorg/eclipse/jetty/util/log/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
static final org.eclipse.jetty.server.HttpInput$Content EOF_CONTENT;
descriptor: Lorg/eclipse/jetty/server/HttpInput$Content;
flags: (0x0018) ACC_STATIC, ACC_FINAL
static final org.eclipse.jetty.server.HttpInput$Content EARLY_EOF_CONTENT;
descriptor: Lorg/eclipse/jetty/server/HttpInput$Content;
flags: (0x0018) ACC_STATIC, ACC_FINAL
private final byte[] _oneByteBuffer;
descriptor: [B
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private org.eclipse.jetty.server.HttpInput$Content _content;
descriptor: Lorg/eclipse/jetty/server/HttpInput$Content;
flags: (0x0002) ACC_PRIVATE
private org.eclipse.jetty.server.HttpInput$Content _intercepted;
descriptor: Lorg/eclipse/jetty/server/HttpInput$Content;
flags: (0x0002) ACC_PRIVATE
private final java.util.Deque<org.eclipse.jetty.server.HttpInput$Content> _inputQ;
descriptor: Ljava/util/Deque;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Deque<Lorg/eclipse/jetty/server/HttpInput$Content;>;
private final org.eclipse.jetty.server.HttpChannelState _channelState;
descriptor: Lorg/eclipse/jetty/server/HttpChannelState;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private javax.servlet.ReadListener _listener;
descriptor: Ljavax/servlet/ReadListener;
flags: (0x0002) ACC_PRIVATE
private org.eclipse.jetty.server.HttpInput$State _state;
descriptor: Lorg/eclipse/jetty/server/HttpInput$State;
flags: (0x0002) ACC_PRIVATE
private long _firstByteTimeStamp;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private long _contentArrived;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private long _contentConsumed;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private long _blockUntil;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private boolean _waitingForContent;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private org.eclipse.jetty.server.HttpInput$Interceptor _interceptor;
descriptor: Lorg/eclipse/jetty/server/HttpInput$Interceptor;
flags: (0x0002) ACC_PRIVATE
protected static final org.eclipse.jetty.server.HttpInput$State STREAM;
descriptor: Lorg/eclipse/jetty/server/HttpInput$State;
flags: (0x001c) ACC_PROTECTED, ACC_STATIC, ACC_FINAL
protected static final org.eclipse.jetty.server.HttpInput$State ASYNC;
descriptor: Lorg/eclipse/jetty/server/HttpInput$State;
flags: (0x001c) ACC_PROTECTED, ACC_STATIC, ACC_FINAL
protected static final org.eclipse.jetty.server.HttpInput$State EARLY_EOF;
descriptor: Lorg/eclipse/jetty/server/HttpInput$State;
flags: (0x001c) ACC_PROTECTED, ACC_STATIC, ACC_FINAL
protected static final org.eclipse.jetty.server.HttpInput$State EOF;
descriptor: Lorg/eclipse/jetty/server/HttpInput$State;
flags: (0x001c) ACC_PROTECTED, ACC_STATIC, ACC_FINAL
protected static final org.eclipse.jetty.server.HttpInput$State AEOF;
descriptor: Lorg/eclipse/jetty/server/HttpInput$State;
flags: (0x001c) ACC_PROTECTED, ACC_STATIC, ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=0, args_size=0
0: ldc Lorg/eclipse/jetty/server/HttpInput;
invokestatic org.eclipse.jetty.util.log.Log.getLogger:(Ljava/lang/Class;)Lorg/eclipse/jetty/util/log/Logger;
putstatic org.eclipse.jetty.server.HttpInput.LOG:Lorg/eclipse/jetty/util/log/Logger;
1: new org.eclipse.jetty.server.HttpInput$EofContent
dup
ldc "EOF"
invokespecial org.eclipse.jetty.server.HttpInput$EofContent.<init>:(Ljava/lang/String;)V
putstatic org.eclipse.jetty.server.HttpInput.EOF_CONTENT:Lorg/eclipse/jetty/server/HttpInput$Content;
2: new org.eclipse.jetty.server.HttpInput$EofContent
dup
ldc "EARLY_EOF"
invokespecial org.eclipse.jetty.server.HttpInput$EofContent.<init>:(Ljava/lang/String;)V
putstatic org.eclipse.jetty.server.HttpInput.EARLY_EOF_CONTENT:Lorg/eclipse/jetty/server/HttpInput$Content;
3: new org.eclipse.jetty.server.HttpInput$1
dup
invokespecial org.eclipse.jetty.server.HttpInput$1.<init>:()V
putstatic org.eclipse.jetty.server.HttpInput.STREAM:Lorg/eclipse/jetty/server/HttpInput$State;
4: new org.eclipse.jetty.server.HttpInput$2
dup
invokespecial org.eclipse.jetty.server.HttpInput$2.<init>:()V
putstatic org.eclipse.jetty.server.HttpInput.ASYNC:Lorg/eclipse/jetty/server/HttpInput$State;
5: new org.eclipse.jetty.server.HttpInput$3
dup
invokespecial org.eclipse.jetty.server.HttpInput$3.<init>:()V
putstatic org.eclipse.jetty.server.HttpInput.EARLY_EOF:Lorg/eclipse/jetty/server/HttpInput$State;
6: new org.eclipse.jetty.server.HttpInput$4
dup
invokespecial org.eclipse.jetty.server.HttpInput$4.<init>:()V
putstatic org.eclipse.jetty.server.HttpInput.EOF:Lorg/eclipse/jetty/server/HttpInput$State;
7: new org.eclipse.jetty.server.HttpInput$5
dup
invokespecial org.eclipse.jetty.server.HttpInput$5.<init>:()V
putstatic org.eclipse.jetty.server.HttpInput.AEOF:Lorg/eclipse/jetty/server/HttpInput$State;
8: return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(org.eclipse.jetty.server.HttpChannelState);
descriptor: (Lorg/eclipse/jetty/server/HttpChannelState;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial javax.servlet.ServletInputStream.<init>:()V
1: aload 0
iconst_1
newarray 8
putfield org.eclipse.jetty.server.HttpInput._oneByteBuffer:[B
2: aload 0
new java.util.ArrayDeque
dup
invokespecial java.util.ArrayDeque.<init>:()V
putfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
3: aload 0
getstatic org.eclipse.jetty.server.HttpInput.STREAM:Lorg/eclipse/jetty/server/HttpInput$State;
putfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
4: aload 0
ldc -1
putfield org.eclipse.jetty.server.HttpInput._firstByteTimeStamp:J
5: aload 0
aload 1
putfield org.eclipse.jetty.server.HttpInput._channelState:Lorg/eclipse/jetty/server/HttpChannelState;
6: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/eclipse/jetty/server/HttpInput;
0 7 1 state Lorg/eclipse/jetty/server/HttpChannelState;
MethodParameters:
Name Flags
state
protected org.eclipse.jetty.server.HttpChannelState getHttpChannelState();
descriptor: ()Lorg/eclipse/jetty/server/HttpChannelState;
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.server.HttpInput._channelState:Lorg/eclipse/jetty/server/HttpChannelState;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/server/HttpInput;
public void recycle();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
dup
astore 1
monitorenter
1: aload 0
getfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
ifnull 3
2: aload 0
getfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
aconst_null
invokevirtual org.eclipse.jetty.server.HttpInput$Content.failed:(Ljava/lang/Throwable;)V
3: StackMap locals: java.util.Deque
StackMap stack:
aload 0
aconst_null
putfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
4: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
invokeinterface java.util.Deque.poll:()Ljava/lang/Object;
checkcast org.eclipse.jetty.server.HttpInput$Content
astore 2
start local 2 5: goto 8
6: StackMap locals: org.eclipse.jetty.server.HttpInput$Content
StackMap stack:
aload 2
aconst_null
invokevirtual org.eclipse.jetty.server.HttpInput$Content.failed:(Ljava/lang/Throwable;)V
7: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
invokeinterface java.util.Deque.poll:()Ljava/lang/Object;
checkcast org.eclipse.jetty.server.HttpInput$Content
astore 2
8: StackMap locals:
StackMap stack:
aload 2
ifnonnull 6
9: aload 0
aconst_null
putfield org.eclipse.jetty.server.HttpInput._listener:Ljavax/servlet/ReadListener;
10: aload 0
getstatic org.eclipse.jetty.server.HttpInput.STREAM:Lorg/eclipse/jetty/server/HttpInput$State;
putfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
11: aload 0
lconst_0
putfield org.eclipse.jetty.server.HttpInput._contentArrived:J
12: aload 0
lconst_0
putfield org.eclipse.jetty.server.HttpInput._contentConsumed:J
13: aload 0
ldc -1
putfield org.eclipse.jetty.server.HttpInput._firstByteTimeStamp:J
14: aload 0
lconst_0
putfield org.eclipse.jetty.server.HttpInput._blockUntil:J
15: aload 0
iconst_0
putfield org.eclipse.jetty.server.HttpInput._waitingForContent:Z
16: aload 0
getfield org.eclipse.jetty.server.HttpInput._interceptor:Lorg/eclipse/jetty/server/HttpInput$Interceptor;
instanceof org.eclipse.jetty.util.component.Destroyable
ifeq 18
17: aload 0
getfield org.eclipse.jetty.server.HttpInput._interceptor:Lorg/eclipse/jetty/server/HttpInput$Interceptor;
checkcast org.eclipse.jetty.util.component.Destroyable
invokeinterface org.eclipse.jetty.util.component.Destroyable.destroy:()V
18: StackMap locals:
StackMap stack:
aload 0
aconst_null
putfield org.eclipse.jetty.server.HttpInput._interceptor:Lorg/eclipse/jetty/server/HttpInput$Interceptor;
end local 2 19: aload 1
monitorexit
20: goto 23
StackMap locals: org.eclipse.jetty.server.HttpInput java.util.Deque
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 Lorg/eclipse/jetty/server/HttpInput;
5 19 2 item Lorg/eclipse/jetty/server/HttpInput$Content;
Exception table:
from to target type
1 20 21 any
21 22 21 any
public org.eclipse.jetty.server.HttpInput$Interceptor getInterceptor();
descriptor: ()Lorg/eclipse/jetty/server/HttpInput$Interceptor;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.server.HttpInput._interceptor:Lorg/eclipse/jetty/server/HttpInput$Interceptor;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/server/HttpInput;
public void setInterceptor(org.eclipse.jetty.server.HttpInput$Interceptor);
descriptor: (Lorg/eclipse/jetty/server/HttpInput$Interceptor;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield org.eclipse.jetty.server.HttpInput._interceptor:Lorg/eclipse/jetty/server/HttpInput$Interceptor;
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/jetty/server/HttpInput;
0 2 1 interceptor Lorg/eclipse/jetty/server/HttpInput$Interceptor;
MethodParameters:
Name Flags
interceptor
public void addInterceptor(org.eclipse.jetty.server.HttpInput$Interceptor);
descriptor: (Lorg/eclipse/jetty/server/HttpInput$Interceptor;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.eclipse.jetty.server.HttpInput._interceptor:Lorg/eclipse/jetty/server/HttpInput$Interceptor;
ifnonnull 2
1: aload 0
aload 1
putfield org.eclipse.jetty.server.HttpInput._interceptor:Lorg/eclipse/jetty/server/HttpInput$Interceptor;
goto 3
2: StackMap locals:
StackMap stack:
aload 0
new org.eclipse.jetty.server.HttpInput$ChainedInterceptor
dup
aload 0
getfield org.eclipse.jetty.server.HttpInput._interceptor:Lorg/eclipse/jetty/server/HttpInput$Interceptor;
aload 1
invokespecial org.eclipse.jetty.server.HttpInput$ChainedInterceptor.<init>:(Lorg/eclipse/jetty/server/HttpInput$Interceptor;Lorg/eclipse/jetty/server/HttpInput$Interceptor;)V
putfield org.eclipse.jetty.server.HttpInput._interceptor:Lorg/eclipse/jetty/server/HttpInput$Interceptor;
3: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/eclipse/jetty/server/HttpInput;
0 4 1 interceptor Lorg/eclipse/jetty/server/HttpInput$Interceptor;
MethodParameters:
Name Flags
interceptor
public int available();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=5, args_size=1
start local 0 0: iconst_0
istore 1
start local 1 1: iconst_0
istore 2
start local 2 2: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
dup
astore 3
monitorenter
3: aload 0
getfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
ifnonnull 5
4: aload 0
aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
invokeinterface java.util.Deque.poll:()Ljava/lang/Object;
checkcast org.eclipse.jetty.server.HttpInput$Content
putfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
5: StackMap locals: int int java.util.Deque
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
ifnonnull 12
6: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.produceContent:()V
7: goto 10
8: StackMap locals:
StackMap stack: java.io.IOException
astore 4
start local 4 9: aload 0
aload 4
invokevirtual org.eclipse.jetty.server.HttpInput.failed:(Ljava/lang/Throwable;)Z
istore 2
end local 4 10: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
ifnonnull 12
11: aload 0
aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
invokeinterface java.util.Deque.poll:()Ljava/lang/Object;
checkcast org.eclipse.jetty.server.HttpInput$Content
putfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
12: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
ifnull 14
13: aload 0
getfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
invokevirtual org.eclipse.jetty.server.HttpInput$Content.remaining:()I
istore 1
14: StackMap locals:
StackMap stack:
aload 3
monitorexit
15: goto 18
StackMap locals:
StackMap stack: java.lang.Throwable
16: aload 3
monitorexit
17: athrow
18: StackMap locals:
StackMap stack:
iload 2
ifeq 20
19: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.wake:()V
20: StackMap locals:
StackMap stack:
iload 1
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 21 0 this Lorg/eclipse/jetty/server/HttpInput;
1 21 1 available I
2 21 2 woken Z
9 10 4 e Ljava/io/IOException;
Exception table:
from to target type
6 7 8 Class java.io.IOException
3 15 16 any
16 17 16 any
protected void wake();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=3, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.server.HttpInput._channelState:Lorg/eclipse/jetty/server/HttpChannelState;
invokevirtual org.eclipse.jetty.server.HttpChannelState.getHttpChannel:()Lorg/eclipse/jetty/server/HttpChannel;
astore 1
start local 1 1: aload 1
invokevirtual org.eclipse.jetty.server.HttpChannel.getConnector:()Lorg/eclipse/jetty/server/Connector;
invokeinterface org.eclipse.jetty.server.Connector.getServer:()Lorg/eclipse/jetty/server/Server;
invokevirtual org.eclipse.jetty.server.Server.getThreadPool:()Lorg/eclipse/jetty/util/thread/ThreadPool;
astore 2
start local 2 2: aload 2
aload 1
invokeinterface java.util.concurrent.Executor.execute:(Ljava/lang/Runnable;)V
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/eclipse/jetty/server/HttpInput;
1 4 1 channel Lorg/eclipse/jetty/server/HttpChannel;
2 4 2 executor Ljava/util/concurrent/Executor;
public int read();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=1
start local 0 0: aload 0
aload 0
getfield org.eclipse.jetty.server.HttpInput._oneByteBuffer:[B
iconst_0
iconst_1
invokevirtual org.eclipse.jetty.server.HttpInput.read:([BII)I
istore 1
start local 1 1: iload 1
ifne 3
2: new java.lang.IllegalStateException
dup
ldc "unready read=0"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals: int
StackMap stack:
iload 1
ifge 4
iconst_m1
goto 5
StackMap locals:
StackMap stack:
4: aload 0
getfield org.eclipse.jetty.server.HttpInput._oneByteBuffer:[B
iconst_0
baload
sipush 255
iand
StackMap locals:
StackMap stack: int
5: ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/eclipse/jetty/server/HttpInput;
1 6 1 read I
Exceptions:
throws java.io.IOException
public int read(byte[], int, int);
descriptor: ([BII)I
flags: (0x0001) ACC_PUBLIC
Code:
stack=9, locals=14, args_size=4
start local 0 start local 1 start local 2 start local 3 0: iconst_0
istore 4
start local 4 1: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
dup
astore 6
monitorenter
2: aload 0
getfield org.eclipse.jetty.server.HttpInput._channelState:Lorg/eclipse/jetty/server/HttpChannelState;
invokevirtual org.eclipse.jetty.server.HttpChannelState.getHttpChannel:()Lorg/eclipse/jetty/server/HttpChannel;
invokevirtual org.eclipse.jetty.server.HttpChannel.getHttpConfiguration:()Lorg/eclipse/jetty/server/HttpConfiguration;
invokevirtual org.eclipse.jetty.server.HttpConfiguration.getMinRequestDataRate:()J
lstore 7
start local 7 3: lload 7
lconst_0
lcmp
ifle 13
aload 0
getfield org.eclipse.jetty.server.HttpInput._firstByteTimeStamp:J
ldc -1
lcmp
ifeq 13
4: invokestatic java.lang.System.nanoTime:()J
aload 0
getfield org.eclipse.jetty.server.HttpInput._firstByteTimeStamp:J
lsub
lstore 9
start local 9 5: lload 9
lconst_0
lcmp
ifle 13
6: lload 7
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
lload 9
invokevirtual java.util.concurrent.TimeUnit.toMillis:(J)J
lmul
getstatic java.util.concurrent.TimeUnit.SECONDS:Ljava/util/concurrent/TimeUnit;
lconst_1
invokevirtual java.util.concurrent.TimeUnit.toMillis:(J)J
ldiv
lstore 11
start local 11 7: aload 0
getfield org.eclipse.jetty.server.HttpInput._contentArrived:J
lload 11
lcmp
ifge 13
8: new org.eclipse.jetty.http.BadMessageException
dup
sipush 408
9: ldc "Request content data rate < %d B/s"
iconst_1
anewarray java.lang.Object
dup
iconst_0
lload 7
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
10: invokespecial org.eclipse.jetty.http.BadMessageException.<init>:(ILjava/lang/String;)V
astore 13
start local 13 11: aload 0
getfield org.eclipse.jetty.server.HttpInput._channelState:Lorg/eclipse/jetty/server/HttpChannelState;
invokevirtual org.eclipse.jetty.server.HttpChannelState.getHttpChannel:()Lorg/eclipse/jetty/server/HttpChannel;
aload 13
invokevirtual org.eclipse.jetty.server.HttpChannel.abort:(Ljava/lang/Throwable;)V
12: aload 13
athrow
end local 13 end local 11 end local 9 13: StackMap locals: org.eclipse.jetty.server.HttpInput byte[] int int int top java.util.Deque long
StackMap stack:
aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.nextContent:()Lorg/eclipse/jetty/server/HttpInput$Content;
astore 9
start local 9 14: aload 9
ifnull 21
15: aload 0
aload 9
aload 1
iload 2
iload 3
invokevirtual org.eclipse.jetty.server.HttpInput.get:(Lorg/eclipse/jetty/server/HttpInput$Content;[BII)I
istore 5
start local 5 16: getstatic org.eclipse.jetty.server.HttpInput.LOG:Lorg/eclipse/jetty/util/log/Logger;
invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
ifeq 18
17: getstatic org.eclipse.jetty.server.HttpInput.LOG:Lorg/eclipse/jetty/util/log/Logger;
ldc "{} read {} from {}"
iconst_3
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
iload 5
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_2
aload 9
aastore
invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
18: StackMap locals: org.eclipse.jetty.server.HttpInput byte[] int int int int java.util.Deque long org.eclipse.jetty.server.HttpInput$Content
StackMap stack:
aload 9
invokevirtual org.eclipse.jetty.server.HttpInput$Content.isEmpty:()Z
ifeq 25
19: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.nextInterceptedContent:()Lorg/eclipse/jetty/server/HttpInput$Content;
pop
20: goto 25
end local 5 21: StackMap locals: org.eclipse.jetty.server.HttpInput byte[] int int int top java.util.Deque long org.eclipse.jetty.server.HttpInput$Content
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
aload 0
invokevirtual org.eclipse.jetty.server.HttpInput$State.blockForContent:(Lorg/eclipse/jetty/server/HttpInput;)Z
ifne 13
22: aload 0
getfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
invokevirtual org.eclipse.jetty.server.HttpInput$State.noContent:()I
istore 5
start local 5 23: iload 5
ifge 25
24: aload 0
getfield org.eclipse.jetty.server.HttpInput._channelState:Lorg/eclipse/jetty/server/HttpChannelState;
invokevirtual org.eclipse.jetty.server.HttpChannelState.onReadEof:()Z
istore 4
end local 9 end local 7 25: StackMap locals: org.eclipse.jetty.server.HttpInput byte[] int int int int java.util.Deque
StackMap stack:
aload 6
monitorexit
26: goto 29
end local 5 StackMap locals: org.eclipse.jetty.server.HttpInput byte[] int int int top java.util.Deque
StackMap stack: java.lang.Throwable
27: aload 6
monitorexit
28: athrow
start local 5 29: StackMap locals: org.eclipse.jetty.server.HttpInput byte[] int int int int
StackMap stack:
iload 4
ifeq 31
30: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.wake:()V
31: StackMap locals:
StackMap stack:
iload 5
ireturn
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 32 0 this Lorg/eclipse/jetty/server/HttpInput;
0 32 1 b [B
0 32 2 off I
0 32 3 len I
1 32 4 wake Z
16 21 5 l I
23 27 5 l I
29 32 5 l I
3 25 7 minRequestDataRate J
5 13 9 period J
7 13 11 minimumData J
11 13 13 bad Lorg/eclipse/jetty/http/BadMessageException;
14 25 9 item Lorg/eclipse/jetty/server/HttpInput$Content;
Exception table:
from to target type
2 26 27 any
27 28 27 any
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
b
off
len
protected void produceContent();
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 Lorg/eclipse/jetty/server/HttpInput;
Exceptions:
throws java.io.IOException
public void asyncReadProduce();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
dup
astore 1
monitorenter
1: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.produceContent:()V
2: aload 1
monitorexit
3: goto 6
StackMap locals: org.eclipse.jetty.server.HttpInput java.util.Deque
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 Lorg/eclipse/jetty/server/HttpInput;
Exception table:
from to target type
1 3 4 any
4 5 4 any
Exceptions:
throws java.io.IOException
protected org.eclipse.jetty.server.HttpInput$Content nextContent();
descriptor: ()Lorg/eclipse/jetty/server/HttpInput$Content;
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=2, args_size=1
start local 0 0: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.nextNonSentinelContent:()Lorg/eclipse/jetty/server/HttpInput$Content;
astore 1
start local 1 1: aload 1
ifnonnull 4
aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.isFinished:()Z
ifne 4
2: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.produceContent:()V
3: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.nextNonSentinelContent:()Lorg/eclipse/jetty/server/HttpInput$Content;
astore 1
4: StackMap locals: org.eclipse.jetty.server.HttpInput$Content
StackMap stack:
aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/eclipse/jetty/server/HttpInput;
1 5 1 content Lorg/eclipse/jetty/server/HttpInput$Content;
Exceptions:
throws java.io.IOException
protected org.eclipse.jetty.server.HttpInput$Content nextNonSentinelContent();
descriptor: ()Lorg/eclipse/jetty/server/HttpInput$Content;
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=2, args_size=1
start local 0 0: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.nextInterceptedContent:()Lorg/eclipse/jetty/server/HttpInput$Content;
astore 1
start local 1 1: aload 1
instanceof org.eclipse.jetty.server.HttpInput$SentinelContent
ifeq 4
2: aload 0
aload 1
invokevirtual org.eclipse.jetty.server.HttpInput.consume:(Lorg/eclipse/jetty/server/HttpInput$Content;)V
3: goto 0
4: StackMap locals: org.eclipse.jetty.server.HttpInput$Content
StackMap stack:
aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/eclipse/jetty/server/HttpInput;
1 5 1 content Lorg/eclipse/jetty/server/HttpInput$Content;
protected org.eclipse.jetty.server.HttpInput$Content produceNextContext();
descriptor: ()Lorg/eclipse/jetty/server/HttpInput$Content;
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=2, args_size=1
start local 0 0: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.nextInterceptedContent:()Lorg/eclipse/jetty/server/HttpInput$Content;
astore 1
start local 1 1: aload 1
ifnonnull 4
aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.isFinished:()Z
ifne 4
2: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.produceContent:()V
3: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.nextInterceptedContent:()Lorg/eclipse/jetty/server/HttpInput$Content;
astore 1
4: StackMap locals: org.eclipse.jetty.server.HttpInput$Content
StackMap stack:
aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/eclipse/jetty/server/HttpInput;
1 5 1 content Lorg/eclipse/jetty/server/HttpInput$Content;
Exceptions:
throws java.io.IOException
protected org.eclipse.jetty.server.HttpInput$Content nextInterceptedContent();
descriptor: ()Lorg/eclipse/jetty/server/HttpInput$Content;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.server.HttpInput._intercepted:Lorg/eclipse/jetty/server/HttpInput$Content;
ifnull 5
1: aload 0
getfield org.eclipse.jetty.server.HttpInput._intercepted:Lorg/eclipse/jetty/server/HttpInput$Content;
invokevirtual org.eclipse.jetty.server.HttpInput$Content.hasContent:()Z
ifeq 3
2: aload 0
getfield org.eclipse.jetty.server.HttpInput._intercepted:Lorg/eclipse/jetty/server/HttpInput$Content;
areturn
3: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._intercepted:Lorg/eclipse/jetty/server/HttpInput$Content;
invokevirtual org.eclipse.jetty.server.HttpInput$Content.succeeded:()V
4: aload 0
aconst_null
putfield org.eclipse.jetty.server.HttpInput._intercepted:Lorg/eclipse/jetty/server/HttpInput$Content;
5: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
ifnonnull 19
6: aload 0
aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
invokeinterface java.util.Deque.poll:()Ljava/lang/Object;
checkcast org.eclipse.jetty.server.HttpInput$Content
putfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
7: goto 19
8: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._interceptor:Lorg/eclipse/jetty/server/HttpInput$Interceptor;
ifnull 15
9: aload 0
aload 0
getfield org.eclipse.jetty.server.HttpInput._interceptor:Lorg/eclipse/jetty/server/HttpInput$Interceptor;
aload 0
getfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
invokeinterface org.eclipse.jetty.server.HttpInput$Interceptor.readFrom:(Lorg/eclipse/jetty/server/HttpInput$Content;)Lorg/eclipse/jetty/server/HttpInput$Content;
putfield org.eclipse.jetty.server.HttpInput._intercepted:Lorg/eclipse/jetty/server/HttpInput$Content;
10: aload 0
getfield org.eclipse.jetty.server.HttpInput._intercepted:Lorg/eclipse/jetty/server/HttpInput$Content;
ifnull 14
aload 0
getfield org.eclipse.jetty.server.HttpInput._intercepted:Lorg/eclipse/jetty/server/HttpInput$Content;
aload 0
getfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
if_acmpeq 14
11: aload 0
getfield org.eclipse.jetty.server.HttpInput._intercepted:Lorg/eclipse/jetty/server/HttpInput$Content;
invokevirtual org.eclipse.jetty.server.HttpInput$Content.hasContent:()Z
ifeq 13
12: aload 0
getfield org.eclipse.jetty.server.HttpInput._intercepted:Lorg/eclipse/jetty/server/HttpInput$Content;
areturn
13: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._intercepted:Lorg/eclipse/jetty/server/HttpInput$Content;
invokevirtual org.eclipse.jetty.server.HttpInput$Content.succeeded:()V
14: StackMap locals:
StackMap stack:
aload 0
aconst_null
putfield org.eclipse.jetty.server.HttpInput._intercepted:Lorg/eclipse/jetty/server/HttpInput$Content;
15: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
invokevirtual org.eclipse.jetty.server.HttpInput$Content.hasContent:()Z
ifne 16
aload 0
getfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
instanceof org.eclipse.jetty.server.HttpInput$SentinelContent
ifeq 17
16: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
areturn
17: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
invokevirtual org.eclipse.jetty.server.HttpInput$Content.succeeded:()V
18: aload 0
aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
invokeinterface java.util.Deque.poll:()Ljava/lang/Object;
checkcast org.eclipse.jetty.server.HttpInput$Content
putfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
19: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
ifnonnull 8
20: aconst_null
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 21 0 this Lorg/eclipse/jetty/server/HttpInput;
private void consume(org.eclipse.jetty.server.HttpInput$Content);
descriptor: (Lorg/eclipse/jetty/server/HttpInput$Content;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.isError:()Z
ifne 6
aload 1
instanceof org.eclipse.jetty.server.HttpInput$EofContent
ifeq 6
1: aload 1
getstatic org.eclipse.jetty.server.HttpInput.EARLY_EOF_CONTENT:Lorg/eclipse/jetty/server/HttpInput$Content;
if_acmpne 3
2: aload 0
getstatic org.eclipse.jetty.server.HttpInput.EARLY_EOF:Lorg/eclipse/jetty/server/HttpInput$State;
putfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
goto 6
3: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._listener:Ljavax/servlet/ReadListener;
ifnonnull 5
4: aload 0
getstatic org.eclipse.jetty.server.HttpInput.EOF:Lorg/eclipse/jetty/server/HttpInput$State;
putfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
goto 6
5: StackMap locals:
StackMap stack:
aload 0
getstatic org.eclipse.jetty.server.HttpInput.AEOF:Lorg/eclipse/jetty/server/HttpInput$State;
putfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
6: StackMap locals:
StackMap stack:
aload 1
invokevirtual org.eclipse.jetty.server.HttpInput$Content.succeeded:()V
7: aload 0
getfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
aload 1
if_acmpne 9
8: aload 0
aconst_null
putfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
goto 11
9: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._intercepted:Lorg/eclipse/jetty/server/HttpInput$Content;
aload 1
if_acmpne 11
10: aload 0
aconst_null
putfield org.eclipse.jetty.server.HttpInput._intercepted:Lorg/eclipse/jetty/server/HttpInput$Content;
11: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lorg/eclipse/jetty/server/HttpInput;
0 12 1 content Lorg/eclipse/jetty/server/HttpInput$Content;
MethodParameters:
Name Flags
content
protected int get(org.eclipse.jetty.server.HttpInput$Content, byte[], int, int);
descriptor: (Lorg/eclipse/jetty/server/HttpInput$Content;[BII)I
flags: (0x0004) ACC_PROTECTED
Code:
stack=5, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 1
aload 2
iload 3
iload 4
invokevirtual org.eclipse.jetty.server.HttpInput$Content.get:([BII)I
istore 5
start local 5 1: aload 0
dup
getfield org.eclipse.jetty.server.HttpInput._contentConsumed:J
iload 5
i2l
ladd
putfield org.eclipse.jetty.server.HttpInput._contentConsumed:J
2: iload 5
ireturn
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 3 0 this Lorg/eclipse/jetty/server/HttpInput;
0 3 1 content Lorg/eclipse/jetty/server/HttpInput$Content;
0 3 2 buffer [B
0 3 3 offset I
0 3 4 length I
1 3 5 l I
MethodParameters:
Name Flags
content
buffer
offset
length
protected void skip(org.eclipse.jetty.server.HttpInput$Content, int);
descriptor: (Lorg/eclipse/jetty/server/HttpInput$Content;I)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 1
iload 2
invokevirtual org.eclipse.jetty.server.HttpInput$Content.skip:(I)I
istore 3
start local 3 1: aload 0
dup
getfield org.eclipse.jetty.server.HttpInput._contentConsumed:J
iload 3
i2l
ladd
putfield org.eclipse.jetty.server.HttpInput._contentConsumed:J
2: iload 3
ifle 4
aload 1
invokevirtual org.eclipse.jetty.server.HttpInput$Content.isEmpty:()Z
ifeq 4
3: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.nextNonSentinelContent:()Lorg/eclipse/jetty/server/HttpInput$Content;
pop
4: StackMap locals: int
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/eclipse/jetty/server/HttpInput;
0 5 1 content Lorg/eclipse/jetty/server/HttpInput$Content;
0 5 2 length I
1 5 3 l I
MethodParameters:
Name Flags
content
length
protected void blockForContent();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=7, locals=4, args_size=1
start local 0 0: aload 0
iconst_1
putfield org.eclipse.jetty.server.HttpInput._waitingForContent:Z
1: aload 0
getfield org.eclipse.jetty.server.HttpInput._channelState:Lorg/eclipse/jetty/server/HttpChannelState;
invokevirtual org.eclipse.jetty.server.HttpChannelState.getHttpChannel:()Lorg/eclipse/jetty/server/HttpChannel;
invokevirtual org.eclipse.jetty.server.HttpChannel.onBlockWaitForContent:()V
2: iconst_0
istore 1
start local 1 3: lconst_0
lstore 2
start local 2 4: StackMap locals: int long
StackMap stack:
iload 1
ifeq 6
5: goto 15
6: StackMap locals:
StackMap stack:
getstatic org.eclipse.jetty.server.HttpInput.LOG:Lorg/eclipse/jetty/util/log/Logger;
invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
ifeq 8
7: getstatic org.eclipse.jetty.server.HttpInput.LOG:Lorg/eclipse/jetty/util/log/Logger;
ldc "{} blocking for content timeout={}"
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
lload 2
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
8: StackMap locals:
StackMap stack:
lload 2
lconst_0
lcmp
ifle 10
9: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
lload 2
invokevirtual java.lang.Object.wait:(J)V
goto 11
10: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
invokevirtual java.lang.Object.wait:()V
11: StackMap locals:
StackMap stack:
iconst_1
istore 1
12: goto 4
end local 2 end local 1 13: StackMap locals: org.eclipse.jetty.server.HttpInput
StackMap stack: java.lang.Throwable
astore 1
start local 1 14: aload 0
getfield org.eclipse.jetty.server.HttpInput._channelState:Lorg/eclipse/jetty/server/HttpChannelState;
invokevirtual org.eclipse.jetty.server.HttpChannelState.getHttpChannel:()Lorg/eclipse/jetty/server/HttpChannel;
aload 1
invokevirtual org.eclipse.jetty.server.HttpChannel.onBlockWaitForContentFailure:(Ljava/lang/Throwable;)V
end local 1 15: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lorg/eclipse/jetty/server/HttpInput;
3 13 1 loop Z
4 13 2 timeout J
14 15 1 x Ljava/lang/Throwable;
Exception table:
from to target type
0 13 13 Class java.lang.Throwable
Exceptions:
throws java.io.IOException
public boolean addContent(org.eclipse.jetty.server.HttpInput$Content);
descriptor: (Lorg/eclipse/jetty/server/HttpInput$Content;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
dup
astore 2
monitorenter
1: aload 0
iconst_0
putfield org.eclipse.jetty.server.HttpInput._waitingForContent:Z
2: aload 0
getfield org.eclipse.jetty.server.HttpInput._firstByteTimeStamp:J
ldc -1
lcmp
ifne 4
3: aload 0
invokestatic java.lang.System.nanoTime:()J
putfield org.eclipse.jetty.server.HttpInput._firstByteTimeStamp:J
4: StackMap locals: java.util.Deque
StackMap stack:
aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.isFinished:()Z
ifeq 11
5: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.isError:()Z
ifeq 6
aload 0
getfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
invokevirtual org.eclipse.jetty.server.HttpInput$State.getError:()Ljava/lang/Throwable;
goto 7
StackMap locals:
StackMap stack:
6: new java.io.EOFException
dup
ldc "Content after EOF"
invokespecial java.io.EOFException.<init>:(Ljava/lang/String;)V
StackMap locals:
StackMap stack: java.lang.Throwable
7: astore 3
start local 3 8: aload 1
aload 3
invokevirtual org.eclipse.jetty.server.HttpInput$Content.failed:(Ljava/lang/Throwable;)V
9: aload 2
monitorexit
10: iconst_0
ireturn
end local 3 11: StackMap locals:
StackMap stack:
aload 0
dup
getfield org.eclipse.jetty.server.HttpInput._contentArrived:J
aload 1
invokevirtual org.eclipse.jetty.server.HttpInput$Content.remaining:()I
i2l
ladd
putfield org.eclipse.jetty.server.HttpInput._contentArrived:J
12: aload 0
getfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
ifnonnull 14
aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
invokeinterface java.util.Deque.isEmpty:()Z
ifeq 14
13: aload 0
aload 1
putfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
goto 15
14: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
aload 1
invokeinterface java.util.Deque.offer:(Ljava/lang/Object;)Z
pop
15: StackMap locals:
StackMap stack:
getstatic org.eclipse.jetty.server.HttpInput.LOG:Lorg/eclipse/jetty/util/log/Logger;
invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
ifeq 17
16: getstatic org.eclipse.jetty.server.HttpInput.LOG:Lorg/eclipse/jetty/util/log/Logger;
ldc "{} addContent {}"
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
17: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.nextInterceptedContent:()Lorg/eclipse/jetty/server/HttpInput$Content;
ifnull 20
18: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.wakeup:()Z
aload 2
monitorexit
19: ireturn
20: StackMap locals:
StackMap stack:
aload 2
monitorexit
21: iconst_0
ireturn
22: StackMap locals:
StackMap stack: java.lang.Throwable
aload 2
monitorexit
23: athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 24 0 this Lorg/eclipse/jetty/server/HttpInput;
0 24 1 content Lorg/eclipse/jetty/server/HttpInput$Content;
8 11 3 failure Ljava/lang/Throwable;
Exception table:
from to target type
1 10 22 any
11 19 22 any
20 21 22 any
22 23 22 any
MethodParameters:
Name Flags
content
public boolean hasContent();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
dup
astore 1
monitorenter
1: aload 0
getfield org.eclipse.jetty.server.HttpInput._content:Lorg/eclipse/jetty/server/HttpInput$Content;
ifnonnull 2
aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
invokeinterface java.util.Deque.size:()I
ifgt 2
iconst_0
goto 3
StackMap locals: java.util.Deque
StackMap stack:
2: iconst_1
StackMap locals:
StackMap stack: int
3: aload 1
monitorexit
4: ireturn
5: StackMap locals:
StackMap stack: java.lang.Throwable
aload 1
monitorexit
6: athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/eclipse/jetty/server/HttpInput;
Exception table:
from to target type
1 4 5 any
5 6 5 any
public void unblock();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
dup
astore 1
monitorenter
1: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
invokevirtual java.lang.Object.notify:()V
2: aload 1
monitorexit
3: goto 6
StackMap locals: org.eclipse.jetty.server.HttpInput java.util.Deque
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 Lorg/eclipse/jetty/server/HttpInput;
Exception table:
from to target type
1 3 4 any
4 5 4 any
public long getContentConsumed();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
dup
astore 1
monitorenter
1: aload 0
getfield org.eclipse.jetty.server.HttpInput._contentConsumed:J
aload 1
monitorexit
2: lreturn
3: StackMap locals: org.eclipse.jetty.server.HttpInput java.util.Deque
StackMap stack: java.lang.Throwable
aload 1
monitorexit
4: athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/eclipse/jetty/server/HttpInput;
Exception table:
from to target type
1 2 3 any
3 4 3 any
public boolean earlyEOF();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getstatic org.eclipse.jetty.server.HttpInput.EARLY_EOF_CONTENT:Lorg/eclipse/jetty/server/HttpInput$Content;
invokevirtual org.eclipse.jetty.server.HttpInput.addContent:(Lorg/eclipse/jetty/server/HttpInput$Content;)Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/server/HttpInput;
public boolean eof();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getstatic org.eclipse.jetty.server.HttpInput.EOF_CONTENT:Lorg/eclipse/jetty/server/HttpInput$Content;
invokevirtual org.eclipse.jetty.server.HttpInput.addContent:(Lorg/eclipse/jetty/server/HttpInput$Content;)Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/server/HttpInput;
public boolean consumeAll();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
dup
astore 1
monitorenter
1: StackMap locals: java.util.Deque
StackMap stack:
aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.nextContent:()Lorg/eclipse/jetty/server/HttpInput$Content;
astore 2
start local 2 2: aload 2
ifnonnull 4
3: goto 6
4: StackMap locals: org.eclipse.jetty.server.HttpInput$Content
StackMap stack:
aload 0
aload 2
aload 2
invokevirtual org.eclipse.jetty.server.HttpInput$Content.remaining:()I
invokevirtual org.eclipse.jetty.server.HttpInput.skip:(Lorg/eclipse/jetty/server/HttpInput$Content;I)V
end local 2 5: goto 1
6: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.isFinished:()Z
ifeq 11
7: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.isError:()Z
ifeq 8
iconst_0
goto 9
StackMap locals:
StackMap stack:
8: iconst_1
StackMap locals:
StackMap stack: int
9: aload 1
monitorexit
10: ireturn
11: StackMap locals:
StackMap stack:
aload 0
getstatic org.eclipse.jetty.server.HttpInput.EARLY_EOF:Lorg/eclipse/jetty/server/HttpInput$State;
putfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
12: aload 1
monitorexit
13: iconst_0
ireturn
14: StackMap locals:
StackMap stack: java.lang.Throwable
astore 2
start local 2 15: getstatic org.eclipse.jetty.server.HttpInput.LOG:Lorg/eclipse/jetty/util/log/Logger;
aload 2
invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/Throwable;)V
16: aload 0
new org.eclipse.jetty.server.HttpInput$ErrorState
dup
aload 0
aload 2
invokespecial org.eclipse.jetty.server.HttpInput$ErrorState.<init>:(Lorg/eclipse/jetty/server/HttpInput;Ljava/lang/Throwable;)V
putfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
17: aload 1
monitorexit
18: iconst_0
ireturn
end local 2 19: StackMap locals:
StackMap stack: java.lang.Throwable
aload 1
monitorexit
20: athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 21 0 this Lorg/eclipse/jetty/server/HttpInput;
2 5 2 item Lorg/eclipse/jetty/server/HttpInput$Content;
15 19 2 e Ljava/lang/Throwable;
Exception table:
from to target type
1 9 14 Class java.lang.Throwable
11 12 14 Class java.lang.Throwable
1 10 19 any
11 13 19 any
14 18 19 any
19 20 19 any
public boolean isError();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
dup
astore 1
monitorenter
1: aload 0
getfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
instanceof org.eclipse.jetty.server.HttpInput$ErrorState
aload 1
monitorexit
2: ireturn
3: StackMap locals: org.eclipse.jetty.server.HttpInput java.util.Deque
StackMap stack: java.lang.Throwable
aload 1
monitorexit
4: athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/eclipse/jetty/server/HttpInput;
Exception table:
from to target type
1 2 3 any
3 4 3 any
public boolean isAsync();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
dup
astore 1
monitorenter
1: aload 0
getfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
getstatic org.eclipse.jetty.server.HttpInput.ASYNC:Lorg/eclipse/jetty/server/HttpInput$State;
if_acmpne 2
iconst_1
goto 3
StackMap locals: java.util.Deque
StackMap stack:
2: iconst_0
StackMap locals:
StackMap stack: int
3: aload 1
monitorexit
4: ireturn
5: StackMap locals:
StackMap stack: java.lang.Throwable
aload 1
monitorexit
6: athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/eclipse/jetty/server/HttpInput;
Exception table:
from to target type
1 4 5 any
5 6 5 any
public boolean isFinished();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
dup
astore 1
monitorenter
1: aload 0
getfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
instanceof org.eclipse.jetty.server.HttpInput$EOFState
aload 1
monitorexit
2: ireturn
3: StackMap locals: org.eclipse.jetty.server.HttpInput java.util.Deque
StackMap stack: java.lang.Throwable
aload 1
monitorexit
4: athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/eclipse/jetty/server/HttpInput;
Exception table:
from to target type
1 2 3 any
3 4 3 any
public boolean isReady();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
dup
astore 1
monitorenter
1: aload 0
getfield org.eclipse.jetty.server.HttpInput._listener:Ljavax/servlet/ReadListener;
ifnonnull 4
2: aload 1
monitorexit
3: iconst_1
ireturn
4: StackMap locals: java.util.Deque
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
instanceof org.eclipse.jetty.server.HttpInput$EOFState
ifeq 7
5: aload 1
monitorexit
6: iconst_1
ireturn
7: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._waitingForContent:Z
ifeq 10
8: aload 1
monitorexit
9: iconst_0
ireturn
10: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.produceNextContext:()Lorg/eclipse/jetty/server/HttpInput$Content;
ifnull 13
11: aload 1
monitorexit
12: iconst_1
ireturn
13: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._channelState:Lorg/eclipse/jetty/server/HttpChannelState;
invokevirtual org.eclipse.jetty.server.HttpChannelState.onReadUnready:()V
14: aload 0
iconst_1
putfield org.eclipse.jetty.server.HttpInput._waitingForContent:Z
15: aload 1
monitorexit
16: goto 19
StackMap locals:
StackMap stack: java.lang.Throwable
17: aload 1
monitorexit
18: athrow
19: StackMap locals:
StackMap stack:
iconst_0
ireturn
20: StackMap locals:
StackMap stack: java.io.IOException
astore 1
start local 1 21: getstatic org.eclipse.jetty.server.HttpInput.LOG:Lorg/eclipse/jetty/util/log/Logger;
aload 1
invokeinterface org.eclipse.jetty.util.log.Logger.ignore:(Ljava/lang/Throwable;)V
22: iconst_1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 23 0 this Lorg/eclipse/jetty/server/HttpInput;
21 23 1 e Ljava/io/IOException;
Exception table:
from to target type
1 3 17 any
4 6 17 any
7 9 17 any
10 12 17 any
13 16 17 any
17 18 17 any
0 3 20 Class java.io.IOException
4 6 20 Class java.io.IOException
7 9 20 Class java.io.IOException
10 12 20 Class java.io.IOException
13 19 20 Class java.io.IOException
public void setReadListener(javax.servlet.ReadListener);
descriptor: (Ljavax/servlet/ReadListener;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: iconst_0
istore 2
start local 2 1: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
dup
astore 3
monitorenter
2: aload 0
getfield org.eclipse.jetty.server.HttpInput._listener:Ljavax/servlet/ReadListener;
ifnull 4
3: new java.lang.IllegalStateException
dup
ldc "ReadListener already set"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals: int java.util.Deque
StackMap stack:
aload 0
aload 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast javax.servlet.ReadListener
putfield org.eclipse.jetty.server.HttpInput._listener:Ljavax/servlet/ReadListener;
5: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.produceNextContext:()Lorg/eclipse/jetty/server/HttpInput$Content;
astore 4
start local 4 6: aload 4
ifnull 10
7: aload 0
getstatic org.eclipse.jetty.server.HttpInput.ASYNC:Lorg/eclipse/jetty/server/HttpInput$State;
putfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
8: aload 0
getfield org.eclipse.jetty.server.HttpInput._channelState:Lorg/eclipse/jetty/server/HttpChannelState;
invokevirtual org.eclipse.jetty.server.HttpChannelState.onReadReady:()Z
istore 2
9: goto 17
10: StackMap locals: org.eclipse.jetty.server.HttpInput$Content
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
getstatic org.eclipse.jetty.server.HttpInput.EOF:Lorg/eclipse/jetty/server/HttpInput$State;
if_acmpne 14
11: aload 0
getstatic org.eclipse.jetty.server.HttpInput.AEOF:Lorg/eclipse/jetty/server/HttpInput$State;
putfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
12: aload 0
getfield org.eclipse.jetty.server.HttpInput._channelState:Lorg/eclipse/jetty/server/HttpChannelState;
invokevirtual org.eclipse.jetty.server.HttpChannelState.onReadEof:()Z
istore 2
13: goto 17
14: StackMap locals:
StackMap stack:
aload 0
getstatic org.eclipse.jetty.server.HttpInput.ASYNC:Lorg/eclipse/jetty/server/HttpInput$State;
putfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
15: aload 0
getfield org.eclipse.jetty.server.HttpInput._channelState:Lorg/eclipse/jetty/server/HttpChannelState;
invokevirtual org.eclipse.jetty.server.HttpChannelState.onReadUnready:()V
16: aload 0
iconst_1
putfield org.eclipse.jetty.server.HttpInput._waitingForContent:Z
end local 4 17: StackMap locals:
StackMap stack:
aload 3
monitorexit
18: goto 23
StackMap locals:
StackMap stack: java.lang.Throwable
19: aload 3
monitorexit
20: athrow
21: StackMap locals: org.eclipse.jetty.server.HttpInput javax.servlet.ReadListener int
StackMap stack: java.io.IOException
astore 3
start local 3 22: new org.eclipse.jetty.io.RuntimeIOException
dup
aload 3
invokespecial org.eclipse.jetty.io.RuntimeIOException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 3 23: StackMap locals:
StackMap stack:
iload 2
ifeq 25
24: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.wake:()V
25: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 26 0 this Lorg/eclipse/jetty/server/HttpInput;
0 26 1 readListener Ljavax/servlet/ReadListener;
1 26 2 woken Z
6 17 4 content Lorg/eclipse/jetty/server/HttpInput$Content;
22 23 3 e Ljava/io/IOException;
Exception table:
from to target type
2 18 19 any
19 20 19 any
1 21 21 Class java.io.IOException
MethodParameters:
Name Flags
readListener
public boolean onIdleTimeout(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
dup
astore 2
monitorenter
1: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.getHttpChannelState:()Lorg/eclipse/jetty/server/HttpChannelState;
invokevirtual org.eclipse.jetty.server.HttpChannelState.isIdle:()Z
istore 3
start local 3 2: aload 0
getfield org.eclipse.jetty.server.HttpInput._waitingForContent:Z
ifne 3
iload 3
ifeq 8
StackMap locals: java.util.Deque int
StackMap stack:
3: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.isError:()Z
ifne 8
4: aload 1
new java.lang.Throwable
dup
ldc "HttpInput idle timeout"
invokespecial java.lang.Throwable.<init>:(Ljava/lang/String;)V
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
5: aload 0
new org.eclipse.jetty.server.HttpInput$ErrorState
dup
aload 0
aload 1
invokespecial org.eclipse.jetty.server.HttpInput$ErrorState.<init>:(Lorg/eclipse/jetty/server/HttpInput;Ljava/lang/Throwable;)V
putfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
6: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.wakeup:()Z
aload 2
monitorexit
7: ireturn
8: StackMap locals:
StackMap stack:
aload 2
monitorexit
9: iconst_0
ireturn
end local 3 10: StackMap locals: org.eclipse.jetty.server.HttpInput java.lang.Throwable java.util.Deque
StackMap stack: java.lang.Throwable
aload 2
monitorexit
11: athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lorg/eclipse/jetty/server/HttpInput;
0 12 1 x Ljava/lang/Throwable;
2 10 3 neverDispatched Z
Exception table:
from to target type
1 7 10 any
8 9 10 any
10 11 10 any
MethodParameters:
Name Flags
x
public boolean failed(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
dup
astore 2
monitorenter
1: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.isError:()Z
ifeq 7
2: getstatic org.eclipse.jetty.server.HttpInput.LOG:Lorg/eclipse/jetty/util/log/Logger;
invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
ifeq 9
3: new java.lang.Throwable
dup
aload 0
getfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
invokevirtual org.eclipse.jetty.server.HttpInput$State.getError:()Ljava/lang/Throwable;
invokespecial java.lang.Throwable.<init>:(Ljava/lang/Throwable;)V
astore 3
start local 3 4: aload 3
aload 1
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
5: getstatic org.eclipse.jetty.server.HttpInput.LOG:Lorg/eclipse/jetty/util/log/Logger;
aload 3
invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/Throwable;)V
end local 3 6: goto 9
7: StackMap locals: java.util.Deque
StackMap stack:
aload 1
new java.lang.Throwable
dup
ldc "HttpInput failure"
invokespecial java.lang.Throwable.<init>:(Ljava/lang/String;)V
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
8: aload 0
new org.eclipse.jetty.server.HttpInput$ErrorState
dup
aload 0
aload 1
invokespecial org.eclipse.jetty.server.HttpInput$ErrorState.<init>:(Lorg/eclipse/jetty/server/HttpInput;Ljava/lang/Throwable;)V
putfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
9: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.wakeup:()Z
aload 2
monitorexit
10: ireturn
11: StackMap locals:
StackMap stack: java.lang.Throwable
aload 2
monitorexit
12: athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lorg/eclipse/jetty/server/HttpInput;
0 13 1 x Ljava/lang/Throwable;
4 6 3 failure Ljava/lang/Throwable;
Exception table:
from to target type
1 10 11 any
11 12 11 any
MethodParameters:
Name Flags
x
private boolean wakeup();
descriptor: ()Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.server.HttpInput._listener:Ljavax/servlet/ReadListener;
ifnull 2
1: aload 0
getfield org.eclipse.jetty.server.HttpInput._channelState:Lorg/eclipse/jetty/server/HttpChannelState;
invokevirtual org.eclipse.jetty.server.HttpChannelState.onContentAdded:()Z
ireturn
2: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
invokevirtual java.lang.Object.notify:()V
3: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/eclipse/jetty/server/HttpInput;
public void run();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=6, args_size=1
start local 0 0: iconst_0
istore 3
start local 3 1: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
dup
astore 4
monitorenter
2: aload 0
getfield org.eclipse.jetty.server.HttpInput._listener:Ljavax/servlet/ReadListener;
astore 1
start local 1 3: aload 0
getfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
getstatic org.eclipse.jetty.server.HttpInput.EOF:Lorg/eclipse/jetty/server/HttpInput$State;
if_acmpne 6
4: aload 4
monitorexit
5: return
6: StackMap locals: org.eclipse.jetty.server.HttpInput javax.servlet.ReadListener top int java.util.Deque
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
getstatic org.eclipse.jetty.server.HttpInput.AEOF:Lorg/eclipse/jetty/server/HttpInput$State;
if_acmpne 9
7: aload 0
getstatic org.eclipse.jetty.server.HttpInput.EOF:Lorg/eclipse/jetty/server/HttpInput$State;
putfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
8: iconst_1
istore 3
9: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
invokevirtual org.eclipse.jetty.server.HttpInput$State.getError:()Ljava/lang/Throwable;
astore 2
start local 2 10: iload 3
ifne 22
aload 2
ifnonnull 22
11: aload 0
invokevirtual org.eclipse.jetty.server.HttpInput.nextInterceptedContent:()Lorg/eclipse/jetty/server/HttpInput$Content;
astore 5
start local 5 12: aload 5
ifnonnull 15
13: aload 4
monitorexit
14: return
15: StackMap locals: org.eclipse.jetty.server.HttpInput javax.servlet.ReadListener java.lang.Throwable int java.util.Deque org.eclipse.jetty.server.HttpInput$Content
StackMap stack:
aload 5
instanceof org.eclipse.jetty.server.HttpInput$EofContent
ifeq 22
16: aload 0
aload 5
invokevirtual org.eclipse.jetty.server.HttpInput.consume:(Lorg/eclipse/jetty/server/HttpInput$Content;)V
17: aload 0
getfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
getstatic org.eclipse.jetty.server.HttpInput.EARLY_EOF:Lorg/eclipse/jetty/server/HttpInput$State;
if_acmpne 19
18: aload 0
getfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
invokevirtual org.eclipse.jetty.server.HttpInput$State.getError:()Ljava/lang/Throwable;
astore 2
goto 22
19: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
getstatic org.eclipse.jetty.server.HttpInput.AEOF:Lorg/eclipse/jetty/server/HttpInput$State;
if_acmpne 22
20: iconst_1
istore 3
21: aload 0
getstatic org.eclipse.jetty.server.HttpInput.EOF:Lorg/eclipse/jetty/server/HttpInput$State;
putfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
end local 5 22: StackMap locals:
StackMap stack:
aload 4
monitorexit
23: goto 26
end local 2 end local 1 StackMap locals: org.eclipse.jetty.server.HttpInput top top int java.util.Deque
StackMap stack: java.lang.Throwable
24: aload 4
monitorexit
25: athrow
start local 1 start local 2 26: StackMap locals: org.eclipse.jetty.server.HttpInput javax.servlet.ReadListener java.lang.Throwable int
StackMap stack:
aload 2
ifnull 30
27: aload 0
getfield org.eclipse.jetty.server.HttpInput._channelState:Lorg/eclipse/jetty/server/HttpChannelState;
invokevirtual org.eclipse.jetty.server.HttpChannelState.getHttpChannel:()Lorg/eclipse/jetty/server/HttpChannel;
invokevirtual org.eclipse.jetty.server.HttpChannel.getResponse:()Lorg/eclipse/jetty/server/Response;
invokevirtual org.eclipse.jetty.server.Response.getHttpFields:()Lorg/eclipse/jetty/http/HttpFields;
getstatic org.eclipse.jetty.server.HttpConnection.CONNECTION_CLOSE:Lorg/eclipse/jetty/http/HttpField;
invokevirtual org.eclipse.jetty.http.HttpFields.add:(Lorg/eclipse/jetty/http/HttpField;)V
28: aload 1
aload 2
invokeinterface javax.servlet.ReadListener.onError:(Ljava/lang/Throwable;)V
29: goto 46
30: StackMap locals:
StackMap stack:
iload 3
ifeq 33
31: aload 1
invokeinterface javax.servlet.ReadListener.onAllDataRead:()V
32: goto 46
33: StackMap locals:
StackMap stack:
aload 1
invokeinterface javax.servlet.ReadListener.onDataAvailable:()V
34: goto 46
35: StackMap locals:
StackMap stack: java.lang.Throwable
astore 4
start local 4 36: getstatic org.eclipse.jetty.server.HttpInput.LOG:Lorg/eclipse/jetty/util/log/Logger;
aload 4
invokevirtual java.lang.Throwable.toString:()Ljava/lang/String;
iconst_0
anewarray java.lang.Object
invokeinterface org.eclipse.jetty.util.log.Logger.warn:(Ljava/lang/String;[Ljava/lang/Object;)V
37: getstatic org.eclipse.jetty.server.HttpInput.LOG:Lorg/eclipse/jetty/util/log/Logger;
aload 4
invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/Throwable;)V
38: iload 3
ifne 39
aload 2
ifnonnull 46
39: StackMap locals: java.lang.Throwable
StackMap stack:
aload 0
getfield org.eclipse.jetty.server.HttpInput._channelState:Lorg/eclipse/jetty/server/HttpChannelState;
invokevirtual org.eclipse.jetty.server.HttpChannelState.getHttpChannel:()Lorg/eclipse/jetty/server/HttpChannel;
invokevirtual org.eclipse.jetty.server.HttpChannel.getResponse:()Lorg/eclipse/jetty/server/Response;
invokevirtual org.eclipse.jetty.server.Response.getHttpFields:()Lorg/eclipse/jetty/http/HttpFields;
getstatic org.eclipse.jetty.server.HttpConnection.CONNECTION_CLOSE:Lorg/eclipse/jetty/http/HttpField;
invokevirtual org.eclipse.jetty.http.HttpFields.add:(Lorg/eclipse/jetty/http/HttpField;)V
40: aload 1
aload 4
invokeinterface javax.servlet.ReadListener.onError:(Ljava/lang/Throwable;)V
41: goto 46
42: StackMap locals:
StackMap stack: java.lang.Throwable
astore 5
start local 5 43: getstatic org.eclipse.jetty.server.HttpInput.LOG:Lorg/eclipse/jetty/util/log/Logger;
aload 5
invokevirtual java.lang.Throwable.toString:()Ljava/lang/String;
iconst_0
anewarray java.lang.Object
invokeinterface org.eclipse.jetty.util.log.Logger.warn:(Ljava/lang/String;[Ljava/lang/Object;)V
44: getstatic org.eclipse.jetty.server.HttpInput.LOG:Lorg/eclipse/jetty/util/log/Logger;
aload 5
invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/Throwable;)V
45: new org.eclipse.jetty.io.RuntimeIOException
dup
aload 5
invokespecial org.eclipse.jetty.io.RuntimeIOException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 5 end local 4 46: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 47 0 this Lorg/eclipse/jetty/server/HttpInput;
3 24 1 listener Ljavax/servlet/ReadListener;
26 47 1 listener Ljavax/servlet/ReadListener;
10 24 2 error Ljava/lang/Throwable;
26 47 2 error Ljava/lang/Throwable;
1 47 3 aeof Z
12 22 5 content Lorg/eclipse/jetty/server/HttpInput$Content;
36 46 4 e Ljava/lang/Throwable;
43 46 5 e2 Ljava/lang/Throwable;
Exception table:
from to target type
2 5 24 any
6 14 24 any
15 23 24 any
24 25 24 any
26 34 35 Class java.lang.Throwable
38 41 42 Class java.lang.Throwable
public java.lang.String toString();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=7, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
dup
astore 6
monitorenter
1: aload 0
getfield org.eclipse.jetty.server.HttpInput._state:Lorg/eclipse/jetty/server/HttpInput$State;
astore 1
start local 1 2: aload 0
getfield org.eclipse.jetty.server.HttpInput._contentConsumed:J
lstore 2
start local 2 3: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
invokeinterface java.util.Deque.size:()I
istore 4
start local 4 4: aload 0
getfield org.eclipse.jetty.server.HttpInput._inputQ:Ljava/util/Deque;
invokeinterface java.util.Deque.peekFirst:()Ljava/lang/Object;
checkcast org.eclipse.jetty.server.HttpInput$Content
astore 5
start local 5 5: aload 6
monitorexit
6: goto 9
end local 5 end local 4 end local 2 end local 1 StackMap locals: org.eclipse.jetty.server.HttpInput top top top top top java.util.Deque
StackMap stack: java.lang.Throwable
7: aload 6
monitorexit
8: athrow
start local 1 start local 2 start local 4 start local 5 9: StackMap locals: org.eclipse.jetty.server.HttpInput org.eclipse.jetty.server.HttpInput$State long int org.eclipse.jetty.server.HttpInput$Content
StackMap stack:
ldc "%s@%x[c=%d,q=%d,[0]=%s,s=%s]"
bipush 6
anewarray java.lang.Object
dup
iconst_0
10: aload 0
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokevirtual java.lang.Class.getSimpleName:()Ljava/lang/String;
aastore
dup
iconst_1
11: aload 0
invokevirtual java.lang.Object.hashCode:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_2
12: lload 2
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
dup
iconst_3
13: iload 4
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_4
14: aload 5
aastore
dup
iconst_5
15: aload 1
aastore
16: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
areturn
end local 5 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lorg/eclipse/jetty/server/HttpInput;
2 7 1 state Lorg/eclipse/jetty/server/HttpInput$State;
9 17 1 state Lorg/eclipse/jetty/server/HttpInput$State;
3 7 2 consumed J
9 17 2 consumed J
4 7 4 q I
9 17 4 q I
5 7 5 content Lorg/eclipse/jetty/server/HttpInput$Content;
9 17 5 content Lorg/eclipse/jetty/server/HttpInput$Content;
Exception table:
from to target type
1 6 7 any
7 8 7 any
}
SourceFile: "HttpInput.java"
NestMembers:
org.eclipse.jetty.server.HttpInput$1 org.eclipse.jetty.server.HttpInput$2 org.eclipse.jetty.server.HttpInput$3 org.eclipse.jetty.server.HttpInput$4 org.eclipse.jetty.server.HttpInput$5 org.eclipse.jetty.server.HttpInput$ChainedInterceptor org.eclipse.jetty.server.HttpInput$Content org.eclipse.jetty.server.HttpInput$EOFState org.eclipse.jetty.server.HttpInput$EofContent org.eclipse.jetty.server.HttpInput$ErrorState org.eclipse.jetty.server.HttpInput$Interceptor org.eclipse.jetty.server.HttpInput$SentinelContent org.eclipse.jetty.server.HttpInput$State
InnerClasses:
org.eclipse.jetty.server.HttpInput$1
org.eclipse.jetty.server.HttpInput$2
org.eclipse.jetty.server.HttpInput$3
org.eclipse.jetty.server.HttpInput$4
org.eclipse.jetty.server.HttpInput$5
public ChainedInterceptor = org.eclipse.jetty.server.HttpInput$ChainedInterceptor of org.eclipse.jetty.server.HttpInput
public Content = org.eclipse.jetty.server.HttpInput$Content of org.eclipse.jetty.server.HttpInput
protected EOFState = org.eclipse.jetty.server.HttpInput$EOFState of org.eclipse.jetty.server.HttpInput
public EofContent = org.eclipse.jetty.server.HttpInput$EofContent of org.eclipse.jetty.server.HttpInput
protected ErrorState = org.eclipse.jetty.server.HttpInput$ErrorState of org.eclipse.jetty.server.HttpInput
public abstract Interceptor = org.eclipse.jetty.server.HttpInput$Interceptor of org.eclipse.jetty.server.HttpInput
public SentinelContent = org.eclipse.jetty.server.HttpInput$SentinelContent of org.eclipse.jetty.server.HttpInput
protected abstract State = org.eclipse.jetty.server.HttpInput$State of org.eclipse.jetty.server.HttpInput