open-telemetry
/
opentelemetry-java-instrumentation
mirror of https://github.com/open-telemetry/opentelemetry-java-instrumentation.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Mongodb: avoid duplicate tracing (#6465)

This commit is contained in:
Lauri Tulmin 2022-08-12 18:41:18 +03:00 committed by GitHub
parent 08f013f9d6
commit b5f49636f2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
8 changed files with 20 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
instrumentation/mongo/mongo-3.1/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/mongo/v3_1/MongoClientInstrumentationModule.java
View File

@ -66,7 +66,7 @@ public class MongoClientInstrumentationModule extends InstrumentationModule {
@Advice.This MongoClientOptions.Builder builder, @Advice.This MongoClientOptions.Builder builder,
@Advice.FieldValue("commandListeners") List<CommandListener> commandListeners) { @Advice.FieldValue("commandListeners") List<CommandListener> commandListeners) {
for (CommandListener commandListener : commandListeners) { for (CommandListener commandListener : commandListeners) {
if (commandListener == MongoInstrumentationSingletons.LISTENER) { if (MongoInstrumentationSingletons.isTracingListener(commandListener)) {
return; return;
} }
} }

4
instrumentation/mongo/mongo-3.1/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/mongo/v3_1/MongoInstrumentationSingletons.java
View File

@ -14,5 +14,9 @@ public final class MongoInstrumentationSingletons {
public static final CommandListener LISTENER = public static final CommandListener LISTENER =
MongoTelemetry.create(GlobalOpenTelemetry.get()).newCommandListener(); MongoTelemetry.create(GlobalOpenTelemetry.get()).newCommandListener();
public static boolean isTracingListener(CommandListener listener) {
return listener.getClass().getName().equals(LISTENER.getClass().getName());
}
private MongoInstrumentationSingletons() {} private MongoInstrumentationSingletons() {}
} }

2
instrumentation/mongo/mongo-3.7/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/mongo/v3_7/MongoClientSettingsBuilderInstrumentation.java
View File

@ -49,7 +49,7 @@ final class MongoClientSettingsBuilderInstrumentation implements TypeInstrumenta
@Advice.This MongoClientSettings.Builder builder, @Advice.This MongoClientSettings.Builder builder,
@Advice.FieldValue("commandListeners") List<CommandListener> commandListeners) { @Advice.FieldValue("commandListeners") List<CommandListener> commandListeners) {
for (CommandListener commandListener : commandListeners) { for (CommandListener commandListener : commandListeners) {
if (commandListener == MongoInstrumentationSingletons.LISTENER) { if (MongoInstrumentationSingletons.isTracingListener(commandListener)) {
return; return;
} }
} }

4
instrumentation/mongo/mongo-3.7/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/mongo/v3_7/MongoInstrumentationSingletons.java
View File

@ -14,5 +14,9 @@ public final class MongoInstrumentationSingletons {
public static final CommandListener LISTENER = public static final CommandListener LISTENER =
MongoTelemetry.create(GlobalOpenTelemetry.get()).newCommandListener(); MongoTelemetry.create(GlobalOpenTelemetry.get()).newCommandListener();
public static boolean isTracingListener(CommandListener listener) {
return listener.getClass().getName().equals(LISTENER.getClass().getName());
}
private MongoInstrumentationSingletons() {} private MongoInstrumentationSingletons() {}
} }

2
instrumentation/mongo/mongo-4.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/mongo/v4_0/MongoClientSettingsBuilderInstrumentation.java
View File

@ -49,7 +49,7 @@ final class MongoClientSettingsBuilderInstrumentation implements TypeInstrumenta
@Advice.This MongoClientSettings.Builder builder, @Advice.This MongoClientSettings.Builder builder,
@Advice.FieldValue("commandListeners") List<CommandListener> commandListeners) { @Advice.FieldValue("commandListeners") List<CommandListener> commandListeners) {
for (CommandListener commandListener : commandListeners) { for (CommandListener commandListener : commandListeners) {
if (commandListener == MongoInstrumentationSingletons.LISTENER) { if (MongoInstrumentationSingletons.isTracingListener(commandListener)) {
return; return;
} }
} }

4
instrumentation/mongo/mongo-4.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/mongo/v4_0/MongoInstrumentationSingletons.java
View File

@ -14,5 +14,9 @@ public final class MongoInstrumentationSingletons {
public static final CommandListener LISTENER = public static final CommandListener LISTENER =
MongoTelemetry.create(GlobalOpenTelemetry.get()).newCommandListener(); MongoTelemetry.create(GlobalOpenTelemetry.get()).newCommandListener();
public static boolean isTracingListener(CommandListener listener) {
return listener.getClass().getName().equals(LISTENER.getClass().getName());
}
private MongoInstrumentationSingletons() {} private MongoInstrumentationSingletons() {}
} }

2
instrumentation/mongo/mongo-async-3.3/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/mongoasync/v3_3/MongoClientSettingsBuildersInstrumentation.java
View File

@ -51,7 +51,7 @@ final class MongoClientSettingsBuildersInstrumentation implements TypeInstrument
@Advice.This MongoClientSettings.Builder builder, @Advice.This MongoClientSettings.Builder builder,
@Advice.FieldValue("commandListeners") List<CommandListener> commandListeners) { @Advice.FieldValue("commandListeners") List<CommandListener> commandListeners) {
for (CommandListener commandListener : commandListeners) { for (CommandListener commandListener : commandListeners) {
if (commandListener == MongoInstrumentationSingletons.LISTENER) { if (MongoInstrumentationSingletons.isTracingListener(commandListener)) {
return; return;
} }
} }

4
instrumentation/mongo/mongo-async-3.3/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/mongoasync/v3_3/MongoInstrumentationSingletons.java
View File

@ -14,5 +14,9 @@ public final class MongoInstrumentationSingletons {
public static final CommandListener LISTENER = public static final CommandListener LISTENER =
MongoTelemetry.create(GlobalOpenTelemetry.get()).newCommandListener(); MongoTelemetry.create(GlobalOpenTelemetry.get()).newCommandListener();
public static boolean isTracingListener(CommandListener listener) {
return listener.getClass().getName().equals(LISTENER.getClass().getName());
}
private MongoInstrumentationSingletons() {} private MongoInstrumentationSingletons() {}
} }