Code Duplication - huyanping/simple-fork-php - Measure and Improve Code Quality continuously with Scrutinizer

Code Duplication Length = 17-17 lines in 2 locations

src/Queue/Pipe.php 2 locations


     * @param int $size
     * @return string
     */
    public function read($size = 1024)
    {
        if (!is_resource($this->read)) {
            $this->read = fopen($this->filename, 'r+');
            if (!is_resource($this->read)) {
                throw new \RuntimeException('open file failed');
            }
            if (!$this->block) {
                $set = stream_set_blocking($this->read, false);
                if (!$set) {
                    throw new \RuntimeException('stream_set_blocking failed');
                }
            }
        }

        return fread($this->read, $size);
    }

    /**
     * @param $message

     * @param $message
     * @return int
     */
    public function write($message)
    {
        if (!is_resource($this->write)) {
            $this->write = fopen($this->filename, 'w+');
            if (!is_resource($this->write)) {
                throw new \RuntimeException('open file failed');
            }
            if (!$this->block) {
                $set = stream_set_blocking($this->write, false);
                if (!$set) {
                    throw new \RuntimeException('stream_set_blocking failed');
                }
            }
        }

        return fwrite($this->write, $message);
    }

    /**
     *

		@@ 78-94 (lines=17) @@
75		* @param int $size
76		* @return string
77		*/
78		public function read($size = 1024)
79		{
80		if (!is_resource($this->read)) {
81		$this->read = fopen($this->filename, 'r+');
82		if (!is_resource($this->read)) {
83		throw new \RuntimeException('open file failed');
84		}
85		if (!$this->block) {
86		$set = stream_set_blocking($this->read, false);
87		if (!$set) {
88		throw new \RuntimeException('stream_set_blocking failed');
89		}
90		}
91		}
92
93		return fread($this->read, $size);
94		}
95
96		/**
97		* @param $message
		@@ 100-116 (lines=17) @@
97		* @param $message
98		* @return int
99		*/
100		public function write($message)
101		{
102		if (!is_resource($this->write)) {
103		$this->write = fopen($this->filename, 'w+');
104		if (!is_resource($this->write)) {
105		throw new \RuntimeException('open file failed');
106		}
107		if (!$this->block) {
108		$set = stream_set_blocking($this->write, false);
109		if (!$set) {
110		throw new \RuntimeException('stream_set_blocking failed');
111		}
112		}
113		}
114
115		return fwrite($this->write, $message);
116		}
117
118		/**
119		*

huyanping / simple-fork-php

Code Duplication Length = 17-17 lines in 2 locations

src/Queue/Pipe.php 2 locations