mirror of
https://github.com/zhamao-robot/zhamao-framework.git
synced 2026-07-25 01:25:34 +08:00
fix websocket close event
This commit is contained in:
@@ -8,6 +8,7 @@ use Framework\ZMBuf;
|
|||||||
use Swoole\Server;
|
use Swoole\Server;
|
||||||
use ZM\Annotation\Swoole\SwooleEventAfter;
|
use ZM\Annotation\Swoole\SwooleEventAfter;
|
||||||
use ZM\Annotation\Swoole\SwooleEventAt;
|
use ZM\Annotation\Swoole\SwooleEventAt;
|
||||||
|
use ZM\Connection\ConnectionManager;
|
||||||
use ZM\ModBase;
|
use ZM\ModBase;
|
||||||
use ZM\ModHandleType;
|
use ZM\ModHandleType;
|
||||||
use ZM\Utils\ZMUtil;
|
use ZM\Utils\ZMUtil;
|
||||||
@@ -28,6 +29,7 @@ class WSCloseEvent implements SwooleEvent
|
|||||||
*/
|
*/
|
||||||
public function onActivate() {
|
public function onActivate() {
|
||||||
ZMUtil::checkWait();
|
ZMUtil::checkWait();
|
||||||
|
ConnectionManager::close($this->fd);
|
||||||
foreach(ZMBuf::$events[SwooleEventAt::class] ?? [] as $v) {
|
foreach(ZMBuf::$events[SwooleEventAt::class] ?? [] as $v) {
|
||||||
if(strtolower($v->type) == "close" && $this->parseSwooleRule($v)) {
|
if(strtolower($v->type) == "close" && $this->parseSwooleRule($v)) {
|
||||||
$c = $v->class;
|
$c = $v->class;
|
||||||
|
|||||||
Reference in New Issue
Block a user