This commit is contained in:
2020-10-13 14:13:53 +08:00
parent a8af467dd1
commit 6986ca7a67
+9 -6
View File
@@ -28,12 +28,7 @@ abstract class Callback extends Application
*/ */
protected function clear($server, $worker_id, $message) protected function clear($server, $worker_id, $message)
{ {
$event = Snowflake::app()->event; try {
$event->offName(Event::EVENT_AFTER_REQUEST);
$event->offName(Event::EVENT_BEFORE_REQUEST);
$this->eventNotify($message, $event);
$this->warning($server->worker_pid); $this->warning($server->worker_pid);
Snowflake::clearProcessId($server->worker_pid); Snowflake::clearProcessId($server->worker_pid);
Timer::clearAll(); Timer::clearAll();
@@ -41,6 +36,14 @@ abstract class Callback extends Application
$logger = Snowflake::app()->getLogger(); $logger = Snowflake::app()->getLogger();
$logger->write($this->_MESSAGE[$message] . $worker_id); $logger->write($this->_MESSAGE[$message] . $worker_id);
$logger->clear(); $logger->clear();
$event = Snowflake::app()->event;
$event->offName(Event::EVENT_AFTER_REQUEST);
$event->offName(Event::EVENT_BEFORE_REQUEST);
$this->eventNotify($message, $event);
} catch (Exception $exception) {
$this->error($exception->getMessage());
}
} }