Ackintosh\Snidel\ResultQueue

Complexity

Total Complexity

7

Size/Duplication

Total Lines	48
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	enqueue()	0	4	1
A	dequeue()	0	12	2
A	dequeuedCount()	0	4	1
A	__destruct()	0	7	2

<?php
namespace Ackintosh\Snidel;

use Ackintosh\Snidel\IpcKey;
use Opis\Closure\SerializableClosure;

class ResultQueue
{

    const RESULT_MAX_SIZE = 5120;

    private $dequeuedCount = 0;

    public function __construct($ownerPid)
    {
        $this->ownerPid = $ownerPid;

The property ownerPid does not exist. Did you maybe forget to declare it?

        $this->ipcKey = new IpcKey($ownerPid, 'snidel_result_' . uniqid((string) mt_rand(1, 100), true));

The property ipcKey does not exist. Did you maybe forget to declare it?

        $this->id = msg_get_queue($this->ipcKey->generate());

The property id does not exist. Did you maybe forget to declare it?

    }

    public function enqueue($result)
    {
        return msg_send($this->id, 1, serialize($result));
    }

    public function dequeue()
    {
        $this->dequeuedCount++;
        $msgtype = $message = null;
        $success = msg_receive($this->id, 1, $msgtype, self::RESULT_MAX_SIZE, $message);

        if (!$success) {
            throw new \RuntimeException('failed to dequeue result');
        }

        return unserialize($message);
    }

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

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