Code review sweep (run 25185529106) (#18460)

Co-authored-by: otelbot <197425009+otelbot@users.noreply.github.com>
Co-authored-by: Trask Stalnaker <trask.stalnaker@gmail.com>

Author: otelbot[bot]

instrumentation/jsf/jsf-mojarra-1.2/metadata.yaml

@@ -7,6 +7,7 @@ features:
 library_link: https://github.com/eclipse-ee4j/mojarra
 configurations:
   - name: otel.instrumentation.common.experimental.controller-telemetry.enabled
+    declarative_name: java.common.controller_telemetry/development.enabled
     description: Enables the creation of experimental controller spans.
     type: boolean
     default: false

instrumentation/jsf/jsf-mojarra-3.0/javaagent/build.gradle.kts

@@ -7,8 +7,8 @@ muzzle {
     group.set("org.glassfish")
     module.set("jakarta.faces")
     versions.set("[3,)")
-    extraDependency("jakarta.el:jakarta.el-api:4.0.0")
     assertInverse.set(true)
+    extraDependency("jakarta.el:jakarta.el-api:4.0.0")
   }
 }
 
@@ -38,7 +38,7 @@ dependencies {
 }
 
 tasks {
-  withType<Test>().configureEach {
+  test {
     jvmArgs("-Dotel.instrumentation.common.experimental.controller-telemetry.enabled=true")
     systemProperty("collectMetadata", otelProps.collectMetadata)
     systemProperty("metadataConfig", "otel.instrumentation.common.experimental.controller-telemetry.enabled=true")

instrumentation/jsf/jsf-myfaces-1.2/javaagent/build.gradle.kts

@@ -7,8 +7,8 @@ muzzle {
     group.set("org.apache.myfaces.core")
     module.set("myfaces-impl")
     versions.set("[1.2,3)")
-    extraDependency("jakarta.el:jakarta.el-api:3.0.3")
     assertInverse.set(true)
+    extraDependency("jakarta.el:jakarta.el-api:3.0.3")
   }
 }
 

instrumentation/jsf/jsf-myfaces-3.0/javaagent/build.gradle.kts

@@ -38,7 +38,7 @@ dependencies {
 }
 
 tasks {
-  withType<Test>().configureEach {
+  test {
     jvmArgs("-Dotel.instrumentation.common.experimental.controller-telemetry.enabled=true")
     systemProperty("collectMetadata", otelProps.collectMetadata)
     systemProperty("metadataConfig", "otel.instrumentation.common.experimental.controller-telemetry.enabled=true")

instrumentation/jsp-2.3/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/jsp/v2_3/JspSpanAssertions.java

@@ -31,7 +31,7 @@
 import io.opentelemetry.sdk.trace.data.StatusData;
 
 class JspSpanAssertions {
-  static final boolean EXPERIMENTAL_ATTRIBUTES =
+  private static final boolean EXPERIMENTAL_ATTRIBUTES =
       Boolean.getBoolean("otel.instrumentation.jsp.experimental-span-attributes");
 
   private final String baseUrl;
@@ -162,6 +162,8 @@ void assertRenderSpan(SpanDataAssert span, JspSpan spanData) {
                   val.satisfiesAnyOf(
                       v -> assertThat(spanData.getForwardOrigin()).isNull(),
                       v -> assertThat(v).isEqualTo(spanData.getForwardOrigin()))));
+    } else {
+      span.hasTotalAttributeCount(0);
     }
   }
 }

instrumentation/kafka/kafka-clients/kafka-clients-0.11/bootstrap/src/main/java/io/opentelemetry/javaagent/bootstrap/kafka/KafkaClientsConsumerProcessTracing.java

@@ -14,7 +14,7 @@
 public final class KafkaClientsConsumerProcessTracing {
   private static final ThreadLocal<Boolean> wrappingEnabled = ThreadLocal.withInitial(() -> true);
 
-  public static boolean setEnabled(boolean enabled) {
+  public static boolean setWrappingEnabled(boolean enabled) {
     boolean previous = wrappingEnabled.get();
     wrappingEnabled.set(enabled);
     return previous;

instrumentation/kafka/kafka-clients/kafka-clients-0.11/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/kafkaclients/v0_11/KafkaConsumerInstrumentation.java

@@ -70,7 +70,7 @@ public static void onExit(
       KafkaReceiveRequest request = KafkaReceiveRequest.create(records, consumer);
 
       // disable process tracing and store the receive span for each individual record too
-      boolean previousValue = KafkaClientsConsumerProcessTracing.setEnabled(false);
+      boolean previousValue = KafkaClientsConsumerProcessTracing.setWrappingEnabled(false);
       try {
         Context context = null;
         if (consumerReceiveInstrumenter().shouldStart(parentContext, request)) {
@@ -97,7 +97,7 @@ public static void onExit(
           KafkaConsumerContextUtil.set(record, context, consumer);
         }
       } finally {
-        KafkaClientsConsumerProcessTracing.setEnabled(previousValue);
+        KafkaClientsConsumerProcessTracing.setWrappingEnabled(previousValue);
       }
     }
   }

instrumentation/kafka/kafka-connect-2.6/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/kafkaconnect/v2_6/WorkerSinkTaskInstrumentation.java

@@ -39,12 +39,12 @@ public static class ExecuteAdvice {
 
     @Advice.OnMethodEnter(suppress = Throwable.class, inline = false)
     public static boolean onEnter() {
-      return KafkaClientsConsumerProcessTracing.setEnabled(false);
+      return KafkaClientsConsumerProcessTracing.setWrappingEnabled(false);
     }
 
     @Advice.OnMethodExit(onThrowable = Throwable.class, suppress = Throwable.class, inline = false)
     public static void onExit(@Advice.Enter boolean previousValue) {
-      KafkaClientsConsumerProcessTracing.setEnabled(previousValue);
+      KafkaClientsConsumerProcessTracing.setWrappingEnabled(previousValue);
     }
   }
 }

instrumentation/kafka/kafka-streams-0.11/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/kafkastreams/v0_11/StreamThreadInstrumentation.java

@@ -31,12 +31,12 @@ public void transform(TypeTransformer transformer) {
   public static class RunLoopAdvice {
     @Advice.OnMethodEnter(suppress = Throwable.class, inline = false)
     public static boolean onEnter() {
-      return KafkaClientsConsumerProcessTracing.setEnabled(false);
+      return KafkaClientsConsumerProcessTracing.setWrappingEnabled(false);
     }
 
     @Advice.OnMethodExit(suppress = Throwable.class, inline = false)
     public static void onExit(@Advice.Enter boolean previousValue) {
-      KafkaClientsConsumerProcessTracing.setEnabled(previousValue);
+      KafkaClientsConsumerProcessTracing.setWrappingEnabled(previousValue);
     }
   }
 }

instrumentation/reactor/reactor-kafka-1.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/reactor/kafka/v1_0/TracingDisablingKafkaFlux.java

@@ -51,11 +51,11 @@ public Context currentContext() {
 
     @Override
     public void onNext(T record) {
-      boolean previous = KafkaClientsConsumerProcessTracing.setEnabled(false);
+      boolean previous = KafkaClientsConsumerProcessTracing.setWrappingEnabled(false);
       try {
         actual.onNext(record);
       } finally {
-        KafkaClientsConsumerProcessTracing.setEnabled(previous);
+        KafkaClientsConsumerProcessTracing.setWrappingEnabled(previous);
       }
     }