PjbServer\Tools\System\Linux\LinuxProcess

Complexity

Total Complexity

7

Size/Duplication

Total Lines	69
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	2

Test Coverage

Coverage

93.1%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	2
A	isRunning()	0	8	1
B	kill()	0	22	4

<?php

namespace PjbServer\Tools\System\Linux;

use PjbServer\Tools\Exception;
use PjbServer\Tools\System\ProcessInterface;
use Psr\Log\LoggerInterface;
use Psr\Log\NullLogger;

class LinuxProcess implements ProcessInterface
{


    /**
     * @var LoggerInterface
     */
    protected $logger;


    /**
     * LinuxProcess constructor.
     * @param LoggerInterface $logger
     */
    public function __construct($logger = null)
    {
        if ($logger === null) {
            $logger = new NullLogger();
        }
        $this->logger = $logger;
    }

    /**
     * Check whether a pid is running
     *
     * @throws Exception\InvalidArgumentException
     * @param int $pid
     * @return boolean
     */
    public function isRunning($pid)
    {
        $cmd = sprintf("kill -0 %d 2>&1", $pid);
        $this->logger->debug(__METHOD__ . ": Exec command: $cmd");
        exec($cmd, $output, $return_var);
        $running = ($return_var === 0);
        return $running;
    }

    /**
     * Kill a process
     *
     * @throws Exception\InvalidArgumentException
     * @param int $pid
     * @param bool $wait wait for the process to be killed
     * @return bool
     */
    public function kill($pid, $wait = false)
    {
        $killed = false;
        if ($this->isRunning($pid)) {
            if ($wait) {
                $sleep_time = '0.2';
                $cmd = sprintf("kill %d; while ps -p %d; do sleep %s;done;", $pid, $pid, $sleep_time);
                $this->logger->debug(__METHOD__ . " Exec command: $cmd");
                exec($cmd, $output, $return_var);
                $killed = ($return_var === 0);
                if ($killed) {
                    $this->logger->debug(__METHOD__ . " Successfully killed process {$pid}");
                } else {
                    $this->logger->notice(__METHOD__ . " Cannot kill process {$pid}, $output");
                }
            } else {
                //@todo
                throw new \Exception("@todo Only wait=true is supported for now");
            }
        }
        return $killed;
    }
}