From f3e0f76881640ac92d34fab4ec1a5dc28b7cc787 Mon Sep 17 00:00:00 2001 From: "as2252258@163.com" Date: Fri, 9 Apr 2021 03:07:40 +0800 Subject: [PATCH] modify --- HttpServer/Events/OnWorkerStart.php | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/HttpServer/Events/OnWorkerStart.php b/HttpServer/Events/OnWorkerStart.php index 0ec245e6..d9271b31 100644 --- a/HttpServer/Events/OnWorkerStart.php +++ b/HttpServer/Events/OnWorkerStart.php @@ -56,18 +56,16 @@ class OnWorkerStart extends Callback (new Pipeline()) ->if($this->isWorker($worker_id), function ($handler, $server, $worker_id) { $annotation = Snowflake::app()->getAnnotation(); - $annotation->runtime(CONTROLLER_PATH); $annotation->runtime(APP_PATH, CONTROLLER_PATH); + $handler->onWorker($server, $server->worker_id); - name($server->worker_pid, 'Worker.' . $worker_id); }) ->else(function ($handler, $server, $worker_id) { $annotation = Snowflake::app()->getAnnotation(); $annotation->runtime(MODEL_PATH); $handler->onTask($server, $server->worker_id); - name($server->worker_pid, 'Task.' . $worker_id); }) ->catch(function (\Throwable $throwable) { logger()->addError($throwable->getMessage());