Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -286,47 +286,47 @@ private void setSpanAttributes(ThreadContext threadContext, @Nullable Map<String

@Override
public void addError(String spanId, Throwable throwable) {
final var span = Span.fromContextOrNull(spans.get(spanId));
final var span = spanFromContextOrNullWithoutLogging(spans.get(spanId));
if (span != null) {
span.recordException(throwable);
}
}

@Override
public void setAttribute(String spanId, String key, boolean value) {
final var span = Span.fromContextOrNull(spans.get(spanId));
final var span = spanFromContextOrNullWithoutLogging(spans.get(spanId));
if (span != null) {
span.setAttribute(key, value);
}
}

@Override
public void setAttribute(String spanId, String key, double value) {
final var span = Span.fromContextOrNull(spans.get(spanId));
final var span = spanFromContextOrNullWithoutLogging(spans.get(spanId));
if (span != null) {
span.setAttribute(key, value);
}
}

@Override
public void setAttribute(String spanId, String key, long value) {
final var span = Span.fromContextOrNull(spans.get(spanId));
final var span = spanFromContextOrNullWithoutLogging(spans.get(spanId));
if (span != null) {
span.setAttribute(key, value);
}
}

@Override
public void setAttribute(String spanId, String key, String value) {
final var span = Span.fromContextOrNull(spans.get(spanId));
final var span = spanFromContextOrNullWithoutLogging(spans.get(spanId));
if (span != null) {
span.setAttribute(key, value);
}
}

@Override
public void stopTrace(String spanId) {
final var span = Span.fromContextOrNull(spans.remove(spanId));
final var span = spanFromContextOrNullWithoutLogging(spans.remove(spanId));
if (span != null) {
logger.trace("Finishing trace [{}]", spanId);
span.end();
Expand All @@ -335,12 +335,18 @@ public void stopTrace(String spanId) {

@Override
public void addEvent(String spanId, String eventName) {
final var span = Span.fromContextOrNull(spans.get(spanId));
final var span = spanFromContextOrNullWithoutLogging(spans.get(spanId));
if (span != null) {
span.addEvent(eventName);
}
}

private static Span spanFromContextOrNullWithoutLogging(Context context) {
// Span.fromContextOrNull(null) is super-expensive today, see https://github.com/elastic/elasticsearch/issues/89107
// and https://github.com/open-telemetry/opentelemetry-java/pull/4663
return context == null ? null : Span.fromContextOrNull(context);
}

private static class MapKeyGetter implements TextMapGetter<Map<String, String>> {

@Override
Expand Down