Ackintosh\Snidel\Worker

Complexity

Total Complexity

9

Size/Duplication

Total Lines	92
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes	3
Bugs	0	Features	0

6 Methods

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

<?php
namespace Ackintosh\Snidel;

use Ackintosh\Snidel\Pcntl;
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;

    /** @var \Ackintosh\Snidel\Pcntl */
    private $pcntl;

    /**
     * @param   \Ackintosh\Snidel\Fork\Fork $fork
     * @param   \Ackintosh\Snidel\Task\Task
     */
    public function __construct($fork, $task)
    {
        $this->pcntl    = new Pcntl();
        $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;
        }
    }

    /**
     * @param   int     $sig
     * @return  void
     */
    public function terminate($sig)
    {
        posix_kill($this->fork->getPid(), $sig);
        $status = null;
        $this->pcntl->waitpid($this->fork->getPid(), $status);
    }
}