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); - } }