This commit is contained in:
2020-10-13 14:11:59 +08:00
parent a359886e05
commit a8af467dd1
+3 -1
View File
@@ -13,6 +13,7 @@ use Snowflake\Error\Logger;
use Snowflake\Event; use Snowflake\Event;
use Snowflake\Exception\ConfigException; use Snowflake\Exception\ConfigException;
use Snowflake\Snowflake; use Snowflake\Snowflake;
use Swoole\Coroutine\Server;
use Swoole\Timer; use Swoole\Timer;
abstract class Callback extends Application abstract class Callback extends Application
@@ -27,14 +28,15 @@ abstract class Callback extends Application
*/ */
protected function clear($server, $worker_id, $message) protected function clear($server, $worker_id, $message)
{ {
Timer::clearAll();
$event = Snowflake::app()->event; $event = Snowflake::app()->event;
$event->offName(Event::EVENT_AFTER_REQUEST); $event->offName(Event::EVENT_AFTER_REQUEST);
$event->offName(Event::EVENT_BEFORE_REQUEST); $event->offName(Event::EVENT_BEFORE_REQUEST);
$this->eventNotify($message, $event); $this->eventNotify($message, $event);
$this->warning($server->worker_pid);
Snowflake::clearProcessId($server->worker_pid); Snowflake::clearProcessId($server->worker_pid);
Timer::clearAll();
$logger = Snowflake::app()->getLogger(); $logger = Snowflake::app()->getLogger();
$logger->write($this->_MESSAGE[$message] . $worker_id); $logger->write($this->_MESSAGE[$message] . $worker_id);