as2252258/kiri-http-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

变更

Browse Source
This commit is contained in:
as2252258@163.com
2022-10-11 23:27:56 +08:00
parent cc095d2866
commit d3ef6da34a
1 changed files with 21 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Abstracts/ProcessManager.php
+19 -14
View File
@@ -73,13 +73,7 @@ class ProcessManager extends Component
throw new Exception('Process(' . $custom->getName() . ') is exists.'); throw new Exception('Process(' . $custom->getName() . ') is exists.');
} }
$this->_process[$custom->getName()] = new Process(function (Process $process) use ($custom) { $this->_process[$custom->getName()] = new Process(function (Process $process) use ($custom) {
set_env('environmental', Kiri::PROCESS); $this->extracted($custom, $process);
$system = sprintf('[%s].Custom Process', Config::get('id', 'system-service'));
Kiri::getLogger()->alert($system . ' ' . $custom->getName() . ' start.');
if (Kiri::getPlatform()->isLinux()) {
$process->name($system . '[' . $process->pid . '].' . $custom->getName());
}
$custom->onSigterm()->process($process);
}, },
$custom->getRedirectStdinAndStdout(), $custom->getRedirectStdinAndStdout(),
$custom->getPipeType(), $custom->getPipeType(),
@@ -106,13 +100,7 @@ class ProcessManager extends Component
public function resolve(BaseProcess $customProcess): Closure public function resolve(BaseProcess $customProcess): Closure
{ {
return static function (Process $process) use ($customProcess) { return static function (Process $process) use ($customProcess) {
set_env('environmental', Kiri::PROCESS); $this->extracted($customProcess, $process);
$system = sprintf('[%s].Custom Process', Config::get('id', 'system-service'));
Kiri::getLogger()->alert($system . ' ' . $customProcess->getName() . ' start.');
if (Kiri::getPlatform()->isLinux()) {
$process->name($system . '[' . $process->pid . '].' . $customProcess->getName());
}
$customProcess->onSigterm()->process($process);
}; };
} }
@@ -179,5 +167,22 @@ class ProcessManager extends Component
$process->write($message); $process->write($message);
} }
/**
* @param mixed $custom
* @param Process $process
* @return void
* @throws Kiri\Exception\ConfigException
*/
public function extracted(mixed $custom, Process $process): void
{
set_env('environmental', Kiri::PROCESS);
$system = sprintf('[%s].Custom Process', Config::get('id', 'system-service'));
Kiri::getLogger()->alert($system . ' ' . $custom->getName() . ' start.');
if (Kiri::getPlatform()->isLinux()) {
$process->name($system . '[' . $process->pid . '].' . $custom->getName());
}
$custom->onSigterm()->process($process);
}
} }