改名
This commit is contained in:
@@ -35,7 +35,7 @@ class OnWorkerStart extends Callback
|
|||||||
putenv('state=start');
|
putenv('state=start');
|
||||||
putenv('worker=' . $worker_id);
|
putenv('worker=' . $worker_id);
|
||||||
|
|
||||||
name($server->worker_pid, Snowflake::isTask() ? 'task' : 'worker');
|
name($server->worker_pid, $worker_id >= $server->setting['worker_num'] ? 'task' : 'worker');
|
||||||
|
|
||||||
if ($worker_id >= $server->setting['worker_num']) {
|
if ($worker_id >= $server->setting['worker_num']) {
|
||||||
$this->onTask($server, $worker_id);
|
$this->onTask($server, $worker_id);
|
||||||
|
|||||||
+2
-1
@@ -583,6 +583,7 @@ if (!function_exists('name')) {
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* @param int $pid
|
* @param int $pid
|
||||||
|
* @param string|null $prefix
|
||||||
* @throws ConfigException
|
* @throws ConfigException
|
||||||
* @throws Exception
|
* @throws Exception
|
||||||
*/
|
*/
|
||||||
@@ -594,7 +595,7 @@ if (!function_exists('name')) {
|
|||||||
|
|
||||||
$name = Config::get('id', false, 'system') . '[' . $pid . ']';
|
$name = Config::get('id', false, 'system') . '[' . $pid . ']';
|
||||||
if (!empty($prefix)) {
|
if (!empty($prefix)) {
|
||||||
$name .= $prefix;
|
$name .= '.' . $prefix;
|
||||||
}
|
}
|
||||||
swoole_set_process_name($name);
|
swoole_set_process_name($name);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user