Comodojo\Extender\Components\Ipc

Complexity

Total Complexity

10

Size/Duplication

Total Lines	73
Duplicated Lines	0 %

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	hang()	0	4	1
A	free()	0	3	1
A	close()	0	3	1
A	read()	0	9	2
A	init()	0	9	2
A	write()	0	9	2
A	__construct()	0	7	1

<?php namespace Comodojo\Extender\Components;

use \Comodojo\Foundation\Base\Configuration;
use \Comodojo\Foundation\Validation\DataFilter;
use \Exception;

/**
 * @package     Comodojo Extender
 * @author      Marco Giovinazzi <marco.giovinazzi@comodojo.org>
 * @license     MIT
 *
 * LICENSE:
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 * THE SOFTWARE.
 */

class Ipc {

    const READER = 0;

    const WRITER = 1;

    private $bytes;

    private $ipc = [];

    public function __construct(Configuration $configuration) {

        $this->bytes = DataFilter::filterInteger(
            $configuration->get('child-max-result-bytes'),
            1024,

1024 of type integer is incompatible with the type array expected by parameter $min of Comodojo\Foundation\Validation\DataFilter::filterInteger().

            PHP_INT_MAX,

Comodojo\Extender\Components\PHP_INT_MAX of type integer is incompatible with the type array expected by parameter $max of Comodojo\Foundation\Validation\DataFilter::filterInteger().

            16384

16384 of type integer is incompatible with the type array expected by parameter $default of Comodojo\Foundation\Validation\DataFilter::filterInteger().

        );

    }

    public function init($uid) {

        $this->ipc[$uid] = [];

        $socket = socket_create_pair(AF_UNIX, SOCK_STREAM, 0, $this->ipc[$uid]);

        if ( $socket == false ) throw new Exception("Socket error: ".socket_strerror(socket_last_error()));

It seems like you are loosely comparing two booleans. Considering using the strict comparison === instead.

        return $socket;

    }

    public function read($uid) {

        $reader = $this->ipc[$uid][self::READER];

        $result = socket_read($reader, $this->bytes, PHP_BINARY_READ);

        if ( $result === false ) throw new Exception("Socket error: ".socket_strerror(socket_last_error($reader)));

        return $result;

    }

    public function write($uid, $data) {

        $writer = $this->ipc[$uid][self::WRITER];

        $result = socket_write($writer, $data, strlen($data));

        if ( $result === false ) throw new Exception("Socket error: ".socket_strerror(socket_last_error($writer)));

        return $result;

    }

    public function close($uid, $handler) {

        socket_close($this->ipc[$uid][$handler]);

    }

    public function hang($uid) {

        socket_close($this->ipc[$uid][self::READER]);
        socket_close($this->ipc[$uid][self::WRITER]);

    }

    public function free() {

        $this->ipc = [];

    }

}