FM / src

/opt/cpanel/ea-wappspector/vendor/rector/rector/vendor/react/socket/src/

/opt/cpanel/ea-wappspector/vendor/rector/rector/vendor/react/socket/src

Name	Size	Mode	Actions
Connection.php	6093	0644	edit dl rm
ConnectionInterface.php	4461	0644	edit dl rm
Connector.php	7644	0644	edit dl rm
ConnectorInterface.php	2109	0644	edit dl rm
DnsConnector.php	4523	0644	edit dl rm
FdServer.php	7427	0644	edit dl rm
FixedUriConnector.php	1084	0644	edit dl rm
HappyEyeBallsConnectionBuilder.php	11659	0644	edit dl rm
HappyEyeBallsConnector.php	2905	0644	edit dl rm
LimitingServer.php	6649	0644	edit dl rm
SecureConnector.php	4918	0644	edit dl rm
SecureServer.php	7687	0644	edit dl rm
Server.php	3782	0644	edit dl rm
ServerInterface.php	5303	0644	edit dl rm
SocketServer.php	8841	0644	edit dl rm
StreamEncryption.php	5331	0644	edit dl rm
TcpConnector.php	6914	0644	edit dl rm
TcpServer.php	8884	0644	edit dl rm
TimeoutConnector.php	2893	0644	edit dl rm
UnixConnector.php	1690	0644	edit dl rm
UnixServer.php	5046	0644	edit dl rm

Edit: /opt/cpanel/ea-wappspector/vendor/rector/rector/vendor/react/socket/src/UnixConnector.php (1690B)

<?php

namespace RectorPrefix202411\React\Socket;

use RectorPrefix202411\React\EventLoop\Loop;
use RectorPrefix202411\React\EventLoop\LoopInterface;
use RectorPrefix202411\React\Promise;
use InvalidArgumentException;
use RuntimeException;
/**
 * Unix domain socket connector
 *
 * Unix domain sockets use atomic operations, so we can as well emulate
 * async behavior.
 */
final class UnixConnector implements ConnectorInterface
{
    private $loop;
    /**
     * @param ?LoopInterface $loop
     */
    public function __construct($loop = null)
    {
        if ($loop !== null && !$loop instanceof LoopInterface) {
            // manual type check to support legacy PHP < 7.1
            throw new \InvalidArgumentException('Argument #1 ($loop) expected null|React\\EventLoop\\LoopInterface');
        }
        $this->loop = $loop ?: Loop::get();
    }
    public function connect($path)
    {
        if (\strpos($path, '://') === \false) {
            $path = 'unix://' . $path;
        } elseif (\substr($path, 0, 7) !== 'unix://') {
            return Promise\reject(new \InvalidArgumentException('Given URI "' . $path . '" is invalid (EINVAL)', \defined('SOCKET_EINVAL') ? \SOCKET_EINVAL : (\defined('PCNTL_EINVAL') ? \PCNTL_EINVAL : 22)));
        }
        $resource = @\stream_socket_client($path, $errno, $errstr, 1.0);
        if (!$resource) {
            return Promise\reject(new \RuntimeException('Unable to connect to unix domain socket "' . $path . '": ' . $errstr . SocketServer::errconst($errno), $errno));
        }
        $connection = new Connection($resource, $this->loop);
        $connection->unix = \true;
        return Promise\resolve($connection);
    }
}

loop = $loop ?: Loop::get(); } public function connect($path) { if (\strpos($path, '://') === \false) { $path = 'unix://' . $path; } elseif (\substr($path, 0, 7) !== 'unix://') { return Promise\reject(new \InvalidArgumentException('Given URI "' . $path . '" is invalid (EINVAL)', \defined('SOCKET_EINVAL') ? \SOCKET_EINVAL : (\defined('PCNTL_EINVAL') ? \PCNTL_EINVAL : 22))); } $resource = @\stream_socket_client($path, $errno, $errstr, 1.0); if (!$resource) { return Promise\reject(new \RuntimeException('Unable to connect to unix domain socket "' . $path . '": ' . $errstr . SocketServer::errconst($errno), $errno)); } $connection = new Connection($resource, $this->loop); $connection->unix = \true; return Promise\resolve($connection); } }