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-06-17 13:54:11 +08:00
parent e224d2e46b
commit 6c721e957b
1 changed files with 23 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files
DatabasesProviders.php
+23 -25
View File
@@ -69,38 +69,36 @@ class DatabasesProviders extends Providers
*/ */
public function check(OnTaskerStart|OnWorkerStart $start): void public function check(OnTaskerStart|OnWorkerStart $start): void
{ {
$start->server->tick(1150 * 1000, function () use ($start) { $start->server->tick(50 * 1000, static function () use ($start) {
$databases = Config::get('databases.connections', []); $databases = Config::get('databases.connections', []);
if (empty($databases)) { $logger = Kiri::getDi()->get(LoggerInterface::class);
return; $logger->alert('db ticker ' . date('Y-m-d H:i:s'));
} if (!empty($databases)) {
$valid = 0;
$count = 0;
$valid = 0; $connection = Kiri::getDi()->get(PoolConnection::class);
$count = 0; foreach ($databases as $database) {
$count += 1;
$connection = Kiri::getDi()->get(PoolConnection::class); $success = $connection->check($database['cds']);
foreach ($databases as $database) { if ($success) {
$count += 1; $valid += 1;
}
$success = $connection->check($database['cds']); if (isset($database['slaveConfig']) && isset($database['slaveConfig']['cds'])) {
if ($success) { if ($database['slaveConfig']['cds'] != $database['cds']) {
$valid += 1; $count += 1;
} $success = $connection->check($database['slaveConfig']['cds']);
if (isset($database['slaveConfig']) && isset($database['slaveConfig']['cds'])) { if ($success) {
if ($database['slaveConfig']['cds'] != $database['cds']) { $valid += 1;
$count += 1; }
$success = $connection->check($database['slaveConfig']['cds']);
if ($success) {
$valid += 1;
} }
} }
} }
$message = sprintf('Worker %d db client has %d, valid %d', $start->workerId, $count, $valid);
$logger->alert($message);
} }
$message = sprintf('Worker %d db client has %d, valid %d', $start->workerId, $count, $valid);
$logger = Kiri::getDi()->get(LoggerInterface::class);
$logger->alert($message);
}); });
} }