改名
This commit is contained in:
@@ -36,7 +36,7 @@ class OnPacket extends Callback
|
|||||||
public function onHandler(Server $server, string $data, array $clientInfo): mixed
|
public function onHandler(Server $server, string $data, array $clientInfo): mixed
|
||||||
{
|
{
|
||||||
try {
|
try {
|
||||||
$request = Request::createListenRequest($clientInfo, $this->port, $server, $data);
|
$request = Request::createListenRequest($clientInfo, $server, $data);
|
||||||
|
|
||||||
[$host, $port] = [$clientInfo['address'], $clientInfo['port']];
|
[$host, $port] = [$clientInfo['address'], $clientInfo['port']];
|
||||||
|
|
||||||
|
|||||||
@@ -36,7 +36,7 @@ class OnReceive extends Callback
|
|||||||
public function onHandler(Server $server, int $fd, int $reID, string $data): mixed
|
public function onHandler(Server $server, int $fd, int $reID, string $data): mixed
|
||||||
{
|
{
|
||||||
try {
|
try {
|
||||||
$request = Request::createListenRequest($fd, $this->port, $server, $data, $reID);
|
$request = Request::createListenRequest($fd, $server, $data, $reID);
|
||||||
|
|
||||||
$router = Snowflake::app()->getRouter();
|
$router = Snowflake::app()->getRouter();
|
||||||
if (($node = $router->find_path($request)) === null) {
|
if (($node = $router->find_path($request)) === null) {
|
||||||
|
|||||||
@@ -505,7 +505,6 @@ class Request extends HttpService
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* @param $fd
|
* @param $fd
|
||||||
* @param $port
|
|
||||||
* @param Server $server
|
* @param Server $server
|
||||||
* @param $data
|
* @param $data
|
||||||
* @param int $reID
|
* @param int $reID
|
||||||
@@ -514,7 +513,7 @@ class Request extends HttpService
|
|||||||
* @throws ReflectionException
|
* @throws ReflectionException
|
||||||
* @throws Exception
|
* @throws Exception
|
||||||
*/
|
*/
|
||||||
public static function createListenRequest($fd, $port, Server $server, $data, $reID = 0): Request
|
public static function createListenRequest($fd, Server $server, $data, $reID = 0): Request
|
||||||
{
|
{
|
||||||
/** @var Request $sRequest */
|
/** @var Request $sRequest */
|
||||||
$sRequest = Snowflake::createObject(Request::class);
|
$sRequest = Snowflake::createObject(Request::class);
|
||||||
@@ -523,6 +522,8 @@ class Request extends HttpService
|
|||||||
$sRequest->clientInfo = self::getClientInfo($fd, $reID);
|
$sRequest->clientInfo = self::getClientInfo($fd, $reID);
|
||||||
$sRequest->startTime = microtime(true);
|
$sRequest->startTime = microtime(true);
|
||||||
|
|
||||||
|
$port = $sRequest->clientInfo['server_port'];
|
||||||
|
|
||||||
$sRequest->params = new HttpParams(['body' => $data], [], []);
|
$sRequest->params = new HttpParams(['body' => $data], [], []);
|
||||||
|
|
||||||
$sRequest->headers = new HttpHeaders([]);
|
$sRequest->headers = new HttpHeaders([]);
|
||||||
|
|||||||
Reference in New Issue
Block a user