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

AbstractTask::setUpSignalHandling() A
last analyzed 2021-02-05 12:19 UTC

↳ Parent: AbstractTask

Complexity

Conditions	2
Paths	2

Size

Total Lines

Duplication

Lines	5
Ratio	19.23 %

Importance

Changes

Metric	Value
dl	5
loc	26
rs	9.504
c	0
b	0
f	0
cc	2
nc	2
nop	1

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

namespace Net\Bazzline\Component\ProcessForkManager;

/**
 * Class AbstractTask
 * @package Net\Bazzline\Component\ProcessForkManager
 */
abstract class AbstractTask implements TaskInterface
{
    const STATUS_ABORTED = 2;
    const STATUS_FINISHED = 1;
    const STATUS_NOT_STARTED = 0;
    const STATUS_RUNNING = 3;

    /**
     * @var int
     */
    private $parentProcessId;

    /**
     * @var int
     */
    private $startTime = 0;

    /**
     * @var int
     */
    private $status = self::STATUS_NOT_STARTED;

    /**
     * @return int
     */
    public function getRunTime()
    {
        return (time() - $this->startTime);
    }

    /**
     * @return int
     */
    public function getMemoryUsage()
    {
        return memory_get_usage(true);
    }

    /**
     * @return int
     */
    public function getParentProcessId()
    {
        return $this->parentProcessId;
    }

    /**
     * @return int
     */
    public function getProcessId()
    {
        return getmypid();
    }

    /**
     * @return bool
     */
    public function isAborted()
    {
        return ($this->status === self::STATUS_ABORTED);
    }

    /**
     * @return bool
     */
    public function isFinished()
    {
        return ($this->status === self::STATUS_FINISHED);
    }

    /**
     * @return bool
     */
    public function isNotStarted()
    {
        return ($this->status === self::STATUS_NOT_STARTED);
    }

    /**
     * @return bool
     */
    public function isRunning()
    {
        return ($this->status === self::STATUS_RUNNING);
    }

    public function markAsAborted()
    {
        $this->status = self::STATUS_ABORTED;
    }

    public function markAsFinished()
    {
        $this->status = self::STATUS_FINISHED;
    }

    public function markAsRunning()
    {
        $this->status = self::STATUS_RUNNING;
    }

    /**
     * @param int $parentProcessId
     */
    public function setParentProcessId($parentProcessId)
    {
        $this->parentProcessId = (int) $parentProcessId;
    }

    /**
     * @param int $timestamp
     */
    public function setStartTime($timestamp)
    {
        $this->startTime = (int) $timestamp;
    }

    protected function dispatchSignal()
    {
        pcntl_signal_dispatch();
    }

    /**
     * @param $nameOfSignalHandlerMethod
     * @throws InvalidArgumentException
     * @codeCoverageIgnore
     */
    protected function setUpSignalHandling($nameOfSignalHandlerMethod)
    {
        if (!is_callable(array($this, $nameOfSignalHandlerMethod))) {

            throw new InvalidArgumentException(
                'provided method name "' . $nameOfSignalHandlerMethod . '" is not available'
            );
        }

        //pcntl_signal(SIGHUP,    array($this, $nameOfSignalHandlerMethod));
        pcntl_signal(SIGINT,    array($this, $nameOfSignalHandlerMethod));  //shell ctrl+c
        //pcntl_signal(SIGUSR1,   array($this, $nameOfSignalHandlerMethod));
        //pcntl_signal(SIGUSR2,   array($this, $nameOfSignalHandlerMethod));
        //pcntl_signal(SIGQUIT,   array($this, $nameOfSignalHandlerMethod));
        //pcntl_signal(SIGILL,    array($this, $nameOfSignalHandlerMethod));
        //pcntl_signal(SIGABRT,   array($this, $nameOfSignalHandlerMethod));
        //pcntl_signal(SIGFPE,    array($this, $nameOfSignalHandlerMethod));
        //pcntl_signal(SIGSEGV,   array($this, $nameOfSignalHandlerMethod));
        //pcntl_signal(SIGPIPE,   array($this, $nameOfSignalHandlerMethod));
        //pcntl_signal(SIGALRM,   array($this, $nameOfSignalHandlerMethod));
        pcntl_signal(SIGTERM,   array($this, $nameOfSignalHandlerMethod));  //kill <pid>
        //pcntl_signal(SIGCHLD,   array($this, $nameOfSignalHandlerMethod));
        //pcntl_signal(SIGCONT,   array($this, $nameOfSignalHandlerMethod));
        //pcntl_signal(SIGTSTP,   array($this, $nameOfSignalHandlerMethod));
        //pcntl_signal(SIGTTIN,   array($this, $nameOfSignalHandlerMethod));
        //pcntl_signal(SIGTTOU,   array($this, $nameOfSignalHandlerMethod));
    }
}

1		<?php
2		/**
3		* @author stev leibelt <[email protected]>
4		* @since 2014-07-20
5		*/
6
7		namespace Net\Bazzline\Component\ProcessForkManager;
8
9		/**
10		* Class AbstractTask
11		* @package Net\Bazzline\Component\ProcessForkManager
12		*/
13		abstract class AbstractTask implements TaskInterface
14		{
15		const STATUS_ABORTED = 2;
16		const STATUS_FINISHED = 1;
17		const STATUS_NOT_STARTED = 0;
18		const STATUS_RUNNING = 3;
19
20		/**
21		* @var int
22		*/
23		private $parentProcessId;
24
25		/**
26		* @var int
27		*/
28		private $startTime = 0;
29
30		/**
31		* @var int
32		*/
33		private $status = self::STATUS_NOT_STARTED;
34
35		/**
36		* @return int
37		*/
38		public function getRunTime()
39		{
40		return (time() - $this->startTime);
41		}
42
43		/**
44		* @return int
45		*/
46		public function getMemoryUsage()
47		{
48		return memory_get_usage(true);
49		}
50
51		/**
52		* @return int
53		*/
54		public function getParentProcessId()
55		{
56		return $this->parentProcessId;
57		}
58
59		/**
60		* @return int
61		*/
62		public function getProcessId()
63		{
64		return getmypid();
65		}
66
67		/**
68		* @return bool
69		*/
70		public function isAborted()
71		{
72		return ($this->status === self::STATUS_ABORTED);
73		}
74
75		/**
76		* @return bool
77		*/
78		public function isFinished()
79		{
80		return ($this->status === self::STATUS_FINISHED);
81		}
82
83		/**
84		* @return bool
85		*/
86		public function isNotStarted()
87		{
88		return ($this->status === self::STATUS_NOT_STARTED);
89		}
90
91		/**
92		* @return bool
93		*/
94		public function isRunning()
95		{
96		return ($this->status === self::STATUS_RUNNING);
97		}
98
99		public function markAsAborted()
100		{
101		$this->status = self::STATUS_ABORTED;
102		}
103
104		public function markAsFinished()
105		{
106		$this->status = self::STATUS_FINISHED;
107		}
108
109		public function markAsRunning()
110		{
111		$this->status = self::STATUS_RUNNING;
112		}
113
114		/**
115		* @param int $parentProcessId
116		*/
117		public function setParentProcessId($parentProcessId)
118		{
119		$this->parentProcessId = (int) $parentProcessId;
120		}
121
122		/**
123		* @param int $timestamp
124		*/
125		public function setStartTime($timestamp)
126		{
127		$this->startTime = (int) $timestamp;
128		}
129
130		protected function dispatchSignal()
131		{
132		pcntl_signal_dispatch();
133		}
134
135		/**
136		* @param $nameOfSignalHandlerMethod
137		* @throws InvalidArgumentException
138		* @codeCoverageIgnore
139		*/
140		protected function setUpSignalHandling($nameOfSignalHandlerMethod)
141		{
142	View Code Duplication	if (!is_callable(array($this, $nameOfSignalHandlerMethod))) {
		0 ignored issues – show Duplication introduced 2016-02-28 21:55 UTC by Report Bug Copy Issue Report This code seems to be duplicated across 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...
143		throw new InvalidArgumentException(
144		'provided method name "' . $nameOfSignalHandlerMethod . '" is not available'
145		);
146		}
147
148		//pcntl_signal(SIGHUP, array($this, $nameOfSignalHandlerMethod));
149		pcntl_signal(SIGINT, array($this, $nameOfSignalHandlerMethod)); //shell ctrl+c
150		//pcntl_signal(SIGUSR1, array($this, $nameOfSignalHandlerMethod));
151		//pcntl_signal(SIGUSR2, array($this, $nameOfSignalHandlerMethod));
152		//pcntl_signal(SIGQUIT, array($this, $nameOfSignalHandlerMethod));
153		//pcntl_signal(SIGILL, array($this, $nameOfSignalHandlerMethod));
154		//pcntl_signal(SIGABRT, array($this, $nameOfSignalHandlerMethod));
155		//pcntl_signal(SIGFPE, array($this, $nameOfSignalHandlerMethod));
156		//pcntl_signal(SIGSEGV, array($this, $nameOfSignalHandlerMethod));
157		//pcntl_signal(SIGPIPE, array($this, $nameOfSignalHandlerMethod));
158		//pcntl_signal(SIGALRM, array($this, $nameOfSignalHandlerMethod));
159		pcntl_signal(SIGTERM, array($this, $nameOfSignalHandlerMethod)); //kill <pid>
160		//pcntl_signal(SIGCHLD, array($this, $nameOfSignalHandlerMethod));
161		//pcntl_signal(SIGCONT, array($this, $nameOfSignalHandlerMethod));
162		//pcntl_signal(SIGTSTP, array($this, $nameOfSignalHandlerMethod));
163		//pcntl_signal(SIGTTIN, array($this, $nameOfSignalHandlerMethod));
164		//pcntl_signal(SIGTTOU, array($this, $nameOfSignalHandlerMethod));
165		}
166		}

bazzline / php_component_process_fork_manager

AbstractTask::setUpSignalHandling() A last analyzed 2021-02-05 12:19 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

AbstractTask::setUpSignalHandling() A
last analyzed 2021-02-05 12:19 UTC