RunCommand::runStart() - Code Metrics - Inspection of "Merge branch 'feature/doctrine_orm'" - mmucklo/DtcQueueBundle - Measure and Improve Code Quality continuously with Scrutinizer

Test Setup Failed

Push — master ( 298fd3...56daff )

by Matthew

created 2017-10-14 18:10 UTC

RunCommand::runStart() C

↳ Parent: RunCommand

Complexity

Conditions	8
Paths	24

Size

Total Lines	30
Code Lines	23

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	30
rs	5.3846
c	0
b	0
f	0
cc	8
eloc	23
nc	24
nop	3

<?php

namespace Dtc\QueueBundle\Command;

use Doctrine\Common\Persistence\ObjectManager;
use Dtc\QueueBundle\Model\Job;
use Dtc\QueueBundle\Model\Run;
use Psr\Log\LoggerInterface;
use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;

class RunCommand extends ContainerAwareCommand
{
    /** @var ObjectManager */
    protected $runManager;

    /** @var Run $run */
    protected $run;

    /** @var string */
    protected $runClass;

    /** @var OutputInterface */
    protected $output;

    /** @var LoggerInterface */
    protected $logger;

    protected function configure()
    {
        $this
            ->setName('dtc:queue:run')
            ->setDefinition(
                array(
                    new InputArgument('worker_name', InputArgument::OPTIONAL, 'Name of worker', null),
                    new InputArgument('method', InputArgument::OPTIONAL, 'DI method of worker', null),
                    new InputOption(
                        'id',
                        'i',
                        InputOption::VALUE_REQUIRED,
                        'Id of Job to run',
                        null
                    ),
                    new InputOption(
                        'max_count',
                        'm',
                        InputOption::VALUE_REQUIRED,
                        'Maximum number of jobs to work on before exiting',
                        null
                    ),
                    new InputOption(
                        'duration',
                        'd',
                        InputOption::VALUE_REQUIRED,
                        'Duration to run for in seconds',
                        null
                    ),
                    new InputOption(
                        'timeout',
                        't',
                        InputOption::VALUE_REQUIRED,
                        'Process timeout in seconds (hard exit of process regardless)',
                        3600
                    ),
                    new InputOption(
                        'nano_sleep',
                        's',
                        InputOption::VALUE_REQUIRED,
                        'If using duration, this is the time to sleep when there\'s no jobs in nanoseconds',
                        500000000
                    ),
                    new InputOption(
                        'logger',
                        'l',
                        InputOption::VALUE_REQUIRED,
                        'Log using the logger service specified, or output to console if null (or an invalid logger service id) is passed in'
                    ),
                )
            )
            ->setDescription('Start up a job in queue');
    }

    protected function runJobById($start, $jobId)
    {
        $this->runStart($start);
        $container = $this->getContainer();
        $jobManager = $container->get('dtc_queue.job_manager');
        $workerManager = $container->get('dtc_queue.worker_manager');

        $job = $jobManager->getRepository()->find($jobId);
        if (!$job) {
            $this->log('error', "Job id is not found: {$jobId}");
            $this->runStop($start);

            return;
        }

        $job = $workerManager->runJob($job);
        $this->reportJob($job);
        $this->run->setProcessed(1);
        $this->runStop($start);

        return;
    }

    private function validateIntNull($varName, $var, $pow)
    {
        if (null === $var) {
            return null;
        }
        if (!ctype_digit(strval($var))) {
            throw new \Exception("$varName must be an integer");
        }

        if (strval(intval($var)) !== strval($var) || $var <= 0 || $var >= pow(2, $pow)) {
            throw new \Exception("$varName must be an base 10 integer within 2^32");
        }

        return intval($var);
    }

    public function log($level, $msg, array $context = [])
    {
        if ($this->logger) {
            $this->logger->$level($msg, $context);

            return;
        }

        $date = new \DateTime();
        $this->output->write("[$level] [".$date->format('c').'] '.$msg);
        if ($context) {

            $this->output->write(print_r($context, true));
        }
        $this->output->writeln('');
    }

    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $start = microtime(true);
        $this->output = $output;
        $container = $this->getContainer();
        $workerName = $input->getArgument('worker_name');
        $methodName = $input->getArgument('method');
        $maxCount = $input->getOption('max_count', null);

        $duration = $input->getOption('duration', null);

        $processTimeout = $input->getOption('timeout', 3600);

        $nanoSleep = $input->getOption('nano_sleep', 500000000);

        $loggerService = $input->getOption('logger');

        if ($container->has($loggerService)) {
            $this->logger = $container->get($loggerService);
        }

        $maxCount = $this->validateIntNull('max_count', $maxCount, 32);
        $duration = $this->validateIntNull('duration', $duration, 32);
        $processTimeout = $this->validateIntNull('timeout', $processTimeout, 32);
        $nanoSleep = $this->validateIntNull('nano_sleep', $nanoSleep, 63);

        if (null !== $duration && null !== $processTimeout && $duration >= $processTimeout) {
            $this->log('info', "duration ($duration) >= to process timeout ($processTimeout), so doubling process timeout to: ".(2 * $processTimeout));
            $processTimeout *= 2;
        }

        if (null === $maxCount && null === $duration) {
            $maxCount = 1;
        }
        // Check to see if there are other instances
        set_time_limit($processTimeout); // Set timeout on the process

        if ($jobId = $input->getOption('id')) {
            return $this->runJobById($start, $jobId);   // Run a single job
        }

        return $this->runLoop($start, $workerName, $methodName, $nanoSleep, $maxCount, $duration);
    }

    protected function runLoop($start, $workerName, $methodName, $nanoSleep, $maxCount, $duration)
    {
        $container = $this->getContainer();
        $workerManager = $container->get('dtc_queue.worker_manager');
        $workerManager->setLoggingFunc([$this, 'log']);
        $this->runStart($start, $maxCount, $duration);
        try {
            $this->log('info', 'Staring up a new job...');

            $endTime = null;
            if ($duration) {
                $interval = new \DateInterval("PT${duration}S");
                $endTime = $this->run->getStartedAt()->add($interval);
            }

            $currentJob = 1;
            $noMoreJobsToRun = false;
            do {
                $this->run->setLastHeartbeatAt(new \DateTime());
                $this->run->setElapsed(microtime(true) - $start);
                if ($this->runManager) {
                    $this->runManager->persist($this->run);
                    $this->runManager->flush();
                }

                $job = $workerManager->run($workerName, $methodName, true, $this->run->getId());
                if ($job) {
                    $noMoreJobsToRun = false;
                    $this->reportJob($job);
                    $this->run->setProcessed($currentJob);
                    if ($this->runManager) {
                        $this->runManager->persist($this->run);
                        $this->runManager->flush();
                    }
                    ++$currentJob;
                } else {
                    if (!$noMoreJobsToRun) {
                        $this->log('info', 'No more jobs to run ('.($currentJob - 1).' processed so far).');
                        $noMoreJobsToRun = true;
                    }
                    if ($maxCount && !$duration) {
                        // time to finish
                        $this->runStop($start);

                        return 0;
                    }
                    $nanoSleepTime = function_exists('random_int') ? random_int(0, $nanoSleep) : mt_rand(0, $nanoSleep);
                    time_nanosleep(0, $nanoSleepTime); // 500ms ??

                }
            } while ((null === $maxCount || $currentJob <= $maxCount) && (null === $duration || (new \DateTime()) < $endTime));
        } catch (\Exception $e) {
            // Uncaught error: possibly with QueueBundle itself
            $this->log('critical', $e->getMessage(), $e->getTrace());
        }
        $this->runStop($start);

        return 0;
    }

    /**
     * Sets up the runManager (document / entity persister) if appropriate.
     *
     * @param $maxCount
     * @param $duration
     */
    protected function runStart($start, $maxCount = null, $duration = null)
    {
        $container = $this->getContainer();
        $this->runClass = $container->getParameter('dtc_queue.class_run');
        $defaultManager = $container->getParameter('dtc_queue.default_manager');
        if ('mongodb' == $defaultManager && $container->has('dtc_queue.document_manager')) {
            $this->runManager = $container->get('dtc_queue.document_manager');
        } elseif ('orm' == $defaultManager && $container->has('dtc_queue.entity_manager')) {
            $this->runManager = $container->get('dtc_queue.entity_manager');
        }

        $this->run = new $this->runClass();
        $startDate = \DateTime::createFromFormat('U.u', $start);
        $this->run->setLastHeartbeatAt($startDate);
        $this->run->setStartedAt($startDate);
        if (null !== $maxCount) {
            $this->run->setMaxCount($maxCount);
        }
        $timeEnd = null;
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
        if (null !== $duration) {
            $this->run->setDuration($duration);
        }
        $this->run->setHostname(gethostname());
        $this->run->setPid(getmypid());
        $this->run->setProcessed(0);
        if ($this->runManager) {
            $this->runManager->persist($this->run);
            $this->runManager->flush();
        }
    }

    protected function runStop($start)
    {
        $end = microtime(true);
        $endTime = \DateTime::createFromFormat('U.u', $end);
        $this->run->setEndedAt($endTime);
<?php

function getDate($date)
{
    if ($date !== null) {
        return new DateTime($date);
    }

    return false;
}
        $this->run->setElapsed($end - $start);
        if ($this->runManager) {
            $this->runManager->remove($this->run);
            $this->runManager->flush();
        }
        $this->log('info', 'Ended with '.$this->run->getProcessed().' job(s) processed over '.strval($this->run->getElapsed()).' seconds.');
    }

    protected function reportJob(Job $job)
    {
        if (Job::STATUS_ERROR == $job->getStatus()) {
            $message = "Error with job id: {$job->getId()}\n".$job->getMessage();
            $this->log('error', $message);
        }

        $message = "Finished job id: {$job->getId()} in {$job->getElapsed()} seconds\n";
        $this->log('info', $message);
    }
}


1			<?php
2
3			namespace Dtc\QueueBundle\Command;
4
5			use Doctrine\Common\Persistence\ObjectManager;
6			use Dtc\QueueBundle\Model\Job;
7			use Dtc\QueueBundle\Model\Run;
8			use Psr\Log\LoggerInterface;
9			use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
10			use Symfony\Component\Console\Input\InputArgument;
11			use Symfony\Component\Console\Input\InputInterface;
12			use Symfony\Component\Console\Input\InputOption;
13			use Symfony\Component\Console\Output\OutputInterface;
14
15			class RunCommand extends ContainerAwareCommand
16			{
17			/** @var ObjectManager */
18			protected $runManager;
19
20			/** @var Run $run */
21			protected $run;
22
23			/** @var string */
24			protected $runClass;
25
26			/** @var OutputInterface */
27			protected $output;
28
29			/** @var LoggerInterface */
30			protected $logger;
31
32			protected function configure()
33			{
34			$this
35			->setName('dtc:queue:run')
36			->setDefinition(
37			array(
38			new InputArgument('worker_name', InputArgument::OPTIONAL, 'Name of worker', null),
39			new InputArgument('method', InputArgument::OPTIONAL, 'DI method of worker', null),
40			new InputOption(
41			'id',
42			'i',
43			InputOption::VALUE_REQUIRED,
44			'Id of Job to run',
45			null
46			),
47			new InputOption(
48			'max_count',
49			'm',
50			InputOption::VALUE_REQUIRED,
51			'Maximum number of jobs to work on before exiting',
52			null
53			),
54			new InputOption(
55			'duration',
56			'd',
57			InputOption::VALUE_REQUIRED,
58			'Duration to run for in seconds',
59			null
60			),
61			new InputOption(
62			'timeout',
63			't',
64			InputOption::VALUE_REQUIRED,
65			'Process timeout in seconds (hard exit of process regardless)',
66			3600
67			),
68			new InputOption(
69			'nano_sleep',
70			's',
71			InputOption::VALUE_REQUIRED,
72			'If using duration, this is the time to sleep when there\'s no jobs in nanoseconds',
73			500000000
74			),
75			new InputOption(
76			'logger',
77			'l',
78			InputOption::VALUE_REQUIRED,
79			'Log using the logger service specified, or output to console if null (or an invalid logger service id) is passed in'
80			),
81			)
82			)
83			->setDescription('Start up a job in queue');
84			}
85
86			protected function runJobById($start, $jobId)
87			{
88			$this->runStart($start);
89			$container = $this->getContainer();
90			$jobManager = $container->get('dtc_queue.job_manager');
91			$workerManager = $container->get('dtc_queue.worker_manager');
92
93			$job = $jobManager->getRepository()->find($jobId);
94			if (!$job) {
95			$this->log('error', "Job id is not found: {$jobId}");
96			$this->runStop($start);
97
98			return;
99			}
100
101			$job = $workerManager->runJob($job);
102			$this->reportJob($job);
103			$this->run->setProcessed(1);
104			$this->runStop($start);
105
106			return;
107			}
108
109			private function validateIntNull($varName, $var, $pow)
110			{
111			if (null === $var) {
112			return null;
113			}
114			if (!ctype_digit(strval($var))) {
115			throw new \Exception("$varName must be an integer");
116			}
117
118			if (strval(intval($var)) !== strval($var) \|\| $var <= 0 \|\| $var >= pow(2, $pow)) {
119			throw new \Exception("$varName must be an base 10 integer within 2^32");
120			}
121
122			return intval($var);
123			}
124
125			public function log($level, $msg, array $context = [])
126			{
127			if ($this->logger) {
128			$this->logger->$level($msg, $context);
129
130			return;
131			}
132
133			$date = new \DateTime();
134			$this->output->write("[$level] [".$date->format('c').'] '.$msg);
135			if ($context) {
			0 ignored issues – show Bug Best Practice introduced 2017-10-14 18:28 UTC by Report Bug Copy Issue Report The expression `$context` of type `array` is implicitly converted to a boolean; are you sure this is intended? If so, consider using `! empty($expr)` instead to make it clear that you intend to check for an array without elements. This check marks implicit conversions of arrays to boolean values in a comparison. While in PHP an empty array is considered to be equal (but not identical) to false, this is not always apparent. Consider making the comparison explicit by using `empty(..)` or `! empty(...)` instead. Loading history...
136			$this->output->write(print_r($context, true));
137			}
138			$this->output->writeln('');
139			}
140
141			protected function execute(InputInterface $input, OutputInterface $output)
142			{
143			$start = microtime(true);
144			$this->output = $output;
145			$container = $this->getContainer();
146			$workerName = $input->getArgument('worker_name');
147			$methodName = $input->getArgument('method');
148			$maxCount = $input->getOption('max_count', null);
			0 ignored issues – show Unused Code introduced 2017-10-14 18:28 UTC by Report Bug Copy Issue Report The call to `InputInterface::getOption()` has too many arguments starting with `null`. This check compares calls to functions or methods with their respective definitions. If the call has more arguments than are defined, it raises an issue. If a function is defined several times with a different number of parameters, the check may pick up the wrong definition and report false positives. One codebase where this has been known to happen is Wordpress. In this case you can add the `@ignore` PhpDoc annotation to the duplicate definition and it will be ignored. Loading history...
149			$duration = $input->getOption('duration', null);
			0 ignored issues – show Unused Code introduced 2017-10-14 18:28 UTC by Report Bug Copy Issue Report The call to `InputInterface::getOption()` has too many arguments starting with `null`. This check compares calls to functions or methods with their respective definitions. If the call has more arguments than are defined, it raises an issue. If a function is defined several times with a different number of parameters, the check may pick up the wrong definition and report false positives. One codebase where this has been known to happen is Wordpress. In this case you can add the `@ignore` PhpDoc annotation to the duplicate definition and it will be ignored. Loading history...
150			$processTimeout = $input->getOption('timeout', 3600);
			0 ignored issues – show Unused Code introduced 2016-06-02 08:54 UTC by Report Bug Copy Issue Report The call to `InputInterface::getOption()` has too many arguments starting with `3600`. This check compares calls to functions or methods with their respective definitions. If the call has more arguments than are defined, it raises an issue. If a function is defined several times with a different number of parameters, the check may pick up the wrong definition and report false positives. One codebase where this has been known to happen is Wordpress. In this case you can add the `@ignore` PhpDoc annotation to the duplicate definition and it will be ignored. Loading history...
151			$nanoSleep = $input->getOption('nano_sleep', 500000000);
			0 ignored issues – show Unused Code introduced 2017-10-14 18:28 UTC by Report Bug Copy Issue Report The call to `InputInterface::getOption()` has too many arguments starting with `500000000`. This check compares calls to functions or methods with their respective definitions. If the call has more arguments than are defined, it raises an issue. If a function is defined several times with a different number of parameters, the check may pick up the wrong definition and report false positives. One codebase where this has been known to happen is Wordpress. In this case you can add the `@ignore` PhpDoc annotation to the duplicate definition and it will be ignored. Loading history...
152			$loggerService = $input->getOption('logger');
153
154			if ($container->has($loggerService)) {
155			$this->logger = $container->get($loggerService);
156			}
157
158			$maxCount = $this->validateIntNull('max_count', $maxCount, 32);
159			$duration = $this->validateIntNull('duration', $duration, 32);
160			$processTimeout = $this->validateIntNull('timeout', $processTimeout, 32);
161			$nanoSleep = $this->validateIntNull('nano_sleep', $nanoSleep, 63);
162
163			if (null !== $duration && null !== $processTimeout && $duration >= $processTimeout) {
164			$this->log('info', "duration ($duration) >= to process timeout ($processTimeout), so doubling process timeout to: ".(2 * $processTimeout));
165			$processTimeout *= 2;
166			}
167
168			if (null === $maxCount && null === $duration) {
169			$maxCount = 1;
170			}
171			// Check to see if there are other instances
172			set_time_limit($processTimeout); // Set timeout on the process
173
174			if ($jobId = $input->getOption('id')) {
175			return $this->runJobById($start, $jobId); // Run a single job
176			}
177
178			return $this->runLoop($start, $workerName, $methodName, $nanoSleep, $maxCount, $duration);
179			}
180
181			protected function runLoop($start, $workerName, $methodName, $nanoSleep, $maxCount, $duration)
182			{
183			$container = $this->getContainer();
184			$workerManager = $container->get('dtc_queue.worker_manager');
185			$workerManager->setLoggingFunc([$this, 'log']);
186			$this->runStart($start, $maxCount, $duration);
187			try {
188			$this->log('info', 'Staring up a new job...');
189
190			$endTime = null;
191			if ($duration) {
192			$interval = new \DateInterval("PT${duration}S");
193			$endTime = $this->run->getStartedAt()->add($interval);
194			}
195
196			$currentJob = 1;
197			$noMoreJobsToRun = false;
198			do {
199			$this->run->setLastHeartbeatAt(new \DateTime());
200			$this->run->setElapsed(microtime(true) - $start);
201			if ($this->runManager) {
202			$this->runManager->persist($this->run);
203			$this->runManager->flush();
204			}
205
206			$job = $workerManager->run($workerName, $methodName, true, $this->run->getId());
207			if ($job) {
208			$noMoreJobsToRun = false;
209			$this->reportJob($job);
210			$this->run->setProcessed($currentJob);
211			if ($this->runManager) {
212			$this->runManager->persist($this->run);
213			$this->runManager->flush();
214			}
215			++$currentJob;
216			} else {
217			if (!$noMoreJobsToRun) {
218			$this->log('info', 'No more jobs to run ('.($currentJob - 1).' processed so far).');
219			$noMoreJobsToRun = true;
220			}
221			if ($maxCount && !$duration) {
222			// time to finish
223			$this->runStop($start);
224
225			return 0;
226			}
227			$nanoSleepTime = function_exists('random_int') ? random_int(0, $nanoSleep) : mt_rand(0, $nanoSleep);
228			time_nanosleep(0, $nanoSleepTime); // 500ms ??
			0 ignored issues – show Unused Code Comprehensibility introduced 2017-10-14 18:28 UTC by Report Bug Copy Issue Report `50%` of this comment could be valid code. Did you maybe forget this after debugging? Sometimes obsolete code just ends up commented out instead of removed. In this case it is better to remove the code once you have checked you do not need it. The code might also have been commented out for debugging purposes. In this case it is vital that someone uncomments it again or your project may behave in very unexpected ways in production. This check looks for comments that seem to be mostly valid code and reports them. Loading history...
229			}
230			} while ((null === $maxCount \|\| $currentJob <= $maxCount) && (null === $duration \|\| (new \DateTime()) < $endTime));
231			} catch (\Exception $e) {
232			// Uncaught error: possibly with QueueBundle itself
233			$this->log('critical', $e->getMessage(), $e->getTrace());
234			}
235			$this->runStop($start);
236
237			return 0;
238			}
239
240			/**
241			* Sets up the runManager (document / entity persister) if appropriate.
242			*
243			* @param $maxCount
244			* @param $duration
245			*/
246			protected function runStart($start, $maxCount = null, $duration = null)
247			{
248			$container = $this->getContainer();
249			$this->runClass = $container->getParameter('dtc_queue.class_run');
250			$defaultManager = $container->getParameter('dtc_queue.default_manager');
251			if ('mongodb' == $defaultManager && $container->has('dtc_queue.document_manager')) {
252			$this->runManager = $container->get('dtc_queue.document_manager');
253			} elseif ('orm' == $defaultManager && $container->has('dtc_queue.entity_manager')) {
254			$this->runManager = $container->get('dtc_queue.entity_manager');
255			}
256
257			$this->run = new $this->runClass();
258			$startDate = \DateTime::createFromFormat('U.u', $start);
259			$this->run->setLastHeartbeatAt($startDate);
260			$this->run->setStartedAt($startDate);
261			if (null !== $maxCount) {
262			$this->run->setMaxCount($maxCount);
263			}
264			$timeEnd = null;
			0 ignored issues – show Unused Code introduced 2017-10-14 18:28 UTC by Report Bug Copy Issue Report `$timeEnd` is not used, you could remove the assignment. This check looks for variable assignements that are either overwritten by other assignments or where the variable is not used subsequently. $myVar = 'Value'; $higher = false; if (rand(1, 6) > 3) { $higher = true; } else { $higher = false; } Both the `$myVar` assignment in line 1 and the `$higher` assignment in line 2 are dead. The first because `$myVar` is never used and the second because `$higher` is always overwritten for every possible time line. Loading history...
265			if (null !== $duration) {
266			$this->run->setDuration($duration);
267			}
268			$this->run->setHostname(gethostname());
269			$this->run->setPid(getmypid());
270			$this->run->setProcessed(0);
271			if ($this->runManager) {
272			$this->runManager->persist($this->run);
273			$this->runManager->flush();
274			}
275			}
276
277			protected function runStop($start)
278			{
279			$end = microtime(true);
280			$endTime = \DateTime::createFromFormat('U.u', $end);
281			$this->run->setEndedAt($endTime);
			0 ignored issues – show Security Bug introduced 2017-10-14 18:28 UTC by Report Bug Copy Issue Report It seems like `$endTime` defined by `\DateTime::createFromFormat('U.u', $end)` on line `280` can also be of type `false`; however, `Dtc\QueueBundle\Model\Run::setEndedAt()` does only seem to accept `object<DateTime>`, did you maybe forget to handle an error condition? This check looks for type mismatches where the missing type is `false`. This is usually indicative of an error condtion. Consider the follow example <?php function getDate($date) { if ($date !== null) { return new DateTime($date); } return false; } This function either returns a new `DateTime` object or false, if there was an error. This is a typical pattern in PHP programming to show that an error has occurred without raising an exception. The calling code should check for this returned `false` before passing on the value to another function or method that may not be able to handle a `false`. Loading history...
282			$this->run->setElapsed($end - $start);
283			if ($this->runManager) {
284			$this->runManager->remove($this->run);
285			$this->runManager->flush();
286			}
287			$this->log('info', 'Ended with '.$this->run->getProcessed().' job(s) processed over '.strval($this->run->getElapsed()).' seconds.');
288			}
289
290			protected function reportJob(Job $job)
291			{
292			if (Job::STATUS_ERROR == $job->getStatus()) {
293			$message = "Error with job id: {$job->getId()}\n".$job->getMessage();
294			$this->log('error', $message);
295			}
296
297			$message = "Finished job id: {$job->getId()} in {$job->getElapsed()} seconds\n";
298			$this->log('info', $message);
299			}
300			}
301

mmucklo / DtcQueueBundle

Push — master ( 298fd3...56daff )

RunCommand::runStart() C

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like