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:34:55 +08:00
parent 35ce80c19b
commit c075662c59
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
System/Pool/ClientsPool.php
+6 -5
View File
@@ -91,12 +91,13 @@ class ClientsPool extends Component
if ($channel->length() > $min) { if ($channel->length() > $min) {
$this->flush($channel, $min); $this->flush($channel, $min);
} }
$num[$key] += $channel->length(); $length = $channel->length();
if (str_starts_with($key, 'Mysql') && (Snowflake::isWorker() || Snowflake::isTask())
&& $channel->length() > 0) { $num[$key] += $length;
$this->debug('Worker #' . env('worker') . ' use client -> ' . $key . ':' . $channel->length()); if (str_starts_with($key, 'Mysql') && (Snowflake::isWorker() || Snowflake::isTask()) && $length > 0) {
$this->debug('Worker #' . env('worker') . ' use client -> ' . $key . ':' . $length);
} }
$total += $channel->length(); $total += $length;
} }
if ($total < 1) { if ($total < 1) {
Timer::clear($this->creates); Timer::clear($this->creates);