SignalHandler::setDispatcher() - Code Metrics - scones/resque - Measure and Improve Code Quality continuously with Scrutinizer

SignalHandler::setDispatcher() A
last analyzed 2019-05-28 12:05 UTC

↳ Parent: SignalHandler

Complexity

Conditions	1
Paths	1

Size

Total Lines	3
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	2
CRAP Score	1

Importance

Changes

Metric	Value
eloc	1
dl	0
loc	3
ccs	2
cts	2
cp	1
rs	10
c	0
b	0
f	0
cc	1
nc	1
nop	1
crap	1

<?php

declare(strict_types=1);

namespace Resque;

use Resque\Dispatchers\Noop;
use Resque\Interfaces\Dispatcher;
use Resque\Tasks\BeforeSignalsRegister;

class SignalHandler
{
    private $worker = null;
    private $dispatcher;

    private $signals = [
        SIGTERM => 'shutdown',
        SIGINT => 'shutdown',
        SIGQUIT => 'shutdown',
        SIGUSR1 => 'pause',
        SIGCONT => 'continue',
        SIGUSR2 => 'forceShutdown',
    ];

    public function __construct(array $signals = [])
    {
        foreach ($signals as $type => $signalCallback) {
            if (in_array($type, array_keys($this->signals)) && is_callable($signalCallback)) {
                $this->signals[$type] = $signalCallback;
            }
        }
        $this->dispatcher = new Noop();
    }

    public function setDispatcher(Dispatcher $dispatcher): void
    {
        $this->dispatcher = $dispatcher;
    }

    public function setWorker(Worker $worker): void
    {
        $this->worker = $worker;
    }

    public function register(): void
    {
        $payload = $this->dispatcher->dispatch(BeforeSignalsRegister::class, ['signals' => $this->signals]);
        pcntl_async_signals(true);
        foreach ($payload['signals'] as $signalType => $signalHandler) {
            pcntl_signal($signalType, [$this->worker, $signalHandler]);
        }

        register_shutdown_function([$this, 'unregister']);
    }

    public function unregister(): void
    {
        pcntl_async_signals(false);
    }
}


1		<?php
2
3		declare(strict_types=1);
4
5		namespace Resque;
6
7		use Resque\Dispatchers\Noop;
8		use Resque\Interfaces\Dispatcher;
9		use Resque\Tasks\BeforeSignalsRegister;
10
11		class SignalHandler
12		{
13		private $worker = null;
14		private $dispatcher;
15
16		private $signals = [
17		SIGTERM => 'shutdown',
18		SIGINT => 'shutdown',
19		SIGQUIT => 'shutdown',
20		SIGUSR1 => 'pause',
21		SIGCONT => 'continue',
22		SIGUSR2 => 'forceShutdown',
23		];
24
25	3	public function __construct(array $signals = [])
26		{
27	3	foreach ($signals as $type => $signalCallback) {
28	1	if (in_array($type, array_keys($this->signals)) && is_callable($signalCallback)) {
29	1	$this->signals[$type] = $signalCallback;
30		}
31		}
32	3	$this->dispatcher = new Noop();
33	3	}
34
35	2	public function setDispatcher(Dispatcher $dispatcher): void
36		{
37	2	$this->dispatcher = $dispatcher;
38	2	}
39
40	10	public function setWorker(Worker $worker): void
41		{
42	10	$this->worker = $worker;
43	10	}
44
45	2	public function register(): void
46		{
47	2	$payload = $this->dispatcher->dispatch(BeforeSignalsRegister::class, ['signals' => $this->signals]);
48	2	pcntl_async_signals(true);
49	2	foreach ($payload['signals'] as $signalType => $signalHandler) {
50	2	pcntl_signal($signalType, [$this->worker, $signalHandler]);
51		}
52
53	2	register_shutdown_function([$this, 'unregister']);
54	2	}
55
56	1	public function unregister(): void
57		{
58	1	pcntl_async_signals(false);
59	1	}
60		}
61

scones / resque

SignalHandler::setDispatcher() A last analyzed 2019-05-28 12:05 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

SignalHandler::setDispatcher() A
last analyzed 2019-05-28 12:05 UTC