Executor::run() - Code Metrics - loevgaard/cron-bundle - Measure and Improve Code Quality continuously with Scrutinizer

Executor::run() B
last analyzed 2017-10-02 12:44 UTC

↳ Parent: Executor

Complexity

Conditions	5
Paths	5

Size

Total Lines	20
Code Lines	10

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	20
rs	8.8571
c	0
b	0
f	0
cc	5
eloc	10
nc	5
nop	1

<?php

namespace Loevgaard\CronBundle\Executor;

use Loevgaard\CronBundle\Entity\JobInterface;
use Symfony\Component\Process\Process;

class Executor
{
    /**
     * @var Process[]
     */
    protected $processes;

    public function __construct()
    {
        $this->processes = [];
    }

    /**
     * @param JobInterface[] $jobs
     */
    public function run(array $jobs)
    {
        foreach ($jobs as $job) {
            $p = new Process($job->getCommand().($job->getArguments() ? ' '.$job->getArguments() : ''));

            if ($job->getIdleTimeout()) {
                $p->setIdleTimeout($job->getIdleTimeout());
            }

            if ($job->getTimeout()) {
                $p->setIdleTimeout($job->getTimeout());
            }

            $p->start();

            $job->setPid($p->getPid());

            $this->processes[] = $p;
        }
    }

    /**
     * Returns true if any of the processes are still running.
     *
     * @return bool
     */
    public function isRunning(): bool
    {
        foreach ($this->processes as $process) {
            if ($process->isRunning()) {
                return true;
            }
        }

        return false;
    }
}


1			<?php
2
3			namespace Loevgaard\CronBundle\Executor;
4
5			use Loevgaard\CronBundle\Entity\JobInterface;
6			use Symfony\Component\Process\Process;
7
8			class Executor
9			{
10			/**
11			* @var Process[]
12			*/
13			protected $processes;
14
15			public function __construct()
16			{
17			$this->processes = [];
18			}
19
20			/**
21			* @param JobInterface[] $jobs
22			*/
23			public function run(array $jobs)
24			{
25			foreach ($jobs as $job) {
26			$p = new Process($job->getCommand().($job->getArguments() ? ' '.$job->getArguments() : ''));
27
28			if ($job->getIdleTimeout()) {
29			$p->setIdleTimeout($job->getIdleTimeout());
30			}
31
32			if ($job->getTimeout()) {
33			$p->setIdleTimeout($job->getTimeout());
34			}
35
36			$p->start();
37
38			$job->setPid($p->getPid());
39
40			$this->processes[] = $p;
41			}
42			}
43
44			/**
45			* Returns true if any of the processes are still running.
46			*
47			* @return bool
48			*/
49			public function isRunning(): bool
50			{
51			foreach ($this->processes as $process) {
52			if ($process->isRunning()) {
53			return true;
54			}
55			}
56
57			return false;
58			}
59			}
60

loevgaard / cron-bundle

Executor::run() B last analyzed 2017-10-02 12:44 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

Executor::run() B
last analyzed 2017-10-02 12:44 UTC