diff --git a/HttpServer/Events/OnWorkerStart.php b/HttpServer/Events/OnWorkerStart.php index 852f51e6..07fbeef9 100644 --- a/HttpServer/Events/OnWorkerStart.php +++ b/HttpServer/Events/OnWorkerStart.php @@ -95,10 +95,13 @@ class OnWorkerStart extends Callback public function onSignal(Server $server, $worker_id): void { $ret = Coroutine::waitSignal($this->signal, -1); - Coroutine\go(function ($ret, $server, $worker_id) { + Coroutine\go(function ($ret, Server $server, $worker_id) { if ($ret === true) { $this->ticker(); } + if ($server->getWorkerStatus($worker_id) == 3) { + return 1; + } return $server->stop($worker_id); }, $ret, $server, $worker_id); } @@ -114,8 +117,6 @@ class OnWorkerStart extends Callback return; } - var_dump(__METHOD__); - sleep(1); $this->ticker();