Runner::run() - Code Metrics - Inspection of "Support PHPUnit its --only-repeat-failed option" - brianium/paratest - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#218)

unknown

created 2016-07-19 12:41 UTC

Runner::run() B

↳ Parent: Runner

Complexity

Conditions	6
Paths	5

Size

Total Lines	20
Code Lines	12

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	15
CRAP Score	6.0585

Importance

Changes	6
Bugs	0	Features	1

Metric	Value
c	6
b	0
f	1
dl	0
loc	20
ccs	15
cts	17
cp	0.8824
rs	8.8571
cc	6
eloc	12
nc	5
nop	0
crap	6.0585

<?php
namespace ParaTest\Runners\PHPUnit;

use Habitat\Habitat;

class Runner extends BaseRunner
{
    /**
     * A collection of available tokens based on the number
     * of processes specified in $options
     *
     * @var array
     */
    protected $tokens = array();


    public function __construct($opts = array())
    {
        parent::__construct($opts);
        $this->initTokens();
    }

    /**
     * The money maker. Runs all ExecutableTest objects in separate processes.
     */
    public function run()
    {
        parent::run();

        while (count($this->running) || count($this->pending)) {
            /** @var ExecutableTest $test */
            foreach ($this->running as $key => $test) {
                if (!$this->testIsStillRunning($test)) {
                    if ($test->getExitCode() === 0) {
                        $this->succeeded[] = $test;
                    }
                    unset($this->running[$key]);
                    $this->releaseToken($key);
                }
            }
            $this->fillRunQueue();
            usleep(10000);
        }
        $this->complete();
    }

    /**
     * Finalizes the run process. This method
     * prints all results, rewinds the log interpreter,
     * logs any results to JUnit, and cleans up temporary
     * files
     */
    public function complete()
    {
        $this->printer->printResults();
        $this->interpreter->rewind();
        $this->log();
        $this->logCoverage();
        $readers = $this->interpreter->getReaders();
        foreach ($readers as $reader) {
            $reader->removeLog();
        }
    }

    /**
     * This method removes ExecutableTest objects from the pending collection
     * and adds them to the running collection. It is also in charge of recycling and
     * acquiring available test tokens for use
     */
    private function fillRunQueue()
    {
        $opts = $this->options;
        while (sizeof($this->pending) && sizeof($this->running) < $opts->processes) {
<?php

/**
 * @property int $x
 * @property int $y
 * @property string $text
 */
class MyLabel
{
    private $properties;

    private $allowedProperties = array('x', 'y', 'text');

    public function __get($name)
    {
        if (isset($properties[$name]) && in_array($name, $this->allowedProperties)) {
            return $properties[$name];
        } else {
            return null;
        }
    }

    public function __set($name, $value)
    {
        if (in_array($name, $this->allowedProperties)) {
            $properties[$name] = $value;
        } else {
            throw new \LogicException("Property $name is not defined.");
        }
    }

}
            $tokenData = $this->getNextAvailableToken();
            if ($tokenData !== false) {
                $this->acquireToken($tokenData['token']);
                $env = array('TEST_TOKEN' => $tokenData['token'], 'UNIQUE_TEST_TOKEN' => $tokenData['unique']) + Habitat::getAll();
                $this->running[$tokenData['token']] = array_shift($this->pending)->run($opts->phpunit, $opts->filtered, $env);
<?php

/**
 * @property int $x
 * @property int $y
 * @property string $text
 */
class MyLabel
{
    private $properties;

    private $allowedProperties = array('x', 'y', 'text');

    public function __get($name)
    {
        if (isset($properties[$name]) && in_array($name, $this->allowedProperties)) {
            return $properties[$name];
        } else {
            return null;
        }
    }

    public function __set($name, $value)
    {
        if (in_array($name, $this->allowedProperties)) {
            $properties[$name] = $value;
        } else {
            throw new \LogicException("Property $name is not defined.");
        }
    }

}
            }
        }
    }

    /**
     * Returns whether or not a test has finished being
     * executed. If it has, this method also halts a test process - optionally
     * throwing an exception if a fatal error has occurred -
     * prints feedback, and updates the overall exit code
     *
     * @param ExecutableTest $test
     * @return bool
     * @throws \Exception
     */
    private function testIsStillRunning($test)
    {
        if (!$test->isDoneRunning()) {
            return true;
        }
        $this->setExitCode($test);
        $test->stop();
        if ($this->options->stopOnFailure && $test->getExitCode() > 0) {
<?php

/**
 * @property int $x
 * @property int $y
 * @property string $text
 */
class MyLabel
{
    private $properties;

    private $allowedProperties = array('x', 'y', 'text');

    public function __get($name)
    {
        if (isset($properties[$name]) && in_array($name, $this->allowedProperties)) {
            return $properties[$name];
        } else {
            return null;
        }
    }

    public function __set($name, $value)
    {
        if (in_array($name, $this->allowedProperties)) {
            $properties[$name] = $value;
        } else {
            throw new \LogicException("Property $name is not defined.");
        }
    }

}
            $this->pending = array();
        }
        if (static::PHPUNIT_FATAL_ERROR === $test->getExitCode()) {
            $errorOutput = $test->getStderr();
            if (!$errorOutput) {
                $errorOutput = $test->getStdout();
            }
            throw new \Exception($errorOutput);
        }
        $this->printer->printFeedback($test);
        if ($this->hasCoverage()) {
            $this->addCoverage($test);
        }

        return false;
    }

    /**
     * If the provided test object has an exit code
     * higher than the currently set exit code, that exit
     * code will be set as the overall exit code
     *
     * @param ExecutableTest $test
     */
    private function setExitCode(ExecutableTest $test)
    {
        $exit = $test->getExitCode();
        if ($exit > $this->exitcode) {
            $this->exitcode = $exit;
        }
    }

    /**
     * Initialize the available test tokens based
     * on how many processes ParaTest will be run in
     */
    protected function initTokens()
    {
        $this->tokens = array();
        for ($i = 0; $i < $this->options->processes; $i++) {
<?php

/**
 * @property int $x
 * @property int $y
 * @property string $text
 */
class MyLabel
{
    private $properties;

    private $allowedProperties = array('x', 'y', 'text');

    public function __get($name)
    {
        if (isset($properties[$name]) && in_array($name, $this->allowedProperties)) {
            return $properties[$name];
        } else {
            return null;
        }
    }

    public function __set($name, $value)
    {
        if (in_array($name, $this->allowedProperties)) {
            $properties[$name] = $value;
        } else {
            throw new \LogicException("Property $name is not defined.");
        }
    }

}
            $this->tokens[$i] = array('token' => $i, 'unique' => uniqid($i), 'available' => true);
        }
    }

    /**
     * Gets the next token that is available to be acquired
     * from a finished process
     *
     * @return bool|array
     */
    protected function getNextAvailableToken()
    {
        foreach ($this->tokens as $data) {
            if ($data['available']) {
                return $data;
            }
        }
        return false;
    }

    /**
     * Flag a token as available for use
     *
     * @param string $tokenIdentifier
     */
    protected function releaseToken($tokenIdentifier)
    {
        $filtered = array_filter($this->tokens, function ($val) use ($tokenIdentifier) {
            return ($val['token'] === $tokenIdentifier);
        });
        $keys = array_keys($filtered);
        $this->tokens[$keys[0]]['available'] = true;
    }

    /**
     * Flag a token as acquired and not available for use
     *
     * @param string $tokenIdentifier
     */
    protected function acquireToken($tokenIdentifier)
    {
        $filtered = array_filter($this->tokens, function ($val) use ($tokenIdentifier) {
            return ($val['token'] === $tokenIdentifier);
        });
        $keys = array_keys($filtered);
        $this->tokens[$keys[0]]['available'] = false;
    }

    /**
     * @param ExecutableTest $test
     */
    private function addCoverage(ExecutableTest $test)
    {
        $coverageFile = $test->getCoverageFileName();
        $this->getCoverage()->addCoverageFromFile($coverageFile);
    }
}


1		<?php
2		namespace ParaTest\Runners\PHPUnit;
3
4		use Habitat\Habitat;
5
6		class Runner extends BaseRunner
7		{
8		/**
9		* A collection of available tokens based on the number
10		* of processes specified in $options
11		*
12		* @var array
13		*/
14		protected $tokens = array();
15
16
17	8	public function __construct($opts = array())
18		{
19	8	parent::__construct($opts);
20	8	$this->initTokens();
21	8	}
22
23		/**
24		* The money maker. Runs all ExecutableTest objects in separate processes.
25		*/
26	2	public function run()
27		{
28	2	parent::run();
29
30	2	while (count($this->running) \|\| count($this->pending)) {
31		/** @var ExecutableTest $test */
32	2	foreach ($this->running as $key => $test) {
33	2	if (!$this->testIsStillRunning($test)) {
34	2	if ($test->getExitCode() === 0) {
35		$this->succeeded[] = $test;
36		}
37	2	unset($this->running[$key]);
38	2	$this->releaseToken($key);
39	2	}
40	2	}
41	2	$this->fillRunQueue();
42	2	usleep(10000);
43	2	}
44	2	$this->complete();
45	2	}
46
47		/**
48		* Finalizes the run process. This method
49		* prints all results, rewinds the log interpreter,
50		* logs any results to JUnit, and cleans up temporary
51		* files
52		*/
53	2	public function complete()
54		{
55	2	$this->printer->printResults();
56	2	$this->interpreter->rewind();
57	2	$this->log();
58	2	$this->logCoverage();
59	2	$readers = $this->interpreter->getReaders();
60	2	foreach ($readers as $reader) {
61	2	$reader->removeLog();
62	2	}
63	2	}
64
65		/**
66		* This method removes ExecutableTest objects from the pending collection
67		* and adds them to the running collection. It is also in charge of recycling and
68		* acquiring available test tokens for use
69		*/
70	2	private function fillRunQueue()
71		{
72	2	$opts = $this->options;
73	2	while (sizeof($this->pending) && sizeof($this->running) < $opts->processes) {
		0 ignored issues – show Documentation introduced 2015-12-02 18:19 UTC by Report Bug Copy Issue Report The property `$processes` is declared protected in `ParaTest\Runners\PHPUnit\Options`. Since you implemented `__get()`, maybe consider adding a @property or @property-read annotation. This makes it easier for IDEs to provide auto-completion. Since your code implements the magic setter `_set`, this function will be called for any write access on an undefined variable. You can add the `@property` annotation to your class or interface to document the existence of this variable. <?php /** * @property int $x * @property int $y * @property string $text */ class MyLabel { private $properties; private $allowedProperties = array('x', 'y', 'text'); public function __get($name) { if (isset($properties[$name]) && in_array($name, $this->allowedProperties)) { return $properties[$name]; } else { return null; } } public function __set($name, $value) { if (in_array($name, $this->allowedProperties)) { $properties[$name] = $value; } else { throw new \LogicException("Property $name is not defined."); } } } Since the property has write access only, you can use the @property-write annotation instead. Of course, you may also just have mistyped another name, in which case you should fix the error. See also the PhpDoc documentation for @property. Loading history...
74	2	$tokenData = $this->getNextAvailableToken();
75	2	if ($tokenData !== false) {
76	2	$this->acquireToken($tokenData['token']);
77	2	$env = array('TEST_TOKEN' => $tokenData['token'], 'UNIQUE_TEST_TOKEN' => $tokenData['unique']) + Habitat::getAll();
78	2	$this->running[$tokenData['token']] = array_shift($this->pending)->run($opts->phpunit, $opts->filtered, $env);
		0 ignored issues – show Documentation introduced 2015-12-02 18:19 UTC by Report Bug Copy Issue Report The property `$phpunit` is declared protected in `ParaTest\Runners\PHPUnit\Options`. Since you implemented `__get()`, maybe consider adding a @property or @property-read annotation. This makes it easier for IDEs to provide auto-completion. Since your code implements the magic setter `_set`, this function will be called for any write access on an undefined variable. You can add the `@property` annotation to your class or interface to document the existence of this variable. <?php /** * @property int $x * @property int $y * @property string $text / class MyLabel { private $properties; private $allowedProperties = array('x', 'y', 'text'); public function __get($name) { if (isset($properties[$name]) && in_array($name, $this->allowedProperties)) { return $properties[$name]; } else { return null; } } public function __set($name, $value) { if (in_array($name, $this->allowedProperties)) { $properties[$name] = $value; } else { throw new \LogicException("Property $name is not defined."); } } } Since the property has write access only, you can use the @property-write annotation instead. Of course, you may also just have mistyped another name, in which case you should fix the error. See also the PhpDoc documentation for @property. Loading history... Documentation introduced 2015-12-02 18:19 UTC by Report Bug Copy Issue Report The property `$filtered` is declared protected in `ParaTest\Runners\PHPUnit\Options`. Since you implemented `__get()`, maybe consider adding a @property or @property-read annotation. This makes it easier for IDEs to provide auto-completion. Since your code implements the magic setter `_set`, this function will be called for any write access on an undefined variable. You can add the `@property` annotation to your class or interface to document the existence of this variable. <?php /* * @property int $x * @property int $y * @property string $text */ class MyLabel { private $properties; private $allowedProperties = array('x', 'y', 'text'); public function __get($name) { if (isset($properties[$name]) && in_array($name, $this->allowedProperties)) { return $properties[$name]; } else { return null; } } public function __set($name, $value) { if (in_array($name, $this->allowedProperties)) { $properties[$name] = $value; } else { throw new \LogicException("Property $name is not defined."); } } } Since the property has write access only, you can use the @property-write annotation instead. Of course, you may also just have mistyped another name, in which case you should fix the error. See also the PhpDoc documentation for @property. Loading history...
79	2	}
80	2	}
81	2	}
82
83		/**
84		* Returns whether or not a test has finished being
85		* executed. If it has, this method also halts a test process - optionally
86		* throwing an exception if a fatal error has occurred -
87		* prints feedback, and updates the overall exit code
88		*
89		* @param ExecutableTest $test
90		* @return bool
91		* @throws \Exception
92		*/
93	2	private function testIsStillRunning($test)
94		{
95	2	if (!$test->isDoneRunning()) {
96	2	return true;
97		}
98	2	$this->setExitCode($test);
99	2	$test->stop();
100	2	if ($this->options->stopOnFailure && $test->getExitCode() > 0) {
		0 ignored issues – show Documentation introduced 2015-12-02 18:19 UTC by Report Bug Copy Issue Report The property `$stopOnFailure` is declared protected in `ParaTest\Runners\PHPUnit\Options`. Since you implemented `__get()`, maybe consider adding a @property or @property-read annotation. This makes it easier for IDEs to provide auto-completion. Since your code implements the magic setter `_set`, this function will be called for any write access on an undefined variable. You can add the `@property` annotation to your class or interface to document the existence of this variable. <?php /** * @property int $x * @property int $y * @property string $text */ class MyLabel { private $properties; private $allowedProperties = array('x', 'y', 'text'); public function __get($name) { if (isset($properties[$name]) && in_array($name, $this->allowedProperties)) { return $properties[$name]; } else { return null; } } public function __set($name, $value) { if (in_array($name, $this->allowedProperties)) { $properties[$name] = $value; } else { throw new \LogicException("Property $name is not defined."); } } } Since the property has write access only, you can use the @property-write annotation instead. Of course, you may also just have mistyped another name, in which case you should fix the error. See also the PhpDoc documentation for @property. Loading history...
101		$this->pending = array();
102		}
103	2	if (static::PHPUNIT_FATAL_ERROR === $test->getExitCode()) {
104		$errorOutput = $test->getStderr();
105		if (!$errorOutput) {
106		$errorOutput = $test->getStdout();
107		}
108		throw new \Exception($errorOutput);
109		}
110	2	$this->printer->printFeedback($test);
111	2	if ($this->hasCoverage()) {
112	2	$this->addCoverage($test);
113	2	}
114
115	2	return false;
116		}
117
118		/**
119		* If the provided test object has an exit code
120		* higher than the currently set exit code, that exit
121		* code will be set as the overall exit code
122		*
123		* @param ExecutableTest $test
124		*/
125	2	private function setExitCode(ExecutableTest $test)
126		{
127	2	$exit = $test->getExitCode();
128	2	if ($exit > $this->exitcode) {
129	2	$this->exitcode = $exit;
130	2	}
131	2	}
132
133		/**
134		* Initialize the available test tokens based
135		* on how many processes ParaTest will be run in
136		*/
137	8	protected function initTokens()
138		{
139	8	$this->tokens = array();
140	8	for ($i = 0; $i < $this->options->processes; $i++) {
		0 ignored issues – show Documentation introduced 2015-12-02 18:19 UTC by Report Bug Copy Issue Report The property `$processes` is declared protected in `ParaTest\Runners\PHPUnit\Options`. Since you implemented `__get()`, maybe consider adding a @property or @property-read annotation. This makes it easier for IDEs to provide auto-completion. Since your code implements the magic setter `_set`, this function will be called for any write access on an undefined variable. You can add the `@property` annotation to your class or interface to document the existence of this variable. <?php /** * @property int $x * @property int $y * @property string $text */ class MyLabel { private $properties; private $allowedProperties = array('x', 'y', 'text'); public function __get($name) { if (isset($properties[$name]) && in_array($name, $this->allowedProperties)) { return $properties[$name]; } else { return null; } } public function __set($name, $value) { if (in_array($name, $this->allowedProperties)) { $properties[$name] = $value; } else { throw new \LogicException("Property $name is not defined."); } } } Since the property has write access only, you can use the @property-write annotation instead. Of course, you may also just have mistyped another name, in which case you should fix the error. See also the PhpDoc documentation for @property. Loading history...
141	8	$this->tokens[$i] = array('token' => $i, 'unique' => uniqid($i), 'available' => true);
142	8	}
143	8	}
144
145		/**
146		* Gets the next token that is available to be acquired
147		* from a finished process
148		*
149		* @return bool\|array
150		*/
151	4	protected function getNextAvailableToken()
152		{
153	4	foreach ($this->tokens as $data) {
154	4	if ($data['available']) {
155	3	return $data;
156		}
157	4	}
158	1	return false;
159		}
160
161		/**
162		* Flag a token as available for use
163		*
164		* @param string $tokenIdentifier
165		*/
166	3	protected function releaseToken($tokenIdentifier)
167		{
168		$filtered = array_filter($this->tokens, function ($val) use ($tokenIdentifier) {
169	3	return ($val['token'] === $tokenIdentifier);
170	3	});
171	3	$keys = array_keys($filtered);
172	3	$this->tokens[$keys[0]]['available'] = true;
173	3	}
174
175		/**
176		* Flag a token as acquired and not available for use
177		*
178		* @param string $tokenIdentifier
179		*/
180	2	protected function acquireToken($tokenIdentifier)
181		{
182		$filtered = array_filter($this->tokens, function ($val) use ($tokenIdentifier) {
183	2	return ($val['token'] === $tokenIdentifier);
184	2	});
185	2	$keys = array_keys($filtered);
186	2	$this->tokens[$keys[0]]['available'] = false;
187	2	}
188
189		/**
190		* @param ExecutableTest $test
191		*/
192	2	private function addCoverage(ExecutableTest $test)
193		{
194	2	$coverageFile = $test->getCoverageFileName();
195	2	$this->getCoverage()->addCoverageFromFile($coverageFile);
196	2	}
197		}
198

brianium / paratest

Pull Request — master (#218)

Runner::run() B

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like