From 0dcd548645b907b2ec06891a033d5afd10d507a2 Mon Sep 17 00:00:00 2001 From: whwyy Date: Sun, 7 Dec 2025 14:01:37 +0800 Subject: [PATCH] eee --- Connection.php | 45 ++++++++++++++++++++++----------------------- 1 file changed, 22 insertions(+), 23 deletions(-) diff --git a/Connection.php b/Connection.php index 1b9ae71..d354c0a 100644 --- a/Connection.php +++ b/Connection.php @@ -14,21 +14,20 @@ namespace Database; use Database\Affair\BeginTransaction; use Database\Affair\Commit; use Database\Affair\Rollback; +use Database\Base\PDO; use Exception; -use Kiri; -use Kiri\Server\Events\OnWorkerExit; use Kiri\Abstracts\Component; use Kiri\Di\Context; -use Kiri\Pool\Pool; -use Kiri\Events\EventProvider; -use Kiri\Error\StdoutLogger; -use Psr\Log\LoggerInterface; -use Kiri\Server\Events\OnWorkerStart; -use Kiri\Server\Events\OnTaskerStart; -use Kiri\Server\Events\OnAfterRequest; use Kiri\Di\Inject\Container; +use Kiri\Error\StdoutLogger; +use Kiri\Events\EventProvider; +use Kiri\Pool\Pool; +use Kiri\Server\Events\OnAfterRequest; +use Kiri\Server\Events\OnTaskerStart; +use Kiri\Server\Events\OnWorkerExit; +use Kiri\Server\Events\OnWorkerStart; +use Psr\Log\LoggerInterface; use Swoole\Timer; -use Database\Base\PDO; //use PDO; @@ -134,19 +133,19 @@ class Connection extends Component protected function checkClientHealth(Pool $pool): void { $pool->flush($this->getName(), $this->pool['min'] ?? 1); - $length = $pool->size($this->getName()); - for ($i = 0; $i < $length; $i++) { - try { - if (($client = $this->validator($pool)) === false) { - break; - } - $pool->push($this->getName(), $client); - } catch (\Throwable $exception) { - if (!str_contains($exception->getMessage(), 'Client timeout.')) { - $this->logger->error(throwable($exception), [$this->cds]); - } - } - } +// $length = $pool->size($this->getName()); +// for ($i = 0; $i < $length; $i++) { +// try { +// if (($client = $this->validator($pool)) === false) { +// break; +// } +// $pool->push($this->getName(), $client); +// } catch (\Throwable $exception) { +// if (!str_contains($exception->getMessage(), 'Client timeout.')) { +// $this->logger->error(throwable($exception), [$this->cds]); +// } +// } +// } }