as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

modify plugin name

Browse Source
This commit is contained in:
向林
2022-06-22 18:28:46 +08:00
parent 8630d79519
commit 71c1d8c9d3
1 changed files with 117 additions and 123 deletions
Download Patch File Download Diff File Expand all files Collapse all files
kiri-engine/Reload/Scaner.php
+117 -123
View File
@@ -2,167 +2,161 @@
namespace Kiri\Reload;
use DirectoryIterator;
use Exception;
use Kiri\Abstracts\Config;
use Kiri\Annotation\Inject;
use Kiri\Server\Abstracts\BaseProcess;
use Kiri\Server\ServerInterface;
use Psr\Log\LoggerInterface;
use Swoole\Process;
class Scaner extends BaseProcess
{
private array $md5Map = [];
private array $md5Map = [];
public bool $isReloading = FALSE;
public bool $isReloading = FALSE;
private array $dirs = [];
private array $dirs = [];
/**
* @var LoggerInterface
*/
#[Inject(LoggerInterface::class)]
public LoggerInterface $logger;
/**
* @var LoggerInterface
*/
#[Inject(LoggerInterface::class)]
public LoggerInterface $logger;
/**
* @throws Exception
*/
public function process(Process $process): void
{
$this->dirs = Config::get('reload.inotify', []);
/**
* @throws Exception
*/
public function process(Process $process): void
{
$this->dirs = Config::get('reload.inotify', []);
$this->loadDirs();
$this->tick();
}
$this->loadDirs();
$this->tick();
}
/**
* @param bool $isReload
* @throws Exception
*/
private function loadDirs(bool $isReload = FALSE)
{
foreach ($this->dirs as $value) {
if (is_bool($path = realpath($value))) {
continue;
}
if (!is_dir($path)) continue;
$this->loadByDir($path, $isReload);
}
}
/**
* @param bool $isReload
* @throws Exception
*/
private function loadDirs(bool $isReload = FALSE)
{
foreach ($this->dirs as $value) {
$value = new DirectoryIterator($value);
if ($value->isDot() || str_starts_with($value->getFilename(), '.')) {
continue;
}
if ($value->isDir()) {
$this->loadByDir($value, $isReload);
}
}
}
/**
* @param $path
* @param bool $isReload
* @return void
* @throws Exception
*/
private function loadByDir($path, bool $isReload = FALSE): void
{
if (!is_string($path)) {
return;
}
$path = rtrim($path, '/');
foreach (glob(realpath($path) . '/*') as $value) {
if (is_dir($value)) {
$this->loadByDir($value, $isReload);
}
if (is_file($value)) {
if ($this->checkFile($value, $isReload)) {
if ($this->isReloading) {
break;
}
$this->isReloading = TRUE;
sleep(2);
$this->timerReload();
break;
}
}
}
}
/**
* @param DirectoryIterator $path
* @param bool $isReload
* @return void
* @throws Exception
*/
private function loadByDir(DirectoryIterator $path, bool $isReload = FALSE): void
{
if ($path->isDir()) {
$this->loadByDir(new DirectoryIterator($path->getRealPath()), $isReload);
}
if (!str_ends_with($path->getFilename(), '.php')) {
return;
}
if ($this->checkFile($path, $isReload)) {
if ($this->isReloading) {
return;
}
$this->isReloading = TRUE;
sleep(2);
$this->timerReload();
}
}
/**
* @param $value
* @param $isReload
* @return bool
*/
private function checkFile($value, $isReload): bool
{
$md5 = md5($value);
$mTime = filectime($value);
if (!isset($this->md5Map[$md5])) {
if ($isReload) {
return TRUE;
}
$this->md5Map[$md5] = $mTime;
} else {
if ($this->md5Map[$md5] != $mTime) {
if ($isReload) {
return TRUE;
}
$this->md5Map[$md5] = $mTime;
}
}
return FALSE;
}
/**
* @param DirectoryIterator $value
* @param $isReload
* @return bool
*/
private function checkFile(DirectoryIterator $value, $isReload): bool
{
$md5 = md5_file($value->getRealPath());
$mTime = $value->getCTime();
if (!isset($this->md5Map[$md5])) {
if ($isReload) {
return TRUE;
}
$this->md5Map[$md5] = $mTime;
} else {
if ($this->md5Map[$md5] != $mTime) {
if ($isReload) {
return TRUE;
}
$this->md5Map[$md5] = $mTime;
}
}
return FALSE;
}
/**
* @throws Exception
*/
public function timerReload()
{
$this->isReloading = TRUE;
/**
* @throws Exception
*/
public function timerReload()
{
$this->isReloading = TRUE;
$this->logger->warning('file change');
$this->logger->warning('file change');
$swow = \Kiri::getDi()->get(SwooleServerInterface::class);
$swow = \Kiri::getDi()->get(ServerInterface::class);
$swow->reload();
$swow->reload();
$this->loadDirs();
$this->loadDirs();
$this->isReloading = FALSE;
$this->isReloading = FALSE;
$this->tick();
}
$this->tick();
}
/**
* @return $this
*/
public function onSigterm(): static
{
pcntl_signal(SIGTERM, function () {
$this->onProcessStop();
});
return $this;
}
/**
* @return $this
*/
public function onSigterm(): static
{
pcntl_signal(SIGTERM, function () {
$this->onProcessStop();
});
return $this;
}
/**
* @throws Exception
*/
public function tick()
{
if ($this->isStop) {
return;
}
/**
* @throws Exception
*/
public function tick()
{
if ($this->isStop) {
return;
}
$this->loadDirs(TRUE);
$this->loadDirs(TRUE);
sleep(2);
sleep(2);
$this->tick();
}
$this->tick();
}
}