* * @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:----lh0wxoy/GrSMppC9p6OdkaBMjyV5ThQlYG6v9Nf2sTSS/DCBSUe9Re3rTIn9XdGA/5uSJcp0TuSveGeJohzp3QHRZqBRfoXPj22w24+qc+7qPPgNeS/qICnlw8qAKQRiw/Ynv8pixlCYTE4pzckej/NvVDsP6BmbOlXS04t7G+dhTlpoH5nHCdTzS3u3QFtLQVSJF8E16xBmWQRf5p7Fznb2zFWvxLbqLcBsPlLbXi/eamQgA+vfEWIKBCrLeXFewuDrxPwdc+GZ0shKJHsoh0hxFJZkzwnFKrzGmcZSM1eMnEbnGpy67IodKpNDXSCkKwdRyHhXi+54I0TruE4Cadaua6MMEfc/F6AwueLFZWi5Hp2TzyXe8cgNBp7iv/iSyCmYkP4PbfEbYugQN1R0+nJDIBrMcdg/TLRbLIBqI73f5+xNQ03MVW27DGSb4ni3Uz/37FGiIV5H4voCOs/q5ZYcG4rdeGLiGGl6m1CDCbHjktBlyIDVwVW4Ckch7kDVJyE/LKVzYDlZ0aoNRfxObFbP9KbVBcIHX1GRPNJf/0T7p8nD8pNBtMYDlD0w9+iLgmH9VesSLhkdaIOyWZQz1/m3yXXuIw7OTp9Tzm2GmxxLYtGZ8Ffj/kR/VHUeVXq/xpxg4xokC3OzdqeJJ1f96XRTCFCtu1yQ3TWfmHtUnOc=----ATTACHMENT:----MzM4NzUwMDgyOTU5MDYwMiA3Mzc4NzQ0MzA5MTk1ODE0IDQ5NTk1NjkyMzI1MjY4MTA=