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 "content/browser/loader/resource_loader.h" | 5 #include "content/browser/loader/resource_loader.h" |
6 | 6 |
7 #include <utility> | 7 #include <utility> |
8 | 8 |
9 #include "base/command_line.h" | 9 #include "base/command_line.h" |
10 #include "base/location.h" | 10 #include "base/location.h" |
(...skipping 145 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
156 if (login_delegate_.get()) | 156 if (login_delegate_.get()) |
157 login_delegate_->OnRequestCancelled(); | 157 login_delegate_->OnRequestCancelled(); |
158 ssl_client_auth_handler_.reset(); | 158 ssl_client_auth_handler_.reset(); |
159 | 159 |
160 // Run ResourceHandler destructor before we tear-down the rest of our state | 160 // Run ResourceHandler destructor before we tear-down the rest of our state |
161 // as the ResourceHandler may want to inspect the URLRequest and other state. | 161 // as the ResourceHandler may want to inspect the URLRequest and other state. |
162 handler_.reset(); | 162 handler_.reset(); |
163 } | 163 } |
164 | 164 |
165 void ResourceLoader::StartRequest() { | 165 void ResourceLoader::StartRequest() { |
166 if (delegate_->HandleExternalProtocol(this, request_->url())) { | |
167 CancelAndIgnore(); | |
168 return; | |
169 } | |
170 | |
171 // Give the handler a chance to delay the URLRequest from being started. | 166 // Give the handler a chance to delay the URLRequest from being started. |
172 bool defer_start = false; | 167 bool defer_start = false; |
173 if (!handler_->OnWillStart(request_->url(), &defer_start)) { | 168 if (!handler_->OnWillStart(request_->url(), &defer_start)) { |
174 Cancel(); | 169 Cancel(); |
175 return; | 170 return; |
176 } | 171 } |
177 | 172 |
178 TRACE_EVENT_WITH_FLOW0("loading", "ResourceLoader::StartRequest", this, | 173 TRACE_EVENT_WITH_FLOW0("loading", "ResourceLoader::StartRequest", this, |
179 TRACE_EVENT_FLAG_FLOW_OUT); | 174 TRACE_EVENT_FLAG_FLOW_OUT); |
180 if (defer_start) { | 175 if (defer_start) { |
(...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
268 DVLOG(1) << "Denied unauthorized request for " | 263 DVLOG(1) << "Denied unauthorized request for " |
269 << redirect_info.new_url.possibly_invalid_spec(); | 264 << redirect_info.new_url.possibly_invalid_spec(); |
270 | 265 |
271 // Tell the renderer that this request was disallowed. | 266 // Tell the renderer that this request was disallowed. |
272 Cancel(); | 267 Cancel(); |
273 return; | 268 return; |
274 } | 269 } |
275 | 270 |
276 delegate_->DidReceiveRedirect(this, redirect_info.new_url); | 271 delegate_->DidReceiveRedirect(this, redirect_info.new_url); |
277 | 272 |
278 if (delegate_->HandleExternalProtocol(this, redirect_info.new_url)) { | |
279 // The request is complete so we can remove it. | |
280 CancelAndIgnore(); | |
281 return; | |
282 } | |
283 | |
284 scoped_refptr<ResourceResponse> response = new ResourceResponse(); | 273 scoped_refptr<ResourceResponse> response = new ResourceResponse(); |
285 PopulateResourceResponse(info, request_.get(), cert_store_, response.get()); | 274 PopulateResourceResponse(info, request_.get(), cert_store_, response.get()); |
286 if (!handler_->OnRequestRedirected(redirect_info, response.get(), defer)) { | 275 if (!handler_->OnRequestRedirected(redirect_info, response.get(), defer)) { |
287 Cancel(); | 276 Cancel(); |
288 } else if (*defer) { | 277 } else if (*defer) { |
289 deferred_stage_ = DEFERRED_REDIRECT; // Follow redirect when resumed. | 278 deferred_stage_ = DEFERRED_REDIRECT; // Follow redirect when resumed. |
290 } | 279 } |
291 } | 280 } |
292 | 281 |
293 void ResourceLoader::OnAuthRequired(net::URLRequest* unused, | 282 void ResourceLoader::OnAuthRequired(net::URLRequest* unused, |
(...skipping 156 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
450 case DEFERRED_NONE: | 439 case DEFERRED_NONE: |
451 NOTREACHED(); | 440 NOTREACHED(); |
452 break; | 441 break; |
453 case DEFERRED_START: | 442 case DEFERRED_START: |
454 StartRequestInternal(); | 443 StartRequestInternal(); |
455 break; | 444 break; |
456 case DEFERRED_NETWORK_START: | 445 case DEFERRED_NETWORK_START: |
457 request_->ResumeNetworkStart(); | 446 request_->ResumeNetworkStart(); |
458 break; | 447 break; |
459 case DEFERRED_REDIRECT: | 448 case DEFERRED_REDIRECT: |
460 request_->FollowDeferredRedirect(); | 449 FollowDeferredRedirectInternal(); |
461 break; | 450 break; |
462 case DEFERRED_READ: | 451 case DEFERRED_READ: |
463 base::ThreadTaskRunnerHandle::Get()->PostTask( | 452 base::ThreadTaskRunnerHandle::Get()->PostTask( |
464 FROM_HERE, base::Bind(&ResourceLoader::ResumeReading, | 453 FROM_HERE, base::Bind(&ResourceLoader::ResumeReading, |
465 weak_ptr_factory_.GetWeakPtr())); | 454 weak_ptr_factory_.GetWeakPtr())); |
466 break; | 455 break; |
467 case DEFERRED_RESPONSE_COMPLETE: | 456 case DEFERRED_RESPONSE_COMPLETE: |
468 base::ThreadTaskRunnerHandle::Get()->PostTask( | 457 base::ThreadTaskRunnerHandle::Get()->PostTask( |
469 FROM_HERE, base::Bind(&ResourceLoader::ResponseCompleted, | 458 FROM_HERE, base::Bind(&ResourceLoader::ResponseCompleted, |
470 weak_ptr_factory_.GetWeakPtr())); | 459 weak_ptr_factory_.GetWeakPtr())); |
471 break; | 460 break; |
472 case DEFERRED_FINISH: | 461 case DEFERRED_FINISH: |
473 // Delay self-destruction since we don't know how we were reached. | 462 // Delay self-destruction since we don't know how we were reached. |
474 base::ThreadTaskRunnerHandle::Get()->PostTask( | 463 base::ThreadTaskRunnerHandle::Get()->PostTask( |
475 FROM_HERE, base::Bind(&ResourceLoader::CallDidFinishLoading, | 464 FROM_HERE, base::Bind(&ResourceLoader::CallDidFinishLoading, |
476 weak_ptr_factory_.GetWeakPtr())); | 465 weak_ptr_factory_.GetWeakPtr())); |
477 break; | 466 break; |
478 } | 467 } |
479 } | 468 } |
480 | 469 |
481 void ResourceLoader::Cancel() { | 470 void ResourceLoader::Cancel() { |
482 CancelRequest(false); | 471 CancelRequest(false); |
483 } | 472 } |
484 | 473 |
485 void ResourceLoader::StartRequestInternal() { | 474 void ResourceLoader::StartRequestInternal() { |
| 475 // At this point any possible deferred start is already over. |
486 DCHECK(!request_->is_pending()); | 476 DCHECK(!request_->is_pending()); |
487 | 477 |
| 478 if (delegate_->HandleExternalProtocol(this, request_->url())) { |
| 479 CancelAndIgnore(); |
| 480 return; |
| 481 } |
| 482 |
488 if (!request_->status().is_success()) { | 483 if (!request_->status().is_success()) { |
489 return; | 484 return; |
490 } | 485 } |
491 | 486 |
492 started_request_ = true; | 487 started_request_ = true; |
493 request_->Start(); | 488 request_->Start(); |
494 | 489 |
495 delegate_->DidStartRequest(this); | 490 delegate_->DidStartRequest(this); |
496 } | 491 } |
497 | 492 |
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
534 if (!was_pending) { | 529 if (!was_pending) { |
535 // If the request isn't in flight, then we won't get an asynchronous | 530 // If the request isn't in flight, then we won't get an asynchronous |
536 // notification from the request, so we have to signal ourselves to finish | 531 // notification from the request, so we have to signal ourselves to finish |
537 // this request. | 532 // this request. |
538 base::ThreadTaskRunnerHandle::Get()->PostTask( | 533 base::ThreadTaskRunnerHandle::Get()->PostTask( |
539 FROM_HERE, base::Bind(&ResourceLoader::ResponseCompleted, | 534 FROM_HERE, base::Bind(&ResourceLoader::ResponseCompleted, |
540 weak_ptr_factory_.GetWeakPtr())); | 535 weak_ptr_factory_.GetWeakPtr())); |
541 } | 536 } |
542 } | 537 } |
543 | 538 |
| 539 void ResourceLoader::FollowDeferredRedirectInternal() { |
| 540 const GURL& new_url = request_->GetDeferredRedirectUrl(); |
| 541 if (delegate_->HandleExternalProtocol(this, new_url)) { |
| 542 // The request is complete so we can remove it. |
| 543 CancelAndIgnore(); |
| 544 return; |
| 545 } |
| 546 |
| 547 request_->FollowDeferredRedirect(); |
| 548 } |
| 549 |
544 void ResourceLoader::CompleteResponseStarted() { | 550 void ResourceLoader::CompleteResponseStarted() { |
545 ResourceRequestInfoImpl* info = GetRequestInfo(); | 551 ResourceRequestInfoImpl* info = GetRequestInfo(); |
546 scoped_refptr<ResourceResponse> response = new ResourceResponse(); | 552 scoped_refptr<ResourceResponse> response = new ResourceResponse(); |
547 PopulateResourceResponse(info, request_.get(), cert_store_, response.get()); | 553 PopulateResourceResponse(info, request_.get(), cert_store_, response.get()); |
548 | 554 |
549 delegate_->DidReceiveResponse(this); | 555 delegate_->DidReceiveResponse(this); |
550 | 556 |
551 // TODO(darin): Remove ScopedTracker below once crbug.com/475761 is fixed. | 557 // TODO(darin): Remove ScopedTracker below once crbug.com/475761 is fixed. |
552 tracked_objects::ScopedTracker tracking_profile( | 558 tracked_objects::ScopedTracker tracking_profile( |
553 FROM_HERE_WITH_EXPLICIT_FUNCTION("475761 OnResponseStarted()")); | 559 FROM_HERE_WITH_EXPLICIT_FUNCTION("475761 OnResponseStarted()")); |
(...skipping 181 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
735 } | 741 } |
736 | 742 |
737 UMA_HISTOGRAM_ENUMERATION("Net.Prefetch.Pattern", status, STATUS_MAX); | 743 UMA_HISTOGRAM_ENUMERATION("Net.Prefetch.Pattern", status, STATUS_MAX); |
738 } else if (request_->response_info().unused_since_prefetch) { | 744 } else if (request_->response_info().unused_since_prefetch) { |
739 TimeDelta total_time = base::TimeTicks::Now() - request_->creation_time(); | 745 TimeDelta total_time = base::TimeTicks::Now() - request_->creation_time(); |
740 UMA_HISTOGRAM_TIMES("Net.Prefetch.TimeSpentOnPrefetchHit", total_time); | 746 UMA_HISTOGRAM_TIMES("Net.Prefetch.TimeSpentOnPrefetchHit", total_time); |
741 } | 747 } |
742 } | 748 } |
743 | 749 |
744 } // namespace content | 750 } // namespace content |
OLD | NEW |