IGNITE-27929 Add parent process listener to IgniteNodeRunner (#12933)

Author: chesnokoff

modules/compatibility/src/test/java/org/apache/ignite/compatibility/testframework/junits/IgniteCompatibilityNodeRunner.java

@@ -128,6 +128,10 @@ public static void main(String[] args) throws Exception {
     /**
      * Checks that parent process is alive.
      *
+     * <p>This logic is intentionally duplicated here and in {@link IgniteNodeRunner}.
+     * Compatibility tests may run with an older {@code ignite-core-tests} on the classpath,
+     * so this runner cannot safely depend on newly added methods in {@code IgniteNodeRunner}.</p>
+     *
      * <p>We listen on {@code System.in} because this compatibility node is started by the parent JVM via
      * {@link ProcessBuilder}, where {@code System.in} is a pipe from the parent. When the parent process exits,
      * the write-end of the pipe is closed and {@code System.in.read()} returns EOF. We treat this as a signal

modules/core/src/test/java/org/apache/ignite/testframework/junits/multijvm/IgniteNodeRunner.java

@@ -67,11 +67,50 @@ public static void main(String[] args) throws Exception {
 
         X.println("Starting Ignite Node... Args=" + Arrays.toString(args));
 
+        startParentPipeWatcher();
+        
         IgniteConfiguration cfg = readCfgFromFileAndDeleteFile(args[0]);
 
         ignite = Ignition.start(cfg);
     }
 
+    /**
+     * Checks that parent process is alive.
+     *
+     * <p>We listen on {@code System.in} because this node runner is started by the parent JVM via
+     * {@link ProcessBuilder}, where {@code System.in} is a pipe from the parent. When the parent process exits,
+     * the write-end of the pipe is closed and {@code System.in.read()} returns EOF. We treat this as a signal
+     * to stop Ignite and terminate the process.</p>
+     */
+    private static void startParentPipeWatcher() {
+        Thread thread = new Thread(() -> {
+            try {
+                while (System.in.read() != -1) {
+                    // No-op
+                }
+            }
+            catch (IOException e) {
+                X.println("Failed to read parent stdin pipe, stopping Ignite node: " + e);
+            }
+
+            X.println("Parent JVM stdin pipe is closed, stopping Ignite node");
+
+            try {
+                if (ignite != null)
+                    Ignition.stop(ignite.name(), true);
+            }
+            catch (Throwable e) {
+                X.println("Failed to stop Ignite node after parent pipe closure: " + e);
+            }
+            finally {
+                System.exit(0);
+            }
+        }, "ignite-parent-pipe-watcher");
+
+        thread.setDaemon(true);
+        thread.start();
+    }
+
     /**
      * @return Ignite instance started at main.
      */