This commit is contained in:
2021-02-20 13:35:17 +08:00
parent b140054ce9
commit 9ce45e39e8
6 changed files with 23 additions and 20 deletions
+7 -5
View File
@@ -30,13 +30,14 @@ abstract class Pool extends Component
use Timeout;
/**
* @param $driver
* @param $name
* @param false $isMaster
* @param int $max
*/
public function initConnections($name, $isMaster = false, $max = 60)
public function initConnections($driver, $name, $isMaster = false, $max = 60)
{
$name = $this->name($name, $isMaster);
$name = $this->name($driver, $name, $isMaster);
if (isset($this->_items[$name]) && $this->_items[$name] instanceof Channel) {
return;
}
@@ -71,16 +72,17 @@ abstract class Pool extends Component
/**
* @param $driver
* @param $cds
* @param false $isMaster
* @return string
*/
#[Pure] public function name($cds, $isMaster = false): string
#[Pure] public function name($driver, $cds, $isMaster = false): string
{
if ($isMaster === true) {
return hash('sha256', $cds . 'master');
return $driver . ':' . hash('sha256', $cds . 'master');
} else {
return hash('sha256', $cds . 'slave');
return $driver . ':' . hash('sha256', $cds . 'slave');
}
}