Heartbeat::keeping() - Code Metrics - carno-php/pool - Measure and Improve Code Quality continuously with Scrutinizer

Heartbeat::keeping() A
last analyzed 2019-06-19 10:10 UTC

↳ Parent: Heartbeat

Complexity

Conditions	2
Paths	2

Size

Total Lines	10
Code Lines	5

Duplication

Lines	0
Ratio	0 %

Importance

Changes

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

<?php
/**
 * Heartbeats manager
 * User: moyo
 * Date: 09/08/2017
 * Time: 5:47 PM
 */

namespace Carno\Pool\Features;

use Carno\Pool\Chips\CWorker;
use Carno\Pool\Connections;
use Carno\Pool\Options;
use Carno\Pool\Poolable;

class Heartbeat
{
    use CWorker;

    /**
     * Heartbeat constructor.
     * @param Options $options
     * @param Connections $connections
     */
    public function __construct(Options $options, Connections $connections)
    {
        $this->track($connections);
        $this->ticker($options->hbInterval, [$this, 'keeping']);
    }

    /**
     */
    public function keeping() : void
    {
        /**
         * @var Poolable $conn
         */
        while (null !== $conn = $this->conn()->getIdled(false, false)) {
            $conn->heartbeat()->then(static function () use ($conn) {
                $conn->release();
            }, static function () use ($conn) {
                $conn->destroy();
            });
        }
    }
}


1			<?php
2			/**
3			* Heartbeats manager
4			* User: moyo
5			* Date: 09/08/2017
6			* Time: 5:47 PM
7			*/
8
9			namespace Carno\Pool\Features;
10
11			use Carno\Pool\Chips\CWorker;
12			use Carno\Pool\Connections;
13			use Carno\Pool\Options;
14			use Carno\Pool\Poolable;
15
16			class Heartbeat
17			{
18			use CWorker;
19
20			/**
21			* Heartbeat constructor.
22			* @param Options $options
23			* @param Connections $connections
24			*/
25			public function __construct(Options $options, Connections $connections)
26			{
27			$this->track($connections);
28			$this->ticker($options->hbInterval, [$this, 'keeping']);
29			}
30
31			/**
32			*/
33			public function keeping() : void
34			{
35			/**
36			* @var Poolable $conn
37			*/
38			while (null !== $conn = $this->conn()->getIdled(false, false)) {
39			$conn->heartbeat()->then(static function () use ($conn) {
40			$conn->release();
41			}, static function () use ($conn) {
42			$conn->destroy();
43			});
44			}
45			}
46			}
47

carno-php / pool

Heartbeat::keeping() A last analyzed 2019-06-19 10:10 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

Heartbeat::keeping() A
last analyzed 2019-06-19 10:10 UTC