blob: ede2b9604181f67fa63598da3cd81d4aafa69751 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
|
<?php
/**
* Copyright 2010-2013 Amazon.com, Inc. or its affiliates. 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.
* A copy of the License is located at
*
* http://aws.amazon.com/apache2.0
*
* or in the "license" file accompanying this file. This file 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 Aws\S3;
use Guzzle\Http\Exception\HttpException;
use Guzzle\Http\Message\RequestInterface;
use Guzzle\Http\Message\EntityEnclosingRequestInterface;
use Guzzle\Http\Message\Response;
use Guzzle\Plugin\Backoff\BackoffStrategyInterface;
use Guzzle\Plugin\Backoff\AbstractBackoffStrategy;
/**
* Custom S3 exponential backoff checking use to retry 400 responses containing the following reason phrase:
* "Your socket connection to the server was not read from or written to within the timeout period.".
* This error has been reported as intermittent/random, and in most cases, seems to occur during the middle of a
* transfer. This plugin will attempt to retry these failed requests, and if using a local file, will clear the
* stat cache of the file and set a new content-length header on the upload.
*/
class SocketTimeoutChecker extends AbstractBackoffStrategy
{
const ERR = 'Your socket connection to the server was not read from or written to within the timeout period';
/**
* {@inheridoc}
*/
public function __construct(BackoffStrategyInterface $next = null)
{
if ($next) {
$this->setNext($next);
}
}
/**
* {@inheridoc}
*/
public function makesDecision()
{
return true;
}
/**
* {@inheritdoc}
*/
protected function getDelay(
$retries,
RequestInterface $request,
Response $response = null,
HttpException $e = null
) {
if ($response
&& $response->getStatusCode() == 400
&& strpos($response->getBody(), self::ERR)
) {
return true;
}
}
}
|
