Ackintosh\Snidel\Worker

Complexity

Total Complexity

8

Size/Duplication

Total Lines	77
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes	2
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	setResultQueue()	0	4	1
A	getPid()	0	4	1
A	run()	0	16	3
A	error()	0	13	2

<?php
namespace Ackintosh\Snidel;

use Ackintosh\Snidel\Result\Result;

class Worker
{
    /** @var \Ackintosh\Snidel\Task\Task */
    private $task;

    /** @var \Ackintosh\Snidel\Fork\Fork */
    private $fork;

    /** @var \Ackintosh\Snidel\Result\Queue */
    private $resultQueue;

    /**
     * @param   \Ackintosh\Snidel\Fork\Fork $fork
     * @param   \Ackintosh\Snidel\Task\Task
     */
    public function __construct($fork, $task)
    {
        $this->fork = $fork;
        $this->task = $task;
    }

    /**
     * @param   \Ackintosh\Snidel\Result\Queue
     * @return  void
     */
    public function setResultQueue($queue)
    {
        $this->resultQueue = $queue;
    }

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

    /**
     * @return  void
     * @throws  \RuntimeException
     */
    public function run()
    {
        try {
            $result = $this->task->execute();
        } catch (\RuntimeException $e) {
            throw $e;
        }

        $result->setFork($this->fork);

        try {
            $this->resultQueue->enqueue($result);
        } catch (\RuntimeException $e) {
            throw $e;
        }
    }

    /**
     * @return  void
     * @throws  \RuntimeException
     */
    public function error()
    {
        $result = new Result();
        $result->setError(error_get_last());
        $result->setTask($this->task);
        $result->setFork($this->fork);

        try {
            $this->resultQueue->enqueue($result);
        } catch (\RuntimeException $e) {
            throw $e;
        }
    }
}