PipelineCollection::__construct() - Code Metrics - Inspection of "Merge pull request #94 from facile-it/pipelines" - facile-it/paraunit - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( b61e2e...b32211 )

by Alessandro

created 2017-07-04 22:36 UTC

PipelineCollection::__construct() A

↳ Parent: PipelineCollection

Complexity

Conditions	2
Paths	2

Size

Total Lines	8
Code Lines	4

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	4
CRAP Score	2

Importance

Changes

Metric	Value
dl	0
loc	8
ccs	4
cts	4
cp	1
rs	9.4285
c	0
b	0
f	0
cc	2
eloc	4
nc	2
nop	2
crap	2

<?php

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		namespace Paraunit\Runner;
4
5		use Paraunit\Process\AbstractParaunitProcess;
6
7		/**
8		* Class PipelineCollection
9		* @package Paraunit\Runner
10		*/
11		class PipelineCollection
12		{
13		/** @var Pipeline[] \| \SplFixedArray */
14		private $pipelines;
15
16	40	public function __construct(PipelineFactory $pipelineFactory, int $maxProcessNumber = 10)
17		{
18	40	$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...
19
20	40	for ($pipelineNumber = 1; $pipelineNumber <= $maxProcessNumber; $pipelineNumber++) {
21	40	$this->pipelines->offsetSet($pipelineNumber - 1, $pipelineFactory->create($pipelineNumber));
22		}
23		}
24
25		/**
26		* @param AbstractParaunitProcess $process
27		* @return Pipeline
28		* @throws \RuntimeException
29		*/
30	17	public function push(AbstractParaunitProcess $process): Pipeline
31		{
32	17	foreach ($this->pipelines as $pipeline) {
33	17	if ($pipeline->isFree()) {
34	16	$pipeline->execute($process);
35
36	17	return $pipeline;
37		}
38		}
39
40	1	throw new \RuntimeException('Cannot find an available pipeline');
41		}
42
43	19	public function hasEmptySlots(): bool
44		{
45	19	foreach ($this->pipelines as $pipeline) {
46	19	if ($pipeline->isFree()) {
47	19	return true;
48		}
49		}
50
51	2	return false;
52		}
53
54	19	public function isEmpty(): bool
55		{
56	19	foreach ($this->pipelines as $pipeline) {
57	19	if (! $pipeline->isFree()) {
58	19	return false;
59		}
60		}
61
62	16	return true;
63		}
64
65	15	public function triggerProcessTermination()
66		{
67	15	foreach ($this->pipelines as $pipeline) {
68	15	$pipeline->triggerTermination();
69		}
70		}
71		}
72

facile-it / paraunit

Push — master ( b61e2e...b32211 )

PipelineCollection::__construct() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like