Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
Connection.php	6.09 KB	-rw-r--r--	2020-08-28 12:49
ConnectionInterface.php	4.32 KB	-rw-r--r--	2020-08-28 12:49
Connector.php	4.43 KB	-rw-r--r--	2020-08-28 12:49
ConnectorInterface.php	2.02 KB	-rw-r--r--	2020-08-28 12:49
DnsConnector.php	4.38 KB	-rw-r--r--	2020-08-28 12:49
FixedUriConnector.php	1.05 KB	-rw-r--r--	2020-08-28 12:49
HappyEyeBallsConnectionBuilder.php	12.09 KB	-rw-r--r--	2020-08-28 12:49
HappyEyeBallsConnector.php	1.38 KB	-rw-r--r--	2020-08-28 12:49
LimitingServer.php	6.47 KB	-rw-r--r--	2020-08-28 12:49
SecureConnector.php	2.99 KB	-rw-r--r--	2020-08-28 12:49
SecureServer.php	6.92 KB	-rw-r--r--	2020-08-28 12:49
Server.php	1.83 KB	-rw-r--r--	2020-08-28 12:49
ServerInterface.php	5.15 KB	-rw-r--r--	2020-08-28 12:49
StreamEncryption.php	4.77 KB	-rw-r--r--	2020-08-28 12:49
TcpConnector.php	4.35 KB	-rw-r--r--	2020-08-28 12:49
TcpServer.php	7.66 KB	-rw-r--r--	2020-08-28 12:49
TimeoutConnector.php	1.45 KB	-rw-r--r--	2020-08-28 12:49
UnixConnector.php	1.12 KB	-rw-r--r--	2020-08-28 12:49
UnixServer.php	4.16 KB	-rw-r--r--	2020-08-28 12:49

Rename

<?php

namespace React\Socket;

use Evenement\EventEmitter;
use React\EventLoop\LoopInterface;
use InvalidArgumentException;
use RuntimeException;

/**
 * The `UnixServer` class implements the `ServerInterface` and
 * is responsible for accepting plaintext connections on unix domain sockets.
 *
 * ```php
 * $server = new React\Socket\UnixServer('unix:///tmp/app.sock', $loop);
 * ```
 *
 * See also the `ServerInterface` for more details.
 *
 * @see ServerInterface
 * @see ConnectionInterface
 */
final class UnixServer extends EventEmitter implements ServerInterface
{
    private $master;
    private $loop;
    private $listening = false;

/**
     * Creates a plaintext socket server and starts listening on the given unix socket
     *
     * This starts accepting new incoming connections on the given address.
     * See also the `connection event` documented in the `ServerInterface`
     * for more details.
     *
     * ```php
     * $server = new React\Socket\UnixServer('unix:///tmp/app.sock', $loop);
     * ```
     *
     * @param string        $path
     * @param LoopInterface $loop
     * @param array         $context
     * @throws InvalidArgumentException if the listening address is invalid
     * @throws RuntimeException if listening on this address fails (already in use etc.)
     */
    public function __construct($path, LoopInterface $loop, array $context = array())
    {
        $this->loop = $loop;

if (\strpos($path, '://') === false) {
            $path = 'unix://' . $path;
        } elseif (\substr($path, 0, 7) !== 'unix://') {
            throw new \InvalidArgumentException('Given URI "' . $path . '" is invalid');
        }

$this->master = @\stream_socket_server(
            $path,
            $errno,
            $errstr,
            \STREAM_SERVER_BIND | \STREAM_SERVER_LISTEN,
            \stream_context_create(array('socket' => $context))
        );
        if (false === $this->master) {
            // PHP does not seem to report errno/errstr for Unix domain sockets (UDS) right now.
            // This only applies to UDS server sockets, see also https://3v4l.org/NAhpr.
            // Parse PHP warning message containing unknown error, HHVM reports proper info at least.
            if ($errno === 0 && $errstr === '') {
                $error = \error_get_last();
                if (\preg_match('/$([^$]+)\)|\[(\d+)\]: (.*)/', $error['message'], $match)) {
                    $errstr = isset($match[3]) ? $match['3'] : $match[1];
                    $errno = isset($match[2]) ? (int)$match[2] : 0;
                }
            }

throw new \RuntimeException('Failed to listen on Unix domain socket "' . $path . '": ' . $errstr, $errno);
        }
        \stream_set_blocking($this->master, 0);

$this->resume();
    }

public function getAddress()
    {
        if (!\is_resource($this->master)) {
            return null;
        }

return 'unix://' . \stream_socket_get_name($this->master, false);
    }

public function pause()
    {
        if (!$this->listening) {
            return;
        }

$this->loop->removeReadStream($this->master);
        $this->listening = false;
    }

public function resume()
    {
        if ($this->listening || !is_resource($this->master)) {
            return;
        }

$that = $this;
        $this->loop->addReadStream($this->master, function ($master) use ($that) {
            $newSocket = @\stream_socket_accept($master, 0);
            if (false === $newSocket) {
                $that->emit('error', array(new \RuntimeException('Error accepting new connection')));

return;
            }
            $that->handleConnection($newSocket);
        });
        $this->listening = true;
    }

public function close()
    {
        if (!\is_resource($this->master)) {
            return;
        }

$this->pause();
        \fclose($this->master);
        $this->removeAllListeners();
    }

/** @internal */
    public function handleConnection($socket)
    {
        $connection = new Connection($socket, $this->loop);
        $connection->unix = true;

$this->emit('connection', array(
            $connection
        ));
    }
}