Ackintosh\Snidel\AbstractQueue

Complexity

Total Complexity

11

Size/Duplication

Total Lines	98
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	sendMessage()	0	4	1
A	receiveMessage()	0	12	2
A	isExceedsLimit()	0	4	1
A	queuedCount()	0	4	1
A	dequeuedCount()	0	4	1
A	delete()	0	5	1
A	__destruct()	0	6	3

<?php
declare(ticks=1);

namespace Ackintosh\Snidel;

abstract class AbstractQueue
{
    /** @var int */
    protected $ownerPid;

    /** @var \Ackintosh\Snidel\IpcKey */
    protected $ipcKey;

    /** @var \Ackintosh\Snidel\Semaphore */
    protected $semaphore;

    /** @var resource */
    protected $id;

    /** @var array */
    protected $stat;

    /** @var int */
    protected $queuedCount = 0;

    /** @var int */
    protected $dequeuedCount = 0;

    public function __construct(Config $config)
    {
        $this->ownerPid = $config->get('ownerPid');
        $this->ipcKey   = new IpcKey($this->ownerPid, $config->get('id') . str_replace('\\', '_', get_class($this)));
        $this->semaphore = new Semaphore();
        $this->id       = $this->semaphore->getQueue($this->ipcKey->generate());
        $this->stat     = $this->semaphore->statQueue($this->id);

It seems like $this->semaphore->statQueue($this->id) of type * is incompatible with the declared type array of property $stat.

    }

    /**
     * @param   string  $message
     */
    protected function sendMessage($message)
    {
        return $this->semaphore->sendMessage($this->id, 1, $message, false);
    }

    /**
     * @return  string
     * @throws  \RuntimeException
     */
    protected function receiveMessage()
    {
        $msgtype = $message = null;

        // argument #3: specify the maximum number of bytes allowsed in one message queue.
        $success = $this->semaphore->receiveMessage($this->id, 1, $msgtype, $this->stat['msg_qbytes'], $message, false);
        if (!$success) {
            throw new \RuntimeException('failed to receive message.');
        }

        return $message;
    }

    /**
     * @param   string  $message
     * @return  bool
     */
    protected function isExceedsLimit($message)
    {
        return $this->stat['msg_qbytes'] < strlen($message);
    }

    /**
     * @return  int
     */
    public function queuedCount()
    {
        return $this->queuedCount;
    }

    /**
     * @return  int
     */
    public function dequeuedCount()
    {
        return $this->dequeuedCount;
    }

    /**
     * @return bool
     */
    public function delete()
    {
        $this->ipcKey->delete();
        return msg_remove_queue($this->id);
    }

    public function __destruct()
    {
        if (isset($this->ipcKey) && $this->ipcKey->isOwner(getmypid())) {
            $this->delete();
        }
    }// @codeCoverageIgnore
}