PHPDaemon\Core\EventLoop

Complexity

Total Complexity

18

Size/Duplication

Total Lines	81
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	1

14 Methods

Rating	Name	Duplication	Size	Complexity
A	init()	0	7	2
A	__construct()	0	5	1
A	getBase()	0	3	1
A	getDnsBase()	0	3	1
A	reinit()	0	3	1
A	signal()	0	3	1
A	timer()	0	3	1
A	listener()	0	3	1
A	bufferEvent()	0	3	1
A	bufferEventSsl()	0	3	1
A	interrupt()	0	6	2
A	stop()	0	4	1
A	event()	0	3	1
A	run()	0	9	3

<?php
namespace PHPDaemon\Core;
use PHPDaemon\Structures\StackCallbacks;

class EventLoop
{
    public static $instance;
    protected $base;
    protected $dnsBase;
    protected $callbacks;
    protected $stopped = true;


    public static function init() {
        if (self::$instance !== null) {
            self::$instance->reinit();
        } else {
            self::$instance = new static;
        }
    }

    public function __construct() {
        $this->base = new \EventBase;
        $this->callbacks = new StackCallbacks;
        $this->dnsBase = new \EventDnsBase($this->base, false); // @TODO: test with true

Comments for TODO tasks are often forgotten in the code; it might be better to use a dedicated issue tracker.

    }

    public function getBase() {
        return $this->base;
    }

    public function getDnsBase() {
        return $this->dnsBase;
    }

    public function reinit() {
        $this->base->reinit();
    }

    public function signal(...$args) {

The return type could not be reliably inferred; please add a @return annotation.

        return \Event::signal($this->base, ...$args);
    }

    public function timer(...$args) {

The return type could not be reliably inferred; please add a @return annotation.

        return \Event::timer($this->base, ...$args);
    }

    public function listener(...$args) {
        return new \EventListener($this->base, ...$args);
    }

    public function bufferEvent(...$args) {
        return new \EventBufferEvent($this->base, ...$args);
    }

    public function bufferEventSsl(...$args) {

The return type could not be reliably inferred; please add a @return annotation.

        return \EventBufferEvent::sslSocket($this->base, ...$args);
    }

    public function interrupt($cb = null) {
        if ($cb !== null) {
            $this->callbacks->push($cb);
        }
        $this->base->exit();
    }

    public function stop() {
        $this->stopped = true;
        $this->interrupt();
    }

    public function event(...$args) {
        return new \Event($this->base, ...$args);
    }

    public function run() {
        $this->stopped = false;
        while (!$this->stopped) {
            $this->callbacks->executeAll($this);
            if (!$this->base->dispatch()) {
                break;
            }
        }
    }
}