Carno\Shaping\Bucket

Complexity

Total Complexity

10

Size/Duplication

Total Lines	89
Duplicated Lines	0 %

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	stop()	0	3	1
A	out()	0	7	2
A	in()	0	10	5
A	tokens()	0	3	1
A	__construct()	0	8	1

<?php
/**
 * Bucket with tokens
 * User: moyo
 * Date: 19/08/2017
 * Time: 11:42 AM
 */

namespace Carno\Shaping;

use Carno\Timer\Timer;

class Bucket
{
    /**
     * Overall generating interval in ms
     */
    private const GMS = 1000;

    /**
     * How many TICK in once generating loop
     */
    private const PST = 10;

    /**
     * @var Options
     */
    private $options = null;

    /**
     * @var int
     */
    private $tokens = 0;

    /**
     * @var string
     */
    private $generator = null;

    /**
     * @var callable
     */
    private $watcher = null;

    /**
     * Bucket constructor.
     * @param Options $options
     * @param callable $watcher
     */
    public function __construct(Options $options, callable $watcher = null)
    {
        $this->options = $options;

        $this->tokens = $options->capacity;

        $this->watcher = $watcher;
        $this->generator = Timer::loop(self::GMS / self::PST, [$this, 'in']);
    }

    /**
     */
    public function stop() : void
    {
        Timer::clear($this->generator);
    }

    /**
     * @return int
     */
    public function tokens() : int
    {
        return $this->tokens;
    }

    /**
     * tokens in
     */
    public function in() : void
    {
        $this->tokens += intval($this->options->bucketTGS / self::PST);

        $this->options->capacity > 0
            ? $this->tokens > $this->options->capacity && $this->tokens = $this->options->capacity
            : $this->tokens > $this->options->bucketTGS && $this->tokens = $this->options->bucketTGS
        ;

        ($c = $this->watcher) && $c($this);
    }

    /**
     * tokens out
     * @param int $n
     * @return bool
     */
    public function out(int $n) : bool
    {
        if ($n <= $this->tokens) {
            $this->tokens -= $n;
            return true;
        } else {
            return false;
        }
    }
}