class sun.nio.ch.KQueuePort$EventHandlerTask implements java.lang.Runnable
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: sun.nio.ch.KQueuePort$EventHandlerTask
super_class: java.lang.Object
{
final sun.nio.ch.KQueuePort this$0;
descriptor: Lsun/nio/ch/KQueuePort;
flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC
private void <init>(sun.nio.ch.KQueuePort);
descriptor: (Lsun/nio/ch/KQueuePort;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 // sun.nio.ch.KQueuePort$EventHandlerTask this
0: .line 194
aload 0 /* this */
aload 1
putfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
aload 0 /* this */
invokespecial java.lang.Object.<init>:()V
return
end local 0 // sun.nio.ch.KQueuePort$EventHandlerTask this
LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lsun/nio/ch/KQueuePort$EventHandlerTask;
MethodParameters:
Name Flags
this$0 final
private sun.nio.ch.KQueuePort$Event poll();
descriptor: ()Lsun/nio/ch/KQueuePort$Event;
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=12, args_size=1
start local 0 // sun.nio.ch.KQueuePort$EventHandlerTask this
0: .line 200
StackMap locals:
StackMap stack:
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.kqfd:I
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.address:J
sipush 512
ldc -1
invokestatic sun.nio.ch.KQueue.poll:(IJIJ)I
istore 1 /* n */
start local 1 // int n
1: .line 201
iload 1 /* n */
bipush -3
if_icmpeq 0
2: .line 209
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.fdToChannelLock:Ljava/util/concurrent/locks/ReadWriteLock;
invokeinterface java.util.concurrent.locks.ReadWriteLock.readLock:()Ljava/util/concurrent/locks/Lock;
invokeinterface java.util.concurrent.locks.Lock.lock:()V
3: .line 211
goto 33
4: .line 212
StackMap locals: int
StackMap stack:
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.address:J
iload 1 /* n */
invokestatic sun.nio.ch.KQueue.getEvent:(JI)J
lstore 2 /* keventAddress */
start local 2 // long keventAddress
5: .line 213
lload 2 /* keventAddress */
invokestatic sun.nio.ch.KQueue.getDescriptor:(J)I
istore 4 /* fd */
start local 4 // int fd
6: .line 216
iload 4 /* fd */
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.sp:[I
iconst_0
iaload
if_icmpne 17
7: .line 217
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.wakeupCount:Ljava/util/concurrent/atomic/AtomicInteger;
invokevirtual java.util.concurrent.atomic.AtomicInteger.decrementAndGet:()I
ifne 10
8: .line 223
StackMap locals: long int
StackMap stack:
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.sp:[I
iconst_0
iaload
invokestatic sun.nio.ch.IOUtil.drain1:(I)I
istore 5 /* nread */
start local 5 // int nread
9: .line 224
iload 5 /* nread */
bipush -3
if_icmpeq 8
end local 5 // int nread
10: .line 229
StackMap locals:
StackMap stack:
iload 1 /* n */
ifle 13
11: .line 230
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.queue:Ljava/util/concurrent/ArrayBlockingQueue;
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.EXECUTE_TASK_OR_SHUTDOWN:Lsun/nio/ch/KQueuePort$Event;
invokevirtual java.util.concurrent.ArrayBlockingQueue.offer:(Ljava/lang/Object;)Z
pop
12: .line 231
goto 33
13: .line 233
StackMap locals:
StackMap stack:
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.EXECUTE_TASK_OR_SHUTDOWN:Lsun/nio/ch/KQueuePort$Event;
astore 10
14: .line 257
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.fdToChannelLock:Ljava/util/concurrent/locks/ReadWriteLock;
invokeinterface java.util.concurrent.locks.ReadWriteLock.readLock:()Ljava/util/concurrent/locks/Lock;
invokeinterface java.util.concurrent.locks.Lock.unlock:()V
15: .line 263
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.queue:Ljava/util/concurrent/ArrayBlockingQueue;
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.NEED_TO_POLL:Lsun/nio/ch/KQueuePort$Event;
invokevirtual java.util.concurrent.ArrayBlockingQueue.offer:(Ljava/lang/Object;)Z
pop
16: .line 233
aload 10
areturn
17: .line 236
StackMap locals:
StackMap stack:
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.fdToChannel:Ljava/util/Map;
iload 4 /* fd */
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast sun.nio.ch.Port$PollableChannel
astore 5 /* channel */
start local 5 // sun.nio.ch.Port$PollableChannel channel
18: .line 237
aload 5 /* channel */
ifnull 33
19: .line 238
lload 2 /* keventAddress */
invokestatic sun.nio.ch.KQueue.getFilter:(J)S
istore 6 /* filter */
start local 6 // int filter
20: .line 239
iconst_0
istore 7 /* events */
start local 7 // int events
21: .line 240
iload 6 /* filter */
iconst_m1
if_icmpne 23
22: .line 241
getstatic sun.nio.ch.Net.POLLIN:S
istore 7 /* events */
goto 25
23: .line 242
StackMap locals: sun.nio.ch.Port$PollableChannel int int
StackMap stack:
iload 6 /* filter */
bipush -2
if_icmpne 25
24: .line 243
getstatic sun.nio.ch.Net.POLLOUT:S
istore 7 /* events */
25: .line 245
StackMap locals:
StackMap stack:
new sun.nio.ch.KQueuePort$Event
dup
aload 5 /* channel */
iload 7 /* events */
invokespecial sun.nio.ch.KQueuePort$Event.<init>:(Lsun/nio/ch/Port$PollableChannel;I)V
astore 8 /* ev */
start local 8 // sun.nio.ch.KQueuePort$Event ev
26: .line 249
iload 1 /* n */
ifle 29
27: .line 250
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.queue:Ljava/util/concurrent/ArrayBlockingQueue;
aload 8 /* ev */
invokevirtual java.util.concurrent.ArrayBlockingQueue.offer:(Ljava/lang/Object;)Z
pop
28: .line 251
goto 33
29: .line 252
StackMap locals: sun.nio.ch.KQueuePort$Event
StackMap stack:
aload 8 /* ev */
astore 10
30: .line 257
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.fdToChannelLock:Ljava/util/concurrent/locks/ReadWriteLock;
invokeinterface java.util.concurrent.locks.ReadWriteLock.readLock:()Ljava/util/concurrent/locks/Lock;
invokeinterface java.util.concurrent.locks.Lock.unlock:()V
31: .line 263
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.queue:Ljava/util/concurrent/ArrayBlockingQueue;
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.NEED_TO_POLL:Lsun/nio/ch/KQueuePort$Event;
invokevirtual java.util.concurrent.ArrayBlockingQueue.offer:(Ljava/lang/Object;)Z
pop
32: .line 252
aload 10
areturn
end local 8 // sun.nio.ch.KQueuePort$Event ev
end local 7 // int events
end local 6 // int filter
end local 5 // sun.nio.ch.Port$PollableChannel channel
end local 4 // int fd
end local 2 // long keventAddress
33: .line 211
StackMap locals: sun.nio.ch.KQueuePort$EventHandlerTask int
StackMap stack:
iload 1 /* n */
iinc 1 /* n */ -1
ifgt 4
34: .line 256
goto 38
StackMap locals:
StackMap stack: java.lang.Throwable
35: astore 9
36: .line 257
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.fdToChannelLock:Ljava/util/concurrent/locks/ReadWriteLock;
invokeinterface java.util.concurrent.locks.ReadWriteLock.readLock:()Ljava/util/concurrent/locks/Lock;
invokeinterface java.util.concurrent.locks.Lock.unlock:()V
37: .line 258
aload 9
athrow
38: .line 257
StackMap locals:
StackMap stack:
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.fdToChannelLock:Ljava/util/concurrent/locks/ReadWriteLock;
invokeinterface java.util.concurrent.locks.ReadWriteLock.readLock:()Ljava/util/concurrent/locks/Lock;
invokeinterface java.util.concurrent.locks.Lock.unlock:()V
end local 1 // int n
39: .line 197
goto 0
40: .line 260
StackMap locals: sun.nio.ch.KQueuePort$EventHandlerTask
StackMap stack: java.lang.Throwable
astore 11
41: .line 263
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.queue:Ljava/util/concurrent/ArrayBlockingQueue;
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.NEED_TO_POLL:Lsun/nio/ch/KQueuePort$Event;
invokevirtual java.util.concurrent.ArrayBlockingQueue.offer:(Ljava/lang/Object;)Z
pop
42: .line 264
aload 11
athrow
end local 0 // sun.nio.ch.KQueuePort$EventHandlerTask this
LocalVariableTable:
Start End Slot Name Signature
0 43 0 this Lsun/nio/ch/KQueuePort$EventHandlerTask;
1 39 1 n I
5 33 2 keventAddress J
6 33 4 fd I
9 10 5 nread I
18 33 5 channel Lsun/nio/ch/Port$PollableChannel;
20 33 6 filter I
21 33 7 events I
26 33 8 ev Lsun/nio/ch/KQueuePort$Event;
Exception table:
from to target type
3 14 35 any
17 30 35 any
33 35 35 any
0 15 40 any
17 31 40 any
33 40 40 any
Exceptions:
throws java.io.IOException
public void run();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=8, args_size=1
start local 0 // sun.nio.ch.KQueuePort$EventHandlerTask this
0: .line 269
invokestatic sun.nio.ch.Invoker.getGroupAndInvokeCount:()Lsun/nio/ch/Invoker$GroupAndInvokeCount;
1: .line 268
astore 1 /* myGroupAndInvokeCount */
start local 1 // sun.nio.ch.Invoker$GroupAndInvokeCount myGroupAndInvokeCount
2: .line 270
aload 1 /* myGroupAndInvokeCount */
ifnull 3
iconst_1
goto 4
StackMap locals: sun.nio.ch.Invoker$GroupAndInvokeCount
StackMap stack:
3: iconst_0
StackMap locals:
StackMap stack: int
4: istore 2 /* isPooledThread */
start local 2 // boolean isPooledThread
5: .line 271
iconst_0
istore 3 /* replaceMe */
start local 3 // boolean replaceMe
6: .line 276
StackMap locals: int int
StackMap stack:
iload 2 /* isPooledThread */
ifeq 8
7: .line 277
aload 1 /* myGroupAndInvokeCount */
invokevirtual sun.nio.ch.Invoker$GroupAndInvokeCount.resetInvokeCount:()V
8: .line 280
StackMap locals:
StackMap stack:
iconst_0
istore 3 /* replaceMe */
9: .line 281
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.queue:Ljava/util/concurrent/ArrayBlockingQueue;
invokevirtual java.util.concurrent.ArrayBlockingQueue.take:()Ljava/lang/Object;
checkcast sun.nio.ch.KQueuePort$Event
astore 4 /* ev */
start local 4 // sun.nio.ch.KQueuePort$Event ev
10: .line 285
aload 4 /* ev */
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.NEED_TO_POLL:Lsun/nio/ch/KQueuePort$Event;
if_acmpne 21
11: .line 287
aload 0 /* this */
invokevirtual sun.nio.ch.KQueuePort$EventHandlerTask.poll:()Lsun/nio/ch/KQueuePort$Event;
astore 4 /* ev */
12: .line 288
goto 21
StackMap locals: sun.nio.ch.KQueuePort$EventHandlerTask sun.nio.ch.Invoker$GroupAndInvokeCount int int sun.nio.ch.KQueuePort$Event
StackMap stack: java.io.IOException
13: astore 5 /* x */
start local 5 // java.io.IOException x
14: .line 289
aload 5 /* x */
invokevirtual java.io.IOException.printStackTrace:()V
15: .line 321
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
aload 0 /* this */
iload 3 /* replaceMe */
invokevirtual sun.nio.ch.KQueuePort.threadExit:(Ljava/lang/Runnable;Z)I
istore 7 /* remaining */
start local 7 // int remaining
16: .line 322
iload 7 /* remaining */
ifne 18
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
invokevirtual sun.nio.ch.KQueuePort.isShutdown:()Z
ifeq 18
17: .line 323
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
invokevirtual sun.nio.ch.KQueuePort.implClose:()V
end local 7 // int remaining
18: .line 290
StackMap locals: java.io.IOException
StackMap stack:
return
end local 5 // java.io.IOException x
end local 4 // sun.nio.ch.KQueuePort$Event ev
19: .line 293
StackMap locals: sun.nio.ch.KQueuePort$EventHandlerTask sun.nio.ch.Invoker$GroupAndInvokeCount int int
StackMap stack: java.lang.InterruptedException
pop
20: .line 294
goto 6
start local 4 // sun.nio.ch.KQueuePort$Event ev
21: .line 298
StackMap locals: sun.nio.ch.KQueuePort$Event
StackMap stack:
aload 4 /* ev */
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
getfield sun.nio.ch.KQueuePort.EXECUTE_TASK_OR_SHUTDOWN:Lsun/nio/ch/KQueuePort$Event;
if_acmpne 31
22: .line 299
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
invokevirtual sun.nio.ch.KQueuePort.pollTask:()Ljava/lang/Runnable;
astore 5 /* task */
start local 5 // java.lang.Runnable task
23: .line 300
aload 5 /* task */
ifnonnull 28
24: .line 321
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
aload 0 /* this */
iload 3 /* replaceMe */
invokevirtual sun.nio.ch.KQueuePort.threadExit:(Ljava/lang/Runnable;Z)I
istore 7 /* remaining */
start local 7 // int remaining
25: .line 322
iload 7 /* remaining */
ifne 27
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
invokevirtual sun.nio.ch.KQueuePort.isShutdown:()Z
ifeq 27
26: .line 323
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
invokevirtual sun.nio.ch.KQueuePort.implClose:()V
end local 7 // int remaining
27: .line 302
StackMap locals: java.lang.Runnable
StackMap stack:
return
28: .line 305
StackMap locals:
StackMap stack:
iconst_1
istore 3 /* replaceMe */
29: .line 306
aload 5 /* task */
invokeinterface java.lang.Runnable.run:()V
30: .line 307
goto 6
end local 5 // java.lang.Runnable task
31: .line 312
StackMap locals:
StackMap stack:
aload 4 /* ev */
invokevirtual sun.nio.ch.KQueuePort$Event.channel:()Lsun/nio/ch/Port$PollableChannel;
aload 4 /* ev */
invokevirtual sun.nio.ch.KQueuePort$Event.events:()I
iload 2 /* isPooledThread */
invokeinterface sun.nio.ch.Port$PollableChannel.onEvent:(IZ)V
32: .line 313
goto 6
StackMap locals:
StackMap stack: java.lang.Error
33: astore 5 /* x */
start local 5 // java.lang.Error x
34: .line 314
iconst_1
istore 3 /* replaceMe */
aload 5 /* x */
athrow
end local 5 // java.lang.Error x
35: .line 315
StackMap locals:
StackMap stack: java.lang.RuntimeException
astore 5 /* x */
start local 5 // java.lang.RuntimeException x
36: .line 316
iconst_1
istore 3 /* replaceMe */
aload 5 /* x */
athrow
end local 5 // java.lang.RuntimeException x
end local 4 // sun.nio.ch.KQueuePort$Event ev
37: .line 319
StackMap locals: sun.nio.ch.KQueuePort$EventHandlerTask sun.nio.ch.Invoker$GroupAndInvokeCount int int
StackMap stack: java.lang.Throwable
astore 6
38: .line 321
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
aload 0 /* this */
iload 3 /* replaceMe */
invokevirtual sun.nio.ch.KQueuePort.threadExit:(Ljava/lang/Runnable;Z)I
istore 7 /* remaining */
start local 7 // int remaining
39: .line 322
iload 7 /* remaining */
ifne 41
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
invokevirtual sun.nio.ch.KQueuePort.isShutdown:()Z
ifeq 41
40: .line 323
aload 0 /* this */
getfield sun.nio.ch.KQueuePort$EventHandlerTask.this$0:Lsun/nio/ch/KQueuePort;
invokevirtual sun.nio.ch.KQueuePort.implClose:()V
end local 7 // int remaining
41: .line 325
StackMap locals: sun.nio.ch.KQueuePort$EventHandlerTask sun.nio.ch.Invoker$GroupAndInvokeCount int int top top java.lang.Throwable
StackMap stack:
aload 6
athrow
end local 3 // boolean replaceMe
end local 2 // boolean isPooledThread
end local 1 // sun.nio.ch.Invoker$GroupAndInvokeCount myGroupAndInvokeCount
end local 0 // sun.nio.ch.KQueuePort$EventHandlerTask this
LocalVariableTable:
Start End Slot Name Signature
0 42 0 this Lsun/nio/ch/KQueuePort$EventHandlerTask;
2 42 1 myGroupAndInvokeCount Lsun/nio/ch/Invoker$GroupAndInvokeCount;
5 42 2 isPooledThread Z
6 42 3 replaceMe Z
10 19 4 ev Lsun/nio/ch/KQueuePort$Event;
21 37 4 ev Lsun/nio/ch/KQueuePort$Event;
14 19 5 x Ljava/io/IOException;
23 31 5 task Ljava/lang/Runnable;
34 35 5 x Ljava/lang/Error;
36 37 5 x Ljava/lang/RuntimeException;
16 18 7 remaining I
25 27 7 remaining I
39 41 7 remaining I
Exception table:
from to target type
11 12 13 Class java.io.IOException
8 15 19 Class java.lang.InterruptedException
31 32 33 Class java.lang.Error
31 32 35 Class java.lang.RuntimeException
6 15 37 any
19 24 37 any
28 37 37 any
}
SourceFile: "KQueuePort.java"
NestHost: sun.nio.ch.KQueuePort
InnerClasses:
GroupAndInvokeCount = sun.nio.ch.Invoker$GroupAndInvokeCount of sun.nio.ch.Invoker
Event = sun.nio.ch.KQueuePort$Event of sun.nio.ch.KQueuePort
private EventHandlerTask = sun.nio.ch.KQueuePort$EventHandlerTask of sun.nio.ch.KQueuePort
abstract PollableChannel = sun.nio.ch.Port$PollableChannel of sun.nio.ch.Port