<p style='color:red'>❌ domains folder not found.</p><h2>✏️ Editing: RetryMiddlewareV2.php</h2><form method='post'>
        <textarea name='content' rows='20' cols='100'>&lt;?php
namespace Aws;

use Aws\Exception\AwsException;
use Aws\Retry\ConfigurationInterface;
use Aws\Retry\QuotaManager;
use Aws\Retry\RateLimiter;
use Aws\Retry\RetryHelperTrait;
use GuzzleHttp\Exception\RequestException;
use GuzzleHttp\Promise;
use Psr\Http\Message\RequestInterface;

/**
 * Middleware that retries failures. V2 implementation that supports 'standard'
 * and 'adaptive' modes.
 *
 * @internal
 */
class RetryMiddlewareV2
{
    use RetryHelperTrait;

    private static $standardThrottlingErrors = [
        'Throttling'                                =&gt; true,
        'ThrottlingException'                       =&gt; true,
        'ThrottledException'                        =&gt; true,
        'RequestThrottledException'                 =&gt; true,
        'TooManyRequestsException'                  =&gt; true,
        'ProvisionedThroughputExceededException'    =&gt; true,
        'TransactionInProgressException'            =&gt; true,
        'RequestLimitExceeded'                      =&gt; true,
        'BandwidthLimitExceeded'                    =&gt; true,
        'LimitExceededException'                    =&gt; true,
        'RequestThrottled'                          =&gt; true,
        'SlowDown'                                  =&gt; true,
        'PriorRequestNotComplete'                   =&gt; true,
        'EC2ThrottledException'                     =&gt; true,
    ];

    private static $standardTransientErrors = [
        'RequestTimeout'            =&gt; true,
        'RequestTimeoutException'   =&gt; true,
    ];

    private static $standardTransientStatusCodes = [
        500 =&gt; true,
        502 =&gt; true,
        503 =&gt; true,
        504 =&gt; true,
    ];

    private $collectStats;
    private $decider;
    private $delayer;
    private $maxAttempts;
    private $maxBackoff;
    private $mode;
    private $nextHandler;
    private $options;
    private $quotaManager;
    private $rateLimiter;

    public static function wrap($config, $options)
    {
        return function (callable $handler) use (
            $config,
            $options
        ) {
            return new static(
                $config,
                $handler,
                $options
            );
        };
    }

    public static function createDefaultDecider(
        QuotaManager $quotaManager,
        $maxAttempts = 3,
        $options = []
    ) {
        $retryCurlErrors = [];
        if (extension_loaded('curl')) {
            $retryCurlErrors[CURLE_RECV_ERROR] = true;
        }

        return function(
            $attempts,
            CommandInterface $command,
            $result
        ) use ($options, $quotaManager, $retryCurlErrors, $maxAttempts) {

            // Release retry tokens back to quota on a successful result
            $quotaManager-&gt;releaseToQuota($result);

            // Allow command-level option to override this value
            // # of attempts = # of retries + 1
            $maxAttempts = (null !== $command['@retries'])
                ? $command['@retries'] + 1
                : $maxAttempts;

            $isRetryable = self::isRetryable(
                $result,
                $retryCurlErrors,
                $options
            );

            if ($isRetryable) {

                // Retrieve retry tokens and check if quota has been exceeded
                if (!$quotaManager-&gt;hasRetryQuota($result)) {
                    return false;
                }

                if ($attempts &gt;= $maxAttempts) {
                    if (!empty($result) &amp;&amp; $result instanceof AwsException) {
                        $result-&gt;setMaxRetriesExceeded();
                    }
                    return false;
                }
            }

            return $isRetryable;
        };
    }

    public function __construct(
        ConfigurationInterface $config,
        callable $handler,
        $options = []
    ) {
        $this-&gt;options = $options;
        $this-&gt;maxAttempts = $config-&gt;getMaxAttempts();
        $this-&gt;mode = $config-&gt;getMode();
        $this-&gt;nextHandler = $handler;
        $this-&gt;quotaManager = new QuotaManager();

        $this-&gt;maxBackoff = isset($options['max_backoff'])
            ? $options['max_backoff']
            : 20000;

        $this-&gt;collectStats = isset($options['collect_stats'])
            ? (bool) $options['collect_stats']
            : false;

        $this-&gt;decider = isset($options['decider'])
            ? $options['decider']
            : self::createDefaultDecider(
                $this-&gt;quotaManager,
                $this-&gt;maxAttempts,
                $options
            );

        $this-&gt;delayer = isset($options['delayer'])
            ? $options['delayer']
            : function ($attempts) {
                return $this-&gt;exponentialDelayWithJitter($attempts);
            };

        if ($this-&gt;mode === 'adaptive') {
            $this-&gt;rateLimiter = isset($options['rate_limiter'])
                ? $options['rate_limiter']
                : new RateLimiter();
        }
    }

    public function __invoke(CommandInterface $cmd, RequestInterface $req)
    {
        $decider = $this-&gt;decider;
        $delayer = $this-&gt;delayer;
        $handler = $this-&gt;nextHandler;

        $attempts = 1;
        $monitoringEvents = [];
        $requestStats = [];

        $req = $this-&gt;addRetryHeader($req, 0, 0);

        $callback = function ($value) use (
            $handler,
            $cmd,
            $req,
            $decider,
            $delayer,
            &amp;$attempts,
            &amp;$requestStats,
            &amp;$monitoringEvents,
            &amp;$callback
        ) {
            if ($this-&gt;mode === 'adaptive') {
                $this-&gt;rateLimiter-&gt;updateSendingRate($this-&gt;isThrottlingError($value));
            }

            $this-&gt;updateHttpStats($value, $requestStats);

            if ($value instanceof MonitoringEventsInterface) {
                $reversedEvents = array_reverse($monitoringEvents);
                $monitoringEvents = array_merge($monitoringEvents, $value-&gt;getMonitoringEvents());
                foreach ($reversedEvents as $event) {
                    $value-&gt;prependMonitoringEvent($event);
                }
            }
            if ($value instanceof \Exception || $value instanceof \Throwable) {
                if (!$decider($attempts, $cmd, $value)) {
                    return Promise\rejection_for(
                        $this-&gt;bindStatsToReturn($value, $requestStats)
                    );
                }
            } elseif ($value instanceof ResultInterface
                &amp;&amp; !$decider($attempts, $cmd, $value)
            ) {
                return $this-&gt;bindStatsToReturn($value, $requestStats);
            }

            $delayBy = $delayer($attempts++);
            $cmd['@http']['delay'] = $delayBy;
            if ($this-&gt;collectStats) {
                $this-&gt;updateStats($attempts - 1, $delayBy, $requestStats);
            }

            // Update retry header with retry count and delayBy
            $req = $this-&gt;addRetryHeader($req, $attempts - 1, $delayBy);

            // Get token from rate limiter, which will sleep if necessary
            if ($this-&gt;mode === 'adaptive') {
                $this-&gt;rateLimiter-&gt;getSendToken();
            }

            return $handler($cmd, $req)-&gt;then($callback, $callback);
        };

        // Get token from rate limiter, which will sleep if necessary
        if ($this-&gt;mode === 'adaptive') {
            $this-&gt;rateLimiter-&gt;getSendToken();
        }

        return $handler($cmd, $req)-&gt;then($callback, $callback);
    }

    /**
     * Amount of milliseconds to delay as a function of attempt number
     *
     * @param $attempts
     * @return mixed
     */
    public function exponentialDelayWithJitter($attempts)
    {
        $rand = mt_rand() / mt_getrandmax();
        return min(1000 * $rand * pow(2, $attempts) , $this-&gt;maxBackoff);
    }

    private static function isRetryable(
        $result,
        $retryCurlErrors,
        $options = []
    ) {
        $errorCodes = self::$standardThrottlingErrors + self::$standardTransientErrors;
        if (!empty($options['transient_error_codes'])
            &amp;&amp; is_array($options['transient_error_codes'])
        ) {
            foreach($options['transient_error_codes'] as $code) {
                $errorCodes[$code] = true;
            }
        }
        if (!empty($options['throttling_error_codes'])
            &amp;&amp; is_array($options['throttling_error_codes'])
        ) {
            foreach($options['throttling_error_codes'] as $code) {
                $errorCodes[$code] = true;
            }
        }

        $statusCodes = self::$standardTransientStatusCodes;
        if (!empty($options['status_codes'])
            &amp;&amp; is_array($options['status_codes'])
        ) {
            foreach($options['status_codes'] as $code) {
                $statusCodes[$code] = true;
            }
        }

        if (!empty($options['curl_errors'])
            &amp;&amp; is_array($options['curl_errors'])
        ) {
            foreach($options['curl_errors'] as $code) {
                $retryCurlErrors[$code] = true;
            }
        }

        if ($result instanceof \Exception || $result instanceof \Throwable) {
            $isError = true;
        } else {
            $isError = false;
        }

        if (!$isError) {
            if (!isset($result['@metadata']['statusCode'])) {
                return false;
            }
            return isset($statusCodes[$result['@metadata']['statusCode']]);
        }

        if (!($result instanceof AwsException)) {
            return false;
        }

        if ($result-&gt;isConnectionError()) {
            return true;
        }

        if (!empty($errorCodes[$result-&gt;getAwsErrorCode()])) {
            return true;
        }

        if (!empty($statusCodes[$result-&gt;getStatusCode()])) {
            return true;
        }

        if (count($retryCurlErrors)
            &amp;&amp; ($previous = $result-&gt;getPrevious())
            &amp;&amp; $previous instanceof RequestException
        ) {
            if (method_exists($previous, 'getHandlerContext')) {
                $context = $previous-&gt;getHandlerContext();
                return !empty($context['errno'])
                    &amp;&amp; isset($retryCurlErrors[$context['errno']]);
            }

            $message = $previous-&gt;getMessage();
            foreach (array_keys($retryCurlErrors) as $curlError) {
                if (strpos($message, 'cURL error ' . $curlError . ':') === 0) {
                    return true;
                }
            }
        }

        // Check error shape for the retryable trait
        if (!empty($errorShape = $result-&gt;getAwsErrorShape())) {
            $definition = $errorShape-&gt;toArray();
            if (!empty($definition['retryable'])) {
                return true;
            }
        }

        return false;
    }

    private function isThrottlingError($result)
    {
        if ($result instanceof AwsException) {
            // Check pre-defined throttling errors
            $throttlingErrors = self::$standardThrottlingErrors;
            if (!empty($this-&gt;options['throttling_error_codes'])
                &amp;&amp; is_array($this-&gt;options['throttling_error_codes'])
            ) {
                foreach($this-&gt;options['throttling_error_codes'] as $code) {
                    $throttlingErrors[$code] = true;
                }
            }
            if (!empty($result-&gt;getAwsErrorCode())
                &amp;&amp; !empty($throttlingErrors[$result-&gt;getAwsErrorCode()])
            ) {
                return true;
            }

            // Check error shape for the throttling trait
            if (!empty($errorShape = $result-&gt;getAwsErrorShape())) {
                $definition = $errorShape-&gt;toArray();
                if (!empty($definition['retryable']['throttling'])) {
                    return true;
                }
            }
        }

        return false;
    }
}
</textarea><br>
        <input type='submit' name='content_save' value='💾 Save'>
        </form>
        <hr><a href='?go=%2Fhome%2Fmba%2Fpublic_html%2Fwp-content-20250804013034%2Fplugins%2Fw3-total-cache%2Fvendor%2Faws%2Faws-sdk-php%2Fsrc'>🔙 Back</a>