From ebc7ad032bf7aa2ba82abf414f127df9f903bf71 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Tue, 27 Apr 2021 17:27:27 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- HttpServer/Events/OnConnect.php | 58 ++++++++++++++++----------------- 1 file changed, 29 insertions(+), 29 deletions(-) diff --git a/HttpServer/Events/OnConnect.php b/HttpServer/Events/OnConnect.php index 87dae628..650e0b3c 100644 --- a/HttpServer/Events/OnConnect.php +++ b/HttpServer/Events/OnConnect.php @@ -7,7 +7,6 @@ namespace HttpServer\Events; use Exception; use HttpServer\Abstracts\Callback; use Snowflake\Event; -use Snowflake\Snowflake; use Swoole\Server; /** @@ -18,36 +17,37 @@ class OnConnect extends Callback { - /** - * @param Server $server - * @param int $fd - * @param int $reactorId - * @throws Exception - */ - public function onHandler(Server $server, int $fd, int $reactorId) - { - try { - defer(function () { - fire(Event::SYSTEM_RESOURCE_RELEASES); - }); - if (($clientInfo = $server->getClientInfo($fd, $reactorId)) === false) { - return; - } - fire($this->getName($clientInfo), [$server, $fd, $reactorId]); - } catch (\Throwable $throwable) { - $this->addError($throwable, 'connect'); - } - } + /** + * @param Server $server + * @param int $fd + * @param int $reactorId + * @throws Exception + */ + public function onHandler(Server $server, int $fd, int $reactorId) + { + var_dump($fd, $reactorId); + try { + defer(function () { + fire(Event::SYSTEM_RESOURCE_RELEASES); + }); + if (($clientInfo = $server->getClientInfo($fd, $reactorId)) === false) { + return; + } + fire($this->getName($clientInfo), [$server, $fd, $reactorId]); + } catch (\Throwable $throwable) { + $this->addError($throwable, 'connect'); + } + } - /** - * @param array $clientInfo - * @return string - */ - private function getName(array $clientInfo): string - { - return 'listen ' . $clientInfo['server_port'] . ' ' . Event::SERVER_CONNECT; - } + /** + * @param array $clientInfo + * @return string + */ + private function getName(array $clientInfo): string + { + return 'listen ' . $clientInfo['server_port'] . ' ' . Event::SERVER_CONNECT; + } }