Reconciled::shutdown() - Code Metrics - carno-php/hrpca - Measure and Improve Code Quality continuously with Scrutinizer

Reconciled::shutdown() A
last analyzed 2019-04-06 18:26 UTC

↳ Parent: Reconciled

Complexity

Conditions	2
Paths	2

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
eloc	2
dl	0
loc	4
rs	10
c	0
b	0
f	0
cc	2
nc	2
nop	1

<?php
/**
 * Reconciled of packets
 * User: moyo
 * Date: 2018/8/1
 * Time: 10:08 PM
 */

namespace Carno\HRPC\Accel\Transport;

use Throwable;

class Reconciled
{
    /**
     * @var Packet[]
     */
    private $packets = [];

    /**
     * @param int $seq
     * @return Packet
     */
    public function wait(int $seq) : Packet
    {
        return $this->packets[$seq] = new Packet($seq, $this);
    }

    /**
     * @param int $seq
     * @param string $message
     * @return bool
     */
    public function done(int $seq, string $message) : bool
    {
        if ($packet = $this->packets[$seq] ?? null) {
            unset($this->packets[$seq]);
            return $packet->received($message);
        }
        return false;
    }

    /**
     * @param int $seq
     * @param Throwable $e
     * @return bool
     */
    public function fail(int $seq, Throwable $e = null) : bool
    {
        if ($packet = $this->packets[$seq] ?? null) {
            unset($this->packets[$seq]);
            return $packet->failure($e);
        }
        return false;
    }

    /**
     * @param int $seq
     */
    public function free(int $seq) : void
    {
        unset($this->packets[$seq]);
    }

    /**
     * @param Throwable $e
     */
    public function shutdown(Throwable $e = null) : void
    {
        foreach (array_keys($this->packets) as $seq) {
            $this->fail($seq, $e);
        }
    }
}


1			<?php
2			/**
3			* Reconciled of packets
4			* User: moyo
5			* Date: 2018/8/1
6			* Time: 10:08 PM
7			*/
8
9			namespace Carno\HRPC\Accel\Transport;
10
11			use Throwable;
12
13			class Reconciled
14			{
15			/**
16			* @var Packet[]
17			*/
18			private $packets = [];
19
20			/**
21			* @param int $seq
22			* @return Packet
23			*/
24			public function wait(int $seq) : Packet
25			{
26			return $this->packets[$seq] = new Packet($seq, $this);
27			}
28
29			/**
30			* @param int $seq
31			* @param string $message
32			* @return bool
33			*/
34			public function done(int $seq, string $message) : bool
35			{
36			if ($packet = $this->packets[$seq] ?? null) {
37			unset($this->packets[$seq]);
38			return $packet->received($message);
39			}
40			return false;
41			}
42
43			/**
44			* @param int $seq
45			* @param Throwable $e
46			* @return bool
47			*/
48			public function fail(int $seq, Throwable $e = null) : bool
49			{
50			if ($packet = $this->packets[$seq] ?? null) {
51			unset($this->packets[$seq]);
52			return $packet->failure($e);
53			}
54			return false;
55			}
56
57			/**
58			* @param int $seq
59			*/
60			public function free(int $seq) : void
61			{
62			unset($this->packets[$seq]);
63			}
64
65			/**
66			* @param Throwable $e
67			*/
68			public function shutdown(Throwable $e = null) : void
69			{
70			foreach (array_keys($this->packets) as $seq) {
71			$this->fail($seq, $e);
72			}
73			}
74			}
75

carno-php / hrpca

Reconciled::shutdown() A last analyzed 2019-04-06 18:26 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

Reconciled::shutdown() A
last analyzed 2019-04-06 18:26 UTC