From 39777985f741537c16476d9c8992c457e895d7ee Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=91=E6=9E=97?= Date: Fri, 17 Jun 2022 14:25:29 +0800 Subject: [PATCH] modify plugin name --- DatabasesProviders.php | 30 +++++++++++++++--------------- 1 file changed, 15 insertions(+), 15 deletions(-) diff --git a/DatabasesProviders.php b/DatabasesProviders.php index acb7eba..263401a 100644 --- a/DatabasesProviders.php +++ b/DatabasesProviders.php @@ -86,32 +86,32 @@ class DatabasesProviders extends Providers { $timerTick = $start->server->tick(50 * 1000, static function () use ($start) { $databases = Config::get('databases.connections', []); + $valid = 0; + $count = 0; $logger = Kiri::getDi()->get(LoggerInterface::class); - $logger->alert('db size ' . count($databases) . ' ticker ' . date('Y-m-d H:i:s')); if (!empty($databases)) { - $valid = 0; - $count = 0; - $connection = Kiri::getDi()->get(PoolConnection::class); foreach ($databases as $database) { - [$total, $success] = $connection->check($database['cds']); + try { + [$total, $success] = $connection->check($database['cds']); - $count += $total; - $valid += $success; + $count += $total; + $valid += $success; - if (isset($database['slaveConfig']) && isset($database['slaveConfig']['cds'])) { - if ($database['slaveConfig']['cds'] != $database['cds']) { - [$total, $success] = $connection->check($database['slaveConfig']['cds']); + if (isset($database['slaveConfig']) && isset($database['slaveConfig']['cds'])) { + if ($database['slaveConfig']['cds'] != $database['cds']) { + [$total, $success] = $connection->check($database['slaveConfig']['cds']); - $count += $total; - $valid += $success; + $count += $total; + $valid += $success; + } } + } catch (\Throwable $throwable) { + $logger->error($throwable->getMessage()); } } - - $message = sprintf('Worker %d db client has %d, valid %d', $start->workerId, $count, $valid); - $logger->alert($message); } + $logger->alert(sprintf('Worker %d db client has %d, valid %d', $start->workerId, $count, $valid)); }); Kiri\Context::setContext('db.loop.id', $timerTick); }