File tree Expand file tree Collapse file tree 2 files changed +10
-8
lines changed
api/all/src/main/java/io/opentelemetry/api
sdk-extensions/autoconfigure/src/main/java/io/opentelemetry/sdk/autoconfigure Expand file tree Collapse file tree 2 files changed +10
-8
lines changed Original file line number Diff line number Diff line change 1717import io .opentelemetry .context .propagation .ContextPropagators ;
1818import java .lang .reflect .InvocationTargetException ;
1919import java .lang .reflect .Method ;
20- import java .util .function .Function ;
2120import java .util .function .Supplier ;
2221import java .util .logging .Level ;
2322import java .util .logging .Logger ;
@@ -121,8 +120,8 @@ public static void set(OpenTelemetry openTelemetry) {
121120 /**
122121 * Sets the {@link OpenTelemetry} that should be the global instance.
123122 *
124- * <p>This method calls the given {@code supplier} and calls {@link #set(OpenTelemetry)}, all while holding the
125- * {@link GlobalOpenTelemetry} mutex.
123+ * <p>This method calls the given {@code supplier} and calls {@link #set(OpenTelemetry)}, all
124+ * while holding the {@link GlobalOpenTelemetry} mutex.
126125 */
127126 public static void set (Supplier <OpenTelemetry > supplier ) {
128127 synchronized (mutex ) {
Original file line number Diff line number Diff line change 4141import java .util .HashMap ;
4242import java .util .List ;
4343import java .util .Map ;
44+ import java .util .Objects ;
4445import java .util .concurrent .atomic .AtomicReference ;
4546import java .util .function .BiFunction ;
4647import java .util .function .Function ;
@@ -429,11 +430,13 @@ public AutoConfiguredOpenTelemetrySdk build() {
429430 return buildImpl ();
430431 }
431432 AtomicReference <AutoConfiguredOpenTelemetrySdk > autoConfiguredRef = new AtomicReference <>();
432- GlobalOpenTelemetry .set (() -> {
433- autoConfiguredRef .set (buildImpl ());
434- return autoConfiguredRef .get ().getOpenTelemetrySdk ();
435- });
436- return autoConfiguredRef .get ();
433+ GlobalOpenTelemetry .set (
434+ () -> {
435+ AutoConfiguredOpenTelemetrySdk sdk = buildImpl ();
436+ autoConfiguredRef .set (sdk );
437+ return sdk .getOpenTelemetrySdk ();
438+ });
439+ return Objects .requireNonNull (autoConfiguredRef .get ());
437440 }
438441
439442 private AutoConfiguredOpenTelemetrySdk buildImpl () {
You can’t perform that action at this time.
0 commit comments