class com.mongodb.internal.connection.LoggingCommandEventSender implements com.mongodb.internal.connection.CommandEventSender
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: com.mongodb.internal.connection.LoggingCommandEventSender
super_class: java.lang.Object
{
private static final int MAX_COMMAND_DOCUMENT_LENGTH_TO_LOG;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 1000
private final java.util.Set<java.lang.String> securitySensitiveCommands;
descriptor: Ljava/util/Set;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Set<Ljava/lang/String;>;
private final com.mongodb.connection.ConnectionDescription description;
descriptor: Lcom/mongodb/connection/ConnectionDescription;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final com.mongodb.event.CommandListener commandListener;
descriptor: Lcom/mongodb/event/CommandListener;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final com.mongodb.diagnostics.logging.Logger logger;
descriptor: Lcom/mongodb/diagnostics/logging/Logger;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final long startTimeNanos;
descriptor: J
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final com.mongodb.internal.connection.CommandMessage message;
descriptor: Lcom/mongodb/internal/connection/CommandMessage;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.lang.String commandName;
descriptor: Ljava/lang/String;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private volatile org.bson.BsonDocument commandDocument;
descriptor: Lorg/bson/BsonDocument;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
void <init>(java.util.Set<java.lang.String>, com.mongodb.connection.ConnectionDescription, com.mongodb.event.CommandListener, com.mongodb.internal.connection.CommandMessage, com.mongodb.connection.ByteBufferBsonOutput, com.mongodb.diagnostics.logging.Logger);
descriptor: (Ljava/util/Set;Lcom/mongodb/connection/ConnectionDescription;Lcom/mongodb/event/CommandListener;Lcom/mongodb/internal/connection/CommandMessage;Lcom/mongodb/connection/ByteBufferBsonOutput;Lcom/mongodb/diagnostics/logging/Logger;)V
flags: (0x0000)
Code:
stack=3, locals=7, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield com.mongodb.internal.connection.LoggingCommandEventSender.securitySensitiveCommands:Ljava/util/Set;
2: aload 0
aload 2
putfield com.mongodb.internal.connection.LoggingCommandEventSender.description:Lcom/mongodb/connection/ConnectionDescription;
3: aload 0
aload 3
putfield com.mongodb.internal.connection.LoggingCommandEventSender.commandListener:Lcom/mongodb/event/CommandListener;
4: aload 0
aload 6
putfield com.mongodb.internal.connection.LoggingCommandEventSender.logger:Lcom/mongodb/diagnostics/logging/Logger;
5: aload 0
invokestatic java.lang.System.nanoTime:()J
putfield com.mongodb.internal.connection.LoggingCommandEventSender.startTimeNanos:J
6: aload 0
aload 4
putfield com.mongodb.internal.connection.LoggingCommandEventSender.message:Lcom/mongodb/internal/connection/CommandMessage;
7: aload 0
aload 4
aload 5
invokevirtual com.mongodb.internal.connection.CommandMessage.getCommandDocument:(Lcom/mongodb/connection/ByteBufferBsonOutput;)Lorg/bson/BsonDocument;
putfield com.mongodb.internal.connection.LoggingCommandEventSender.commandDocument:Lorg/bson/BsonDocument;
8: aload 0
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.commandDocument:Lorg/bson/BsonDocument;
invokevirtual org.bson.BsonDocument.getFirstKey:()Ljava/lang/String;
putfield com.mongodb.internal.connection.LoggingCommandEventSender.commandName:Ljava/lang/String;
9: return
end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lcom/mongodb/internal/connection/LoggingCommandEventSender;
0 10 1 securitySensitiveCommands Ljava/util/Set<Ljava/lang/String;>;
0 10 2 description Lcom/mongodb/connection/ConnectionDescription;
0 10 3 commandListener Lcom/mongodb/event/CommandListener;
0 10 4 message Lcom/mongodb/internal/connection/CommandMessage;
0 10 5 bsonOutput Lcom/mongodb/connection/ByteBufferBsonOutput;
0 10 6 logger Lcom/mongodb/diagnostics/logging/Logger;
Signature: (Ljava/util/Set<Ljava/lang/String;>;Lcom/mongodb/connection/ConnectionDescription;Lcom/mongodb/event/CommandListener;Lcom/mongodb/internal/connection/CommandMessage;Lcom/mongodb/connection/ByteBufferBsonOutput;Lcom/mongodb/diagnostics/logging/Logger;)V
MethodParameters:
Name Flags
securitySensitiveCommands final
description final
commandListener final
message final
bsonOutput final
logger final
public void sendStartedEvent();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=2, args_size=1
start local 0 0: aload 0
invokevirtual com.mongodb.internal.connection.LoggingCommandEventSender.loggingRequired:()Z
ifeq 7
1: aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.logger:Lcom/mongodb/diagnostics/logging/Logger;
2: ldc "Sending command '%s' with request id %d to database %s on connection [%s] to server %s"
iconst_5
anewarray java.lang.Object
dup
iconst_0
3: aload 0
invokevirtual com.mongodb.internal.connection.LoggingCommandEventSender.getTruncatedJsonCommand:()Ljava/lang/String;
aastore
dup
iconst_1
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.message:Lcom/mongodb/internal/connection/CommandMessage;
invokevirtual com.mongodb.internal.connection.CommandMessage.getId:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_2
4: aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.message:Lcom/mongodb/internal/connection/CommandMessage;
invokevirtual com.mongodb.internal.connection.CommandMessage.getNamespace:()Lcom/mongodb/MongoNamespace;
invokevirtual com.mongodb.MongoNamespace.getDatabaseName:()Ljava/lang/String;
aastore
dup
iconst_3
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.description:Lcom/mongodb/connection/ConnectionDescription;
invokevirtual com.mongodb.connection.ConnectionDescription.getConnectionId:()Lcom/mongodb/connection/ConnectionId;
aastore
dup
iconst_4
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.description:Lcom/mongodb/connection/ConnectionDescription;
invokevirtual com.mongodb.connection.ConnectionDescription.getServerAddress:()Lcom/mongodb/ServerAddress;
aastore
5: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
6: invokeinterface com.mongodb.diagnostics.logging.Logger.debug:(Ljava/lang/String;)V
7: StackMap locals:
StackMap stack:
aload 0
invokevirtual com.mongodb.internal.connection.LoggingCommandEventSender.eventRequired:()Z
ifeq 15
8: aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.securitySensitiveCommands:Ljava/util/Set;
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.commandName:Ljava/lang/String;
invokeinterface java.util.Set.contains:(Ljava/lang/Object;)Z
ifeq 10
9: new org.bson.BsonDocument
dup
invokespecial org.bson.BsonDocument.<init>:()V
goto 11
StackMap locals:
StackMap stack:
10: aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.commandDocument:Lorg/bson/BsonDocument;
11: StackMap locals:
StackMap stack: org.bson.BsonDocument
astore 1
start local 1 12: aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.message:Lcom/mongodb/internal/connection/CommandMessage;
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.message:Lcom/mongodb/internal/connection/CommandMessage;
invokevirtual com.mongodb.internal.connection.CommandMessage.getNamespace:()Lcom/mongodb/MongoNamespace;
invokevirtual com.mongodb.MongoNamespace.getDatabaseName:()Ljava/lang/String;
13: aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.commandName:Ljava/lang/String;
aload 1
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.description:Lcom/mongodb/connection/ConnectionDescription;
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.commandListener:Lcom/mongodb/event/CommandListener;
14: invokestatic com.mongodb.internal.connection.ProtocolHelper.sendCommandStartedEvent:(Lcom/mongodb/internal/connection/RequestMessage;Ljava/lang/String;Ljava/lang/String;Lorg/bson/BsonDocument;Lcom/mongodb/connection/ConnectionDescription;Lcom/mongodb/event/CommandListener;)V
end local 1 15: StackMap locals:
StackMap stack:
aload 0
aconst_null
putfield com.mongodb.internal.connection.LoggingCommandEventSender.commandDocument:Lorg/bson/BsonDocument;
16: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lcom/mongodb/internal/connection/LoggingCommandEventSender;
12 15 1 commandDocumentForEvent Lorg/bson/BsonDocument;
private java.lang.String getTruncatedJsonCommand();
descriptor: ()Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=6, args_size=1
start local 0 0: new java.io.StringWriter
dup
invokespecial java.io.StringWriter.<init>:()V
astore 1
start local 1 1: aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.commandDocument:Lorg/bson/BsonDocument;
invokevirtual org.bson.BsonDocument.asBsonReader:()Lorg/bson/BsonReader;
astore 2
start local 2 2: new org.bson.json.JsonWriter
dup
aload 1
3: invokestatic org.bson.json.JsonWriterSettings.builder:()Lorg/bson/json/JsonWriterSettings$Builder;
getstatic org.bson.json.JsonMode.RELAXED:Lorg/bson/json/JsonMode;
invokevirtual org.bson.json.JsonWriterSettings$Builder.outputMode:(Lorg/bson/json/JsonMode;)Lorg/bson/json/JsonWriterSettings$Builder;
sipush 1000
invokevirtual org.bson.json.JsonWriterSettings$Builder.maxLength:(I)Lorg/bson/json/JsonWriterSettings$Builder;
invokevirtual org.bson.json.JsonWriterSettings$Builder.build:()Lorg/bson/json/JsonWriterSettings;
4: invokespecial org.bson.json.JsonWriter.<init>:(Ljava/io/Writer;Lorg/bson/json/JsonWriterSettings;)V
astore 3
start local 3 5: aload 3
aload 2
invokevirtual org.bson.json.JsonWriter.pipe:(Lorg/bson/BsonReader;)V
6: aload 3
invokevirtual org.bson.json.JsonWriter.isTruncated:()Z
ifeq 8
7: aload 1
ldc " ..."
invokevirtual java.io.StringWriter.append:(Ljava/lang/CharSequence;)Ljava/io/StringWriter;
pop
8: StackMap locals: java.io.StringWriter org.bson.BsonReader org.bson.json.JsonWriter
StackMap stack:
aload 1
invokevirtual java.io.StringWriter.toString:()Ljava/lang/String;
astore 5
9: aload 2
invokeinterface org.bson.BsonReader.close:()V
10: aload 5
areturn
end local 3 11: StackMap locals: com.mongodb.internal.connection.LoggingCommandEventSender java.io.StringWriter org.bson.BsonReader
StackMap stack: java.lang.Throwable
astore 4
12: aload 2
invokeinterface org.bson.BsonReader.close:()V
13: aload 4
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lcom/mongodb/internal/connection/LoggingCommandEventSender;
1 14 1 writer Ljava/io/StringWriter;
2 14 2 bsonReader Lorg/bson/BsonReader;
5 11 3 jsonWriter Lorg/bson/json/JsonWriter;
Exception table:
from to target type
2 9 11 any
public void sendFailedEvent(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=5, args_size=2
start local 0 start local 1 0: aload 1
astore 2
start local 2 1: aload 1
instanceof com.mongodb.MongoCommandException
ifeq 3
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.securitySensitiveCommands:Ljava/util/Set;
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.commandName:Ljava/lang/String;
invokeinterface java.util.Set.contains:(Ljava/lang/Object;)Z
ifeq 3
2: new com.mongodb.MongoCommandException
dup
new org.bson.BsonDocument
dup
invokespecial org.bson.BsonDocument.<init>:()V
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.description:Lcom/mongodb/connection/ConnectionDescription;
invokevirtual com.mongodb.connection.ConnectionDescription.getServerAddress:()Lcom/mongodb/ServerAddress;
invokespecial com.mongodb.MongoCommandException.<init>:(Lorg/bson/BsonDocument;Lcom/mongodb/ServerAddress;)V
astore 2
3: StackMap locals: java.lang.Throwable
StackMap stack:
invokestatic java.lang.System.nanoTime:()J
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.startTimeNanos:J
lsub
lstore 3
start local 3 4: aload 0
invokevirtual com.mongodb.internal.connection.LoggingCommandEventSender.loggingRequired:()Z
ifeq 12
5: aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.logger:Lcom/mongodb/diagnostics/logging/Logger;
6: ldc "Execution of command with request id %d failed to complete successfully in %s ms on connection [%s] to server %s"
iconst_4
anewarray java.lang.Object
dup
iconst_0
7: aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.message:Lcom/mongodb/internal/connection/CommandMessage;
invokevirtual com.mongodb.internal.connection.CommandMessage.getId:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
aload 0
lload 3
invokevirtual com.mongodb.internal.connection.LoggingCommandEventSender.getElapsedTimeFormattedInMilliseconds:(J)Ljava/lang/String;
aastore
dup
iconst_2
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.description:Lcom/mongodb/connection/ConnectionDescription;
invokevirtual com.mongodb.connection.ConnectionDescription.getConnectionId:()Lcom/mongodb/connection/ConnectionId;
aastore
dup
iconst_3
8: aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.description:Lcom/mongodb/connection/ConnectionDescription;
invokevirtual com.mongodb.connection.ConnectionDescription.getServerAddress:()Lcom/mongodb/ServerAddress;
aastore
9: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
10: aload 2
11: invokeinterface com.mongodb.diagnostics.logging.Logger.debug:(Ljava/lang/String;Ljava/lang/Throwable;)V
12: StackMap locals: long
StackMap stack:
aload 0
invokevirtual com.mongodb.internal.connection.LoggingCommandEventSender.eventRequired:()Z
ifeq 14
13: aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.message:Lcom/mongodb/internal/connection/CommandMessage;
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.commandName:Ljava/lang/String;
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.description:Lcom/mongodb/connection/ConnectionDescription;
lload 3
aload 2
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.commandListener:Lcom/mongodb/event/CommandListener;
invokestatic com.mongodb.internal.connection.ProtocolHelper.sendCommandFailedEvent:(Lcom/mongodb/internal/connection/RequestMessage;Ljava/lang/String;Lcom/mongodb/connection/ConnectionDescription;JLjava/lang/Throwable;Lcom/mongodb/event/CommandListener;)V
14: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lcom/mongodb/internal/connection/LoggingCommandEventSender;
0 15 1 t Ljava/lang/Throwable;
1 15 2 commandEventException Ljava/lang/Throwable;
4 15 3 elapsedTimeNanos J
MethodParameters:
Name Flags
t final
public void sendSucceededEvent(com.mongodb.internal.connection.ResponseBuffers);
descriptor: (Lcom/mongodb/internal/connection/ResponseBuffers;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=5, args_size=2
start local 0 start local 1 0: invokestatic java.lang.System.nanoTime:()J
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.startTimeNanos:J
lsub
lstore 2
start local 2 1: aload 0
invokevirtual com.mongodb.internal.connection.LoggingCommandEventSender.loggingRequired:()Z
ifeq 8
2: aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.logger:Lcom/mongodb/diagnostics/logging/Logger;
3: ldc "Execution of command with request id %d completed successfully in %s ms on connection [%s] to server %s"
iconst_4
anewarray java.lang.Object
dup
iconst_0
4: aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.message:Lcom/mongodb/internal/connection/CommandMessage;
invokevirtual com.mongodb.internal.connection.CommandMessage.getId:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
aload 0
lload 2
invokevirtual com.mongodb.internal.connection.LoggingCommandEventSender.getElapsedTimeFormattedInMilliseconds:(J)Ljava/lang/String;
aastore
dup
iconst_2
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.description:Lcom/mongodb/connection/ConnectionDescription;
invokevirtual com.mongodb.connection.ConnectionDescription.getConnectionId:()Lcom/mongodb/connection/ConnectionId;
aastore
dup
iconst_3
5: aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.description:Lcom/mongodb/connection/ConnectionDescription;
invokevirtual com.mongodb.connection.ConnectionDescription.getServerAddress:()Lcom/mongodb/ServerAddress;
aastore
6: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
7: invokeinterface com.mongodb.diagnostics.logging.Logger.debug:(Ljava/lang/String;)V
8: StackMap locals: long
StackMap stack:
aload 0
invokevirtual com.mongodb.internal.connection.LoggingCommandEventSender.eventRequired:()Z
ifeq 16
9: aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.securitySensitiveCommands:Ljava/util/Set;
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.commandName:Ljava/lang/String;
invokeinterface java.util.Set.contains:(Ljava/lang/Object;)Z
ifeq 11
10: new org.bson.BsonDocument
dup
invokespecial org.bson.BsonDocument.<init>:()V
goto 12
11: StackMap locals:
StackMap stack:
aload 1
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.message:Lcom/mongodb/internal/connection/CommandMessage;
invokevirtual com.mongodb.internal.connection.CommandMessage.getId:()I
new org.bson.codecs.RawBsonDocumentCodec
dup
invokespecial org.bson.codecs.RawBsonDocumentCodec.<init>:()V
invokevirtual com.mongodb.internal.connection.ResponseBuffers.getResponseDocument:(ILorg/bson/codecs/Decoder;)Lorg/bson/BsonDocument;
12: StackMap locals:
StackMap stack: org.bson.BsonDocument
astore 4
start local 4 13: aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.message:Lcom/mongodb/internal/connection/CommandMessage;
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.commandName:Ljava/lang/String;
aload 4
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.description:Lcom/mongodb/connection/ConnectionDescription;
14: lload 2
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.commandListener:Lcom/mongodb/event/CommandListener;
15: invokestatic com.mongodb.internal.connection.ProtocolHelper.sendCommandSucceededEvent:(Lcom/mongodb/internal/connection/RequestMessage;Ljava/lang/String;Lorg/bson/BsonDocument;Lcom/mongodb/connection/ConnectionDescription;JLcom/mongodb/event/CommandListener;)V
end local 4 16: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lcom/mongodb/internal/connection/LoggingCommandEventSender;
0 17 1 responseBuffers Lcom/mongodb/internal/connection/ResponseBuffers;
1 17 2 elapsedTimeNanos J
13 16 4 responseDocumentForEvent Lorg/bson/BsonDocument;
MethodParameters:
Name Flags
responseBuffers final
public void sendSucceededEventForOneWayCommand();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=4, args_size=1
start local 0 0: invokestatic java.lang.System.nanoTime:()J
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.startTimeNanos:J
lsub
lstore 1
start local 1 1: aload 0
invokevirtual com.mongodb.internal.connection.LoggingCommandEventSender.loggingRequired:()Z
ifeq 8
2: aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.logger:Lcom/mongodb/diagnostics/logging/Logger;
3: ldc "Execution of one-way command with request id %d completed successfully in %s ms on connection [%s] to server %s"
iconst_4
anewarray java.lang.Object
dup
iconst_0
4: aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.message:Lcom/mongodb/internal/connection/CommandMessage;
invokevirtual com.mongodb.internal.connection.CommandMessage.getId:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
aload 0
lload 1
invokevirtual com.mongodb.internal.connection.LoggingCommandEventSender.getElapsedTimeFormattedInMilliseconds:(J)Ljava/lang/String;
aastore
dup
iconst_2
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.description:Lcom/mongodb/connection/ConnectionDescription;
invokevirtual com.mongodb.connection.ConnectionDescription.getConnectionId:()Lcom/mongodb/connection/ConnectionId;
aastore
dup
iconst_3
5: aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.description:Lcom/mongodb/connection/ConnectionDescription;
invokevirtual com.mongodb.connection.ConnectionDescription.getServerAddress:()Lcom/mongodb/ServerAddress;
aastore
6: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
7: invokeinterface com.mongodb.diagnostics.logging.Logger.debug:(Ljava/lang/String;)V
8: StackMap locals: long
StackMap stack:
aload 0
invokevirtual com.mongodb.internal.connection.LoggingCommandEventSender.eventRequired:()Z
ifeq 13
9: new org.bson.BsonDocument
dup
ldc "ok"
new org.bson.BsonInt32
dup
iconst_1
invokespecial org.bson.BsonInt32.<init>:(I)V
invokespecial org.bson.BsonDocument.<init>:(Ljava/lang/String;Lorg/bson/BsonValue;)V
astore 3
start local 3 10: aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.message:Lcom/mongodb/internal/connection/CommandMessage;
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.commandName:Ljava/lang/String;
aload 3
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.description:Lcom/mongodb/connection/ConnectionDescription;
11: lload 1
aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.commandListener:Lcom/mongodb/event/CommandListener;
12: invokestatic com.mongodb.internal.connection.ProtocolHelper.sendCommandSucceededEvent:(Lcom/mongodb/internal/connection/RequestMessage;Ljava/lang/String;Lorg/bson/BsonDocument;Lcom/mongodb/connection/ConnectionDescription;JLcom/mongodb/event/CommandListener;)V
end local 3 13: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lcom/mongodb/internal/connection/LoggingCommandEventSender;
1 14 1 elapsedTimeNanos J
10 13 3 responseDocumentForEvent Lorg/bson/BsonDocument;
private boolean loggingRequired();
descriptor: ()Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.logger:Lcom/mongodb/diagnostics/logging/Logger;
invokeinterface com.mongodb.diagnostics.logging.Logger.isDebugEnabled:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/mongodb/internal/connection/LoggingCommandEventSender;
private boolean eventRequired();
descriptor: ()Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.mongodb.internal.connection.LoggingCommandEventSender.commandListener:Lcom/mongodb/event/CommandListener;
ifnull 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 Lcom/mongodb/internal/connection/LoggingCommandEventSender;
private java.lang.String getElapsedTimeFormattedInMilliseconds(long);
descriptor: (J)Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: ldc "#0.00"
lload 1
l2d
ldc 1000000.0
ddiv
invokestatic com.mongodb.internal.connection.DecimalFormatHelper.format:(Ljava/lang/String;D)Ljava/lang/String;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/mongodb/internal/connection/LoggingCommandEventSender;
0 1 1 elapsedTimeNanos J
MethodParameters:
Name Flags
elapsedTimeNanos final
}
SourceFile: "LoggingCommandEventSender.java"
InnerClasses:
public final Builder = org.bson.json.JsonWriterSettings$Builder of org.bson.json.JsonWriterSettings