Skip to content
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
26 commits
Select commit Hold shift + click to select a range
c911faa
lambda
SylvainJuge Jan 20, 2025
26e79f9
inject proxies for indy
SylvainJuge Jan 20, 2025
7f3ae3b
kotlinx + integration tests
SylvainJuge Jan 21, 2025
9183992
Merge branch 'main' of github.com:open-telemetry/opentelemetry-java-i…
SylvainJuge Jan 21, 2025
29c99dd
inject missing classes for indy
SylvainJuge Jan 21, 2025
45ead47
do not inject proxies for lambda
SylvainJuge Jan 21, 2025
ba30ba8
move back comment in the expected location
SylvainJuge Jan 21, 2025
eb945b8
remove duplication
SylvainJuge Jan 22, 2025
eba7e20
add jpms compatible class file transformer
SylvainJuge Jan 22, 2025
7a1cbc7
remove lambda java9 module
SylvainJuge Jan 22, 2025
590f86e
fix pebkc
SylvainJuge Jan 22, 2025
a8cbb24
fix lambda instrumentation, must not redefine them
SylvainJuge Jan 22, 2025
403caaa
fix javadoc
SylvainJuge Jan 22, 2025
506cc62
fix things again
SylvainJuge Jan 22, 2025
da1c13d
fix it again
SylvainJuge Jan 22, 2025
c4350d0
make the comments a bit better
SylvainJuge Jan 23, 2025
1d54a14
fix typo
SylvainJuge Jan 23, 2025
03aa810
avoid injecting classes for kotlinxcoroutines
SylvainJuge Jan 24, 2025
2ed4e96
remove commented code
SylvainJuge Jan 24, 2025
77a4f00
Merge branch 'main' of github.com:open-telemetry/opentelemetry-java-i…
SylvainJuge Jan 27, 2025
d9cd13f
Merge branch 'main' of github.com:open-telemetry/opentelemetry-java-i…
SylvainJuge Jan 29, 2025
5e2ef89
Merge branch 'main' of github.com:open-telemetry/opentelemetry-java-i…
SylvainJuge Jan 30, 2025
20856e3
Merge branch 'main' of github.com:open-telemetry/opentelemetry-java-i…
SylvainJuge Jan 31, 2025
a38763f
revert commented code that was there for a reason
SylvainJuge Jan 31, 2025
b77428c
add LambdaTransformer interface + rename things
SylvainJuge Jan 31, 2025
bc785b9
fix typos and comments
SylvainJuge Jan 31, 2025
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 @@ -128,7 +128,7 @@ public void visitMethodInsn(
Opcodes.GETFIELD, slashClassName, "targetClass", "Ljava/lang/Class;");
mv.visitMethodInsn(
Opcodes.INVOKESTATIC,
Type.getInternalName(LambdaTransformer.class),
Type.getInternalName(LambdaTransformerHelper.class),
"transform",
"([BLjava/lang/String;Ljava/lang/Class;)[B",
false);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,14 +5,14 @@

package io.opentelemetry.javaagent.instrumentation.internal.lambda;

import io.opentelemetry.javaagent.bootstrap.ClassFileTransformerHolder;
import io.opentelemetry.javaagent.bootstrap.InjectedClassHelper;
import java.lang.instrument.ClassFileTransformer;
import io.opentelemetry.javaagent.bootstrap.LambdaTransformer;
import io.opentelemetry.javaagent.bootstrap.LambdaTransformerHolder;

/** Helper class for transforming lambda class bytes. */
public final class LambdaTransformer {
public final class LambdaTransformerHelper {

private LambdaTransformer() {}
private LambdaTransformerHelper() {}

/**
* Called from {@code java.lang.invoke.InnerClassLambdaMetafactory} to transform lambda class
Expand All @@ -24,18 +24,13 @@ public static byte[] transform(byte[] classBytes, String slashClassName, Class<?
if (InjectedClassHelper.isHelperClass(targetClass)) {
return classBytes;
}
ClassFileTransformer transformer = ClassFileTransformerHolder.getLambdaClassFileTransformer();
LambdaTransformer transformer = LambdaTransformerHolder.setLambdaTransformer();
if (transformer == null) {
return classBytes;
}

try {
// The 'targetClass' needs to be non-null as it is used in Java9LambdaClassFileTransformer
// to get a reference to the jpms module. However, a null value must be passed to the
// underlying transformer as this code is called when the lambda is defined.
byte[] result =
transformer.transform(
targetClass.getClassLoader(), slashClassName, targetClass, null, classBytes);
byte[] result = transformer.transform(slashClassName, targetClass, classBytes);
if (result != null) {
classBytes = result;
}
Expand Down

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1,24 @@
/*
* Copyright The OpenTelemetry Authors
* SPDX-License-Identifier: Apache-2.0
*/

package io.opentelemetry.javaagent.bootstrap;

import java.lang.instrument.IllegalClassFormatException;

/** Transformer for lambda bytecode */
public interface LambdaTransformer {

/**
* Transforms lambda bytecode for instrumentation
*
* @param className class name in JVM format with slashes
* @param targetClass target class, must not be {@literal null}
* @param classfileBuffer target class bytecode
* @return instrumented lambda bytecode
* @throws IllegalClassFormatException if bytecode is invalid
*/
byte[] transform(String className, Class<?> targetClass, byte[] classfileBuffer)
throws IllegalClassFormatException;
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,36 @@
/*
* Copyright The OpenTelemetry Authors
* SPDX-License-Identifier: Apache-2.0
*/

package io.opentelemetry.javaagent.bootstrap;

/**
* Holder for {@link LambdaTransformer} used by the instrumentation. Calling transform on this
* transformer processes given bytes the same way as they would be processed during loading of the
* class.
*/
public final class LambdaTransformerHolder {

private static volatile LambdaTransformer lambdaTransformer;

/**
* get lambda transformer
*
* @return class transformer for defining lambdas
*/
public static LambdaTransformer setLambdaTransformer() {
return lambdaTransformer;
}

/**
* set lambda transformer
*
* @param transformer transformer
*/
public static void setLambdaTransformer(LambdaTransformer transformer) {
lambdaTransformer = transformer;
}

private LambdaTransformerHolder() {}
}

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1,36 @@
/*
* Copyright The OpenTelemetry Authors
* SPDX-License-Identifier: Apache-2.0
*/

package io.opentelemetry.javaagent.tooling;

import io.opentelemetry.javaagent.bootstrap.LambdaTransformer;
import java.lang.instrument.ClassFileTransformer;
import java.lang.instrument.IllegalClassFormatException;

/** lambda transformer with java9 jpms module compatibility */
public class Java9LambdaTransformer implements LambdaTransformer {

private final ClassFileTransformer delegate;

public Java9LambdaTransformer(ClassFileTransformer delegate) {
this.delegate = delegate;
}

@Override
public byte[] transform(String className, Class<?> targetClass, byte[] classfileBuffer)
throws IllegalClassFormatException {

// lambda instrumentation happens only when the lambda is defined, thus the classBeingRedefined
// must be null otherwise we get a partial instrumentation, for example virtual fields are not
// properly applied
return delegate.transform(
targetClass.getModule(),
targetClass.getClassLoader(),
className,
null,
null,
classfileBuffer);
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -21,9 +21,10 @@
import io.opentelemetry.instrumentation.api.internal.EmbeddedInstrumentationProperties;
import io.opentelemetry.javaagent.bootstrap.AgentClassLoader;
import io.opentelemetry.javaagent.bootstrap.BootstrapPackagePrefixesHolder;
import io.opentelemetry.javaagent.bootstrap.ClassFileTransformerHolder;
import io.opentelemetry.javaagent.bootstrap.DefineClassHelper;
import io.opentelemetry.javaagent.bootstrap.InstrumentedTaskClasses;
import io.opentelemetry.javaagent.bootstrap.LambdaTransformer;
import io.opentelemetry.javaagent.bootstrap.LambdaTransformerHolder;
import io.opentelemetry.javaagent.bootstrap.http.HttpServerResponseCustomizer;
import io.opentelemetry.javaagent.bootstrap.http.HttpServerResponseCustomizerHolder;
import io.opentelemetry.javaagent.bootstrap.http.HttpServerResponseMutator;
Expand Down Expand Up @@ -200,14 +201,15 @@ private static void installBytebuddyAgent(

agentBuilder = AgentBuilderUtil.optimize(agentBuilder);
ClassFileTransformer transformer = agentBuilder.installOn(inst);
LambdaTransformer lambdaTransformer;
if (JavaModule.isSupported()) {
// wrapping in a JPMS compliant implementation
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

[for reviewer] wrapping at registration time helps to make the consumer transparently use it with java 8 API.

transformer = new Java9LambdaClassFileTransformer(transformer);
lambdaTransformer = new Java9LambdaTransformer(transformer);
} else {
// wrapping in a java 8 compliant transformer
transformer = new LambdaClassFileTransformer(transformer);
lambdaTransformer = new Java8LambdaTransformer(transformer);
}
ClassFileTransformerHolder.setLambdaClassFileTransformer(transformer);
LambdaTransformerHolder.setLambdaTransformer(lambdaTransformer);

instrumentationInstalled = true;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,31 +5,26 @@

package io.opentelemetry.javaagent.tooling;

import io.opentelemetry.javaagent.bootstrap.LambdaTransformer;
import java.lang.instrument.ClassFileTransformer;
import java.lang.instrument.IllegalClassFormatException;
import java.security.ProtectionDomain;

/** {@link ClassFileTransformer} for lambda instrumentation without jpms modules */
public class LambdaClassFileTransformer implements ClassFileTransformer {
/** lambda transformer for java < 9 without jpms modules support */
public class Java8LambdaTransformer implements LambdaTransformer {

private final ClassFileTransformer delegate;

public LambdaClassFileTransformer(ClassFileTransformer delegate) {
public Java8LambdaTransformer(ClassFileTransformer delegate) {
this.delegate = delegate;
}

@Override
public byte[] transform(
ClassLoader loader,
String className,
Class<?> classBeingRedefined,
ProtectionDomain protectionDomain,
byte[] classfileBuffer)
public byte[] transform(String className, Class<?> targetClass, byte[] classfileBuffer)
throws IllegalClassFormatException {

// lambda instrumentation happens only when the lambda is defined, thus the classBeingRedefined
// must be null otherwise we get a partial instrumentation, for example virtual fields are not
// properly applied.
return delegate.transform(loader, className, null, null, classfileBuffer);
return delegate.transform(targetClass.getClassLoader(), className, null, null, classfileBuffer);
}
}
Loading