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:52:53 +08:00
parent c075662c59
commit 4d2b462676
1 changed files with 28 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files
System/Pool/ClientsPool.php
+28 -19
View File
@@ -80,29 +80,38 @@ class ClientsPool extends Component
Timer::clear($this->creates);
$this->creates = -1;
} else {
$min = Config::get('databases.pool.min', 1);
$this->heartbeat_flush();
}
}
$num = [];
$total = 0;
foreach (static::$_connections as $key => $channel) {
if (!isset($num[$key])) {
$num[$key] = 0;
}
if ($channel->length() > $min) {
$this->flush($channel, $min);
}
$length = $channel->length();
$num[$key] += $length;
if (str_starts_with($key, 'Mysql') && (Snowflake::isWorker() || Snowflake::isTask()) && $length > 0) {
$this->debug('Worker #' . env('worker') . ' use client -> ' . $key . ':' . $length);
}
$total += $length;
/**
* @throws ConfigException
* @throws Exception
*/
private function heartbeat_flush()
{
$min = Config::get('databases.pool.min', 1);
$num = [];
$total = 0;
foreach (static::$_connections as $key => $channel) {
if (!isset($num[$key])) {
$num[$key] = 0;
}
if ($total < 1) {
Timer::clear($this->creates);
$this->creates = -1;
$length = $channel->length();
if ($length > $min) {
$this->flush($channel, $min);
}
$num[$key] += $length;
if (str_starts_with($key, 'Mysql') && (Snowflake::isWorker() || Snowflake::isTask()) && $length > 0) {
$this->debug('Worker #' . env('worker') . ' use client -> ' . $key . ':' . $length);
}
$total += $length;
}
if ($total < 1) {
Timer::clear($this->creates);
$this->creates = -1;
}
}