Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 #include <set> | 5 #include <set> |
| 6 | 6 |
| 7 #include "content/browser/loader/resource_scheduler.h" | 7 #include "content/browser/loader/resource_scheduler.h" |
| 8 | 8 |
| 9 #include "base/metrics/field_trial.h" | 9 #include "base/metrics/field_trial.h" |
| 10 #include "base/metrics/histogram.h" | |
| 10 #include "base/stl_util.h" | 11 #include "base/stl_util.h" |
| 11 #include "content/common/resource_messages.h" | 12 #include "content/common/resource_messages.h" |
| 12 #include "content/browser/loader/resource_message_delegate.h" | 13 #include "content/browser/loader/resource_message_delegate.h" |
| 13 #include "content/public/browser/resource_controller.h" | 14 #include "content/public/browser/resource_controller.h" |
| 14 #include "content/public/browser/resource_request_info.h" | 15 #include "content/public/browser/resource_request_info.h" |
| 15 #include "content/public/browser/resource_throttle.h" | 16 #include "content/public/browser/resource_throttle.h" |
| 16 #include "ipc/ipc_message_macros.h" | 17 #include "ipc/ipc_message_macros.h" |
| 17 #include "net/base/host_port_pair.h" | 18 #include "net/base/host_port_pair.h" |
| 18 #include "net/base/load_flags.h" | 19 #include "net/base/load_flags.h" |
| 19 #include "net/base/request_priority.h" | 20 #include "net/base/request_priority.h" |
| (...skipping 102 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 122 ResourceScheduler* scheduler, | 123 ResourceScheduler* scheduler, |
| 123 const RequestPriorityParams& priority) | 124 const RequestPriorityParams& priority) |
| 124 : ResourceMessageDelegate(request), | 125 : ResourceMessageDelegate(request), |
| 125 client_id_(client_id), | 126 client_id_(client_id), |
| 126 request_(request), | 127 request_(request), |
| 127 ready_(false), | 128 ready_(false), |
| 128 deferred_(false), | 129 deferred_(false), |
| 129 classification_(NORMAL_REQUEST), | 130 classification_(NORMAL_REQUEST), |
| 130 scheduler_(scheduler), | 131 scheduler_(scheduler), |
| 131 priority_(priority), | 132 priority_(priority), |
| 132 fifo_ordering_(0) { | 133 fifo_ordering_(0), |
| 134 request_seen_(base::TimeTicks::Now()) { | |
|
mmenke
2014/10/30 15:14:19
Should include base/time.h (Timer, included in the
aiolos (Not reviewing)
2014/10/31 23:33:27
Done.
| |
| 133 TRACE_EVENT_ASYNC_BEGIN1("net", "URLRequest", request_, | 135 TRACE_EVENT_ASYNC_BEGIN1("net", "URLRequest", request_, |
| 134 "url", request->url().spec()); | 136 "url", request->url().spec()); |
| 135 } | 137 } |
| 136 | 138 |
| 137 ~ScheduledResourceRequest() override { scheduler_->RemoveRequest(this); } | 139 ~ScheduledResourceRequest() override { scheduler_->RemoveRequest(this); } |
| 138 | 140 |
| 139 void Start() { | 141 void Start() { |
| 140 TRACE_EVENT_ASYNC_STEP_PAST0("net", "URLRequest", request_, "Queued"); | 142 TRACE_EVENT_ASYNC_STEP_PAST0("net", "URLRequest", request_, "Queued"); |
| 141 ready_ = true; | 143 ready_ = true; |
| 142 if (deferred_ && request_->status().is_success()) { | 144 if (deferred_ && request_->status().is_success()) { |
|
mmenke
2014/10/30 15:14:19
If request_->status() isn't success, should we eve
aiolos (Not reviewing)
2014/10/30 16:58:47
Easy enough to change.
mmenke
2014/10/30 17:30:40
Glancing at the loader, looks like we're fine.
| |
| 143 deferred_ = false; | 145 deferred_ = false; |
| 144 controller()->Resume(); | 146 controller()->Resume(); |
| 145 } | 147 } |
| 148 base::TimeDelta time_deferred = base::TimeTicks::Now() - request_seen_; | |
|
mmenke
2014/10/30 15:14:19
This this the time we want? We could measure time
aiolos (Not reviewing)
2014/10/30 16:58:47
I can see value from both options. I'm guessing we
mmenke
2014/10/30 17:30:40
I'm fine with adding both, and a TODO to remove on
aiolos (Not reviewing)
2014/10/31 23:33:27
Done.
| |
| 149 std::string histogram_name = base::StringPrintf( | |
| 150 "ResourceScheduler.%sRequestTimeDeferred", | |
|
Ilya Sherman
2014/10/30 03:18:11
Optional nit: I'd recommend having the Active vs.
mmenke
2014/10/30 15:14:19
It also makes the histograms more searchable.
aiolos (Not reviewing)
2014/10/31 23:33:27
Done.
| |
| 151 scheduler_->IsClientActive(client_id_) ? "Active" : "Background"); | |
| 152 base::HistogramBase* histogram_counter = base::Histogram::FactoryTimeGet( | |
| 153 histogram_name, | |
| 154 base::TimeDelta::FromMilliseconds(1), | |
| 155 base::TimeDelta::FromMinutes(5), | |
| 156 100, | |
|
mmenke
2014/10/30 15:14:19
Do we really need 100 buckets? Think 50 should be
aiolos (Not reviewing)
2014/10/31 23:33:27
Done.
| |
| 157 base::Histogram::kUmaTargetedHistogramFlag); | |
| 158 histogram_counter->AddTime(time_deferred); | |
| 146 } | 159 } |
| 147 | 160 |
| 148 void set_request_priority_params(const RequestPriorityParams& priority) { | 161 void set_request_priority_params(const RequestPriorityParams& priority) { |
| 149 priority_ = priority; | 162 priority_ = priority; |
| 150 } | 163 } |
| 151 const RequestPriorityParams& get_request_priority_params() const { | 164 const RequestPriorityParams& get_request_priority_params() const { |
| 152 return priority_; | 165 return priority_; |
| 153 } | 166 } |
| 154 const ClientId& client_id() const { return client_id_; } | 167 const ClientId& client_id() const { return client_id_; } |
| 155 net::URLRequest* url_request() { return request_; } | 168 net::URLRequest* url_request() { return request_; } |
| (...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 187 } | 200 } |
| 188 | 201 |
| 189 ClientId client_id_; | 202 ClientId client_id_; |
| 190 net::URLRequest* request_; | 203 net::URLRequest* request_; |
| 191 bool ready_; | 204 bool ready_; |
| 192 bool deferred_; | 205 bool deferred_; |
| 193 RequestClassification classification_; | 206 RequestClassification classification_; |
| 194 ResourceScheduler* scheduler_; | 207 ResourceScheduler* scheduler_; |
| 195 RequestPriorityParams priority_; | 208 RequestPriorityParams priority_; |
| 196 uint32 fifo_ordering_; | 209 uint32 fifo_ordering_; |
| 210 base::TimeTicks request_seen_; | |
|
mmenke
2014/10/30 15:14:19
"request_seen_" makes me think "Did we see the req
aiolos (Not reviewing)
2014/10/31 23:33:27
Acknowledged.
| |
| 197 | 211 |
| 198 DISALLOW_COPY_AND_ASSIGN(ScheduledResourceRequest); | 212 DISALLOW_COPY_AND_ASSIGN(ScheduledResourceRequest); |
| 199 }; | 213 }; |
| 200 | 214 |
| 201 bool ResourceScheduler::ScheduledResourceSorter::operator()( | 215 bool ResourceScheduler::ScheduledResourceSorter::operator()( |
| 202 const ScheduledResourceRequest* a, | 216 const ScheduledResourceRequest* a, |
| 203 const ScheduledResourceRequest* b) const { | 217 const ScheduledResourceRequest* b) const { |
| 204 // Want the set to be ordered first by decreasing priority, then by | 218 // Want the set to be ordered first by decreasing priority, then by |
| 205 // decreasing intra_priority. | 219 // decreasing intra_priority. |
| 206 // ie. with (priority, intra_priority) | 220 // ie. with (priority, intra_priority) |
| (...skipping 784 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 991 void ResourceScheduler::LoadCoalescedRequests() { | 1005 void ResourceScheduler::LoadCoalescedRequests() { |
| 992 DCHECK(should_coalesce_); | 1006 DCHECK(should_coalesce_); |
| 993 ClientMap::iterator client_it = client_map_.begin(); | 1007 ClientMap::iterator client_it = client_map_.begin(); |
| 994 while (client_it != client_map_.end()) { | 1008 while (client_it != client_map_.end()) { |
| 995 Client* client = client_it->second; | 1009 Client* client = client_it->second; |
| 996 client->LoadCoalescedRequests(); | 1010 client->LoadCoalescedRequests(); |
| 997 ++client_it; | 1011 ++client_it; |
| 998 } | 1012 } |
| 999 } | 1013 } |
| 1000 | 1014 |
| 1015 bool ResourceScheduler::IsClientActive(ClientId client_id) { | |
| 1016 ClientMap::iterator client_it = client_map_.find(client_id); | |
|
mmenke
2014/10/30 15:14:19
const_iterator
aiolos (Not reviewing)
2014/10/31 23:33:27
Done.
| |
| 1017 if (client_it == client_map_.end()) { | |
| 1018 return false; | |
|
mmenke
2014/10/30 15:14:19
When there's no client, we just let requests throu
aiolos (Not reviewing)
2014/10/31 23:33:27
I made a separate histogram for those requests plu
| |
| 1019 } | |
|
mmenke
2014/10/30 15:14:19
don't use braces when both condition and body of a
aiolos (Not reviewing)
2014/10/31 23:33:27
Done.
| |
| 1020 return client_it->second->is_active(); | |
|
mmenke
2014/10/30 15:14:19
Formatting here is off
aiolos (Not reviewing)
2014/10/31 23:33:27
Done.
| |
| 1021 } | |
| 1022 | |
| 1001 void ResourceScheduler::ReprioritizeRequest(ScheduledResourceRequest* request, | 1023 void ResourceScheduler::ReprioritizeRequest(ScheduledResourceRequest* request, |
| 1002 net::RequestPriority new_priority, | 1024 net::RequestPriority new_priority, |
| 1003 int new_intra_priority_value) { | 1025 int new_intra_priority_value) { |
| 1004 if (request->url_request()->load_flags() & net::LOAD_IGNORE_LIMITS) { | 1026 if (request->url_request()->load_flags() & net::LOAD_IGNORE_LIMITS) { |
| 1005 // We should not be re-prioritizing requests with the | 1027 // We should not be re-prioritizing requests with the |
| 1006 // IGNORE_LIMITS flag. | 1028 // IGNORE_LIMITS flag. |
| 1007 NOTREACHED(); | 1029 NOTREACHED(); |
| 1008 return; | 1030 return; |
| 1009 } | 1031 } |
| 1010 RequestPriorityParams new_priority_params(new_priority, | 1032 RequestPriorityParams new_priority_params(new_priority, |
| (...skipping 18 matching lines...) Expand all Loading... | |
| 1029 client->ReprioritizeRequest( | 1051 client->ReprioritizeRequest( |
| 1030 request, old_priority_params, new_priority_params); | 1052 request, old_priority_params, new_priority_params); |
| 1031 } | 1053 } |
| 1032 | 1054 |
| 1033 ResourceScheduler::ClientId ResourceScheduler::MakeClientId( | 1055 ResourceScheduler::ClientId ResourceScheduler::MakeClientId( |
| 1034 int child_id, int route_id) { | 1056 int child_id, int route_id) { |
| 1035 return (static_cast<ResourceScheduler::ClientId>(child_id) << 32) | route_id; | 1057 return (static_cast<ResourceScheduler::ClientId>(child_id) << 32) | route_id; |
| 1036 } | 1058 } |
| 1037 | 1059 |
| 1038 } // namespace content | 1060 } // namespace content |
| OLD | NEW |