Laravoole\Wrapper\Swoole

Complexity

Total Complexity

12

Size/Duplication

Total Lines	119
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

31.43%

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	onServerStart()	0	8	1
A	onServerShutdown()	0	4	1
B	getParams()	0	41	1
A	start()	0	16	3
A	onWorkerStart()	0	8	1
A	getLogFile()	0	4	1
A	on()	0	4	1
A	send()	0	4	1
A	close()	0	4	1
A	getPid()	0	4	1

<?php
namespace Laravoole\Wrapper;

use swoole_http_server;

use Laravoole\Base;
use Exception;

abstract class Swoole extends Base
{

    // http://wiki.swoole.com/wiki/page/274.html
    public static function getParams()
    {
        return [
            'reactor_num',
            'worker_num',
            'max_request' => 2000,
            'max_conn',
            'task_worker_num',
            'task_ipc_mode',
            'task_max_request',
            'task_tmpdir',
            'dispatch_mode',
            'message_queue_key',
            'daemonize' => 1,
            'backlog',
            'log_file' => [self::class, 'getLogFile'],
            'log_level',
            'heartbeat_check_interval',
            'heartbeat_idle_time',
            'open_eof_check',
            'open_eof_split',
            'package_eof',
            'open_length_check',
            'package_length_type',
            'package_max_length',
            'open_cpu_affinity',
            'cpu_affinity_ignore',
            'open_tcp_nodelay',
            'tcp_defer_accept',
            'ssl_cert_file',
            'ssl_method',
            'user',
            'group',
            'chroot',
            'pipe_buffer_size',
            'buffer_output_size',
            'enable_unsafe_event',
            'discard_timeout_request',
            'enable_reuse_port',
        ];
    }

    public function start()
    {
        $callbacks = array_merge([
            'Start' => [$this, 'onServerStart'],
            'Shutdown' => [$this, 'onServerShutdown'],
            'WorkerStart' => [$this, 'onWorkerStart'],
        ], $this->callbacks);
        if (isset($this->wrapper_config['swoole_ontask'])) {
            $callbacks['Task'] = $this->wrapper_config['swoole_ontask'];
            $callbacks['Finish'] = $this->wrapper_config['swoole_onfinish'];
        }
        foreach ($callbacks as $on => $method) {
            $this->server->on($on, $method);

The method on() does not seem to exist on object<Laravoole\Workerman\Worker>.

        }
        return $this->server->start();

The method start() does not seem to exist on object<Laravoole\Workerman\Worker>.

    }

    /**
     * @codeCoverageIgnore
     */
    public function onServerStart()
    {
        // put pid
        file_put_contents(
            $this->pid_file,
            $this->getPid()
        );
    }

    public function onWorkerStart($serv, $worker_id)
    {
        parent::prepareKernel();

It seems like you call parent on a different method (prepareKernel() instead of onWorkerStart()). Are you sure this is correct? If so, you might want to change this to $this->prepareKernel().

        $server = $this->server;
        $this->app->singleton('laravoole.server', function ($app) use ($server) {

The parameter $app is not used and could be removed.

            return $server;
        });
    }

    /**
     * @codeCoverageIgnore
     */
    public function onServerShutdown($serv)

The parameter $serv is not used and could be removed.

    {
        @unlink($this->pid_file);

It seems like you do not handle an error condition here. This can introduce security issues, and is generally not recommended.

    }

    public static function getLogFile()
    {
        return app()->storagePath() . '/logs/laravoole.log';
    }

    public function on($event, callable $callback)
    {
        return $this->server->on($event, $callback);

The method on() does not seem to exist on object<Laravoole\Workerman\Worker>.

    }

    public function send($fd, $content)
    {
        return $this->server->send($fd, $content);

The method send() does not seem to exist on object<Laravoole\Workerman\Worker>.

    }

    public function close($fd)
    {
        return $this->server->close($fd);

The method close() does not seem to exist on object<Laravoole\Workerman\Worker>.

    }

    public function getPid()
    {
        return $this->server->master_pid;
    }


}