mpyw\Co\Internal\ManualScheduler

Complexity

Total Complexity

13

Size/Duplication

Total Lines	91
Duplicated Lines	15.38 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	add()	0	6	2
A	isEmpty()	0	4	2
A	addImmediate()	14	14	4
A	addReserved()	0	5	2
A	interruptConsume()	0	7	2

<?php

namespace mpyw\Co\Internal;
use mpyw\Co\CURLException;
use mpyw\RuntimePromise\Deferred;

class ManualScheduler extends AbstractScheduler
{
    /**
     * cURL handles those have not been dispatched.
     * @var array
     */
    private $queue = [];

    /**
     * TCP connection counter.
     * @var ConnectionCounter
     */
    private $counter;

    /**
     * Constructor.
     * Initialize cURL multi handle.
     * @param CoOption $options
     * @param resource $mh      curl_multi
     */
    public function __construct(CoOption $options, $mh)
    {
        $this->mh = $mh;
        $this->options = $options;
        $this->counter = new ConnectionCounter($options);
    }

    /**
     * Call curl_multi_add_handle() or push into queue.
     * @param resource $ch
     * @param Deferred $deferred
     */
    public function add($ch, Deferred $deferred = null)
    {
        $this->counter->isPoolFilled($ch)
            ? $this->addReserved($ch, $deferred)
            : $this->addImmediate($ch, $deferred);
    }

    /**
     * Are there no cURL handles?
     * @return bool
     */
    public function isEmpty()
    {
        return !$this->added && !$this->queue;
    }

    /**
     * Call curl_multi_add_handle().
     * @param resource $ch
     * @param Deferred $deferred
     */
    private function addImmediate($ch, Deferred $deferred = null)

This method seems to be duplicated in your project.

    {
        $errno = curl_multi_add_handle($this->mh, $ch);
        if ($errno !== CURLM_OK) {
            // @codeCoverageIgnoreStart
            $msg = curl_multi_strerror($errno) . ": $ch";
            $deferred && $deferred->reject(new \RuntimeException($msg));
            return;
            // @codeCoverageIgnoreEnd
        }
        $this->added[(string)$ch] = $ch;
        $this->counter->addDestination($ch);
        $deferred && $this->deferreds[(string)$ch] = $deferred;
    }

    /**
     * Push into queue.
     * @param resource $ch
     * @param Deferred $deferred
     */
    private function addReserved($ch, Deferred $deferred = null)
    {
        $this->queue[(string)$ch] = $ch;
        $deferred && $this->deferreds[(string)$ch] = $deferred;
    }

    /**
     * Add cURL handles from waiting queue.
     * @param array $entry
     */
    protected function interruptConsume(array $entry)
    {
        $this->counter->removeDestination($entry['handle']);
        if ($this->queue) {
            $this->add(array_shift($this->queue));
        }
    }
}