abstract class com.mongodb.internal.connection.CommandResultBaseCallback<T> extends com.mongodb.internal.connection.ResponseCallback
minor version: 0
major version: 59
flags: flags: (0x0420) ACC_SUPER, ACC_ABSTRACT
this_class: com.mongodb.internal.connection.CommandResultBaseCallback
super_class: com.mongodb.internal.connection.ResponseCallback
{
public static final com.mongodb.diagnostics.logging.Logger LOGGER;
descriptor: Lcom/mongodb/diagnostics/logging/Logger;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
private final org.bson.codecs.Decoder<T> decoder;
descriptor: Lorg/bson/codecs/Decoder;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lorg/bson/codecs/Decoder<TT;>;
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc "protocol.command"
invokestatic com.mongodb.diagnostics.logging.Loggers.getLogger:(Ljava/lang/String;)Lcom/mongodb/diagnostics/logging/Logger;
putstatic com.mongodb.internal.connection.CommandResultBaseCallback.LOGGER:Lcom/mongodb/diagnostics/logging/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
void <init>(org.bson.codecs.Decoder<T>, long, com.mongodb.ServerAddress);
descriptor: (Lorg/bson/codecs/Decoder;JLcom/mongodb/ServerAddress;)V
flags: (0x0000)
Code:
stack=4, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 4 0: aload 0
lload 2
aload 4
invokespecial com.mongodb.internal.connection.ResponseCallback.<init>:(JLcom/mongodb/ServerAddress;)V
1: aload 0
aload 1
putfield com.mongodb.internal.connection.CommandResultBaseCallback.decoder:Lorg/bson/codecs/Decoder;
2: return
end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/mongodb/internal/connection/CommandResultBaseCallback<TT;>;
0 3 1 decoder Lorg/bson/codecs/Decoder<TT;>;
0 3 2 requestId J
0 3 4 serverAddress Lcom/mongodb/ServerAddress;
Signature: (Lorg/bson/codecs/Decoder<TT;>;JLcom/mongodb/ServerAddress;)V
MethodParameters:
Name Flags
decoder final
requestId final
serverAddress final
protected void callCallback(com.mongodb.internal.connection.ResponseBuffers, java.lang.Throwable);
descriptor: (Lcom/mongodb/internal/connection/ResponseBuffers;Ljava/lang/Throwable;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=6, locals=6, args_size=3
start local 0 start local 1 start local 2 0: aload 2
ifnonnull 1
aload 1
ifnonnull 3
1: StackMap locals:
StackMap stack:
aload 0
aconst_null
aload 2
invokevirtual com.mongodb.internal.connection.CommandResultBaseCallback.callCallback:(Ljava/lang/Object;Ljava/lang/Throwable;)V
2: goto 13
3: StackMap locals:
StackMap stack:
new com.mongodb.internal.connection.ReplyMessage
dup
aload 1
aload 0
getfield com.mongodb.internal.connection.CommandResultBaseCallback.decoder:Lorg/bson/codecs/Decoder;
aload 0
invokevirtual com.mongodb.internal.connection.CommandResultBaseCallback.getRequestId:()J
invokespecial com.mongodb.internal.connection.ReplyMessage.<init>:(Lcom/mongodb/internal/connection/ResponseBuffers;Lorg/bson/codecs/Decoder;J)V
astore 3
start local 3 4: aload 0
aload 3
invokevirtual com.mongodb.internal.connection.ReplyMessage.getDocuments:()Ljava/util/List;
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
aconst_null
invokevirtual com.mongodb.internal.connection.CommandResultBaseCallback.callCallback:(Ljava/lang/Object;Ljava/lang/Throwable;)V
end local 3 5: goto 13
StackMap locals:
StackMap stack: java.lang.Throwable
6: astore 4
7: aload 1
ifnull 12
8: aload 1
invokevirtual com.mongodb.internal.connection.ResponseBuffers.close:()V
9: goto 12
StackMap locals: com.mongodb.internal.connection.CommandResultBaseCallback com.mongodb.internal.connection.ResponseBuffers java.lang.Throwable top java.lang.Throwable
StackMap stack: java.lang.Throwable
10: astore 5
start local 5 11: getstatic com.mongodb.internal.connection.CommandResultBaseCallback.LOGGER:Lcom/mongodb/diagnostics/logging/Logger;
ldc "GetMore ResponseBuffer close exception"
aload 5
invokeinterface com.mongodb.diagnostics.logging.Logger.debug:(Ljava/lang/String;Ljava/lang/Throwable;)V
end local 5 12: StackMap locals:
StackMap stack:
aload 4
athrow
13: StackMap locals: com.mongodb.internal.connection.CommandResultBaseCallback com.mongodb.internal.connection.ResponseBuffers java.lang.Throwable
StackMap stack:
aload 1
ifnull 18
14: aload 1
invokevirtual com.mongodb.internal.connection.ResponseBuffers.close:()V
15: goto 18
StackMap locals:
StackMap stack: java.lang.Throwable
16: astore 5
start local 5 17: getstatic com.mongodb.internal.connection.CommandResultBaseCallback.LOGGER:Lcom/mongodb/diagnostics/logging/Logger;
ldc "GetMore ResponseBuffer close exception"
aload 5
invokeinterface com.mongodb.diagnostics.logging.Logger.debug:(Ljava/lang/String;Ljava/lang/Throwable;)V
end local 5 18: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lcom/mongodb/internal/connection/CommandResultBaseCallback<TT;>;
0 19 1 responseBuffers Lcom/mongodb/internal/connection/ResponseBuffers;
0 19 2 t Ljava/lang/Throwable;
4 5 3 replyMessage Lcom/mongodb/internal/connection/ReplyMessage<TT;>;
11 12 5 t1 Ljava/lang/Throwable;
17 18 5 t1 Ljava/lang/Throwable;
Exception table:
from to target type
0 6 6 any
7 9 10 Class java.lang.Throwable
13 15 16 Class java.lang.Throwable
MethodParameters:
Name Flags
responseBuffers final
t final
protected abstract void callCallback(T, java.lang.Throwable);
descriptor: (Ljava/lang/Object;Ljava/lang/Throwable;)V
flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
Signature: (TT;Ljava/lang/Throwable;)V
MethodParameters:
Name Flags
response
t
}
Signature: <T:Ljava/lang/Object;>Lcom/mongodb/internal/connection/ResponseCallback;
SourceFile: "CommandResultBaseCallback.java"