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/Connection.php (6093B)

<?php

namespace RectorPrefix202411\React\Socket;

use RectorPrefix202411\Evenement\EventEmitter;
use RectorPrefix202411\React\EventLoop\LoopInterface;
use RectorPrefix202411\React\Stream\DuplexResourceStream;
use RectorPrefix202411\React\Stream\Util;
use RectorPrefix202411\React\Stream\WritableResourceStream;
use RectorPrefix202411\React\Stream\WritableStreamInterface;
/**
 * The actual connection implementation for ConnectionInterface
 *
 * This class should only be used internally, see ConnectionInterface instead.
 *
 * @see ConnectionInterface
 * @internal
 */
class Connection extends EventEmitter implements ConnectionInterface
{
    /**
     * Internal flag whether this is a Unix domain socket (UDS) connection
     *
     * @internal
     */
    public $unix = \false;
    /**
     * Internal flag whether encryption has been enabled on this connection
     *
     * Mostly used by internal StreamEncryption so that connection returns
     * `tls://` scheme for encrypted connections instead of `tcp://`.
     *
     * @internal
     */
    public $encryptionEnabled = \false;
    /** @internal */
    public $stream;
    private $input;
    public function __construct($resource, LoopInterface $loop)
    {
        // PHP < 7.3.3 (and PHP < 7.2.15) suffers from a bug where feof() might
        // block with 100% CPU usage on fragmented TLS records.
        // We try to work around this by always consuming the complete receive
        // buffer at once to avoid stale data in TLS buffers. This is known to
        // work around high CPU usage for well-behaving peers, but this may
        // cause very large data chunks for high throughput scenarios. The buggy
        // behavior can still be triggered due to network I/O buffers or
        // malicious peers on affected versions, upgrading is highly recommended.
        // @link https://bugs.php.net/bug.php?id=77390
        $clearCompleteBuffer = \PHP_VERSION_ID < 70215 || \PHP_VERSION_ID >= 70300 && \PHP_VERSION_ID < 70303;
        // PHP < 7.1.4 (and PHP < 7.0.18) suffers from a bug when writing big
        // chunks of data over TLS streams at once.
        // We try to work around this by limiting the write chunk size to 8192
        // bytes for older PHP versions only.
        // This is only a work-around and has a noticable performance penalty on
        // affected versions. Please update your PHP version.
        // This applies to all streams because TLS may be enabled later on.
        // See https://github.com/reactphp/socket/issues/105
        $limitWriteChunks = \PHP_VERSION_ID < 70018 || \PHP_VERSION_ID >= 70100 && \PHP_VERSION_ID < 70104;
        $this->input = new DuplexResourceStream($resource, $loop, $clearCompleteBuffer ? -1 : null, new WritableResourceStream($resource, $loop, null, $limitWriteChunks ? 8192 : null));
        $this->stream = $resource;
        Util::forwardEvents($this->input, $this, array('data', 'end', 'error', 'close', 'pipe', 'drain'));
        $this->input->on('close', array($this, 'close'));
    }
    public function isReadable()
    {
        return $this->input->isReadable();
    }
    public function isWritable()
    {
        return $this->input->isWritable();
    }
    public function pause()
    {
        $this->input->pause();
    }
    public function resume()
    {
        $this->input->resume();
    }
    public function pipe(WritableStreamInterface $dest, array $options = array())
    {
        return $this->input->pipe($dest, $options);
    }
    public function write($data)
    {
        return $this->input->write($data);
    }
    public function end($data = null)
    {
        $this->input->end($data);
    }
    public function close()
    {
        $this->input->close();
        $this->handleClose();
        $this->removeAllListeners();
    }
    public function handleClose()
    {
        if (!\is_resource($this->stream)) {
            return;
        }
        // Try to cleanly shut down socket and ignore any errors in case other
        // side already closed. Underlying Stream implementation will take care
        // of closing stream resource, so we otherwise keep this open here.
        @\stream_socket_shutdown($this->stream, \STREAM_SHUT_RDWR);
    }
    public function getRemoteAddress()
    {
        if (!\is_resource($this->stream)) {
            return null;
        }
        return $this->parseAddress(\stream_socket_get_name($this->stream, \true));
    }
    public function getLocalAddress()
    {
        if (!\is_resource($this->stream)) {
            return null;
        }
        return $this->parseAddress(\stream_socket_get_name($this->stream, \false));
    }
    private function parseAddress($address)
    {
        if ($address === \false) {
            return null;
        }
        if ($this->unix) {
            // remove trailing colon from address for HHVM < 3.19: https://3v4l.org/5C1lo
            // note that technically ":" is a valid address, so keep this in place otherwise
            if (\substr($address, -1) === ':' && \defined('HHVM_VERSION_ID') && \HHVM_VERSION_ID < 31900) {
                $address = (string) \substr($address, 0, -1);
                // @codeCoverageIgnore
            }
            // work around unknown addresses should return null value: https://3v4l.org/5C1lo and https://bugs.php.net/bug.php?id=74556
            // PHP uses "\0" string and HHVM uses empty string (colon removed above)
            if ($address === '' || $address[0] === "\x00") {
                return null;
                // @codeCoverageIgnore
            }
            return 'unix://' . $address;
        }
        // check if this is an IPv6 address which includes multiple colons but no square brackets
        $pos = \strrpos($address, ':');
        if ($pos !== \false && \strpos($address, ':') < $pos && \substr($address, 0, 1) !== '[') {
            $address = '[' . \substr($address, 0, $pos) . ']:' . \substr($address, $pos + 1);
            // @codeCoverageIgnore
        }
        return ($this->encryptionEnabled ? 'tls' : 'tcp') . '://' . $address;
    }
}

cmd: