[v0.1.6] resolve issue with 'mysql gone away' in cron context

Author: Benjamin Calef

Model/Processor/ForkedProcessor.php

@@ -86,11 +86,14 @@ private function handleSingleChildProcesses(): void
             } else {
                 // child process
                 $this->processChild($currentPage, $totalPages, $childProcessCounter);
-                exit(0);
+                register_shutdown_function(function() {
+                    posix_kill(getmypid(), SIGKILL);
+                });
+                exit;
             }
 
             $pid = pcntl_waitpid($pid, $status);
-            if (pcntl_wexitstatus($status) != 0) {
+            if (pcntl_wtermsig($status) != 9) {
                 $this->logger->error('Error with child process', [
                     'pid' => $pid,
                     'exit_code' => $status
@@ -122,7 +125,7 @@ private function handleMultipleChildProcesses(): void
             // manage children
             while ($childProcessCounter >= $this->maxChildrenProcess) {
                 $pid = pcntl_wait($status);
-                if (pcntl_wexitstatus($status) != 0) {
+                if (pcntl_wtermsig($status) != 9) {
                     $this->logger->error('Error with child process', [
                         'pid' => $pid,
                         'exit_code' => $status
@@ -143,7 +146,10 @@ private function handleMultipleChildProcesses(): void
             } else {
                 // child process
                 $this->processChild($currentPage, $totalPages, $childProcessCounter);
-                exit(0);
+                register_shutdown_function(function() {
+                    posix_kill(getmypid(), SIGKILL);
+                });
+                exit;
             }
 
             $currentPage++;
@@ -157,7 +163,7 @@ private function handleMultipleChildProcesses(): void
         while ($childProcessCounter > 0) {
             $pid = pcntl_wait($status);
             $childProcessCounter--;
-            if (pcntl_wexitstatus($status) != 0) {
+            if (pcntl_wtermsig($status) != 9) {
                 $this->logger->error('Error with child process', [
                     'pid' => $pid,
                     'exit_code' => $status
@@ -202,7 +208,10 @@ private function processChild(int $currentPage, int $totalPages, int $childProce
                 'current_page' => $currentPage,
                 'exception' => $e
             ]);
-            exit(1);
+            register_shutdown_function(function() {
+                posix_kill(getmypid(), SIGABRT);
+            });
+            exit;
         }
 
         $this->logger->info('Running child process', [
@@ -229,7 +238,10 @@ private function processChild(int $currentPage, int $totalPages, int $childProce
         }
 
         if ($itemProceed === 0) {
-            exit(1);
+            register_shutdown_function(function() {
+                posix_kill(getmypid(), SIGABRT);
+            });
+            exit;
         }
 
         $this->logger->info('Finished child process', [

composer.json

@@ -2,7 +2,7 @@
     "name": "zepgram/module-multi-threading",
     "description": "This module is a powerful tool for developers who want to process large data sets in a short amount of time",
     "type": "magento2-module",
-    "version": "0.1.5",
+    "version": "0.1.6",
     "authors": [
         {
             "name": "Benjamin Calef",
@@ -12,7 +12,8 @@
     "require": {
         "magento/framework": "^101.0.0|^102.0.0|^103.0.0",
         "magento/module-store": "^101",
-        "ext-pcntl": "*"
+        "ext-pcntl": "*",
+        "ext-posix": "*"
     },
     "autoload": {
         "files": [