public class io.netty.util.concurrent.DefaultPromise<V> extends io.netty.util.concurrent.AbstractFuture<V> implements io.netty.util.concurrent.Promise<V>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.netty.util.concurrent.DefaultPromise
super_class: io.netty.util.concurrent.AbstractFuture
{
private static final io.netty.util.internal.logging.InternalLogger logger;
descriptor: Lio/netty/util/internal/logging/InternalLogger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final io.netty.util.internal.logging.InternalLogger rejectedExecutionLogger;
descriptor: Lio/netty/util/internal/logging/InternalLogger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final int MAX_LISTENER_STACK_DEPTH;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final java.util.concurrent.atomic.AtomicReferenceFieldUpdater<io.netty.util.concurrent.DefaultPromise, java.lang.Object> RESULT_UPDATER;
descriptor: Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<Lio/netty/util/concurrent/DefaultPromise;Ljava/lang/Object;>;
private static final java.lang.Object SUCCESS;
descriptor: Ljava/lang/Object;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final java.lang.Object UNCANCELLABLE;
descriptor: Ljava/lang/Object;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final io.netty.util.concurrent.DefaultPromise$CauseHolder CANCELLATION_CAUSE_HOLDER;
descriptor: Lio/netty/util/concurrent/DefaultPromise$CauseHolder;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private volatile java.lang.Object result;
descriptor: Ljava/lang/Object;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private final io.netty.util.concurrent.EventExecutor executor;
descriptor: Lio/netty/util/concurrent/EventExecutor;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private java.lang.Object listeners;
descriptor: Ljava/lang/Object;
flags: (0x0002) ACC_PRIVATE
private short waiters;
descriptor: S
flags: (0x0002) ACC_PRIVATE
private boolean notifyingListeners;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=5, locals=0, args_size=0
0: ldc Lio/netty/util/concurrent/DefaultPromise;
invokestatic io.netty.util.internal.logging.InternalLoggerFactory.getInstance:(Ljava/lang/Class;)Lio/netty/util/internal/logging/InternalLogger;
putstatic io.netty.util.concurrent.DefaultPromise.logger:Lio/netty/util/internal/logging/InternalLogger;
1: new java.lang.StringBuilder
dup
ldc Lio/netty/util/concurrent/DefaultPromise;
invokevirtual java.lang.Class.getName:()Ljava/lang/String;
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc ".rejectedExecution"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokestatic io.netty.util.internal.logging.InternalLoggerFactory.getInstance:(Ljava/lang/String;)Lio/netty/util/internal/logging/InternalLogger;
2: putstatic io.netty.util.concurrent.DefaultPromise.rejectedExecutionLogger:Lio/netty/util/internal/logging/InternalLogger;
3: bipush 8
4: ldc "io.netty.defaultPromise.maxListenerStackDepth"
bipush 8
invokestatic io.netty.util.internal.SystemPropertyUtil.getInt:(Ljava/lang/String;I)I
5: invokestatic java.lang.Math.min:(II)I
putstatic io.netty.util.concurrent.DefaultPromise.MAX_LISTENER_STACK_DEPTH:I
6: ldc Lio/netty/util/concurrent/DefaultPromise;
ldc Ljava/lang/Object;
ldc "result"
invokestatic java.util.concurrent.atomic.AtomicReferenceFieldUpdater.newUpdater:(Ljava/lang/Class;Ljava/lang/Class;Ljava/lang/String;)Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
7: putstatic io.netty.util.concurrent.DefaultPromise.RESULT_UPDATER:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
8: new java.lang.Object
dup
invokespecial java.lang.Object.<init>:()V
putstatic io.netty.util.concurrent.DefaultPromise.SUCCESS:Ljava/lang/Object;
9: new java.lang.Object
dup
invokespecial java.lang.Object.<init>:()V
putstatic io.netty.util.concurrent.DefaultPromise.UNCANCELLABLE:Ljava/lang/Object;
10: new io.netty.util.concurrent.DefaultPromise$CauseHolder
dup
11: new java.util.concurrent.CancellationException
dup
invokespecial java.util.concurrent.CancellationException.<init>:()V
ldc Lio/netty/util/concurrent/DefaultPromise;
ldc "cancel(...)"
12: invokestatic io.netty.util.internal.ThrowableUtil.unknownStackTrace:(Ljava/lang/Throwable;Ljava/lang/Class;Ljava/lang/String;)Ljava/lang/Throwable;
invokespecial io.netty.util.concurrent.DefaultPromise$CauseHolder.<init>:(Ljava/lang/Throwable;)V
putstatic io.netty.util.concurrent.DefaultPromise.CANCELLATION_CAUSE_HOLDER:Lio/netty/util/concurrent/DefaultPromise$CauseHolder;
13: return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(io.netty.util.concurrent.EventExecutor);
descriptor: (Lio/netty/util/concurrent/EventExecutor;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial io.netty.util.concurrent.AbstractFuture.<init>:()V
1: aload 0
aload 1
ldc "executor"
invokestatic io.netty.util.internal.ObjectUtil.checkNotNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast io.netty.util.concurrent.EventExecutor
putfield io.netty.util.concurrent.DefaultPromise.executor:Lio/netty/util/concurrent/EventExecutor;
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
0 3 1 executor Lio/netty/util/concurrent/EventExecutor;
MethodParameters:
Name Flags
executor
protected void <init>();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokespecial io.netty.util.concurrent.AbstractFuture.<init>:()V
1: aload 0
aconst_null
putfield io.netty.util.concurrent.DefaultPromise.executor:Lio/netty/util/concurrent/EventExecutor;
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
public io.netty.util.concurrent.Promise<V> setSuccess(V);
descriptor: (Ljava/lang/Object;)Lio/netty/util/concurrent/Promise;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual io.netty.util.concurrent.DefaultPromise.setSuccess0:(Ljava/lang/Object;)Z
ifeq 3
1: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.notifyListeners:()V
2: aload 0
areturn
3: StackMap locals:
StackMap stack:
new java.lang.IllegalStateException
dup
new java.lang.StringBuilder
dup
ldc "complete already: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
0 4 1 result TV;
Signature: (TV;)Lio/netty/util/concurrent/Promise<TV;>;
MethodParameters:
Name Flags
result
public boolean trySuccess();
descriptor: (Ljava/lang/Object;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual io.netty.util.concurrent.DefaultPromise.setSuccess0:(Ljava/lang/Object;)Z
ifeq 3
1: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.notifyListeners:()V
2: iconst_1
ireturn
3: StackMap locals:
StackMap stack:
iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
0 4 1 result TV;
Signature: (TV;)Z
MethodParameters:
Name Flags
result
public io.netty.util.concurrent.Promise<V> setFailure(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Lio/netty/util/concurrent/Promise;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual io.netty.util.concurrent.DefaultPromise.setFailure0:(Ljava/lang/Throwable;)Z
ifeq 3
1: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.notifyListeners:()V
2: aload 0
areturn
3: StackMap locals:
StackMap stack:
new java.lang.IllegalStateException
dup
new java.lang.StringBuilder
dup
ldc "complete already: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
aload 1
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
0 4 1 cause Ljava/lang/Throwable;
Signature: (Ljava/lang/Throwable;)Lio/netty/util/concurrent/Promise<TV;>;
MethodParameters:
Name Flags
cause
public boolean tryFailure(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual io.netty.util.concurrent.DefaultPromise.setFailure0:(Ljava/lang/Throwable;)Z
ifeq 3
1: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.notifyListeners:()V
2: iconst_1
ireturn
3: StackMap locals:
StackMap stack:
iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
0 4 1 cause Ljava/lang/Throwable;
MethodParameters:
Name Flags
cause
public boolean setUncancellable();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=1
start local 0 0: getstatic io.netty.util.concurrent.DefaultPromise.RESULT_UPDATER:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
aload 0
aconst_null
getstatic io.netty.util.concurrent.DefaultPromise.UNCANCELLABLE:Ljava/lang/Object;
invokevirtual java.util.concurrent.atomic.AtomicReferenceFieldUpdater.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 2
1: iconst_1
ireturn
2: StackMap locals:
StackMap stack:
aload 0
getfield io.netty.util.concurrent.DefaultPromise.result:Ljava/lang/Object;
astore 1
start local 1 3: aload 1
invokestatic io.netty.util.concurrent.DefaultPromise.isDone0:(Ljava/lang/Object;)Z
ifeq 4
aload 1
invokestatic io.netty.util.concurrent.DefaultPromise.isCancelled0:(Ljava/lang/Object;)Z
ifeq 4
iconst_0
ireturn
StackMap locals: java.lang.Object
StackMap stack:
4: iconst_1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
3 5 1 result Ljava/lang/Object;
public boolean isSuccess();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield io.netty.util.concurrent.DefaultPromise.result:Ljava/lang/Object;
astore 1
start local 1 1: aload 1
ifnull 2
aload 1
getstatic io.netty.util.concurrent.DefaultPromise.UNCANCELLABLE:Ljava/lang/Object;
if_acmpeq 2
aload 1
instanceof io.netty.util.concurrent.DefaultPromise$CauseHolder
ifne 2
iconst_1
ireturn
StackMap locals: java.lang.Object
StackMap stack:
2: iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
1 3 1 result Ljava/lang/Object;
public boolean isCancellable();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.netty.util.concurrent.DefaultPromise.result:Ljava/lang/Object;
ifnonnull 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
public java.lang.Throwable cause();
descriptor: ()Ljava/lang/Throwable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=2, args_size=1
start local 0 0: aload 0
getfield io.netty.util.concurrent.DefaultPromise.result:Ljava/lang/Object;
astore 1
start local 1 1: aload 1
instanceof io.netty.util.concurrent.DefaultPromise$CauseHolder
ifeq 2
aload 1
checkcast io.netty.util.concurrent.DefaultPromise$CauseHolder
getfield io.netty.util.concurrent.DefaultPromise$CauseHolder.cause:Ljava/lang/Throwable;
goto 3
StackMap locals: java.lang.Object
StackMap stack:
2: aconst_null
StackMap locals:
StackMap stack: java.lang.Throwable
3: areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
1 4 1 result Ljava/lang/Object;
public io.netty.util.concurrent.Promise<V> addListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>);
descriptor: (Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/util/concurrent/Promise;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 1
ldc "listener"
invokestatic io.netty.util.internal.ObjectUtil.checkNotNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
dup
astore 2
monitorenter
2: aload 0
aload 1
invokevirtual io.netty.util.concurrent.DefaultPromise.addListener0:(Lio/netty/util/concurrent/GenericFutureListener;)V
3: aload 2
monitorexit
4: goto 7
StackMap locals: io.netty.util.concurrent.DefaultPromise io.netty.util.concurrent.GenericFutureListener io.netty.util.concurrent.DefaultPromise
StackMap stack: java.lang.Throwable
5: aload 2
monitorexit
6: athrow
7: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.isDone:()Z
ifeq 9
8: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.notifyListeners:()V
9: StackMap locals:
StackMap stack:
aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
0 10 1 listener Lio/netty/util/concurrent/GenericFutureListener<+Lio/netty/util/concurrent/Future<-TV;>;>;
Exception table:
from to target type
2 4 5 any
5 6 5 any
Signature: (Lio/netty/util/concurrent/GenericFutureListener<+Lio/netty/util/concurrent/Future<-TV;>;>;)Lio/netty/util/concurrent/Promise<TV;>;
MethodParameters:
Name Flags
listener
public io.netty.util.concurrent.Promise<V> addListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>[]);
descriptor: ([Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/util/concurrent/Promise;
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=2, locals=7, args_size=2
start local 0 start local 1 0: aload 1
ldc "listeners"
invokestatic io.netty.util.internal.ObjectUtil.checkNotNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
dup
astore 2
monitorenter
2: aload 1
dup
astore 6
arraylength
istore 5
iconst_0
istore 4
goto 8
StackMap locals: io.netty.util.concurrent.DefaultPromise io.netty.util.concurrent.GenericFutureListener[] io.netty.util.concurrent.DefaultPromise top int int io.netty.util.concurrent.GenericFutureListener[]
StackMap stack:
3: aload 6
iload 4
aaload
astore 3
start local 3 4: aload 3
ifnonnull 6
5: goto 9
6: StackMap locals: io.netty.util.concurrent.DefaultPromise io.netty.util.concurrent.GenericFutureListener[] io.netty.util.concurrent.DefaultPromise io.netty.util.concurrent.GenericFutureListener int int io.netty.util.concurrent.GenericFutureListener[]
StackMap stack:
aload 0
aload 3
invokevirtual io.netty.util.concurrent.DefaultPromise.addListener0:(Lio/netty/util/concurrent/GenericFutureListener;)V
end local 3 7: iinc 4 1
StackMap locals: io.netty.util.concurrent.DefaultPromise io.netty.util.concurrent.GenericFutureListener[] io.netty.util.concurrent.DefaultPromise top int int io.netty.util.concurrent.GenericFutureListener[]
StackMap stack:
8: iload 4
iload 5
if_icmplt 3
9: StackMap locals: io.netty.util.concurrent.DefaultPromise io.netty.util.concurrent.GenericFutureListener[] io.netty.util.concurrent.DefaultPromise
StackMap stack:
aload 2
monitorexit
10: goto 13
StackMap locals:
StackMap stack: java.lang.Throwable
11: aload 2
monitorexit
12: athrow
13: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.isDone:()Z
ifeq 15
14: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.notifyListeners:()V
15: StackMap locals:
StackMap stack:
aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
0 16 1 listeners [Lio/netty/util/concurrent/GenericFutureListener;
4 7 3 listener Lio/netty/util/concurrent/GenericFutureListener<+Lio/netty/util/concurrent/Future<-TV;>;>;
Exception table:
from to target type
2 10 11 any
11 12 11 any
Signature: ([Lio/netty/util/concurrent/GenericFutureListener<+Lio/netty/util/concurrent/Future<-TV;>;>;)Lio/netty/util/concurrent/Promise<TV;>;
MethodParameters:
Name Flags
listeners
public io.netty.util.concurrent.Promise<V> removeListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>);
descriptor: (Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/util/concurrent/Promise;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 1
ldc "listener"
invokestatic io.netty.util.internal.ObjectUtil.checkNotNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
dup
astore 2
monitorenter
2: aload 0
aload 1
invokevirtual io.netty.util.concurrent.DefaultPromise.removeListener0:(Lio/netty/util/concurrent/GenericFutureListener;)V
3: aload 2
monitorexit
4: goto 7
StackMap locals: io.netty.util.concurrent.DefaultPromise io.netty.util.concurrent.GenericFutureListener io.netty.util.concurrent.DefaultPromise
StackMap stack: java.lang.Throwable
5: aload 2
monitorexit
6: athrow
7: StackMap locals:
StackMap stack:
aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
0 8 1 listener Lio/netty/util/concurrent/GenericFutureListener<+Lio/netty/util/concurrent/Future<-TV;>;>;
Exception table:
from to target type
2 4 5 any
5 6 5 any
Signature: (Lio/netty/util/concurrent/GenericFutureListener<+Lio/netty/util/concurrent/Future<-TV;>;>;)Lio/netty/util/concurrent/Promise<TV;>;
MethodParameters:
Name Flags
listener final
public io.netty.util.concurrent.Promise<V> removeListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>[]);
descriptor: ([Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/util/concurrent/Promise;
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=2, locals=7, args_size=2
start local 0 start local 1 0: aload 1
ldc "listeners"
invokestatic io.netty.util.internal.ObjectUtil.checkNotNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
dup
astore 2
monitorenter
2: aload 1
dup
astore 6
arraylength
istore 5
iconst_0
istore 4
goto 8
StackMap locals: io.netty.util.concurrent.DefaultPromise io.netty.util.concurrent.GenericFutureListener[] io.netty.util.concurrent.DefaultPromise top int int io.netty.util.concurrent.GenericFutureListener[]
StackMap stack:
3: aload 6
iload 4
aaload
astore 3
start local 3 4: aload 3
ifnonnull 6
5: goto 9
6: StackMap locals: io.netty.util.concurrent.DefaultPromise io.netty.util.concurrent.GenericFutureListener[] io.netty.util.concurrent.DefaultPromise io.netty.util.concurrent.GenericFutureListener int int io.netty.util.concurrent.GenericFutureListener[]
StackMap stack:
aload 0
aload 3
invokevirtual io.netty.util.concurrent.DefaultPromise.removeListener0:(Lio/netty/util/concurrent/GenericFutureListener;)V
end local 3 7: iinc 4 1
StackMap locals: io.netty.util.concurrent.DefaultPromise io.netty.util.concurrent.GenericFutureListener[] io.netty.util.concurrent.DefaultPromise top int int io.netty.util.concurrent.GenericFutureListener[]
StackMap stack:
8: iload 4
iload 5
if_icmplt 3
9: StackMap locals: io.netty.util.concurrent.DefaultPromise io.netty.util.concurrent.GenericFutureListener[] io.netty.util.concurrent.DefaultPromise
StackMap stack:
aload 2
monitorexit
10: goto 13
StackMap locals:
StackMap stack: java.lang.Throwable
11: aload 2
monitorexit
12: athrow
13: StackMap locals:
StackMap stack:
aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
0 14 1 listeners [Lio/netty/util/concurrent/GenericFutureListener;
4 7 3 listener Lio/netty/util/concurrent/GenericFutureListener<+Lio/netty/util/concurrent/Future<-TV;>;>;
Exception table:
from to target type
2 10 11 any
11 12 11 any
Signature: ([Lio/netty/util/concurrent/GenericFutureListener<+Lio/netty/util/concurrent/Future<-TV;>;>;)Lio/netty/util/concurrent/Promise<TV;>;
MethodParameters:
Name Flags
listeners final
public io.netty.util.concurrent.Promise<V> await();
descriptor: ()Lio/netty/util/concurrent/Promise;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=1
start local 0 0: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.isDone:()Z
ifeq 2
1: aload 0
areturn
2: StackMap locals:
StackMap stack:
invokestatic java.lang.Thread.interrupted:()Z
ifeq 4
3: new java.lang.InterruptedException
dup
aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.toString:()Ljava/lang/String;
invokespecial java.lang.InterruptedException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.checkDeadLock:()V
5: aload 0
dup
astore 1
monitorenter
6: goto 14
7: StackMap locals: io.netty.util.concurrent.DefaultPromise
StackMap stack:
aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.incWaiters:()V
8: aload 0
invokevirtual java.lang.Object.wait:()V
9: goto 13
StackMap locals:
StackMap stack: java.lang.Throwable
10: astore 2
11: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.decWaiters:()V
12: aload 2
athrow
13: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.decWaiters:()V
14: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.isDone:()Z
ifeq 7
15: aload 1
monitorexit
16: goto 19
StackMap locals:
StackMap stack: java.lang.Throwable
17: aload 1
monitorexit
18: athrow
19: StackMap locals:
StackMap stack:
aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
Exception table:
from to target type
8 10 10 any
6 16 17 any
17 18 17 any
Exceptions:
throws java.lang.InterruptedException
Signature: ()Lio/netty/util/concurrent/Promise<TV;>;
public io.netty.util.concurrent.Promise<V> awaitUninterruptibly();
descriptor: ()Lio/netty/util/concurrent/Promise;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=1
start local 0 0: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.isDone:()Z
ifeq 2
1: aload 0
areturn
2: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.checkDeadLock:()V
3: iconst_0
istore 1
start local 1 4: aload 0
dup
astore 2
monitorenter
5: goto 16
6: StackMap locals: int io.netty.util.concurrent.DefaultPromise
StackMap stack:
aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.incWaiters:()V
7: aload 0
invokevirtual java.lang.Object.wait:()V
8: goto 15
StackMap locals:
StackMap stack: java.lang.InterruptedException
9: pop
10: iconst_1
istore 1
11: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.decWaiters:()V
goto 16
12: StackMap locals:
StackMap stack: java.lang.Throwable
astore 3
13: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.decWaiters:()V
14: aload 3
athrow
15: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.decWaiters:()V
16: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.isDone:()Z
ifeq 6
17: aload 2
monitorexit
18: goto 21
StackMap locals:
StackMap stack: java.lang.Throwable
19: aload 2
monitorexit
20: athrow
21: StackMap locals:
StackMap stack:
iload 1
ifeq 23
22: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
23: StackMap locals:
StackMap stack:
aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 24 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
4 24 1 interrupted Z
Exception table:
from to target type
7 8 9 Class java.lang.InterruptedException
7 11 12 any
5 18 19 any
19 20 19 any
Signature: ()Lio/netty/util/concurrent/Promise<TV;>;
public boolean await(long, java.util.concurrent.TimeUnit);
descriptor: (JLjava/util/concurrent/TimeUnit;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 3 0: aload 0
aload 3
lload 1
invokevirtual java.util.concurrent.TimeUnit.toNanos:(J)J
iconst_1
invokevirtual io.netty.util.concurrent.DefaultPromise.await0:(JZ)Z
ireturn
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
0 1 1 timeout J
0 1 3 unit Ljava/util/concurrent/TimeUnit;
Exceptions:
throws java.lang.InterruptedException
MethodParameters:
Name Flags
timeout
unit
public boolean await(long);
descriptor: (J)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
lload 1
invokevirtual java.util.concurrent.TimeUnit.toNanos:(J)J
iconst_1
invokevirtual io.netty.util.concurrent.DefaultPromise.await0:(JZ)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
0 1 1 timeoutMillis J
Exceptions:
throws java.lang.InterruptedException
MethodParameters:
Name Flags
timeoutMillis
public boolean awaitUninterruptibly(long, java.util.concurrent.TimeUnit);
descriptor: (JLjava/util/concurrent/TimeUnit;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 3 0: aload 0
aload 3
lload 1
invokevirtual java.util.concurrent.TimeUnit.toNanos:(J)J
iconst_0
invokevirtual io.netty.util.concurrent.DefaultPromise.await0:(JZ)Z
1: ireturn
2: StackMap locals:
StackMap stack: java.lang.InterruptedException
pop
3: new java.lang.InternalError
dup
invokespecial java.lang.InternalError.<init>:()V
athrow
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
0 4 1 timeout J
0 4 3 unit Ljava/util/concurrent/TimeUnit;
Exception table:
from to target type
0 1 2 Class java.lang.InterruptedException
MethodParameters:
Name Flags
timeout
unit
public boolean awaitUninterruptibly(long);
descriptor: (J)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
lload 1
invokevirtual java.util.concurrent.TimeUnit.toNanos:(J)J
iconst_0
invokevirtual io.netty.util.concurrent.DefaultPromise.await0:(JZ)Z
1: ireturn
2: StackMap locals:
StackMap stack: java.lang.InterruptedException
pop
3: new java.lang.InternalError
dup
invokespecial java.lang.InternalError.<init>:()V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
0 4 1 timeoutMillis J
Exception table:
from to target type
0 1 2 Class java.lang.InterruptedException
MethodParameters:
Name Flags
timeoutMillis
public V getNow();
descriptor: ()Ljava/lang/Object;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield io.netty.util.concurrent.DefaultPromise.result:Ljava/lang/Object;
astore 1
start local 1 1: aload 1
instanceof io.netty.util.concurrent.DefaultPromise$CauseHolder
ifne 2
aload 1
getstatic io.netty.util.concurrent.DefaultPromise.SUCCESS:Ljava/lang/Object;
if_acmpne 3
2: StackMap locals: java.lang.Object
StackMap stack:
aconst_null
areturn
3: StackMap locals:
StackMap stack:
aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
1 4 1 result Ljava/lang/Object;
Signature: ()TV;
public boolean cancel(boolean);
descriptor: (Z)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: getstatic io.netty.util.concurrent.DefaultPromise.RESULT_UPDATER:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
aload 0
aconst_null
getstatic io.netty.util.concurrent.DefaultPromise.CANCELLATION_CAUSE_HOLDER:Lio/netty/util/concurrent/DefaultPromise$CauseHolder;
invokevirtual java.util.concurrent.atomic.AtomicReferenceFieldUpdater.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 4
1: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.checkNotifyWaiters:()V
2: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.notifyListeners:()V
3: iconst_1
ireturn
4: StackMap locals:
StackMap stack:
iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
0 5 1 mayInterruptIfRunning Z
MethodParameters:
Name Flags
mayInterruptIfRunning
public boolean isCancelled();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.netty.util.concurrent.DefaultPromise.result:Ljava/lang/Object;
invokestatic io.netty.util.concurrent.DefaultPromise.isCancelled0:(Ljava/lang/Object;)Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
public boolean isDone();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.netty.util.concurrent.DefaultPromise.result:Ljava/lang/Object;
invokestatic io.netty.util.concurrent.DefaultPromise.isDone0:(Ljava/lang/Object;)Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
public io.netty.util.concurrent.Promise<V> sync();
descriptor: ()Lio/netty/util/concurrent/Promise;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.await:()Lio/netty/util/concurrent/Promise;
pop
1: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.rethrowIfFailed:()V
2: aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
Exceptions:
throws java.lang.InterruptedException
Signature: ()Lio/netty/util/concurrent/Promise<TV;>;
public io.netty.util.concurrent.Promise<V> syncUninterruptibly();
descriptor: ()Lio/netty/util/concurrent/Promise;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.awaitUninterruptibly:()Lio/netty/util/concurrent/Promise;
pop
1: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.rethrowIfFailed:()V
2: aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
Signature: ()Lio/netty/util/concurrent/Promise<TV;>;
public java.lang.String toString();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.toStringBuilder:()Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
protected java.lang.StringBuilder toStringBuilder();
descriptor: ()Ljava/lang/StringBuilder;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=3, args_size=1
start local 0 0: new java.lang.StringBuilder
dup
bipush 64
invokespecial java.lang.StringBuilder.<init>:(I)V
1: aload 0
invokestatic io.netty.util.internal.StringUtil.simpleClassName:(Ljava/lang/Object;)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
2: bipush 64
invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
3: aload 0
invokevirtual java.lang.Object.hashCode:()I
invokestatic java.lang.Integer.toHexString:(I)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
4: astore 1
start local 1 5: aload 0
getfield io.netty.util.concurrent.DefaultPromise.result:Ljava/lang/Object;
astore 2
start local 2 6: aload 2
getstatic io.netty.util.concurrent.DefaultPromise.SUCCESS:Ljava/lang/Object;
if_acmpne 9
7: aload 1
ldc "(success)"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
pop
8: goto 23
StackMap locals: java.lang.StringBuilder java.lang.Object
StackMap stack:
9: aload 2
getstatic io.netty.util.concurrent.DefaultPromise.UNCANCELLABLE:Ljava/lang/Object;
if_acmpne 12
10: aload 1
ldc "(uncancellable)"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
pop
11: goto 23
StackMap locals:
StackMap stack:
12: aload 2
instanceof io.netty.util.concurrent.DefaultPromise$CauseHolder
ifeq 17
13: aload 1
ldc "(failure: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
14: aload 2
checkcast io.netty.util.concurrent.DefaultPromise$CauseHolder
getfield io.netty.util.concurrent.DefaultPromise$CauseHolder.cause:Ljava/lang/Throwable;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
15: bipush 41
invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
pop
16: goto 23
StackMap locals:
StackMap stack:
17: aload 2
ifnull 22
18: aload 1
ldc "(success: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
19: aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
20: bipush 41
invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
pop
21: goto 23
22: StackMap locals:
StackMap stack:
aload 1
ldc "(incomplete)"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
pop
23: StackMap locals:
StackMap stack:
aload 1
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 24 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
5 24 1 buf Ljava/lang/StringBuilder;
6 24 2 result Ljava/lang/Object;
protected io.netty.util.concurrent.EventExecutor executor();
descriptor: ()Lio/netty/util/concurrent/EventExecutor;
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.netty.util.concurrent.DefaultPromise.executor:Lio/netty/util/concurrent/EventExecutor;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
protected void checkDeadLock();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.executor:()Lio/netty/util/concurrent/EventExecutor;
astore 1
start local 1 1: aload 1
ifnull 3
aload 1
invokeinterface io.netty.util.concurrent.EventExecutor.inEventLoop:()Z
ifeq 3
2: new io.netty.util.concurrent.BlockingOperationException
dup
aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.toString:()Ljava/lang/String;
invokespecial io.netty.util.concurrent.BlockingOperationException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals: io.netty.util.concurrent.EventExecutor
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
1 4 1 e Lio/netty/util/concurrent/EventExecutor;
protected static void notifyListener(io.netty.util.concurrent.EventExecutor, io.netty.util.concurrent.Future<?>, io.netty.util.concurrent.GenericFutureListener<?>);
descriptor: (Lio/netty/util/concurrent/EventExecutor;Lio/netty/util/concurrent/Future;Lio/netty/util/concurrent/GenericFutureListener;)V
flags: (0x000c) ACC_PROTECTED, ACC_STATIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
ldc "eventExecutor"
invokestatic io.netty.util.internal.ObjectUtil.checkNotNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
ldc "future"
invokestatic io.netty.util.internal.ObjectUtil.checkNotNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 2
ldc "listener"
invokestatic io.netty.util.internal.ObjectUtil.checkNotNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 0
aload 1
aload 2
invokestatic io.netty.util.concurrent.DefaultPromise.notifyListenerWithStackOverFlowProtection:(Lio/netty/util/concurrent/EventExecutor;Lio/netty/util/concurrent/Future;Lio/netty/util/concurrent/GenericFutureListener;)V
4: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 eventExecutor Lio/netty/util/concurrent/EventExecutor;
0 5 1 future Lio/netty/util/concurrent/Future<*>;
0 5 2 listener Lio/netty/util/concurrent/GenericFutureListener<*>;
Signature: (Lio/netty/util/concurrent/EventExecutor;Lio/netty/util/concurrent/Future<*>;Lio/netty/util/concurrent/GenericFutureListener<*>;)V
MethodParameters:
Name Flags
eventExecutor
future final
listener final
private void notifyListeners();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=5, args_size=1
start local 0 0: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.executor:()Lio/netty/util/concurrent/EventExecutor;
astore 1
start local 1 1: aload 1
invokeinterface io.netty.util.concurrent.EventExecutor.inEventLoop:()Z
ifeq 13
2: invokestatic io.netty.util.internal.InternalThreadLocalMap.get:()Lio/netty/util/internal/InternalThreadLocalMap;
astore 2
start local 2 3: aload 2
invokevirtual io.netty.util.internal.InternalThreadLocalMap.futureListenerStackDepth:()I
istore 3
start local 3 4: iload 3
getstatic io.netty.util.concurrent.DefaultPromise.MAX_LISTENER_STACK_DEPTH:I
if_icmpge 13
5: aload 2
iload 3
iconst_1
iadd
invokevirtual io.netty.util.internal.InternalThreadLocalMap.setFutureListenerStackDepth:(I)V
6: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.notifyListenersNow:()V
7: goto 11
StackMap locals: io.netty.util.concurrent.DefaultPromise io.netty.util.concurrent.EventExecutor io.netty.util.internal.InternalThreadLocalMap int
StackMap stack: java.lang.Throwable
8: astore 4
9: aload 2
iload 3
invokevirtual io.netty.util.internal.InternalThreadLocalMap.setFutureListenerStackDepth:(I)V
10: aload 4
athrow
11: StackMap locals:
StackMap stack:
aload 2
iload 3
invokevirtual io.netty.util.internal.InternalThreadLocalMap.setFutureListenerStackDepth:(I)V
12: return
end local 3 end local 2 13: StackMap locals:
StackMap stack:
aload 1
new io.netty.util.concurrent.DefaultPromise$1
dup
aload 0
invokespecial io.netty.util.concurrent.DefaultPromise$1.<init>:(Lio/netty/util/concurrent/DefaultPromise;)V
invokestatic io.netty.util.concurrent.DefaultPromise.safeExecute:(Lio/netty/util/concurrent/EventExecutor;Ljava/lang/Runnable;)V
14: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
1 15 1 executor Lio/netty/util/concurrent/EventExecutor;
3 13 2 threadLocals Lio/netty/util/internal/InternalThreadLocalMap;
4 13 3 stackDepth I
Exception table:
from to target type
6 8 8 any
private static void notifyListenerWithStackOverFlowProtection(io.netty.util.concurrent.EventExecutor, io.netty.util.concurrent.Future<?>, io.netty.util.concurrent.GenericFutureListener<?>);
descriptor: (Lio/netty/util/concurrent/EventExecutor;Lio/netty/util/concurrent/Future;Lio/netty/util/concurrent/GenericFutureListener;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=6, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokeinterface io.netty.util.concurrent.EventExecutor.inEventLoop:()Z
ifeq 12
1: invokestatic io.netty.util.internal.InternalThreadLocalMap.get:()Lio/netty/util/internal/InternalThreadLocalMap;
astore 3
start local 3 2: aload 3
invokevirtual io.netty.util.internal.InternalThreadLocalMap.futureListenerStackDepth:()I
istore 4
start local 4 3: iload 4
getstatic io.netty.util.concurrent.DefaultPromise.MAX_LISTENER_STACK_DEPTH:I
if_icmpge 12
4: aload 3
iload 4
iconst_1
iadd
invokevirtual io.netty.util.internal.InternalThreadLocalMap.setFutureListenerStackDepth:(I)V
5: aload 1
aload 2
invokestatic io.netty.util.concurrent.DefaultPromise.notifyListener0:(Lio/netty/util/concurrent/Future;Lio/netty/util/concurrent/GenericFutureListener;)V
6: goto 10
StackMap locals: io.netty.util.concurrent.EventExecutor io.netty.util.concurrent.Future io.netty.util.concurrent.GenericFutureListener io.netty.util.internal.InternalThreadLocalMap int
StackMap stack: java.lang.Throwable
7: astore 5
8: aload 3
iload 4
invokevirtual io.netty.util.internal.InternalThreadLocalMap.setFutureListenerStackDepth:(I)V
9: aload 5
athrow
10: StackMap locals:
StackMap stack:
aload 3
iload 4
invokevirtual io.netty.util.internal.InternalThreadLocalMap.setFutureListenerStackDepth:(I)V
11: return
end local 4 end local 3 12: StackMap locals:
StackMap stack:
aload 0
new io.netty.util.concurrent.DefaultPromise$2
dup
aload 1
aload 2
invokespecial io.netty.util.concurrent.DefaultPromise$2.<init>:(Lio/netty/util/concurrent/Future;Lio/netty/util/concurrent/GenericFutureListener;)V
invokestatic io.netty.util.concurrent.DefaultPromise.safeExecute:(Lio/netty/util/concurrent/EventExecutor;Ljava/lang/Runnable;)V
13: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 executor Lio/netty/util/concurrent/EventExecutor;
0 14 1 future Lio/netty/util/concurrent/Future<*>;
0 14 2 listener Lio/netty/util/concurrent/GenericFutureListener<*>;
2 12 3 threadLocals Lio/netty/util/internal/InternalThreadLocalMap;
3 12 4 stackDepth I
Exception table:
from to target type
5 7 7 any
Signature: (Lio/netty/util/concurrent/EventExecutor;Lio/netty/util/concurrent/Future<*>;Lio/netty/util/concurrent/GenericFutureListener<*>;)V
MethodParameters:
Name Flags
executor final
future final
listener final
private void notifyListenersNow();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=1
start local 0 0: aload 0
dup
astore 2
monitorenter
1: aload 0
getfield io.netty.util.concurrent.DefaultPromise.notifyingListeners:Z
ifne 2
aload 0
getfield io.netty.util.concurrent.DefaultPromise.listeners:Ljava/lang/Object;
ifnonnull 4
2: StackMap locals: io.netty.util.concurrent.DefaultPromise top io.netty.util.concurrent.DefaultPromise
StackMap stack:
aload 2
monitorexit
3: return
4: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield io.netty.util.concurrent.DefaultPromise.notifyingListeners:Z
5: aload 0
getfield io.netty.util.concurrent.DefaultPromise.listeners:Ljava/lang/Object;
astore 1
start local 1 6: aload 0
aconst_null
putfield io.netty.util.concurrent.DefaultPromise.listeners:Ljava/lang/Object;
7: aload 2
monitorexit
8: goto 11
end local 1 StackMap locals:
StackMap stack: java.lang.Throwable
9: aload 2
monitorexit
10: athrow
start local 1 11: StackMap locals: io.netty.util.concurrent.DefaultPromise java.lang.Object
StackMap stack:
aload 1
instanceof io.netty.util.concurrent.DefaultFutureListeners
ifeq 14
12: aload 0
aload 1
checkcast io.netty.util.concurrent.DefaultFutureListeners
invokevirtual io.netty.util.concurrent.DefaultPromise.notifyListeners0:(Lio/netty/util/concurrent/DefaultFutureListeners;)V
13: goto 15
14: StackMap locals:
StackMap stack:
aload 0
aload 1
checkcast io.netty.util.concurrent.GenericFutureListener
invokestatic io.netty.util.concurrent.DefaultPromise.notifyListener0:(Lio/netty/util/concurrent/Future;Lio/netty/util/concurrent/GenericFutureListener;)V
15: StackMap locals:
StackMap stack:
aload 0
dup
astore 2
monitorenter
16: aload 0
getfield io.netty.util.concurrent.DefaultPromise.listeners:Ljava/lang/Object;
ifnonnull 20
17: aload 0
iconst_0
putfield io.netty.util.concurrent.DefaultPromise.notifyingListeners:Z
18: aload 2
monitorexit
19: return
20: StackMap locals: io.netty.util.concurrent.DefaultPromise
StackMap stack:
aload 0
getfield io.netty.util.concurrent.DefaultPromise.listeners:Ljava/lang/Object;
astore 1
21: aload 0
aconst_null
putfield io.netty.util.concurrent.DefaultPromise.listeners:Ljava/lang/Object;
22: aload 2
monitorexit
23: goto 11
StackMap locals:
StackMap stack: java.lang.Throwable
24: aload 2
monitorexit
25: athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 26 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
6 9 1 listeners Ljava/lang/Object;
11 26 1 listeners Ljava/lang/Object;
Exception table:
from to target type
1 3 9 any
4 8 9 any
9 10 9 any
16 19 24 any
20 23 24 any
24 25 24 any
private void notifyListeners0(io.netty.util.concurrent.DefaultFutureListeners);
descriptor: (Lio/netty/util/concurrent/DefaultFutureListeners;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual io.netty.util.concurrent.DefaultFutureListeners.listeners:()[Lio/netty/util/concurrent/GenericFutureListener;
astore 2
start local 2 1: aload 1
invokevirtual io.netty.util.concurrent.DefaultFutureListeners.size:()I
istore 3
start local 3 2: iconst_0
istore 4
start local 4 3: goto 6
4: StackMap locals: io.netty.util.concurrent.GenericFutureListener[] int int
StackMap stack:
aload 0
aload 2
iload 4
aaload
invokestatic io.netty.util.concurrent.DefaultPromise.notifyListener0:(Lio/netty/util/concurrent/Future;Lio/netty/util/concurrent/GenericFutureListener;)V
5: iinc 4 1
StackMap locals:
StackMap stack:
6: iload 4
iload 3
if_icmplt 4
end local 4 7: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
0 8 1 listeners Lio/netty/util/concurrent/DefaultFutureListeners;
1 8 2 a [Lio/netty/util/concurrent/GenericFutureListener;
2 8 3 size I
3 7 4 i I
MethodParameters:
Name Flags
listeners
private static void notifyListener0(io.netty.util.concurrent.Future, io.netty.util.concurrent.GenericFutureListener);
descriptor: (Lio/netty/util/concurrent/Future;Lio/netty/util/concurrent/GenericFutureListener;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 1
aload 0
invokeinterface io.netty.util.concurrent.GenericFutureListener.operationComplete:(Lio/netty/util/concurrent/Future;)V
1: goto 4
StackMap locals:
StackMap stack: java.lang.Throwable
2: astore 2
start local 2 3: getstatic io.netty.util.concurrent.DefaultPromise.logger:Lio/netty/util/internal/logging/InternalLogger;
new java.lang.StringBuilder
dup
ldc "An exception was thrown by "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokevirtual java.lang.Class.getName:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ".operationComplete()"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
aload 2
invokeinterface io.netty.util.internal.logging.InternalLogger.warn:(Ljava/lang/String;Ljava/lang/Throwable;)V
end local 2 4: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 future Lio/netty/util/concurrent/Future;
0 5 1 l Lio/netty/util/concurrent/GenericFutureListener;
3 4 2 t Ljava/lang/Throwable;
Exception table:
from to target type
0 1 2 Class java.lang.Throwable
MethodParameters:
Name Flags
future
l
private void addListener0(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>);
descriptor: (Lio/netty/util/concurrent/GenericFutureListener;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.netty.util.concurrent.DefaultPromise.listeners:Ljava/lang/Object;
ifnonnull 3
1: aload 0
aload 1
putfield io.netty.util.concurrent.DefaultPromise.listeners:Ljava/lang/Object;
2: goto 7
StackMap locals:
StackMap stack:
3: aload 0
getfield io.netty.util.concurrent.DefaultPromise.listeners:Ljava/lang/Object;
instanceof io.netty.util.concurrent.DefaultFutureListeners
ifeq 6
4: aload 0
getfield io.netty.util.concurrent.DefaultPromise.listeners:Ljava/lang/Object;
checkcast io.netty.util.concurrent.DefaultFutureListeners
aload 1
invokevirtual io.netty.util.concurrent.DefaultFutureListeners.add:(Lio/netty/util/concurrent/GenericFutureListener;)V
5: goto 7
6: StackMap locals:
StackMap stack:
aload 0
new io.netty.util.concurrent.DefaultFutureListeners
dup
aload 0
getfield io.netty.util.concurrent.DefaultPromise.listeners:Ljava/lang/Object;
checkcast io.netty.util.concurrent.GenericFutureListener
aload 1
invokespecial io.netty.util.concurrent.DefaultFutureListeners.<init>:(Lio/netty/util/concurrent/GenericFutureListener;Lio/netty/util/concurrent/GenericFutureListener;)V
putfield io.netty.util.concurrent.DefaultPromise.listeners:Ljava/lang/Object;
7: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
0 8 1 listener Lio/netty/util/concurrent/GenericFutureListener<+Lio/netty/util/concurrent/Future<-TV;>;>;
Signature: (Lio/netty/util/concurrent/GenericFutureListener<+Lio/netty/util/concurrent/Future<-TV;>;>;)V
MethodParameters:
Name Flags
listener
private void removeListener0(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>);
descriptor: (Lio/netty/util/concurrent/GenericFutureListener;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.netty.util.concurrent.DefaultPromise.listeners:Ljava/lang/Object;
instanceof io.netty.util.concurrent.DefaultFutureListeners
ifeq 3
1: aload 0
getfield io.netty.util.concurrent.DefaultPromise.listeners:Ljava/lang/Object;
checkcast io.netty.util.concurrent.DefaultFutureListeners
aload 1
invokevirtual io.netty.util.concurrent.DefaultFutureListeners.remove:(Lio/netty/util/concurrent/GenericFutureListener;)V
2: goto 5
StackMap locals:
StackMap stack:
3: aload 0
getfield io.netty.util.concurrent.DefaultPromise.listeners:Ljava/lang/Object;
aload 1
if_acmpne 5
4: aload 0
aconst_null
putfield io.netty.util.concurrent.DefaultPromise.listeners:Ljava/lang/Object;
5: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
0 6 1 listener Lio/netty/util/concurrent/GenericFutureListener<+Lio/netty/util/concurrent/Future<-TV;>;>;
Signature: (Lio/netty/util/concurrent/GenericFutureListener<+Lio/netty/util/concurrent/Future<-TV;>;>;)V
MethodParameters:
Name Flags
listener
private boolean setSuccess0();
descriptor: (Ljava/lang/Object;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
ifnonnull 1
getstatic io.netty.util.concurrent.DefaultPromise.SUCCESS:Ljava/lang/Object;
goto 2
StackMap locals:
StackMap stack: io.netty.util.concurrent.DefaultPromise
1: aload 1
StackMap locals: io.netty.util.concurrent.DefaultPromise java.lang.Object
StackMap stack: io.netty.util.concurrent.DefaultPromise java.lang.Object
2: invokevirtual io.netty.util.concurrent.DefaultPromise.setValue0:(Ljava/lang/Object;)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
0 3 1 result TV;
Signature: (TV;)Z
MethodParameters:
Name Flags
result
private boolean setFailure0(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
new io.netty.util.concurrent.DefaultPromise$CauseHolder
dup
aload 1
ldc "cause"
invokestatic io.netty.util.internal.ObjectUtil.checkNotNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast java.lang.Throwable
invokespecial io.netty.util.concurrent.DefaultPromise$CauseHolder.<init>:(Ljava/lang/Throwable;)V
invokevirtual io.netty.util.concurrent.DefaultPromise.setValue0:(Ljava/lang/Object;)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
0 1 1 cause Ljava/lang/Throwable;
MethodParameters:
Name Flags
cause
private boolean setValue0(java.lang.Object);
descriptor: (Ljava/lang/Object;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: getstatic io.netty.util.concurrent.DefaultPromise.RESULT_UPDATER:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
aload 0
aconst_null
aload 1
invokevirtual java.util.concurrent.atomic.AtomicReferenceFieldUpdater.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
ifne 2
1: getstatic io.netty.util.concurrent.DefaultPromise.RESULT_UPDATER:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
aload 0
getstatic io.netty.util.concurrent.DefaultPromise.UNCANCELLABLE:Ljava/lang/Object;
aload 1
invokevirtual java.util.concurrent.atomic.AtomicReferenceFieldUpdater.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 4
2: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.checkNotifyWaiters:()V
3: iconst_1
ireturn
4: StackMap locals:
StackMap stack:
iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
0 5 1 objResult Ljava/lang/Object;
MethodParameters:
Name Flags
objResult
private synchronized void checkNotifyWaiters();
descriptor: ()V
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.netty.util.concurrent.DefaultPromise.waiters:S
ifle 2
1: aload 0
invokevirtual java.lang.Object.notifyAll:()V
2: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
private void incWaiters();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=1, args_size=1
start local 0 0: aload 0
getfield io.netty.util.concurrent.DefaultPromise.waiters:S
sipush 32767
if_icmpne 2
1: new java.lang.IllegalStateException
dup
new java.lang.StringBuilder
dup
ldc "too many waiters: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 0
dup
getfield io.netty.util.concurrent.DefaultPromise.waiters:S
iconst_1
iadd
i2s
putfield io.netty.util.concurrent.DefaultPromise.waiters:S
3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
private void decWaiters();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
dup
getfield io.netty.util.concurrent.DefaultPromise.waiters:S
iconst_1
isub
i2s
putfield io.netty.util.concurrent.DefaultPromise.waiters:S
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
private void rethrowIfFailed();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=2, args_size=1
start local 0 0: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.cause:()Ljava/lang/Throwable;
astore 1
start local 1 1: aload 1
ifnonnull 3
2: return
3: StackMap locals: java.lang.Throwable
StackMap stack:
aload 1
invokestatic io.netty.util.internal.PlatformDependent.throwException:(Ljava/lang/Throwable;)V
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
1 5 1 cause Ljava/lang/Throwable;
private boolean await0(long, boolean);
descriptor: (JZ)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=7, locals=14, args_size=3
start local 0 start local 1 start local 3 0: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.isDone:()Z
ifeq 2
1: iconst_1
ireturn
2: StackMap locals:
StackMap stack:
lload 1
lconst_0
lcmp
ifgt 4
3: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.isDone:()Z
ireturn
4: StackMap locals:
StackMap stack:
iload 3
ifeq 6
invokestatic java.lang.Thread.interrupted:()Z
ifeq 6
5: new java.lang.InterruptedException
dup
aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.toString:()Ljava/lang/String;
invokespecial java.lang.InterruptedException.<init>:(Ljava/lang/String;)V
athrow
6: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.checkDeadLock:()V
7: invokestatic java.lang.System.nanoTime:()J
lstore 4
start local 4 8: lload 1
lstore 6
start local 6 9: iconst_0
istore 8
start local 8 10: StackMap locals: long long int
StackMap stack:
aload 0
dup
astore 9
monitorenter
11: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.isDone:()Z
ifeq 16
12: aload 9
monitorexit
13: iload 8
ifeq 15
14: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
15: StackMap locals: io.netty.util.concurrent.DefaultPromise
StackMap stack:
iconst_1
ireturn
16: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.incWaiters:()V
17: aload 0
lload 6
ldc 1000000
ldiv
lload 6
ldc 1000000
lrem
l2i
invokevirtual java.lang.Object.wait:(JI)V
18: goto 27
StackMap locals:
StackMap stack: java.lang.InterruptedException
19: astore 10
start local 10 20: iload 3
ifeq 22
21: aload 10
athrow
22: StackMap locals: java.lang.InterruptedException
StackMap stack:
iconst_1
istore 8
end local 10 23: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.decWaiters:()V
goto 28
24: StackMap locals: io.netty.util.concurrent.DefaultPromise long int long long int io.netty.util.concurrent.DefaultPromise
StackMap stack: java.lang.Throwable
astore 11
25: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.decWaiters:()V
26: aload 11
athrow
27: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.decWaiters:()V
28: StackMap locals:
StackMap stack:
aload 9
monitorexit
29: goto 32
StackMap locals:
StackMap stack: java.lang.Throwable
30: aload 9
monitorexit
31: athrow
32: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.isDone:()Z
ifeq 36
33: iload 8
ifeq 35
34: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
35: StackMap locals:
StackMap stack:
iconst_1
ireturn
36: StackMap locals:
StackMap stack:
lload 1
invokestatic java.lang.System.nanoTime:()J
lload 4
lsub
lsub
lstore 6
37: lload 6
lconst_0
lcmp
ifgt 10
38: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.isDone:()Z
istore 13
39: iload 8
ifeq 41
40: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
41: StackMap locals: io.netty.util.concurrent.DefaultPromise long int long long int top top top top int
StackMap stack:
iload 13
ireturn
42: StackMap locals: io.netty.util.concurrent.DefaultPromise long int long long int
StackMap stack: java.lang.Throwable
astore 12
43: iload 8
ifeq 45
44: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
45: StackMap locals: io.netty.util.concurrent.DefaultPromise long int long long int top top top java.lang.Throwable
StackMap stack:
aload 12
athrow
end local 8 end local 6 end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 46 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
0 46 1 timeoutNanos J
0 46 3 interruptable Z
8 46 4 startTime J
9 46 6 waitTime J
10 46 8 interrupted Z
20 23 10 e Ljava/lang/InterruptedException;
Exception table:
from to target type
17 18 19 Class java.lang.InterruptedException
17 23 24 any
11 13 30 any
16 29 30 any
30 31 30 any
10 13 42 any
16 33 42 any
36 39 42 any
Exceptions:
throws java.lang.InterruptedException
MethodParameters:
Name Flags
timeoutNanos
interruptable
void notifyProgressiveListeners(long, long);
descriptor: (JJ)V
flags: (0x0000)
Code:
stack=12, locals=9, args_size=3
start local 0 start local 1 start local 3 0: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.progressiveListeners:()Ljava/lang/Object;
astore 5
start local 5 1: aload 5
ifnonnull 3
2: return
3: StackMap locals: java.lang.Object
StackMap stack:
aload 0
checkcast io.netty.util.concurrent.ProgressiveFuture
astore 6
start local 6 4: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.executor:()Lio/netty/util/concurrent/EventExecutor;
astore 7
start local 7 5: aload 7
invokeinterface io.netty.util.concurrent.EventExecutor.inEventLoop:()Z
ifeq 13
6: aload 5
instanceof io.netty.util.concurrent.GenericProgressiveFutureListener[]
ifeq 10
7: aload 6
aload 5
checkcast io.netty.util.concurrent.GenericProgressiveFutureListener[]
lload 1
lload 3
8: invokestatic io.netty.util.concurrent.DefaultPromise.notifyProgressiveListeners0:(Lio/netty/util/concurrent/ProgressiveFuture;[Lio/netty/util/concurrent/GenericProgressiveFutureListener;JJ)V
9: goto 21
10: StackMap locals: io.netty.util.concurrent.ProgressiveFuture io.netty.util.concurrent.EventExecutor
StackMap stack:
aload 6
aload 5
checkcast io.netty.util.concurrent.GenericProgressiveFutureListener
lload 1
lload 3
11: invokestatic io.netty.util.concurrent.DefaultPromise.notifyProgressiveListener0:(Lio/netty/util/concurrent/ProgressiveFuture;Lio/netty/util/concurrent/GenericProgressiveFutureListener;JJ)V
12: goto 21
13: StackMap locals:
StackMap stack:
aload 5
instanceof io.netty.util.concurrent.GenericProgressiveFutureListener[]
ifeq 18
14: aload 5
checkcast io.netty.util.concurrent.GenericProgressiveFutureListener[]
15: astore 8
start local 8 16: aload 7
new io.netty.util.concurrent.DefaultPromise$3
dup
aload 0
aload 6
aload 8
lload 1
lload 3
invokespecial io.netty.util.concurrent.DefaultPromise$3.<init>:(Lio/netty/util/concurrent/DefaultPromise;Lio/netty/util/concurrent/ProgressiveFuture;[Lio/netty/util/concurrent/GenericProgressiveFutureListener;JJ)V
invokestatic io.netty.util.concurrent.DefaultPromise.safeExecute:(Lio/netty/util/concurrent/EventExecutor;Ljava/lang/Runnable;)V
end local 8 17: goto 21
18: StackMap locals:
StackMap stack:
aload 5
checkcast io.netty.util.concurrent.GenericProgressiveFutureListener
19: astore 8
start local 8 20: aload 7
new io.netty.util.concurrent.DefaultPromise$4
dup
aload 0
aload 6
aload 8
lload 1
lload 3
invokespecial io.netty.util.concurrent.DefaultPromise$4.<init>:(Lio/netty/util/concurrent/DefaultPromise;Lio/netty/util/concurrent/ProgressiveFuture;Lio/netty/util/concurrent/GenericProgressiveFutureListener;JJ)V
invokestatic io.netty.util.concurrent.DefaultPromise.safeExecute:(Lio/netty/util/concurrent/EventExecutor;Ljava/lang/Runnable;)V
end local 8 21: StackMap locals:
StackMap stack:
return
end local 7 end local 6 end local 5 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 22 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
0 22 1 progress J
0 22 3 total J
1 22 5 listeners Ljava/lang/Object;
4 22 6 self Lio/netty/util/concurrent/ProgressiveFuture<TV;>;
5 22 7 executor Lio/netty/util/concurrent/EventExecutor;
16 17 8 array [Lio/netty/util/concurrent/GenericProgressiveFutureListener;
20 21 8 l Lio/netty/util/concurrent/GenericProgressiveFutureListener<Lio/netty/util/concurrent/ProgressiveFuture<TV;>;>;
MethodParameters:
Name Flags
progress final
total final
private synchronized java.lang.Object progressiveListeners();
descriptor: ()Ljava/lang/Object;
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=3, locals=9, args_size=1
start local 0 0: aload 0
getfield io.netty.util.concurrent.DefaultPromise.listeners:Ljava/lang/Object;
astore 1
start local 1 1: aload 1
ifnonnull 3
2: aconst_null
areturn
3: StackMap locals: java.lang.Object
StackMap stack:
aload 1
instanceof io.netty.util.concurrent.DefaultFutureListeners
ifeq 26
4: aload 1
checkcast io.netty.util.concurrent.DefaultFutureListeners
astore 2
start local 2 5: aload 2
invokevirtual io.netty.util.concurrent.DefaultFutureListeners.progressiveSize:()I
istore 3
start local 3 6: iload 3
tableswitch { // 0 - 1
0: 7
1: 8
default: 15
}
7: StackMap locals: io.netty.util.concurrent.DefaultFutureListeners int
StackMap stack:
aconst_null
areturn
8: StackMap locals:
StackMap stack:
aload 2
invokevirtual io.netty.util.concurrent.DefaultFutureListeners.listeners:()[Lio/netty/util/concurrent/GenericFutureListener;
dup
astore 7
arraylength
istore 6
iconst_0
istore 5
goto 13
StackMap locals: io.netty.util.concurrent.DefaultPromise java.lang.Object io.netty.util.concurrent.DefaultFutureListeners int top int int io.netty.util.concurrent.GenericFutureListener[]
StackMap stack:
9: aload 7
iload 5
aaload
astore 4
start local 4 10: aload 4
instanceof io.netty.util.concurrent.GenericProgressiveFutureListener
ifeq 12
11: aload 4
areturn
end local 4 12: StackMap locals:
StackMap stack:
iinc 5 1
StackMap locals:
StackMap stack:
13: iload 5
iload 6
if_icmplt 9
14: aconst_null
areturn
15: StackMap locals: io.netty.util.concurrent.DefaultPromise java.lang.Object io.netty.util.concurrent.DefaultFutureListeners int
StackMap stack:
aload 2
invokevirtual io.netty.util.concurrent.DefaultFutureListeners.listeners:()[Lio/netty/util/concurrent/GenericFutureListener;
astore 4
start local 4 16: iload 3
anewarray io.netty.util.concurrent.GenericProgressiveFutureListener
astore 5
start local 5 17: iconst_0
istore 6
start local 6 18: iconst_0
istore 7
start local 7 19: goto 24
20: StackMap locals: io.netty.util.concurrent.DefaultPromise java.lang.Object io.netty.util.concurrent.DefaultFutureListeners int io.netty.util.concurrent.GenericFutureListener[] io.netty.util.concurrent.GenericProgressiveFutureListener[] int int
StackMap stack:
aload 4
iload 6
aaload
astore 8
start local 8 21: aload 8
instanceof io.netty.util.concurrent.GenericProgressiveFutureListener
ifeq 23
22: aload 5
iload 7
iinc 7 1
aload 8
checkcast io.netty.util.concurrent.GenericProgressiveFutureListener
aastore
end local 8 23: StackMap locals:
StackMap stack:
iinc 6 1
StackMap locals:
StackMap stack:
24: iload 7
iload 3
if_icmplt 20
end local 7 end local 6 25: aload 5
areturn
end local 5 end local 4 end local 3 end local 2 26: StackMap locals: io.netty.util.concurrent.DefaultPromise java.lang.Object
StackMap stack:
aload 1
instanceof io.netty.util.concurrent.GenericProgressiveFutureListener
ifeq 28
27: aload 1
areturn
28: StackMap locals:
StackMap stack:
aconst_null
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 29 0 this Lio/netty/util/concurrent/DefaultPromise<TV;>;
1 29 1 listeners Ljava/lang/Object;
5 26 2 dfl Lio/netty/util/concurrent/DefaultFutureListeners;
6 26 3 progressiveSize I
10 12 4 l Lio/netty/util/concurrent/GenericFutureListener<*>;
16 26 4 array [Lio/netty/util/concurrent/GenericFutureListener;
17 26 5 copy [Lio/netty/util/concurrent/GenericProgressiveFutureListener;
18 25 6 i I
19 25 7 j I
21 23 8 l Lio/netty/util/concurrent/GenericFutureListener<*>;
private static void notifyProgressiveListeners0(io.netty.util.concurrent.ProgressiveFuture<?>, io.netty.util.concurrent.GenericProgressiveFutureListener<?>[], long, );
descriptor: (Lio/netty/util/concurrent/ProgressiveFuture;[Lio/netty/util/concurrent/GenericProgressiveFutureListener;JJ)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=6, locals=10, args_size=4
start local 0 start local 1 start local 2 start local 4 0: aload 1
dup
astore 9
arraylength
istore 8
iconst_0
istore 7
goto 6
StackMap locals: io.netty.util.concurrent.ProgressiveFuture io.netty.util.concurrent.GenericProgressiveFutureListener[] long long top int int io.netty.util.concurrent.GenericProgressiveFutureListener[]
StackMap stack:
1: aload 9
iload 7
aaload
astore 6
start local 6 2: aload 6
ifnonnull 4
3: goto 7
4: StackMap locals: io.netty.util.concurrent.ProgressiveFuture io.netty.util.concurrent.GenericProgressiveFutureListener[] long long io.netty.util.concurrent.GenericProgressiveFutureListener int int io.netty.util.concurrent.GenericProgressiveFutureListener[]
StackMap stack:
aload 0
aload 6
lload 2
lload 4
invokestatic io.netty.util.concurrent.DefaultPromise.notifyProgressiveListener0:(Lio/netty/util/concurrent/ProgressiveFuture;Lio/netty/util/concurrent/GenericProgressiveFutureListener;JJ)V
end local 6 5: iinc 7 1
StackMap locals: io.netty.util.concurrent.ProgressiveFuture io.netty.util.concurrent.GenericProgressiveFutureListener[] long long top int int io.netty.util.concurrent.GenericProgressiveFutureListener[]
StackMap stack:
6: iload 7
iload 8
if_icmplt 1
7: StackMap locals: io.netty.util.concurrent.ProgressiveFuture io.netty.util.concurrent.GenericProgressiveFutureListener[] long long
StackMap stack:
return
end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 future Lio/netty/util/concurrent/ProgressiveFuture<*>;
0 8 1 listeners [Lio/netty/util/concurrent/GenericProgressiveFutureListener;
0 8 2 progress J
0 8 4 total J
2 5 6 l Lio/netty/util/concurrent/GenericProgressiveFutureListener<*>;
Signature: (Lio/netty/util/concurrent/ProgressiveFuture<*>;[Lio/netty/util/concurrent/GenericProgressiveFutureListener<*>;JJ)V
MethodParameters:
Name Flags
future
listeners
progress
total
private static void notifyProgressiveListener0(io.netty.util.concurrent.ProgressiveFuture, io.netty.util.concurrent.GenericProgressiveFutureListener, long, long);
descriptor: (Lio/netty/util/concurrent/ProgressiveFuture;Lio/netty/util/concurrent/GenericProgressiveFutureListener;JJ)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=6, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 4 0: aload 1
aload 0
lload 2
lload 4
invokeinterface io.netty.util.concurrent.GenericProgressiveFutureListener.operationProgressed:(Lio/netty/util/concurrent/ProgressiveFuture;JJ)V
1: goto 4
StackMap locals:
StackMap stack: java.lang.Throwable
2: astore 6
start local 6 3: getstatic io.netty.util.concurrent.DefaultPromise.logger:Lio/netty/util/internal/logging/InternalLogger;
new java.lang.StringBuilder
dup
ldc "An exception was thrown by "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokevirtual java.lang.Class.getName:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ".operationProgressed()"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
aload 6
invokeinterface io.netty.util.internal.logging.InternalLogger.warn:(Ljava/lang/String;Ljava/lang/Throwable;)V
end local 6 4: StackMap locals:
StackMap stack:
return
end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 future Lio/netty/util/concurrent/ProgressiveFuture;
0 5 1 l Lio/netty/util/concurrent/GenericProgressiveFutureListener;
0 5 2 progress J
0 5 4 total J
3 4 6 t Ljava/lang/Throwable;
Exception table:
from to target type
0 1 2 Class java.lang.Throwable
MethodParameters:
Name Flags
future
l
progress
total
private static boolean isCancelled0(java.lang.Object);
descriptor: (Ljava/lang/Object;)Z
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
instanceof io.netty.util.concurrent.DefaultPromise$CauseHolder
ifeq 1
aload 0
checkcast io.netty.util.concurrent.DefaultPromise$CauseHolder
getfield io.netty.util.concurrent.DefaultPromise$CauseHolder.cause:Ljava/lang/Throwable;
instanceof java.util.concurrent.CancellationException
ifeq 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 result Ljava/lang/Object;
MethodParameters:
Name Flags
result
private static boolean isDone0(java.lang.Object);
descriptor: (Ljava/lang/Object;)Z
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
ifnull 1
aload 0
getstatic io.netty.util.concurrent.DefaultPromise.UNCANCELLABLE:Ljava/lang/Object;
if_acmpeq 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 result Ljava/lang/Object;
MethodParameters:
Name Flags
result
private static void safeExecute(io.netty.util.concurrent.EventExecutor, java.lang.Runnable);
descriptor: (Lio/netty/util/concurrent/EventExecutor;Ljava/lang/Runnable;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokeinterface io.netty.util.concurrent.EventExecutor.execute:(Ljava/lang/Runnable;)V
1: goto 4
StackMap locals:
StackMap stack: java.lang.Throwable
2: astore 2
start local 2 3: getstatic io.netty.util.concurrent.DefaultPromise.rejectedExecutionLogger:Lio/netty/util/internal/logging/InternalLogger;
ldc "Failed to submit a listener notification task. Event loop shut down?"
aload 2
invokeinterface io.netty.util.internal.logging.InternalLogger.error:(Ljava/lang/String;Ljava/lang/Throwable;)V
end local 2 4: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 executor Lio/netty/util/concurrent/EventExecutor;
0 5 1 task Ljava/lang/Runnable;
3 4 2 t Ljava/lang/Throwable;
Exception table:
from to target type
0 1 2 Class java.lang.Throwable
MethodParameters:
Name Flags
executor
task
public io.netty.util.concurrent.Future addListeners(io.netty.util.concurrent.GenericFutureListener[]);
descriptor: ([Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/util/concurrent/Future;
flags: (0x10c1) ACC_PUBLIC, ACC_BRIDGE, ACC_VARARGS, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
checkcast io.netty.util.concurrent.GenericFutureListener[]
invokevirtual io.netty.util.concurrent.DefaultPromise.addListeners:([Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/util/concurrent/Promise;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.netty.util.concurrent.Future syncUninterruptibly();
descriptor: ()Lio/netty/util/concurrent/Future;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.syncUninterruptibly:()Lio/netty/util/concurrent/Promise;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.netty.util.concurrent.Future sync();
descriptor: ()Lio/netty/util/concurrent/Future;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.sync:()Lio/netty/util/concurrent/Promise;
areturn
LocalVariableTable:
Start End Slot Name Signature
Exceptions:
throws java.lang.InterruptedException
public io.netty.util.concurrent.Future removeListener(io.netty.util.concurrent.GenericFutureListener);
descriptor: (Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/util/concurrent/Future;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
checkcast io.netty.util.concurrent.GenericFutureListener
invokevirtual io.netty.util.concurrent.DefaultPromise.removeListener:(Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/util/concurrent/Promise;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.netty.util.concurrent.Future awaitUninterruptibly();
descriptor: ()Lio/netty/util/concurrent/Future;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.awaitUninterruptibly:()Lio/netty/util/concurrent/Promise;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.netty.util.concurrent.Future addListener(io.netty.util.concurrent.GenericFutureListener);
descriptor: (Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/util/concurrent/Future;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
checkcast io.netty.util.concurrent.GenericFutureListener
invokevirtual io.netty.util.concurrent.DefaultPromise.addListener:(Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/util/concurrent/Promise;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.netty.util.concurrent.Future await();
descriptor: ()Lio/netty/util/concurrent/Future;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.netty.util.concurrent.DefaultPromise.await:()Lio/netty/util/concurrent/Promise;
areturn
LocalVariableTable:
Start End Slot Name Signature
Exceptions:
throws java.lang.InterruptedException
public io.netty.util.concurrent.Future removeListeners(io.netty.util.concurrent.GenericFutureListener[]);
descriptor: ([Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/util/concurrent/Future;
flags: (0x10c1) ACC_PUBLIC, ACC_BRIDGE, ACC_VARARGS, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
checkcast io.netty.util.concurrent.GenericFutureListener[]
invokevirtual io.netty.util.concurrent.DefaultPromise.removeListeners:([Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/util/concurrent/Promise;
areturn
LocalVariableTable:
Start End Slot Name Signature
}
Signature: <V:Ljava/lang/Object;>Lio/netty/util/concurrent/AbstractFuture<TV;>;Lio/netty/util/concurrent/Promise<TV;>;
SourceFile: "DefaultPromise.java"
NestMembers:
io.netty.util.concurrent.DefaultPromise$1 io.netty.util.concurrent.DefaultPromise$2 io.netty.util.concurrent.DefaultPromise$3 io.netty.util.concurrent.DefaultPromise$4 io.netty.util.concurrent.DefaultPromise$CauseHolder
InnerClasses:
io.netty.util.concurrent.DefaultPromise$1
io.netty.util.concurrent.DefaultPromise$2
io.netty.util.concurrent.DefaultPromise$3
io.netty.util.concurrent.DefaultPromise$4
private final CauseHolder = io.netty.util.concurrent.DefaultPromise$CauseHolder of io.netty.util.concurrent.DefaultPromise