diff --git a/HttpServer/Events/OnStart.php b/HttpServer/Events/OnStart.php index e5fad17a..ff6e6a9b 100644 --- a/HttpServer/Events/OnStart.php +++ b/HttpServer/Events/OnStart.php @@ -5,6 +5,7 @@ namespace HttpServer\Events; use HttpServer\Abstracts\Callback; +use Snowflake\Abstracts\Config; use Snowflake\Event; use Snowflake\Snowflake; use Swoole\Server; @@ -19,11 +20,15 @@ class OnStart extends Callback public function onHandler($server) { Snowflake::setProcessId($server->master_pid); - + $event = Snowflake::app()->event; if ($event->exists(Event::SERVER_EVENT_START)) { $event->trigger(Event::SERVER_EVENT_START, null, $server); } + + if (Snowflake::isLinux()) { + name(rtrim(Config::get('id', 'system:'), ':')); + } } } diff --git a/HttpServer/Events/OnWorkerStart.php b/HttpServer/Events/OnWorkerStart.php index df54a916..b82d5899 100644 --- a/HttpServer/Events/OnWorkerStart.php +++ b/HttpServer/Events/OnWorkerStart.php @@ -9,8 +9,10 @@ use HttpServer\Abstracts\Callback; use HttpServer\Route\Annotation\Websocket as AWebsocket; use HttpServer\Service\Http; use HttpServer\Service\Websocket; +use Snowflake\Abstracts\Config; use Snowflake\Error\Logger; use Snowflake\Event; +use Snowflake\Exception\ConfigException; use Snowflake\Snowflake; use Swoole\Server; @@ -66,10 +68,11 @@ class OnWorkerStart extends Callback * @param $socket * @param $worker_id * @return string + * @throws ConfigException */ private function get_process_name($socket, $worker_id) { - $prefix = 'system:'; + $prefix = rtrim(Config::get('id', 'system:'), ':'); if ($worker_id >= $socket->setting['worker_num']) { return $prefix . ': Task: No.' . $worker_id; } else {