diff --git a/System/Pool/Connection.php b/System/Pool/Connection.php index c20db418..19495dbd 100644 --- a/System/Pool/Connection.php +++ b/System/Pool/Connection.php @@ -193,7 +193,7 @@ class Connection extends Pool }); if ($connections === false) { Coroutine::sleep(0.003); - return $this->newClient($config, $coroutineName); + return $this->getConnection($config, $coroutineName); } return $connections; } diff --git a/System/Pool/Redis.php b/System/Pool/Redis.php index 239183a2..8a12ae4b 100644 --- a/System/Pool/Redis.php +++ b/System/Pool/Redis.php @@ -90,7 +90,7 @@ class Redis extends Pool }); if ($client === false) { Coroutine::sleep(0.003); - return $this->newClient($config, $coroutineName); + return $this->getConnection($config, $coroutineName); } $this->printClients($config['host'], $coroutineName, true); return $client;