改名
This commit is contained in:
@@ -49,7 +49,10 @@ 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->tree_search(explode('/', Socket::CLOSE . '::event'), 'sw::socket');
|
||||||
|
|
||||||
|
// $node = $router->search('/' . Socket::CLOSE . '::event', 'sw::socket');
|
||||||
if ($node instanceof Node) {
|
if ($node instanceof Node) {
|
||||||
$node->dispatch($server, $fd);
|
$node->dispatch($server, $fd);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -106,7 +106,9 @@ class OnHandshake extends Callback
|
|||||||
return $this->connect($response, 101);
|
return $this->connect($response, 101);
|
||||||
}
|
}
|
||||||
$router = Snowflake::app()->getRouter();
|
$router = Snowflake::app()->getRouter();
|
||||||
$node = $router->search('/' . Socket::HANDSHAKE . '::event', 'sw::socket');
|
|
||||||
|
$node = $router->tree_search(explode('/', Socket::HANDSHAKE . '::event'), 'sw::socket');
|
||||||
|
// $node = $router->search('/' . Socket::HANDSHAKE . '::event', 'sw::socket');
|
||||||
if ($node === null) {
|
if ($node === null) {
|
||||||
return $this->disconnect($response, 502);
|
return $this->disconnect($response, 502);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user