SignalAware::channel() - Code Metrics - Inspection of "add benchmark" - Innmind/AMQP - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — develop ( 4cbc06...07baac )

by Baptiste

created 2017-10-21 10:34 UTC

SignalAware::channel() A

↳ Parent: SignalAware

Complexity

Conditions	1
Paths	1

Size

Total Lines	6
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	3
CRAP Score	1

Importance

Changes

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

<?php
declare(strict_types = 1);

namespace Innmind\AMQP\Client;

use Innmind\AMQP\Client as ClientInterface;

final class SignalAware implements ClientInterface
{
    private $client;
    private $handlersRegistered = false;

    public function __construct(ClientInterface $client)
    {
        $this->client = $client;
    }

    public function channel(): Channel
    {
        $this->register();

        return $this->client->channel();
    }

    public function closed(): bool
    {
        return $this->client->closed();
    }

    public function close(): void
    {
        $this->client->close();
    }

    private function register(): void
    {
        if ($this->handlersRegistered === true) {
            return;
        }

        pcntl_async_signals(true);

        $softClose = function(): void {
            $this->close();
        };

        pcntl_signal(SIGHUP, static function() {
            //do nothing so it can run in background
        });
        pcntl_signal(SIGINT, $softClose);
        pcntl_signal(SIGABRT, $softClose);
        pcntl_signal(SIGTERM, $softClose);
        pcntl_signal(SIGTSTP, $softClose);
        pcntl_signal(SIGALRM, $softClose);
        $this->handlersRegistered = true;
    }
}


1		<?php
2		declare(strict_types = 1);
3
4		namespace Innmind\AMQP\Client;
5
6		use Innmind\AMQP\Client as ClientInterface;
7
8		final class SignalAware implements ClientInterface
9		{
10		private $client;
11		private $handlersRegistered = false;
12
13	2	public function __construct(ClientInterface $client)
14		{
15	2	$this->client = $client;
16	2	}
17
18	2	public function channel(): Channel
19		{
20	2	$this->register();
21
22	2	return $this->client->channel();
23		}
24
25	2	public function closed(): bool
26		{
27	2	return $this->client->closed();
28		}
29
30	2	public function close(): void
31		{
32	2	$this->client->close();
33	2	}
34
35	2	private function register(): void
36		{
37	2	if ($this->handlersRegistered === true) {
38		return;
39		}
40
41	2	pcntl_async_signals(true);
42
43	2	$softClose = function(): void {
44	2	$this->close();
45	2	};
46
47	2	pcntl_signal(SIGHUP, static function() {
48		//do nothing so it can run in background
49	2	});
50		pcntl_signal(SIGINT, $softClose);
51		pcntl_signal(SIGABRT, $softClose);
52		pcntl_signal(SIGTERM, $softClose);
53		pcntl_signal(SIGTSTP, $softClose);
54		pcntl_signal(SIGALRM, $softClose);
55		$this->handlersRegistered = true;
56		}
57		}
58

Innmind / AMQP

GitHub Access Token became invalid

Push — develop ( 4cbc06...07baac )

SignalAware::channel() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like