改名
This commit is contained in:
@@ -15,6 +15,7 @@ use Snowflake\Snowflake;
|
|||||||
use Swoole\Coroutine;
|
use Swoole\Coroutine;
|
||||||
use Swoole\Coroutine\Channel;
|
use Swoole\Coroutine\Channel;
|
||||||
use Swoole\Coroutine\WaitGroup;
|
use Swoole\Coroutine\WaitGroup;
|
||||||
|
use Swoole\IDEHelper\StubGenerators\Swoole;
|
||||||
use Swoole\Process;
|
use Swoole\Process;
|
||||||
use Snowflake\Abstracts\Config as SConfig;
|
use Snowflake\Abstracts\Config as SConfig;
|
||||||
use Throwable;
|
use Throwable;
|
||||||
@@ -38,6 +39,10 @@ class Kafka extends \Snowflake\Process\Process
|
|||||||
{
|
{
|
||||||
$this->channelListener();
|
$this->channelListener();
|
||||||
|
|
||||||
|
Process::signal(SIGUSR1, function () use ($process) {
|
||||||
|
var_dump($process);
|
||||||
|
});
|
||||||
|
|
||||||
$waite = new WaitGroup();
|
$waite = new WaitGroup();
|
||||||
$kafkaServers = SConfig::get('kafka.servers');
|
$kafkaServers = SConfig::get('kafka.servers');
|
||||||
foreach ($kafkaServers as $kafkaServer) {
|
foreach ($kafkaServers as $kafkaServer) {
|
||||||
|
|||||||
@@ -209,19 +209,6 @@ class ServerInotify extends Process
|
|||||||
public function trigger_reload()
|
public function trigger_reload()
|
||||||
{
|
{
|
||||||
Snowflake::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);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user