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 5
1: new java.io.IOException
dup
ldc "Connection is null"
invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
2: aload 3
3: invokestatic org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.failure:(Ljava/lang/Throwable;Lorg/glassfish/grizzly/CompletionHandler;)V
4: return
5: StackMap locals:
StackMap stack:
aload 1
invokeinterface org.glassfish.grizzly.Connection.isOpen:()Z
ifne 10
6: new java.io.IOException
dup
ldc "Connection is closed"
invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
7: aload 3
8: invokestatic org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.failure:(Ljava/lang/Throwable;Lorg/glassfish/grizzly/CompletionHandler;)V
9: return
10: StackMap locals:
StackMap stack:
aload 1
checkcast org.glassfish.grizzly.nio.NIOConnection
invokevirtual org.glassfish.grizzly.nio.NIOConnection.getAsyncReadQueue:()Lorg/glassfish/grizzly/asyncqueue/TaskQueue;
11: astore 5
start local 5 12: aload 1
aload 2
aload 3
aload 4
13: 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 14: aload 6
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.getCurrentResult:()Lorg/glassfish/grizzly/ReadResult;
15: astore 7
start local 7 16: aload 5
iconst_1
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.reserveSpace:(I)I
iconst_1
if_icmpne 17
iconst_1
goto 18
StackMap locals: org.glassfish.grizzly.asyncqueue.TaskQueue org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord org.glassfish.grizzly.ReadResult
StackMap stack:
17: iconst_0
StackMap locals:
StackMap stack: int
18: istore 8
start local 8 19: iload 8
ifeq 44
20: aload 0
aload 1
aload 6
invokevirtual org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.doRead:(Lorg/glassfish/grizzly/Connection;Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;)I
pop
21: aload 0
22: iconst_1
aload 6
aload 7
23: invokevirtual org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.intercept:(ILorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;Lorg/glassfish/grizzly/ReadResult;)I
istore 9
start local 9 24: iload 9
iconst_1
iand
ifne 26
25: aload 4
ifnonnull 35
aload 6
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.isFinished:()Z
ifeq 35
26: StackMap locals: int int
StackMap stack:
aload 5
iconst_1
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.releaseSpaceAndNotify:(I)I
ifne 27
iconst_1
goto 28
StackMap locals:
StackMap stack:
27: iconst_0
28: StackMap locals:
StackMap stack: int
istore 10
start local 10 29: aload 6
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.notifyComplete:()V
30: iload 10
ifne 32
31: aload 0
aload 1
invokevirtual org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.onReadyToRead:(Lorg/glassfish/grizzly/Connection;)V
32: 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
33: aload 6
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.recycle:()V
end local 10 34: goto 52
35: StackMap locals:
StackMap stack:
iload 9
iconst_4
iand
ifeq 39
36: aload 7
aconst_null
invokevirtual org.glassfish.grizzly.ReadResult.setMessage:(Ljava/lang/Object;)V
37: aload 7
iconst_0
invokevirtual org.glassfish.grizzly.ReadResult.setReadSize:(I)V
38: aload 6
aconst_null
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.setMessage:(Ljava/lang/Object;)V
39: StackMap locals:
StackMap stack:
aload 5
aload 6
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.setCurrentElement:(Lorg/glassfish/grizzly/asyncqueue/AsyncQueueRecord;)V
40: aload 6
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.notifyIncomplete:()V
41: aload 0
aload 1
invokevirtual org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.onReadyToRead:(Lorg/glassfish/grizzly/Connection;)V
42: 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 43: goto 52
44: StackMap locals:
StackMap stack:
aload 5
aload 6
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.offer:(Lorg/glassfish/grizzly/asyncqueue/AsyncQueueRecord;)V
45: aload 1
invokeinterface org.glassfish.grizzly.Connection.isOpen:()Z
ifne 52
aload 5
aload 6
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.remove:(Lorg/glassfish/grizzly/asyncqueue/AsyncQueueRecord;)Z
ifeq 52
46: aload 0
aload 1
aload 6
47: new java.io.EOFException
dup
ldc "Connection is closed"
invokespecial java.io.EOFException.<init>:(Ljava/lang/String;)V
48: invokevirtual org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.onReadFailure:(Lorg/glassfish/grizzly/Connection;Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;Ljava/io/IOException;)V
49: goto 52
StackMap locals:
StackMap stack: java.io.IOException
50: astore 9
start local 9 51: 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 52: 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 53 0 this Lorg/glassfish/grizzly/nio/AbstractNIOAsyncQueueReader;
0 53 1 connection Lorg/glassfish/grizzly/Connection<Ljava/net/SocketAddress;>;
0 53 2 buffer Lorg/glassfish/grizzly/Buffer;
0 53 3 completionHandler Lorg/glassfish/grizzly/CompletionHandler<Lorg/glassfish/grizzly/ReadResult<Lorg/glassfish/grizzly/Buffer;Ljava/net/SocketAddress;>;>;
0 53 4 interceptor Lorg/glassfish/grizzly/Interceptor<Lorg/glassfish/grizzly/ReadResult;>;
12 53 5 connectionQueue Lorg/glassfish/grizzly/asyncqueue/TaskQueue<Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;>;
14 53 6 queueRecord Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;
16 53 7 currentResult Lorg/glassfish/grizzly/ReadResult<Lorg/glassfish/grizzly/Buffer;Ljava/net/SocketAddress;>;
19 53 8 isCurrent Z
24 43 9 interceptInstructions I
29 34 10 isQueueEmpty Z
51 52 9 e Ljava/io/IOException;
Exception table:
from to target type
19 49 50 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;
1: astore 2
start local 2 2: aload 2
ifnull 3
aload 2
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.isEmpty:()Z
ifne 3
iconst_1
ireturn
StackMap locals: org.glassfish.grizzly.asyncqueue.TaskQueue
StackMap stack:
3: iconst_0
ireturn
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;
2 4 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;
4: astore 3
start local 3 5: iconst_0
istore 4
start local 4 6: aconst_null
astore 5
start local 5 7: goto 38
8: 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 9: aload 0
aload 2
aload 5
invokevirtual org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.doRead:(Lorg/glassfish/grizzly/Connection;Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;)I
pop
10: aload 5
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.getInterceptor:()Lorg/glassfish/grizzly/Interceptor;
11: astore 7
start local 7 12: aload 0
13: iconst_1
aload 5
14: aload 6
15: invokevirtual org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.intercept:(ILorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;Lorg/glassfish/grizzly/ReadResult;)I
istore 8
start local 8 16: iload 8
iconst_1
iand
ifne 18
17: aload 7
ifnonnull 29
aload 5
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.isFinished:()Z
ifeq 29
18: StackMap locals: org.glassfish.grizzly.ReadResult org.glassfish.grizzly.Interceptor int
StackMap stack:
aload 1
invokevirtual org.glassfish.grizzly.Context.isManualIOEventControl:()Z
ifne 21
19: aload 3
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.spaceInBytes:()I
iconst_1
isub
ifgt 21
20: aload 1
invokevirtual org.glassfish.grizzly.Context.setManualIOEventControl:()V
21: StackMap locals:
StackMap stack:
aload 3
iconst_1
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.releaseSpaceAndNotify:(I)I
ifne 22
iconst_1
goto 23
StackMap locals:
StackMap stack:
22: iconst_0
StackMap locals:
StackMap stack: int
23: istore 4
24: aload 5
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.notifyComplete:()V
25: 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
26: aload 5
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.recycle:()V
27: iload 4
ifeq 38
28: goto 40
29: StackMap locals:
StackMap stack:
iload 8
iconst_4
iand
ifeq 33
30: aload 6
aconst_null
invokevirtual org.glassfish.grizzly.ReadResult.setMessage:(Ljava/lang/Object;)V
31: aload 6
iconst_0
invokevirtual org.glassfish.grizzly.ReadResult.setReadSize:(I)V
32: aload 5
aconst_null
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.setMessage:(Ljava/lang/Object;)V
33: StackMap locals:
StackMap stack:
aload 3
aload 5
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.setCurrentElement:(Lorg/glassfish/grizzly/asyncqueue/AsyncQueueRecord;)V
34: aload 5
invokevirtual org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord.notifyIncomplete:()V
35: 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
36: getstatic org.glassfish.grizzly.asyncqueue.AsyncQueue$AsyncResult.INCOMPLETE:Lorg/glassfish/grizzly/asyncqueue/AsyncQueue$AsyncResult;
37: areturn
end local 8 end local 7 end local 6 38: StackMap locals:
StackMap stack:
aload 3
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.poll:()Lorg/glassfish/grizzly/asyncqueue/AsyncQueueRecord;
checkcast org.glassfish.grizzly.asyncqueue.AsyncReadQueueRecord
39: dup
astore 5
ifnonnull 8
40: StackMap locals:
StackMap stack:
iload 4
ifne 51
41: getstatic org.glassfish.grizzly.asyncqueue.AsyncQueue$AsyncResult.EXPECTING_MORE:Lorg/glassfish/grizzly/asyncqueue/AsyncQueue$AsyncResult;
42: areturn
43: StackMap locals:
StackMap stack: java.io.IOException
astore 6
start local 6 44: 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 45: goto 51
46: StackMap locals:
StackMap stack: java.lang.Exception
astore 6
start local 6 47: ldc "Unexpected exception occurred in AsyncQueueReader"
astore 7
start local 7 48: 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
49: 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 50: 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 51: 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 52 0 this Lorg/glassfish/grizzly/nio/AbstractNIOAsyncQueueReader;
0 52 1 context Lorg/glassfish/grizzly/Context;
1 52 2 nioConnection Lorg/glassfish/grizzly/nio/NIOConnection;
5 52 3 connectionQueue Lorg/glassfish/grizzly/asyncqueue/TaskQueue<Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;>;
6 52 4 done Z
7 52 5 queueRecord Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;
9 38 6 currentResult Lorg/glassfish/grizzly/ReadResult;
12 38 7 interceptor Lorg/glassfish/grizzly/Interceptor<Lorg/glassfish/grizzly/ReadResult;>;
16 38 8 interceptInstructions I
44 45 6 e Ljava/io/IOException;
47 51 6 e Ljava/lang/Exception;
48 51 7 message Ljava/lang/String;
50 51 8 ioe Ljava/io/IOException;
Exception table:
from to target type
7 37 43 Class java.io.IOException
38 42 43 Class java.io.IOException
7 37 46 Class java.lang.Exception
38 42 46 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
1: astore 2
start local 2 2: aload 2
invokevirtual org.glassfish.grizzly.nio.NIOConnection.getAsyncReadQueue:()Lorg/glassfish/grizzly/asyncqueue/TaskQueue;
3: astore 3
start local 3 4: aload 3
invokevirtual org.glassfish.grizzly.asyncqueue.TaskQueue.isEmpty:()Z
ifne 13
5: aload 0
getfield org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.cachedEOFException:Ljava/io/EOFException;
astore 4
start local 4 6: aload 4
ifnonnull 11
7: new java.io.EOFException
dup
ldc "Connection closed"
invokespecial java.io.EOFException.<init>:(Ljava/lang/String;)V
astore 4
8: aload 0
aload 4
putfield org.glassfish.grizzly.nio.AbstractNIOAsyncQueueReader.cachedEOFException:Ljava/io/EOFException;
9: goto 11
start local 5 10: 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 11: 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 12: ifnonnull 10
end local 5 end local 4 13: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lorg/glassfish/grizzly/nio/AbstractNIOAsyncQueueReader;
0 14 1 connection Lorg/glassfish/grizzly/Connection;
2 14 2 nioConnection Lorg/glassfish/grizzly/nio/NIOConnection;
4 14 3 readQueue Lorg/glassfish/grizzly/asyncqueue/TaskQueue<Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;>;
6 13 4 error Ljava/io/EOFException;
10 11 5 record Lorg/glassfish/grizzly/asyncqueue/AsyncReadQueueRecord;
12 13 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