This commit is contained in:
2020-09-05 03:51:21 +08:00
parent 90674fb6aa
commit 8baffa4099
+2 -3
View File
@@ -28,8 +28,7 @@ abstract class Pool extends Component
public function initConnections($name, $isMaster = false, $max = 60) public function initConnections($name, $isMaster = false, $max = 60)
{ {
$name = $this->name($name, $isMaster); $name = $this->name($name, $isMaster);
if (isset($this->_items[$name]) && if (isset($this->_items[$name]) && $this->_items[$name] instanceof Channel) {
$this->_items[$name] instanceof Channel) {
return; return;
} }
$this->_items[$name] = new Channel($max); $this->_items[$name] = new Channel($max);
@@ -127,7 +126,7 @@ abstract class Pool extends Component
{ {
$this->_items[$name]->push([time(), $client]); $this->_items[$name]->push([time(), $client]);
unset($client); unset($client);
$this->debug('release connect.' . $this->size($name)); $this->debug('release connect.' . $this->max . ':' . $this->size($name));
} }