class org.glassfish.grizzly.http2.DefaultInputBuffer implements org.glassfish.grizzly.http2.StreamInputBuffer
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: org.glassfish.grizzly.http2.DefaultInputBuffer
super_class: java.lang.Object
{
private static final java.util.logging.Logger LOGGER;
descriptor: Ljava/util/logging/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final long NULL_CONTENT_LENGTH;
descriptor: J
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: -9223372036854775808
private static final java.util.concurrent.atomic.AtomicIntegerFieldUpdater<org.glassfish.grizzly.http2.DefaultInputBuffer> inputQueueSizeUpdater;
descriptor: Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater<Lorg/glassfish/grizzly/http2/DefaultInputBuffer;>;
private volatile int inputQueueSize;
descriptor: I
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private final java.util.concurrent.BlockingQueue<org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement> inputQueue;
descriptor: Ljava/util/concurrent/BlockingQueue;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/concurrent/BlockingQueue<Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;>;
private final java.util.concurrent.atomic.AtomicBoolean inputClosed;
descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private static final java.util.concurrent.atomic.AtomicReferenceFieldUpdater<org.glassfish.grizzly.http2.DefaultInputBuffer, org.glassfish.grizzly.http2.Termination> closeFlagUpdater;
descriptor: Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<Lorg/glassfish/grizzly/http2/DefaultInputBuffer;Lorg/glassfish/grizzly/http2/Termination;>;
private volatile org.glassfish.grizzly.http2.Termination closeFlag;
descriptor: Lorg/glassfish/grizzly/http2/Termination;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private final java.lang.Object terminateSync;
descriptor: Ljava/lang/Object;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.glassfish.grizzly.http2.Http2Stream stream;
descriptor: Lorg/glassfish/grizzly/http2/Http2Stream;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.glassfish.grizzly.http2.Http2Session http2Session;
descriptor: Lorg/glassfish/grizzly/http2/Http2Session;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.lang.Object expectInputSwitchSync;
descriptor: Ljava/lang/Object;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private boolean expectInputSwitch;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private long remainingContentLength;
descriptor: J
flags: (0x0002) ACC_PRIVATE
static final boolean $assertionsDisabled;
descriptor: Z
flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=0, args_size=0
0: ldc Lorg/glassfish/grizzly/http2/DefaultInputBuffer;
invokevirtual java.lang.Class.desiredAssertionStatus:()Z
ifne 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: putstatic org.glassfish.grizzly.http2.DefaultInputBuffer.$assertionsDisabled:Z
3: ldc Lorg/glassfish/grizzly/http2/StreamInputBuffer;
invokestatic org.glassfish.grizzly.Grizzly.logger:(Ljava/lang/Class;)Ljava/util/logging/Logger;
putstatic org.glassfish.grizzly.http2.DefaultInputBuffer.LOGGER:Ljava/util/logging/Logger;
4: ldc Lorg/glassfish/grizzly/http2/DefaultInputBuffer;
ldc "inputQueueSize"
invokestatic java.util.concurrent.atomic.AtomicIntegerFieldUpdater.newUpdater:(Ljava/lang/Class;Ljava/lang/String;)Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
5: putstatic org.glassfish.grizzly.http2.DefaultInputBuffer.inputQueueSizeUpdater:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
6: ldc Lorg/glassfish/grizzly/http2/DefaultInputBuffer;
ldc Lorg/glassfish/grizzly/http2/Termination;
ldc "closeFlag"
invokestatic java.util.concurrent.atomic.AtomicReferenceFieldUpdater.newUpdater:(Ljava/lang/Class;Ljava/lang/Class;Ljava/lang/String;)Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
7: putstatic org.glassfish.grizzly.http2.DefaultInputBuffer.closeFlagUpdater:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
8: return
LocalVariableTable:
Start End Slot Name Signature
void <init>(org.glassfish.grizzly.http2.Http2Stream);
descriptor: (Lorg/glassfish/grizzly/http2/Http2Stream;)V
flags: (0x0000)
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.concurrent.LinkedTransferQueue
dup
invokespecial java.util.concurrent.LinkedTransferQueue.<init>:()V
putfield org.glassfish.grizzly.http2.DefaultInputBuffer.inputQueue:Ljava/util/concurrent/BlockingQueue;
2: aload 0
new java.util.concurrent.atomic.AtomicBoolean
dup
invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:()V
putfield org.glassfish.grizzly.http2.DefaultInputBuffer.inputClosed:Ljava/util/concurrent/atomic/AtomicBoolean;
3: aload 0
new java.lang.Object
dup
invokespecial java.lang.Object.<init>:()V
putfield org.glassfish.grizzly.http2.DefaultInputBuffer.terminateSync:Ljava/lang/Object;
4: aload 0
new java.lang.Object
dup
invokespecial java.lang.Object.<init>:()V
putfield org.glassfish.grizzly.http2.DefaultInputBuffer.expectInputSwitchSync:Ljava/lang/Object;
5: aload 0
ldc -9223372036854775808
putfield org.glassfish.grizzly.http2.DefaultInputBuffer.remainingContentLength:J
6: aload 0
aload 1
putfield org.glassfish.grizzly.http2.DefaultInputBuffer.stream:Lorg/glassfish/grizzly/http2/Http2Stream;
7: aload 0
aload 1
invokevirtual org.glassfish.grizzly.http2.Http2Stream.getHttp2Session:()Lorg/glassfish/grizzly/http2/Http2Session;
putfield org.glassfish.grizzly.http2.DefaultInputBuffer.http2Session:Lorg/glassfish/grizzly/http2/Http2Session;
8: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/glassfish/grizzly/http2/DefaultInputBuffer;
0 9 1 stream Lorg/glassfish/grizzly/http2/Http2Stream;
MethodParameters:
Name Flags
stream final
public void onReadEventComplete();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=2, args_size=1
start local 0 0: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.stream:Lorg/glassfish/grizzly/http2/Http2Stream;
getfield org.glassfish.grizzly.http2.Http2Stream.isProcessingComplete:Z
ifne 2
1: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.stream:Lorg/glassfish/grizzly/http2/Http2Stream;
invokevirtual org.glassfish.grizzly.http2.Http2Stream.getInputHttpHeader:()Lorg/glassfish/grizzly/http/HttpHeader;
invokevirtual org.glassfish.grizzly.http.HttpHeader.isExpectContent:()Z
ifne 3
2: StackMap locals:
StackMap stack:
return
3: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.isClosed:()Z
ifeq 10
4: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.http2Session:Lorg/glassfish/grizzly/http2/Http2Session;
aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.stream:Lorg/glassfish/grizzly/http2/Http2Stream;
5: aload 0
6: new java.io.EOFException
dup
aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.closeFlag:Lorg/glassfish/grizzly/http2/Termination;
invokevirtual org.glassfish.grizzly.http2.Termination.getDescription:()Ljava/lang/String;
invokespecial java.io.EOFException.<init>:(Ljava/lang/String;)V
7: invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.buildBrokenHttpContent:(Ljava/lang/Throwable;)Lorg/glassfish/grizzly/http/HttpContent;
8: invokevirtual org.glassfish.grizzly.http2.Http2Session.sendMessageUpstream:(Lorg/glassfish/grizzly/http2/Http2Stream;Lorg/glassfish/grizzly/http/HttpPacket;)V
9: return
10: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.switchOnExpectInput:()V
11: aload 0
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.switchOffExpectInputIfQueueNotEmpty:()I
dup
istore 1
start local 1 12: ifle 14
13: aload 0
aconst_null
iload 1
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.passPayloadUpstream:(Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;I)V
14: StackMap locals: int
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lorg/glassfish/grizzly/http2/DefaultInputBuffer;
12 15 1 queueSize I
public boolean offer(org.glassfish.grizzly.Buffer, boolean);
descriptor: (Lorg/glassfish/grizzly/Buffer;Z)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.inputClosed:Ljava/util/concurrent/atomic/AtomicBoolean;
invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
ifeq 3
1: aload 1
invokeinterface org.glassfish.grizzly.Buffer.tryDispose:()Z
pop
2: iconst_0
ireturn
3: StackMap locals:
StackMap stack:
getstatic org.glassfish.grizzly.http2.DefaultInputBuffer.LOGGER:Ljava/util/logging/Logger;
getstatic java.util.logging.Level.FINE:Ljava/util/logging/Level;
invokevirtual java.util.logging.Logger.isLoggable:(Ljava/util/logging/Level;)Z
ifeq 7
4: getstatic org.glassfish.grizzly.http2.DefaultInputBuffer.LOGGER:Ljava/util/logging/Logger;
getstatic java.util.logging.Level.FINE:Ljava/util/logging/Level;
ldc "{0}: offer {1} isLast={2}"
5: iconst_3
anewarray java.lang.Object
dup
iconst_0
aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.stream:Lorg/glassfish/grizzly/http2/Http2Stream;
invokevirtual org.glassfish.grizzly.http2.Http2Stream.getId:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
iload 2
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
aastore
6: invokevirtual java.util.logging.Logger.log:(Ljava/util/logging/Level;Ljava/lang/String;[Ljava/lang/Object;)V
7: StackMap locals:
StackMap stack:
iload 2
aload 0
aload 1
invokeinterface org.glassfish.grizzly.Buffer.remaining:()I
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.checkContentLength:(I)Z
ior
istore 3
start local 3 8: new org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement
dup
aload 1
iload 3
iconst_0
invokespecial org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement.<init>:(Ljava/lang/Object;ZZ)V
astore 4
start local 4 9: aload 0
aload 4
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.offer0:(Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;)V
10: iload 3
ifeq 12
11: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.inputClosed:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
12: StackMap locals: int org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement
StackMap stack:
aload 0
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.isClosed:()Z
ifeq 15
aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.inputQueue:Ljava/util/concurrent/BlockingQueue;
aload 4
invokeinterface java.util.concurrent.BlockingQueue.remove:(Ljava/lang/Object;)Z
ifeq 15
13: aload 1
invokeinterface org.glassfish.grizzly.Buffer.tryDispose:()Z
pop
14: iconst_0
ireturn
15: StackMap locals:
StackMap stack:
iconst_1
ireturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lorg/glassfish/grizzly/http2/DefaultInputBuffer;
0 16 1 data Lorg/glassfish/grizzly/Buffer;
0 16 2 isLast Z
8 16 3 isLastData Z
9 16 4 element Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;
MethodParameters:
Name Flags
data final
isLast final
private void offer0(org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement);
descriptor: (Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.switchOffExpectInput:()Z
ifeq 3
1: aload 0
aload 1
aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.inputQueueSize:I
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.passPayloadUpstream:(Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;I)V
2: goto 9
3: StackMap locals:
StackMap stack:
aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.inputQueue:Ljava/util/concurrent/BlockingQueue;
aload 1
invokeinterface java.util.concurrent.BlockingQueue.offer:(Ljava/lang/Object;)Z
ifne 5
4: new java.lang.IllegalStateException
dup
ldc "New element can't be added"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
5: StackMap locals:
StackMap stack:
getstatic org.glassfish.grizzly.http2.DefaultInputBuffer.inputQueueSizeUpdater:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
aload 0
invokevirtual java.util.concurrent.atomic.AtomicIntegerFieldUpdater.incrementAndGet:(Ljava/lang/Object;)I
pop
6: aload 0
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.switchOffExpectInputIfQueueNotEmpty:()I
dup
istore 2
start local 2 7: ifle 9
8: aload 0
aconst_null
iload 2
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.passPayloadUpstream:(Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;I)V
end local 2 9: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/glassfish/grizzly/http2/DefaultInputBuffer;
0 10 1 inputElement Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;
7 9 2 readyBuffersCount I
MethodParameters:
Name Flags
inputElement final
private void passPayloadUpstream(org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement, int);
descriptor: (Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;I)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=5, args_size=3
start local 0 start local 1 start local 2 0: iload 2
iconst_m1
if_icmpne 2
1: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.inputQueueSize:I
istore 2
2: StackMap locals:
StackMap stack:
aconst_null
astore 3
start local 3 3: iload 2
ifle 6
4: aload 0
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.poll0:()Lorg/glassfish/grizzly/Buffer;
astore 3
5: getstatic org.glassfish.grizzly.http2.DefaultInputBuffer.$assertionsDisabled:Z
ifne 6
aload 3
ifnonnull 6
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
6: StackMap locals: org.glassfish.grizzly.Buffer
StackMap stack:
aload 1
ifnull 17
7: aload 1
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement.toBuffer:()Lorg/glassfish/grizzly/Buffer;
astore 4
start local 4 8: aload 1
getfield org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement.isService:Z
ifne 14
9: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.http2Session:Lorg/glassfish/grizzly/http2/Http2Session;
invokevirtual org.glassfish.grizzly.http2.Http2Session.getMemoryManager:()Lorg/glassfish/grizzly/memory/MemoryManager;
10: aload 3
aload 4
11: invokestatic org.glassfish.grizzly.memory.Buffers.appendBuffers:(Lorg/glassfish/grizzly/memory/MemoryManager;Lorg/glassfish/grizzly/Buffer;Lorg/glassfish/grizzly/Buffer;)Lorg/glassfish/grizzly/Buffer;
astore 3
12: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.http2Session:Lorg/glassfish/grizzly/http2/Http2Session;
aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.stream:Lorg/glassfish/grizzly/http2/Http2Stream;
aload 4
invokestatic org.glassfish.grizzly.http2.DefaultInputBuffer.bufSz:(Lorg/glassfish/grizzly/Buffer;)I
invokevirtual org.glassfish.grizzly.http2.Http2Session.ackConsumedData:(Lorg/glassfish/grizzly/http2/Http2Stream;I)V
13: goto 16
StackMap locals: org.glassfish.grizzly.Buffer
StackMap stack:
14: aload 3
ifnonnull 16
15: aload 4
astore 3
16: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.checkEOF:(Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;)V
end local 4 17: StackMap locals:
StackMap stack:
aload 0
aload 3
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.buildHttpContent:(Lorg/glassfish/grizzly/Buffer;)Lorg/glassfish/grizzly/http/HttpContent;
astore 4
start local 4 18: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.http2Session:Lorg/glassfish/grizzly/http2/Http2Session;
aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.stream:Lorg/glassfish/grizzly/http2/Http2Stream;
aload 4
invokevirtual org.glassfish.grizzly.http2.Http2Session.sendMessageUpstreamWithParseNotify:(Lorg/glassfish/grizzly/http2/Http2Stream;Lorg/glassfish/grizzly/http/HttpContent;)V
end local 4 end local 3 19: goto 22
StackMap locals: org.glassfish.grizzly.http2.DefaultInputBuffer org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement int
StackMap stack: java.io.IOException
20: astore 3
start local 3 21: getstatic org.glassfish.grizzly.http2.DefaultInputBuffer.LOGGER:Ljava/util/logging/Logger;
getstatic java.util.logging.Level.WARNING:Ljava/util/logging/Level;
ldc "Unexpected IOException: {0}"
aload 3
invokevirtual java.io.IOException.getMessage:()Ljava/lang/String;
invokevirtual java.util.logging.Logger.log:(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Object;)V
end local 3 22: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 23 0 this Lorg/glassfish/grizzly/http2/DefaultInputBuffer;
0 23 1 inputElement Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;
0 23 2 readyBuffersCount I
3 19 3 payload Lorg/glassfish/grizzly/Buffer;
8 17 4 data Lorg/glassfish/grizzly/Buffer;
18 19 4 content Lorg/glassfish/grizzly/http/HttpContent;
21 22 3 e Ljava/io/IOException;
Exception table:
from to target type
0 19 20 Class java.io.IOException
MethodParameters:
Name Flags
inputElement final
readyBuffersCount
public org.glassfish.grizzly.http.HttpContent poll();
descriptor: ()Lorg/glassfish/grizzly/http/HttpContent;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
aload 0
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.poll0:()Lorg/glassfish/grizzly/Buffer;
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.buildHttpContent:(Lorg/glassfish/grizzly/Buffer;)Lorg/glassfish/grizzly/http/HttpContent;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/glassfish/grizzly/http2/DefaultInputBuffer;
Exceptions:
throws java.io.IOException
private org.glassfish.grizzly.Buffer poll0();
descriptor: ()Lorg/glassfish/grizzly/Buffer;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=8, args_size=1
start local 0 0: aload 0
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.isClosed:()Z
ifeq 2
1: getstatic org.glassfish.grizzly.memory.Buffers.EMPTY_BUFFER:Lorg/glassfish/grizzly/Buffer;
areturn
2: StackMap locals:
StackMap stack:
aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.terminateSync:Ljava/lang/Object;
dup
astore 2
monitorenter
3: getstatic org.glassfish.grizzly.http2.DefaultInputBuffer.inputQueueSizeUpdater:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
aload 0
iconst_0
invokevirtual java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndSet:(Ljava/lang/Object;I)I
istore 4
start local 4 4: iload 4
ifgt 18
5: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.inputQueue:Ljava/util/concurrent/BlockingQueue;
aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.http2Session:Lorg/glassfish/grizzly/http2/Http2Session;
invokevirtual org.glassfish.grizzly.http2.Http2Session.getConnection:()Lorg/glassfish/grizzly/Connection;
6: getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokeinterface org.glassfish.grizzly.Connection.getReadTimeout:(Ljava/util/concurrent/TimeUnit;)J
7: getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
8: invokeinterface java.util.concurrent.BlockingQueue.poll:(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object;
checkcast org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement
astore 3
start local 3 9: goto 12
end local 3 StackMap locals: org.glassfish.grizzly.http2.DefaultInputBuffer top java.lang.Object top int
StackMap stack: java.lang.InterruptedException
10: pop
11: new java.io.IOException
dup
ldc "Blocking read was interrupted"
invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
athrow
start local 3 12: StackMap locals: org.glassfish.grizzly.http2.DefaultInputBuffer top java.lang.Object org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement int
StackMap stack:
aload 3
ifnonnull 14
13: new java.io.IOException
dup
ldc "Blocking read timeout"
invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
athrow
14: StackMap locals:
StackMap stack:
getstatic org.glassfish.grizzly.http2.DefaultInputBuffer.inputQueueSizeUpdater:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
aload 0
iload 4
iconst_1
isub
invokevirtual java.util.concurrent.atomic.AtomicIntegerFieldUpdater.addAndGet:(Ljava/lang/Object;I)I
pop
15: aload 0
aload 3
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.checkEOF:(Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;)V
16: aload 3
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement.toBuffer:()Lorg/glassfish/grizzly/Buffer;
astore 1
start local 1 17: goto 38
end local 3 end local 1 StackMap locals: org.glassfish.grizzly.http2.DefaultInputBuffer top java.lang.Object top int
StackMap stack:
18: iload 4
iconst_1
if_icmpne 23
19: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.inputQueue:Ljava/util/concurrent/BlockingQueue;
invokeinterface java.util.concurrent.BlockingQueue.poll:()Ljava/lang/Object;
checkcast org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement
astore 3
start local 3 20: aload 0
aload 3
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.checkEOF:(Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;)V
21: aload 3
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement.toBuffer:()Lorg/glassfish/grizzly/Buffer;
astore 1
start local 1 22: goto 38
end local 3 end local 1 23: StackMap locals:
StackMap stack:
aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.http2Session:Lorg/glassfish/grizzly/http2/Http2Session;
invokevirtual org.glassfish.grizzly.http2.Http2Session.getMemoryManager:()Lorg/glassfish/grizzly/memory/MemoryManager;
invokestatic org.glassfish.grizzly.memory.CompositeBuffer.newBuffer:(Lorg/glassfish/grizzly/memory/MemoryManager;)Lorg/glassfish/grizzly/memory/CompositeBuffer;
24: astore 5
start local 5 25: iconst_0
istore 6
start local 6 26: goto 34
27: StackMap locals: org.glassfish.grizzly.memory.CompositeBuffer int
StackMap stack:
aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.inputQueue:Ljava/util/concurrent/BlockingQueue;
invokeinterface java.util.concurrent.BlockingQueue.poll:()Ljava/lang/Object;
checkcast org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement
astore 7
start local 7 28: aload 0
aload 7
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.checkEOF:(Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;)V
29: aload 7
getfield org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement.isService:Z
ifne 31
30: aload 5
aload 7
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement.toBuffer:()Lorg/glassfish/grizzly/Buffer;
invokevirtual org.glassfish.grizzly.memory.CompositeBuffer.append:(Lorg/glassfish/grizzly/Buffer;)Lorg/glassfish/grizzly/memory/CompositeBuffer;
pop
31: StackMap locals: org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement
StackMap stack:
aload 7
getfield org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement.isLast:Z
ifeq 33
32: goto 35
end local 7 33: StackMap locals:
StackMap stack:
iinc 6 1
StackMap locals:
StackMap stack:
34: iload 6
iload 4
if_icmplt 27
end local 6 35: StackMap locals:
StackMap stack:
aload 5
iconst_1
invokevirtual org.glassfish.grizzly.memory.CompositeBuffer.allowBufferDispose:(Z)V
36: aload 5
iconst_1
invokevirtual org.glassfish.grizzly.memory.CompositeBuffer.allowInternalBuffersDispose:(Z)V
37: aload 5
astore 1
end local 5 end local 4 start local 1 38: StackMap locals: org.glassfish.grizzly.http2.DefaultInputBuffer org.glassfish.grizzly.Buffer java.lang.Object
StackMap stack:
aload 2
monitorexit
39: goto 42
end local 1 StackMap locals: org.glassfish.grizzly.http2.DefaultInputBuffer top java.lang.Object
StackMap stack: java.lang.Throwable
40: aload 2
monitorexit
41: athrow
start local 1 42: StackMap locals: org.glassfish.grizzly.http2.DefaultInputBuffer org.glassfish.grizzly.Buffer
StackMap stack:
aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.http2Session:Lorg/glassfish/grizzly/http2/Http2Session;
aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.stream:Lorg/glassfish/grizzly/http2/Http2Stream;
aload 1
invokestatic org.glassfish.grizzly.http2.DefaultInputBuffer.bufSz:(Lorg/glassfish/grizzly/Buffer;)I
invokevirtual org.glassfish.grizzly.http2.Http2Session.ackConsumedData:(Lorg/glassfish/grizzly/http2/Http2Stream;I)V
43: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 44 0 this Lorg/glassfish/grizzly/http2/DefaultInputBuffer;
17 18 1 buffer Lorg/glassfish/grizzly/Buffer;
22 23 1 buffer Lorg/glassfish/grizzly/Buffer;
38 40 1 buffer Lorg/glassfish/grizzly/Buffer;
42 44 1 buffer Lorg/glassfish/grizzly/Buffer;
9 10 3 inputElement Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;
12 18 3 inputElement Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;
20 23 3 inputElement Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;
4 38 4 inputQueueSizeNow I
25 38 5 compositeBuffer Lorg/glassfish/grizzly/memory/CompositeBuffer;
26 35 6 i I
28 33 7 currentElement Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;
Exception table:
from to target type
5 9 10 Class java.lang.InterruptedException
3 39 40 any
40 41 40 any
Exceptions:
throws java.io.IOException
public void close(org.glassfish.grizzly.http2.Termination);
descriptor: (Lorg/glassfish/grizzly/http2/Termination;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.inputClosed:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_0
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
ifeq 5
1: aload 1
invokevirtual org.glassfish.grizzly.http2.Termination.getType:()Lorg/glassfish/grizzly/http2/Termination$TerminationType;
pop
2: aload 1
invokevirtual org.glassfish.grizzly.http2.Termination.isSessionClosed:()Z
ifeq 4
3: return
4: StackMap locals:
StackMap stack:
aload 0
new org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement
dup
aload 1
iconst_1
iconst_1
invokespecial org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement.<init>:(Ljava/lang/Object;ZZ)V
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.offer0:(Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;)V
5: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/glassfish/grizzly/http2/DefaultInputBuffer;
0 6 1 termination Lorg/glassfish/grizzly/http2/Termination;
MethodParameters:
Name Flags
termination final
public void terminate(org.glassfish.grizzly.http2.Termination);
descriptor: (Lorg/glassfish/grizzly/http2/Termination;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=7, args_size=2
start local 0 start local 1 0: getstatic org.glassfish.grizzly.http2.DefaultInputBuffer.closeFlagUpdater:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
aload 0
aconst_null
aload 1
invokevirtual java.util.concurrent.atomic.AtomicReferenceFieldUpdater.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
istore 2
start local 2 1: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.inputClosed:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_0
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
ifeq 5
2: aload 1
invokevirtual org.glassfish.grizzly.http2.Termination.getType:()Lorg/glassfish/grizzly/http2/Termination$TerminationType;
pop
3: aload 1
invokevirtual org.glassfish.grizzly.http2.Termination.isSessionClosed:()Z
ifne 5
4: aload 0
new org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement
dup
aload 1
iconst_1
iconst_1
invokespecial org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement.<init>:(Ljava/lang/Object;ZZ)V
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.offer0:(Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;)V
5: StackMap locals: int
StackMap stack:
iload 2
ifeq 22
6: iconst_0
istore 3
start local 3 7: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.terminateSync:Ljava/lang/Object;
dup
astore 4
monitorenter
8: goto 13
start local 5 9: StackMap locals: int java.lang.Object org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement
StackMap stack:
aload 5
getfield org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement.isService:Z
ifne 13
10: aload 5
invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement.toBuffer:()Lorg/glassfish/grizzly/Buffer;
astore 6
start local 6 11: iload 3
aload 6
invokeinterface org.glassfish.grizzly.Buffer.remaining:()I
iadd
istore 3
12: aload 6
invokeinterface org.glassfish.grizzly.Buffer.tryDispose:()Z
pop
end local 6 end local 5 13: StackMap locals:
StackMap stack:
aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.inputQueue:Ljava/util/concurrent/BlockingQueue;
invokeinterface java.util.concurrent.BlockingQueue.poll:()Ljava/lang/Object;
checkcast org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement
dup
astore 5
start local 5 14: ifnonnull 9
end local 5 15: aload 4
monitorexit
16: goto 19
StackMap locals:
StackMap stack: java.lang.Throwable
17: aload 4
monitorexit
18: athrow
19: StackMap locals:
StackMap stack:
iload 3
ifle 21
20: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.http2Session:Lorg/glassfish/grizzly/http2/Http2Session;
iload 3
invokevirtual org.glassfish.grizzly.http2.Http2Session.ackConsumedData:(I)V
21: StackMap locals:
StackMap stack:
aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.stream:Lorg/glassfish/grizzly/http2/Http2Stream;
invokevirtual org.glassfish.grizzly.http2.Http2Stream.onInputClosed:()V
end local 3 22: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 23 0 this Lorg/glassfish/grizzly/http2/DefaultInputBuffer;
0 23 1 termination Lorg/glassfish/grizzly/http2/Termination;
1 23 2 isSet Z
7 22 3 szToRelease I
9 13 5 element Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;
14 15 5 element Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;
11 13 6 buffer Lorg/glassfish/grizzly/Buffer;
Exception table:
from to target type
8 16 17 any
17 18 17 any
MethodParameters:
Name Flags
termination final
public boolean isClosed();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.closeFlag:Lorg/glassfish/grizzly/http2/Termination;
ifnull 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/glassfish/grizzly/http2/DefaultInputBuffer;
private void checkEOF(org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement);
descriptor: (Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 1
getfield org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement.isLast:Z
ifeq 8
1: aload 1
getfield org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement.isService:Z
ifne 3
2: getstatic org.glassfish.grizzly.http2.Termination.IN_FIN_TERMINATION:Lorg/glassfish/grizzly/http2/Termination;
goto 4
3: StackMap locals:
StackMap stack:
aload 1
getfield org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement.content:Ljava/lang/Object;
checkcast org.glassfish.grizzly.http2.Termination
4: StackMap locals:
StackMap stack: org.glassfish.grizzly.http2.Termination
astore 2
start local 2 5: getstatic org.glassfish.grizzly.http2.DefaultInputBuffer.closeFlagUpdater:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
aload 0
aconst_null
aload 2
invokevirtual java.util.concurrent.atomic.AtomicReferenceFieldUpdater.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 8
6: aload 2
invokevirtual org.glassfish.grizzly.http2.Termination.doTask:()V
7: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.stream:Lorg/glassfish/grizzly/http2/Http2Stream;
invokevirtual org.glassfish.grizzly.http2.Http2Stream.onInputClosed:()V
end local 2 8: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/glassfish/grizzly/http2/DefaultInputBuffer;
0 9 1 inputElement Lorg/glassfish/grizzly/http2/DefaultInputBuffer$InputElement;
5 8 2 termination Lorg/glassfish/grizzly/http2/Termination;
MethodParameters:
Name Flags
inputElement final
private boolean checkContentLength(int);
descriptor: (I)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.remainingContentLength:J
ldc -9223372036854775808
lcmp
ifne 2
1: aload 0
aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.stream:Lorg/glassfish/grizzly/http2/Http2Stream;
invokevirtual org.glassfish.grizzly.http2.Http2Stream.getInputHttpHeader:()Lorg/glassfish/grizzly/http/HttpHeader;
invokevirtual org.glassfish.grizzly.http.HttpHeader.getContentLength:()J
putfield org.glassfish.grizzly.http2.DefaultInputBuffer.remainingContentLength:J
2: StackMap locals:
StackMap stack:
aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.remainingContentLength:J
lconst_0
lcmp
iflt 10
3: aload 0
dup
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.remainingContentLength:J
iload 1
i2l
lsub
putfield org.glassfish.grizzly.http2.DefaultInputBuffer.remainingContentLength:J
4: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.remainingContentLength:J
lconst_0
lcmp
ifne 6
5: iconst_1
ireturn
6: StackMap locals:
StackMap stack:
aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.remainingContentLength:J
lconst_0
lcmp
ifge 10
7: new java.lang.IllegalStateException
dup
new java.lang.StringBuilder
dup
ldc "Http2Stream #"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.stream:Lorg/glassfish/grizzly/http2/Http2Stream;
invokevirtual org.glassfish.grizzly.http2.Http2Stream.getId:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
8: ldc ": peer is sending data beyond specified content-length limit"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
9: invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
10: StackMap locals:
StackMap stack:
iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/glassfish/grizzly/http2/DefaultInputBuffer;
0 11 1 newDataChunkSize I
MethodParameters:
Name Flags
newDataChunkSize final
private boolean switchOffExpectInput();
descriptor: ()Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.expectInputSwitchSync:Ljava/lang/Object;
dup
astore 1
monitorenter
1: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.expectInputSwitch:Z
ifeq 5
2: aload 0
iconst_0
putfield org.glassfish.grizzly.http2.DefaultInputBuffer.expectInputSwitch:Z
3: aload 1
monitorexit
4: iconst_1
ireturn
5: StackMap locals: java.lang.Object
StackMap stack:
aload 1
monitorexit
6: iconst_0
ireturn
7: StackMap locals:
StackMap stack: java.lang.Throwable
aload 1
monitorexit
8: athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/glassfish/grizzly/http2/DefaultInputBuffer;
Exception table:
from to target type
1 4 7 any
5 6 7 any
7 8 7 any
private int switchOffExpectInputIfQueueNotEmpty();
descriptor: ()I
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=1
start local 0 0: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.expectInputSwitchSync:Ljava/lang/Object;
dup
astore 1
monitorenter
1: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.expectInputSwitch:Z
ifeq 6
aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.inputQueueSize:I
dup
istore 2
start local 2 2: ifle 6
3: aload 0
iconst_0
putfield org.glassfish.grizzly.http2.DefaultInputBuffer.expectInputSwitch:Z
4: iload 2
aload 1
monitorexit
5: ireturn
end local 2 6: StackMap locals: java.lang.Object
StackMap stack:
aload 1
monitorexit
7: iconst_0
ireturn
8: StackMap locals:
StackMap stack: java.lang.Throwable
aload 1
monitorexit
9: athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/glassfish/grizzly/http2/DefaultInputBuffer;
2 6 2 queueSize I
Exception table:
from to target type
1 5 8 any
6 7 8 any
8 9 8 any
private void switchOnExpectInput();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.expectInputSwitchSync:Ljava/lang/Object;
dup
astore 1
monitorenter
1: aload 0
iconst_1
putfield org.glassfish.grizzly.http2.DefaultInputBuffer.expectInputSwitch:Z
2: aload 1
monitorexit
3: goto 6
StackMap locals: org.glassfish.grizzly.http2.DefaultInputBuffer java.lang.Object
StackMap stack: java.lang.Throwable
4: aload 1
monitorexit
5: athrow
6: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/glassfish/grizzly/http2/DefaultInputBuffer;
Exception table:
from to target type
1 3 4 any
4 5 4 any
private org.glassfish.grizzly.http.HttpContent buildHttpContent(org.glassfish.grizzly.Buffer);
descriptor: (Lorg/glassfish/grizzly/Buffer;)Lorg/glassfish/grizzly/http/HttpContent;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=6, args_size=2
start local 0 start local 1 0: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.closeFlag:Lorg/glassfish/grizzly/http2/Termination;
astore 2
start local 2 1: aload 2
getstatic org.glassfish.grizzly.http2.Termination.IN_FIN_TERMINATION:Lorg/glassfish/grizzly/http2/Termination;
if_acmpne 2
iconst_1
goto 3
StackMap locals: org.glassfish.grizzly.http2.Termination
StackMap stack:
2: iconst_0
StackMap locals:
StackMap stack: int
3: istore 3
start local 3 4: aload 1
invokeinterface org.glassfish.grizzly.Buffer.hasRemaining:()Z
ifne 5
aload 2
ifnull 5
iload 3
ifeq 15
5: StackMap locals: int
StackMap stack:
aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.stream:Lorg/glassfish/grizzly/http2/Http2Stream;
invokevirtual org.glassfish.grizzly.http2.Http2Stream.getInputHttpHeader:()Lorg/glassfish/grizzly/http/HttpHeader;
astore 5
start local 5 6: aload 5
iload 3
ifeq 7
iconst_0
goto 8
StackMap locals: org.glassfish.grizzly.http2.DefaultInputBuffer org.glassfish.grizzly.Buffer org.glassfish.grizzly.http2.Termination int top org.glassfish.grizzly.http.HttpHeader
StackMap stack: org.glassfish.grizzly.http.HttpHeader
7: iconst_1
StackMap locals: org.glassfish.grizzly.http2.DefaultInputBuffer org.glassfish.grizzly.Buffer org.glassfish.grizzly.http2.Termination int top org.glassfish.grizzly.http.HttpHeader
StackMap stack: org.glassfish.grizzly.http.HttpHeader int
8: invokevirtual org.glassfish.grizzly.http.HttpHeader.setExpectContent:(Z)V
9: aload 5
invokestatic org.glassfish.grizzly.http.HttpContent.builder:(Lorg/glassfish/grizzly/http/HttpHeader;)Lorg/glassfish/grizzly/http/HttpContent$Builder;
10: aload 1
invokevirtual org.glassfish.grizzly.http.HttpContent$Builder.content:(Lorg/glassfish/grizzly/Buffer;)Lorg/glassfish/grizzly/http/HttpContent$Builder;
11: iload 3
invokevirtual org.glassfish.grizzly.http.HttpContent$Builder.last:(Z)Lorg/glassfish/grizzly/http/HttpContent$Builder;
12: invokevirtual org.glassfish.grizzly.http.HttpContent$Builder.build:()Lorg/glassfish/grizzly/http/HttpContent;
13: astore 4
end local 5 start local 4 14: goto 18
end local 4 15: StackMap locals: org.glassfish.grizzly.http2.DefaultInputBuffer org.glassfish.grizzly.Buffer org.glassfish.grizzly.http2.Termination int
StackMap stack:
aload 0
16: new java.io.EOFException
dup
aload 2
invokevirtual org.glassfish.grizzly.http2.Termination.getDescription:()Ljava/lang/String;
invokespecial java.io.EOFException.<init>:(Ljava/lang/String;)V
17: invokevirtual org.glassfish.grizzly.http2.DefaultInputBuffer.buildBrokenHttpContent:(Ljava/lang/Throwable;)Lorg/glassfish/grizzly/http/HttpContent;
astore 4
start local 4 18: StackMap locals: org.glassfish.grizzly.http.HttpContent
StackMap stack:
aload 4
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lorg/glassfish/grizzly/http2/DefaultInputBuffer;
0 19 1 payload Lorg/glassfish/grizzly/Buffer;
1 19 2 localTermination Lorg/glassfish/grizzly/http2/Termination;
4 19 3 isFin Z
14 15 4 httpContent Lorg/glassfish/grizzly/http/HttpContent;
18 19 4 httpContent Lorg/glassfish/grizzly/http/HttpContent;
6 14 5 inputHttpHeader Lorg/glassfish/grizzly/http/HttpHeader;
MethodParameters:
Name Flags
payload final
private org.glassfish.grizzly.http.HttpContent buildBrokenHttpContent(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Lorg/glassfish/grizzly/http/HttpContent;
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.stream:Lorg/glassfish/grizzly/http2/Http2Stream;
invokevirtual org.glassfish.grizzly.http2.Http2Stream.getInputHttpHeader:()Lorg/glassfish/grizzly/http/HttpHeader;
iconst_0
invokevirtual org.glassfish.grizzly.http.HttpHeader.setExpectContent:(Z)V
1: aload 0
getfield org.glassfish.grizzly.http2.DefaultInputBuffer.stream:Lorg/glassfish/grizzly/http2/Http2Stream;
invokevirtual org.glassfish.grizzly.http2.Http2Stream.getInputHttpHeader:()Lorg/glassfish/grizzly/http/HttpHeader;
invokestatic org.glassfish.grizzly.http.HttpBrokenContent.builder:(Lorg/glassfish/grizzly/http/HttpHeader;)Lorg/glassfish/grizzly/http/HttpBrokenContent$Builder;
2: aload 1
invokevirtual org.glassfish.grizzly.http.HttpBrokenContent$Builder.error:(Ljava/lang/Throwable;)Lorg/glassfish/grizzly/http/HttpBrokenContent$Builder;
3: invokevirtual org.glassfish.grizzly.http.HttpBrokenContent$Builder.build:()Lorg/glassfish/grizzly/http/HttpBrokenContent;
4: areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/glassfish/grizzly/http2/DefaultInputBuffer;
0 5 1 t Ljava/lang/Throwable;
MethodParameters:
Name Flags
t final
private static int bufSz(org.glassfish.grizzly.Buffer);
descriptor: (Lorg/glassfish/grizzly/Buffer;)I
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
ifnull 1
aload 0
invokeinterface org.glassfish.grizzly.Buffer.remaining:()I
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 buffer Lorg/glassfish/grizzly/Buffer;
MethodParameters:
Name Flags
buffer final
}
SourceFile: "DefaultInputBuffer.java"
NestMembers:
org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement
InnerClasses:
public final Builder = org.glassfish.grizzly.http.HttpBrokenContent$Builder of org.glassfish.grizzly.http.HttpBrokenContent
public Builder = org.glassfish.grizzly.http.HttpContent$Builder of org.glassfish.grizzly.http.HttpContent
private final InputElement = org.glassfish.grizzly.http2.DefaultInputBuffer$InputElement of org.glassfish.grizzly.http2.DefaultInputBuffer
final TerminationType = org.glassfish.grizzly.http2.Termination$TerminationType of org.glassfish.grizzly.http2.Termination