This commit is contained in:
2021-02-23 15:40:36 +08:00
parent 7b99a5109f
commit a453caf0f4
+3 -4
View File
@@ -35,15 +35,14 @@ class OnWorkerStart extends Callback
swoole_set_process_name($get_name); swoole_set_process_name($get_name);
} }
putenv('workerId=' . ($worker_id >= $server->setting['worker_num'] ? 'Task' : 'Worker') . '.' . $worker_id);
if ($worker_id >= $server->setting['worker_num']) { if ($worker_id >= $server->setting['worker_num']) {
fire(Event::SERVER_TASK_START); fire(Event::SERVER_TASK_START);
putenv('workerId=Task.' . $worker_id); } else {
return;
}
putenv('workerId=Worker.' . $worker_id);
Snowflake::setWorkerId($server->worker_pid); Snowflake::setWorkerId($server->worker_pid);
$this->setWorkerAction($worker_id); $this->setWorkerAction($worker_id);
} }
}
/** /**
* @param $worker_id * @param $worker_id