SwooleTW\Http\Server\PidManager

Complexity

Total Complexity

11

Size/Duplication

Total Lines	82
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	setPidFile()	0	5	1
A	__construct()	0	4	2
A	delete()	0	7	2
A	write()	0	11	3
A	file()	0	3	1
A	read()	0	12	2

<?php

namespace SwooleTW\Http\Server;

class PidManager
{
    protected $pidFile;

    public function __construct(string $pidFile = null)
    {
        $this->setPidFile(
            $pidFile ?: sys_get_temp_dir() . '/swoole.pid'
        );
    }

    /**
     * Set pid file path
     */
    public function setPidFile(string $pidFile): self
    {
        $this->pidFile = $pidFile;

        return $this;
    }

    /**
     * Write master pid and manager pid to pid file
     *
     * @throws \RuntimeException when $pidFile is not writable
     */
    public function write(int $masterPid, int $managerPid): void
    {
        if (! is_writable($this->pidFile)
            && ! is_writable(dirname($this->pidFile))
        ) {
            throw new \RuntimeException(
                sprintf('Pid file "%s" is not writable', $this->pidFile)
            );
        }

        file_put_contents($this->pidFile, $masterPid . ',' . $managerPid);
    }

    /**
     * Read master pid and manager pid from pid file
     *
     * @return string[] {
     *   @var string $masterPid
     *   @var string $managerPid
     * }
     */
    public function read(): array
    {
        $pids = [];

        if (is_readable($this->pidFile)) {
            $content = file_get_contents($this->pidFile);
            $pids = explode(',', $content);
        }

        return [
            'masterPid' => $pids[0] ?? null,
            'managerPid' => $pids[1] ?? null
        ];
    }

    /**
     * Gets pid file path.
     *
     * @return string
     */
    public function file()
    {
        return $this->pidFile;
    }

    /**
     * Delete pid file
     */
    public function delete(): bool
    {
        if (is_writable($this->pidFile)) {
            return unlink($this->pidFile);
        }

        return false;
    }
}