fileUnableToCreateTemporaryFile../../coders/url.c`%s': %swb:ftphttpNoDataReturned`%s'HTTPURLHTTPSFTPFILEUniform Resource Locator (http://)Uniform Resource Locator (https://)Uniform Resource Locator (ftp://)Uniform Resource Locator (file://)ReadURLImage;D`((LxzRx $ FJ w?:*3$"D\t8!|TFBB B(A0A8G L@L`I`u`JaSaOaU`) 8D0A(B BBBF `]aV`A`(T!EHK FA4X<Ho>д>  <==o>>>  >>Ȫ> oX oo>o)>6>ode) { $errorCodes[$code] = true; } } $statusCodes = self::$retryStatusCodes; if (!empty($extraConfig['status_codes']) && is_array($extraConfig['status_codes']) ) { foreach($extraConfig['status_codes'] as $code) { $statusCodes[$code] = true; } } if (!empty($extraConfig['curl_errors']) && is_array($extraConfig['curl_errors']) ) { foreach($extraConfig['curl_errors'] as $code) { $retryCurlErrors[$code] = true; } } if (!$error) { if (!isset($result['@metadata']['statusCode'])) { return false; } return isset($statusCodes[$result['@metadata']['statusCode']]); } if (!($error instanceof AwsException)) { return false; } if ($error->isConnectionError()) { return true; } if (isset($errorCodes[$error->getAwsErrorCode()])) { return true; } if (isset($statusCodes[$error->getStatusCode()])) { return true; } if (count($retryCurlErrors) && ($previous = $error->getPrevious()) && $previous instanceof RequestException ) { if (method_exists($previous, 'getHandlerContext')) { $context = $previous->getHandlerContext(); return !empty($context['errno']) && isset($retryCurlErrors[$context['errno']]); } $message = $previous->getMessage(); foreach (array_keys($retryCurlErrors) as $curlError) { if (strpos($message, 'cURL error ' . $curlError . ':') === 0) { return true; } } } return false; } /** * Delay function that calculates an exponential delay. * * Exponential backoff with jitter, 100ms base, 20 sec ceiling * * @param $retries - The number of retries that have already been attempted * * @return int * * @link https://aws.amazon.com/blogs/architecture/exponential-backoff-and-jitter/ */ public static function exponentialDelay($retries) { return mt_rand(0, (int) min(20000, (int) pow(2, $retries) * 100)); } /** * @param CommandInterface $command * @param RequestInterface $request * * @return PromiseInterface */ public function __invoke( CommandInterface $command, RequestInterface $request = null ) { $retries = 0; $requestStats = []; $monitoringEvents = []; $handler = $this->nextHandler; $decider = $this->decider; $delay = $this->delay; $request = $this->addRetryHeader($request, 0, 0); $g = function ($value) use ( $handler, $decider, $delay, $command, $request, &$retries, &$requestStats, &$monitoringEvents, &$g ) { $this->updateHttpStats($value, $requestStats); if ($value instanceof MonitoringEventsInterface) { $reversedEvents = array_reverse($monitoringEvents); $monitoringEvents = array_merge($monitoringEvents, $value->getMonitoringEvents()); foreach ($reversedEvents as $event) { $value->prependMonitoringEvent($event); } } if ($value instanceof \Exception || $value instanceof \Throwable) { if (!$decider($retries, $command, $request, null, $value)) { return Promise\Create::rejectionFor( $this->bindStatsToReturn($value, $requestStats) ); } } elseif ($value instanceof ResultInterface && !$decider($retries, $command, $request, $value, null) ) { return $this->bindStatsToReturn($value, $requestStats); } // Delay fn is called with 0, 1, ... so increment after the call. $delayBy = $delay($retries++); $command['@http']['delay'] = $delayBy; if ($this->collectStats) { $this->updateStats($retries, $delayBy, $requestStats); } // Update retry header with retry count and delayBy $request = $this->addRetryHeader($request, $retries, $delayBy); return $handler($command, $request)->then($g, $g); }; return $handler($command, $request)->then($g, $g); } }