modify plugin name

This commit is contained in:
2022-02-18 14:01:24 +08:00
parent 28d3d48ab0
commit 7e87d86546
2 changed files with 3 additions and 3 deletions
+2 -2
View File
@@ -51,12 +51,12 @@ class OnServerWorker extends \Kiri\Server\Abstracts\Server
$dispatch->dispatch(new OnBeforeWorkerStart($workerId)); $dispatch->dispatch(new OnBeforeWorkerStart($workerId));
set_env('environmental_workerId', $workerId); set_env('environmental_workerId', $workerId);
if ($workerId < $server->setting['worker_num']) { if ($workerId < $server->setting['worker_num']) {
$this->setProcessName(sprintf('Worker[%d].%d', $server->worker_pid, $workerId)); $this->setProcessName(sprintf('Worker Process[%d].%d', $server->worker_pid, $workerId));
$dispatch->dispatch(new OnWorkerStart($server, $workerId)); $dispatch->dispatch(new OnWorkerStart($server, $workerId));
set_env('environmental', Kiri::WORKER); set_env('environmental', Kiri::WORKER);
} else { } else {
$dispatch->dispatch(new OnTaskStart($server, $workerId)); $dispatch->dispatch(new OnTaskStart($server, $workerId));
$this->setProcessName(sprintf('Tasker[%d].%d', $server->worker_pid, $workerId)); $this->setProcessName(sprintf('Tasker Process[%d].%d', $server->worker_pid, $workerId));
set_env('environmental', Kiri::TASK); set_env('environmental', Kiri::TASK);
} }
$dispatch->dispatch(new OnAfterWorkerStart()); $dispatch->dispatch(new OnAfterWorkerStart());
+1 -1
View File
@@ -43,7 +43,7 @@ class ProcessManager
$customProcess = Kiri::getDi()->get($customProcess); $customProcess = Kiri::getDi()->get($customProcess);
} }
$system = sprintf('[%s].process', Config::get('id', 'system-service')); $system = sprintf('[%s].Custom Process', Config::get('id', 'system-service'));
$this->logger->debug($system . ' ' . $customProcess->getName() . ' start.'); $this->logger->debug($system . ' ' . $customProcess->getName() . ' start.');
$process = $this->parse($customProcess, $system); $process = $this->parse($customProcess, $system);