Comodojo\Daemon\Utils\PosixSignals

Complexity

Total Complexity

25

Size/Duplication

Total Lines	140
Duplicated Lines	12.86 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

36.17%

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
B	__construct()	0	10	6
A	sigNo()	0	7	2
A	sigName()	0	5	2
A	on()	0	11	3
A	any()	0	7	1
A	call()	0	16	4
A	setDefault()	0	15	3
A	mask()	9	9	2
A	unmask()	9	9	2

<?php namespace Comodojo\Daemon\Utils;

use \Comodojo\Foundation\DataAccess\IteratorTrait;
use \Comodojo\Foundation\DataAccess\CountableTrait;
use \Comodojo\Foundation\DataAccess\ArrayAccessTrait;
use \Iterator;
use \Countable;
use \ArrayAccess;

/**
 * @package     Comodojo Daemon
 * @author      Marco Giovinazzi <marco.giovinazzi@comodojo.org>
 * @license     MIT
 *
 * LICENSE:
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 * THE SOFTWARE.
 */

class PosixSignals implements Iterator, Countable, ArrayAccess {

    use IteratorTrait;
    use CountableTrait;
    use ArrayAccessTrait;

    protected $data = [
        SIGHUP => 'SIGHUP',
        SIGINT => 'SIGINT',
        SIGQUIT => 'SIGQUIT',
        SIGILL => 'SIGILL',
        SIGTRAP => 'SIGTRAP',
        SIGABRT => 'SIGABRT',
        SIGIOT => 'SIGIOT',
        SIGBUS => 'SIGBUS',
        SIGFPE => 'SIGFPE',
        // Noone can catch SIGKILL!
        // SIGKILL => 'SIGKILL',

43% of this comment could be valid code. Did you maybe forget this after debugging?

        SIGUSR1 => 'SIGUSR1',
        SIGSEGV => 'SIGSEGV',
        SIGUSR2 => 'SIGUSR2',
        SIGPIPE => 'SIGPIPE',
        SIGALRM => 'SIGALRM',
        SIGTERM => 'SIGTERM',
        SIGCHLD => 'SIGCHLD',
        SIGCONT => 'SIGCONT',
        SIGTSTP => 'SIGTSTP',
        SIGTTIN => 'SIGTTIN',
        SIGTTOU => 'SIGTTOU',
        SIGURG => 'SIGURG',
        SIGXCPU => 'SIGXCPU',
        SIGXFSZ => 'SIGXFSZ',
        SIGVTALRM => 'SIGVTALRM',
        SIGPROF => 'SIGPROF',
        SIGWINCH => 'SIGWINCH',
        SIGSYS => 'SIGSYS',
        SIGBABY => 'SIGBABY'
    ];

    protected $pointer = [];

    public function __construct() {

        if ( defined('SIGPOLL') ) $this->data[SIGPOLL] = 'SIGPOLL';
        if ( defined('SIGPWR') ) $this->data[SIGPWR] = 'SIGPWR';
        if ( defined('SIGSTKFLT') ) $this->data[SIGSTKFLT] = 'SIGSTKFLT';
        // if ( defined('SIGSTOP') ) $this->data[SIGSTOP] = 'SIGSTOP';

53% of this comment could be valid code. Did you maybe forget this after debugging?

        if ( defined('SIGIO') ) $this->data[SIGIO] = 'SIGIO';
        if ( defined('SIGCLD') ) $this->data[SIGCLD] = 'SIGCLD';

    }

    public function sigNo($signame) {

        $reverse_signals = array_flip($this->data);

        return array_key_exists($signame, $reverse_signals) ? $reverse_signals[$signame] : null;

    }

    public function sigName($signo) {

        return array_key_exists($signo, $this->data) ? $this->data[$signo] : null;

    }

    public function on(...$signals) {

        foreach ($signals as $signal) {
            if ( !isset($this[$signal]) ) throw new Exception("Signal $signal not supported");
        }

        $this->pointer = $signals;

        return $this;

    }

    public function any() {

        $this->pointer = [];

        return $this;

    }

    public function call($callable) {

        if ( empty($this->pointer) ) {
            $result = [];
            foreach ($this as $signo => $signame) {
                $result[] = $re = pcntl_signal($signo, $callable);
                if (!$re) echo "\n>>>Signal $signo (".$this->sigName($signo).") failed\n";
            }
            return !in_array(false, $result);
        }

        return array_map(function($signal) {
            return pcntl_signal($signal, $callable);

The variable $callable does not exist. Did you forget to declare it?

        }, $this->pointer);

    }

    public function setDefault() {

        if ( empty($this->pointer) ) {
            $result = [];
            foreach ($this as $signo => $signame) {
                $result[] = pcntl_signal($signo, SIG_DFL);
            }
            return !in_array(false, $result);
        }

        return array_map(function($signal) {
            return pcntl_signal($signal, SIG_DFL);
        }, $this->pointer);

    }

    public function mask() {

This method seems to be duplicated in your project.

        if ( empty($this->pointer) ) {
            return pcntl_sigprocmask(SIG_SETMASK, (array) $this);
        }

        return pcntl_sigprocmask(SIG_BLOCK, $this->pointer);

    }

    public function unmask() {

This method seems to be duplicated in your project.

        if ( empty($this->pointer) ) {
            return pcntl_sigprocmask(SIG_SETMASK, []);
        }

        return pcntl_sigprocmask(SIG_UNBLOCK, $this->pointer);

    }

}