Spatie\Async\Runtime

Complexity

Total Complexity

13

Size/Duplication

Total Lines	91
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	maximumExecutionTime()	0	6	1
A	start()	0	21	2
A	handleFinishedProcess()	0	14	2
A	handleRunningProcess()	0	14	4
A	executeChildProcess()	0	12	2
A	readProcessOutputFromSocket()	0	14	2

<?php

namespace Spatie\Async;

use Exception;
use Spatie\Async\Output\ErrorProcessOutput;
use Spatie\Async\Output\ProcessOutput;
use Throwable;

class Runtime
{
    protected $maximumExecutionTime = 300;

    public function maximumExecutionTime(int $maximumExecutionTime): self
    {
        $this->maximumExecutionTime = $maximumExecutionTime;

        return $this;
    }

    public function start(Process $process): Process
    {
        socket_create_pair(AF_UNIX, SOCK_STREAM, 0, $sockets);

        [$parentSocket, $childSocket] = $sockets;

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

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

        if (($pid = pcntl_fork()) == 0) {
            socket_close($childSocket);

            $this->executeChildProcess($parentSocket, $process);

            exit;
        }

        socket_close($parentSocket);

        return $process
            ->setPid($pid)
            ->setSocket($childSocket)
            ->setStartTime(time());
    }

    public function handleFinishedProcess(Process $process): bool
    {
        $output = $this->readProcessOutputFromSocket($process);

        if (!$output->isSuccess()) {
            $process->triggerError($output->payload());

            return false;
        }

        $process->triggerSuccess($output->payload());

        return true;
    }

    public function handleRunningProcess(Process $process, $status): bool
    {
        if ($process->startTime() + $this->maximumExecutionTime < time() || pcntl_wifstopped($status)) {
            if (! posix_kill($process->pid(), SIGKILL)) {
                throw new Exception("Failed to kill {$process->pid()}: ".posix_strerror(posix_get_last_error()));
            }

            $process->triggerTimeout();

            return false;
        }

        return true;
    }

    protected function executeChildProcess($parentSocket, Process $process): void
    {
        try {
            $output = ProcessOutput::create($process->execute())->setSuccess();
        } catch (Throwable $e) {
            $output = ErrorProcessOutput::create($e);
        }

        socket_write($parentSocket, $output->serialize());

        socket_close($parentSocket);
    }

    protected function readProcessOutputFromSocket(Process $process): ProcessOutput
    {
        $rawOutput = '';

        while ($buffer = socket_read($process->socket(), 1024)) {
            $rawOutput .= $buffer;
        }

        $output = unserialize($rawOutput);

        socket_close($process->socket());

        return $output;
    }
}