Apply spotless code formatting.

tduncan · tduncan · commit 6292ec38c396 · 2025-03-27T09:47:07.000-07:00
diff --git a/profiler/src/main/java/com/splunk/opentelemetry/profiler/snapshot/ActiveSpanTracker.java b/profiler/src/main/java/com/splunk/opentelemetry/profiler/snapshot/ActiveSpanTracker.java
@@ -1,3 +1,19 @@
+/*
+ * Copyright Splunk Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package com.splunk.opentelemetry.profiler.snapshot;
 
 import io.opentelemetry.api.trace.Span;
@@ -30,7 +46,7 @@ public Scope attach(Context toAttach) {
     }
 
     String traceId = spanContext.getTraceId();
-    SpanContext current =  activeSpans.get(traceId);
+    SpanContext current = activeSpans.get(traceId);
     if (current == spanContext) {
       return scope;
     }
diff --git a/profiler/src/main/java/com/splunk/opentelemetry/profiler/snapshot/InterceptingContextStorageSpanTrackingActivator.java b/profiler/src/main/java/com/splunk/opentelemetry/profiler/snapshot/InterceptingContextStorageSpanTrackingActivator.java
@@ -1,3 +1,19 @@
+/*
+ * Copyright Splunk Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package com.splunk.opentelemetry.profiler.snapshot;
 
 import com.google.common.annotations.VisibleForTesting;
@@ -13,16 +29,18 @@ class InterceptingContextStorageSpanTrackingActivator implements SpanTrackingAct
   }
 
   @VisibleForTesting
-  InterceptingContextStorageSpanTrackingActivator(Consumer<UnaryOperator<ContextStorage>> contextStorageWrappingFunction) {
+  InterceptingContextStorageSpanTrackingActivator(
+      Consumer<UnaryOperator<ContextStorage>> contextStorageWrappingFunction) {
     this.contextStorageWrappingFunction = contextStorageWrappingFunction;
   }
 
   @Override
   public void activate(TraceRegistry registry) {
-    contextStorageWrappingFunction.accept(contextStorage -> {
-      ActiveSpanTracker tracker = new ActiveSpanTracker(contextStorage, registry);
-      SpanTrackerProvider.INSTANCE.configure(tracker);
-      return tracker;
-    });
+    contextStorageWrappingFunction.accept(
+        contextStorage -> {
+          ActiveSpanTracker tracker = new ActiveSpanTracker(contextStorage, registry);
+          SpanTrackerProvider.INSTANCE.configure(tracker);
+          return tracker;
+        });
   }
 }
diff --git a/profiler/src/main/java/com/splunk/opentelemetry/profiler/snapshot/ScheduledExecutorStackTraceSampler.java b/profiler/src/main/java/com/splunk/opentelemetry/profiler/snapshot/ScheduledExecutorStackTraceSampler.java
@@ -43,7 +43,8 @@ class ScheduledExecutorStackTraceSampler implements StackTraceSampler {
   private final Supplier<SpanTracker> spanTracker;
   private final Duration samplingPeriod;
 
-  ScheduledExecutorStackTraceSampler(StagingArea stagingArea, Supplier<SpanTracker> spanTracker, Duration samplingPeriod) {
+  ScheduledExecutorStackTraceSampler(
+      StagingArea stagingArea, Supplier<SpanTracker> spanTracker, Duration samplingPeriod) {
     this.stagingArea = stagingArea;
     this.spanTracker = spanTracker;
     this.samplingPeriod = samplingPeriod;
@@ -91,7 +92,8 @@ public void run() {
         Instant now = Instant.now();
         ThreadInfo threadInfo = threadMXBean.getThreadInfo(threadId, Integer.MAX_VALUE);
         SpanContext spanContext = retrieveActiveSpan(traceId);
-        StackTrace stackTrace = StackTrace.from(now, samplingPeriod, threadInfo, traceId, spanContext.getSpanId());
+        StackTrace stackTrace =
+            StackTrace.from(now, samplingPeriod, threadInfo, traceId, spanContext.getSpanId());
         stagingArea.stage(traceId, stackTrace);
       } catch (Exception e) {
         logger.log(Level.SEVERE, e, samplerErrorMessage(traceId, threadId));
diff --git a/profiler/src/main/java/com/splunk/opentelemetry/profiler/snapshot/SnapshotProfilingSdkCustomizer.java b/profiler/src/main/java/com/splunk/opentelemetry/profiler/snapshot/SnapshotProfilingSdkCustomizer.java
@@ -38,7 +38,10 @@ public class SnapshotProfilingSdkCustomizer implements AutoConfigurationCustomiz
   private final SpanTrackingActivator spanTrackingActivator;
 
   public SnapshotProfilingSdkCustomizer() {
-    this(new TraceRegistry(), stackTraceSamplerProvider(), new InterceptingContextStorageSpanTrackingActivator());
+    this(
+        new TraceRegistry(),
+        stackTraceSamplerProvider(),
+        new InterceptingContextStorageSpanTrackingActivator());
   }
 
   private static Function<ConfigProperties, StackTraceSampler> stackTraceSamplerProvider() {
@@ -119,7 +122,8 @@ private boolean includeTraceContextPropagator(Set<String> configuredPropagators)
     return configuredPropagators.isEmpty();
   }
 
-  private Function<ConfigProperties, Map<String, String>> startTrackingActiveSpans(TraceRegistry registry) {
+  private Function<ConfigProperties, Map<String, String>> startTrackingActiveSpans(
+      TraceRegistry registry) {
     return properties -> {
       if (snapshotProfilingEnabled(properties)) {
         spanTrackingActivator.activate(registry);
diff --git a/profiler/src/main/java/com/splunk/opentelemetry/profiler/snapshot/SpanTracker.java b/profiler/src/main/java/com/splunk/opentelemetry/profiler/snapshot/SpanTracker.java
@@ -1,3 +1,19 @@
+/*
+ * Copyright Splunk Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package com.splunk.opentelemetry.profiler.snapshot;
 
 import io.opentelemetry.api.trace.SpanContext;
diff --git a/profiler/src/main/java/com/splunk/opentelemetry/profiler/snapshot/SpanTrackerProvider.java b/profiler/src/main/java/com/splunk/opentelemetry/profiler/snapshot/SpanTrackerProvider.java
@@ -1,10 +1,26 @@
+/*
+ * Copyright Splunk Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package com.splunk.opentelemetry.profiler.snapshot;
 
 import java.util.Objects;
 import java.util.function.Supplier;
 
 class SpanTrackerProvider implements Supplier<SpanTracker> {
-  public static final  SpanTrackerProvider INSTANCE = new SpanTrackerProvider();
+  public static final SpanTrackerProvider INSTANCE = new SpanTrackerProvider();
 
   private SpanTracker tracker = SpanTracker.NOOP;
 
diff --git a/profiler/src/main/java/com/splunk/opentelemetry/profiler/snapshot/SpanTrackingActivator.java b/profiler/src/main/java/com/splunk/opentelemetry/profiler/snapshot/SpanTrackingActivator.java
@@ -1,3 +1,19 @@
+/*
+ * Copyright Splunk Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package com.splunk.opentelemetry.profiler.snapshot;
 
 interface SpanTrackingActivator {
diff --git a/profiler/src/main/java/com/splunk/opentelemetry/profiler/snapshot/StackTrace.java b/profiler/src/main/java/com/splunk/opentelemetry/profiler/snapshot/StackTrace.java
@@ -22,7 +22,8 @@
 import java.time.Instant;
 
 class StackTrace {
-  static StackTrace from(Instant timestamp, Duration duration, ThreadInfo thread, String traceId, String spanId) {
+  static StackTrace from(
+      Instant timestamp, Duration duration, ThreadInfo thread, String traceId, String spanId) {
     return new StackTrace(
         timestamp,
         duration,
@@ -31,8 +32,7 @@ static StackTrace from(Instant timestamp, Duration duration, ThreadInfo thread,
         thread.getThreadState(),
         thread.getStackTrace(),
         traceId,
-        spanId
-    );
+        spanId);
   }
 
   private final Instant timestamp;
diff --git a/profiler/src/test/java/com/splunk/opentelemetry/profiler/snapshot/ActiveSpanTrackerTest.java b/profiler/src/test/java/com/splunk/opentelemetry/profiler/snapshot/ActiveSpanTrackerTest.java
@@ -1,3 +1,19 @@
+/*
+ * Copyright Splunk Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package com.splunk.opentelemetry.profiler.snapshot;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
@@ -95,7 +111,8 @@ void restoreActiveSpanToPreviousSpanAfterScopeClosing() {
       scope.close();
 
       var rootSpanContext = root.getSpanContext();
-      assertEquals(Optional.of(rootSpanContext), spanTracker.getActiveSpan(rootSpanContext.getTraceId()));
+      assertEquals(
+          Optional.of(rootSpanContext), spanTracker.getActiveSpan(rootSpanContext.getTraceId()));
     }
   }
 
@@ -108,7 +125,7 @@ void trackActiveSpanForMultipleTraces() throws Exception {
     registry.register(root2.getSpanContext());
 
     try (var ignoredScope1 = executor.submit(attach(root1)).get();
-         var ignoredScope2 = executor.submit(attach(root2)).get()) {
+        var ignoredScope2 = executor.submit(attach(root2)).get()) {
       var traceId1 = root1.getSpanContext().getTraceId();
       assertEquals(Optional.of(root1.getSpanContext()), spanTracker.getActiveSpan(traceId1));
       var traceId2 = root2.getSpanContext().getTraceId();
@@ -167,7 +184,9 @@ void doNotTrackContinuallyTrackSameSpan() {
     try (var ignored = spanTracker.attach(context)) {
       var newContext = context.with(ContextKey.named("test-key"), "value");
       try (var scope = spanTracker.attach(newContext)) {
-        assertEquals("io.opentelemetry.context.ThreadLocalContextStorage$ScopeImpl", scope.getClass().getName());
+        assertEquals(
+            "io.opentelemetry.context.ThreadLocalContextStorage$ScopeImpl",
+            scope.getClass().getName());
       }
     }
   }
diff --git a/profiler/src/test/java/com/splunk/opentelemetry/profiler/snapshot/InMemorySpanTracker.java b/profiler/src/test/java/com/splunk/opentelemetry/profiler/snapshot/InMemorySpanTracker.java
@@ -1,7 +1,22 @@
+/*
+ * Copyright Splunk Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package com.splunk.opentelemetry.profiler.snapshot;
 
 import io.opentelemetry.api.trace.SpanContext;
-
 import java.util.HashMap;
 import java.util.Map;
 import java.util.Optional;
diff --git a/profiler/src/test/java/com/splunk/opentelemetry/profiler/snapshot/InterceptingContextStorageSpanTrackingActivatorTest.java b/profiler/src/test/java/com/splunk/opentelemetry/profiler/snapshot/InterceptingContextStorageSpanTrackingActivatorTest.java
@@ -1,15 +1,32 @@
+/*
+ * Copyright Splunk Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package com.splunk.opentelemetry.profiler.snapshot;
 
+import static org.junit.jupiter.api.Assertions.assertInstanceOf;
+
 import io.opentelemetry.context.ContextStorage;
 import java.util.function.Consumer;
 import java.util.function.UnaryOperator;
 import org.junit.jupiter.api.Test;
 
-import static org.junit.jupiter.api.Assertions.assertInstanceOf;
-
 class InterceptingContextStorageSpanTrackingActivatorTest {
   private final ContextStorageRecorder delegate = new ContextStorageRecorder();
-  private final InterceptingContextStorageSpanTrackingActivator activator = new InterceptingContextStorageSpanTrackingActivator(delegate);
+  private final InterceptingContextStorageSpanTrackingActivator activator =
+      new InterceptingContextStorageSpanTrackingActivator(delegate);
 
   @Test
   void interceptContextStorage() {
diff --git a/profiler/src/test/java/com/splunk/opentelemetry/profiler/snapshot/ScheduledExecutorStackTraceSamplerTest.java b/profiler/src/test/java/com/splunk/opentelemetry/profiler/snapshot/ScheduledExecutorStackTraceSamplerTest.java
@@ -23,14 +23,14 @@
 import static org.junit.jupiter.api.Assertions.assertNotNull;
 
 import io.opentelemetry.api.trace.SpanContext;
+import io.opentelemetry.sdk.trace.IdGenerator;
 import java.time.Duration;
 import java.time.Instant;
 import java.util.Collections;
 import java.util.concurrent.Callable;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.Executors;
 import java.util.stream.Collectors;
-import io.opentelemetry.sdk.trace.IdGenerator;
 import org.junit.jupiter.api.Test;
 
 class ScheduledExecutorStackTraceSamplerTest {
diff --git a/profiler/src/test/java/com/splunk/opentelemetry/profiler/snapshot/SnapshotProfilingLogExportingTest.java b/profiler/src/test/java/com/splunk/opentelemetry/profiler/snapshot/SnapshotProfilingLogExportingTest.java
@@ -47,13 +47,12 @@
 import org.junit.jupiter.params.ParameterizedTest;
 
 class SnapshotProfilingLogExportingTest {
-  @RegisterExtension private final ResetContextStorage spanTrackingActivator = new ResetContextStorage();
+  @RegisterExtension
+  private final ResetContextStorage spanTrackingActivator = new ResetContextStorage();
 
   private final InMemoryLogRecordExporter logExporter = InMemoryLogRecordExporter.create();
-  private final SnapshotProfilingSdkCustomizer customizer = Snapshotting.customizer()
-          .withRealStackTraceSampler()
-          .with(spanTrackingActivator)
-          .build();
+  private final SnapshotProfilingSdkCustomizer customizer =
+      Snapshotting.customizer().withRealStackTraceSampler().with(spanTrackingActivator).build();
 
   @RegisterExtension
   public final OpenTelemetrySdkExtension sdk =
@@ -92,11 +91,11 @@ void exportStackTracesForProfiledTraces(SpanKind kind, Tracer tracer) throws Exc
 
   private Set<String> findLabelValues(Profile profile, AttributeKey<String> key) {
     return profile.getSampleList().stream()
-            .flatMap(sampleLabels(profile))
-            .filter(label(key))
-            .map(Map.Entry::getValue)
-            .map(String::valueOf)
-            .collect(Collectors.toSet());
+        .flatMap(sampleLabels(profile))
+        .filter(label(key))
+        .map(Map.Entry::getValue)
+        .map(String::valueOf)
+        .collect(Collectors.toSet());
   }
 
   private Function<Sample, Stream<Map.Entry<String, Object>>> sampleLabels(Profile profile) {
@@ -110,7 +109,8 @@ private Predicate<Map.Entry<String, Object>> label(AttributeKey<String> key) {
   private static class ResetContextStorage implements SpanTrackingActivator, AfterEachCallback {
     @Override
     public void activate(TraceRegistry registry) {
-      ActiveSpanTracker spanTracker = new ActiveSpanTracker(ContextStorage.defaultStorage(),  registry);
+      ActiveSpanTracker spanTracker =
+          new ActiveSpanTracker(ContextStorage.defaultStorage(), registry);
       SpanTrackerProvider.INSTANCE.configure(spanTracker);
       SettableContextStorageProvider.setContextStorage(spanTracker);
     }
diff --git a/profiler/src/test/java/com/splunk/opentelemetry/profiler/snapshot/Snapshotting.java b/profiler/src/test/java/com/splunk/opentelemetry/profiler/snapshot/Snapshotting.java
diff --git a/profiler/src/test/java/com/splunk/opentelemetry/profiler/snapshot/SpanTrackerProviderTest.java b/profiler/src/test/java/com/splunk/opentelemetry/profiler/snapshot/SpanTrackerProviderTest.java
diff --git a/profiler/src/test/java/com/splunk/opentelemetry/profiler/snapshot/StackTraceBuilder.java b/profiler/src/test/java/com/splunk/opentelemetry/profiler/snapshot/StackTraceBuilder.java
