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 15:57:44 +08:00
parent 7246d88e44
commit c545686b8f
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
System/Pool/ClientsPool.php
+3 -4
View File
@@ -73,9 +73,8 @@ class ClientsPool extends Component
/** /**
* @throws Exception * @throws Exception
*/ */
public function Heartbeat_detection($ticker, string $name) public function Heartbeat_detection($ticker)
{ {
var_dump($name);
if (env('state') == 'exit') { if (env('state') == 'exit') {
Timer::clear($this->creates); Timer::clear($this->creates);
$this->creates = -1; $this->creates = -1;
@@ -148,7 +147,7 @@ class ClientsPool extends Component
return; return;
} }
if ($this->creates === -1) { if ($this->creates === -1) {
$this->creates = Timer::tick(30000, [$this, 'Heartbeat_detection'], $name); $this->creates = Timer::tick(30000, [$this, 'Heartbeat_detection']);
} }
static::$_connections[$name] = new Channel($max); static::$_connections[$name] = new Channel($max);
$this->max = $max; $this->max = $max;
@@ -165,7 +164,7 @@ class ClientsPool extends Component
if (!isset(static::$_connections[$name])) { if (!isset(static::$_connections[$name])) {
static::$_connections[$name] = new Channel(Config::get('databases.pool.max', 10)); static::$_connections[$name] = new Channel(Config::get('databases.pool.max', 10));
if ($this->creates === -1) { if ($this->creates === -1) {
$this->creates = Timer::tick(30000, [$this, 'Heartbeat_detection'], $name); $this->creates = Timer::tick(30000, [$this, 'Heartbeat_detection']);
} }
} }
return static::$_connections[$name]; return static::$_connections[$name];