Skip to content
Merged
Show file tree
Hide file tree
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
@@ -1,5 +1,6 @@
package datadog.trace.bootstrap.debugger;

import datadog.instrument.asm.Type;
import datadog.trace.api.Config;
import datadog.trace.bootstrap.debugger.util.TimeoutChecker;
import datadog.trace.bootstrap.instrumentation.api.AgentSpan;
Expand Down Expand Up @@ -100,7 +101,7 @@ public interface ExceptionDebugger {
public interface CodeOriginRecorder {
String captureCodeOrigin(boolean entry);

String captureCodeOrigin(Method method, boolean entry);
String captureCodeOrigin(String typeName, String methodName, String descriptor, boolean entry);
}

private static volatile ProbeResolver probeResolver;
Expand Down Expand Up @@ -506,11 +507,27 @@ public static void captureCodeOrigin(boolean entry) {
}
}

public static void captureCodeOrigin(
String typeName, String methodName, String descriptor, boolean entry) {
try {
CodeOriginRecorder recorder = codeOriginRecorder;
if (recorder != null) {
recorder.captureCodeOrigin(typeName, methodName, descriptor, entry);
}
} catch (Exception ex) {
LOGGER.debug("Error in captureCodeOrigin: ", ex);
}
}

public static void captureCodeOrigin(Method method, boolean entry) {
try {
CodeOriginRecorder recorder = codeOriginRecorder;
if (recorder != null) {
recorder.captureCodeOrigin(method, entry);
recorder.captureCodeOrigin(
method.getDeclaringClass().getName(),
method.getName(),
Type.getMethodDescriptor(method),
entry);
}
} catch (Exception ex) {
LOGGER.debug("Error in captureCodeOrigin: ", ex);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@

import com.datadog.debugger.agent.ConfigurationUpdater;
import com.datadog.debugger.exception.Fingerprinter;
import com.datadog.debugger.instrumentation.Types;
import com.datadog.debugger.probe.CodeOriginProbe;
import com.datadog.debugger.probe.LogProbe;
import com.datadog.debugger.probe.LogProbe.Builder;
Expand All @@ -20,7 +21,6 @@
import datadog.trace.bootstrap.instrumentation.api.AgentTracer;
import datadog.trace.util.AgentTaskScheduler;
import datadog.trace.util.stacktrace.StackWalkerFactory;
import java.lang.reflect.Method;
import java.util.Collection;
import java.util.Collections;
import java.util.HashMap;
Expand Down Expand Up @@ -82,11 +82,13 @@ public String captureCodeOrigin(boolean entry) {
}

@Override
public String captureCodeOrigin(Method method, boolean entry) {
String fingerprint = method.toString();
public String captureCodeOrigin(
String typeName, String methodName, String descriptor, boolean entry) {
String fingerprint = typeName + "." + methodName + descriptor;
CodeOriginProbe probe = probesByFingerprint.get(fingerprint);
if (probe == null) {
probe = createProbe(fingerprint, entry, Where.of(method));
String signature = Types.descriptorToSignature(descriptor);
probe = createProbe(fingerprint, entry, Where.of(typeName, methodName, signature));
LOG.debug("Creating probe for method {}", fingerprint);
}
return probe.getId();
Expand Down
Original file line number Diff line number Diff line change
@@ -1,22 +1,18 @@
package com.datadog.debugger.probe;

import static java.util.Arrays.stream;

import com.datadog.debugger.agent.Generated;
import com.datadog.debugger.instrumentation.Types;
import com.datadog.debugger.util.ClassFileLines;
import com.squareup.moshi.JsonAdapter;
import com.squareup.moshi.JsonReader;
import com.squareup.moshi.JsonWriter;
import java.io.IOException;
import java.lang.reflect.Method;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Objects;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import java.util.stream.Collectors;
import org.objectweb.asm.Opcodes;
import org.objectweb.asm.tree.MethodNode;

Expand Down Expand Up @@ -50,13 +46,8 @@ public static Where of(String typeName, String methodName, String signature, Str
return new Where(typeName, methodName, signature, lines, null);
}

public static Where of(Method method) {
return of(
method.getDeclaringClass().getName(),
method.getName(),
stream(method.getParameterTypes())
.map(Class::getTypeName)
.collect(Collectors.joining(", ", "(", ")")));
public static Where of(String typeName, String methodName, String signature) {
return new Where(typeName, methodName, signature, (SourceLine[]) null, null);
}

protected static SourceLine[] sourceLines(String[] defs) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -133,8 +133,8 @@ public void withDebug1() throws Exception {
final String className = "com.datadog.debugger.CodeOrigin02";
installProbes();
final Class<?> testClass = compileAndLoadClass(className);
codeOriginRecorder.captureCodeOrigin(testClass.getMethod("entry"), true);
codeOriginRecorder.captureCodeOrigin(testClass.getMethod("exit"), false);
codeOriginRecorder.captureCodeOrigin(className, "entry", "()", true);
codeOriginRecorder.captureCodeOrigin(className, "exit", "()", false);
checkResults(testClass, "fullTrace", 0);
checkResults(testClass, "debug_1", 2);
}
Expand All @@ -145,8 +145,8 @@ public void withLogProbe() throws Exception {
installProbes(
createProbeBuilder(PROBE_ID, CLASS_NAME, "entry", "()").captureSnapshot(true).build());
final Class<?> testClass = compileAndLoadClass(CLASS_NAME);
codeOriginRecorder.captureCodeOrigin(testClass.getMethod("entry"), true);
codeOriginRecorder.captureCodeOrigin(testClass.getMethod("exit"), false);
codeOriginRecorder.captureCodeOrigin(CLASS_NAME, "entry", "()", true);
codeOriginRecorder.captureCodeOrigin(CLASS_NAME, "exit", "()", false);
checkResults(testClass, "debug_1", 3);
}

Expand Down Expand Up @@ -230,7 +230,7 @@ public void testCaptureCodeOriginWithExplicitInfo()
installProbes();
CodeOriginProbe probe =
codeOriginRecorder.getProbe(
codeOriginRecorder.captureCodeOrigin(testClass.getMethod("main", int.class), true));
codeOriginRecorder.captureCodeOrigin(CLASS_NAME, "main", "(I)", true));
assertNotNull(probe, "The probe should have been created.");
assertTrue(probe.entrySpanProbe(), "Should be an entry probe.");
}
Expand All @@ -241,10 +241,8 @@ public void testDuplicateInstrumentations()
final String CLASS_NAME = "com.datadog.debugger.CodeOrigin04";
final Class<?> testClass = compileAndLoadClass(CLASS_NAME);
installProbes();
String probe1 =
codeOriginRecorder.captureCodeOrigin(testClass.getMethod("main", int.class), true);
String probe2 =
codeOriginRecorder.captureCodeOrigin(testClass.getMethod("main", int.class), true);
String probe1 = codeOriginRecorder.captureCodeOrigin(CLASS_NAME, "main", "(I)", true);
String probe2 = codeOriginRecorder.captureCodeOrigin(CLASS_NAME, "main", "(I)", true);
assertEquals(probe1, probe2);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,15 +3,17 @@
import static datadog.trace.bootstrap.debugger.DebuggerContext.captureCodeOrigin;
import static datadog.trace.bootstrap.debugger.DebuggerContext.marker;

import java.lang.reflect.Method;
import net.bytebuddy.asm.Advice;

public class CodeOriginTestAdvice {

@Advice.OnMethodEnter
@SuppressWarnings("bytebuddy-exception-suppression")
public static void onEnter(@Advice.Origin final Method method) {
public static void onEnter(
@Advice.Origin("#t") String typeName,
@Advice.Origin("#m") String methodName,
@Advice.Origin("#d") String descriptor) {
marker();
captureCodeOrigin(method, true);
captureCodeOrigin(typeName, methodName, descriptor, true);
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -8,8 +8,6 @@ import datadog.trace.instrumentation.micronaut.v4_0.MicronautDecorator
import datadog.trace.instrumentation.netty41.server.NettyHttpServerDecorator
import test.MicronautServer

import java.lang.reflect.Method

import static datadog.trace.agent.test.base.HttpServerTest.ServerEndpoint.ERROR
import static datadog.trace.agent.test.base.HttpServerTest.ServerEndpoint.EXCEPTION
import static datadog.trace.agent.test.base.HttpServerTest.ServerEndpoint.NOT_FOUND
Expand All @@ -35,7 +33,7 @@ class MicronautTest extends HttpServerTest<Object> {
}

@Override
String captureCodeOrigin(Method method, boolean entry) {
String captureCodeOrigin(String typeName, String methodName, String descriptor, boolean entry) {
invoked = true
return "done"
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,15 +3,17 @@
import static datadog.trace.bootstrap.debugger.DebuggerContext.captureCodeOrigin;
import static datadog.trace.bootstrap.debugger.DebuggerContext.marker;

import java.lang.reflect.Method;
import net.bytebuddy.asm.Advice;

public class EntrySpanOriginAdvice {

@Advice.OnMethodEnter
@SuppressWarnings("bytebuddy-exception-suppression")
public static void onEnter(@Advice.Origin final Method method) {
public static void onEnter(
@Advice.Origin("#t") String typeName,
@Advice.Origin("#m") String methodName,
@Advice.Origin("#d") String descriptor) {
marker();
captureCodeOrigin(method, true);
captureCodeOrigin(typeName, methodName, descriptor, true);
}
}
Loading