Snidel_SharedMemory

Complexity

Total Complexity

15

Size/Duplication

Total Lines	108
Duplicated Lines	8.33 %

Coupling/Cohesion

Components	1
Dependencies	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	open()	0	9	4
A	write()	0	9	2
A	read()	0	9	2
A	delete()	0	6	2
A	close()	0	7	2
A	generateKey()	9	9	2

<?php
class Snidel_SharedMemory

PSR1 recommends that each class must be in a namespace of at least one level to avoid collisions.

{
    /** @int **/
    private $pid;

    /** @int **/
    private $key;

    /** @int **/
    private $segmentId;

    /**
     * @param   int     $pid
     */
    public function __construct($pid)
    {
        $this->pid = $pid;
        $this->key = $this->generateKey($pid);
    }

    /**
     * create or open shared memory block
     *
     * @param   int     $length
     * @throws  RuntimeException
     */
    public function open($length = 0)
    {
        $flags  = ($length === 0) ? 'a' : 'n';
        $mode   = ($length === 0) ? 0 : 0666;
        $this->segmentId = shmop_open($this->key, $flags, $mode, $length);
        if ($this->segmentId === false) {
            throw new RuntimeException('could not open shared memory');
        }
    }

    /**
     * write data into shared memory block
     *
     * @param   string  $data
     * @throws  RuntimeException
     */
    public function write($data)
    {
        $writtenSize = shmop_write($this->segmentId, $data, 0);
        if ($writtenSize === false) {
            $this->delete();
            $this->close();
            throw new RuntimeException('could not write the data to shared memory');
        }
    }

    /**
     * read data from shared memory block
     *
     * @return string
     * @throws  RuntimeException
     */
    public function read()
    {
        $data = shmop_read($this->segmentId, 0, shmop_size($this->segmentId));
        if ($data === false) {
            throw new RuntimeException('could not read the data to shared memory');
        }

        return $data;
    }

    /**
     * delete shared memory block
     *
     * @throws  RuntimeException
     */
    public function delete()
    {
        if (!shmop_delete($this->segmentId)) {
            throw new RuntimeException('could not delete the data to shared memory');
        }
    }

    /**
     * cloase shared memory block
     *
     * @param   bool    $removeTmpFile
     */
    public function close($removeTmpFile = false)
    {
        shmop_close($this->segmentId);
        if ($removeTmpFile) {
            unlink('/tmp/' . sha1($this->pid));
        }
    }

    /**
     * generate IPC key
     *
     * @return  int
     */
    private function generateKey($pid)

This method seems to be duplicated in your project.

    {
        $pathname = '/tmp/' . sha1($pid);
        if (!file_exists($pathname)) {
            touch($pathname);
        }

        return ftok($pathname, 'S');
    }
}