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
Expand Up @@ -17,4 +17,17 @@ public String getSimpleClassName(@QueryParam("className") String className) {
return "FAILED";
}
}

@GET
@Path("/lambda")
public String getLambdaClassName() {
try {
ResourceLambda lambda = new ResourceLambda();
Class<?> clazz = lambda.getLambdaFuncClass(5);
return clazz.getSimpleName();
} catch (Exception e) {
return e.toString();
}
}

}
Original file line number Diff line number Diff line change
@@ -0,0 +1,40 @@
package io.quarkus.it.rest;

import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.lang.invoke.SerializedLambda;
import java.util.Comparator;

import io.quarkus.runtime.annotations.RegisterForReflection;

/**
* This class is registering itself for lambda capturing
*/
@RegisterForReflection(lambdaCapturingTypes = "java.util.Comparator", targets = {
SerializedLambda.class, SerializableDoubleFunction.class }, serialization = true)
public class ResourceLambda {
private static final String file = "target/serialized.txt";

public Class<?> getLambdaFuncClass(Integer n) throws IOException, ClassNotFoundException {
SerializableDoubleFunction func = new SerializableDoubleFunction(n);
Comparator<Integer> comp = Comparator.comparingDouble(func);
serializeObject(comp);
return deserializeObject().getClass();
}

private void serializeObject(Object o) throws IOException {
FileOutputStream out = new FileOutputStream(file);
ObjectOutputStream objectOutputStream = new ObjectOutputStream(out);
objectOutputStream.writeObject(o);
objectOutputStream.close();
}

private Object deserializeObject() throws IOException, ClassNotFoundException {
FileInputStream in = new FileInputStream(file);
ObjectInputStream objectInputStream = new ObjectInputStream(in);
return objectInputStream.readObject();
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,17 @@
package io.quarkus.it.rest;

import java.io.Serializable;
import java.util.function.ToDoubleFunction;

class SerializableDoubleFunction implements Serializable, ToDoubleFunction<Integer> {
private final double value;

public SerializableDoubleFunction(double inputValue) {
value = inputValue;
}

@Override
public double applyAsDouble(Integer o) {
return value;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,7 @@ quarkus.native.resources.excludes = **/unwanted.*

quarkus.log.metrics.enabled=true

#quarkus.native.additional-build-args =-H:ReflectionConfigurationFiles=reflection-config.json,-H:SerializationConfigurationResources=serialization-config.json
quarkus.native.additional-build-args =-H:ReflectionConfigurationFiles=reflection-config.json
quarkus.class-loading.removed-resources."io.quarkus\:quarkus-integration-test-shared-library"=io/quarkus/it/shared/RemovedResource.class
quarkus.class-loading.removed-resources."io.quarkus\:quarkus-integration-test-main"=io/quarkus/it/rest/RemovedJaxRsApplication.class
Original file line number Diff line number Diff line change
@@ -0,0 +1,9 @@
{
"types":[
{"name":"io.quarkus.it.rest.SerializableDoubleFunction"},
{"name":"java.lang.invoke.SerializedLambda"}
],
"lambdaCapturingTypes":[
{"name":"java.util.Comparator"}
]
}
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package io.quarkus.it.main;

import static org.hamcrest.Matchers.is;
import static org.hamcrest.Matchers.startsWith;

import org.junit.jupiter.api.Test;

Expand Down Expand Up @@ -68,6 +69,16 @@ public void testTargetWithoutNested() {
assertRegistration("FAILED", resourceD + "$StaticClassOfD$OtherAccessibleClassOfD");
}

@Test
@DisableIfBuiltWithGraalVMOlderThan(GraalVMVersion.GRAALVM_22_1)
public void testLambdaCapturing() {
final String resourceLambda = BASE_PKG + ".ResourceLambda";

// Starting with GraalVM 22.1 support Lambda functions serialization
// (see https://github.com/oracle/graal/issues/3756)
RestAssured.given().when().get("/reflection/lambda").then().body(startsWith("Comparator$$Lambda$"));
}

private void assertRegistration(String expected, String queryParam) {
RestAssured.given().queryParam("className", queryParam).when().get(ENDPOINT).then().body(is(expected));
}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package io.quarkus.it.main;

import static org.hamcrest.Matchers.is;
import static org.hamcrest.Matchers.startsWith;

import org.junit.jupiter.api.Test;

Expand Down Expand Up @@ -51,6 +52,14 @@ public void testTargetWithoutNested() {
assertRegistration("OtherAccessibleClassOfD", resourceD + "$StaticClassOfD$OtherAccessibleClassOfD");
}

@Test
public void testLambdaCapturing() {
final String resourceLambda = BASE_PKG + ".ResourceLambda";

assertRegistration("ResourceLambda", resourceLambda);
RestAssured.given().when().get("/reflection/lambda").then().body(startsWith("Comparator$$Lambda$"));
}

private void assertRegistration(String expected, String queryParam) {
RestAssured.given().queryParam("className", queryParam).when().get(ENDPOINT).then().body(is(expected));
}
Expand Down