Carno\HRPC\Accel\Plugins\ServerPorting

Complexity

Total Complexity

8

Size/Duplication

Total Lines	55
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	enabled()	0	7	5
A	hooking()	0	18	2
A	__construct()	0	3	1

<?php
/**
 * TCP accelerator for HRPC server
 * User: moyo
 * Date: 2018/7/30
 * Time: 12:07 PM
 */

namespace Carno\HRPC\Accel\Plugins;

use Carno\Consul\Types\Tagging;

The type Carno\Consul\Types\Tagging was not found. Maybe you did not declare it correctly or list all dependencies?

use Carno\Container\DI;

The type Carno\Container\DI was not found. Maybe you did not declare it correctly or list all dependencies?

use Carno\HRPC\Accel\Marking;
use Carno\HRPC\Accel\Server;
use Carno\Net\Address;
use Carno\Net\Contracts\Conn;
use Carno\Net\Events;
use Carno\RPC\Service\Dispatcher;

The type Carno\RPC\Service\Dispatcher was not found. Maybe you did not declare it correctly or list all dependencies?

use Carno\Serving\Contracts\Plugins;

The type Carno\Serving\Contracts\Plugins was not found. Maybe you did not declare it correctly or list all dependencies?

class ServerPorting implements Plugins
{
    /**
     * @var Address
     */
    private $listen = null;

    /**
     * @var Server
     */
    private $server = null;

    /**
     * ServerPorting constructor.
     * @param Address $listen
     */
    public function __construct(Address $listen)
    {
        $this->listen = $listen;
    }

    /**
     * @return bool
     */
    public function enabled() : bool
    {
        return !debug() &&

The function debug was not found. Maybe you did not declare it correctly or list all dependencies?

            $this->listen->valid() &&
            DI::has(Tagging::class) &&
            DI::has(Dispatcher::class) &&
            version_compare(SWOOLE_VERSION, '1.8.0') >= 0

The constant Carno\HRPC\Accel\Plugins\SWOOLE_VERSION was not found. Maybe you did not declare it correctly or list all dependencies?

        ;
    }

    /**
     * @param Events $events
     */
    public function hooking(Events $events) : void
    {
        $events
        ->attach(Events\Server::CREATED, function (Conn $serv) {
            ($this->server = new Server($this->listen, $serv->server()->raw(), $serv->events()))->serve();
            if ($port = $this->server->ported()) {
                /**
                 * @var Tagging $tagger
                 */
                $tagger = DI::get(Tagging::class);
                $tagger->setTags(Marking::viaTCP($port));
                logger('hrpc-accel')->info('TCP accelerator started', ['port' => $port]);
            } else {
                logger('hrpc-accel')->notice('TCP accelerator startup failed .. skip');
            }
        })
        ->attach(Events\Worker::STOPPED, function () {
            $this->server->shutdown();
        });
    }
}