This commit is contained in:
as2252258@163.com
2021-04-23 03:38:26 +08:00
parent a5a607495f
commit 1edd8c5429
15 changed files with 264 additions and 278 deletions
-1
View File
@@ -29,7 +29,6 @@ class OnClose extends Callback
try {
defer(function () {
fire(Event::SYSTEM_RESOURCE_RELEASES);
logger_insert();
});
$clientInfo = $server->getClientInfo($fd);
$event = Snowflake::app()->getEvent();
-1
View File
@@ -28,7 +28,6 @@ class OnConnect extends Callback
{
defer(function () {
fire(Event::SYSTEM_RESOURCE_RELEASES);
logger_insert();
});
$event = Snowflake::app()->getEvent();
-1
View File
@@ -29,7 +29,6 @@ class OnFinish extends Callback
try {
defer(function () {
fire(Event::SYSTEM_RESOURCE_RELEASES);
logger_insert();
});
fire(Event::TASK_FINISH, [$task_id, $data]);
} catch (\Throwable $exception) {
-1
View File
@@ -99,7 +99,6 @@ class OnHandshake extends Callback
try {
defer(function () {
fire(Event::SYSTEM_RESOURCE_CLEAN);
logger_insert();
});
$this->execute($request, $response);
} catch (\Throwable $exception) {
-1
View File
@@ -40,7 +40,6 @@ class OnMessage extends Callback
try {
defer(function () {
fire(Event::SYSTEM_RESOURCE_CLEAN);
logger_insert();
});
if ($frame->opcode === 0x08) {
return;
-1
View File
@@ -38,7 +38,6 @@ class OnPacket extends Callback
try {
defer(function () {
fire(Event::SYSTEM_RESOURCE_RELEASES);
\logger_insert();
});
$request = $this->_request($clientInfo, $server, $data);
-1
View File
@@ -28,7 +28,6 @@ class OnPipeMessage extends Callback
{
defer(function () {
fire(Event::SYSTEM_RESOURCE_RELEASES);
logger_insert();
});
match ($swollen_universalize['action'] ?? null) {
'kafka' => $this->onKafkaWorker($swollen_universalize),
-1
View File
@@ -50,7 +50,6 @@ class OnReceive extends Callback
try {
defer(function (){
fire(Event::SYSTEM_RESOURCE_RELEASES);
\logger_insert();
});
$request = $this->_request($fd, $data, $reID);
if (($node = $this->router->find_path($request)) === null) {
+1 -3
View File
@@ -34,7 +34,6 @@ class OnRequest extends Callback
public function init()
{
$this->event = Snowflake::app()->getEvent();
$this->logger = Snowflake::app()->getLogger();
}
@@ -48,8 +47,7 @@ class OnRequest extends Callback
{
try {
defer(function () {
$this->event->trigger(Event::SYSTEM_RESOURCE_RELEASES);
$this->logger->insert();
fire(Event::SYSTEM_RESOURCE_RELEASES);
});
/** @var HRequest $request */
[$request, $response] = OnRequest::createContext($request, $response);
-1
View File
@@ -104,7 +104,6 @@ class OnTask extends Callback
try {
defer(function () {
fire(Event::SYSTEM_RESOURCE_CLEAN);
logger_insert();
});
$serialize = $this->before($data);
if ($serialize === null) {
-2
View File
@@ -36,8 +36,6 @@ class OnWorkerError extends Callback
);
write($message, 'worker-exit');
logger_insert();
}
}
+12 -13
View File
@@ -17,22 +17,21 @@ use Swoole\Timer;
class OnWorkerExit extends Callback
{
/**
* @param $server
* @param $worker_id
* @throws Exception
*/
public function onHandler($server, $worker_id)
{
putenv('state=exit');
$channel = Snowflake::app()->getChannel();
/**
* @param $server
* @param $worker_id
* @throws Exception
*/
public function onHandler($server, $worker_id)
{
putenv('state=exit');
$event = Snowflake::app()->getEvent();
$channel = Snowflake::app()->getChannel();
$channel->cleanAll();
$event = Snowflake::app()->getEvent();
$event->trigger(Event::SERVER_WORKER_EXIT);
$event->trigger(Event::SERVER_WORKER_EXIT);
logger_insert();
logger()->insert();
}
}
+2 -2
View File
@@ -32,9 +32,9 @@ class OnWorkerStop extends Callback
$this->clearMysqlClient();
$this->clearRedisClient();
Timer::clearAll();
fire(Event::SYSTEM_RESOURCE_CLEAN);
logger_insert();
Timer::clearAll();
}
}