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

run formatter

This commit is contained in:
Marco Ferrer 2019-09-06 19:57:59 -04:00
parent 8ee5d8ddc0
commit bcfb2ac3e7
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -7,10 +7,10 @@ import datadog.trace.context.TraceScope;
import io.grpc.ForwardingServerCall;
import io.grpc.ForwardingServerCallListener;
import io.grpc.Metadata;
import io.grpc.Status;
import io.grpc.ServerCall;
import io.grpc.ServerCallHandler;
import io.grpc.ServerInterceptor;
import io.grpc.Status;
import io.opentracing.Scope;
import io.opentracing.Span;
import io.opentracing.SpanContext;
@ -64,7 +64,8 @@ public class TracingServerInterceptor implements ServerInterceptor {
try {
// Wrap the server call so that we can decorate the span
// with the resulting status
TracingServerCall<ReqT, RespT> tracingServerCall = new TracingServerCall<>(tracer, span, call);
TracingServerCall<ReqT, RespT> tracingServerCall =
new TracingServerCall<>(tracer, span, call);
// call other interceptors
result = next.startCall(tracingServerCall, headers);
@ -85,11 +86,12 @@ public class TracingServerInterceptor implements ServerInterceptor {
}
static final class TracingServerCall<ReqT, RespT>
extends ForwardingServerCall.SimpleForwardingServerCall<ReqT, RespT> {
extends ForwardingServerCall.SimpleForwardingServerCall<ReqT, RespT> {
final Tracer tracer;
final Span span;
TracingServerCall(final Tracer tracer, final Span span, final ServerCall<ReqT, RespT> delegate) {
TracingServerCall(
final Tracer tracer, final Span span, final ServerCall<ReqT, RespT> delegate) {
super(delegate);
this.tracer = tracer;
this.span = span;
@ -98,7 +100,6 @@ public class TracingServerInterceptor implements ServerInterceptor {
@Override
public void close(final Status status, final Metadata trailers) {
DECORATE.onClose(span, status);
// Finishes span.
try (final Scope scope = tracer.scopeManager().activate(span, false)) {
if (scope instanceof TraceScope) {
((TraceScope) scope).setAsyncPropagation(true);
@ -112,7 +113,6 @@ public class TracingServerInterceptor implements ServerInterceptor {
throw e;
}
}
}
static final class TracingServerCallListener<ReqT>
@ -215,7 +215,6 @@ public class TracingServerInterceptor implements ServerInterceptor {
}
}
@Override
public void onReady() {
try (final Scope scope = tracer.scopeManager().activate(span, false)) {