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-04-27 17:27:27 +08:00
parent 33083e706f
commit ebc7ad032b
1 changed files with 29 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files
HttpServer/Events/OnConnect.php
+29 -29
View File
@@ -7,7 +7,6 @@ namespace HttpServer\Events;
use Exception; use Exception;
use HttpServer\Abstracts\Callback; use HttpServer\Abstracts\Callback;
use Snowflake\Event; use Snowflake\Event;
use Snowflake\Snowflake;
use Swoole\Server; use Swoole\Server;
/** /**
@@ -18,36 +17,37 @@ class OnConnect extends Callback
{ {
/** /**
* @param Server $server * @param Server $server
* @param int $fd * @param int $fd
* @param int $reactorId * @param int $reactorId
* @throws Exception * @throws Exception
*/ */
public function onHandler(Server $server, int $fd, int $reactorId) public function onHandler(Server $server, int $fd, int $reactorId)
{ {
try { var_dump($fd, $reactorId);
defer(function () { try {
fire(Event::SYSTEM_RESOURCE_RELEASES); defer(function () {
}); fire(Event::SYSTEM_RESOURCE_RELEASES);
if (($clientInfo = $server->getClientInfo($fd, $reactorId)) === false) { });
return; if (($clientInfo = $server->getClientInfo($fd, $reactorId)) === false) {
} return;
fire($this->getName($clientInfo), [$server, $fd, $reactorId]); }
} catch (\Throwable $throwable) { fire($this->getName($clientInfo), [$server, $fd, $reactorId]);
$this->addError($throwable, 'connect'); } catch (\Throwable $throwable) {
} $this->addError($throwable, 'connect');
} }
}
/** /**
* @param array $clientInfo * @param array $clientInfo
* @return string * @return string
*/ */
private function getName(array $clientInfo): string private function getName(array $clientInfo): string
{ {
return 'listen ' . $clientInfo['server_port'] . ' ' . Event::SERVER_CONNECT; return 'listen ' . $clientInfo['server_port'] . ' ' . Event::SERVER_CONNECT;
} }
} }