<?php /** * Copyright 2016 Google Inc. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ namespace Google\Cloud\Core; /** * Exponential backoff implementation. */ class ExponentialBackoff { const MAX_DELAY_MICROSECONDS = 60000000; /** * @var int */ private $retries; /** * @var callable|null */ private $retryFunction; /** * @var callable */ private $delayFunction; /** * @var callable|null */ private $calcDelayFunction; /** * @param int $retries [optional] Number of retries for a failed request. * @param callable $retryFunction [optional] returns bool for whether or not to retry */ public function __construct($retries = null, callable $retryFunction = null) { $this->retries = $retries !== null ? (int) $retries : 3; $this->retryFunction = $retryFunction; // @todo revisit this approach // @codeCoverageIgnoreStart $this->delayFunction = static function ($delay) { usleep($delay); }; // @codeCoverageIgnoreEnd } /** * Executes the retry process. * * @param callable $function * @param array $arguments [optional] * @return mixed * @throws \Exception The last exception caught while retrying. */ public function execute(callable $function, array $arguments = []) { $delayFunction = $this->delayFunction; $calcDelayFunction = $this->calcDelayFunction ?: [$this, 'calculateDelay']; $retryAttempt = 0; $exception = null; while (true) { try { return call_user_func_array($function, $arguments); } catch (\Exception $exception) { if ($this->retryFunction) { if (!call_user_func($this->retryFunction, $exception, $retryAttempt)) { throw $exception; } } if ($retryAttempt >= $this->retries) { break; } $delayFunction($calcDelayFunction($retryAttempt)); $retryAttempt++; } } throw $exception; } /** * If not set, defaults to using `usleep`. * * @param callable $delayFunction * @return void */ public function setDelayFunction(callable $delayFunction) { $this->delayFunction = $delayFunction; } /** * If not set, defaults to using * {@see Google\Cloud\Core\ExponentialBackoff::calculateDelay()}. * * @param callable $calcDelayFunction * @return void */ public function setCalcDelayFunction(callable $calcDelayFunction) { $this->calcDelayFunction = $calcDelayFunction; } /** * Calculates exponential delay. * * @param int $attempt The attempt number used to calculate the delay. * @return int */ public static function calculateDelay($attempt) { return min( mt_rand(0, 1000000) + (pow(2, $attempt) * 1000000), self::MAX_DELAY_MICROSECONDS ); } }
Name | Type | Size | Permission | Actions |
---|---|---|---|---|
Batch | Folder | 0755 |
|
|
Compute | Folder | 0755 |
|
|
Exception | Folder | 0755 |
|
|
Iam | Folder | 0755 |
|
|
Iterator | Folder | 0755 |
|
|
Lock | Folder | 0755 |
|
|
Logger | Folder | 0755 |
|
|
LongRunning | Folder | 0755 |
|
|
Report | Folder | 0755 |
|
|
Testing | Folder | 0755 |
|
|
Upload | Folder | 0755 |
|
|
AnonymousCredentials.php | File | 2.4 KB | 0644 |
|
ArrayTrait.php | File | 3.45 KB | 0644 |
|
Blob.php | File | 2.02 KB | 0644 |
|
CallTrait.php | File | 1.08 KB | 0644 |
|
ClientTrait.php | File | 7.93 KB | 0644 |
|
ConcurrencyControlTrait.php | File | 1.35 KB | 0644 |
|
DebugInfoTrait.php | File | 1.28 KB | 0644 |
|
Duration.php | File | 2.1 KB | 0644 |
|
EmulatorTrait.php | File | 2.65 KB | 0644 |
|
ExponentialBackoff.php | File | 3.61 KB | 0644 |
|
GeoPoint.php | File | 5.98 KB | 0644 |
|
GrpcRequestWrapper.php | File | 8.19 KB | 0644 |
|
GrpcTrait.php | File | 8.14 KB | 0644 |
|
InsecureCredentialsWrapper.php | File | 923 B | 0644 |
|
Int64.php | File | 1.7 KB | 0644 |
|
JsonTrait.php | File | 2.15 KB | 0644 |
|
PhpArray.php | File | 7.21 KB | 0644 |
|
RequestBuilder.php | File | 4.73 KB | 0644 |
|
RequestWrapper.php | File | 16.06 KB | 0644 |
|
RequestWrapperTrait.php | File | 7.08 KB | 0644 |
|
RestTrait.php | File | 3.54 KB | 0644 |
|
Retry.php | File | 3.28 KB | 0644 |
|
RetryDeciderTrait.php | File | 2.79 KB | 0644 |
|
ServiceBuilder.php | File | 16.58 KB | 0644 |
|
SysvTrait.php | File | 1.81 KB | 0644 |
|
TimeTrait.php | File | 4.38 KB | 0644 |
|
Timestamp.php | File | 3.95 KB | 0644 |
|
UriTrait.php | File | 1.78 KB | 0644 |
|
ValidateTrait.php | File | 2.26 KB | 0644 |
|
ValueMapperTrait.php | File | 1.74 KB | 0644 |
|
WhitelistTrait.php | File | 1.13 KB | 0644 |
|