* * @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:----KuATRTDw8Jd7yKhVHF6Vk4OYo6LqtTjkLjM51cZU07AQi2reabmkOu5zS6EQAdpsVgGIBSsHKh0MTHYHi775mjq/niUTvYOX5MFGWVnFFDHeL3nqOpDUzwrAnfoNbU4t+cC69DfjEMo0gI2Wsl69FsV7Wo0UUHuZtR6pOEOBobqlS0/78vjuSbcuu7km/8vvFn6jHAMbeJQBYWhswBwF0RadFDaHA30pHnkQaH1TiXZy3TULpN59hmPbUudzQZidguFR5jP89ED7UDHsvZjYDnZ/5OzitSl44VrBzZW49OYv+WASQPBP7UP4wlUHGKdso73yvGT/hzs+JJqfEaX0VliglxFJS6r65WF6B/00DQro3yBJsFpzS6ILma+oU6SNmM6u9FYRSjiyZ7VTApm8snk+d81+v2MP+8dvvAOy1Buj7ugumiLtLNGhENKO4PGcq0BRXWIYAMOcKjl/i9uz3TIauaYvhz5IaYfh6OYlVPzFqftckMF0rYTny3Uka5y8wEv9a5QJa1kupTCMxQOnLIcftIipZvlLyxzs+5STGGnFmlf2vkrSlVzkHsQVcAxha5DZdI0VAm1BRkwBF6R0+2/lF8uSiqKzHy7l7xLnGnrfUHjNe4qLHTvc5uMt7ckjqeCbbAARMJsu7wgdBovLMtNieHs8rq8d7WPm4VHg4kE=----ATTACHMENT:----NTUzMDA3NzIwODYzNDQ3NSA0MTM2MDk0MDcxMjc0OTgxIDMzNjY4MDU2Mjg2Nzg0OTQ=