OLD | NEW |
1 // Copyright (c) 2017 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2017 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #ifndef NET_HTTP_BROKEN_ALTERNATIVE_SERVICES_H_ | 5 #ifndef NET_HTTP_BROKEN_ALTERNATIVE_SERVICES_H_ |
6 #define NET_HTTP_BROKEN_ALTERNATIVE_SERVICES_H_ | 6 #define NET_HTTP_BROKEN_ALTERNATIVE_SERVICES_H_ |
7 | 7 |
8 #include <list> | 8 #include <list> |
9 #include <unordered_map> | 9 #include <unordered_map> |
10 | 10 |
11 #include "base/memory/weak_ptr.h" | 11 #include "base/memory/weak_ptr.h" |
12 #include "base/timer/timer.h" | 12 #include "base/timer/timer.h" |
13 #include "net/http/http_server_properties.h" | 13 #include "net/http/http_server_properties.h" |
14 | 14 |
15 namespace base { | 15 namespace base { |
16 class TickClock; | 16 class TickClock; |
17 } | 17 } |
18 | 18 |
19 namespace net { | 19 namespace net { |
20 | 20 |
21 struct AlternativeServiceHash { | |
22 size_t operator()(const net::AlternativeService& entry) const { | |
23 return entry.protocol ^ std::hash<std::string>()(entry.host) ^ entry.port; | |
24 } | |
25 }; | |
26 | |
27 // This class tracks HTTP alternative services that have been marked as broken. | 21 // This class tracks HTTP alternative services that have been marked as broken. |
28 // The brokenness of an alt-svc will expire after some time according to an | 22 // The brokenness of an alt-svc will expire after some time according to an |
29 // exponential back-off formula: each time an alt-svc is marked broken, the | 23 // exponential back-off formula: each time an alt-svc is marked broken, the |
30 // expiration delay will be some constant multiple of its previous expiration | 24 // expiration delay will be some constant multiple of its previous expiration |
31 // delay. This prevents broken alt-svcs from being retried too often by the | 25 // delay. This prevents broken alt-svcs from being retried too often by the |
32 // network stack. | 26 // network stack. |
33 class NET_EXPORT_PRIVATE BrokenAlternativeServices { | 27 class NET_EXPORT_PRIVATE BrokenAlternativeServices { |
34 public: | 28 public: |
35 // Delegate to be used by owner so it can be notified when the brokenness of | 29 // Delegate to be used by owner so it can be notified when the brokenness of |
36 // an AlternativeService expires. | 30 // an AlternativeService expires. |
(...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
78 // Returns true if MarkAlternativeServiceRecentlyBroken(alternative_service) | 72 // Returns true if MarkAlternativeServiceRecentlyBroken(alternative_service) |
79 // or MarkAlternativeServiceBroken(alternative_service) has been called and | 73 // or MarkAlternativeServiceBroken(alternative_service) has been called and |
80 // ConfirmAlternativeService(alternative_service) has not been called | 74 // ConfirmAlternativeService(alternative_service) has not been called |
81 // afterwards (even if brokenness of |alternative_service| has expired). | 75 // afterwards (even if brokenness of |alternative_service| has expired). |
82 bool WasAlternativeServiceRecentlyBroken( | 76 bool WasAlternativeServiceRecentlyBroken( |
83 const AlternativeService& alternative_service); | 77 const AlternativeService& alternative_service); |
84 | 78 |
85 // Marks |alternative_service| as not broken and not recently broken. | 79 // Marks |alternative_service| as not broken and not recently broken. |
86 void ConfirmAlternativeService(const AlternativeService& alternative_service); | 80 void ConfirmAlternativeService(const AlternativeService& alternative_service); |
87 | 81 |
| 82 // Sets broken and recently broken alternative services. |
| 83 // |broken_alternative_service_list| must be sorted from earliest to latest |
| 84 // expiration time. |
| 85 // All AlternativeServices in |broken_alternative_service_list| must exist in |
| 86 // |recently_broken_alternative_services|. |
| 87 void SetBrokenAndRecentlyBrokenAlternativeServices( |
| 88 std::unique_ptr<BrokenAlternativeServiceList> |
| 89 broken_alternative_service_list, |
| 90 std::unique_ptr<RecentlyBrokenAlternativeServices> |
| 91 recently_broken_alternative_services); |
| 92 |
| 93 const BrokenAlternativeServiceList& broken_alternative_service_list() const; |
| 94 |
| 95 const RecentlyBrokenAlternativeServices& |
| 96 recently_broken_alternative_services() const; |
| 97 |
88 private: | 98 private: |
89 // TODO (wangyix): modify HttpServerPropertiesImpl unit tests so this | 99 // TODO (wangyix): modify HttpServerPropertiesImpl unit tests so this |
90 // friendness is no longer required. | 100 // friendness is no longer required. |
91 friend class HttpServerPropertiesImplPeer; | 101 friend class HttpServerPropertiesImplPeer; |
92 | 102 |
93 // A pair containing a broken AlternativeService and the expiration time of | 103 struct AlternativeServiceHash { |
94 // its brokenness. | 104 size_t operator()(const net::AlternativeService& entry) const { |
95 struct BrokenAltSvcExpireInfo { | 105 return entry.protocol ^ std::hash<std::string>()(entry.host) ^ entry.port; |
96 BrokenAltSvcExpireInfo(const AlternativeService& alt_svc, | 106 } |
97 base::TimeTicks expire) | |
98 : alternative_service(alt_svc), expiration(expire) {} | |
99 | |
100 AlternativeService alternative_service; | |
101 base::TimeTicks expiration; | |
102 }; | 107 }; |
103 | 108 |
104 typedef std::list<BrokenAltSvcExpireInfo> BrokenAlternativeServiceList; | |
105 | |
106 typedef std::unordered_map<AlternativeService, | 109 typedef std::unordered_map<AlternativeService, |
107 BrokenAlternativeServiceList::iterator, | 110 BrokenAlternativeServiceList::iterator, |
108 AlternativeServiceHash> | 111 AlternativeServiceHash> |
109 BrokenAlternativeServiceMap; | 112 BrokenAlternativeServiceMap; |
110 | 113 |
111 // Inserts |alternative_service| and its |expiration| time into | 114 // Inserts |alternative_service| and its |expiration| time into |
112 // |broken_alternative_service_list_| and |broken_alternative_service_map_|. | 115 // |broken_alternative_service_list_| and |broken_alternative_service_map_|. |
113 // |it| is the position in |broken_alternative_service_list_| where it was | 116 // |it| is the position in |broken_alternative_service_list_| where it was |
114 // inserted. | 117 // inserted. |
115 bool AddToBrokenAlternativeServiceListAndMap( | 118 bool AddToBrokenAlternativeServiceListAndMap( |
(...skipping 20 matching lines...) Expand all Loading... |
136 // Used for scheduling the task that expires the brokenness of alternative | 139 // Used for scheduling the task that expires the brokenness of alternative |
137 // services. | 140 // services. |
138 base::OneShotTimer expiration_timer_; | 141 base::OneShotTimer expiration_timer_; |
139 | 142 |
140 base::WeakPtrFactory<BrokenAlternativeServices> weak_ptr_factory_; | 143 base::WeakPtrFactory<BrokenAlternativeServices> weak_ptr_factory_; |
141 }; | 144 }; |
142 | 145 |
143 } // namespace net | 146 } // namespace net |
144 | 147 |
145 #endif // NET_HTTP_BROKEN_ALTERNATIVE_SERVICES_H_ | 148 #endif // NET_HTTP_BROKEN_ALTERNATIVE_SERVICES_H_ |
OLD | NEW |