From 0afa8fc4009e00055770754927f31192f950c557 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=91=E6=9E=97?= Date: Fri, 7 Jan 2022 17:59:37 +0800 Subject: [PATCH] =?UTF-8?q?Revert=20"=E6=94=B9=E5=90=8D"?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit This reverts commit fdf58326 --- kiri-websocket-server/Sender.php | 1 - kiri-websocket-server/Server.php | 4 ++++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/kiri-websocket-server/Sender.php b/kiri-websocket-server/Sender.php index 4f08cd94..821c2f69 100644 --- a/kiri-websocket-server/Sender.php +++ b/kiri-websocket-server/Sender.php @@ -8,7 +8,6 @@ class Sender public function push($fd, $data) { - } diff --git a/kiri-websocket-server/Server.php b/kiri-websocket-server/Server.php index b5c27a58..dc2d5897 100644 --- a/kiri-websocket-server/Server.php +++ b/kiri-websocket-server/Server.php @@ -63,6 +63,10 @@ class Server extends AbstractServer implements OnHandshakeInterface, OnMessageIn */ public function onClose(\Swoole\Server $server, int $fd): void { + $clientInfo = $server->getClientInfo($fd); + if (!isset($clientInfo['websocket_status'])) { + return; + } if ($this->callback instanceof OnCloseInterface) { $this->callback->onClose($server, $fd); }