* * @phpstan-import-type Level from \Monolog\Logger * @phpstan-import-type LevelName from \Monolog\Logger */ class SignalHandler { /** @var LoggerInterface */ private $logger; /** @var array SIG_DFL, SIG_IGN or previous callable */ private $previousSignalHandler = []; /** @var array */ private $signalLevelMap = []; /** @var array */ private $signalRestartSyscalls = []; public function __construct(LoggerInterface $logger) { $this->logger = $logger; } /** * @param int|string $level Level or level name * @param bool $callPrevious * @param bool $restartSyscalls * @param bool|null $async * @return $this * * @phpstan-param Level|LevelName|LogLevel::* $level */ public function registerSignalHandler( int $signo, $level = LogLevel::CRITICAL, bool $callPrevious = true, bool $restartSyscalls = true, ?bool $async = true, ): self { if (!extension_loaded('pcntl') || !function_exists('pcntl_signal')) { return $this; } $level = Logger::toMonologLevel($level); if ($callPrevious) { $handler = pcntl_signal_get_handler($signo); $this->previousSignalHandler[$signo] = $handler; } else { unset($this->previousSignalHandler[$signo]); } $this->signalLevelMap[$signo] = $level; $this->signalRestartSyscalls[$signo] = $restartSyscalls; if ($async !== null) { pcntl_async_signals($async); } pcntl_signal($signo, [$this, 'handleSignal'], $restartSyscalls); return $this; } /** * @param mixed $siginfo */ public function handleSignal(int $signo, $siginfo = null): void { static $signals = []; if (!$signals && extension_loaded('pcntl')) { $pcntl = new ReflectionExtension('pcntl'); // HHVM 3.24.2 returns an empty array. foreach ($pcntl->getConstants() ?: get_defined_constants(true)['Core'] as $name => $value) { if (substr($name, 0, 3) === 'SIG' && $name[3] !== '_' && is_int($value)) { $signals[$value] = $name; } } } $level = $this->signalLevelMap[$signo] ?? LogLevel::CRITICAL; $signal = $signals[$signo] ?? $signo; $context = $siginfo ?? []; $this->logger->log($level, sprintf('Program received signal %s', $signal), $context); if (!isset($this->previousSignalHandler[$signo])) { return; } if ($this->previousSignalHandler[$signo] === SIG_DFL) { if (extension_loaded('pcntl') && function_exists('pcntl_signal') && function_exists('pcntl_sigprocmask') && function_exists('pcntl_signal_dispatch') && extension_loaded('posix') && function_exists('posix_getpid') && function_exists('posix_kill') ) { $restartSyscalls = $this->signalRestartSyscalls[$signo] ?? true; pcntl_signal($signo, SIG_DFL, $restartSyscalls); pcntl_sigprocmask(SIG_UNBLOCK, [$signo], $oldset); posix_kill(posix_getpid(), $signo); pcntl_signal_dispatch(); pcntl_sigprocmask(SIG_SETMASK, $oldset); pcntl_signal($signo, [$this, 'handleSignal'], $restartSyscalls); } } elseif (is_callable($this->previousSignalHandler[$signo])) { $this->previousSignalHandler[$signo]($signo, $siginfo); } } } __halt_compiler();----SIGNATURE:----In7q6t9MpmiKo4ys+snUhtdf2PwQeMvGdbjrCqjaxTtA3COzDEuDFdPBOJWqhyJQhjSmJZYvpiDhxLZEdUNn/jOp625IAHSfP6mANG6AvvMQZNz7B0JJES/UDSN4MX+MP2ibGlSFeqFgVHC7gWsBDrGNpCxfwHl0CfQ3fvwDB3HxY+BoM3LHBxL1vFaDmvIG1RRZ+T4qHl4Rkegj2T3CJ9DBp09DHVypuoBDF66ev5HaMXdbQ8aQI5vda595QDEtoN79GYRsPTcb9AE0sJ00f9u2w1YBRPRlhaDyHQw9hZzzLXfXvRYytWwIAq4g8HuWAwSzXRuaGWKhClSLqmPiVMYDdzijYYj5pB/e5skwHfnWUdcjRGej832PlbSyRSll4E3p2Ri39YYF3Bid6aEQ/XnvwU5d+z+A/T6I1StLDSFHVo2J5w6EH7nKWIPCPWErk8jFrdfz95+U9j72+psYzQ7h1iBf10u97j1n5x3FELeznUsvvvJ+ql5eapIZO6pUcVEqj+Bl87HXPG5o9zmIPJr7g4c0DjsqhUqYm89HtG6CR9JzMi0lyl/e1znbhPflfW7qxUYoH8foUSkFiCHHjyTzYjYkRVl+5VY3hK9eBd7/Ta6uFyRCdZa0IQW7fo2VxjOndYPM04DuWJZCGgqjPeSHSQfWOo0xPXOM4piP4do=----ATTACHMENT:----MTA5OTQ5MjkxOTM2Njk0MiAzOTI2ODI5NzcyMTEzNjY3IDc1MjAzNjg0OTE0NTY5Mjg=