This commit is contained in:
2021-03-29 11:41:46 +08:00
parent 118ac9efe5
commit 98778b69fb
4 changed files with 16 additions and 17 deletions
+3 -3
View File
@@ -35,7 +35,7 @@ class OnWorkerStart extends Callback
putenv('state=start');
putenv('worker=' . $worker_id);
name($server->worker_pid);
name($server->worker_pid, Snowflake::isTask() ? 'task' : 'worker');
if ($worker_id >= $server->setting['worker_num']) {
$this->onTask($server, $worker_id);
@@ -54,9 +54,9 @@ class OnWorkerStart extends Callback
{
putenv('environmental=' . Snowflake::TASK);
Snowflake::setTaskId($server->worker_pid);
Snowflake::setTaskId($server->worker_pid);
fire(Event::SERVER_TASK_START);
fire(Event::SERVER_TASK_START);
}