class io.netty.channel.pool.FixedChannelPool$5 implements java.lang.Runnable
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: io.netty.channel.pool.FixedChannelPool$5
super_class: java.lang.Object
{
final io.netty.channel.pool.FixedChannelPool this$0;
descriptor: Lio/netty/channel/pool/FixedChannelPool;
flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC
void <init>(io.netty.channel.pool.FixedChannelPool);
descriptor: (Lio/netty/channel/pool/FixedChannelPool;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 // io.netty.channel.pool.FixedChannelPool$5 this
0: .line 440
aload 0 /* this */
aload 1
putfield io.netty.channel.pool.FixedChannelPool$5.this$0:Lio/netty/channel/pool/FixedChannelPool;
aload 0 /* this */
invokespecial java.lang.Object.<init>:()V
return
end local 0 // io.netty.channel.pool.FixedChannelPool$5 this
LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/channel/pool/FixedChannelPool$5;
MethodParameters:
Name Flags
this$0 final
public void run();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=1
start local 0 // io.netty.channel.pool.FixedChannelPool$5 this
0: .line 443
aload 0 /* this */
getfield io.netty.channel.pool.FixedChannelPool$5.this$0:Lio/netty/channel/pool/FixedChannelPool;
getfield io.netty.channel.pool.FixedChannelPool.closed:Z
ifne 13
1: .line 444
aload 0 /* this */
getfield io.netty.channel.pool.FixedChannelPool$5.this$0:Lio/netty/channel/pool/FixedChannelPool;
iconst_1
putfield io.netty.channel.pool.FixedChannelPool.closed:Z
2: .line 446
StackMap locals:
StackMap stack:
aload 0 /* this */
getfield io.netty.channel.pool.FixedChannelPool$5.this$0:Lio/netty/channel/pool/FixedChannelPool;
getfield io.netty.channel.pool.FixedChannelPool.pendingAcquireQueue:Ljava/util/Queue;
invokeinterface java.util.Queue.poll:()Ljava/lang/Object;
checkcast io.netty.channel.pool.FixedChannelPool$AcquireTask
astore 1 /* task */
start local 1 // io.netty.channel.pool.FixedChannelPool$AcquireTask task
3: .line 447
aload 1 /* task */
ifnonnull 5
4: .line 448
goto 10
5: .line 450
StackMap locals: io.netty.channel.pool.FixedChannelPool$AcquireTask
StackMap stack:
aload 1 /* task */
getfield io.netty.channel.pool.FixedChannelPool$AcquireTask.timeoutFuture:Ljava/util/concurrent/ScheduledFuture;
astore 2 /* f */
start local 2 // java.util.concurrent.ScheduledFuture f
6: .line 451
aload 2 /* f */
ifnull 8
7: .line 452
aload 2 /* f */
iconst_0
invokeinterface java.util.concurrent.ScheduledFuture.cancel:(Z)Z
pop
8: .line 454
StackMap locals: java.util.concurrent.ScheduledFuture
StackMap stack:
aload 1 /* task */
getfield io.netty.channel.pool.FixedChannelPool$AcquireTask.promise:Lio/netty/util/concurrent/Promise;
new java.nio.channels.ClosedChannelException
dup
invokespecial java.nio.channels.ClosedChannelException.<init>:()V
invokeinterface io.netty.util.concurrent.Promise.setFailure:(Ljava/lang/Throwable;)Lio/netty/util/concurrent/Promise;
pop
end local 2 // java.util.concurrent.ScheduledFuture f
end local 1 // io.netty.channel.pool.FixedChannelPool$AcquireTask task
9: .line 445
goto 2
10: .line 456
StackMap locals:
StackMap stack:
aload 0 /* this */
getfield io.netty.channel.pool.FixedChannelPool$5.this$0:Lio/netty/channel/pool/FixedChannelPool;
iconst_0
putfield io.netty.channel.pool.FixedChannelPool.acquiredChannelCount:I
11: .line 457
aload 0 /* this */
getfield io.netty.channel.pool.FixedChannelPool$5.this$0:Lio/netty/channel/pool/FixedChannelPool;
iconst_0
putfield io.netty.channel.pool.FixedChannelPool.pendingAcquireCount:I
12: .line 458
aload 0 /* this */
getfield io.netty.channel.pool.FixedChannelPool$5.this$0:Lio/netty/channel/pool/FixedChannelPool;
invokestatic io.netty.channel.pool.FixedChannelPool.access$2:(Lio/netty/channel/pool/FixedChannelPool;)V
13: .line 460
StackMap locals:
StackMap stack:
return
end local 0 // io.netty.channel.pool.FixedChannelPool$5 this
LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lio/netty/channel/pool/FixedChannelPool$5;
3 9 1 task Lio/netty/channel/pool/FixedChannelPool$AcquireTask;
6 9 2 f Ljava/util/concurrent/ScheduledFuture<*>;
}
SourceFile: "FixedChannelPool.java"
EnclosingMethod: io.netty.channel.pool.FixedChannelPool.close:()V
NestHost: io.netty.channel.pool.FixedChannelPool
InnerClasses:
io.netty.channel.pool.FixedChannelPool$5
private final AcquireTask = io.netty.channel.pool.FixedChannelPool$AcquireTask of io.netty.channel.pool.FixedChannelPool