From 7509597582ce072bdc736e5d853197d2e8554d89 Mon Sep 17 00:00:00 2001 From: as2252258 Date: Sun, 10 Jul 2022 01:23:32 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8F=98=E6=9B=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- DatabasesProviders.php | 15 ++++++--------- 1 file changed, 6 insertions(+), 9 deletions(-) diff --git a/DatabasesProviders.php b/DatabasesProviders.php index 600a270..19fbf19 100644 --- a/DatabasesProviders.php +++ b/DatabasesProviders.php @@ -27,6 +27,9 @@ class DatabasesProviders extends Providers { + public int $timer = 50000; + + /** * @var EventProvider */ @@ -34,13 +37,6 @@ class DatabasesProviders extends Providers public EventProvider $provider; - /** - * @var PoolConnection - */ - #[Inject(PoolConnection::class)] - public PoolConnection $connection; - - /** * @param LocalService $application * @return void @@ -73,8 +69,9 @@ class DatabasesProviders extends Providers Timer::clearAll(); $databases = Config::get('databases.connections', []); if (!empty($databases)) { + $connection = Kiri::getDi()->get(PoolConnection::class); foreach ($databases as $database) { - $this->connection->disconnect($database['cds']); + $connection->disconnect($database['cds']); } } } @@ -96,7 +93,7 @@ class DatabasesProviders extends Providers */ public function check(OnTaskerStart|OnWorkerStart $start): void { - Timer::tick(50000, static function () use ($start) { + Timer::tick($this->timer, static function () use ($start) { $valid = $count = 0; $logger = Kiri::getDi()->get(LoggerInterface::class); $databases = Config::get('databases.connections', []);