From 297990dd34415d425f6a94217cc767069f92b400 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=91=E6=9E=97?= Date: Fri, 18 Feb 2022 14:22:26 +0800 Subject: [PATCH] modify plugin name --- Handler/OnServerWorker.php | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/Handler/OnServerWorker.php b/Handler/OnServerWorker.php index 0902b6a..ebf6772 100644 --- a/Handler/OnServerWorker.php +++ b/Handler/OnServerWorker.php @@ -51,13 +51,13 @@ class OnServerWorker extends \Kiri\Server\Abstracts\Server $dispatch->dispatch(new OnBeforeWorkerStart($workerId)); set_env('environmental_workerId', $workerId); if ($workerId < $server->setting['worker_num']) { + set_env('environmental', Kiri::WORKER); $this->setProcessName(sprintf('Worker Process[%d].%d', $server->worker_pid, $workerId)); $dispatch->dispatch(new OnWorkerStart($server, $workerId)); - set_env('environmental', Kiri::WORKER); } else { - $dispatch->dispatch(new OnTaskStart($server, $workerId)); - $this->setProcessName(sprintf('Tasker Process[%d].%d', $server->worker_pid, $workerId)); set_env('environmental', Kiri::TASK); + $this->setProcessName(sprintf('Tasker Process[%d].%d', $server->worker_pid, $workerId)); + $dispatch->dispatch(new OnTaskStart($server, $workerId)); } $dispatch->dispatch(new OnAfterWorkerStart()); }