AsyncPHP\Process\PosixHandler

Complexity

Total Complexity

8

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	start()	0	10	2
A	running()	0	21	3
A	stop()	0	6	3

<?php

namespace AsyncPHP\Process;

class PosixHandler implements Handler
{
    /**
     * @var int
     */
    private $pid = 0;

    /**
     * @inheritdoc
     *
     * @param string $id
     * @param string $command
     * @param bool $background
     */
    public function start($id, $command, $background = false)
    {
        $shhh = "";

        if ($background) {
            $shhh = " > /dev/null 2> /dev/null &";
        }

        passthru("ASYNCPHP_PROCESS_ID={$id} {$command} {$shhh}");
    }

    /**
     * @inheritdoc
     *
     * @param string $id
     *
     * @return bool
     */
    public function running($id)
    {
        $switch = "e";

        if (stristr(PHP_OS, "DAR")) {
            $switch = "E";
        }

        exec("ps {$switch} | grep \"[A]SYNCPHP_PROCESS_ID={$id}\"", $output);

        if (count($output)) {
            $line = trim($output[0]);
            $values = explode(" ", $line);

            $this->pid = (int) $values[0];

            return true;
        }

        return false;
    }

    /**
     * @inheritdoc
     *
     * @param string $id
     */
    public function stop($id)
    {
        if ($this->running($id) && $this->pid) {
            exec("kill -9 {$this->pid}");
        }
    }
}