Revert "改名"
This reverts commit fdf58326
This commit is contained in:
+9
-1
@@ -3,12 +3,14 @@
|
||||
namespace Kiri\Server;
|
||||
|
||||
use Kiri\Abstracts\Config;
|
||||
use Kiri\Annotation\Inject;
|
||||
use Kiri\Context;
|
||||
use Kiri\Exception\ConfigException;
|
||||
use Kiri\Kiri;
|
||||
use Kiri\Server\Abstracts\BaseProcess;
|
||||
use Kiri\Server\Broadcast\Message;
|
||||
use Kiri\Server\Contract\OnProcessInterface;
|
||||
use Psr\Log\LoggerInterface;
|
||||
use Swoole\Coroutine;
|
||||
use Swoole\Process;
|
||||
|
||||
@@ -20,6 +22,9 @@ class ProcessManager
|
||||
private array $_process = [];
|
||||
|
||||
|
||||
#[Inject(LoggerInterface::class)]
|
||||
public LoggerInterface $logger;
|
||||
|
||||
/**
|
||||
* @param string|OnProcessInterface|BaseProcess $customProcess
|
||||
* @return void
|
||||
@@ -31,8 +36,11 @@ class ProcessManager
|
||||
if (is_string($customProcess)) {
|
||||
$customProcess = Kiri::getDi()->get($customProcess);
|
||||
}
|
||||
|
||||
$system = sprintf('[%s].process', Config::get('id', 'system-service'));
|
||||
$server->logger->debug($system . ' ' . $customProcess->getName() . ' start.');
|
||||
|
||||
$this->logger->debug($system . ' ' . $customProcess->getName() . ' start.');
|
||||
|
||||
$server->addProcess($process = $this->parse($customProcess, $system));
|
||||
$this->_process[$customProcess->getName()] = $process;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user