abstract class io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask implements java.lang.Runnable
minor version: 0
major version: 59
flags: flags: (0x0420) ACC_SUPER, ACC_ABSTRACT
this_class: io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask
super_class: java.lang.Object
{
private static final boolean ESTIMATE_TASK_SIZE_ON_SUBMIT;
descriptor: Z
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final int WRITE_TASK_OVERHEAD;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private final io.netty.util.Recycler$Handle<io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask> handle;
descriptor: Lio/netty/util/Recycler$Handle;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lio/netty/util/Recycler$Handle<Lio/netty/channel/AbstractChannelHandlerContext$AbstractWriteTask;>;
private io.netty.channel.AbstractChannelHandlerContext ctx;
descriptor: Lio/netty/channel/AbstractChannelHandlerContext;
flags: (0x0002) ACC_PRIVATE
private java.lang.Object msg;
descriptor: Ljava/lang/Object;
flags: (0x0002) ACC_PRIVATE
private io.netty.channel.ChannelPromise promise;
descriptor: Lio/netty/channel/ChannelPromise;
flags: (0x0002) ACC_PRIVATE
private int size;
descriptor: I
flags: (0x0002) ACC_PRIVATE
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: ldc "io.netty.transport.estimateSizeOnSubmit"
iconst_1
invokestatic io.netty.util.internal.SystemPropertyUtil.getBoolean:(Ljava/lang/String;Z)Z
1: putstatic io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.ESTIMATE_TASK_SIZE_ON_SUBMIT:Z
2: ldc "io.netty.transport.writeTaskSizeOverhead"
bipush 48
invokestatic io.netty.util.internal.SystemPropertyUtil.getInt:(Ljava/lang/String;I)I
3: putstatic io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.WRITE_TASK_OVERHEAD:I
4: return
LocalVariableTable:
Start End Slot Name Signature
private void <init>(io.netty.util.Recycler$Handle<? extends io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask>);
descriptor: (Lio/netty/util/Recycler$Handle;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.handle:Lio/netty/util/Recycler$Handle;
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/netty/channel/AbstractChannelHandlerContext$AbstractWriteTask;
0 3 1 handle Lio/netty/util/Recycler$Handle<+Lio/netty/channel/AbstractChannelHandlerContext$AbstractWriteTask;>;
Signature: (Lio/netty/util/Recycler$Handle<+Lio/netty/channel/AbstractChannelHandlerContext$AbstractWriteTask;>;)V
MethodParameters:
Name Flags
handle
protected static void init(io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask, io.netty.channel.AbstractChannelHandlerContext, java.lang.Object, io.netty.channel.ChannelPromise);
descriptor: (Lio/netty/channel/AbstractChannelHandlerContext$AbstractWriteTask;Lio/netty/channel/AbstractChannelHandlerContext;Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)V
flags: (0x000c) ACC_PROTECTED, ACC_STATIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
putfield io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.ctx:Lio/netty/channel/AbstractChannelHandlerContext;
1: aload 0
aload 2
putfield io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.msg:Ljava/lang/Object;
2: aload 0
aload 3
putfield io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.promise:Lio/netty/channel/ChannelPromise;
3: getstatic io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.ESTIMATE_TASK_SIZE_ON_SUBMIT:Z
ifeq 7
4: aload 0
aload 1
getfield io.netty.channel.AbstractChannelHandlerContext.pipeline:Lio/netty/channel/DefaultChannelPipeline;
invokevirtual io.netty.channel.DefaultChannelPipeline.estimatorHandle:()Lio/netty/channel/MessageSizeEstimator$Handle;
aload 2
invokeinterface io.netty.channel.MessageSizeEstimator$Handle.size:(Ljava/lang/Object;)I
getstatic io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.WRITE_TASK_OVERHEAD:I
iadd
putfield io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.size:I
5: aload 1
getfield io.netty.channel.AbstractChannelHandlerContext.pipeline:Lio/netty/channel/DefaultChannelPipeline;
aload 0
getfield io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.size:I
i2l
invokevirtual io.netty.channel.DefaultChannelPipeline.incrementPendingOutboundBytes:(J)V
6: goto 8
7: StackMap locals:
StackMap stack:
aload 0
iconst_0
putfield io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.size:I
8: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 task Lio/netty/channel/AbstractChannelHandlerContext$AbstractWriteTask;
0 9 1 ctx Lio/netty/channel/AbstractChannelHandlerContext;
0 9 2 msg Ljava/lang/Object;
0 9 3 promise Lio/netty/channel/ChannelPromise;
MethodParameters:
Name Flags
task
ctx
msg
promise
public final void run();
descriptor: ()V
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=1
start local 0 0: getstatic io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.ESTIMATE_TASK_SIZE_ON_SUBMIT:Z
ifeq 2
1: aload 0
getfield io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.ctx:Lio/netty/channel/AbstractChannelHandlerContext;
getfield io.netty.channel.AbstractChannelHandlerContext.pipeline:Lio/netty/channel/DefaultChannelPipeline;
aload 0
getfield io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.size:I
i2l
invokevirtual io.netty.channel.DefaultChannelPipeline.decrementPendingOutboundBytes:(J)V
2: StackMap locals:
StackMap stack:
aload 0
aload 0
getfield io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.ctx:Lio/netty/channel/AbstractChannelHandlerContext;
aload 0
getfield io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.msg:Ljava/lang/Object;
aload 0
getfield io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.promise:Lio/netty/channel/ChannelPromise;
invokevirtual io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write:(Lio/netty/channel/AbstractChannelHandlerContext;Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)V
3: goto 10
StackMap locals:
StackMap stack: java.lang.Throwable
4: astore 1
5: aload 0
aconst_null
putfield io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.ctx:Lio/netty/channel/AbstractChannelHandlerContext;
6: aload 0
aconst_null
putfield io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.msg:Ljava/lang/Object;
7: aload 0
aconst_null
putfield io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.promise:Lio/netty/channel/ChannelPromise;
8: aload 0
getfield io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.handle:Lio/netty/util/Recycler$Handle;
aload 0
invokeinterface io.netty.util.Recycler$Handle.recycle:(Ljava/lang/Object;)V
9: aload 1
athrow
10: StackMap locals:
StackMap stack:
aload 0
aconst_null
putfield io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.ctx:Lio/netty/channel/AbstractChannelHandlerContext;
11: aload 0
aconst_null
putfield io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.msg:Ljava/lang/Object;
12: aload 0
aconst_null
putfield io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.promise:Lio/netty/channel/ChannelPromise;
13: aload 0
getfield io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.handle:Lio/netty/util/Recycler$Handle;
aload 0
invokeinterface io.netty.util.Recycler$Handle.recycle:(Ljava/lang/Object;)V
14: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lio/netty/channel/AbstractChannelHandlerContext$AbstractWriteTask;
Exception table:
from to target type
0 4 4 any
protected void write(io.netty.channel.AbstractChannelHandlerContext, java.lang.Object, io.netty.channel.ChannelPromise);
descriptor: (Lio/netty/channel/AbstractChannelHandlerContext;Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
aload 2
aload 3
invokevirtual io.netty.channel.AbstractChannelHandlerContext.invokeWrite:(Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/netty/channel/AbstractChannelHandlerContext$AbstractWriteTask;
0 2 1 ctx Lio/netty/channel/AbstractChannelHandlerContext;
0 2 2 msg Ljava/lang/Object;
0 2 3 promise Lio/netty/channel/ChannelPromise;
MethodParameters:
Name Flags
ctx
msg
promise
}
SourceFile: "AbstractChannelHandlerContext.java"
NestHost: io.netty.channel.AbstractChannelHandlerContext
InnerClasses:
abstract AbstractWriteTask = io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask of io.netty.channel.AbstractChannelHandlerContext
public abstract Handle = io.netty.channel.MessageSizeEstimator$Handle of io.netty.channel.MessageSizeEstimator
public abstract Handle = io.netty.util.Recycler$Handle of io.netty.util.Recycler