Index: content/browser/loader/resource_scheduler.cc |
diff --git a/content/browser/loader/resource_scheduler.cc b/content/browser/loader/resource_scheduler.cc |
index 6cc902ea561895a7c7216103c6146b5b7107ff68..c8d1c08f4f2332184de7fd8ba14a5dca4e7bf58b 100644 |
--- a/content/browser/loader/resource_scheduler.cc |
+++ b/content/browser/loader/resource_scheduler.cc |
@@ -7,7 +7,9 @@ |
#include "content/browser/loader/resource_scheduler.h" |
#include "base/metrics/field_trial.h" |
+#include "base/metrics/histogram.h" |
#include "base/stl_util.h" |
+#include "base/time/time.h" |
#include "content/common/resource_messages.h" |
#include "content/browser/loader/resource_message_delegate.h" |
#include "content/public/browser/resource_controller.h" |
@@ -118,11 +120,13 @@ class ResourceScheduler::ScheduledResourceRequest |
public ResourceThrottle { |
public: |
ScheduledResourceRequest(const ClientId& client_id, |
+ ResourceScheduler::ClientState client_state, |
mmenke
2014/11/03 16:05:55
Optional nit: Suggest not taking this as an argum
aiolos (Not reviewing)
2014/11/03 17:50:25
Done.
|
net::URLRequest* request, |
ResourceScheduler* scheduler, |
const RequestPriorityParams& priority) |
: ResourceMessageDelegate(request), |
client_id_(client_id), |
+ client_state_on_creation_(client_state), |
request_(request), |
ready_(false), |
deferred_(false), |
@@ -139,9 +143,25 @@ class ResourceScheduler::ScheduledResourceRequest |
void Start() { |
TRACE_EVENT_ASYNC_STEP_PAST0("net", "URLRequest", request_, "Queued"); |
ready_ = true; |
- if (deferred_ && request_->status().is_success()) { |
- deferred_ = false; |
- controller()->Resume(); |
+ if (request_->status().is_success()) { |
mmenke
2014/11/03 16:05:55
nit: Suggest making this an early return - early
aiolos (Not reviewing)
2014/11/03 17:50:26
Done.
|
+ base::TimeTicks time = base::TimeTicks::Now(); |
+ ClientState current_state = scheduler_->GetClientState(client_id_); |
+ const char* client_state = |
+ current_state == UNKNOWN || current_state != client_state_on_creation_ |
+ ? "Other" |
+ : current_state == ACTIVE ? "Active" : "Background"; |
mmenke
2014/11/03 16:05:54
Suggest a method or function for this, or splittin
aiolos (Not reviewing)
2014/11/03 17:50:25
Done.
|
+ if (deferred_) { |
+ deferred_ = false; |
+ controller()->Resume(); |
+ scheduler_->PostHistogram( |
+ "RequestTimeDeferred", client_state, time - time_deferred_); |
mmenke
2014/11/03 16:05:55
If !deferred_, we should be recording a 0, I belie
aiolos (Not reviewing)
2014/11/03 17:50:25
Done.
|
+ } |
+ // TODO(aiolos): Remove one of these histograms after gaining an |
+ // understanding of the difference between them and which one is more |
+ // interesting. |
+ scheduler_->PostHistogram("RequestTimeThrottled", |
+ client_state, |
+ time - request_->creation_time()); |
} |
} |
@@ -177,7 +197,10 @@ class ResourceScheduler::ScheduledResourceRequest |
} |
// ResourceThrottle interface: |
- void WillStartRequest(bool* defer) override { deferred_ = *defer = !ready_; } |
+ void WillStartRequest(bool* defer) override { |
+ deferred_ = *defer = !ready_; |
+ time_deferred_ = base::TimeTicks::Now(); |
+ } |
const char* GetNameForLogging() const override { return "ResourceScheduler"; } |
@@ -187,6 +210,7 @@ class ResourceScheduler::ScheduledResourceRequest |
} |
ClientId client_id_; |
+ ResourceScheduler::ClientState client_state_on_creation_; |
net::URLRequest* request_; |
bool ready_; |
bool deferred_; |
@@ -194,6 +218,7 @@ class ResourceScheduler::ScheduledResourceRequest |
ResourceScheduler* scheduler_; |
RequestPriorityParams priority_; |
uint32 fifo_ordering_; |
+ base::TimeTicks time_deferred_; |
DISALLOW_COPY_AND_ASSIGN(ScheduledResourceRequest); |
}; |
@@ -754,9 +779,12 @@ scoped_ptr<ResourceThrottle> ResourceScheduler::ScheduleRequest( |
net::URLRequest* url_request) { |
DCHECK(CalledOnValidThread()); |
ClientId client_id = MakeClientId(child_id, route_id); |
- scoped_ptr<ScheduledResourceRequest> request( |
- new ScheduledResourceRequest(client_id, url_request, this, |
- RequestPriorityParams(url_request->priority(), 0))); |
+ scoped_ptr<ScheduledResourceRequest> request(new ScheduledResourceRequest( |
+ client_id, |
+ GetClientState(client_id), |
+ url_request, |
+ this, |
+ RequestPriorityParams(url_request->priority(), 0))); |
ClientMap::iterator it = client_map_.find(client_id); |
if (it == client_map_.end()) { |
@@ -998,6 +1026,14 @@ void ResourceScheduler::LoadCoalescedRequests() { |
} |
} |
+ResourceScheduler::ClientState ResourceScheduler::GetClientState( |
+ ClientId client_id) const { |
+ ClientMap::const_iterator client_it = client_map_.find(client_id); |
+ if (client_it == client_map_.end()) |
+ return UNKNOWN; |
+ return client_it->second->is_active() ? ACTIVE : BACKGROUND; |
+} |
+ |
void ResourceScheduler::ReprioritizeRequest(ScheduledResourceRequest* request, |
net::RequestPriority new_priority, |
int new_intra_priority_value) { |
@@ -1035,4 +1071,17 @@ ResourceScheduler::ClientId ResourceScheduler::MakeClientId( |
return (static_cast<ResourceScheduler::ClientId>(child_id) << 32) | route_id; |
} |
+void ResourceScheduler::PostHistogram(const char* base_name, |
mmenke
2014/11/03 16:05:55
This should be in an anonymous namespace up top.
aiolos (Not reviewing)
2014/11/03 17:50:26
Done.
|
+ const char* suffix, |
+ base::TimeDelta time) { |
+ std::string histogram_name = |
+ base::StringPrintf("ResourceScheduler.%s_%s", base_name, suffix); |
+ base::HistogramBase* histogram_counter = base::Histogram::FactoryTimeGet( |
+ histogram_name, |
+ base::TimeDelta::FromMilliseconds(1), |
+ base::TimeDelta::FromMinutes(5), |
+ 50, |
+ base::Histogram::kUmaTargetedHistogramFlag); |
+ histogram_counter->AddTime(time); |
+} |
} // namespace content |