modify plugin name
This commit is contained in:
@@ -98,8 +98,6 @@ class Connection extends Component
|
|||||||
{
|
{
|
||||||
$minx = Config::get('databases.pool.min', 1);
|
$minx = Config::get('databases.pool.min', 1);
|
||||||
|
|
||||||
CoordinatorManager::utility($config['cds'])->yield();
|
|
||||||
|
|
||||||
return $this->pool->get($config['cds'], $this->generate($config), $minx);
|
return $this->pool->get($config['cds'], $this->generate($config), $minx);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -64,14 +64,18 @@ class Pool extends Component
|
|||||||
*/
|
*/
|
||||||
public function check($name): void
|
public function check($name): void
|
||||||
{
|
{
|
||||||
CoordinatorManager::utility($name)->waite();
|
|
||||||
|
|
||||||
$channel = $this->channel($name);
|
$channel = $this->channel($name);
|
||||||
|
|
||||||
|
$lists = [];
|
||||||
while (($pdo = $channel->pop()) instanceof PDO) {
|
while (($pdo = $channel->pop()) instanceof PDO) {
|
||||||
$pdo->check();
|
$pdo->check();
|
||||||
}
|
|
||||||
|
|
||||||
CoordinatorManager::utility($name)->done();
|
$lists[] = $pdo;
|
||||||
|
|
||||||
|
}
|
||||||
|
foreach ($lists as $list) {
|
||||||
|
$channel->push($list);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user