in universal-profiling-integration/src/main/java/co/elastic/otel/UniversalProfilingProcessor.java [240:253]
private void onContextChange(@Nullable Context previous, @Nullable Context next) {
if (!tlsPropagationActive) {
return;
}
try {
Span oldSpan = safeSpanFromContext(previous);
Span newSpan = safeSpanFromContext(next);
if (oldSpan != newSpan && !oldSpan.getSpanContext().equals(newSpan.getSpanContext())) {
ProfilerSharedMemoryWriter.updateThreadCorrelationStorage(newSpan);
}
} catch (Throwable t) {
log.log(Level.SEVERE, "Error on context update", t);
}
}