60 lines
1.1 KiB
PHP
60 lines
1.1 KiB
PHP
<?php
|
|
|
|
namespace Kiri\Server;
|
|
|
|
use Kiri\Abstracts\Component;
|
|
use Kiri\Server\Abstracts\TraitServer;
|
|
use Swoole\Process;
|
|
use function config;
|
|
|
|
class State extends Component
|
|
{
|
|
|
|
use TraitServer;
|
|
|
|
|
|
public array $servers = [];
|
|
|
|
|
|
/**
|
|
* @return void
|
|
*/
|
|
public function init(): void
|
|
{
|
|
$this->servers = config('servers.server.ports');
|
|
}
|
|
|
|
|
|
/**
|
|
* @return bool
|
|
* @throws
|
|
*/
|
|
public function isRunner(): bool
|
|
{
|
|
$ports = $this->sortService($this->servers);
|
|
foreach ($ports as $config) {
|
|
if (checkPortIsAlready($config['port'])) {
|
|
return true;
|
|
}
|
|
}
|
|
return false;
|
|
}
|
|
|
|
|
|
/**
|
|
* @param $port
|
|
* @throws
|
|
*/
|
|
public function exit($port): void
|
|
{
|
|
if (!($pid = checkPortIsAlready($port))) {
|
|
return;
|
|
}
|
|
while (checkPortIsAlready($port)) {
|
|
Process::kill($pid, 0) && Process::kill($pid, SIGTERM);
|
|
usleep(300);
|
|
}
|
|
}
|
|
|
|
}
|