From: Philipp Date: Sun, 31 Oct 2021 19:23:23 +0000 (+0100) Subject: Fix PID at forking X-Git-Url: https://git.mxchange.org/?a=commitdiff_plain;h=a7487ee50da6c469130afdfbb2321c5bf38f0e48;p=friendica.git Fix PID at forking --- 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(); }