as2252258/kiri-databases
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-07-11 16:26:14 +08:00
parent 64fd34a23c
commit e33776314b
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
DatabasesProviders.php
+4 -4
View File
@@ -93,17 +93,18 @@ class DatabasesProviders extends Providers
*/ */
public function check(OnTaskerStart|OnWorkerStart $start): void public function check(OnTaskerStart|OnWorkerStart $start): void
{ {
Timer::after(10000, [$this, 'filter']); Timer::tick(10000, [$this, 'filter']);
} }
/** /**
* @param $timerId
* @return void * @return void
* @throws ConfigException * @throws ConfigException
* @throws ContainerExceptionInterface * @throws ContainerExceptionInterface
* @throws NotFoundExceptionInterface * @throws NotFoundExceptionInterface
*/ */
public function filter(): void public function filter($timerId): void
{ {
$valid = $count = 0; $valid = $count = 0;
$logger = Kiri::getDi()->get(LoggerInterface::class); $logger = Kiri::getDi()->get(LoggerInterface::class);
@@ -114,9 +115,8 @@ class DatabasesProviders extends Providers
$const = 'Worker %d db client has %d, valid %d'; $const = 'Worker %d db client has %d, valid %d';
$logger->alert(sprintf($const, env('environmental_workerId'), $count, $valid)); $logger->alert(sprintf($const, env('environmental_workerId'), $count, $valid));
if ($this->container->get(WorkerStatus::class)->is(StatusEnum::EXIT)) { if ($this->container->get(WorkerStatus::class)->is(StatusEnum::EXIT)) {
return; Timer::clear($timerId);
} }
Timer::after(10000, [$this, 'filter']);
} }