public abstract class org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader extends org.glassfish.grizzly.AbstractReader<java.net.SocketAddress> implements org.glassfish.grizzly.asyncqueue.AsyncQueueReader<java.net.SocketAddress>
minor version: 0
major version: 59
flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
this_class: org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader
super_class: org.glassfish.grizzly.AbstractReader
{
private static final java.util.logging.Logger LOGGER;
descriptor: Ljava/util/logging/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
public static final int DEFAULT_BUFFER_SIZE;
descriptor: I
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: 8192
protected int defaultBufferSize;
descriptor: I
flags: (0x0004) ACC_PROTECTED
protected final org.glassfish.grizzly.nio.NIOTransport transport;
descriptor: Lorg/glassfish/grizzly/nio/NIOTransport;
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
private java.io.EOFException cachedEOFException;
descriptor: Ljava/io/EOFException;
flags: (0x0002) ACC_PRIVATE
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lorg/glassfish/grizzly/nio/AbstractNIOAsyncQueueReader;
invokestatic org.glassfish.grizzly.Grizzly.logger:(Ljava/lang/Class;)Ljava/util/logging/Logger;
putstatic org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.LOGGER:Ljava/util/logging/Logger;
1: return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(org.glassfish.grizzly.nio.NIOTransport);
descriptor: (Lorg/glassfish/grizzly/nio/NIOTransport;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial org.glassfish.grizzly.AbstractReader.<init>:()V
1: aload 0
sipush 8192
putfield org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.defaultBufferSize:I
2: aload 0
aload 1
putfield org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.transport:Lorg/glassfish/grizzly/nio/NIOTransport;
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/glassfish/grizzly/nio/AbstractNIOAsyncQueueReader;
0 4 1 transport Lorg/glassfish/grizzly/nio/NIOTransport;
MethodParameters:
Name Flags
transport
public void read(org.glassfish.grizzly.Connection<java.net.SocketAddress>, org.glassfish.grizzly.Buffer, org.glassfish.grizzly.CompletionHandler<org.glassfish.grizzly.ReadResult<org.glassfish.grizzly.Buffer, java.net.SocketAddress>>, org.glassfish.grizzly.Interceptor<org.glassfish.grizzly.ReadResult>);
descriptor: (Lorg/glassfish/grizzly/Connection;Lorg/glassfish/grizzly/Buffer;Lorg/glassfish/grizzly/CompletionHandler;Lorg/glassfish/grizzly/Interceptor;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=11, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 1
ifnonnull 3
1: new java.io.IOException
dup
ldc "Connection is null"
invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
aload 3
invokestatic org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.failure:(Ljava/lang/Throwable;Lorg/glassfish/grizzly/CompletionHandler;)V
2: return
3: StackMap locals:
StackMap stack:
aload 1
invokeinterface org.glassfish.grizzly.Connection.isOpen:()Z
ifne 6
4: new java.io.IOException
dup
ldc "Connection is closed"
invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
aload 3
invokestatic org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.failure:(Ljava/lang/Throwable;Lorg/glassfish/grizzly/CompletionHandler;)V
5: return
6: StackMap locals:
StackMap stack:
aload 1
checkcast org.glassfish.grizzly.nio.NIOConnection
invokevirtual org.glassfish.grizzly.nio.NIOConnection.getAsyncReadQueue:()Lorg/glassfish/grizzly/asyncqueue/TaskQueue;
astore 5
start local 5 7: aload 1
aload 2
aload 3
aload 4
invokestatic org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.create:(Lorg/glassfish/grizzly/Connection;Lorg/glassfish/grizzly/Buffer;Lorg/glassfish/grizzly/CompletionHandler;Lorg/glassfish/grizzly/Interceptor;)Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;
astore 6
start local 6 8: aload 6
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.getCurrentResult:()Lorg/glassfish/grizzly/ReadResult;
astore 7
start local 7 9: aload 5
iconst_1
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.reserveSpace:(I)I
iconst_1
if_icmpne 10
iconst_1
goto 11
StackMap locals: org.glassfish.grizzly.asyncqueue.TaskQueue org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord org.glassfish.grizzly.ReadResult
StackMap stack:
10: iconst_0
StackMap locals:
StackMap stack: int
11: istore 8
start local 8 12: iload 8
ifeq 34
13: aload 0
aload 1
aload 6
invokevirtual org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.doRead:(Lorg/glassfish/grizzly/Connection;Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;)I
pop
14: aload 0
iconst_1
aload 6
aload 7
invokevirtual org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.intercept:(ILorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;Lorg/glassfish/grizzly/ReadResult;)I
istore 9
start local 9 15: iload 9
iconst_1
iand
ifne 16
aload 4
ifnonnull 25
aload 6
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.isFinished:()Z
ifeq 25
16: StackMap locals: int int
StackMap stack:
aload 5
iconst_1
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.releaseSpaceAndNotify:(I)I
ifne 17
iconst_1
goto 18
StackMap locals:
StackMap stack:
17: iconst_0
StackMap locals:
StackMap stack: int
18: istore 10
start local 10 19: aload 6
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.notifyComplete:()V
20: iload 10
ifne 22
21: aload 0
aload 1
invokevirtual org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.onReadyToRead:(Lorg/glassfish/grizzly/Connection;)V
22: StackMap locals: int
StackMap stack:
aload 0
iconst_2
aload 6
aconst_null
invokevirtual org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.intercept:(ILorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;Lorg/glassfish/grizzly/ReadResult;)I
pop
23: aload 6
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.recycle:()V
end local 10 24: goto 40
25: StackMap locals:
StackMap stack:
iload 9
iconst_4
iand
ifeq 29
26: aload 7
aconst_null
invokevirtual org.glassfish.grizzly.ReadResult.setMessage:(Ljava/lang/Object;)V
27: aload 7
iconst_0
invokevirtual org.glassfish.grizzly.ReadResult.setReadSize:(I)V
28: aload 6
aconst_null
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.setMessage:(Ljava/lang/Object;)V
29: StackMap locals:
StackMap stack:
aload 5
aload 6
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.setCurrentElement:(Lorg/glassfish/grizzly/asyncqueue/AsyncQueueRecord;)V
30: aload 6
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.notifyIncomplete:()V
31: aload 0
aload 1
invokevirtual org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.onReadyToRead:(Lorg/glassfish/grizzly/Connection;)V
32: aload 0
iconst_3
aload 6
aconst_null
invokevirtual org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.intercept:(ILorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;Lorg/glassfish/grizzly/ReadResult;)I
pop
end local 9 33: goto 40
34: StackMap locals:
StackMap stack:
aload 5
aload 6
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.offer:(Lorg/glassfish/grizzly/asyncqueue/AsyncQueueRecord;)V
35: aload 1
invokeinterface org.glassfish.grizzly.Connection.isOpen:()Z
ifne 40
aload 5
aload 6
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.remove:(Lorg/glassfish/grizzly/asyncqueue/AsyncQueueRecord;)Z
ifeq 40
36: aload 0
aload 1
aload 6
new java.io.EOFException
dup
ldc "Connection is closed"
invokespecial java.io.EOFException.<init>:(Ljava/lang/String;)V
invokevirtual org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.onReadFailure:(Lorg/glassfish/grizzly/Connection;Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;Ljava/io/IOException;)V
37: goto 40
StackMap locals:
StackMap stack: java.io.IOException
38: astore 9
start local 9 39: aload 0
aload 1
aload 6
aload 9
invokevirtual org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.onReadFailure:(Lorg/glassfish/grizzly/Connection;Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;Ljava/io/IOException;)V
end local 9 40: StackMap locals:
StackMap stack:
return
end local 8 end local 7 end local 6 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 41 0 this Lorg/glassfish/grizzly/nio/AbstractNIOAsyncQueueReader;
0 41 1 connection Lorg/glassfish/grizzly/Connection<Ljava/net/SocketAddress;>;
0 41 2 buffer Lorg/glassfish/grizzly/Buffer;
0 41 3 completionHandler Lorg/glassfish/grizzly/CompletionHandler<Lorg/glassfish/grizzly/ReadResult<Lorg/glassfish/grizzly/Buffer;Ljava/net/SocketAddress;>;>;
0 41 4 interceptor Lorg/glassfish/grizzly/Interceptor<Lorg/glassfish/grizzly/ReadResult;>;
7 41 5 connectionQueue Lorg/glassfish/grizzly/asyncqueue/TaskQueue<Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;>;
8 41 6 queueRecord Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;
9 41 7 currentResult Lorg/glassfish/grizzly/ReadResult<Lorg/glassfish/grizzly/Buffer;Ljava/net/SocketAddress;>;
12 41 8 isCurrent Z
15 33 9 interceptInstructions I
19 24 10 isQueueEmpty Z
39 40 9 e Ljava/io/IOException;
Exception table:
from to target type
12 37 38 Class java.io.IOException
Signature: (Lorg/glassfish/grizzly/Connection<Ljava/net/SocketAddress;>;Lorg/glassfish/grizzly/Buffer;Lorg/glassfish/grizzly/CompletionHandler<Lorg/glassfish/grizzly/ReadResult<Lorg/glassfish/grizzly/Buffer;Ljava/net/SocketAddress;>;>;Lorg/glassfish/grizzly/Interceptor<Lorg/glassfish/grizzly/ReadResult;>;)V
MethodParameters:
Name Flags
connection final
buffer
completionHandler final
interceptor final
public final boolean isReady(org.glassfish.grizzly.Connection);
descriptor: (Lorg/glassfish/grizzly/Connection;)Z
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=1, locals=3, args_size=2
start local 0 start local 1 0: aload 1
checkcast org.glassfish.grizzly.nio.NIOConnection
invokevirtual org.glassfish.grizzly.nio.NIOConnection.getAsyncReadQueue:()Lorg/glassfish/grizzly/asyncqueue/TaskQueue;
astore 2
start local 2 1: aload 2
ifnull 2
aload 2
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.isEmpty:()Z
ifne 2
iconst_1
ireturn
StackMap locals: org.glassfish.grizzly.asyncqueue.TaskQueue
StackMap stack:
2: iconst_0
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/glassfish/grizzly/nio/AbstractNIOAsyncQueueReader;
0 3 1 connection Lorg/glassfish/grizzly/Connection;
1 3 2 connectionQueue Lorg/glassfish/grizzly/asyncqueue/TaskQueue;
MethodParameters:
Name Flags
connection final
public org.glassfish.grizzly.asyncqueue.AsyncQueue$AsyncResult processAsync(org.glassfish.grizzly.Context);
descriptor: (Lorg/glassfish/grizzly/Context;)Lorg/glassfish/grizzly/asyncqueue/AsyncQueue$AsyncResult;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=9, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual org.glassfish.grizzly.Context.getConnection:()Lorg/glassfish/grizzly/Connection;
checkcast org.glassfish.grizzly.nio.NIOConnection
astore 2
start local 2 1: aload 2
invokevirtual org.glassfish.grizzly.nio.NIOConnection.isOpen:()Z
ifne 3
2: getstatic org.glassfish.grizzly.asyncqueue.AsyncQueue$AsyncResult.COMPLETE:Lorg/glassfish/grizzly/asyncqueue/AsyncQueue$AsyncResult;
areturn
3: StackMap locals: org.glassfish.grizzly.nio.NIOConnection
StackMap stack:
aload 2
invokevirtual org.glassfish.grizzly.nio.NIOConnection.getAsyncReadQueue:()Lorg/glassfish/grizzly/asyncqueue/TaskQueue;
astore 3
start local 3 4: iconst_0
istore 4
start local 4 5: aconst_null
astore 5
start local 5 6: goto 31
7: StackMap locals: org.glassfish.grizzly.asyncqueue.TaskQueue int org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord
StackMap stack:
aload 5
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.getCurrentResult:()Lorg/glassfish/grizzly/ReadResult;
astore 6
start local 6 8: aload 0
aload 2
aload 5
invokevirtual org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.doRead:(Lorg/glassfish/grizzly/Connection;Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;)I
pop
9: aload 5
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.getInterceptor:()Lorg/glassfish/grizzly/Interceptor;
astore 7
start local 7 10: aload 0
iconst_1
aload 5
aload 6
invokevirtual org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.intercept:(ILorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;Lorg/glassfish/grizzly/ReadResult;)I
istore 8
start local 8 11: iload 8
iconst_1
iand
ifne 12
aload 7
ifnonnull 22
aload 5
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.isFinished:()Z
ifeq 22
12: StackMap locals: org.glassfish.grizzly.ReadResult org.glassfish.grizzly.Interceptor int
StackMap stack:
aload 1
invokevirtual org.glassfish.grizzly.Context.isManualIOEventControl:()Z
ifne 14
aload 3
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.spaceInBytes:()I
iconst_1
isub
ifgt 14
13: aload 1
invokevirtual org.glassfish.grizzly.Context.setManualIOEventControl:()V
14: StackMap locals:
StackMap stack:
aload 3
iconst_1
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.releaseSpaceAndNotify:(I)I
ifne 15
iconst_1
goto 16
StackMap locals:
StackMap stack:
15: iconst_0
StackMap locals:
StackMap stack: int
16: istore 4
17: aload 5
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.notifyComplete:()V
18: aload 0
iconst_2
aload 5
aconst_null
invokevirtual org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.intercept:(ILorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;Lorg/glassfish/grizzly/ReadResult;)I
pop
19: aload 5
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.recycle:()V
20: iload 4
ifeq 31
21: goto 32
22: StackMap locals:
StackMap stack:
iload 8
iconst_4
iand
ifeq 26
23: aload 6
aconst_null
invokevirtual org.glassfish.grizzly.ReadResult.setMessage:(Ljava/lang/Object;)V
24: aload 6
iconst_0
invokevirtual org.glassfish.grizzly.ReadResult.setReadSize:(I)V
25: aload 5
aconst_null
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.setMessage:(Ljava/lang/Object;)V
26: StackMap locals:
StackMap stack:
aload 3
aload 5
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.setCurrentElement:(Lorg/glassfish/grizzly/asyncqueue/AsyncQueueRecord;)V
27: aload 5
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.notifyIncomplete:()V
28: aload 0
iconst_3
aload 5
aconst_null
invokevirtual org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.intercept:(ILorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;Lorg/glassfish/grizzly/ReadResult;)I
pop
29: getstatic org.glassfish.grizzly.asyncqueue.AsyncQueue$AsyncResult.INCOMPLETE:Lorg/glassfish/grizzly/asyncqueue/AsyncQueue$AsyncResult;
30: areturn
end local 8 end local 7 end local 6 31: StackMap locals:
StackMap stack:
aload 3
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.poll:()Lorg/glassfish/grizzly/asyncqueue/AsyncQueueRecord;
checkcast org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord
dup
astore 5
ifnonnull 7
32: StackMap locals:
StackMap stack:
iload 4
ifne 43
33: getstatic org.glassfish.grizzly.asyncqueue.AsyncQueue$AsyncResult.EXPECTING_MORE:Lorg/glassfish/grizzly/asyncqueue/AsyncQueue$AsyncResult;
34: areturn
35: StackMap locals:
StackMap stack: java.io.IOException
astore 6
start local 6 36: aload 0
aload 2
aload 5
aload 6
invokevirtual org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.onReadFailure:(Lorg/glassfish/grizzly/Connection;Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;Ljava/io/IOException;)V
end local 6 37: goto 43
38: StackMap locals:
StackMap stack: java.lang.Exception
astore 6
start local 6 39: ldc "Unexpected exception occurred in AsyncQueueReader"
astore 7
start local 7 40: getstatic org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.LOGGER:Ljava/util/logging/Logger;
getstatic java.util.logging.Level.SEVERE:Ljava/util/logging/Level;
aload 7
aload 6
invokevirtual java.util.logging.Logger.log:(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V
41: new java.io.IOException
dup
new java.lang.StringBuilder
dup
invokespecial java.lang.StringBuilder.<init>:()V
aload 6
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
ldc ": "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 7
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
astore 8
start local 8 42: aload 0
aload 2
aload 5
aload 8
invokevirtual org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.onReadFailure:(Lorg/glassfish/grizzly/Connection;Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;Ljava/io/IOException;)V
end local 8 end local 7 end local 6 43: StackMap locals:
StackMap stack:
getstatic org.glassfish.grizzly.asyncqueue.AsyncQueue$AsyncResult.COMPLETE:Lorg/glassfish/grizzly/asyncqueue/AsyncQueue$AsyncResult;
areturn
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 44 0 this Lorg/glassfish/grizzly/nio/AbstractNIOAsyncQueueReader;
0 44 1 context Lorg/glassfish/grizzly/Context;
1 44 2 nioConnection Lorg/glassfish/grizzly/nio/NIOConnection;
4 44 3 connectionQueue Lorg/glassfish/grizzly/asyncqueue/TaskQueue<Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;>;
5 44 4 done Z
6 44 5 queueRecord Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;
8 31 6 currentResult Lorg/glassfish/grizzly/ReadResult;
10 31 7 interceptor Lorg/glassfish/grizzly/Interceptor<Lorg/glassfish/grizzly/ReadResult;>;
11 31 8 interceptInstructions I
36 37 6 e Ljava/io/IOException;
39 43 6 e Ljava/lang/Exception;
40 43 7 message Ljava/lang/String;
42 43 8 ioe Ljava/io/IOException;
Exception table:
from to target type
6 30 35 Class java.io.IOException
31 34 35 Class java.io.IOException
6 30 38 Class java.lang.Exception
31 34 38 Class java.lang.Exception
MethodParameters:
Name Flags
context final
public void onClose(org.glassfish.grizzly.Connection);
descriptor: (Lorg/glassfish/grizzly/Connection;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=6, args_size=2
start local 0 start local 1 0: aload 1
checkcast org.glassfish.grizzly.nio.NIOConnection
astore 2
start local 2 1: aload 2
invokevirtual org.glassfish.grizzly.nio.NIOConnection.getAsyncReadQueue:()Lorg/glassfish/grizzly/asyncqueue/TaskQueue;
astore 3
start local 3 2: aload 3
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.isEmpty:()Z
ifne 11
3: aload 0
getfield org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.cachedEOFException:Ljava/io/EOFException;
astore 4
start local 4 4: aload 4
ifnonnull 9
5: new java.io.EOFException
dup
ldc "Connection closed"
invokespecial java.io.EOFException.<init>:(Ljava/lang/String;)V
astore 4
6: aload 0
aload 4
putfield org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.cachedEOFException:Ljava/io/EOFException;
7: goto 9
start local 5 8: StackMap locals: org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader org.glassfish.grizzly.Connection org.glassfish.grizzly.nio.NIOConnection org.glassfish.grizzly.asyncqueue.TaskQueue java.io.EOFException org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord
StackMap stack:
aload 5
aload 4
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.notifyFailure:(Ljava/lang/Throwable;)V
end local 5 9: StackMap locals:
StackMap stack:
aload 3
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.poll:()Lorg/glassfish/grizzly/asyncqueue/AsyncQueueRecord;
checkcast org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord
dup
astore 5
start local 5 10: ifnonnull 8
end local 5 end local 4 11: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lorg/glassfish/grizzly/nio/AbstractNIOAsyncQueueReader;
0 12 1 connection Lorg/glassfish/grizzly/Connection;
1 12 2 nioConnection Lorg/glassfish/grizzly/nio/NIOConnection;
2 12 3 readQueue Lorg/glassfish/grizzly/asyncqueue/TaskQueue<Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;>;
4 11 4 error Ljava/io/EOFException;
8 9 5 record Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;
10 11 5 record Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;
MethodParameters:
Name Flags
connection
public final void close();
descriptor: ()V
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
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/glassfish/grizzly/nio/AbstractNIOAsyncQueueReader;
protected final int doRead(org.glassfish.grizzly.Connection, org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord);
descriptor: (Lorg/glassfish/grizzly/Connection;Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;)I
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
Code:
stack=4, locals=7, args_size=3
start local 0 start local 1 start local 2 0: aload 2
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.getMessage:()Ljava/lang/Object;
astore 3
start local 3 1: aload 3
checkcast org.glassfish.grizzly.Buffer
astore 4
start local 4 2: aload 2
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.getCurrentResult:()Lorg/glassfish/grizzly/ReadResult;
astore 5
start local 5 3: aload 0
aload 1
aload 4
aload 5
invokevirtual org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.read0:(Lorg/glassfish/grizzly/Connection;Lorg/glassfish/grizzly/Buffer;Lorg/glassfish/grizzly/ReadResult;)I
istore 6
start local 6 4: iload 6
iconst_m1
if_icmpne 6
5: new java.io.EOFException
dup
invokespecial java.io.EOFException.<init>:()V
athrow
6: StackMap locals: org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader org.glassfish.grizzly.Connection org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord java.lang.Object org.glassfish.grizzly.Buffer org.glassfish.grizzly.ReadResult int
StackMap stack:
iload 6
ireturn
end local 6 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 7 0 this Lorg/glassfish/grizzly/nio/AbstractNIOAsyncQueueReader;
0 7 1 connection Lorg/glassfish/grizzly/Connection;
0 7 2 queueRecord Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;
1 7 3 message Ljava/lang/Object;
2 7 4 buffer Lorg/glassfish/grizzly/Buffer;
3 7 5 currentResult Lorg/glassfish/grizzly/ReadResult;
4 7 6 readBytes I
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
connection final
queueRecord final
protected final void onReadFailure(org.glassfish.grizzly.Connection, org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord, java.io.IOException);
descriptor: (Lorg/glassfish/grizzly/Connection;Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;Ljava/io/IOException;)V
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
Code:
stack=2, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 2
ifnull 2
1: aload 2
aload 3
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.notifyFailure:(Ljava/lang/Throwable;)V
2: StackMap locals:
StackMap stack:
aload 1
invokeinterface org.glassfish.grizzly.Connection.closeSilently:()V
3: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/glassfish/grizzly/nio/AbstractNIOAsyncQueueReader;
0 4 1 connection Lorg/glassfish/grizzly/Connection;
0 4 2 failedRecord Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;
0 4 3 e Ljava/io/IOException;
MethodParameters:
Name Flags
connection final
failedRecord final
e final
private static void failure(java.lang.Throwable, org.glassfish.grizzly.CompletionHandler<org.glassfish.grizzly.ReadResult<org.glassfish.grizzly.Buffer, java.net.SocketAddress>>);
descriptor: (Ljava/lang/Throwable;Lorg/glassfish/grizzly/CompletionHandler;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ifnull 2
1: aload 1
aload 0
invokeinterface org.glassfish.grizzly.CompletionHandler.failed:(Ljava/lang/Throwable;)V
2: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 failure Ljava/lang/Throwable;
0 3 1 completionHandler Lorg/glassfish/grizzly/CompletionHandler<Lorg/glassfish/grizzly/ReadResult<Lorg/glassfish/grizzly/Buffer;Ljava/net/SocketAddress;>;>;
Signature: (Ljava/lang/Throwable;Lorg/glassfish/grizzly/CompletionHandler<Lorg/glassfish/grizzly/ReadResult<Lorg/glassfish/grizzly/Buffer;Ljava/net/SocketAddress;>;>;)V
MethodParameters:
Name Flags
failure final
completionHandler final
private int intercept(int, org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord, org.glassfish.grizzly.ReadResult);
descriptor: (ILorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;Lorg/glassfish/grizzly/ReadResult;)I
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 2
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.getInterceptor:()Lorg/glassfish/grizzly/Interceptor;
astore 4
start local 4 1: aload 4
ifnull 3
2: aload 4
iload 1
aload 2
aload 3
invokeinterface org.glassfish.grizzly.Interceptor.intercept:(ILjava/lang/Object;Ljava/lang/Object;)I
ireturn
3: StackMap locals: org.glassfish.grizzly.Interceptor
StackMap stack:
iconst_0
ireturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/glassfish/grizzly/nio/AbstractNIOAsyncQueueReader;
0 4 1 event I
0 4 2 asyncQueueRecord Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;
0 4 3 currentResult Lorg/glassfish/grizzly/ReadResult;
1 4 4 interceptor Lorg/glassfish/grizzly/Interceptor<Lorg/glassfish/grizzly/ReadResult;>;
MethodParameters:
Name Flags
event final
asyncQueueRecord final
currentResult final
protected abstract int read0(org.glassfish.grizzly.Connection, org.glassfish.grizzly.Buffer, org.glassfish.grizzly.ReadResult<org.glassfish.grizzly.Buffer, java.net.SocketAddress>);
descriptor: (Lorg/glassfish/grizzly/Connection;Lorg/glassfish/grizzly/Buffer;Lorg/glassfish/grizzly/ReadResult;)I
flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
Exceptions:
throws java.io.IOException
Signature: (Lorg/glassfish/grizzly/Connection;Lorg/glassfish/grizzly/Buffer;Lorg/glassfish/grizzly/ReadResult<Lorg/glassfish/grizzly/Buffer;Ljava/net/SocketAddress;>;)I
MethodParameters:
Name Flags
connection
buffer
currentResult
protected abstract void onReadyToRead(org.glassfish.grizzly.Connection);
descriptor: (Lorg/glassfish/grizzly/Connection;)V
flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
connection
}
Signature: Lorg/glassfish/grizzly/AbstractReader<Ljava/net/SocketAddress;>;Lorg/glassfish/grizzly/asyncqueue/AsyncQueueReader<Ljava/net/SocketAddress;>;
SourceFile: "AbstractNIOAsyncQueueReader.java"
InnerClasses:
public final AsyncResult = org.glassfish.grizzly.asyncqueue.AsyncQueue$AsyncResult of org.glassfish.grizzly.asyncqueue.AsyncQueue