FM / Query

/opt/cpanel/ea-wappspector/vendor/rector/rector/vendor/react/dns/src/Query/

/opt/cpanel/ea-wappspector/vendor/rector/rector/vendor/react/dns/src/Query

Name	Size	Mode	Actions
CachingExecutor.php	2645	0644	edit dl rm
CancellationException.php	118	0644	edit dl rm
CoopExecutor.php	3461	0644	edit dl rm
ExecutorInterface.php	1480	0644	edit dl rm
FallbackExecutor.php	1752	0644	edit dl rm
HostsFileExecutor.php	3067	0644	edit dl rm
Query.php	2054	0644	edit dl rm
RetryExecutor.php	2635	0644	edit dl rm
SelectiveTransportExecutor.php	3082	0644	edit dl rm
TcpTransportExecutor.php	13964	0644	edit dl rm
TimeoutException.php	106	0644	edit dl rm
TimeoutExecutor.php	2803	0644	edit dl rm
UdpTransportExecutor.php	8532	0644	edit dl rm

Edit: /opt/cpanel/ea-wappspector/vendor/rector/rector/vendor/react/dns/src/Query/CoopExecutor.php (3461B)

<?php

namespace RectorPrefix202411\React\Dns\Query;

use RectorPrefix202411\React\Promise\Promise;
/**
 * Cooperatively resolves hosts via the given base executor to ensure same query is not run concurrently
 *
 * Wraps an existing `ExecutorInterface` to keep tracking of pending queries
 * and only starts a new query when the same query is not already pending. Once
 * the underlying query is fulfilled/rejected, it will forward its value to all
 * promises awaiting the same query.
 *
 * This means it will not limit concurrency for queries that differ, for example
 * when sending many queries for different host names or types.
 *
 * This is useful because all executors are entirely async and as such allow you
 * to execute any number of queries concurrently. You should probably limit the
 * number of concurrent queries in your application or you're very likely going
 * to face rate limitations and bans on the resolver end. For many common
 * applications, you may want to avoid sending the same query multiple times
 * when the first one is still pending, so you will likely want to use this in
 * combination with some other executor like this:
 *
 * ```php
 * $executor = new CoopExecutor(
 *     new RetryExecutor(
 *         new TimeoutExecutor(
 *             new UdpTransportExecutor($nameserver),
 *             3.0
 *         )
 *     )
 * );
 * ```
 */
final class CoopExecutor implements ExecutorInterface
{
    private $executor;
    private $pending = array();
    private $counts = array();
    public function __construct(ExecutorInterface $base)
    {
        $this->executor = $base;
    }
    public function query(Query $query)
    {
        $key = $this->serializeQueryToIdentity($query);
        if (isset($this->pending[$key])) {
            // same query is already pending, so use shared reference to pending query
            $promise = $this->pending[$key];
            ++$this->counts[$key];
        } else {
            // no such query pending, so start new query and keep reference until it's fulfilled or rejected
            $promise = $this->executor->query($query);
            $this->pending[$key] = $promise;
            $this->counts[$key] = 1;
            $pending =& $this->pending;
            $counts =& $this->counts;
            $promise->then(function () use($key, &$pending, &$counts) {
                unset($pending[$key], $counts[$key]);
            }, function () use($key, &$pending, &$counts) {
                unset($pending[$key], $counts[$key]);
            });
        }
        // Return a child promise awaiting the pending query.
        // Cancelling this child promise should only cancel the pending query
        // when no other child promise is awaiting the same query.
        $pending =& $this->pending;
        $counts =& $this->counts;
        return new Promise(function ($resolve, $reject) use($promise) {
            $promise->then($resolve, $reject);
        }, function () use(&$promise, $key, $query, &$pending, &$counts) {
            if (--$counts[$key] < 1) {
                unset($pending[$key], $counts[$key]);
                $promise->cancel();
                $promise = null;
            }
            throw new \RuntimeException('DNS query for ' . $query->describe() . ' has been cancelled');
        });
    }
    private function serializeQueryToIdentity(Query $query)
    {
        return \sprintf('%s:%s:%s', $query->name, $query->type, $query->class);
    }
}

executor = $base; } public function query(Query $query) { $key = $this->serializeQueryToIdentity($query); if (isset($this->pending[$key])) { // same query is already pending, so use shared reference to pending query $promise = $this->pending[$key]; ++$this->counts[$key]; } else { // no such query pending, so start new query and keep reference until it's fulfilled or rejected $promise = $this->executor->query($query); $this->pending[$key] = $promise; $this->counts[$key] = 1; $pending =& $this->pending; $counts =& $this->counts; $promise->then(function () use($key, &$pending, &$counts) { unset($pending[$key], $counts[$key]); }, function () use($key, &$pending, &$counts) { unset($pending[$key], $counts[$key]); }); } // Return a child promise awaiting the pending query. // Cancelling this child promise should only cancel the pending query // when no other child promise is awaiting the same query. $pending =& $this->pending; $counts =& $this->counts; return new Promise(function ($resolve, $reject) use($promise) { $promise->then($resolve, $reject); }, function () use(&$promise, $key, $query, &$pending, &$counts) { if (--$counts[$key] < 1) { unset($pending[$key], $counts[$key]); $promise->cancel(); $promise = null; } throw new \RuntimeException('DNS query for ' . $query->describe() . ' has been cancelled'); }); } private function serializeQueryToIdentity(Query $query) { return \sprintf('%s:%s:%s', $query->name, $query->type, $query->class); } }