ACIL FM

Nama	Ukuran	Aksi
Connection.php	5.95 MB	View DL Edit
ConnectionInterface.php	4.36 MB	View DL Edit
Connector.php	7.46 MB	View DL Edit
ConnectorInterface.php	2.06 MB	View DL Edit
DnsConnector.php	4.42 MB	View DL Edit
FdServer.php	7.25 MB	View DL Edit
FixedUriConnector.php	1.06 MB	View DL Edit
HappyEyeBallsConnectionBuilder.php	11.39 MB	View DL Edit
HappyEyeBallsConnector.php	2.84 MB	View DL Edit
LimitingServer.php	6.49 MB	View DL Edit
SecureConnector.php	4.8 MB	View DL Edit
SecureServer.php	7.51 MB	View DL Edit
Server.php	3.69 MB	View DL Edit
ServerInterface.php	5.18 MB	View DL Edit
SocketServer.php	8.63 MB	View DL Edit
StreamEncryption.php	5.21 MB	View DL Edit
TcpConnector.php	6.75 MB	View DL Edit
TcpServer.php	8.68 MB	View DL Edit
TimeoutConnector.php	2.83 MB	View DL Edit
UnixConnector.php	1.65 MB	View DL Edit
UnixServer.php	4.93 MB	View DL Edit

Edit file: /opt/cpanel/ea-wappspector/vendor/rector/rector/vendor/react/socket/src/TimeoutConnector.php

<?php

namespace RectorPrefix202411\React\Socket;

use RectorPrefix202411\React\EventLoop\Loop;
use RectorPrefix202411\React\EventLoop\LoopInterface;
use RectorPrefix202411\React\Promise\Promise;
final class TimeoutConnector implements ConnectorInterface
{
    private $connector;
    private $timeout;
    private $loop;
    /**
     * @param ConnectorInterface $connector
     * @param float $timeout
     * @param ?LoopInterface $loop
     */
    public function __construct(ConnectorInterface $connector, $timeout, $loop = null)
    {
        if ($loop !== null && !$loop instanceof LoopInterface) {
            // manual type check to support legacy PHP < 7.1
            throw new \InvalidArgumentException('Argument #3 ($loop) expected null|React\\EventLoop\\LoopInterface');
        }
        $this->connector = $connector;
        $this->timeout = $timeout;
        $this->loop = $loop ?: Loop::get();
    }
    public function connect($uri)
    {
        $promise = $this->connector->connect($uri);
        $loop = $this->loop;
        $time = $this->timeout;
        return new Promise(function ($resolve, $reject) use($loop, $time, $promise, $uri) {
            $timer = null;
            $promise = $promise->then(function ($v) use(&$timer, $loop, $resolve) {
                if ($timer) {
                    $loop->cancelTimer($timer);
                }
                $timer = \false;
                $resolve($v);
            }, function ($v) use(&$timer, $loop, $reject) {
                if ($timer) {
                    $loop->cancelTimer($timer);
                }
                $timer = \false;
                $reject($v);
            });
            // promise already resolved => no need to start timer
            if ($timer === \false) {
                return;
            }
            // start timeout timer which will cancel the pending promise
            $timer = $loop->addTimer($time, function () use($time, &$promise, $reject, $uri) {
                $reject(new \RuntimeException('Connection to ' . $uri . ' timed out after ' . $time . ' seconds (ETIMEDOUT)', \defined('SOCKET_ETIMEDOUT') ? \SOCKET_ETIMEDOUT : 110));
                // Cancel pending connection to clean up any underlying resources and references.
                // Avoid garbage references in call stack by passing pending promise by reference.
                \assert(\method_exists($promise, 'cancel'));
                $promise->cancel();
                $promise = null;
            });
        }, function () use(&$promise) {
            // Cancelling this promise will cancel the pending connection, thus triggering the rejection logic above.
            // Avoid garbage references in call stack by passing pending promise by reference.
            \assert(\method_exists($promise, 'cancel'));
            $promise->cancel();
            $promise = null;
        });
    }
}

Batal