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

111

Browse Source
This commit is contained in:
as2252258@163.com
2021-09-06 01:57:01 +08:00
parent 05adb043f2
commit 5bd3d98250
1 changed files with 5 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core/Pool/Pool.php
+5 -7
View File
@@ -47,14 +47,12 @@ class Pool extends Component
*/ */
protected function pop(Channel $channel, $retain_number): void protected function pop(Channel $channel, $retain_number): void
{ {
if (!Context::inCoroutine()) {
$channel->close();
return;
}
while ($channel->length() > $retain_number) { while ($channel->length() > $retain_number) {
$connection = $channel->pop(); if (Context::inCoroutine()) {
if ($connection instanceof StopHeartbeatCheck) { $connection = $channel->pop();
$connection->stopHeartbeatCheck(); if ($connection instanceof StopHeartbeatCheck) {
$connection->stopHeartbeatCheck();
}
} }
} }
} }