public final class com.mongodb.internal.connection.CommandHelper
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: com.mongodb.internal.connection.CommandHelper
super_class: java.lang.Object
{
static org.bson.BsonDocument executeCommand(java.lang.String, org.bson.BsonDocument, com.mongodb.internal.connection.InternalConnection);
descriptor: (Ljava/lang/String;Lorg/bson/BsonDocument;Lcom/mongodb/internal/connection/InternalConnection;)Lorg/bson/BsonDocument;
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aconst_null
aload 2
invokestatic com.mongodb.internal.connection.CommandHelper.sendAndReceive:(Ljava/lang/String;Lorg/bson/BsonDocument;Lcom/mongodb/internal/connection/ClusterClock;Lcom/mongodb/internal/connection/InternalConnection;)Lorg/bson/BsonDocument;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 database Ljava/lang/String;
0 1 1 command Lorg/bson/BsonDocument;
0 1 2 internalConnection Lcom/mongodb/internal/connection/InternalConnection;
MethodParameters:
Name Flags
database final
command final
internalConnection final
public static org.bson.BsonDocument executeCommand(java.lang.String, org.bson.BsonDocument, com.mongodb.internal.connection.ClusterClock, com.mongodb.internal.connection.InternalConnection);
descriptor: (Ljava/lang/String;Lorg/bson/BsonDocument;Lcom/mongodb/internal/connection/ClusterClock;Lcom/mongodb/internal/connection/InternalConnection;)Lorg/bson/BsonDocument;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
aload 3
invokestatic com.mongodb.internal.connection.CommandHelper.sendAndReceive:(Ljava/lang/String;Lorg/bson/BsonDocument;Lcom/mongodb/internal/connection/ClusterClock;Lcom/mongodb/internal/connection/InternalConnection;)Lorg/bson/BsonDocument;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 database Ljava/lang/String;
0 1 1 command Lorg/bson/BsonDocument;
0 1 2 clusterClock Lcom/mongodb/internal/connection/ClusterClock;
0 1 3 internalConnection Lcom/mongodb/internal/connection/InternalConnection;
MethodParameters:
Name Flags
database final
command final
clusterClock final
internalConnection final
static org.bson.BsonDocument executeCommandWithoutCheckingForFailure(java.lang.String, org.bson.BsonDocument, com.mongodb.internal.connection.InternalConnection);
descriptor: (Ljava/lang/String;Lorg/bson/BsonDocument;Lcom/mongodb/internal/connection/InternalConnection;)Lorg/bson/BsonDocument;
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aconst_null
aload 2
invokestatic com.mongodb.internal.connection.CommandHelper.sendAndReceive:(Ljava/lang/String;Lorg/bson/BsonDocument;Lcom/mongodb/internal/connection/ClusterClock;Lcom/mongodb/internal/connection/InternalConnection;)Lorg/bson/BsonDocument;
1: areturn
2: StackMap locals:
StackMap stack: com.mongodb.MongoServerException
pop
3: new org.bson.BsonDocument
dup
invokespecial org.bson.BsonDocument.<init>:()V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 database Ljava/lang/String;
0 4 1 command Lorg/bson/BsonDocument;
0 4 2 internalConnection Lcom/mongodb/internal/connection/InternalConnection;
Exception table:
from to target type
0 1 2 Class com.mongodb.MongoServerException
MethodParameters:
Name Flags
database final
command final
internalConnection final
static void executeCommandAsync(java.lang.String, org.bson.BsonDocument, com.mongodb.internal.connection.InternalConnection, com.mongodb.async.SingleResultCallback<org.bson.BsonDocument>);
descriptor: (Ljava/lang/String;Lorg/bson/BsonDocument;Lcom/mongodb/internal/connection/InternalConnection;Lcom/mongodb/async/SingleResultCallback;)V
flags: (0x0008) ACC_STATIC
Code:
stack=7, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 2
aload 0
aload 1
aload 2
invokestatic com.mongodb.internal.connection.CommandHelper.getCommandMessage:(Ljava/lang/String;Lorg/bson/BsonDocument;Lcom/mongodb/internal/connection/InternalConnection;)Lcom/mongodb/internal/connection/CommandMessage;
new org.bson.codecs.BsonDocumentCodec
dup
invokespecial org.bson.codecs.BsonDocumentCodec.<init>:()V
1: getstatic com.mongodb.internal.connection.NoOpSessionContext.INSTANCE:Lcom/mongodb/internal/connection/NoOpSessionContext;
new com.mongodb.internal.connection.CommandHelper$1
dup
aload 3
invokespecial com.mongodb.internal.connection.CommandHelper$1.<init>:(Lcom/mongodb/async/SingleResultCallback;)V
2: invokeinterface com.mongodb.internal.connection.InternalConnection.sendAndReceiveAsync:(Lcom/mongodb/internal/connection/CommandMessage;Lorg/bson/codecs/Decoder;Lcom/mongodb/session/SessionContext;Lcom/mongodb/async/SingleResultCallback;)V
3: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 database Ljava/lang/String;
0 4 1 command Lorg/bson/BsonDocument;
0 4 2 internalConnection Lcom/mongodb/internal/connection/InternalConnection;
0 4 3 callback Lcom/mongodb/async/SingleResultCallback<Lorg/bson/BsonDocument;>;
Signature: (Ljava/lang/String;Lorg/bson/BsonDocument;Lcom/mongodb/internal/connection/InternalConnection;Lcom/mongodb/async/SingleResultCallback<Lorg/bson/BsonDocument;>;)V
MethodParameters:
Name Flags
database final
command final
internalConnection final
callback final
static boolean isCommandOk(org.bson.BsonDocument);
descriptor: (Lorg/bson/BsonDocument;)Z
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
ldc "ok"
invokevirtual org.bson.BsonDocument.containsKey:(Ljava/lang/Object;)Z
ifne 2
1: iconst_0
ireturn
2: StackMap locals:
StackMap stack:
aload 0
ldc "ok"
invokevirtual org.bson.BsonDocument.get:(Ljava/lang/Object;)Lorg/bson/BsonValue;
astore 1
start local 1 3: aload 1
invokevirtual org.bson.BsonValue.isBoolean:()Z
ifeq 5
4: aload 1
invokevirtual org.bson.BsonValue.asBoolean:()Lorg/bson/BsonBoolean;
invokevirtual org.bson.BsonBoolean.getValue:()Z
ireturn
5: StackMap locals: org.bson.BsonValue
StackMap stack:
aload 1
invokevirtual org.bson.BsonValue.isNumber:()Z
ifeq 8
6: aload 1
invokevirtual org.bson.BsonValue.asNumber:()Lorg/bson/BsonNumber;
invokevirtual org.bson.BsonNumber.intValue:()I
iconst_1
if_icmpne 7
iconst_1
ireturn
StackMap locals:
StackMap stack:
7: iconst_0
ireturn
8: StackMap locals:
StackMap stack:
iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 response Lorg/bson/BsonDocument;
3 9 1 okValue Lorg/bson/BsonValue;
MethodParameters:
Name Flags
response final
private static org.bson.BsonDocument sendAndReceive(java.lang.String, org.bson.BsonDocument, com.mongodb.internal.connection.ClusterClock, com.mongodb.internal.connection.InternalConnection);
descriptor: (Ljava/lang/String;Lorg/bson/BsonDocument;Lcom/mongodb/internal/connection/ClusterClock;Lcom/mongodb/internal/connection/InternalConnection;)Lorg/bson/BsonDocument;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=4, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 2
ifnonnull 1
getstatic com.mongodb.internal.connection.NoOpSessionContext.INSTANCE:Lcom/mongodb/internal/connection/NoOpSessionContext;
goto 2
1: StackMap locals:
StackMap stack:
new com.mongodb.internal.connection.ClusterClockAdvancingSessionContext
dup
getstatic com.mongodb.internal.connection.NoOpSessionContext.INSTANCE:Lcom/mongodb/internal/connection/NoOpSessionContext;
aload 2
invokespecial com.mongodb.internal.connection.ClusterClockAdvancingSessionContext.<init>:(Lcom/mongodb/session/SessionContext;Lcom/mongodb/internal/connection/ClusterClock;)V
2: StackMap locals:
StackMap stack: com.mongodb.session.SessionContext
astore 4
start local 4 3: aload 3
aload 0
aload 1
aload 3
invokestatic com.mongodb.internal.connection.CommandHelper.getCommandMessage:(Ljava/lang/String;Lorg/bson/BsonDocument;Lcom/mongodb/internal/connection/InternalConnection;)Lcom/mongodb/internal/connection/CommandMessage;
new org.bson.codecs.BsonDocumentCodec
dup
invokespecial org.bson.codecs.BsonDocumentCodec.<init>:()V
4: aload 4
5: invokeinterface com.mongodb.internal.connection.InternalConnection.sendAndReceive:(Lcom/mongodb/internal/connection/CommandMessage;Lorg/bson/codecs/Decoder;Lcom/mongodb/session/SessionContext;)Ljava/lang/Object;
checkcast org.bson.BsonDocument
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 database Ljava/lang/String;
0 6 1 command Lorg/bson/BsonDocument;
0 6 2 clusterClock Lcom/mongodb/internal/connection/ClusterClock;
0 6 3 internalConnection Lcom/mongodb/internal/connection/InternalConnection;
3 6 4 sessionContext Lcom/mongodb/session/SessionContext;
MethodParameters:
Name Flags
database final
command final
clusterClock final
internalConnection final
private static com.mongodb.internal.connection.CommandMessage getCommandMessage(java.lang.String, org.bson.BsonDocument, com.mongodb.internal.connection.InternalConnection);
descriptor: (Ljava/lang/String;Lorg/bson/BsonDocument;Lcom/mongodb/internal/connection/InternalConnection;)Lcom/mongodb/internal/connection/CommandMessage;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=8, locals=3, args_size=3
start local 0 start local 1 start local 2 0: new com.mongodb.internal.connection.CommandMessage
dup
new com.mongodb.MongoNamespace
dup
aload 0
ldc "$cmd"
invokespecial com.mongodb.MongoNamespace.<init>:(Ljava/lang/String;Ljava/lang/String;)V
aload 1
new com.mongodb.internal.validator.NoOpFieldNameValidator
dup
invokespecial com.mongodb.internal.validator.NoOpFieldNameValidator.<init>:()V
invokestatic com.mongodb.ReadPreference.primary:()Lcom/mongodb/ReadPreference;
1: invokestatic com.mongodb.internal.connection.MessageSettings.builder:()Lcom/mongodb/internal/connection/MessageSettings$Builder;
2: aload 2
invokeinterface com.mongodb.internal.connection.InternalConnection.getDescription:()Lcom/mongodb/connection/ConnectionDescription;
invokevirtual com.mongodb.connection.ConnectionDescription.getMaxWireVersion:()I
invokevirtual com.mongodb.internal.connection.MessageSettings$Builder.maxWireVersion:(I)Lcom/mongodb/internal/connection/MessageSettings$Builder;
3: invokevirtual com.mongodb.internal.connection.MessageSettings$Builder.build:()Lcom/mongodb/internal/connection/MessageSettings;
4: invokespecial com.mongodb.internal.connection.CommandMessage.<init>:(Lcom/mongodb/MongoNamespace;Lorg/bson/BsonDocument;Lorg/bson/FieldNameValidator;Lcom/mongodb/ReadPreference;Lcom/mongodb/internal/connection/MessageSettings;)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 database Ljava/lang/String;
0 5 1 command Lorg/bson/BsonDocument;
0 5 2 internalConnection Lcom/mongodb/internal/connection/InternalConnection;
MethodParameters:
Name Flags
database final
command final
internalConnection final
private void <init>();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/mongodb/internal/connection/CommandHelper;
}
SourceFile: "CommandHelper.java"
NestMembers:
com.mongodb.internal.connection.CommandHelper$1
InnerClasses:
com.mongodb.internal.connection.CommandHelper$1
public final Builder = com.mongodb.internal.connection.MessageSettings$Builder of com.mongodb.internal.connection.MessageSettings