class com.mongodb.client.internal.CommandMarker implements java.io.Closeable
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: com.mongodb.client.internal.CommandMarker
super_class: java.lang.Object
{
private final com.mongodb.client.MongoClient client;
descriptor: Lcom/mongodb/client/MongoClient;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.lang.ProcessBuilder processBuilder;
descriptor: Ljava/lang/ProcessBuilder;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
void <init>(boolean, java.util.Map<java.lang.String, java.lang.Object>);
descriptor: (ZLjava/util/Map;)V
flags: (0x0000)
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: iload 1
ifeq 5
2: aload 0
aconst_null
putfield com.mongodb.client.internal.CommandMarker.processBuilder:Ljava/lang/ProcessBuilder;
3: aload 0
aconst_null
putfield com.mongodb.client.internal.CommandMarker.client:Lcom/mongodb/client/MongoClient;
4: return
5: StackMap locals: com.mongodb.client.internal.CommandMarker int java.util.Map
StackMap stack:
aload 2
ldc "mongocryptdBypassSpawn"
invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
ifeq 6
aload 2
ldc "mongocryptdBypassSpawn"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.Boolean
invokevirtual java.lang.Boolean.booleanValue:()Z
ifne 9
6: StackMap locals:
StackMap stack:
aload 0
aload 2
invokestatic com.mongodb.internal.capi.MongoCryptHelper.createProcessBuilder:(Ljava/util/Map;)Ljava/lang/ProcessBuilder;
putfield com.mongodb.client.internal.CommandMarker.processBuilder:Ljava/lang/ProcessBuilder;
7: aload 0
getfield com.mongodb.client.internal.CommandMarker.processBuilder:Ljava/lang/ProcessBuilder;
invokestatic com.mongodb.internal.capi.MongoCryptHelper.startProcess:(Ljava/lang/ProcessBuilder;)V
8: goto 10
9: StackMap locals:
StackMap stack:
aload 0
aconst_null
putfield com.mongodb.client.internal.CommandMarker.processBuilder:Ljava/lang/ProcessBuilder;
10: StackMap locals:
StackMap stack:
aload 0
aload 2
ldc "mongocryptdURI"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
invokestatic com.mongodb.internal.capi.MongoCryptHelper.createMongocryptdClientSettings:(Ljava/lang/String;)Lcom/mongodb/MongoClientSettings;
invokestatic com.mongodb.client.MongoClients.create:(Lcom/mongodb/MongoClientSettings;)Lcom/mongodb/client/MongoClient;
putfield com.mongodb.client.internal.CommandMarker.client:Lcom/mongodb/client/MongoClient;
11: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lcom/mongodb/client/internal/CommandMarker;
0 12 1 isBypassAutoEncryption Z
0 12 2 options Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
Signature: (ZLjava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;)V
MethodParameters:
Name Flags
isBypassAutoEncryption final
options final
org.bson.RawBsonDocument mark(java.lang.String, org.bson.RawBsonDocument);
descriptor: (Ljava/lang/String;Lorg/bson/RawBsonDocument;)Lorg/bson/RawBsonDocument;
flags: (0x0000)
Code:
stack=3, locals=4, args_size=3
start local 0 start local 1 start local 2 0: ldc "client"
aload 0
getfield com.mongodb.client.internal.CommandMarker.client:Lcom/mongodb/client/MongoClient;
invokestatic com.mongodb.assertions.Assertions.notNull:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 0
aload 1
aload 2
invokevirtual com.mongodb.client.internal.CommandMarker.executeCommand:(Ljava/lang/String;Lorg/bson/RawBsonDocument;)Lorg/bson/RawBsonDocument;
2: areturn
3: StackMap locals:
StackMap stack: com.mongodb.MongoTimeoutException
astore 3
start local 3 4: aload 0
getfield com.mongodb.client.internal.CommandMarker.processBuilder:Ljava/lang/ProcessBuilder;
ifnonnull 6
5: aload 3
athrow
6: StackMap locals: com.mongodb.MongoTimeoutException
StackMap stack:
aload 0
getfield com.mongodb.client.internal.CommandMarker.processBuilder:Ljava/lang/ProcessBuilder;
invokestatic com.mongodb.internal.capi.MongoCryptHelper.startProcess:(Ljava/lang/ProcessBuilder;)V
7: aload 0
aload 1
aload 2
invokevirtual com.mongodb.client.internal.CommandMarker.executeCommand:(Ljava/lang/String;Lorg/bson/RawBsonDocument;)Lorg/bson/RawBsonDocument;
8: areturn
end local 3 9: StackMap locals: com.mongodb.client.internal.CommandMarker java.lang.String org.bson.RawBsonDocument
StackMap stack: com.mongodb.MongoException
astore 3
start local 3 10: aload 0
aload 3
invokevirtual com.mongodb.client.internal.CommandMarker.wrapInClientException:(Lcom/mongodb/MongoException;)Lcom/mongodb/MongoClientException;
athrow
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lcom/mongodb/client/internal/CommandMarker;
0 11 1 databaseName Ljava/lang/String;
0 11 2 command Lorg/bson/RawBsonDocument;
4 9 3 e Lcom/mongodb/MongoTimeoutException;
10 11 3 e Lcom/mongodb/MongoException;
Exception table:
from to target type
1 2 3 Class com.mongodb.MongoTimeoutException
1 2 9 Class com.mongodb.MongoException
3 8 9 Class com.mongodb.MongoException
MethodParameters:
Name Flags
databaseName final
command final
public void close();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.mongodb.client.internal.CommandMarker.client:Lcom/mongodb/client/MongoClient;
ifnull 2
1: aload 0
getfield com.mongodb.client.internal.CommandMarker.client:Lcom/mongodb/client/MongoClient;
invokeinterface com.mongodb.client.MongoClient.close:()V
2: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/mongodb/client/internal/CommandMarker;
private org.bson.RawBsonDocument executeCommand(java.lang.String, org.bson.RawBsonDocument);
descriptor: (Ljava/lang/String;Lorg/bson/RawBsonDocument;)Lorg/bson/RawBsonDocument;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield com.mongodb.client.internal.CommandMarker.client:Lcom/mongodb/client/MongoClient;
aload 1
invokeinterface com.mongodb.client.MongoClient.getDatabase:(Ljava/lang/String;)Lcom/mongodb/client/MongoDatabase;
1: getstatic com.mongodb.ReadConcern.DEFAULT:Lcom/mongodb/ReadConcern;
invokeinterface com.mongodb.client.MongoDatabase.withReadConcern:(Lcom/mongodb/ReadConcern;)Lcom/mongodb/client/MongoDatabase;
2: invokestatic com.mongodb.ReadPreference.primary:()Lcom/mongodb/ReadPreference;
invokeinterface com.mongodb.client.MongoDatabase.withReadPreference:(Lcom/mongodb/ReadPreference;)Lcom/mongodb/client/MongoDatabase;
3: aload 2
ldc Lorg/bson/RawBsonDocument;
invokeinterface com.mongodb.client.MongoDatabase.runCommand:(Lorg/bson/conversions/Bson;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.bson.RawBsonDocument
4: areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lcom/mongodb/client/internal/CommandMarker;
0 5 1 databaseName Ljava/lang/String;
0 5 2 markableCommand Lorg/bson/RawBsonDocument;
MethodParameters:
Name Flags
databaseName final
markableCommand final
private com.mongodb.MongoClientException wrapInClientException(com.mongodb.MongoException);
descriptor: (Lcom/mongodb/MongoException;)Lcom/mongodb/MongoClientException;
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: new com.mongodb.MongoClientException
dup
new java.lang.StringBuilder
dup
ldc "Exception in encryption library: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual com.mongodb.MongoException.getMessage:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
aload 1
invokespecial com.mongodb.MongoClientException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/mongodb/client/internal/CommandMarker;
0 1 1 e Lcom/mongodb/MongoException;
MethodParameters:
Name Flags
e final
}
SourceFile: "CommandMarker.java"