diff --git a/HttpServer/Events/OnWorkerStart.php b/HttpServer/Events/OnWorkerStart.php index 7f70acfb..7a313d32 100644 --- a/HttpServer/Events/OnWorkerStart.php +++ b/HttpServer/Events/OnWorkerStart.php @@ -71,7 +71,6 @@ class OnWorkerStart extends Callback } - /** * @param Server $server * @param int $worker_id @@ -99,21 +98,20 @@ class OnWorkerStart extends Callback */ public function onSignal($server, $worker_id) { - $env = ucfirst(Snowflake::getEnvironmental()); - - $receive = Coroutine::waitSignal($this->signal, -1); - var_dump($receive); - while ($receive === true) { - if ($this->isPrint === false) { - $this->warning(sprintf('Receive %s#%d stop event.', $env, $worker_id)); - $this->isPrint = true; - } - if (!Snowflake::app()->isRun()) { - break; - } - sleep(1); - } - return $server->stop($worker_id); +// $env = ucfirst(Snowflake::getEnvironmental()); +// +// $receive = Coroutine::waitSignal($this->signal, 30); +// while ($receive === true) { +// if ($this->isPrint === false) { +// $this->warning(sprintf('Receive %s#%d stop event.', $env, $worker_id)); +// $this->isPrint = true; +// } +// if (!Snowflake::app()->isRun()) { +// break; +// } +// sleep(1); +// } +// return $server->stop($worker_id); }