Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "chrome/browser/net/resource_prefetch_predictor_observer.h" | 5 #include "chrome/browser/net/resource_prefetch_predictor_observer.h" |
| 6 | 6 |
| 7 #include <memory> | 7 #include <memory> |
| 8 #include <string> | 8 #include <string> |
| 9 #include <utility> | 9 #include <utility> |
| 10 | 10 |
| 11 #include "base/memory/ptr_util.h" | 11 #include "base/memory/ptr_util.h" |
| 12 #include "base/metrics/histogram_macros.h" | 12 #include "base/metrics/histogram_macros.h" |
| 13 #include "content/public/browser/browser_thread.h" | 13 #include "content/public/browser/browser_thread.h" |
| 14 #include "content/public/browser/resource_request_info.h" | 14 #include "content/public/browser/resource_request_info.h" |
| 15 #include "net/url_request/url_request.h" | 15 #include "net/url_request/url_request.h" |
| 16 #include "url/gurl.h" | 16 #include "url/gurl.h" |
| 17 | 17 |
| 18 namespace content { | 18 namespace content { |
| 19 class WebContents; | 19 class WebContents; |
| 20 } | 20 } |
| 21 | 21 |
| 22 using content::BrowserThread; | 22 using content::BrowserThread; |
| 23 using predictors::ResourcePrefetchPredictor; | |
| 24 using URLRequestSummary = | 23 using URLRequestSummary = |
| 25 predictors::ResourcePrefetchPredictor::URLRequestSummary; | 24 predictors::ResourcePrefetchPredictor::URLRequestSummary; |
| 26 | 25 |
| 27 namespace { | 26 namespace { |
| 28 | 27 |
| 29 // Enum for measuring statistics pertaining to observed request, responses and | 28 // Enum for measuring statistics pertaining to observed request, responses and |
| 30 // redirects. | 29 // redirects. |
| 31 enum RequestStats { | 30 enum RequestStats { |
| 32 REQUEST_STATS_TOTAL_RESPONSES = 0, | 31 REQUEST_STATS_TOTAL_RESPONSES = 0, |
| 33 REQUEST_STATS_TOTAL_PROCESSED_RESPONSES = 1, | 32 REQUEST_STATS_TOTAL_PROCESSED_RESPONSES = 1, |
| (...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 73 // A WebContents might be associated with something that is not a tab. | 72 // A WebContents might be associated with something that is not a tab. |
| 74 // In this case tab_id will be -1 and is_valid() will return false. | 73 // In this case tab_id will be -1 and is_valid() will return false. |
| 75 return navigation_id->is_valid(); | 74 return navigation_id->is_valid(); |
| 76 } | 75 } |
| 77 | 76 |
| 78 } // namespace | 77 } // namespace |
| 79 | 78 |
| 80 namespace chrome_browser_net { | 79 namespace chrome_browser_net { |
| 81 | 80 |
| 82 ResourcePrefetchPredictorObserver::ResourcePrefetchPredictorObserver( | 81 ResourcePrefetchPredictorObserver::ResourcePrefetchPredictorObserver( |
| 83 ResourcePrefetchPredictor* predictor) | 82 predictors::GlowplugCollector* collector) |
| 84 : predictor_(predictor->AsWeakPtr()) { | 83 : collector_(collector->AsWeakPtr()) { |
| 85 DCHECK_CURRENTLY_ON(BrowserThread::UI); | 84 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 86 } | 85 } |
| 87 | 86 |
| 88 ResourcePrefetchPredictorObserver::~ResourcePrefetchPredictorObserver() { | 87 ResourcePrefetchPredictorObserver::~ResourcePrefetchPredictorObserver() { |
| 89 CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI) || | 88 CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI) || |
| 90 BrowserThread::CurrentlyOn(BrowserThread::IO)); | 89 BrowserThread::CurrentlyOn(BrowserThread::IO)); |
| 91 } | 90 } |
| 92 | 91 |
| 93 void ResourcePrefetchPredictorObserver::OnRequestStarted( | 92 void ResourcePrefetchPredictorObserver::OnRequestStarted( |
| 94 net::URLRequest* request, | 93 net::URLRequest* request, |
| 95 content::ResourceType resource_type, | 94 content::ResourceType resource_type, |
| 96 const content::ResourceRequestInfo::WebContentsGetter& | 95 const content::ResourceRequestInfo::WebContentsGetter& |
| 97 web_contents_getter) { | 96 web_contents_getter) { |
| 98 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 97 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 99 | 98 |
| 100 if (resource_type == content::RESOURCE_TYPE_MAIN_FRAME) | 99 if (resource_type == content::RESOURCE_TYPE_MAIN_FRAME) |
| 101 ReportMainFrameRequestStats(MAIN_FRAME_REQUEST_STATS_TOTAL_REQUESTS); | 100 ReportMainFrameRequestStats(MAIN_FRAME_REQUEST_STATS_TOTAL_REQUESTS); |
| 102 | 101 |
| 103 if (!ResourcePrefetchPredictor::ShouldRecordRequest(request, resource_type)) | 102 if (!predictors::GlowplugCollector::ShouldRecordRequest(request, |
|
Benoit L
2017/05/22 13:37:16
nit: why not
"using predictors::LoadingDataCollect
trevordixon
2017/05/23 13:05:15
Done.
| |
| 103 resource_type)) | |
| 104 return; | 104 return; |
| 105 | 105 |
| 106 auto summary = base::MakeUnique<URLRequestSummary>(); | 106 auto summary = base::MakeUnique<URLRequestSummary>(); |
| 107 summary->resource_url = request->original_url(); | 107 summary->resource_url = request->original_url(); |
| 108 summary->resource_type = resource_type; | 108 summary->resource_type = resource_type; |
| 109 | 109 |
| 110 BrowserThread::PostTask( | 110 BrowserThread::PostTask( |
| 111 BrowserThread::UI, FROM_HERE, | 111 BrowserThread::UI, FROM_HERE, |
| 112 base::BindOnce( | 112 base::BindOnce( |
| 113 &ResourcePrefetchPredictorObserver::OnRequestStartedOnUIThread, | 113 &ResourcePrefetchPredictorObserver::OnRequestStartedOnUIThread, |
| (...skipping 12 matching lines...) Expand all Loading... | |
| 126 web_contents_getter) { | 126 web_contents_getter) { |
| 127 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 127 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 128 | 128 |
| 129 const content::ResourceRequestInfo* request_info = | 129 const content::ResourceRequestInfo* request_info = |
| 130 content::ResourceRequestInfo::ForRequest(request); | 130 content::ResourceRequestInfo::ForRequest(request); |
| 131 if (request_info && | 131 if (request_info && |
| 132 request_info->GetResourceType() == content::RESOURCE_TYPE_MAIN_FRAME) { | 132 request_info->GetResourceType() == content::RESOURCE_TYPE_MAIN_FRAME) { |
| 133 ReportMainFrameRequestStats(MAIN_FRAME_REQUEST_STATS_TOTAL_REDIRECTS); | 133 ReportMainFrameRequestStats(MAIN_FRAME_REQUEST_STATS_TOTAL_REDIRECTS); |
| 134 } | 134 } |
| 135 | 135 |
| 136 if (!ResourcePrefetchPredictor::ShouldRecordRedirect(request)) | 136 if (!predictors::GlowplugCollector::ShouldRecordRedirect(request)) |
|
Benoit L
2017/05/22 13:37:16
nit: ditto.
trevordixon
2017/05/23 13:05:15
Done.
| |
| 137 return; | 137 return; |
| 138 | 138 |
| 139 auto summary = base::MakeUnique<URLRequestSummary>(); | 139 auto summary = base::MakeUnique<URLRequestSummary>(); |
| 140 if (!ResourcePrefetchPredictor::URLRequestSummary::SummarizeResponse( | 140 if (!URLRequestSummary::SummarizeResponse(*request, summary.get())) { |
| 141 *request, summary.get())) { | |
| 142 return; | 141 return; |
| 143 } | 142 } |
| 144 summary->redirect_url = redirect_url; | 143 summary->redirect_url = redirect_url; |
| 145 | 144 |
| 146 BrowserThread::PostTask( | 145 BrowserThread::PostTask( |
| 147 BrowserThread::UI, FROM_HERE, | 146 BrowserThread::UI, FROM_HERE, |
| 148 base::BindOnce( | 147 base::BindOnce( |
| 149 &ResourcePrefetchPredictorObserver::OnRequestRedirectedOnUIThread, | 148 &ResourcePrefetchPredictorObserver::OnRequestRedirectedOnUIThread, |
| 150 base::Unretained(this), base::Passed(std::move(summary)), | 149 base::Unretained(this), base::Passed(std::move(summary)), |
| 151 web_contents_getter, request->first_party_for_cookies(), | 150 web_contents_getter, request->first_party_for_cookies(), |
| (...skipping 13 matching lines...) Expand all Loading... | |
| 165 | 164 |
| 166 ReportRequestStats(REQUEST_STATS_TOTAL_RESPONSES); | 165 ReportRequestStats(REQUEST_STATS_TOTAL_RESPONSES); |
| 167 | 166 |
| 168 const content::ResourceRequestInfo* request_info = | 167 const content::ResourceRequestInfo* request_info = |
| 169 content::ResourceRequestInfo::ForRequest(request); | 168 content::ResourceRequestInfo::ForRequest(request); |
| 170 if (request_info && | 169 if (request_info && |
| 171 request_info->GetResourceType() == content::RESOURCE_TYPE_MAIN_FRAME) { | 170 request_info->GetResourceType() == content::RESOURCE_TYPE_MAIN_FRAME) { |
| 172 ReportMainFrameRequestStats(MAIN_FRAME_REQUEST_STATS_TOTAL_RESPONSES); | 171 ReportMainFrameRequestStats(MAIN_FRAME_REQUEST_STATS_TOTAL_RESPONSES); |
| 173 } | 172 } |
| 174 | 173 |
| 175 if (!ResourcePrefetchPredictor::ShouldRecordResponse(request)) | 174 if (!predictors::GlowplugCollector::ShouldRecordResponse(request)) |
| 176 return; | 175 return; |
| 177 auto summary = base::MakeUnique<URLRequestSummary>(); | 176 auto summary = base::MakeUnique<URLRequestSummary>(); |
| 178 if (!ResourcePrefetchPredictor::URLRequestSummary::SummarizeResponse( | 177 if (!URLRequestSummary::SummarizeResponse(*request, summary.get())) { |
| 179 *request, summary.get())) { | |
| 180 return; | 178 return; |
| 181 } | 179 } |
| 182 | 180 |
| 183 BrowserThread::PostTask( | 181 BrowserThread::PostTask( |
| 184 BrowserThread::UI, FROM_HERE, | 182 BrowserThread::UI, FROM_HERE, |
| 185 base::BindOnce( | 183 base::BindOnce( |
| 186 &ResourcePrefetchPredictorObserver::OnResponseStartedOnUIThread, | 184 &ResourcePrefetchPredictorObserver::OnResponseStartedOnUIThread, |
| 187 base::Unretained(this), base::Passed(std::move(summary)), | 185 base::Unretained(this), base::Passed(std::move(summary)), |
| 188 web_contents_getter, request->first_party_for_cookies(), | 186 web_contents_getter, request->first_party_for_cookies(), |
| 189 request->creation_time())); | 187 request->creation_time())); |
| 190 | 188 |
| 191 ReportRequestStats(REQUEST_STATS_TOTAL_PROCESSED_RESPONSES); | 189 ReportRequestStats(REQUEST_STATS_TOTAL_PROCESSED_RESPONSES); |
| 192 if (request_info && | 190 if (request_info && |
| 193 request_info->GetResourceType() == content::RESOURCE_TYPE_MAIN_FRAME) { | 191 request_info->GetResourceType() == content::RESOURCE_TYPE_MAIN_FRAME) { |
| 194 ReportMainFrameRequestStats(MAIN_FRAME_REQUEST_STATS_PROCESSED_RESPONSES); | 192 ReportMainFrameRequestStats(MAIN_FRAME_REQUEST_STATS_PROCESSED_RESPONSES); |
| 195 } | 193 } |
| 196 } | 194 } |
| 197 | 195 |
| 198 void ResourcePrefetchPredictorObserver::OnRequestStartedOnUIThread( | 196 void ResourcePrefetchPredictorObserver::OnRequestStartedOnUIThread( |
| 199 std::unique_ptr<URLRequestSummary> summary, | 197 std::unique_ptr<URLRequestSummary> summary, |
| 200 const content::ResourceRequestInfo::WebContentsGetter& web_contents_getter, | 198 const content::ResourceRequestInfo::WebContentsGetter& web_contents_getter, |
| 201 const GURL& main_frame_url, | 199 const GURL& main_frame_url, |
| 202 const base::TimeTicks& creation_time) const { | 200 const base::TimeTicks& creation_time) const { |
| 203 DCHECK_CURRENTLY_ON(BrowserThread::UI); | 201 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 204 if (!TryToFillNavigationID(&summary->navigation_id, web_contents_getter, | 202 if (!TryToFillNavigationID(&summary->navigation_id, web_contents_getter, |
| 205 main_frame_url, creation_time)) { | 203 main_frame_url, creation_time)) { |
| 206 return; | 204 return; |
| 207 } | 205 } |
| 208 predictor_->RecordURLRequest(*summary); | 206 collector_->RecordURLRequest(*summary); |
| 209 } | 207 } |
| 210 | 208 |
| 211 void ResourcePrefetchPredictorObserver::OnRequestRedirectedOnUIThread( | 209 void ResourcePrefetchPredictorObserver::OnRequestRedirectedOnUIThread( |
| 212 std::unique_ptr<URLRequestSummary> summary, | 210 std::unique_ptr<URLRequestSummary> summary, |
| 213 const content::ResourceRequestInfo::WebContentsGetter& web_contents_getter, | 211 const content::ResourceRequestInfo::WebContentsGetter& web_contents_getter, |
| 214 const GURL& main_frame_url, | 212 const GURL& main_frame_url, |
| 215 const base::TimeTicks& creation_time) const { | 213 const base::TimeTicks& creation_time) const { |
| 216 DCHECK_CURRENTLY_ON(BrowserThread::UI); | 214 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 217 if (!TryToFillNavigationID(&summary->navigation_id, web_contents_getter, | 215 if (!TryToFillNavigationID(&summary->navigation_id, web_contents_getter, |
| 218 main_frame_url, creation_time)) { | 216 main_frame_url, creation_time)) { |
| 219 return; | 217 return; |
| 220 } | 218 } |
| 221 predictor_->RecordURLRedirect(*summary); | 219 collector_->RecordURLRedirect(*summary); |
| 222 } | 220 } |
| 223 | 221 |
| 224 void ResourcePrefetchPredictorObserver::OnResponseStartedOnUIThread( | 222 void ResourcePrefetchPredictorObserver::OnResponseStartedOnUIThread( |
| 225 std::unique_ptr<URLRequestSummary> summary, | 223 std::unique_ptr<URLRequestSummary> summary, |
| 226 const content::ResourceRequestInfo::WebContentsGetter& web_contents_getter, | 224 const content::ResourceRequestInfo::WebContentsGetter& web_contents_getter, |
| 227 const GURL& main_frame_url, | 225 const GURL& main_frame_url, |
| 228 const base::TimeTicks& creation_time) const { | 226 const base::TimeTicks& creation_time) const { |
| 229 DCHECK_CURRENTLY_ON(BrowserThread::UI); | 227 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 230 if (!TryToFillNavigationID(&summary->navigation_id, web_contents_getter, | 228 if (!TryToFillNavigationID(&summary->navigation_id, web_contents_getter, |
| 231 main_frame_url, creation_time)) { | 229 main_frame_url, creation_time)) { |
| 232 return; | 230 return; |
| 233 } | 231 } |
| 234 predictor_->RecordURLResponse(*summary); | 232 collector_->RecordURLResponse(*summary); |
| 235 } | 233 } |
| 236 | 234 |
| 237 } // namespace chrome_browser_net | 235 } // namespace chrome_browser_net |
| OLD | NEW |