From 062b7ff769d437dd80e46cf0dfd5c2a705efa9f6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Wed, 23 Dec 2020 16:54:51 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Kafka/Kafka.php | 5 +++++ System/Process/ServerInotify.php | 13 ------------- 2 files changed, 5 insertions(+), 13 deletions(-) diff --git a/Kafka/Kafka.php b/Kafka/Kafka.php index cff5a7ba..3b8662df 100644 --- a/Kafka/Kafka.php +++ b/Kafka/Kafka.php @@ -15,6 +15,7 @@ use Snowflake\Snowflake; use Swoole\Coroutine; use Swoole\Coroutine\Channel; use Swoole\Coroutine\WaitGroup; +use Swoole\IDEHelper\StubGenerators\Swoole; use Swoole\Process; use Snowflake\Abstracts\Config as SConfig; use Throwable; @@ -38,6 +39,10 @@ class Kafka extends \Snowflake\Process\Process { $this->channelListener(); + Process::signal(SIGUSR1, function () use ($process) { + var_dump($process); + }); + $waite = new WaitGroup(); $kafkaServers = SConfig::get('kafka.servers'); foreach ($kafkaServers as $kafkaServer) { diff --git a/System/Process/ServerInotify.php b/System/Process/ServerInotify.php index 4d09fd4b..2c12073b 100644 --- a/System/Process/ServerInotify.php +++ b/System/Process/ServerInotify.php @@ -209,19 +209,6 @@ class ServerInotify extends Process public function trigger_reload() { Snowflake::reload(); - - $system = Snowflake::app()->server; - - $processes = Config::get('processes'); - if (!empty($processes) && is_array($processes)) { - $processes = merge($processes, $system->getProcesses()); - } else { - $processes = $system->getProcesses(); - } - foreach ($processes as $name => $process) { - $process = Snowflake::app()->get($name); - $process->exit(0); - } }