TailReader::__destruct() - Code Metrics - huyanping/log-monitor - Measure and Improve Code Quality continuously with Scrutinizer

TailReader::__destruct() A
last analyzed 2016-07-08 02:38 UTC

↳ Parent: TailReader

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	3
CRAP Score	1

Importance

Changes	1
Bugs	0	Features	1

Metric	Value
c	1
b	0
f	1
dl	0
loc	4
ccs	3
cts	3
cp	1
rs	10
cc	1
eloc	2
nc	1
nop	0
crap	1

<?php
/**
 * Created by PhpStorm.
 * User: Jenner
 * Date: 2015/10/14
 * Time: 9:52
 */

namespace Jenner\LogMonitor\Reader;


class TailReader implements ReaderInterface
{
    protected $file;
    protected $error_file;
    protected $handle;
    protected $pipes;
    protected $process;

    public function configure($file)
    {
        if (!file_exists($file)) {
            throw new \RuntimeException("log file is not exists. file:" . $file);
        }
        $this->file = $file;
    }

    /**
     * open stream
     */
    public function open()
    {
        $command = "tail -F {$this->file}";
        $descriptors = array(
            0 => array("pipe", "r"),  // stdin is a pipe that the child will read from
            1 => array("pipe", "w"),  // stdout is a pipe that the child will write to
            2 => array("file", "/dev/null", "a") // stderr is a file to write to
        );

        $cwd = '/tmp';
        $this->process = proc_open($command, $descriptors, $this->pipes, $cwd);
        $this->handle = $this->pipes[1];
    }

    public function info()
    {
        return $this->file;
    }

    /**
     * read from stream
     * @param null $length
     * @return bool|string If there is no more data to read, the process will be blocked
     */
    public function read($length = null)
    {
        return fgets($this->handle);
    }

    /**
     * close stream
     * @return mixed
     */
    public function close()
    {
        if(!is_resource($this->process)) {
            return;
        }
        $status = proc_get_status($this->process);
        if ($status['running'] == true) { //process ran too long, kill it
            //close all pipes that are still open
            @fclose($this->pipes[0]); //stdin
// For example instead of
@mkdir($dir);

// Better use
if (@mkdir($dir) === false) {
    throw new \RuntimeException('The directory '.$dir.' could not be created.');
}
            @fclose($this->pipes[1]); //stdout
// For example instead of
@mkdir($dir);

// Better use
if (@mkdir($dir) === false) {
    throw new \RuntimeException('The directory '.$dir.' could not be created.');
}
            @fclose($this->pipes[2]); //stderr
// For example instead of
@mkdir($dir);

// Better use
if (@mkdir($dir) === false) {
    throw new \RuntimeException('The directory '.$dir.' could not be created.');
}
            //get the parent pid of the process we want to kill
            $parent_pid = $status['pid'];
            //use ps to get all the children of this process, and kill them
            $pids = preg_split('/\s+/', `ps -o pid --no-heading --ppid $parent_pid`);
            foreach ($pids as $pid) {
                if (is_numeric($pid)) {
                    posix_kill($pid, 9); //9 is the SIGKILL signal
                }
            }

            proc_close($this->process);
        }
    }

    public function __destruct()
    {
        $this->close();
    }
}

1		<?php
2		/**
3		* Created by PhpStorm.
4		* User: Jenner
5		* Date: 2015/10/14
6		* Time: 9:52
7		*/
8
9		namespace Jenner\LogMonitor\Reader;
10
11
12		class TailReader implements ReaderInterface
13		{
14		protected $file;
15		protected $error_file;
16		protected $handle;
17		protected $pipes;
18		protected $process;
19
20	6	public function configure($file)
21		{
22	6	if (!file_exists($file)) {
23	3	throw new \RuntimeException("log file is not exists. file:" . $file);
24		}
25	3	$this->file = $file;
26	3	}
27
28		/**
29		* open stream
30		*/
31	3	public function open()
32		{
33	3	$command = "tail -F {$this->file}";
34		$descriptors = array(
35	3	0 => array("pipe", "r"), // stdin is a pipe that the child will read from
36	3	1 => array("pipe", "w"), // stdout is a pipe that the child will write to
37	3	2 => array("file", "/dev/null", "a") // stderr is a file to write to
38	3	);
39
40	3	$cwd = '/tmp';
41	3	$this->process = proc_open($command, $descriptors, $this->pipes, $cwd);
42	3	$this->handle = $this->pipes[1];
43	3	}
44
45		public function info()
46		{
47		return $this->file;
48		}
49
50		/**
51		* read from stream
52		* @param null $length
53		* @return bool\|string If there is no more data to read, the process will be blocked
54		*/
55	3	public function read($length = null)
56		{
57	3	return fgets($this->handle);
58		}
59
60		/**
61		* close stream
62		* @return mixed
63		*/
64	6	public function close()
65		{
66	6	if(!is_resource($this->process)) {
67	3	return;
68		}
69	3	$status = proc_get_status($this->process);
70	3	if ($status['running'] == true) { //process ran too long, kill it
71		//close all pipes that are still open
72	3	@fclose($this->pipes[0]); //stdin
		0 ignored issues – show Security Best Practice introduced 2016-07-06 09:27 UTC by Report Bug Copy Issue Report It seems like you do not handle an error condition here. This can introduce security issues, and is generally not recommended. If you suppress an error, we recommend checking for the error condition explicitly: // For example instead of @mkdir($dir); // Better use if (@mkdir($dir) === false) { throw new \RuntimeException('The directory '.$dir.' could not be created.'); } Loading history...
73	3	@fclose($this->pipes[1]); //stdout
		0 ignored issues – show Security Best Practice introduced 2016-07-06 09:27 UTC by Report Bug Copy Issue Report It seems like you do not handle an error condition here. This can introduce security issues, and is generally not recommended. If you suppress an error, we recommend checking for the error condition explicitly: // For example instead of @mkdir($dir); // Better use if (@mkdir($dir) === false) { throw new \RuntimeException('The directory '.$dir.' could not be created.'); } Loading history...
74	3	@fclose($this->pipes[2]); //stderr
		0 ignored issues – show Security Best Practice introduced 2016-07-06 09:27 UTC by Report Bug Copy Issue Report It seems like you do not handle an error condition here. This can introduce security issues, and is generally not recommended. If you suppress an error, we recommend checking for the error condition explicitly: // For example instead of @mkdir($dir); // Better use if (@mkdir($dir) === false) { throw new \RuntimeException('The directory '.$dir.' could not be created.'); } Loading history...
75		//get the parent pid of the process we want to kill
76	3	$parent_pid = $status['pid'];
77		//use ps to get all the children of this process, and kill them
78	3	$pids = preg_split('/\s+/', `ps -o pid --no-heading --ppid $parent_pid`);
79	3	foreach ($pids as $pid) {
80	3	if (is_numeric($pid)) {
81	3	posix_kill($pid, 9); //9 is the SIGKILL signal
82	3	}
83	3	}
84
85	3	proc_close($this->process);
86	3	}
87	3	}
88
89	6	public function __destruct()
90		{
91	6	$this->close();
92		}
93		}

huyanping / log-monitor

TailReader::__destruct() A last analyzed 2016-07-08 02:38 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

TailReader::__destruct() A
last analyzed 2016-07-08 02:38 UTC