From a7487ee50da6c469130afdfbb2321c5bf38f0e48 Mon Sep 17 00:00:00 2001 From: Philipp Date: Sun, 31 Oct 2021 20:23:23 +0100 Subject: [PATCH] Fix PID at forking --- src/Core/Worker.php | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/Core/Worker.php b/src/Core/Worker.php index faa29717c1..a4f14a48c4 100644 --- a/src/Core/Worker.php +++ b/src/Core/Worker.php @@ -1183,22 +1183,22 @@ class Worker DBA::connect(); DI::flushLogger(); - $process = DI::process()->create($pid); + $process = DI::process()->create(getmypid()); $cycles = 0; - while (!self::IPCJobsExists($pid) && (++$cycles < 100)) { + while (!self::IPCJobsExists($process->pid) && (++$cycles < 100)) { usleep(10000); } - Logger::info('Worker spawned', ['pid' => $pid, 'wait_cycles' => $cycles]); + Logger::info('Worker spawned', ['pid' => $process->pid, 'wait_cycles' => $cycles]); self::processQueue($do_cron, $process); self::unclaimProcess($process); - self::IPCSetJobState(false, $pid); + self::IPCSetJobState(false, $process->pid); DI::process()->delete($process); - Logger::info('Worker ended', ['pid' => $pid]); + Logger::info('Worker ended', ['pid' => $process->pid]); exit(); }