think\process\pipes\Unix

Complexity

Total Complexity

38

Size/Duplication

Total Lines	179
Duplicated Lines	0 %

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	getFiles()	0	3	1
A	__destruct()	0	3	1
A	getDescriptors()	0	32	5
A	create()	0	3	1
F	readAndWrite()	0	83	27
A	__construct()	0	10	2
A	areOpen()	0	3	1

<?php
// +----------------------------------------------------------------------

You must use "/**" style comments for a file comment

// | ThinkPHP [ WE CAN DO IT JUST THINK ]
// +----------------------------------------------------------------------
// | Copyright (c) 2006~2015 http://thinkphp.cn All rights reserved.
// +----------------------------------------------------------------------
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | Author: yunwuxin <448901948@qq.com>
// +----------------------------------------------------------------------

namespace think\process\pipes;

use think\Process;

class Unix extends Pipes

Missing class doc comment

{

    /** @var bool */

The open comment tag must be the only content on the line

Missing short description in doc comment

The close comment tag must be the only content on the line

    private $ttyMode;

Private member variable "ttyMode" must be prefixed with an underscore

    /** @var bool */

The open comment tag must be the only content on the line

Missing short description in doc comment

The close comment tag must be the only content on the line

    private $ptyMode;

Private member variable "ptyMode" must be prefixed with an underscore

    /** @var bool */

The open comment tag must be the only content on the line

Missing short description in doc comment

The close comment tag must be the only content on the line

    private $disableOutput;

Private member variable "disableOutput" must be prefixed with an underscore

    public function __construct($ttyMode, $ptyMode, $input, $disableOutput)

Missing function doc comment

    {
        $this->ttyMode       = (bool) $ttyMode;
        $this->ptyMode       = (bool) $ptyMode;
        $this->disableOutput = (bool) $disableOutput;

        if (is_resource($input)) {
            $this->input = $input;
        } else {
            $this->inputBuffer = (string) $input;
        }
    }

    public function __destruct()

Missing function doc comment

    {
        $this->close();
    }

    /**
     * {@inheritdoc}
     */

Missing @return tag in function comment

    public function getDescriptors()
    {
        if ($this->disableOutput) {
            $nullstream = fopen('/dev/null', 'c');

            return [
                ['pipe', 'r'],
                $nullstream,
                $nullstream,
            ];
        }

        if ($this->ttyMode) {
            return [
                ['file', '/dev/tty', 'r'],
                ['file', '/dev/tty', 'w'],
                ['file', '/dev/tty', 'w'],
            ];
        }

        if ($this->ptyMode && Process::isPtySupported()) {
            return [
                ['pty'],
                ['pty'],
                ['pty'],
            ];
        }

        return [
            ['pipe', 'r'],
            ['pipe', 'w'], // stdout
            ['pipe', 'w'], // stderr
        ];
    }

    /**
     * {@inheritdoc}
     */

Missing @return tag in function comment

    public function getFiles()
    {
        return [];
    }

    /**

Parameter $blocking should have a doc-comment as per coding-style.

Parameter $close should have a doc-comment as per coding-style.

     * {@inheritdoc}
     */

Missing @return tag in function comment

    public function readAndWrite($blocking, $close = false)
    {

        if (1 === count($this->pipes) && [0] === array_keys($this->pipes)) {
            fclose($this->pipes[0]);
            unset($this->pipes[0]);
        }

        if (empty($this->pipes)) {
            return [];
        }

        $this->unblock();

        $read = [];

        if (null !== $this->input) {
            $r = array_merge($this->pipes, ['input' => $this->input]);
        } else {
            $r = $this->pipes;
        }

        unset($r[0]);

        $w = isset($this->pipes[0]) ? [$this->pipes[0]] : null;
        $e = null;

        if (false === $n = @stream_select($r, $w, $e, 0, $blocking ? Process::TIMEOUT_PRECISION * 1E6 : 0)) {

It seems like $w can also be of type null; however, parameter $write of stream_select() does only seem to accept array, maybe add an additional type check?

$e of type null is incompatible with the type array expected by parameter $except of stream_select().

It seems like $blocking ? think\Process::TIMEOUT_PRECISION * 1000000.0 : 0 can also be of type double; however, parameter $tv_usec of stream_select() does only seem to accept integer, maybe add an additional type check?

            if (!$this->hasSystemCallBeenInterrupted()) {
                $this->pipes = [];
            }

            return $read;
        }

        if (0 === $n) {
            return $read;
        }

        foreach ($r as $pipe) {

            $type = (false !== $found = array_search($pipe, $this->pipes)) ? $found : 'input';
            $data = '';
            while ('' !== $dataread = (string) fread($pipe, self::CHUNK_SIZE)) {
                $data .= $dataread;
            }

            if ('' !== $data) {
                if ('input' === $type) {
                    $this->inputBuffer .= $data;
                } else {
                    $read[$type] = $data;
                }
            }

            if (false === $data || (true === $close && feof($pipe) && '' === $data)) {
                if ('input' === $type) {
                    $this->input = null;
                } else {
                    fclose($this->pipes[$type]);
                    unset($this->pipes[$type]);
                }
            }
        }

        if (null !== $w && 0 < count($w)) {
            while (strlen($this->inputBuffer)) {
                $written = fwrite($w[0], $this->inputBuffer, 2 << 18); // write 512k
                if ($written > 0) {
                    $this->inputBuffer = (string) substr($this->inputBuffer, $written);
                } else {
                    break;
                }
            }
        }

        if ('' === $this->inputBuffer && null === $this->input && isset($this->pipes[0])) {
            fclose($this->pipes[0]);
            unset($this->pipes[0]);
        }

        return $read;
    }

    /**
     * {@inheritdoc}
     */

Missing @return tag in function comment

    public function areOpen()
    {
        return (bool) $this->pipes;
    }

    /**
     * 创建一个新的 UnixPipes 实例
     * @param Process         $process

Missing parameter comment

Tag value indented incorrectly; expected 2 spaces but found 1

     * @param string|resource $input

Missing parameter comment

Tag value indented incorrectly; expected 2 spaces but found 1

     * @return self
     */
    public static function create(Process $process, $input)
    {
        return new static($process->isTty(), $process->isPty(), $input, $process->isOutputDisabled());
    }
}