Set the new pid

diff --git a/src/Core/Process.php b/src/Core/Process.php
index 919d37dea1faacad4469cb03ed4d375c7ec1bc77..447d312d44d3e20bc152d85d1f761c52b5a2c55f 100644 (file)
--- a/src/Core/Process.php
+++ b/src/Core/Process.php
@@ -77,6 +77,17 @@ class Process
                $this->pid = $pid;
        }
 
+       /**
+        * Set the process id
+        *
+        * @param integer $pid
+        * @return void
+        */
+       public function setPid(int $pid)
+       {
+               $this->pid = $pid;
+       }
+
        /**
         * Log active processes into the "process" table
         */

diff --git a/src/Core/Worker.php b/src/Core/Worker.php
index d2468a2a804bf1f427108a48f9f196c0cae03fb9..54bfdedf3ef0df4ea2a6f4a0feedbaabe8080f05 100644 (file)
--- a/src/Core/Worker.php
+++ b/src/Core/Worker.php
@@ -1234,6 +1234,7 @@ class Worker
                // We now are in the new worker
                DBA::connect();
                /// @todo Reinitialize the logger to set a new process_id and uid
+               DI::process()->setPid($pid);
 
                $cycles = 0;
                while (!self::IPCJobsExists($pid) && (++$cycles < 100)) {