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-18 14:22:26 +08:00
parent 7e87d86546
commit 297990dd34
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Handler/OnServerWorker.php
+3 -3
View File
@@ -51,13 +51,13 @@ 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']) {
set_env('environmental', Kiri::WORKER);
$this->setProcessName(sprintf('Worker Process[%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);
} else { } else {
$dispatch->dispatch(new OnTaskStart($server, $workerId));
$this->setProcessName(sprintf('Tasker Process[%d].%d', $server->worker_pid, $workerId));
set_env('environmental', Kiri::TASK); 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()); $dispatch->dispatch(new OnAfterWorkerStart());
} }