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 16:20:00 +08:00
parent af3b482c1f
commit 3e53f8d3c2
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
@@ -92,8 +92,7 @@ class ClientsPool extends Component
} }
$num[$key] += $channel->length(); $num[$key] += $channel->length();
var_dump($key); if (str_starts_with($key, 'Mysql')) {
if (str_starts_with('Mysql', $key)) {
$this->debug('Worker #' . env('worker') . ' use client -> ' . $key . ':' . $total); $this->debug('Worker #' . env('worker') . ' use client -> ' . $key . ':' . $total);
} }
$total += $channel->length(); $total += $channel->length();
@@ -156,7 +155,7 @@ class ClientsPool extends Component
return; return;
} }
if ($this->creates === -1) { if ($this->creates === -1) {
$this->creates = Timer::tick(30000, [$this, 'Heartbeat_detection']); $this->creates = Timer::tick(3000, [$this, 'Heartbeat_detection']);
} }
static::$_connections[$name] = new Channel($max); static::$_connections[$name] = new Channel($max);
$this->max = $max; $this->max = $max;
@@ -173,7 +172,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']); $this->creates = Timer::tick(3000, [$this, 'Heartbeat_detection']);
} }
} }
return static::$_connections[$name]; return static::$_connections[$name];