This commit is contained in:
2021-02-22 18:04:32 +08:00
parent 12ba82bf49
commit 95970faecb
+7 -1
View File
@@ -51,12 +51,18 @@ class OnWorkerStart extends Callback
*/ */
private function setWorkerAction($worker_id) private function setWorkerAction($worker_id)
{ {
$event = Snowflake::app()->getEvent();
try { try {
$this->debug(sprintf('Worker #%d is start.....', $worker_id)); $this->debug(sprintf('Worker #%d is start.....', $worker_id));
$event = Snowflake::app()->getEvent();
$event->trigger(Event::SERVER_WORKER_START, [$worker_id]); $event->trigger(Event::SERVER_WORKER_START, [$worker_id]);
} catch (\Throwable $exception) {
$this->addError($exception);
write($exception->getMessage(), 'worker');
}
try {
$event->trigger(Event::SERVER_AFTER_WORKER_START, [$worker_id]); $event->trigger(Event::SERVER_AFTER_WORKER_START, [$worker_id]);
} catch (\Throwable $exception) { } catch (\Throwable $exception) {
$this->addError($exception);
write($exception->getMessage(), 'worker'); write($exception->getMessage(), 'worker');
} }
} }