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
2020-12-15 17:03:20 +08:00
parent 4699ca29af
commit 272bea30ab
3 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
HttpServer/Events/OnClose.php
+2 -2
View File
@@ -56,7 +56,7 @@ class OnClose extends Callback
if (!($server instanceof WServer) || !$server->isEstablished($fd)) { if (!($server instanceof WServer) || !$server->isEstablished($fd)) {
return; return;
} }
$node = $router->search(Socket::CLOSE . '::event', 'sw:socket'); $node = $router->search(Socket::CLOSE . '::event', 'sw::socket');
if ($node instanceof Node) { if ($node instanceof Node) {
$node->dispatch(); $node->dispatch();
} }
@@ -82,7 +82,7 @@ class OnClose extends Callback
return [null, null]; return [null, null];
} }
$router = Snowflake::app()->getRouter(); $router = Snowflake::app()->getRouter();
$node = $router->search(Socket::HANDSHAKE . '::' . null, 'sw:socket'); $node = $router->search(Socket::HANDSHAKE . '::' . null, 'sw::socket');
if ($node === null) { if ($node === null) {
return [null, null]; return [null, null];
} }
HttpServer/Events/OnHandshake.php
+1 -1
View File
@@ -98,7 +98,7 @@ class OnHandshake extends Callback
$this->resolveParse($request, $response); $this->resolveParse($request, $response);
$router = Snowflake::app()->getRouter(); $router = Snowflake::app()->getRouter();
$node = $router->search(Socket::HANDSHAKE . '::event', 'sw:socket'); $node = $router->search(Socket::HANDSHAKE . '::event', 'sw::socket');
var_dump($node); var_dump($node);
if ($node === null) { if ($node === null) {
return $this->disconnect($response, 502); return $this->disconnect($response, 502);
HttpServer/Events/OnMessage.php
+1 -1
View File
@@ -64,7 +64,7 @@ class OnMessage extends Callback
throw new Exception('Format error.'); throw new Exception('Format error.');
} }
$router = Snowflake::app()->getRouter(); $router = Snowflake::app()->getRouter();
$node = $router->search(Socket::MESSAGE . '::' . $route, 'sw:socket'); $node = $router->search(Socket::MESSAGE . '::' . $route, 'sw::socket');
if ($node === null) { if ($node === null) {
throw new Exception('Page not found.'); throw new Exception('Page not found.');
} }