Ackintosh\Snidel\SharedMemory

Complexity

Total Complexity

18

Size/Duplication

Total Lines	117
Duplicated Lines	7.69 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	1
Bugs	0	Features	0

8 Methods

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

<?php
namespace Ackintosh\Snidel;

use Ackintosh\Snidel\Exception\SharedMemoryControlException;

class SharedMemory
{
    /** @var int **/
    private $pid;

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

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

    /** @const string **/
    const TMP_FILE_PREFIX = 'snidel_shm_';

    /**
     * @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  Ackintosh\Snidel\Exception\SharedMemoryControlException
     */
    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 SharedMemoryControlException('could not open shared memory');
        }
    }

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

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

        return $data;
    }

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

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

    public function exists()
    {
        $ret = @shmop_open($this->key, 'a', 0, 0);
        return $ret !== false;
    }

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

This method seems to be duplicated in your project.

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

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