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) {