QueueMonitor::monitor() - Code Metrics - Inspection of "Added marking of processes as crashed" - glooby/task-bundle - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 410c5e...621de0 )

by Emil

created 2018-01-10 18:43 UTC

QueueMonitor::monitor() A

↳ Parent: QueueMonitor

Complexity

Conditions	3
Paths	3

Size

Total Lines	13
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
dl	0
loc	13
rs	9.4285
c	1
b	0
f	0
cc	3
eloc	7
nc	3
nop	0

<?php

namespace Glooby\TaskBundle\Queue;

use Doctrine\Common\Persistence\ManagerRegistry;
use Glooby\TaskBundle\Manager\TaskManager;

/**
 * @author Emil Kilhage
 */
class QueueMonitor
{
    /**
     * @var ManagerRegistry
     */
    protected $doctrine;

    /**
     * @param ManagerRegistry $doctrine
     */
    public function setDoctrine($doctrine)
    {
        $this->doctrine = $doctrine;
    }

    /**
     * @var TaskManager
     */
    private $taskManager;

    /**
     * @param TaskManager $taskManager
     */
    public function setTaskManager(TaskManager $taskManager)
    {
        $this->taskManager = $taskManager;
    }

    /**
     *
     */
    public function monitor()
    {
        $taskRepo = $this->doctrine->getManager()
            ->getRepository('GloobyTaskBundle:QueuedTask');

        foreach ($taskRepo->findRunning() as $task) {
            if (false === posix_getpgid($task->getPId())) {
                $this->taskManager->failure($task, 'crashed');
            }
        }

        $this->doctrine->getManager()->flush();
    }
}


1			<?php
2
3			namespace Glooby\TaskBundle\Queue;
4
5			use Doctrine\Common\Persistence\ManagerRegistry;
6			use Glooby\TaskBundle\Manager\TaskManager;
7
8			/**
9			* @author Emil Kilhage
10			*/
11			class QueueMonitor
12			{
13			/**
14			* @var ManagerRegistry
15			*/
16			protected $doctrine;
17
18			/**
19			* @param ManagerRegistry $doctrine
20			*/
21			public function setDoctrine($doctrine)
22			{
23			$this->doctrine = $doctrine;
24			}
25
26			/**
27			* @var TaskManager
28			*/
29			private $taskManager;
30
31			/**
32			* @param TaskManager $taskManager
33			*/
34			public function setTaskManager(TaskManager $taskManager)
35			{
36			$this->taskManager = $taskManager;
37			}
38
39			/**
40			*
41			*/
42			public function monitor()
43			{
44			$taskRepo = $this->doctrine->getManager()
45			->getRepository('GloobyTaskBundle:QueuedTask');
46
47			foreach ($taskRepo->findRunning() as $task) {
48			if (false === posix_getpgid($task->getPId())) {
49			$this->taskManager->failure($task, 'crashed');
50			}
51			}
52
53			$this->doctrine->getManager()->flush();
54			}
55			}
56

glooby / task-bundle

Push — master ( 410c5e...621de0 )

QueueMonitor::monitor() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like