This commit is contained in:
2022-07-10 01:23:32 +08:00
parent 86798409fd
commit 7509597582
+6 -9
View File
@@ -27,6 +27,9 @@ class DatabasesProviders extends Providers
{ {
public int $timer = 50000;
/** /**
* @var EventProvider * @var EventProvider
*/ */
@@ -34,13 +37,6 @@ class DatabasesProviders extends Providers
public EventProvider $provider; public EventProvider $provider;
/**
* @var PoolConnection
*/
#[Inject(PoolConnection::class)]
public PoolConnection $connection;
/** /**
* @param LocalService $application * @param LocalService $application
* @return void * @return void
@@ -73,8 +69,9 @@ class DatabasesProviders extends Providers
Timer::clearAll(); Timer::clearAll();
$databases = Config::get('databases.connections', []); $databases = Config::get('databases.connections', []);
if (!empty($databases)) { if (!empty($databases)) {
$connection = Kiri::getDi()->get(PoolConnection::class);
foreach ($databases as $database) { 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 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; $valid = $count = 0;
$logger = Kiri::getDi()->get(LoggerInterface::class); $logger = Kiri::getDi()->get(LoggerInterface::class);
$databases = Config::get('databases.connections', []); $databases = Config::get('databases.connections', []);