modify

2021-02-27 05:09:42 +08:00
parent ecf217fde6
commit 6bd7a2a2e4
1 changed files with 10 additions and 11 deletions
@@ -71,9 +71,7 @@ class OnWorkerStart extends Callback
    {
        Coroutine\go(function (Server $server, $worker_id) {
            $sigkill = Coroutine::waitSignal(SIGTERM | SIGKILL | SIGUSR2 | SIGUSR1);
-            if ($sigkill !== false) {
-                return $server->stop(null, true);
-            }
+            if ($sigkill === false) {
                do {
                    $number = Co::stats()['coroutine_num'];
                    var_dump($number);
@@ -82,7 +80,8 @@ class OnWorkerStart extends Callback
                    }
                    Coroutine::sleep(0.01);
                } while (true);
-            return $server->stop(null, true);
+            }
+            return $server->stop();
        }, $server, $worker_id);
    }