Add initial support of Project CRaC

Author: AntonKozlov

bom/application/pom.xml

@@ -198,6 +198,7 @@
         <strimzi-oauth.version>0.10.0</strimzi-oauth.version>
         <strimzi-oauth.nimbus.version>9.22</strimzi-oauth.nimbus.version>
         <java-buildpack-client.version>0.0.6</java-buildpack-client.version>
+        <org-crac.version>0.1.1</org-crac.version>
     </properties>
 
     <dependencyManagement>
@@ -5544,6 +5545,11 @@
                 <artifactId>quarkus-awt-deployment</artifactId>
                 <version>${project.version}</version>
             </dependency>
+            <dependency>
+                <groupId>io.github.crac</groupId>
+                <artifactId>org-crac</artifactId>
+                <version>${org-crac.version}</version>
+            </dependency>
 
             <!-- Relocations -->
             <dependency>

core/runtime/pom.xml

@@ -223,6 +223,8 @@
                         <runnerParentFirstArtifact>org.wildfly.common:wildfly-common</runnerParentFirstArtifact>
                         <!-- This is needed because it contains some jar handling classes -->
                         <runnerParentFirstArtifact>io.smallrye.common:smallrye-common-io</runnerParentFirstArtifact>
+                        <!-- QuarkusEntryPoint needs org-crac class definition -->
+                        <runnerParentFirstArtifact>io.github.crac:org-crac</runnerParentFirstArtifact>
                     </runnerParentFirstArtifacts>
                     <excludedArtifacts>
                         <excludedArtifact>io.smallrye:smallrye-config</excludedArtifact>

extensions/vertx-http/runtime/pom.xml

@@ -66,6 +66,10 @@
             <artifactId>svm</artifactId>
             <scope>provided</scope>
         </dependency>
+        <dependency>
+            <groupId>io.github.crac</groupId>
+            <artifactId>org-crac</artifactId>
+        </dependency>
         <!-- Test dependencies -->
         <dependency>
             <groupId>org.junit.jupiter</groupId>

extensions/vertx-http/runtime/src/main/java/io/quarkus/vertx/http/runtime/VertxHttpRecorder.java

@@ -37,6 +37,7 @@
 
 import javax.enterprise.event.Event;
 
+import org.crac.Resource;
 import org.jboss.logging.Logger;
 import org.wildfly.common.cpu.ProcessorInfo;
 
@@ -1039,7 +1040,7 @@ public GracefulShutdownFilter createGracefulShutdownHandler() {
         return new GracefulShutdownFilter();
     }
 
-    private static class WebDeploymentVerticle extends AbstractVerticle {
+    private static class WebDeploymentVerticle extends AbstractVerticle implements Resource {
 
         private HttpServer httpServer;
         private HttpServer httpsServer;
@@ -1065,6 +1066,7 @@ public WebDeploymentVerticle(HttpServerOptions httpOptions, HttpServerOptions ht
             this.insecureRequests = insecureRequests;
             this.quarkusConfig = quarkusConfig;
             this.connectionCount = connectionCount;
+            org.crac.Core.getGlobalContext().register(this);
         }
 
         @Override
@@ -1294,6 +1296,24 @@ public void stop(Promise<Void> stopFuture) {
         private String propertyWithProfilePrefix(String portPropertyName) {
             return "%" + launchMode.getDefaultProfile() + "." + portPropertyName;
         }
+
+        @Override
+        public void beforeCheckpoint(org.crac.Context<? extends Resource> context) throws Exception {
+            Promise<Void> p = Promise.promise();
+            stop(p);
+            CountDownLatch latch = new CountDownLatch(1);
+            p.future().onComplete(event -> latch.countDown());
+            latch.await();
+        }
+
+        @Override
+        public void afterRestore(org.crac.Context<? extends Resource> context) throws Exception {
+            Promise<Void> p = Promise.promise();
+            start(p);
+            CountDownLatch latch = new CountDownLatch(1);
+            p.future().onComplete(event -> latch.countDown());
+            latch.await();
+        }
     }
 
     protected static ServerBootstrap virtualBootstrap;

independent-projects/bootstrap/bom/pom.xml

@@ -343,6 +343,11 @@
                 <artifactId>jsoup</artifactId>
                 <version>${jsoup.version}</version>
             </dependency>
+            <dependency>
+                <groupId>io.github.crac</groupId>
+                <artifactId>org-crac</artifactId>
+                <version>${org-crac.version}</version>
+            </dependency>
             <!-- Smallrye Common dependencies, imported as a BOM -->
             <dependency>
                 <groupId>io.smallrye.common</groupId>

independent-projects/bootstrap/pom.xml

@@ -67,6 +67,7 @@
         <smallrye-common.version>1.11.0</smallrye-common.version>
         <gradle-tooling.version>7.4.2</gradle-tooling.version>
         <quarkus-fs-util.version>0.0.9</quarkus-fs-util.version>
+        <org-crac.version>0.1.1</org-crac.version>
     </properties>
     <modules>
         <module>bom</module>

independent-projects/bootstrap/runner/pom.xml

@@ -50,6 +50,10 @@
             <groupId>org.jboss.logging</groupId>
             <artifactId>jboss-logging</artifactId>
         </dependency>
+        <dependency>
+            <groupId>io.github.crac</groupId>
+            <artifactId>org-crac</artifactId>
+        </dependency>
         <dependency>
             <groupId>org.junit.jupiter</groupId>
             <artifactId>junit-jupiter</artifactId>

independent-projects/bootstrap/runner/src/main/java/io/quarkus/bootstrap/runner/RunnerClassLoader.java

@@ -7,6 +7,8 @@
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
+import org.crac.Context;
+import org.crac.Resource;
 
 /**
  * Classloader used with the fast-jar package type.
@@ -41,6 +43,8 @@ public final class RunnerClassLoader extends ClassLoader {
     //Protected by synchronization on the above field, as they are related.
     private boolean postBootPhase = false;
 
+    private final CracResource resource;
+
     RunnerClassLoader(ClassLoader parent, Map<String, ClassLoadingResource[]> resourceDirectoryMap,
             Set<String> parentFirstPackages, Set<String> nonExistentResources,
             List<String> fullyIndexedDirectories, Map<String, ClassLoadingResource[]> directlyIndexedResourcesIndexMap) {
@@ -50,6 +54,9 @@ public final class RunnerClassLoader extends ClassLoader {
         this.nonExistentResources = nonExistentResources;
         this.fullyIndexedDirectories = fullyIndexedDirectories;
         this.directlyIndexedResourcesIndexMap = directlyIndexedResourcesIndexMap;
+
+        resource = new CracResource();
+        org.crac.Core.getGlobalContext().register(resource);
     }
 
     @Override
@@ -290,4 +297,22 @@ public void resetInternalCaches() {
             this.postBootPhase = true;
         }
     }
+
+    class CracResource implements Resource {
+        @Override
+        public void beforeCheckpoint(Context<? extends Resource> ctx) {
+            synchronized (currentlyBufferedResources) {
+                for (int i = 0; i < currentlyBufferedResources.length; ++i) {
+                    if (currentlyBufferedResources[i] != null) {
+                        currentlyBufferedResources[i].resetInternalCaches();
+                        currentlyBufferedResources[i] = null;
+                    }
+                }
+            }
+        }
+
+        @Override
+        public void afterRestore(Context<? extends Resource> ctx) {
+        }
+    }
 }