Carno\Pool\Features\Heartbeat

Complexity

Total Complexity

3

Size/Duplication

Total Lines	27
Duplicated Lines	0 %

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	keeping()	0	10	2

<?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();
            });
        }
    }
}