This commit is contained in:
2021-02-16 23:47:41 +08:00
parent dda2d08b55
commit e8c2e63439
3 changed files with 5 additions and 12 deletions
+3 -4
View File
@@ -127,11 +127,10 @@ abstract class Pool extends Component
public function createConnect(array $config, string $coroutineName, callable $createHandler): PDO|Redis|false
{
if (Context::hasContext('create:connect:' . $coroutineName)) {
while (!($client = Context::hasContext($coroutineName))){
while (!($client = Context::getContext($coroutineName))){
var_dump($client);
}
var_dump($client);
return true;
return $client;
}
Context::setContext('create:connect:' . $coroutineName, 1);
@@ -139,7 +138,7 @@ abstract class Pool extends Component
Context::deleteId('create:connect:' . $coroutineName);
return $client;
return Context::setContext($coroutineName, $client);
}
+1 -4
View File
@@ -151,10 +151,7 @@ class Connection extends Pool
return Context::getContext($coroutineName);
}
if (!$this->hasItem($coroutineName)) {
if (($client = $this->newClient($config, $coroutineName)) == true) {
return Context::getContext($coroutineName);
}
return Context::setContext($coroutineName, $client);
return $this->newClient($config, $coroutineName);
}
[$time, $connections] = $this->get($coroutineName);
if (!($connections instanceof PDO)) {
+1 -4
View File
@@ -47,10 +47,7 @@ class Redis extends Pool
return Context::getContext($coroutineName);
}
if (!$this->hasItem($coroutineName)) {
if (($client = $this->newClient($config, $coroutineName)) == true) {
return Context::getContext($coroutineName);
}
return Context::setContext($coroutineName, $client);
return $this->newClient($config, $coroutineName);
}
[$time, $clients] = $this->get($coroutineName);
if ($clients === null) {