Connection::command() - Code Metrics - Inspection of "EventLoopContainer" - kakserpom/phpdaemon - Measure and Improve Code Quality continuously with Scrutinizer

Completed
Push — EventLoopContainer ( c9a84d...6e77fa )

by Vasily
created 2016-06-06 02:46 UTC
Connection::command() F

↳ Parent: Connection
Complexity

Conditions	68
Paths	752
Size

Total Lines	202
Code Lines	142
Duplication

Lines	112
Ratio	55.45 %
Importance

Changes	5
Bugs	2	Features	0
Metric	Value
cc	68
eloc	142
c	5
b	2
f	0
nc	752
nop	3
dl	112
loc	202
rs	2
How to fix Long Method Complexity

<?php
namespace PHPDaemon\Clients\Redis;

use PHPDaemon\Core\CallbackWrapper;
use PHPDaemon\Core\Daemon;
use PHPDaemon\Core\Debug;
use PHPDaemon\Network\ClientConnection;

/**
 * @package    NetworkClients
 * @subpackage RedisClient
 * @author     Vasily Zorin <[email protected]>
 */
class Connection extends ClientConnection implements \Iterator
{
    /**
     * Default flag
     */
    const RESULT_TYPE_DEFAULT = 0;

    /**
     * Flag - parse message response
     */
    const RESULT_TYPE_MESSAGE = 1;

    /**
     * Flag - parse response with arguments
     */
    const RESULT_TYPE_ARGSVALS = 2;

    /**
     * Flag - parse response to associative array
     */
    const RESULT_TYPE_ASSOC = 3;

    /**
     * @var array|null Current result
     */
    public $result = null;

    /**
     * @var string Channel name
     */
    public $channel = null;

    /**
     * @var string Message
     */
    public $msg = null;

    /**
     * @var string Current error message
     */
    public $error;

    /**
     * @var array Subcriptions
     */
    public $subscribeCb = [];

    public $psubscribeCb = [];

    /**
     * @var string Current incoming key
     */
    protected $key;

    protected $stack = [];

    protected $ptr;

    /**
     * @var integer Current value length
     */
    protected $valueLength = 0;

    /**
     * @var integer Current level length
     */
    protected $levelLength = null;

    /**
     * @var string
     */
    protected $EOL = "\r\n";

    /**
     * @var boolean Is it a subscription connection?
     */
    protected $subscribed = false;

    /**
     * @var float Timeout
     */
    protected $timeoutRead = 5;

    /**
     * @var integer Iterator position
     */
    protected $pos = 0;

    /**
     * @var \SplStack Stack of results types
     */
    protected $resultTypeStack;

    /**
     * @var null|array Current result type
     */
    protected $resultType = 0;

    /**
     * @var \SplStack Stack of commands arguments
     */
    protected $argsStack;

    /**
     * @var null|array Current arguments
     */
    protected $args = null;

    /**
     * @var null|array Associative result storage
     */
    protected $assocData = null;

    /**
     * In the middle of binary response part
     */
    const STATE_BINARY = 1;

    public function __construct($fd, $pool = null)
    {
        parent::__construct($fd, $pool);
        $this->resultTypeStack = new \SplStack;
        $this->argsStack = new \SplStack;
    }

    public function rewind()
    {
        $this->pos = 0;
    }

    public function current()

    {
        if (!is_array($this->result)) {
            return $this->pos === 0 ? $this->result : null;
        } elseif ($this->resultType === static::RESULT_TYPE_DEFAULT || $this->resultType === static::RESULT_TYPE_ARGSVALS) {

            return $this->result[$this->pos];
        } elseif ($this->resultType === static::RESULT_TYPE_MESSAGE) {
            // message
            return $this->result[2];
        } elseif ($this->resultType === static::RESULT_TYPE_ASSOC) {
            return $this->result[$this->pos * 2 + 1];
        }
    }

    public function key()

    {
        if (!is_array($this->result)) {
            return $this->pos === 0 ? 0 : null;
        } elseif ($this->resultType === static::RESULT_TYPE_DEFAULT) {
            return $this->pos;
        } elseif ($this->resultType === static::RESULT_TYPE_MESSAGE) {
            // channel
            return $this->result[1];
        } elseif ($this->resultType === static::RESULT_TYPE_ARGSVALS) {
            return $this->args[$this->pos];
        } elseif ($this->resultType === static::RESULT_TYPE_ASSOC) {
            return $this->result[$this->pos * 2];
        }
    }

    public function next()
    {
        ++$this->pos;
    }

    public function valid()
    {
        if (!is_array($this->result)) {
            return false;
        } elseif ($this->resultType === static::RESULT_TYPE_DEFAULT) {
            return isset($this->result[$this->pos]);
        } elseif ($this->resultType === static::RESULT_TYPE_ARGSVALS) {
            return isset($this->args[$this->pos]) && isset($this->result[$this->pos]);
        } elseif ($this->resultType === static::RESULT_TYPE_MESSAGE || $this->resultType === static::RESULT_TYPE_ASSOC) {

            return isset($this->result[$this->pos * 2 + 1]);
        }
    }

    /**
     * Get associative result
     * @param  string $name
     * @return array

     */
    public function __get($name)
    {
        if ($name === 'assoc') {
            if ($this->assocData === null) {
                if (!is_array($this->result) || empty($this->result)) {
                    $this->assocData = [];
                } elseif ($this->resultType === static::RESULT_TYPE_MESSAGE) {
                    $this->assocData = [$this->result[1] => $this->result[2]];
                } elseif ($this->resultType === static::RESULT_TYPE_ARGSVALS) {
                    $hash = [];
                    for ($i = 0, $s = sizeof($this->result); $i < $s; ++$i) {

                        $hash[$this->args[$i]] = $this->result[$i];
                    }
                    $this->assocData = $hash;
                } elseif ($this->resultType === static::RESULT_TYPE_ASSOC) {
                    $hash = [];
                    for ($i = 0, $s = sizeof($this->result) - 1; $i < $s; ++$i) {

                        $hash[$this->result[$i]] = $this->result[++$i];
                    }
                    $this->assocData = $hash;
                } else {
                    $this->assocData = $this->result;
                }
            }
            return $this->assocData;
        }
    }

    /**
     * Converts array into hash
     * @param array $array
     * @return array $hash
     */
    public function arrayToHash($array)
    {
        $hash = [];
        for ($i = 0, $s = sizeof($array) - 1; $i < $s; ++$i) {

            $hash[$array[$i]] = $array[++$i];
        }
        return $hash;
    }

    /**
     * @TODO

     * @param  string $key
     * @param  integer $timeout
     * @return Lock
     */
    public function lock($key, $timeout)
    {
        return new Lock($key, $timeout, $this);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
    }

    /**
     * Easy wrapper for queue of eval's
     * @param  callable $cb

     * @return MultiEval
     */
    public function meval($cb = null)
    {
        return new MultiEval($cb, $this);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
    }

    /**
     * Wrapper for scans commands
     * @param  string $cmd Command
     * @param  array $args Arguments
     * @param  cllable $cbEnd Callback

     * @param  integer $limit Limit

     * @return AutoScan
     */
    public function autoscan($cmd, $args = [], $cbEnd = null, $limit = null)
    {
        return new AutoScan($this, $cmd, $args, $cbEnd, $limit);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
    }

    /**
     * @TODO

     * @param  string $chan
     * @return integer
     */
    public function getLocalSubscribersCount($chan)
    {
        if (!isset($this->subscribeCb[$chan])) {
            return 0;
        }
        return sizeof($this->subscribeCb[$chan]);
    }

    /**
     * Called when the connection is handshaked (at low-level), and peer is ready to recv. data
     * @return void
     */
    public function onReady()
    {
        $this->ptr =& $this->result;
        if (!isset($this->password)) {
            if (isset($this->pool->config->select->value)) {
                $this->select($this->pool->config->select->value);
class ParentClass {
    private $data = array();

    public function __call($method, array $args) {
        if (0 === strpos($method, 'get')) {
            return $this->data[strtolower(substr($method, 3))];
        }

        throw new \LogicException(sprintf('Unsupported method: %s', $method));
    }
}

/**
 * If this class knows which fields exist, you can specify the methods here:
 *
 * @method string getName()
 */
class SomeClass extends ParentClass { }
            }
            parent::onReady();
            $this->setWatermark(null, $this->pool->maxAllowedPacket + 2);
            return;
        }
        $this->sendCommand('AUTH', [$this->password], function () {
            if ($this->result !== 'OK') {
                $this->log('Auth. error: ' . json_encode($this->result));
                $this->finish();
            }
            if (isset($this->pool->config->select->value)) {
                $this->select($this->pool->config->select->value);
class ParentClass {
    private $data = array();

    public function __call($method, array $args) {
        if (0 === strpos($method, 'get')) {
            return $this->data[strtolower(substr($method, 3))];
        }

        throw new \LogicException(sprintf('Unsupported method: %s', $method));
    }
}

/**
 * If this class knows which fields exist, you can specify the methods here:
 *
 * @method string getName()
 */
class SomeClass extends ParentClass { }
            }
            parent::onReady();
            $this->setWatermark(null, $this->pool->maxAllowedPacket + 2);
        });
    }

    /**
     * Magic __call
     * Example:
     * $redis->lpush('mylist', microtime(true));
     * @param  sting $cmd
     * @param  array $args
     * @return void
     */
    public function __call($cmd, $args)
    {
        $cb = null;
        for ($i = sizeof($args) - 1; $i >= 0; --$i) {

            $a = $args[$i];
            if ((is_array($a) || is_object($a)) && is_callable($a)) {
                $cb = CallbackWrapper::wrap($a);
                $args = array_slice($args, 0, $i);
                break;
            } elseif ($a !== null) {
                break;
            }
        }
        $cmd = strtoupper($cmd);
        $this->command($cmd, $args, $cb);
    }

    /**
     * @TODO

     * @param  string $name
     * @param  array $args
     * @param  callable $cb

     * @callback $cb ( )
     * @return void
     */
    public function command($name, $args, $cb = null)
    {
        if ($name === 'MULTI' || $name === 'WATCH') {
            $this->acquire();
        } // PUB/SUB handling
        elseif (mb_orig_substr($name, -9) === 'SUBSCRIBE') {
            if (!$this->subscribed) {
                $this->subscribed = true;
                $this->pool->servConnSub[$this->url] = $this;
                $this->acquire();
                $this->setTimeouts(86400, 86400); // @TODO: remove timeout

            }

            $opcb = null;
            for ($i = sizeof($args) - 1; $i >= 0; --$i) {

                $a = $args[$i];
                if ((is_array($a) || is_object($a)) && is_callable($a)) {
                    $opcb = $cb;
                    $cb = CallbackWrapper::wrap($a);
                    $args = array_slice($args, 0, $i);
                    break;
                } elseif ($a !== null) {
                    break;
                }
            }
        }

        if ($name === 'SUBSCRIBE') {
            $this->subscribed();
class ParentClass {
    private $data = array();

    public function __call($method, array $args) {
        if (0 === strpos($method, 'get')) {
            return $this->data[strtolower(substr($method, 3))];
        }

        throw new \LogicException(sprintf('Unsupported method: %s', $method));
    }
}

/**
 * If this class knows which fields exist, you can specify the methods here:
 *
 * @method string getName()
 */
class SomeClass extends ParentClass { }
            $channels = [];
            foreach ($args as $arg) {

                if (!is_array($arg)) {
                    $arg = [$arg];
                }
                foreach ($arg as $chan) {
                    $b = !isset($this->subscribeCb[$chan]);
                    CallbackWrapper::addToArray($this->subscribeCb[$chan], $cb);
                    if ($b) {
                        $channels[] = $chan;
                    } else {
                        if ($opcb !== null) {
                            $opcb($this);
function myFunction($a) {
    switch ($a) {
        case 'foo':
            $x = 1;
            break;

        case 'bar':
            $x = 2;
            break;
    }

    // $x is potentially undefined here.
    echo $x;
}
                        }
                    }
                }
            }
            if (sizeof($channels)) {
                $this->sendCommand($name, $channels, $opcb);
            }
        } elseif ($name === 'PSUBSCRIBE') {
            $this->subscribed();
class ParentClass {
    private $data = array();

    public function __call($method, array $args) {
        if (0 === strpos($method, 'get')) {
            return $this->data[strtolower(substr($method, 3))];
        }

        throw new \LogicException(sprintf('Unsupported method: %s', $method));
    }
}

/**
 * If this class knows which fields exist, you can specify the methods here:
 *
 * @method string getName()
 */
class SomeClass extends ParentClass { }
            $channels = [];
            foreach ($args as $arg) {

                if (!is_array($arg)) {
                    $arg = [$arg];
                }
                foreach ($arg as $chan) {
                    $b = !isset($this->psubscribeCb[$chan]);
                    CallbackWrapper::addToArray($this->psubscribeCb[$chan], $cb);
                    if ($b) {
                        $channels[] = $chan;
                    } else {
                        if ($opcb !== null) {
                            $opcb($this);
                        }
                    }
                }
            }
            if (sizeof($channels)) {
                $this->sendCommand($name, $channels, $opcb);
            }
        } elseif ($name === 'UNSUBSCRIBE') {
            $channels = [];
            foreach ($args as $arg) {
                if (!is_array($arg)) {
                    $arg = [$arg];
                }
                foreach ($arg as $chan) {
                    if (!isset($this->subscribeCb[$chan])) {
                        if ($opcb !== null) {
                            $opcb($this);
                        }
                        return;
                    }
                    CallbackWrapper::removeFromArray($this->subscribeCb[$chan], $cb);
                    if (sizeof($this->subscribeCb[$chan]) === 0) {

                        $channels[] = $chan;
                        unset($this->subscribeCb[$chan]);
                    } else {
                        if ($opcb !== null) {
                            $opcb($this);
                        }
                    }
                }
            }
            if (sizeof($channels)) {
                $this->sendCommand($name, $channels, $opcb);
            }
        } elseif ($name === 'UNSUBSCRIBEREAL') {

            /* Race-condition-free UNSUBSCRIBE */
            $old = $this->subscribeCb;
            $this->sendCommand('UNSUBSCRIBE', $args, function ($redis) use ($cb, $args, $old) {
                if (!$redis) {
                    $cb($redis);
                    return;
                }
                foreach ($args as $arg) {
                    if (!isset($this->subscribeCb[$arg])) {
                        continue;
                    }
                    foreach ($old[$arg] as $oldcb) {
                        CallbackWrapper::removeFromArray($this->subscribeCb[$arg], $oldcb);
                    }
                    if (!sizeof($this->subscribeCb[$arg])) {
                        unset($this->subscribeCb[$arg]);
                    }
                }
                if ($cb !== null) {
                    $cb($this);
                }
            });
        } elseif ($name === 'PUNSUBSCRIBE') {
            $channels = [];
            foreach ($args as $arg) {
                if (!is_array($arg)) {
                    $arg = [$arg];
                }
                foreach ($arg as $chan) {
                    CallbackWrapper::removeFromArray($this->psubscribeCb[$chan], $cb);
                    if (sizeof($this->psubscribeCb[$chan]) === 0) {

                        $channels[] = $chan;
                        unset($this->psubscribeCb[$chan]);
                    } else {
                        if ($opcb !== null) {
                            $opcb($this);
                        }
                    }
                }
            }
            if (sizeof($channels)) {
                $this->sendCommand($name, $channels, $opcb);
            }
        } elseif ($name === 'PUNSUBSCRIBEREAL') {

            /* Race-condition-free PUNSUBSCRIBE */
            $old = $this->psubscribeCb;
            $this->sendCommand('PUNSUBSCRIBE', $args, function ($redis) use ($cb, $args, $old) {
                if (!$redis) {
                    $cb($redis);
                    return;
                }
                foreach ($args as $arg) {
                    if (!isset($this->psubscribeCb[$arg])) {
                        continue;
                    }
                    foreach ($old[$arg] as $oldcb) {
                        CallbackWrapper::removeFromArray($this->psubscribeCb[$arg], $oldcb);
                    }
                    if (!sizeof($this->psubscribeCb[$arg])) {
                        unset($this->psubscribeCb[$arg]);
                    }
                }
                if ($cb !== null) {
                    $cb($this);
                }
            });
        } else {
            if ($name === 'MGET') {
                $this->resultTypeStack->push(static::RESULT_TYPE_ARGSVALS);
                $this->argsStack->push($args);
            } elseif ($name === 'HMGET') {
                $this->resultTypeStack->push(static::RESULT_TYPE_ARGSVALS);
                $a = $args;
                array_shift($a);
                $this->argsStack->push($a);
            } elseif ($name === 'HMSET') {
                if (sizeof($args) === 2) {
                    if (is_array($args[1])) {
                        $newArgs = [$args[0]];
                        foreach ($args[1] as $key => $value) {
                            $newArgs[] = $key;
                            $newArgs[] = $value;
                        }
                        $args = $newArgs;
                    }
                }
            } elseif ($name === 'HGETALL') {
                $this->resultTypeStack->push(static::RESULT_TYPE_ASSOC);
            } elseif (($name === 'ZRANGE' || $name === 'ZRANGEBYSCORE' || $name === 'ZREVRANGE' || $name === 'ZREVRANGEBYSCORE')

                && preg_grep('/WITHSCORES/i', $args)
            ) {
                $this->resultTypeStack->push(static::RESULT_TYPE_ASSOC);
            } else {
                $this->resultTypeStack->push(static::RESULT_TYPE_DEFAULT);
            }

            $this->sendCommand($name, $args, $cb);

            if ($name === 'EXEC' || $name === 'DISCARD') {
                $this->release();
            }
        }
    }

    /**
     * @TODO

     * @param  string $name
     * @param  array $args
     * @param  callable $cb

     * @callback $cb ( )
     * @return void
     */
    public function sendCommand($name, $args, $cb = null)
    {
        if ($name === 'MULTI') {
            $this->onResponse(null);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        } else {
            $this->onResponse($cb);

        }
        if (!is_array($args)) {
            $args = [$args];
        }
        array_unshift($args, $name);
        $this->writeln('*' . sizeof($args));
        foreach ($args as $arg) {
            $this->writeln('$' . mb_orig_strlen($arg) . $this->EOL . $arg);
        }
        if ($name === 'MULTI') {
            if ($cb !== null) {
                $cb($this);
            }
        }
    }

    /**
     * Called when connection finishes
     * @return void
     */
    public function onFinish()
    {
        parent::onFinish();
        if ($this->subscribed) {
            unset($this->pool->servConnSub[$this->url]);
        }
        /* we should reassign subscriptions */
        foreach ($this->subscribeCb as $sub => $cbs) {
            foreach ($cbs as $cb) {
                $this->pool->subscribe($sub, $cb);
            }
        }
        foreach ($this->psubscribeCb as $sub => $cbs) {
            foreach ($cbs as $cb) {
                $this->pool->psubscribe($sub, $cb);
            }
        }
    }

    protected function onPacket()
    {
        $this->result = $this->ptr;
        if (!$this->subscribed) {
            $this->resultType = !$this->resultTypeStack->isEmpty() ? $this->resultTypeStack->shift() : static::RESULT_TYPE_DEFAULT;

            if ($this->resultType === static::RESULT_TYPE_ARGSVALS) {

                $this->args = !$this->argsStack->isEmpty() ? $this->argsStack->shift() : [];
            }
            $this->onResponse->executeOne($this);
            goto clean;
        } elseif ($this->result[0] === 'message') {
            $t = &$this->subscribeCb;
        } elseif ($this->result[0] === 'pmessage') {
            $t = &$this->psubscribeCb;
        } else {
            $this->resultType = !$this->resultTypeStack->isEmpty() ? $this->resultTypeStack->shift() : static::RESULT_TYPE_DEFAULT;

            if ($this->resultType === static::RESULT_TYPE_ARGSVALS) {

                $this->args = !$this->argsStack->isEmpty() ? $this->argsStack->shift() : [];
            }
            $this->onResponse->executeOne($this);
            goto clean;
        }
        if (isset($t[$this->result[1]])) {
            $this->resultType = static::RESULT_TYPE_MESSAGE;

            $this->channel = $this->result[1];
            $this->msg = $this->result[2];
            foreach ($t[$this->result[1]] as $cb) {
                if (is_callable($cb)) {
                    $cb($this);
                }
            }
        } elseif ($this->pool->config->logpubsubracecondition->value) {
            Daemon::log('[Redis client]' . ': PUB/SUB race condition at channel ' . Debug::json($this->result[1]));
        }
        clean:
        $this->args = null;
        $this->result = null;
        $this->channel = null;
        $this->msg = null;
        $this->error = false;
$answer = 42;

$correct = false;

$correct = (bool) $answer;
        $this->pos = 0;
        $this->resultType = static::RESULT_TYPE_DEFAULT;

        $this->assocData = null;
        if (!isset($t)) {
            $this->checkFree();
        }
    }

    /**
     * @TODO

     * @param  mixed $val
     * @return void
     */
    public function pushValue($val)
    {
        if (is_array($this->ptr)) {
            $this->ptr[] = $val;
        } else {
            $this->ptr = $val;
        }
        start:
        if (sizeof($this->ptr) < $this->levelLength) {
            return;
        }
        array_pop($this->stack);
        if (!sizeof($this->stack)) {
            $this->levelLength = null;
            $this->onPacket();
            $this->ptr =& $dummy;

            $this->ptr = null;
            return;
        }

        $this->ptr =& $dummy;

        list($this->ptr, $this->levelLength) = end($this->stack);

        goto start;
    }

    /**
     * Called when new data received
     * @return void
     */
    protected function onRead()
    {
        start:
        if ($this->state === static::STATE_STANDBY) { // outside of packet
            while (($l = $this->readline()) !== null) {
                if ($l === '') {
                    continue;
                }
                $char = $l{0};
                $val = mb_orig_substr($l, 1);
                if ($char === ':') { // inline integer
                    $this->pushValue((int)$val);
                    goto start;
                } elseif (($char === '+') || ($char === '-')) { // inline string
                    $this->error = $char === '-';
$answer = 42;

$correct = false;

$correct = (bool) $answer;
                    $this->pushValue($val);
                    goto start;
                } elseif ($char === '*') { // defines number of elements of incoming array
                    $length = (int)$val;
                    if ($length <= 0) {
                        $this->pushValue([]);
                        goto start;
                    }

                    $ptr = [];

                    if (is_array($this->ptr)) {
                        $this->ptr[] =& $ptr;
                    }

                    $this->ptr =& $ptr;
                    $this->stack[] = [&$ptr, $length];
                    $this->levelLength = $length;
                    unset($ptr);

                    goto start;
                } elseif ($char === '$') { // defines size of the data block
                    if ($l{1} === '-') {
                        $this->pushValue(null);
                        goto start;
                    }
                    $this->valueLength = (int)$val;
                    if ($this->valueLength + 2 > $this->pool->maxAllowedPacket) {
                        $this->log('max-allowed-packet (' . $this->pool->config->maxallowedpacket->getHumanValue() . ') exceed, aborting connection');

                        $this->finish();
                        return;
                    }
                    $this->setWatermark($this->valueLength + 2);
                    $this->state = static::STATE_BINARY; // binary data block
                    break; // stop reading line-by-line
                }
            }
        }

        if ($this->state === static::STATE_BINARY) { // inside of binary data block
            if ($this->getInputLength() < $this->valueLength + 2) {
                return; //we do not have a whole packet
            }
            $value = $this->read($this->valueLength);
            if ($this->read(2) !== $this->EOL) {
                $this->finish();
                return;
            }
            $this->state = static::STATE_STANDBY;
            $this->setWatermark(3);
            $this->pushValue($value);
            goto start;
        }
    }
}

1			<?php
2			namespace PHPDaemon\Clients\Redis;
3
4			use PHPDaemon\Core\CallbackWrapper;
5			use PHPDaemon\Core\Daemon;
6			use PHPDaemon\Core\Debug;
7			use PHPDaemon\Network\ClientConnection;
8
9			/**
10			* @package NetworkClients
11			* @subpackage RedisClient
12			* @author Vasily Zorin <[email protected]>
13			*/
14			class Connection extends ClientConnection implements \Iterator
15			{
16			/**
17			* Default flag
18			*/
19			const RESULT_TYPE_DEFAULT = 0;
20
21			/**
22			* Flag - parse message response
23			*/
24			const RESULT_TYPE_MESSAGE = 1;
25
26			/**
27			* Flag - parse response with arguments
28			*/
29			const RESULT_TYPE_ARGSVALS = 2;
30
31			/**
32			* Flag - parse response to associative array
33			*/
34			const RESULT_TYPE_ASSOC = 3;
35
36			/**
37			* @var array\|null Current result
38			*/
39			public $result = null;
40
kakserpom / phpdaemon

Push — EventLoopContainer ( c9a84d...6e77fa )

Connection::command() F

Complexity

Size

Duplication

Importance

How to fix Long Method Complexity

Long Method

Available Fixes

Duplication Side-by-Side

Filter issues like
