as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2021-07-05 11:06:39 +08:00
parent 216bc1d894
commit c17e829f75
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
System/Abstracts/Pool.php
+5 -4
View File
@@ -73,18 +73,19 @@ abstract class Pool extends Component
/** /**
* @throws Exception * @throws Exception
*/ */
public function Heartbeat_detection(string $name) public function Heartbeat_detection(string $name, bool $isMaster)
{ {
$name = $this->name('', $name, $isMaster);
if (env('state') == 'exit') { if (env('state') == 'exit') {
Timer::clear($this->creates); Timer::clear($this->creates);
$this->creates = -1; $this->creates = -1;
} else { } else {
$min = Config::get('databases.pool.min', 1); $min = Config::get('databases.pool.min', 1);
if (($length = $this->getChannel($name)->length()) > $min) { if (($length = $this->getChannel($name)->length()) > $min) {
$this->debug("$length -> min length $min"); $this->debug("$name -> $length -> min length $min");
$this->flush($min); $this->flush($min);
} else { } else {
$this->debug("$length -> min length $min"); $this->debug("$name -> $length -> min length $min");
} }
} }
} }
@@ -158,7 +159,7 @@ abstract class Pool extends Component
return; return;
} }
if ($this->creates === -1) { if ($this->creates === -1) {
$this->creates = Timer::tick(1000, [$this, 'Heartbeat_detection'], $name); $this->creates = Timer::tick(1000, [$this, 'Heartbeat_detection'], $name, $isMaster);
} }
static::$_items[$name] = new Channel($max); static::$_items[$name] = new Channel($max);
$this->max = $max; $this->max = $max;