From 4b5d136b9cd5dde2ffae8f4ea11a4f8ddfbad23a Mon Sep 17 00:00:00 2001 From: Lauri Tulmin Date: Mon, 6 May 2024 15:33:02 +0300 Subject: [PATCH] use class from influxdb client for call depth counting --- .../influxdb/v2_4/InfluxDbImplInstrumentation.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/instrumentation/influxdb-2.4/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/influxdb/v2_4/InfluxDbImplInstrumentation.java b/instrumentation/influxdb-2.4/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/influxdb/v2_4/InfluxDbImplInstrumentation.java index b247c7131fd8..256202acc80a 100644 --- a/instrumentation/influxdb-2.4/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/influxdb/v2_4/InfluxDbImplInstrumentation.java +++ b/instrumentation/influxdb-2.4/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/influxdb/v2_4/InfluxDbImplInstrumentation.java @@ -79,7 +79,7 @@ public static void onEnter( @Advice.Local("otelRequest") InfluxDbRequest influxDbRequest, @Advice.Local("otelContext") Context context, @Advice.Local("otelScope") Scope scope) { - callDepth = CallDepth.forClass(Retrofit.class); + callDepth = CallDepth.forClass(InfluxDBImpl.class); if (callDepth.getAndIncrement() > 0) { return; } @@ -137,7 +137,7 @@ public static void onEnter( @Advice.Local("otelRequest") InfluxDbRequest influxDbRequest, @Advice.Local("otelContext") Context context, @Advice.Local("otelScope") Scope scope) { - callDepth = CallDepth.forClass(Retrofit.class); + callDepth = CallDepth.forClass(InfluxDBImpl.class); if (callDepth.getAndIncrement() > 0) { return; }