PhpProfiler\Inspector\Daemon\Dispatcher\WorkerPool

Complexity

Total Complexity

13

Size/Duplication

Total Lines	82
Duplicated Lines	0 %

Importance

Changes	2
Bugs	1	Features	1

6 Methods

Rating	Name	Duplication	Size	Complexity
A	getWorkers()	0	4	2
A	__construct()	0	5	1
A	getFreeWorker()	0	9	3
A	returnWorkerToPool()	0	5	3
A	create()	0	26	3
A	debugDump()	0	5	1

<?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\Inspector\Daemon\Dispatcher;

use Amp\Promise;

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

use PhpProfiler\Inspector\Daemon\Reader\Context\PhpReaderContextCreatorInterface;
use PhpProfiler\Inspector\Daemon\Reader\Controller\PhpReaderControllerInterface;
use PhpProfiler\Inspector\Settings\GetTraceSettings\GetTraceSettings;
use PhpProfiler\Inspector\Settings\TargetPhpSettings\TargetPhpSettings;
use PhpProfiler\Inspector\Settings\TraceLoopSettings\TraceLoopSettings;

final class WorkerPool implements WorkerPoolInterface
{
    /** @var array<int, PhpReaderControllerInterface> */
    private array $contexts;

    /** @var array<int, bool> */
    private array $is_free_list;

    /** @var array<int, bool> */
    private array $on_read_list;

    /** @no-named-arguments */
    public function __construct(PhpReaderControllerInterface ...$contexts)
    {
        $this->contexts = $contexts;
        $this->is_free_list = array_fill(0, count($contexts), true);
        $this->on_read_list = array_fill(0, count($contexts), false);
    }

    public static function create(
        PhpReaderContextCreatorInterface $creator,
        int $number,
        TargetPhpSettings $target_php_settings,
        TraceLoopSettings $loop_settings,
        GetTraceSettings $get_trace_settings
    ): self {
        $contexts = [];
        $started = [];
        for ($i = 0; $i < $number; $i++) {
            $context = $creator->create();
            $started[] = $context->start();
            $contexts[] = $context;
        }
        Promise\wait(Promise\all($started));

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

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

        $send_settings = [];
        for ($i = 0; $i < $number; $i++) {
            $send_settings[] = $contexts[$i]->sendSettings(
                $target_php_settings,
                $loop_settings,
                $get_trace_settings
            );
        }
        Promise\wait(Promise\all($send_settings));

        return new self(...$contexts);
    }

    public function getFreeWorker(): ?PhpReaderControllerInterface
    {
        foreach ($this->contexts as $key => $context) {
            if ($this->is_free_list[$key]) {
                $this->is_free_list[$key] = false;
                return $context;
            }
        }
        return null;
    }

    /**
     * @return iterable<int, PhpReaderControllerInterface>
     */
    public function getWorkers(): iterable
    {
        foreach ($this->contexts as $key => $context) {
            yield $key => $context;
        }
    }

    public function returnWorkerToPool(PhpReaderControllerInterface $context_to_return): void
    {
        foreach ($this->contexts as $key => $context) {
            if ($context === $context_to_return) {
                $this->is_free_list[$key] = true;
            }
        }
    }

    public function debugDump(): array
    {
        return [
            'all' => array_keys($this->contexts),
            'is_free_list' => $this->is_free_list,
        ];
    }
}