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

modify plugin name

Browse Source
This commit is contained in:
向林
2022-02-14 11:31:25 +08:00
parent fed145a43f
commit f272d8e451
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
ProcessManager.php
+3 -2
View File
@@ -39,7 +39,6 @@ class ProcessManager
*/ */
public function add(string|OnProcessInterface|BaseProcess $customProcess, string $tag = 'default') public function add(string|OnProcessInterface|BaseProcess $customProcess, string $tag = 'default')
{ {
$server = Kiri::getDi()->get(SwooleServerInterface::class);
if (is_string($customProcess)) { if (is_string($customProcess)) {
$customProcess = Kiri::getDi()->get($customProcess); $customProcess = Kiri::getDi()->get($customProcess);
} }
@@ -48,9 +47,11 @@ class ProcessManager
$this->logger->debug($system . ' ' . $customProcess->getName() . ' start.'); $this->logger->debug($system . ' ' . $customProcess->getName() . ' start.');
$process = $this->parse($customProcess, $system); $process = $this->parse($customProcess, $system);
if (Context::inCoroutine()) { if (!Kiri::getDi()->has(SwooleServerInterface::class)) {
$process->start(); $process->start();
} else { } else {
$server = Kiri::getDi()->get(SwooleServerInterface::class);
$server->addProcess($process = $this->parse($customProcess, $system)); $server->addProcess($process = $this->parse($customProcess, $system));
} }
$this->_process[$tag][$customProcess->getName()] = $process; $this->_process[$tag][$customProcess->getName()] = $process;