From b70225ec111ff670cf3e29ba94da6fea4822a2d4 Mon Sep 17 00:00:00 2001 From: "as2252258@163.com" Date: Sun, 28 Feb 2021 00:08:33 +0800 Subject: [PATCH] modify --- HttpServer/Events/OnWorkerStart.php | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/HttpServer/Events/OnWorkerStart.php b/HttpServer/Events/OnWorkerStart.php index 03b75e0a..457ded07 100644 --- a/HttpServer/Events/OnWorkerStart.php +++ b/HttpServer/Events/OnWorkerStart.php @@ -68,16 +68,16 @@ class OnWorkerStart extends Callback public function onSignal($server, $worker_id) { $this->debug(sprintf(workerName($worker_id) . ' #%d is start.....', $worker_id)); - Coroutine\go(function (Server $server) { + Coroutine\go(function (Server $server, $worker_id) { $sigkill = Coroutine::waitSignal($this->signal); if ($sigkill === false) { - return $server->stop(); + return $server->stop($worker_id, true); } while (Co::stats()['coroutine_num'] > 0) { Coroutine::sleep(0.01); } - return $server->stop(-1, true); - }, $server); + return $server->stop($worker_id, true); + }, $server, $worker_id); }