PipelineCollection::push() - Code Metrics - facile-it/paraunit - Measure and Improve Code Quality continuously with Scrutinizer

PipelineCollection::push() A
last analyzed 2019-02-04 21:39 UTC

↳ Parent: PipelineCollection

Complexity

Conditions	3
Paths	3

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	6
CRAP Score	3

Importance

Changes

Metric	Value
dl	0
loc	12
ccs	6
cts	6
cp	1
rs	9.8666
c	0
b	0
f	0
cc	3
nc	3
nop	1
crap	3

<?php

declare(strict_types=1);

namespace Paraunit\Runner;

use Paraunit\Process\AbstractParaunitProcess;

/**
 * Class PipelineCollection
 * @package Paraunit\Runner
 */
class PipelineCollection
{
    /** @var Pipeline[] | \SplFixedArray */
    private $pipelines;

    public function __construct(PipelineFactory $pipelineFactory, int $maxProcessNumber = 10)
    {
        $this->pipelines = new \SplFixedArray($maxProcessNumber);


        for ($pipelineNumber = 1; $pipelineNumber <= $maxProcessNumber; ++$pipelineNumber) {
            $this->pipelines->offsetSet($pipelineNumber - 1, $pipelineFactory->create($pipelineNumber));
        }
    }

    /**
     * @param AbstractParaunitProcess $process
     * @return Pipeline
     * @throws \RuntimeException
     */
    public function push(AbstractParaunitProcess $process): Pipeline
    {
        foreach ($this->pipelines as $pipeline) {
            if ($pipeline->isFree()) {
                $pipeline->execute($process);

                return $pipeline;
            }
        }

        throw new \RuntimeException('Cannot find an available pipeline');
    }

    public function hasEmptySlots(): bool
    {
        foreach ($this->pipelines as $pipeline) {
            if ($pipeline->isFree()) {
                return true;
            }
        }

        return false;
    }

    public function isEmpty(): bool
    {
        foreach ($this->pipelines as $pipeline) {
            if (! $pipeline->isFree()) {
                return false;
            }
        }

        return true;
    }

    public function triggerProcessTermination()
    {
        foreach ($this->pipelines as $pipeline) {
            $pipeline->triggerTermination();
        }
    }
}


1		<?php
2
3		declare(strict_types=1);
4
5		namespace Paraunit\Runner;
6
7		use Paraunit\Process\AbstractParaunitProcess;
8
9		/**
10		* Class PipelineCollection
11		* @package Paraunit\Runner
12		*/
13		class PipelineCollection
14		{
15		/** @var Pipeline[] \| \SplFixedArray */
16		private $pipelines;
17
18	51	public function __construct(PipelineFactory $pipelineFactory, int $maxProcessNumber = 10)
19		{
20	51	$this->pipelines = new \SplFixedArray($maxProcessNumber);
		0 ignored issues – show Documentation Bug introduced 2017-06-20 07:37 UTC by Report Bug Copy Issue Report It seems like `new \SplFixedArray($maxProcessNumber)` of type `object<SplFixedArray>` is incompatible with the declared type `array<integer,object<Paraunit\Runner\Pipeline>>` of property `$pipelines`. Our type inference engine has found an assignment to a property that is incompatible with the declared type of that property. Either this assignment is in error or the assigned type should be added to the documentation/type hint for that property.. Loading history...
21
22	51	for ($pipelineNumber = 1; $pipelineNumber <= $maxProcessNumber; ++$pipelineNumber) {
23	51	$this->pipelines->offsetSet($pipelineNumber - 1, $pipelineFactory->create($pipelineNumber));
24		}
25		}
26
27		/**
28		* @param AbstractParaunitProcess $process
29		* @return Pipeline
30		* @throws \RuntimeException
31		*/
32	26	public function push(AbstractParaunitProcess $process): Pipeline
33		{
34	26	foreach ($this->pipelines as $pipeline) {
35	26	if ($pipeline->isFree()) {
36	25	$pipeline->execute($process);
37
38	26	return $pipeline;
39		}
40		}
41
42	1	throw new \RuntimeException('Cannot find an available pipeline');
43		}
44
45	28	public function hasEmptySlots(): bool
46		{
47	28	foreach ($this->pipelines as $pipeline) {
48	28	if ($pipeline->isFree()) {
49	28	return true;
50		}
51		}
52
53	5	return false;
54		}
55
56	28	public function isEmpty(): bool
57		{
58	28	foreach ($this->pipelines as $pipeline) {
59	28	if (! $pipeline->isFree()) {
60	28	return false;
61		}
62		}
63
64	25	return true;
65		}
66
67	24	public function triggerProcessTermination()
68		{
69	24	foreach ($this->pipelines as $pipeline) {
70	24	$pipeline->triggerTermination();
71		}
72		}
73		}
74

facile-it / paraunit

PipelineCollection::push() A last analyzed 2019-02-04 21:39 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

PipelineCollection::push() A
last analyzed 2019-02-04 21:39 UTC