PhpProfiler\Command\Inspector\DaemonCommand

Complexity

Total Complexity

6

Size/Duplication

Total Lines	124
Duplicated Lines	0 %

Importance

Changes	4
Bugs	0	Features	1

2 Methods

Rating	Name	Duplication	Size	Complexity
A	configure()	0	52	1
A	execute()	0	61	5

<?php

/**
 * This file is part of the sj-i/php-profiler package.
 *
 * (c) sji <sji@sj-i.dev>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace PhpProfiler\Command\Inspector;

use Amp\Loop;

The type Amp\Loop was not found. Maybe you did not declare it correctly or list all dependencies?

use Amp\Promise;

The type Amp\Promise was not found. Maybe you did not declare it correctly or list all dependencies?

use Amp\Parallel\Context;

The type Amp\Parallel\Context was not found. Maybe you did not declare it correctly or list all dependencies?

use PhpProfiler\Command\Inspector\Settings\GetTraceSettings;
use PhpProfiler\Command\Inspector\Settings\TargetPhpSettings;
use PhpProfiler\Command\Inspector\Settings\TraceLoopSettings;
use Symfony\Component\Console\Command\Command;

The type Symfony\Component\Console\Command\Command was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Console\Input\InputInterface;

The type Symfony\Component\Console\Input\InputInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Console\Input\InputOption;

The type Symfony\Component\Console\Input\InputOption was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Console\Output\OutputInterface;

The type Symfony\Component\Console\Output\OutputInterface was not found. Maybe you did not declare it correctly or list all dependencies?

final class DaemonCommand extends Command
{
    public function configure(): void
    {
        $this->setName('inspector:daemon')
            ->setDescription('periodically get running function name from an outer process or thread')
            ->addOption(
                'target-regex',
                'P',
                InputOption::VALUE_OPTIONAL,
                'regex to find the php binary loaded in the target process'
            )
            ->addOption('depth', 'd', InputOption::VALUE_OPTIONAL, 'max depth')
            ->addOption(
                'sleep-ns',
                's',
                InputOption::VALUE_OPTIONAL,
                'nanoseconds between traces (default: 1000 * 1000 * 10)'
            )
            ->addOption(
                'max-retries',
                'r',
                InputOption::VALUE_OPTIONAL,
                'max retries on contiguous errors of read (default: 10)'
            )
            ->addOption(
                'php-regex',
                null,
                InputOption::VALUE_OPTIONAL,
                'regex to find the php binary loaded in the target process'
            )
            ->addOption(
                'libpthread-regex',
                null,
                InputOption::VALUE_OPTIONAL,
                'regex to find the libpthread.so loaded in the target process'
            )
            ->addOption(
                'php-version',
                null,
                InputOption::VALUE_OPTIONAL,
                'php version of the target'
            )
            ->addOption(
                'php-path',
                null,
                InputOption::VALUE_OPTIONAL,
                'path to the php binary (only needed in tracing chrooted ZTS target)'
            )
            ->addOption(
                'libpthread-path',
                null,
                InputOption::VALUE_OPTIONAL,
                'path to the libpthread.so (only needed in tracing chrooted ZTS target)'
            )
        ;
    }

    /**
     * @param InputInterface $input
     * @param OutputInterface $output
     * @return int
     */
    public function execute(InputInterface $input, OutputInterface $output): int
    {
        $target_php_settings = TargetPhpSettings::fromConsoleInput($input);
        $loop_settings = TraceLoopSettings::fromConsoleInput($input);
        $get_trace_settings = GetTraceSettings::fromConsoleInput($input);

        /** @var string $target_regex */
        $target_regex = '{' . ($input->getOption('target-regex') ?? '^php-fpm') . '}';
        $context = Context\create(__DIR__ . '/Worker/php-searcher.php');

The function create was not found. Maybe you did not declare it correctly or list all dependencies?

        /** @var int $searcher_pid */
        $searcher_pid = Promise\wait($context->start());

The function wait was not found. Maybe you did not declare it correctly or list all dependencies?

The assignment to $searcher_pid is dead and can be removed.

        Promise\wait($context->send($target_regex));
        /** @var int[] $pid_list */
        $pid_list = Promise\wait($context->receive());
        $readers = [];
        foreach ($pid_list as $target_pid) {
            $context = Context\create(__DIR__ . '/Worker/php-reader.php');
            Promise\wait($context->start());
            Promise\wait($context->send([$target_pid, $target_php_settings, $loop_settings, $get_trace_settings]));
            $readers[$target_pid] = $context;
        }
        exec('stty -icanon -echo');

        Loop::run(function () use (&$readers, $output) {
            Loop::onReadable(
                STDIN,
                /** @param resource $stream */
                function (string $watcher_id, $stream) {
                    $key = fread($stream, 1);
                    if ($key === 'q') {
                        Loop::cancel($watcher_id);
                        Loop::stop();
                    }
                }
            );
            Loop::repeat(10, function () use (&$readers, $output) {
                /** @var array<int, Context\Context> $readers */

                $promises = [];
                foreach ($readers as $pid => $reader) {
                    if (!$reader->isRunning()) {
                        /** @psalm-suppress MixedArrayAccess*/
                        unset($readers[$pid]);
                        continue;
                    }
                    $promises[] = \Amp\call(

The function call was not found. Maybe you did not declare it correctly or list all dependencies?

                        function () use ($reader, &$readers, $pid, $output) {
                            /** @psalm-suppress MixedArrayAccess*/
                            unset($readers[$pid]);
                            /** @var string $result */
                            $result = yield $reader->receive();
                            $output->write($result);
                            $readers[$pid] = $reader;
                        }
                    );
                }
                yield $promises;
            });
        });

        return 0;
    }
}