TaskManager::markOpenTaskAsRunning() - Code Metrics - bazzline/php_component_process_fork_manager - Measure and Improve Code Quality continuously with Scrutinizer

TaskManager::markOpenTaskAsRunning() A
last analyzed 2021-02-05 12:19 UTC

↳ Parent: TaskManager

Complexity

Conditions	1
Paths	1

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	7
rs	10
c	0
b	0
f	0
cc	1
nc	1
nop	1

<?php
/**
 * @author stev leibelt <[email protected]>
 * @since 2014-07-23 
 */

namespace Net\Bazzline\Component\ProcessForkManager;

/**
 * Class TaskManager
 * @package Net\Bazzline\Component\ProcessForkManager
 */
class TaskManager
{
    /**
     * @var array|AbstractTask[]
     */
    private $abortedTasks;

    /**
     * @var bool
     */
    private $areThereOpenTasksLeft;

    /**
     * @var array|AbstractTask[]
     */
    private $finishedTasks;

    /**
     * @var array|AbstractTask[]
     */
    private $openTasks;

    /**
     * @var array|AbstractTask[]
     */
    private $runningTasks;

    public function __construct()
    {
        $this->abortedTasks = array();
        $this->areThereOpenTasksLeft = false;
        $this->finishedTasks = array();
        $this->openTasks = array();
        $this->runningTasks = array();
    }

    /**
     * @return bool
     */
    public function areThereOpenTasksLeft()
    {
        return $this->areThereOpenTasksLeft;
    }

    /**
     * @param AbstractTask $task
     * @return $this
     */
    public function addOpenTask(AbstractTask $task)
    {
        $this->openTasks[] = $task;
        $this->areThereOpenTasksLeft = true;

        return $this;
    }

    /**
     * @return null|AbstractTask
     */
    public function getOpenTask()
    {
        $task = array_shift($this->openTasks);

        if (empty($this->openTasks)) {
            $this->areThereOpenTasksLeft = false;
        }

        return $task;
    }

    /**
     * @param AbstractTask $task
     * @throws RuntimeException
     */
    public function markRunningTaskAsAborted(AbstractTask $task)

    {
        $key = $this->getValidRunningTaskKey($task);

        $this->abortedTasks[$key] = $this->runningTasks[$key];
        $this->abortedTasks[$key]->markAsAborted();
        unset($this->runningTasks[$key]);
    }

    /**
     * @param AbstractTask $task
     * @throws RuntimeException
     */
    public function markRunningTaskAsFinished(AbstractTask $task)

    {
        $key = $this->getValidRunningTaskKey($task);

        $this->finishedTasks[$key] = $this->runningTasks[$key];
        $this->finishedTasks[$key]->markAsFinished();
        unset($this->runningTasks[$key]);
    }

    /**
     * @param AbstractTask $task
     * @throws InvalidArgumentException
     * @todo implement validation if task is not in open|finished|aborted|running array
     */
    public function markOpenTaskAsRunning(AbstractTask $task)
    {
        $key = $this->getArrayIndexKey($task);
        $task->markAsRunning();

        $this->runningTasks[$key] = $task;
    }

    /**
     * @param AbstractTask $task
     * @return string
     * @throws RuntimeException
     */
    private function getValidRunningTaskKey(AbstractTask $task)
    {
        $key = $this->getArrayIndexKey($task);

        if (!isset($this->runningTasks[$key])) {
            throw new RuntimeException(
                'provided task is not running'
            );
        }

        return $key;
    }

    /**
     * @param AbstractTask $task
     * @return string
     */
    private function getArrayIndexKey(AbstractTask $task)
    {
        return spl_object_hash($task);
    }
}

1		<?php
2		/**
3		* @author stev leibelt <[email protected]>
4		* @since 2014-07-23
5		*/
6
7		namespace Net\Bazzline\Component\ProcessForkManager;
8
9		/**
10		* Class TaskManager
11		* @package Net\Bazzline\Component\ProcessForkManager
12		*/
13		class TaskManager
14		{
15		/**
16		* @var array\|AbstractTask[]
17		*/
18		private $abortedTasks;
19
20		/**
21		* @var bool
22		*/
23		private $areThereOpenTasksLeft;
24
25		/**
26		* @var array\|AbstractTask[]
27		*/
28		private $finishedTasks;
29
30		/**
31		* @var array\|AbstractTask[]
32		*/
33		private $openTasks;
34
35		/**
36		* @var array\|AbstractTask[]
37		*/
38		private $runningTasks;
39
40		public function __construct()
41		{
42		$this->abortedTasks = array();
43		$this->areThereOpenTasksLeft = false;
44		$this->finishedTasks = array();
45		$this->openTasks = array();
46		$this->runningTasks = array();
47		}
48
49		/**
50		* @return bool
51		*/
52		public function areThereOpenTasksLeft()
53		{
54		return $this->areThereOpenTasksLeft;
55		}
56
57		/**
58		* @param AbstractTask $task
59		* @return $this
60		*/
61		public function addOpenTask(AbstractTask $task)
62		{
63		$this->openTasks[] = $task;
64		$this->areThereOpenTasksLeft = true;
65
66		return $this;
67		}
68
69		/**
70		* @return null\|AbstractTask
71		*/
72		public function getOpenTask()
73		{
74		$task = array_shift($this->openTasks);
75
76		if (empty($this->openTasks)) {
77		$this->areThereOpenTasksLeft = false;
78		}
79
80		return $task;
81		}
82
83		/**
84		* @param AbstractTask $task
85		* @throws RuntimeException
86		*/
87	View Code Duplication	public function markRunningTaskAsAborted(AbstractTask $task)
		0 ignored issues – show Duplication introduced 2021-02-05 12:19 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
88		{
89		$key = $this->getValidRunningTaskKey($task);
90
91		$this->abortedTasks[$key] = $this->runningTasks[$key];
92		$this->abortedTasks[$key]->markAsAborted();
93		unset($this->runningTasks[$key]);
94		}
95
96		/**
97		* @param AbstractTask $task
98		* @throws RuntimeException
99		*/
100	View Code Duplication	public function markRunningTaskAsFinished(AbstractTask $task)
		0 ignored issues – show Duplication introduced 2021-02-05 12:19 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
101		{
102		$key = $this->getValidRunningTaskKey($task);
103
104		$this->finishedTasks[$key] = $this->runningTasks[$key];
105		$this->finishedTasks[$key]->markAsFinished();
106		unset($this->runningTasks[$key]);
107		}
108
109		/**
110		* @param AbstractTask $task
111		* @throws InvalidArgumentException
112		* @todo implement validation if task is not in open\|finished\|aborted\|running array
113		*/
114		public function markOpenTaskAsRunning(AbstractTask $task)
115		{
116		$key = $this->getArrayIndexKey($task);
117		$task->markAsRunning();
118
119		$this->runningTasks[$key] = $task;
120		}
121
122		/**
123		* @param AbstractTask $task
124		* @return string
125		* @throws RuntimeException
126		*/
127		private function getValidRunningTaskKey(AbstractTask $task)
128		{
129		$key = $this->getArrayIndexKey($task);
130
131		if (!isset($this->runningTasks[$key])) {
132		throw new RuntimeException(
133		'provided task is not running'
134		);
135		}
136
137		return $key;
138		}
139
140		/**
141		* @param AbstractTask $task
142		* @return string
143		*/
144		private function getArrayIndexKey(AbstractTask $task)
145		{
146		return spl_object_hash($task);
147		}
148		}

bazzline / php_component_process_fork_manager

TaskManager::markOpenTaskAsRunning() A last analyzed 2021-02-05 12:19 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

TaskManager::markOpenTaskAsRunning() A
last analyzed 2021-02-05 12:19 UTC