open-telemetry
/
opentelemetry-java-instrumentation
mirror of https://github.com/open-telemetry/opentelemetry-java-instrumentation.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Enable executor instrumentation for gRPC server calls 

This might be more than is needed.  Maybe cut back later.
This commit is contained in:
Tyler Benson 2018-08-24 20:25:13 +10:00
parent 51d74f6147
commit 63bee3737c
1 changed files with 43 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

47
dd-java-agent/instrumentation/grpc-1.5/src/main/java/datadog/trace/instrumentation/grpc/server/TracingServerInterceptor.java
View File

@ -4,6 +4,7 @@ import static io.opentracing.log.Fields.ERROR_OBJECT;
import datadog.trace.api.DDSpanTypes; import datadog.trace.api.DDSpanTypes;
import datadog.trace.api.DDTags; import datadog.trace.api.DDTags;
import datadog.trace.context.TraceScope;
import io.grpc.ForwardingServerCallListener; import io.grpc.ForwardingServerCallListener;
import io.grpc.Metadata; import io.grpc.Metadata;
import io.grpc.ServerCall; import io.grpc.ServerCall;
@ -54,6 +55,11 @@ public class TracingServerInterceptor implements ServerInterceptor {
spanBuilder.asChildOf(spanContext); spanBuilder.asChildOf(spanContext);
} }
final Scope scope = spanBuilder.startActive(false); final Scope scope = spanBuilder.startActive(false);
if (scope instanceof TraceScope) {
((TraceScope) scope).setAsyncPropagation(true);
}
final Span span = scope.span(); final Span span = scope.span();
final ServerCall.Listener<ReqT> result; final ServerCall.Listener<ReqT> result;
@ -66,6 +72,9 @@ public class TracingServerInterceptor implements ServerInterceptor {
span.finish(); span.finish();
throw e; throw e;
} finally { } finally {
if (scope instanceof TraceScope) {
((TraceScope) scope).setAsyncPropagation(false);
}
scope.close(); scope.close();
} }
@ -95,6 +104,9 @@ public class TracingServerInterceptor implements ServerInterceptor {
.withTag(DDTags.SPAN_TYPE, DDSpanTypes.RPC) .withTag(DDTags.SPAN_TYPE, DDSpanTypes.RPC)
.withTag(Tags.SPAN_KIND.getKey(), Tags.SPAN_KIND_SERVER) .withTag(Tags.SPAN_KIND.getKey(), Tags.SPAN_KIND_SERVER)
.startActive(true); .startActive(true);
if (scope instanceof TraceScope) {
((TraceScope) scope).setAsyncPropagation(true);
}
try { try {
delegate().onMessage(message); delegate().onMessage(message);
} catch (final RuntimeException | Error e) { } catch (final RuntimeException | Error e) {
@ -104,14 +116,23 @@ public class TracingServerInterceptor implements ServerInterceptor {
this.span.finish(); this.span.finish();
throw e; throw e;
} finally { } finally {
if (scope instanceof TraceScope) {
((TraceScope) scope).setAsyncPropagation(false);
}
scope.close(); scope.close();
} }
} }
@Override @Override
public void onHalfClose() { public void onHalfClose() {
try (final Scope ignored = tracer.scopeManager().activate(span, false)) { try (final Scope scope = tracer.scopeManager().activate(span, false)) {
if (scope instanceof TraceScope) {
((TraceScope) scope).setAsyncPropagation(true);
}
delegate().onHalfClose(); delegate().onHalfClose();
if (scope instanceof TraceScope) {
((TraceScope) scope).setAsyncPropagation(false);
}
} catch (final RuntimeException | Error e) { } catch (final RuntimeException | Error e) {
Tags.ERROR.set(span, true); Tags.ERROR.set(span, true);
span.log(Collections.singletonMap(ERROR_OBJECT, e)); span.log(Collections.singletonMap(ERROR_OBJECT, e));
@ -123,9 +144,15 @@ public class TracingServerInterceptor implements ServerInterceptor {
@Override @Override
public void onCancel() { public void onCancel() {
// Finishes span. // Finishes span.
try (final Scope ignored = tracer.scopeManager().activate(span, true)) { try (final Scope scope = tracer.scopeManager().activate(span, true)) {
if (scope instanceof TraceScope) {
((TraceScope) scope).setAsyncPropagation(true);
}
delegate().onCancel(); delegate().onCancel();
span.setTag("canceled", true); span.setTag("canceled", true);
if (scope instanceof TraceScope) {
((TraceScope) scope).setAsyncPropagation(false);
}
} catch (final RuntimeException | Error e) { } catch (final RuntimeException | Error e) {
Tags.ERROR.set(span, true); Tags.ERROR.set(span, true);
span.log(Collections.singletonMap(ERROR_OBJECT, e)); span.log(Collections.singletonMap(ERROR_OBJECT, e));
@ -137,8 +164,14 @@ public class TracingServerInterceptor implements ServerInterceptor {
@Override @Override
public void onComplete() { public void onComplete() {
// Finishes span. // Finishes span.
try (final Scope ignored = tracer.scopeManager().activate(span, true)) { try (final Scope scope = tracer.scopeManager().activate(span, true)) {
if (scope instanceof TraceScope) {
((TraceScope) scope).setAsyncPropagation(true);
}
delegate().onComplete(); delegate().onComplete();
if (scope instanceof TraceScope) {
((TraceScope) scope).setAsyncPropagation(false);
}
} catch (final RuntimeException | Error e) { } catch (final RuntimeException | Error e) {
Tags.ERROR.set(span, true); Tags.ERROR.set(span, true);
span.log(Collections.singletonMap(ERROR_OBJECT, e)); span.log(Collections.singletonMap(ERROR_OBJECT, e));
@ -149,8 +182,14 @@ public class TracingServerInterceptor implements ServerInterceptor {
@Override @Override
public void onReady() { public void onReady() {
try (final Scope ignored = tracer.scopeManager().activate(span, false)) { try (final Scope scope = tracer.scopeManager().activate(span, false)) {
if (scope instanceof TraceScope) {
((TraceScope) scope).setAsyncPropagation(true);
}
delegate().onReady(); delegate().onReady();
if (scope instanceof TraceScope) {
((TraceScope) scope).setAsyncPropagation(false);
}
} catch (final RuntimeException | Error e) { } catch (final RuntimeException | Error e) {
Tags.ERROR.set(span, true); Tags.ERROR.set(span, true);
span.log(Collections.singletonMap(ERROR_OBJECT, e)); span.log(Collections.singletonMap(ERROR_OBJECT, e));