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-03-08 18:23:46 +08:00
parent cf2bcd7497
commit b41096636c
2 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
HttpServer/Events/OnConnect.php
+7 -3
View File
@@ -18,17 +18,21 @@ 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(\Swoole\Server $server, int $fd, int $reactorId) public function onHandler(Server $server, int $fd, int $reactorId)
{ {
$event = Snowflake::app()->getEvent(); $event = Snowflake::app()->getEvent();
$event->trigger(Event::RECEIVE_CONNECTION, [$server, $fd, $reactorId]);
$clientInfo = $server->getClientInfo($fd);
$name = 'listen ' . $clientInfo['server_port'] . ' ' . Event::RECEIVE_CONNECTION;
$event->trigger($name, [$server, $fd, $reactorId]);
fire(Event::SYSTEM_RESOURCE_RELEASES); fire(Event::SYSTEM_RESOURCE_RELEASES);
logger()->insert(); logger()->insert();
HttpServer/Server.php
+1 -1
View File
@@ -308,7 +308,7 @@ class Server extends HttpService
} }
$event = Snowflake::app()->getEvent(); $event = Snowflake::app()->getEvent();
foreach ($config['events'] as $name => $_event) { foreach ($config['events'] as $name => $_event) {
$event->on($name, $_event); $event->on('listen ' . $config['port'] . ' ' . $name, $_event);
} }
} }