From aa646f65ab6d4b9104977411dc64b6a1dabc5c99 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Tue, 2 Mar 2021 15:19:27 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- System/Abstracts/Pool.php | 8 +++++--- System/Pool/Connection.php | 2 -- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/System/Abstracts/Pool.php b/System/Abstracts/Pool.php index f87df99c..4fa7958a 100644 --- a/System/Abstracts/Pool.php +++ b/System/Abstracts/Pool.php @@ -8,8 +8,10 @@ use Exception; use HttpServer\Http\Context; use JetBrains\PhpStorm\Pure; +use Phalcon\Mvc\Model\Query\Lang; use Snowflake\Exception\ComponentException; use Snowflake\Exception\ConfigException; +use Snowflake\Snowflake; use Swoole\Coroutine; use Swoole\Coroutine\Channel; use Swoole\Timer; @@ -146,9 +148,9 @@ abstract class Pool extends Component */ private function createByCallback($name, mixed $callback) { -// if ($this->creates === -1 && !is_callable($callback)) { -// $this->creates = Timer::tick(1000, [$this, 'Heartbeat_detection']); -// } + if ($this->creates === -1 && !is_callable($callback)) { + $this->creates = Timer::tick(1000, [$this, 'Heartbeat_detection']); + } if (!Context::hasContext('create::client::ing::' . $name)) { $this->push($name, $this->createClient($name, $callback)); Context::remove('create::client::ing::' . $name); diff --git a/System/Pool/Connection.php b/System/Pool/Connection.php index b81d2392..fb8c48b9 100644 --- a/System/Pool/Connection.php +++ b/System/Pool/Connection.php @@ -156,7 +156,6 @@ class Connection extends Pool * @param string $name * @param mixed $config * @return PDO - * @throws ComponentException */ public function createClient(string $name, mixed $config): PDO { @@ -183,7 +182,6 @@ class Connection extends Pool * @param $cds * @param $coroutineName * @param false $isBefore - * @throws ComponentException */ public function printClients($cds, $coroutineName, $isBefore = false) {