Set the new pid
This commit is contained in:
@@ -77,6 +77,17 @@ class Process
|
|||||||
$this->pid = $pid;
|
$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
|
* Log active processes into the "process" table
|
||||||
*/
|
*/
|
||||||
|
|||||||
@@ -1234,6 +1234,7 @@ class Worker
|
|||||||
// We now are in the new worker
|
// We now are in the new worker
|
||||||
DBA::connect();
|
DBA::connect();
|
||||||
/// @todo Reinitialize the logger to set a new process_id and uid
|
/// @todo Reinitialize the logger to set a new process_id and uid
|
||||||
|
DI::process()->setPid($pid);
|
||||||
|
|
||||||
$cycles = 0;
|
$cycles = 0;
|
||||||
while (!self::IPCJobsExists($pid) && (++$cycles < 100)) {
|
while (!self::IPCJobsExists($pid) && (++$cycles < 100)) {
|
||||||
|
|||||||
Reference in New Issue
Block a user