From 2f8e873cc7b7ff56bd77480893e03bb9ff3b5315 Mon Sep 17 00:00:00 2001 From: Michael Date: Tue, 5 Jan 2021 16:47:55 +0000 Subject: [PATCH] Wait for parent --- src/Core/Worker.php | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/src/Core/Worker.php b/src/Core/Worker.php index 619cb5bfa..d2468a2a8 100644 --- a/src/Core/Worker.php +++ b/src/Core/Worker.php @@ -1234,9 +1234,13 @@ class Worker // We now are in the new worker DBA::connect(); /// @todo Reinitialize the logger to set a new process_id and uid - - self::IPCSetJobState(true, getmypid()); - Logger::info('Worker spawned', ['pid' => getmypid()]); + + $cycles = 0; + while (!self::IPCJobsExists($pid) && (++$cycles < 100)) { + usleep(10000); + } + + Logger::info('Worker spawned', ['pid' => getmypid(), 'wait_cycles' => $cycles]); self::processQueue($do_cron);