Disable Unsafe access for RxJavas in fault-tolerance

quarkusio · Oct 8, 2018 · 95c6a78 · 95c6a78
1 parent fbef4f5
commit 95c6a78
Show file tree

Hide file tree

Showing 3 changed files with 23 additions and 0 deletions.
diff --git a/fault-tolerance/deployment/pom.xml b/fault-tolerance/deployment/pom.xml
@@ -21,6 +21,12 @@
       <groupId>org.jboss.shamrock</groupId>
       <artifactId>shamrock-fault-tolerance-runtime</artifactId>
     </dependency>
+    <dependency>
+      <groupId>org.jboss.graalvm</groupId>
+      <artifactId>graal-annotations</artifactId>
+      <version>1.0.0-rc4</version>
+      <scope>provided</scope>
+    </dependency>
   </dependencies>
 
 </project>
diff --git a/.../java/org/jboss/shamrock/faulttolerance/deployment/FaultToleranceAnnotationProcessor.java b/.../java/org/jboss/shamrock/faulttolerance/deployment/FaultToleranceAnnotationProcessor.java
@@ -56,6 +56,9 @@ public void process(ArchiveContext archiveContext, ProcessorContext processorCon
 
         IndexView index = archiveContext.getCombinedIndex();
 
+        //Make sure rx.internal.util.unsafe.UnsafeAccess.DISABLED_BY_USER is set.
+        processorContext.addNativeImageSystemProperty( "rx.unsafe-disable", "true" );
+
         // Add reflective acccess to fallback handlers
         Collection<ClassInfo> fallbackHandlers = index.getAllKnownImplementors(DotName.createSimple(FallbackHandler.class.getName()));
         for (ClassInfo fallbackHandler : fallbackHandlers) {

diff --git a/.../java/org/jboss/shamrock/faulttolerance/deployment/substitutions/rxjava/UnsafeAccess.java b/.../java/org/jboss/shamrock/faulttolerance/deployment/substitutions/rxjava/UnsafeAccess.java
@@ -0,0 +1,14 @@
+package org.jboss.shamrock.faulttolerance.deployment.substitutions.rxjava;
+
+import com.oracle.svm.core.annotate.Substitute;
+import com.oracle.svm.core.annotate.TargetClass;
+
+@TargetClass(className = "rx.internal.util.unsafe.UnsafeAccess")
+public final class UnsafeAccess {
+
+	@Substitute
+	public static boolean isUnsafeAvailable() {
+		return false;
+	}
+
+}