-
Notifications
You must be signed in to change notification settings - Fork 494
/
HttpTimeoutPolicyDefault.cs
53 lines (44 loc) · 2.17 KB
/
HttpTimeoutPolicyDefault.cs
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
//------------------------------------------------------------
// Copyright (c) Microsoft Corporation. All rights reserved.
//------------------------------------------------------------
namespace Microsoft.Azure.Cosmos
{
using System;
using System.Collections.Generic;
using System.Net.Http;
using System.Text;
internal sealed class HttpTimeoutPolicyDefault : HttpTimeoutPolicy
{
public static readonly HttpTimeoutPolicy Instance = new HttpTimeoutPolicyDefault(false);
public static readonly HttpTimeoutPolicy InstanceShouldThrow503OnTimeout = new HttpTimeoutPolicyDefault(true);
public bool shouldThrow503OnTimeout;
private static readonly string Name = nameof(HttpTimeoutPolicyDefault);
private HttpTimeoutPolicyDefault(bool shouldThrow503OnTimeout)
{
this.shouldThrow503OnTimeout = shouldThrow503OnTimeout;
}
private readonly IReadOnlyList<(TimeSpan requestTimeout, TimeSpan delayForNextRequest)> TimeoutsAndDelays = new List<(TimeSpan requestTimeout, TimeSpan delayForNextRequest)>()
{
(TimeSpan.FromSeconds(65), TimeSpan.Zero),
(TimeSpan.FromSeconds(65), TimeSpan.FromSeconds(1)),
(TimeSpan.FromSeconds(65), TimeSpan.Zero),
};
public override string TimeoutPolicyName => HttpTimeoutPolicyDefault.Name;
public override int TotalRetryCount => this.TimeoutsAndDelays.Count;
public override IEnumerator<(TimeSpan requestTimeout, TimeSpan delayForNextRequest)> GetTimeoutEnumerator()
{
return this.TimeoutsAndDelays.GetEnumerator();
}
// Assume that it is not safe to retry unless it is a get method.
// Create and other operations could have succeeded even though a timeout occurred.
public override bool IsSafeToRetry(HttpMethod httpMethod)
{
return httpMethod == HttpMethod.Get;
}
public override bool ShouldRetryBasedOnResponse(HttpMethod requestHttpMethod, HttpResponseMessage responseMessage)
{
return false;
}
public override bool ShouldThrow503OnTimeout => this.shouldThrow503OnTimeout;
}
}