Antidot\React\Child::fork()

Complexity

Conditions	5
Paths	5

Size

Total Lines	29
Code Lines	15

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	30

Importance

Changes	1
Bugs	0	Features	0

<?php
    public static function fork(
        int $numberOfWorkers,
        callable $asyncServer,
        int $numberOfFork = self::DEFAULT_NUMBER_OF_FORKS
    ): int {
        if (strtoupper(substr(PHP_OS, 0, 3)) === 'WIN') {
            throw new RuntimeException('The PHP pcntl extension is not available for Windows systems');
        }

        $pid = pcntl_fork();
        if (-1 === $pid) {
            throw new RuntimeException('Fork Failed');
        }

        if (0 === $pid) {
            $asyncServer();
            pcntl_waitpid($pid, $status);
            return $pid;
        }

        // @parent
        $numberOfWorkers--;
        ++$numberOfFork;
        if (self::DEFAULT_NUMBER_OF_FORKS < $numberOfWorkers) {
            self::fork($numberOfWorkers, $asyncServer, $numberOfFork);
        }

        pcntl_waitpid($pid, $status);
        return $pid;
    }