as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2021-03-04 10:48:29 +08:00
parent 2451737d88
commit bfee7ca962
1 changed files with 14 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
HttpServer/Events/OnWorkerStart.php
+14 -9
View File
@@ -40,28 +40,31 @@ class OnWorkerStart extends Callback
annotation()->read(APP_PATH . 'app', 'App'); annotation()->read(APP_PATH . 'app', 'App');
$this->debug(sprintf('scan app dir use time %s', microtime(true) - $start)); $this->debug(sprintf('scan app dir use time %s', microtime(true) - $start));
$prefix = sprintf('%s #%d Pid:%d start.', ucfirst(env('environmental')), $worker_id, $server->worker_pid);
if ($worker_id >= $server->setting['worker_num']) { if ($worker_id >= $server->setting['worker_num']) {
$this->onTask($server, $worker_id); $this->onTask($server, $worker_id, $prefix);
} else { } else {
$this->onWorker($server, $worker_id); $this->onWorker($server, $worker_id, $prefix);
} }
$this->debug(sprintf('%s #%d Pid:%d start.', ucfirst(env('environmental')), $worker_id, $server->worker_pid));
} }
/** /**
* @param Server $server * @param Server $server
* @param int $worker_id * @param int $worker_id
* @throws ComponentException|ConfigException * @param $prefix
* @throws ComponentException
* @throws ConfigException
*/ */
public function onTask(Server $server, int $worker_id) public function onTask(Server $server, int $worker_id, $prefix)
{ {
putenv('environmental=' . Snowflake::TASK); putenv('environmental=' . Snowflake::TASK);
$start = microtime(true); $start = microtime(true);
fire(Event::SERVER_TASK_START); fire(Event::SERVER_TASK_START);
$this->debug(sprintf('Event::SERVER_WORKER_START use time %s', microtime(true) - $start)); $this->debug(sprintf('%s use time %s', $prefix, microtime(true) - $start));
$this->set_process_name($server, $worker_id); $this->set_process_name($server, $worker_id);
} }
@@ -70,17 +73,19 @@ class OnWorkerStart extends Callback
/** /**
* @param Server $server * @param Server $server
* @param int $worker_id * @param int $worker_id
* @param $prefix
* @throws ComponentException
* @throws ConfigException
* @throws Exception * @throws Exception
* onWorker
*/ */
public function onWorker(Server $server, int $worker_id) public function onWorker(Server $server, int $worker_id, $prefix)
{ {
Snowflake::setWorkerId($server->worker_pid); Snowflake::setWorkerId($server->worker_pid);
putenv('environmental=' . Snowflake::WORKER); putenv('environmental=' . Snowflake::WORKER);
try { try {
$start = microtime(true); $start = microtime(true);
fire(Event::SERVER_WORKER_START, [$worker_id]); fire(Event::SERVER_WORKER_START, [$worker_id]);
$this->debug(sprintf('Event::SERVER_WORKER_START use time %s', microtime(true) - $start)); $this->debug(sprintf('%s use time %s', $prefix, microtime(true) - $start));
} catch (\Throwable $exception) { } catch (\Throwable $exception) {
$this->addError($exception); $this->addError($exception);
write($exception->getMessage(), 'worker'); write($exception->getMessage(), 'worker');