OLD | NEW |
1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2010 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 // See http://dev.chromium.org/developers/design-documents/multi-process-resourc
e-loading | 5 // See http://dev.chromium.org/developers/design-documents/multi-process-resourc
e-loading |
6 | 6 |
7 #include "chrome/browser/renderer_host/resource_dispatcher_host.h" | 7 #include "chrome/browser/renderer_host/resource_dispatcher_host.h" |
8 | 8 |
9 #include <vector> | 9 #include <vector> |
10 | 10 |
(...skipping 139 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
150 NOTREACHED() << "Denied unauthorized upload of " | 150 NOTREACHED() << "Denied unauthorized upload of " |
151 << iter->file_path().value(); | 151 << iter->file_path().value(); |
152 return false; | 152 return false; |
153 } | 153 } |
154 } | 154 } |
155 } | 155 } |
156 | 156 |
157 return true; | 157 return true; |
158 } | 158 } |
159 | 159 |
160 void PopulateResourceResponse(URLRequest* request, | 160 void PopulateResourceResponse(net::URLRequest* request, |
161 bool replace_extension_localization_templates, | 161 bool replace_extension_localization_templates, |
162 ResourceResponse* response) { | 162 ResourceResponse* response) { |
163 response->response_head.status = request->status(); | 163 response->response_head.status = request->status(); |
164 response->response_head.request_time = request->request_time(); | 164 response->response_head.request_time = request->request_time(); |
165 response->response_head.response_time = request->response_time(); | 165 response->response_head.response_time = request->response_time(); |
166 response->response_head.headers = request->response_headers(); | 166 response->response_head.headers = request->response_headers(); |
167 request->GetCharset(&response->response_head.charset); | 167 request->GetCharset(&response->response_head.charset); |
168 response->response_head.replace_extension_localization_templates = | 168 response->response_head.replace_extension_localization_templates = |
169 replace_extension_localization_templates; | 169 replace_extension_localization_templates; |
170 response->response_head.content_length = request->GetExpectedContentSize(); | 170 response->response_head.content_length = request->GetExpectedContentSize(); |
(...skipping 68 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
239 BrowserThread::IO, FROM_HERE, | 239 BrowserThread::IO, FROM_HERE, |
240 NewRunnableFunction(&appcache::AppCacheInterceptor::EnsureRegistered)); | 240 NewRunnableFunction(&appcache::AppCacheInterceptor::EnsureRegistered)); |
241 } | 241 } |
242 | 242 |
243 void ResourceDispatcherHost::Shutdown() { | 243 void ResourceDispatcherHost::Shutdown() { |
244 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 244 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
245 BrowserThread::PostTask(BrowserThread::IO, FROM_HERE, new ShutdownTask(this)); | 245 BrowserThread::PostTask(BrowserThread::IO, FROM_HERE, new ShutdownTask(this)); |
246 } | 246 } |
247 | 247 |
248 void ResourceDispatcherHost::SetRequestInfo( | 248 void ResourceDispatcherHost::SetRequestInfo( |
249 URLRequest* request, | 249 net::URLRequest* request, |
250 ResourceDispatcherHostRequestInfo* info) { | 250 ResourceDispatcherHostRequestInfo* info) { |
251 request->SetUserData(NULL, info); | 251 request->SetUserData(NULL, info); |
252 } | 252 } |
253 | 253 |
254 void ResourceDispatcherHost::OnShutdown() { | 254 void ResourceDispatcherHost::OnShutdown() { |
255 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 255 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
256 is_shutdown_ = true; | 256 is_shutdown_ = true; |
257 resource_queue_.Shutdown(); | 257 resource_queue_.Shutdown(); |
258 STLDeleteValues(&pending_requests_); | 258 STLDeleteValues(&pending_requests_); |
259 // Make sure we shutdown the timer now, otherwise by the time our destructor | 259 // Make sure we shutdown the timer now, otherwise by the time our destructor |
(...skipping 18 matching lines...) Expand all Loading... |
278 CancelBlockedRequestsForRoute(iter->first, iter->second); | 278 CancelBlockedRequestsForRoute(iter->first, iter->second); |
279 } | 279 } |
280 } | 280 } |
281 | 281 |
282 bool ResourceDispatcherHost::HandleExternalProtocol(int request_id, | 282 bool ResourceDispatcherHost::HandleExternalProtocol(int request_id, |
283 int child_id, | 283 int child_id, |
284 int route_id, | 284 int route_id, |
285 const GURL& url, | 285 const GURL& url, |
286 ResourceType::Type type, | 286 ResourceType::Type type, |
287 ResourceHandler* handler) { | 287 ResourceHandler* handler) { |
288 if (!ResourceType::IsFrame(type) || URLRequest::IsHandledURL(url)) | 288 if (!ResourceType::IsFrame(type) || net::URLRequest::IsHandledURL(url)) |
289 return false; | 289 return false; |
290 | 290 |
291 BrowserThread::PostTask( | 291 BrowserThread::PostTask( |
292 BrowserThread::UI, FROM_HERE, | 292 BrowserThread::UI, FROM_HERE, |
293 NewRunnableFunction( | 293 NewRunnableFunction( |
294 &ExternalProtocolHandler::LaunchUrl, url, child_id, route_id)); | 294 &ExternalProtocolHandler::LaunchUrl, url, child_id, route_id)); |
295 | 295 |
296 handler->OnResponseCompleted(request_id, URLRequestStatus( | 296 handler->OnResponseCompleted(request_id, URLRequestStatus( |
297 URLRequestStatus::FAILED, | 297 URLRequestStatus::FAILED, |
298 net::ERR_ABORTED), | 298 net::ERR_ABORTED), |
(...skipping 124 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
423 if (request_data.download_to_file) | 423 if (request_data.download_to_file) |
424 handler = new RedirectToFileResourceHandler(handler, child_id, this); | 424 handler = new RedirectToFileResourceHandler(handler, child_id, this); |
425 | 425 |
426 if (HandleExternalProtocol(request_id, child_id, route_id, | 426 if (HandleExternalProtocol(request_id, child_id, route_id, |
427 request_data.url, request_data.resource_type, | 427 request_data.url, request_data.resource_type, |
428 handler)) { | 428 handler)) { |
429 return; | 429 return; |
430 } | 430 } |
431 | 431 |
432 // Construct the request. | 432 // Construct the request. |
433 URLRequest* request = new URLRequest(request_data.url, this); | 433 net::URLRequest* request = new net::URLRequest(request_data.url, this); |
434 request->set_method(request_data.method); | 434 request->set_method(request_data.method); |
435 request->set_first_party_for_cookies(request_data.first_party_for_cookies); | 435 request->set_first_party_for_cookies(request_data.first_party_for_cookies); |
436 request->set_referrer(CommandLine::ForCurrentProcess()->HasSwitch( | 436 request->set_referrer(CommandLine::ForCurrentProcess()->HasSwitch( |
437 switches::kNoReferrers) ? std::string() : request_data.referrer.spec()); | 437 switches::kNoReferrers) ? std::string() : request_data.referrer.spec()); |
438 net::HttpRequestHeaders headers; | 438 net::HttpRequestHeaders headers; |
439 headers.AddHeadersFromString(request_data.headers); | 439 headers.AddHeadersFromString(request_data.headers); |
440 request->SetExtraRequestHeaders(headers); | 440 request->SetExtraRequestHeaders(headers); |
441 | 441 |
442 int load_flags = request_data.load_flags; | 442 int load_flags = request_data.load_flags; |
443 // Although EV status is irrelevant to sub-frames and sub-resources, we have | 443 // Although EV status is irrelevant to sub-frames and sub-resources, we have |
(...skipping 256 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
700 if (!ChildProcessSecurityPolicy::GetInstance()-> | 700 if (!ChildProcessSecurityPolicy::GetInstance()-> |
701 CanRequestURL(child_id, url)) { | 701 CanRequestURL(child_id, url)) { |
702 VLOG(1) << "Denied unauthorized download request for " | 702 VLOG(1) << "Denied unauthorized download request for " |
703 << url.possibly_invalid_spec(); | 703 << url.possibly_invalid_spec(); |
704 return; | 704 return; |
705 } | 705 } |
706 | 706 |
707 // Ensure the Chrome plugins are loaded, as they may intercept network | 707 // Ensure the Chrome plugins are loaded, as they may intercept network |
708 // requests. Does nothing if they are already loaded. | 708 // requests. Does nothing if they are already loaded. |
709 PluginService::GetInstance()->LoadChromePlugins(this); | 709 PluginService::GetInstance()->LoadChromePlugins(this); |
710 URLRequest* request = new URLRequest(url, this); | 710 net::URLRequest* request = new net::URLRequest(url, this); |
711 | 711 |
712 request_id_--; | 712 request_id_--; |
713 | 713 |
714 scoped_refptr<ResourceHandler> handler( | 714 scoped_refptr<ResourceHandler> handler( |
715 new DownloadResourceHandler(this, | 715 new DownloadResourceHandler(this, |
716 child_id, | 716 child_id, |
717 route_id, | 717 route_id, |
718 request_id_, | 718 request_id_, |
719 url, | 719 url, |
720 download_file_manager_.get(), | 720 download_file_manager_.get(), |
721 request, | 721 request, |
722 prompt_for_save_location, | 722 prompt_for_save_location, |
723 save_info)); | 723 save_info)); |
724 | 724 |
725 if (safe_browsing_->enabled()) { | 725 if (safe_browsing_->enabled()) { |
726 handler = CreateSafeBrowsingResourceHandler(handler, child_id, route_id, | 726 handler = CreateSafeBrowsingResourceHandler(handler, child_id, route_id, |
727 ResourceType::MAIN_FRAME); | 727 ResourceType::MAIN_FRAME); |
728 } | 728 } |
729 | 729 |
730 if (!URLRequest::IsHandledURL(url)) { | 730 if (!net::URLRequest::IsHandledURL(url)) { |
731 VLOG(1) << "Download request for unsupported protocol: " | 731 VLOG(1) << "Download request for unsupported protocol: " |
732 << url.possibly_invalid_spec(); | 732 << url.possibly_invalid_spec(); |
733 return; | 733 return; |
734 } | 734 } |
735 | 735 |
736 request->set_method("GET"); | 736 request->set_method("GET"); |
737 request->set_referrer(CommandLine::ForCurrentProcess()->HasSwitch( | 737 request->set_referrer(CommandLine::ForCurrentProcess()->HasSwitch( |
738 switches::kNoReferrers) ? std::string() : referrer.spec()); | 738 switches::kNoReferrers) ? std::string() : referrer.spec()); |
739 request->set_context(request_context); | 739 request->set_context(request_context); |
740 request->set_load_flags(request->load_flags() | | 740 request->set_load_flags(request->load_flags() | |
(...skipping 20 matching lines...) Expand all Loading... |
761 // requests. Does nothing if they are already loaded. | 761 // requests. Does nothing if they are already loaded. |
762 PluginService::GetInstance()->LoadChromePlugins(this); | 762 PluginService::GetInstance()->LoadChromePlugins(this); |
763 | 763 |
764 scoped_refptr<ResourceHandler> handler( | 764 scoped_refptr<ResourceHandler> handler( |
765 new SaveFileResourceHandler(child_id, | 765 new SaveFileResourceHandler(child_id, |
766 route_id, | 766 route_id, |
767 url, | 767 url, |
768 save_file_manager_.get())); | 768 save_file_manager_.get())); |
769 request_id_--; | 769 request_id_--; |
770 | 770 |
771 bool known_proto = URLRequest::IsHandledURL(url); | 771 bool known_proto = net::URLRequest::IsHandledURL(url); |
772 if (!known_proto) { | 772 if (!known_proto) { |
773 // Since any URLs which have non-standard scheme have been filtered | 773 // Since any URLs which have non-standard scheme have been filtered |
774 // by save manager(see GURL::SchemeIsStandard). This situation | 774 // by save manager(see GURL::SchemeIsStandard). This situation |
775 // should not happen. | 775 // should not happen. |
776 NOTREACHED(); | 776 NOTREACHED(); |
777 return; | 777 return; |
778 } | 778 } |
779 | 779 |
780 URLRequest* request = new URLRequest(url, this); | 780 net::URLRequest* request = new net::URLRequest(url, this); |
781 request->set_method("GET"); | 781 request->set_method("GET"); |
782 request->set_referrer(CommandLine::ForCurrentProcess()->HasSwitch( | 782 request->set_referrer(CommandLine::ForCurrentProcess()->HasSwitch( |
783 switches::kNoReferrers) ? std::string() : referrer.spec()); | 783 switches::kNoReferrers) ? std::string() : referrer.spec()); |
784 // So far, for saving page, we need fetch content from cache, in the | 784 // So far, for saving page, we need fetch content from cache, in the |
785 // future, maybe we can use a configuration to configure this behavior. | 785 // future, maybe we can use a configuration to configure this behavior. |
786 request->set_load_flags(net::LOAD_PREFERRING_CACHE); | 786 request->set_load_flags(net::LOAD_PREFERRING_CACHE); |
787 request->set_context(request_context); | 787 request->set_context(request_context); |
788 | 788 |
789 // Since we're just saving some resources we need, disallow downloading. | 789 // Since we're just saving some resources we need, disallow downloading. |
790 ResourceDispatcherHostRequestInfo* extra_info = | 790 ResourceDispatcherHostRequestInfo* extra_info = |
(...skipping 28 matching lines...) Expand all Loading... |
819 if (i == pending_requests_.end()) { | 819 if (i == pending_requests_.end()) { |
820 // The request may have been destroyed | 820 // The request may have been destroyed |
821 LOG(WARNING) << "Trying to resume a non-existent request (" | 821 LOG(WARNING) << "Trying to resume a non-existent request (" |
822 << process_unique_id << ", " << request_id << ")"; | 822 << process_unique_id << ", " << request_id << ")"; |
823 return; | 823 return; |
824 } | 824 } |
825 | 825 |
826 // TODO(eroman): are there other considerations for paused or blocked | 826 // TODO(eroman): are there other considerations for paused or blocked |
827 // requests? | 827 // requests? |
828 | 828 |
829 URLRequest* request = i->second; | 829 net::URLRequest* request = i->second; |
830 InsertIntoResourceQueue(request, *InfoForRequest(request)); | 830 InsertIntoResourceQueue(request, *InfoForRequest(request)); |
831 } | 831 } |
832 | 832 |
833 bool ResourceDispatcherHost::WillSendData(int child_id, | 833 bool ResourceDispatcherHost::WillSendData(int child_id, |
834 int request_id) { | 834 int request_id) { |
835 PendingRequestList::iterator i = pending_requests_.find( | 835 PendingRequestList::iterator i = pending_requests_.find( |
836 GlobalRequestID(child_id, request_id)); | 836 GlobalRequestID(child_id, request_id)); |
837 if (i == pending_requests_.end()) { | 837 if (i == pending_requests_.end()) { |
838 NOTREACHED() << "WillSendData for invalid request"; | 838 NOTREACHED() << "WillSendData for invalid request"; |
839 return false; | 839 return false; |
(...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
920 } | 920 } |
921 } | 921 } |
922 | 922 |
923 // Remove matches. | 923 // Remove matches. |
924 for (size_t i = 0; i < matching_requests.size(); ++i) { | 924 for (size_t i = 0; i < matching_requests.size(); ++i) { |
925 PendingRequestList::iterator iter = | 925 PendingRequestList::iterator iter = |
926 pending_requests_.find(matching_requests[i]); | 926 pending_requests_.find(matching_requests[i]); |
927 // Although every matching request was in pending_requests_ when we built | 927 // Although every matching request was in pending_requests_ when we built |
928 // matching_requests, it is normal for a matching request to be not found | 928 // matching_requests, it is normal for a matching request to be not found |
929 // in pending_requests_ after we have removed some matching requests from | 929 // in pending_requests_ after we have removed some matching requests from |
930 // pending_requests_. For example, deleting a URLRequest that has | 930 // pending_requests_. For example, deleting a net::URLRequest that has |
931 // exclusive (write) access to an HTTP cache entry may unblock another | 931 // exclusive (write) access to an HTTP cache entry may unblock another |
932 // URLRequest that needs exclusive access to the same cache entry, and | 932 // net::URLRequest that needs exclusive access to the same cache entry, and |
933 // that URLRequest may complete and remove itself from pending_requests_. | 933 // that net::URLRequest may complete and remove itself from |
934 // So we need to check that iter is not equal to pending_requests_.end(). | 934 // pending_requests_. So we need to check that iter is not equal to |
| 935 // pending_requests_.end(). |
935 if (iter != pending_requests_.end()) | 936 if (iter != pending_requests_.end()) |
936 RemovePendingRequest(iter); | 937 RemovePendingRequest(iter); |
937 } | 938 } |
938 | 939 |
939 // Now deal with blocked requests if any. | 940 // Now deal with blocked requests if any. |
940 if (route_id != -1) { | 941 if (route_id != -1) { |
941 if (blocked_requests_map_.find(std::pair<int, int>(child_id, route_id)) != | 942 if (blocked_requests_map_.find(std::pair<int, int>(child_id, route_id)) != |
942 blocked_requests_map_.end()) { | 943 blocked_requests_map_.end()) { |
943 CancelBlockedRequestsForRoute(child_id, route_id); | 944 CancelBlockedRequestsForRoute(child_id, route_id); |
944 } | 945 } |
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
989 resource_queue_.RemoveRequest(iter->first); | 990 resource_queue_.RemoveRequest(iter->first); |
990 | 991 |
991 delete iter->second; | 992 delete iter->second; |
992 pending_requests_.erase(iter); | 993 pending_requests_.erase(iter); |
993 | 994 |
994 // If we have no more pending requests, then stop the load state monitor | 995 // If we have no more pending requests, then stop the load state monitor |
995 if (pending_requests_.empty()) | 996 if (pending_requests_.empty()) |
996 update_load_states_timer_.Stop(); | 997 update_load_states_timer_.Stop(); |
997 } | 998 } |
998 | 999 |
999 // URLRequest::Delegate ------------------------------------------------------- | 1000 // net::URLRequest::Delegate --------------------------------------------------- |
1000 | 1001 |
1001 void ResourceDispatcherHost::OnReceivedRedirect(URLRequest* request, | 1002 void ResourceDispatcherHost::OnReceivedRedirect(net::URLRequest* request, |
1002 const GURL& new_url, | 1003 const GURL& new_url, |
1003 bool* defer_redirect) { | 1004 bool* defer_redirect) { |
1004 VLOG(1) << "OnReceivedRedirect: " << request->url().spec(); | 1005 VLOG(1) << "OnReceivedRedirect: " << request->url().spec(); |
1005 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); | 1006 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); |
1006 | 1007 |
1007 DCHECK(request->status().is_success()); | 1008 DCHECK(request->status().is_success()); |
1008 | 1009 |
1009 if (info->process_type() != ChildProcessInfo::PLUGIN_PROCESS && | 1010 if (info->process_type() != ChildProcessInfo::PLUGIN_PROCESS && |
1010 !ChildProcessSecurityPolicy::GetInstance()-> | 1011 !ChildProcessSecurityPolicy::GetInstance()-> |
1011 CanRequestURL(info->child_id(), new_url)) { | 1012 CanRequestURL(info->child_id(), new_url)) { |
(...skipping 18 matching lines...) Expand all Loading... |
1030 scoped_refptr<ResourceResponse> response(new ResourceResponse); | 1031 scoped_refptr<ResourceResponse> response(new ResourceResponse); |
1031 PopulateResourceResponse(request, | 1032 PopulateResourceResponse(request, |
1032 info->replace_extension_localization_templates(), response); | 1033 info->replace_extension_localization_templates(), response); |
1033 if (!info->resource_handler()->OnRequestRedirected(info->request_id(), | 1034 if (!info->resource_handler()->OnRequestRedirected(info->request_id(), |
1034 new_url, | 1035 new_url, |
1035 response, defer_redirect)) | 1036 response, defer_redirect)) |
1036 CancelRequestInternal(request, false); | 1037 CancelRequestInternal(request, false); |
1037 } | 1038 } |
1038 | 1039 |
1039 void ResourceDispatcherHost::OnAuthRequired( | 1040 void ResourceDispatcherHost::OnAuthRequired( |
1040 URLRequest* request, | 1041 net::URLRequest* request, |
1041 net::AuthChallengeInfo* auth_info) { | 1042 net::AuthChallengeInfo* auth_info) { |
1042 // Create a login dialog on the UI thread to get authentication data, | 1043 // Create a login dialog on the UI thread to get authentication data, |
1043 // or pull from cache and continue on the IO thread. | 1044 // or pull from cache and continue on the IO thread. |
1044 // TODO(mpcomplete): We should block the parent tab while waiting for | 1045 // TODO(mpcomplete): We should block the parent tab while waiting for |
1045 // authentication. | 1046 // authentication. |
1046 // That would also solve the problem of the URLRequest being cancelled | 1047 // That would also solve the problem of the net::URLRequest being cancelled |
1047 // before we receive authentication. | 1048 // before we receive authentication. |
1048 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); | 1049 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); |
1049 DCHECK(!info->login_handler()) << | 1050 DCHECK(!info->login_handler()) << |
1050 "OnAuthRequired called with login_handler pending"; | 1051 "OnAuthRequired called with login_handler pending"; |
1051 info->set_login_handler(CreateLoginPrompt(auth_info, request)); | 1052 info->set_login_handler(CreateLoginPrompt(auth_info, request)); |
1052 } | 1053 } |
1053 | 1054 |
1054 void ResourceDispatcherHost::OnCertificateRequested( | 1055 void ResourceDispatcherHost::OnCertificateRequested( |
1055 URLRequest* request, | 1056 net::URLRequest* request, |
1056 net::SSLCertRequestInfo* cert_request_info) { | 1057 net::SSLCertRequestInfo* cert_request_info) { |
1057 DCHECK(request); | 1058 DCHECK(request); |
1058 | 1059 |
1059 if (cert_request_info->client_certs.empty()) { | 1060 if (cert_request_info->client_certs.empty()) { |
1060 // No need to query the user if there are no certs to choose from. | 1061 // No need to query the user if there are no certs to choose from. |
1061 request->ContinueWithCertificate(NULL); | 1062 request->ContinueWithCertificate(NULL); |
1062 return; | 1063 return; |
1063 } | 1064 } |
1064 | 1065 |
1065 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); | 1066 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); |
1066 DCHECK(!info->ssl_client_auth_handler()) << | 1067 DCHECK(!info->ssl_client_auth_handler()) << |
1067 "OnCertificateRequested called with ssl_client_auth_handler pending"; | 1068 "OnCertificateRequested called with ssl_client_auth_handler pending"; |
1068 info->set_ssl_client_auth_handler( | 1069 info->set_ssl_client_auth_handler( |
1069 new SSLClientAuthHandler(request, cert_request_info)); | 1070 new SSLClientAuthHandler(request, cert_request_info)); |
1070 info->ssl_client_auth_handler()->SelectCertificate(); | 1071 info->ssl_client_auth_handler()->SelectCertificate(); |
1071 } | 1072 } |
1072 | 1073 |
1073 void ResourceDispatcherHost::OnSSLCertificateError( | 1074 void ResourceDispatcherHost::OnSSLCertificateError( |
1074 URLRequest* request, | 1075 net::URLRequest* request, |
1075 int cert_error, | 1076 int cert_error, |
1076 net::X509Certificate* cert) { | 1077 net::X509Certificate* cert) { |
1077 DCHECK(request); | 1078 DCHECK(request); |
1078 SSLManager::OnSSLCertificateError(this, request, cert_error, cert); | 1079 SSLManager::OnSSLCertificateError(this, request, cert_error, cert); |
1079 } | 1080 } |
1080 | 1081 |
1081 void ResourceDispatcherHost::OnSetCookie(URLRequest* request, | 1082 void ResourceDispatcherHost::OnSetCookie(net::URLRequest* request, |
1082 const std::string& cookie_line, | 1083 const std::string& cookie_line, |
1083 const net::CookieOptions& options, | 1084 const net::CookieOptions& options, |
1084 bool blocked_by_policy) { | 1085 bool blocked_by_policy) { |
1085 VLOG(1) << "OnSetCookie: " << request->url().spec(); | 1086 VLOG(1) << "OnSetCookie: " << request->url().spec(); |
1086 | 1087 |
1087 int render_process_id, render_view_id; | 1088 int render_process_id, render_view_id; |
1088 if (!RenderViewForRequest(request, &render_process_id, &render_view_id)) | 1089 if (!RenderViewForRequest(request, &render_process_id, &render_view_id)) |
1089 return; | 1090 return; |
1090 | 1091 |
1091 CallRenderViewHostContentSettingsDelegate( | 1092 CallRenderViewHostContentSettingsDelegate( |
1092 render_process_id, render_view_id, | 1093 render_process_id, render_view_id, |
1093 &RenderViewHostDelegate::ContentSettings::OnCookieAccessed, | 1094 &RenderViewHostDelegate::ContentSettings::OnCookieAccessed, |
1094 request->url(), cookie_line, options, blocked_by_policy); | 1095 request->url(), cookie_line, options, blocked_by_policy); |
1095 } | 1096 } |
1096 | 1097 |
1097 void ResourceDispatcherHost::OnResponseStarted(URLRequest* request) { | 1098 void ResourceDispatcherHost::OnResponseStarted(net::URLRequest* request) { |
1098 VLOG(1) << "OnResponseStarted: " << request->url().spec(); | 1099 VLOG(1) << "OnResponseStarted: " << request->url().spec(); |
1099 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); | 1100 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); |
1100 if (PauseRequestIfNeeded(info)) { | 1101 if (PauseRequestIfNeeded(info)) { |
1101 VLOG(1) << "OnResponseStarted pausing: " << request->url().spec(); | 1102 VLOG(1) << "OnResponseStarted pausing: " << request->url().spec(); |
1102 return; | 1103 return; |
1103 } | 1104 } |
1104 | 1105 |
1105 if (request->status().is_success()) { | 1106 if (request->status().is_success()) { |
1106 // We want to send a final upload progress message prior to sending | 1107 // We want to send a final upload progress message prior to sending |
1107 // the response complete message even if we're waiting for an ack to | 1108 // the response complete message even if we're waiting for an ack to |
(...skipping 10 matching lines...) Expand all Loading... |
1118 return; | 1119 return; |
1119 } | 1120 } |
1120 | 1121 |
1121 StartReading(request); | 1122 StartReading(request); |
1122 } | 1123 } |
1123 } else { | 1124 } else { |
1124 OnResponseCompleted(request); | 1125 OnResponseCompleted(request); |
1125 } | 1126 } |
1126 } | 1127 } |
1127 | 1128 |
1128 bool ResourceDispatcherHost::CompleteResponseStarted(URLRequest* request) { | 1129 bool ResourceDispatcherHost::CompleteResponseStarted(net::URLRequest* request) { |
1129 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); | 1130 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); |
1130 | 1131 |
1131 scoped_refptr<ResourceResponse> response(new ResourceResponse); | 1132 scoped_refptr<ResourceResponse> response(new ResourceResponse); |
1132 PopulateResourceResponse(request, | 1133 PopulateResourceResponse(request, |
1133 info->replace_extension_localization_templates(), response); | 1134 info->replace_extension_localization_templates(), response); |
1134 | 1135 |
1135 if (request->ssl_info().cert) { | 1136 if (request->ssl_info().cert) { |
1136 int cert_id = | 1137 int cert_id = |
1137 CertStore::GetSharedInstance()->StoreCert(request->ssl_info().cert, | 1138 CertStore::GetSharedInstance()->StoreCert(request->ssl_info().cert, |
1138 info->child_id()); | 1139 info->child_id()); |
(...skipping 23 matching lines...) Expand all Loading... |
1162 if (i == pending_requests_.end()) { | 1163 if (i == pending_requests_.end()) { |
1163 // We probably want to remove this warning eventually, but I wanted to be | 1164 // We probably want to remove this warning eventually, but I wanted to be |
1164 // able to notice when this happens during initial development since it | 1165 // able to notice when this happens during initial development since it |
1165 // should be rare and may indicate a bug. | 1166 // should be rare and may indicate a bug. |
1166 DLOG(WARNING) << "Canceling a request that wasn't found"; | 1167 DLOG(WARNING) << "Canceling a request that wasn't found"; |
1167 return; | 1168 return; |
1168 } | 1169 } |
1169 CancelRequestInternal(i->second, from_renderer); | 1170 CancelRequestInternal(i->second, from_renderer); |
1170 } | 1171 } |
1171 | 1172 |
1172 void ResourceDispatcherHost::CancelRequestInternal(URLRequest* request, | 1173 void ResourceDispatcherHost::CancelRequestInternal(net::URLRequest* request, |
1173 bool from_renderer) { | 1174 bool from_renderer) { |
1174 VLOG(1) << "CancelRequest: " << request->url().spec(); | 1175 VLOG(1) << "CancelRequest: " << request->url().spec(); |
1175 | 1176 |
1176 // WebKit will send us a cancel for downloads since it no longer handles them. | 1177 // WebKit will send us a cancel for downloads since it no longer handles them. |
1177 // In this case, ignore the cancel since we handle downloads in the browser. | 1178 // In this case, ignore the cancel since we handle downloads in the browser. |
1178 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); | 1179 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); |
1179 if (!from_renderer || !info->is_download()) { | 1180 if (!from_renderer || !info->is_download()) { |
1180 if (info->login_handler()) { | 1181 if (info->login_handler()) { |
1181 info->login_handler()->OnRequestCancelled(); | 1182 info->login_handler()->OnRequestCancelled(); |
1182 info->set_login_handler(NULL); | 1183 info->set_login_handler(NULL); |
(...skipping 28 matching lines...) Expand all Loading... |
1211 if (new_cost == 0) | 1212 if (new_cost == 0) |
1212 outstanding_requests_memory_cost_map_.erase(prev_entry); | 1213 outstanding_requests_memory_cost_map_.erase(prev_entry); |
1213 else | 1214 else |
1214 outstanding_requests_memory_cost_map_[child_id] = new_cost; | 1215 outstanding_requests_memory_cost_map_[child_id] = new_cost; |
1215 | 1216 |
1216 return new_cost; | 1217 return new_cost; |
1217 } | 1218 } |
1218 | 1219 |
1219 // static | 1220 // static |
1220 int ResourceDispatcherHost::CalculateApproximateMemoryCost( | 1221 int ResourceDispatcherHost::CalculateApproximateMemoryCost( |
1221 URLRequest* request) { | 1222 net::URLRequest* request) { |
1222 // The following fields should be a minor size contribution (experimentally | 1223 // The following fields should be a minor size contribution (experimentally |
1223 // on the order of 100). However since they are variable length, it could | 1224 // on the order of 100). However since they are variable length, it could |
1224 // in theory be a sizeable contribution. | 1225 // in theory be a sizeable contribution. |
1225 int strings_cost = request->extra_request_headers().ToString().size() + | 1226 int strings_cost = request->extra_request_headers().ToString().size() + |
1226 request->original_url().spec().size() + | 1227 request->original_url().spec().size() + |
1227 request->referrer().size() + | 1228 request->referrer().size() + |
1228 request->method().size(); | 1229 request->method().size(); |
1229 | 1230 |
1230 int upload_cost = 0; | 1231 int upload_cost = 0; |
1231 | 1232 |
(...skipping 14 matching lines...) Expand all Loading... |
1246 } | 1247 } |
1247 } | 1248 } |
1248 } | 1249 } |
1249 #endif | 1250 #endif |
1250 | 1251 |
1251 // Note that this expression will typically be dominated by: | 1252 // Note that this expression will typically be dominated by: |
1252 // |kAvgBytesPerOutstandingRequest|. | 1253 // |kAvgBytesPerOutstandingRequest|. |
1253 return kAvgBytesPerOutstandingRequest + strings_cost + upload_cost; | 1254 return kAvgBytesPerOutstandingRequest + strings_cost + upload_cost; |
1254 } | 1255 } |
1255 | 1256 |
1256 void ResourceDispatcherHost::BeginRequestInternal(URLRequest* request) { | 1257 void ResourceDispatcherHost::BeginRequestInternal(net::URLRequest* request) { |
1257 DCHECK(!request->is_pending()); | 1258 DCHECK(!request->is_pending()); |
1258 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); | 1259 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); |
1259 | 1260 |
1260 // Add the memory estimate that starting this request will consume. | 1261 // Add the memory estimate that starting this request will consume. |
1261 info->set_memory_cost(CalculateApproximateMemoryCost(request)); | 1262 info->set_memory_cost(CalculateApproximateMemoryCost(request)); |
1262 int memory_cost = IncrementOutstandingRequestsMemoryCost(info->memory_cost(), | 1263 int memory_cost = IncrementOutstandingRequestsMemoryCost(info->memory_cost(), |
1263 info->child_id()); | 1264 info->child_id()); |
1264 | 1265 |
1265 // If enqueing/starting this request will exceed our per-process memory | 1266 // If enqueing/starting this request will exceed our per-process memory |
1266 // bound, abort it right away. | 1267 // bound, abort it right away. |
1267 if (memory_cost > max_outstanding_requests_cost_per_process_) { | 1268 if (memory_cost > max_outstanding_requests_cost_per_process_) { |
1268 // We call "SimulateError()" as a way of setting the URLRequest's | 1269 // We call "SimulateError()" as a way of setting the net::URLRequest's |
1269 // status -- it has no effect beyond this, since the request hasn't started. | 1270 // status -- it has no effect beyond this, since the request hasn't started. |
1270 request->SimulateError(net::ERR_INSUFFICIENT_RESOURCES); | 1271 request->SimulateError(net::ERR_INSUFFICIENT_RESOURCES); |
1271 | 1272 |
1272 // TODO(eroman): this is kinda funky -- we insert the unstarted request into | 1273 // TODO(eroman): this is kinda funky -- we insert the unstarted request into |
1273 // |pending_requests_| simply to please OnResponseCompleted(). | 1274 // |pending_requests_| simply to please OnResponseCompleted(). |
1274 GlobalRequestID global_id(info->child_id(), info->request_id()); | 1275 GlobalRequestID global_id(info->child_id(), info->request_id()); |
1275 pending_requests_[global_id] = request; | 1276 pending_requests_[global_id] = request; |
1276 OnResponseCompleted(request); | 1277 OnResponseCompleted(request); |
1277 return; | 1278 return; |
1278 } | 1279 } |
1279 | 1280 |
1280 std::pair<int, int> pair_id(info->child_id(), info->route_id()); | 1281 std::pair<int, int> pair_id(info->child_id(), info->route_id()); |
1281 BlockedRequestMap::const_iterator iter = blocked_requests_map_.find(pair_id); | 1282 BlockedRequestMap::const_iterator iter = blocked_requests_map_.find(pair_id); |
1282 if (iter != blocked_requests_map_.end()) { | 1283 if (iter != blocked_requests_map_.end()) { |
1283 // The request should be blocked. | 1284 // The request should be blocked. |
1284 iter->second->push_back(request); | 1285 iter->second->push_back(request); |
1285 return; | 1286 return; |
1286 } | 1287 } |
1287 | 1288 |
1288 GlobalRequestID global_id(info->child_id(), info->request_id()); | 1289 GlobalRequestID global_id(info->child_id(), info->request_id()); |
1289 pending_requests_[global_id] = request; | 1290 pending_requests_[global_id] = request; |
1290 | 1291 |
1291 // Give the resource handlers an opportunity to delay the URLRequest from | 1292 // Give the resource handlers an opportunity to delay the net::URLRequest from |
1292 // being started. | 1293 // being started. |
1293 // | 1294 // |
1294 // There are three cases: | 1295 // There are three cases: |
1295 // | 1296 // |
1296 // (1) if OnWillStart() returns false, the request is cancelled (regardless | 1297 // (1) if OnWillStart() returns false, the request is cancelled (regardless |
1297 // of whether |defer_start| was set). | 1298 // of whether |defer_start| was set). |
1298 // (2) If |defer_start| was set to true, then the request is not added | 1299 // (2) If |defer_start| was set to true, then the request is not added |
1299 // into the resource queue, and will only be started in response to | 1300 // into the resource queue, and will only be started in response to |
1300 // calling StartDeferredRequest(). | 1301 // calling StartDeferredRequest(). |
1301 // (3) If |defer_start| is not set, then the request is inserted into | 1302 // (3) If |defer_start| is not set, then the request is inserted into |
1302 // the resource_queue_ (which may pause it further, or start it). | 1303 // the resource_queue_ (which may pause it further, or start it). |
1303 bool defer_start = false; | 1304 bool defer_start = false; |
1304 if (!info->resource_handler()->OnWillStart( | 1305 if (!info->resource_handler()->OnWillStart( |
1305 info->request_id(), request->url(), | 1306 info->request_id(), request->url(), |
1306 &defer_start)) { | 1307 &defer_start)) { |
1307 CancelRequestInternal(request, false); | 1308 CancelRequestInternal(request, false); |
1308 return; | 1309 return; |
1309 } | 1310 } |
1310 | 1311 |
1311 if (!defer_start) | 1312 if (!defer_start) |
1312 InsertIntoResourceQueue(request, *info); | 1313 InsertIntoResourceQueue(request, *info); |
1313 } | 1314 } |
1314 | 1315 |
1315 void ResourceDispatcherHost::InsertIntoResourceQueue( | 1316 void ResourceDispatcherHost::InsertIntoResourceQueue( |
1316 URLRequest* request, | 1317 net::URLRequest* request, |
1317 const ResourceDispatcherHostRequestInfo& request_info) { | 1318 const ResourceDispatcherHostRequestInfo& request_info) { |
1318 resource_queue_.AddRequest(request, request_info); | 1319 resource_queue_.AddRequest(request, request_info); |
1319 | 1320 |
1320 // Make sure we have the load state monitor running | 1321 // Make sure we have the load state monitor running |
1321 if (!update_load_states_timer_.IsRunning()) { | 1322 if (!update_load_states_timer_.IsRunning()) { |
1322 update_load_states_timer_.Start( | 1323 update_load_states_timer_.Start( |
1323 TimeDelta::FromMilliseconds(kUpdateLoadStatesIntervalMsec), | 1324 TimeDelta::FromMilliseconds(kUpdateLoadStatesIntervalMsec), |
1324 this, &ResourceDispatcherHost::UpdateLoadStates); | 1325 this, &ResourceDispatcherHost::UpdateLoadStates); |
1325 } | 1326 } |
1326 } | 1327 } |
1327 | 1328 |
1328 bool ResourceDispatcherHost::PauseRequestIfNeeded( | 1329 bool ResourceDispatcherHost::PauseRequestIfNeeded( |
1329 ResourceDispatcherHostRequestInfo* info) { | 1330 ResourceDispatcherHostRequestInfo* info) { |
1330 if (info->pause_count() > 0) | 1331 if (info->pause_count() > 0) |
1331 info->set_is_paused(true); | 1332 info->set_is_paused(true); |
1332 return info->is_paused(); | 1333 return info->is_paused(); |
1333 } | 1334 } |
1334 | 1335 |
1335 void ResourceDispatcherHost::ResumeRequest(const GlobalRequestID& request_id) { | 1336 void ResourceDispatcherHost::ResumeRequest(const GlobalRequestID& request_id) { |
1336 PendingRequestList::iterator i = pending_requests_.find(request_id); | 1337 PendingRequestList::iterator i = pending_requests_.find(request_id); |
1337 if (i == pending_requests_.end()) // The request may have been destroyed | 1338 if (i == pending_requests_.end()) // The request may have been destroyed |
1338 return; | 1339 return; |
1339 | 1340 |
1340 URLRequest* request = i->second; | 1341 net::URLRequest* request = i->second; |
1341 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); | 1342 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); |
1342 if (!info->is_paused()) | 1343 if (!info->is_paused()) |
1343 return; | 1344 return; |
1344 | 1345 |
1345 VLOG(1) << "Resuming: " << i->second->url().spec(); | 1346 VLOG(1) << "Resuming: " << i->second->url().spec(); |
1346 | 1347 |
1347 info->set_is_paused(false); | 1348 info->set_is_paused(false); |
1348 | 1349 |
1349 if (info->called_on_response_started()) { | 1350 if (info->called_on_response_started()) { |
1350 if (info->has_started_reading()) { | 1351 if (info->has_started_reading()) { |
1351 OnReadCompleted(i->second, info->paused_read_bytes()); | 1352 OnReadCompleted(i->second, info->paused_read_bytes()); |
1352 } else { | 1353 } else { |
1353 StartReading(request); | 1354 StartReading(request); |
1354 } | 1355 } |
1355 } else { | 1356 } else { |
1356 OnResponseStarted(i->second); | 1357 OnResponseStarted(i->second); |
1357 } | 1358 } |
1358 } | 1359 } |
1359 | 1360 |
1360 void ResourceDispatcherHost::StartReading(URLRequest* request) { | 1361 void ResourceDispatcherHost::StartReading(net::URLRequest* request) { |
1361 // Start reading. | 1362 // Start reading. |
1362 int bytes_read = 0; | 1363 int bytes_read = 0; |
1363 if (Read(request, &bytes_read)) { | 1364 if (Read(request, &bytes_read)) { |
1364 OnReadCompleted(request, bytes_read); | 1365 OnReadCompleted(request, bytes_read); |
1365 } else if (!request->status().is_io_pending()) { | 1366 } else if (!request->status().is_io_pending()) { |
1366 DCHECK(!InfoForRequest(request)->is_paused()); | 1367 DCHECK(!InfoForRequest(request)->is_paused()); |
1367 // If the error is not an IO pending, then we're done reading. | 1368 // If the error is not an IO pending, then we're done reading. |
1368 OnResponseCompleted(request); | 1369 OnResponseCompleted(request); |
1369 } | 1370 } |
1370 } | 1371 } |
1371 | 1372 |
1372 bool ResourceDispatcherHost::Read(URLRequest* request, int* bytes_read) { | 1373 bool ResourceDispatcherHost::Read(net::URLRequest* request, int* bytes_read) { |
1373 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); | 1374 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); |
1374 DCHECK(!info->is_paused()); | 1375 DCHECK(!info->is_paused()); |
1375 | 1376 |
1376 net::IOBuffer* buf; | 1377 net::IOBuffer* buf; |
1377 int buf_size; | 1378 int buf_size; |
1378 if (!info->resource_handler()->OnWillRead(info->request_id(), | 1379 if (!info->resource_handler()->OnWillRead(info->request_id(), |
1379 &buf, &buf_size, -1)) { | 1380 &buf, &buf_size, -1)) { |
1380 return false; | 1381 return false; |
1381 } | 1382 } |
1382 | 1383 |
1383 DCHECK(buf); | 1384 DCHECK(buf); |
1384 DCHECK(buf_size > 0); | 1385 DCHECK(buf_size > 0); |
1385 | 1386 |
1386 info->set_has_started_reading(true); | 1387 info->set_has_started_reading(true); |
1387 return request->Read(buf, buf_size, bytes_read); | 1388 return request->Read(buf, buf_size, bytes_read); |
1388 } | 1389 } |
1389 | 1390 |
1390 void ResourceDispatcherHost::OnReadCompleted(URLRequest* request, | 1391 void ResourceDispatcherHost::OnReadCompleted(net::URLRequest* request, |
1391 int bytes_read) { | 1392 int bytes_read) { |
1392 DCHECK(request); | 1393 DCHECK(request); |
1393 VLOG(1) << "OnReadCompleted: " << request->url().spec(); | 1394 VLOG(1) << "OnReadCompleted: " << request->url().spec(); |
1394 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); | 1395 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); |
1395 | 1396 |
1396 // OnReadCompleted can be called without Read (e.g., for chrome:// URLs). | 1397 // OnReadCompleted can be called without Read (e.g., for chrome:// URLs). |
1397 // Make sure we know that a read has begun. | 1398 // Make sure we know that a read has begun. |
1398 info->set_has_started_reading(true); | 1399 info->set_has_started_reading(true); |
1399 | 1400 |
1400 if (PauseRequestIfNeeded(info)) { | 1401 if (PauseRequestIfNeeded(info)) { |
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1433 << request->url().spec(); | 1434 << request->url().spec(); |
1434 return; | 1435 return; |
1435 } | 1436 } |
1436 | 1437 |
1437 // If the status is not IO pending then we've either finished (success) or we | 1438 // If the status is not IO pending then we've either finished (success) or we |
1438 // had an error. Either way, we're done! | 1439 // had an error. Either way, we're done! |
1439 if (!request->status().is_io_pending()) | 1440 if (!request->status().is_io_pending()) |
1440 OnResponseCompleted(request); | 1441 OnResponseCompleted(request); |
1441 } | 1442 } |
1442 | 1443 |
1443 bool ResourceDispatcherHost::CompleteRead(URLRequest* request, | 1444 bool ResourceDispatcherHost::CompleteRead(net::URLRequest* request, |
1444 int* bytes_read) { | 1445 int* bytes_read) { |
1445 if (!request || !request->status().is_success()) { | 1446 if (!request || !request->status().is_success()) { |
1446 NOTREACHED(); | 1447 NOTREACHED(); |
1447 return false; | 1448 return false; |
1448 } | 1449 } |
1449 | 1450 |
1450 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); | 1451 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); |
1451 if (!info->resource_handler()->OnReadCompleted(info->request_id(), | 1452 if (!info->resource_handler()->OnReadCompleted(info->request_id(), |
1452 bytes_read)) { | 1453 bytes_read)) { |
1453 CancelRequestInternal(request, false); | 1454 CancelRequestInternal(request, false); |
1454 return false; | 1455 return false; |
1455 } | 1456 } |
1456 | 1457 |
1457 return *bytes_read != 0; | 1458 return *bytes_read != 0; |
1458 } | 1459 } |
1459 | 1460 |
1460 void ResourceDispatcherHost::OnResponseCompleted(URLRequest* request) { | 1461 void ResourceDispatcherHost::OnResponseCompleted(net::URLRequest* request) { |
1461 VLOG(1) << "OnResponseCompleted: " << request->url().spec(); | 1462 VLOG(1) << "OnResponseCompleted: " << request->url().spec(); |
1462 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); | 1463 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); |
1463 | 1464 |
1464 // If the load for a main frame has failed, track it in a histogram, | 1465 // If the load for a main frame has failed, track it in a histogram, |
1465 // since it will probably cause the user to see an error page. | 1466 // since it will probably cause the user to see an error page. |
1466 if (!request->status().is_success() && | 1467 if (!request->status().is_success() && |
1467 info->resource_type() == ResourceType::MAIN_FRAME) { | 1468 info->resource_type() == ResourceType::MAIN_FRAME) { |
1468 UMA_HISTOGRAM_CUSTOM_ENUMERATION("Net.ErrorCodesForMainFrame", | 1469 UMA_HISTOGRAM_CUSTOM_ENUMERATION("Net.ErrorCodesForMainFrame", |
1469 -request->status().os_error(), | 1470 -request->status().os_error(), |
1470 GetAllNetErrorCodes()); | 1471 GetAllNetErrorCodes()); |
(...skipping 16 matching lines...) Expand all Loading... |
1487 | 1488 |
1488 // The request is complete so we can remove it. | 1489 // The request is complete so we can remove it. |
1489 RemovePendingRequest(info->child_id(), info->request_id()); | 1490 RemovePendingRequest(info->child_id(), info->request_id()); |
1490 } | 1491 } |
1491 // If the handler's OnResponseCompleted returns false, we are deferring the | 1492 // If the handler's OnResponseCompleted returns false, we are deferring the |
1492 // call until later. We will notify the world and clean up when we resume. | 1493 // call until later. We will notify the world and clean up when we resume. |
1493 } | 1494 } |
1494 | 1495 |
1495 // static | 1496 // static |
1496 ResourceDispatcherHostRequestInfo* ResourceDispatcherHost::InfoForRequest( | 1497 ResourceDispatcherHostRequestInfo* ResourceDispatcherHost::InfoForRequest( |
1497 URLRequest* request) { | 1498 net::URLRequest* request) { |
1498 // Avoid writing this function twice by casting the cosnt version. | 1499 // Avoid writing this function twice by casting the cosnt version. |
1499 const URLRequest* const_request = request; | 1500 const net::URLRequest* const_request = request; |
1500 return const_cast<ResourceDispatcherHostRequestInfo*>( | 1501 return const_cast<ResourceDispatcherHostRequestInfo*>( |
1501 InfoForRequest(const_request)); | 1502 InfoForRequest(const_request)); |
1502 } | 1503 } |
1503 | 1504 |
1504 // static | 1505 // static |
1505 const ResourceDispatcherHostRequestInfo* ResourceDispatcherHost::InfoForRequest( | 1506 const ResourceDispatcherHostRequestInfo* ResourceDispatcherHost::InfoForRequest( |
1506 const URLRequest* request) { | 1507 const net::URLRequest* request) { |
1507 const ResourceDispatcherHostRequestInfo* info = | 1508 const ResourceDispatcherHostRequestInfo* info = |
1508 static_cast<const ResourceDispatcherHostRequestInfo*>( | 1509 static_cast<const ResourceDispatcherHostRequestInfo*>( |
1509 request->GetUserData(NULL)); | 1510 request->GetUserData(NULL)); |
1510 DLOG_IF(WARNING, !info) << "Request doesn't seem to have our data"; | 1511 DLOG_IF(WARNING, !info) << "Request doesn't seem to have our data"; |
1511 return info; | 1512 return info; |
1512 } | 1513 } |
1513 | 1514 |
1514 // static | 1515 // static |
1515 bool ResourceDispatcherHost::RenderViewForRequest(const URLRequest* request, | 1516 bool ResourceDispatcherHost::RenderViewForRequest( |
1516 int* render_process_host_id, | 1517 const net::URLRequest* request, |
1517 int* render_view_host_id) { | 1518 int* render_process_host_id, |
| 1519 int* render_view_host_id) { |
1518 const ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); | 1520 const ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); |
1519 if (!info) { | 1521 if (!info) { |
1520 *render_process_host_id = -1; | 1522 *render_process_host_id = -1; |
1521 *render_view_host_id = -1; | 1523 *render_view_host_id = -1; |
1522 return false; | 1524 return false; |
1523 } | 1525 } |
1524 | 1526 |
1525 // If the request is from the worker process, find a tab that owns the worker. | 1527 // If the request is from the worker process, find a tab that owns the worker. |
1526 if (info->process_type() == ChildProcessInfo::WORKER_PROCESS) { | 1528 if (info->process_type() == ChildProcessInfo::WORKER_PROCESS) { |
1527 const WorkerProcessHost::WorkerInstance* worker_instance = | 1529 const WorkerProcessHost::WorkerInstance* worker_instance = |
(...skipping 18 matching lines...) Expand all Loading... |
1546 } | 1548 } |
1547 | 1549 |
1548 void ResourceDispatcherHost::AddObserver(Observer* obs) { | 1550 void ResourceDispatcherHost::AddObserver(Observer* obs) { |
1549 observer_list_.AddObserver(obs); | 1551 observer_list_.AddObserver(obs); |
1550 } | 1552 } |
1551 | 1553 |
1552 void ResourceDispatcherHost::RemoveObserver(Observer* obs) { | 1554 void ResourceDispatcherHost::RemoveObserver(Observer* obs) { |
1553 observer_list_.RemoveObserver(obs); | 1555 observer_list_.RemoveObserver(obs); |
1554 } | 1556 } |
1555 | 1557 |
1556 URLRequest* ResourceDispatcherHost::GetURLRequest( | 1558 net::URLRequest* ResourceDispatcherHost::GetURLRequest( |
1557 const GlobalRequestID& request_id) const { | 1559 const GlobalRequestID& request_id) const { |
1558 // This should be running in the IO loop. | 1560 // This should be running in the IO loop. |
1559 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 1561 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
1560 | 1562 |
1561 PendingRequestList::const_iterator i = pending_requests_.find(request_id); | 1563 PendingRequestList::const_iterator i = pending_requests_.find(request_id); |
1562 if (i == pending_requests_.end()) | 1564 if (i == pending_requests_.end()) |
1563 return NULL; | 1565 return NULL; |
1564 | 1566 |
1565 return i->second; | 1567 return i->second; |
1566 } | 1568 } |
1567 | 1569 |
1568 static int GetCertID(URLRequest* request, int child_id) { | 1570 static int GetCertID(net::URLRequest* request, int child_id) { |
1569 if (request->ssl_info().cert) { | 1571 if (request->ssl_info().cert) { |
1570 return CertStore::GetSharedInstance()->StoreCert(request->ssl_info().cert, | 1572 return CertStore::GetSharedInstance()->StoreCert(request->ssl_info().cert, |
1571 child_id); | 1573 child_id); |
1572 } | 1574 } |
1573 // If there is no SSL info attached to this request, we must either be a non | 1575 // If there is no SSL info attached to this request, we must either be a non |
1574 // secure request, or the request has been canceled or failed (before the SSL | 1576 // secure request, or the request has been canceled or failed (before the SSL |
1575 // info was populated), or the response is an error (we have seen 403, 404, | 1577 // info was populated), or the response is an error (we have seen 403, 404, |
1576 // and 501) made up by the proxy. | 1578 // and 501) made up by the proxy. |
1577 DCHECK(!request->url().SchemeIsSecure() || | 1579 DCHECK(!request->url().SchemeIsSecure() || |
1578 (request->status().status() == URLRequestStatus::CANCELED) || | 1580 (request->status().status() == URLRequestStatus::CANCELED) || |
1579 (request->status().status() == URLRequestStatus::FAILED) || | 1581 (request->status().status() == URLRequestStatus::FAILED) || |
1580 ((request->response_headers()->response_code() >= 400) && | 1582 ((request->response_headers()->response_code() >= 400) && |
1581 (request->response_headers()->response_code() <= 599))); | 1583 (request->response_headers()->response_code() <= 599))); |
1582 return 0; | 1584 return 0; |
1583 } | 1585 } |
1584 | 1586 |
1585 void ResourceDispatcherHost::NotifyResponseStarted(URLRequest* request, | 1587 void ResourceDispatcherHost::NotifyResponseStarted(net::URLRequest* request, |
1586 int child_id) { | 1588 int child_id) { |
1587 // Notify the observers on the IO thread. | 1589 // Notify the observers on the IO thread. |
1588 FOR_EACH_OBSERVER(Observer, observer_list_, OnRequestStarted(this, request)); | 1590 FOR_EACH_OBSERVER(Observer, observer_list_, OnRequestStarted(this, request)); |
1589 | 1591 |
1590 int render_process_id, render_view_id; | 1592 int render_process_id, render_view_id; |
1591 if (!RenderViewForRequest(request, &render_process_id, &render_view_id)) | 1593 if (!RenderViewForRequest(request, &render_process_id, &render_view_id)) |
1592 return; | 1594 return; |
1593 | 1595 |
1594 // Notify the observers on the UI thread. | 1596 // Notify the observers on the UI thread. |
1595 CallRenderViewHostResourceDelegate( | 1597 CallRenderViewHostResourceDelegate( |
1596 render_process_id, render_view_id, | 1598 render_process_id, render_view_id, |
1597 &RenderViewHostDelegate::Resource::DidStartReceivingResourceResponse, | 1599 &RenderViewHostDelegate::Resource::DidStartReceivingResourceResponse, |
1598 ResourceRequestDetails(request, GetCertID(request, child_id))); | 1600 ResourceRequestDetails(request, GetCertID(request, child_id))); |
1599 } | 1601 } |
1600 | 1602 |
1601 void ResourceDispatcherHost::NotifyResponseCompleted(URLRequest* request, | 1603 void ResourceDispatcherHost::NotifyResponseCompleted(net::URLRequest* request, |
1602 int child_id) { | 1604 int child_id) { |
1603 // Notify the observers on the IO thread. | 1605 // Notify the observers on the IO thread. |
1604 FOR_EACH_OBSERVER(Observer, observer_list_, | 1606 FOR_EACH_OBSERVER(Observer, observer_list_, |
1605 OnResponseCompleted(this, request)); | 1607 OnResponseCompleted(this, request)); |
1606 } | 1608 } |
1607 | 1609 |
1608 void ResourceDispatcherHost::NotifyReceivedRedirect(URLRequest* request, | 1610 void ResourceDispatcherHost::NotifyReceivedRedirect(net::URLRequest* request, |
1609 int child_id, | 1611 int child_id, |
1610 const GURL& new_url) { | 1612 const GURL& new_url) { |
1611 // Notify the observers on the IO thread. | 1613 // Notify the observers on the IO thread. |
1612 FOR_EACH_OBSERVER(Observer, observer_list_, | 1614 FOR_EACH_OBSERVER(Observer, observer_list_, |
1613 OnReceivedRedirect(this, request, new_url)); | 1615 OnReceivedRedirect(this, request, new_url)); |
1614 | 1616 |
1615 int render_process_id, render_view_id; | 1617 int render_process_id, render_view_id; |
1616 if (!RenderViewForRequest(request, &render_process_id, &render_view_id)) | 1618 if (!RenderViewForRequest(request, &render_process_id, &render_view_id)) |
1617 return; | 1619 return; |
1618 | 1620 |
(...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1680 // Populate this map with load state changes, and then send them on to the UI | 1682 // Populate this map with load state changes, and then send them on to the UI |
1681 // thread where they can be passed along to the respective RVHs. | 1683 // thread where they can be passed along to the respective RVHs. |
1682 LoadInfoMap info_map; | 1684 LoadInfoMap info_map; |
1683 | 1685 |
1684 PendingRequestList::const_iterator i; | 1686 PendingRequestList::const_iterator i; |
1685 | 1687 |
1686 // Determine the largest upload size of all requests | 1688 // Determine the largest upload size of all requests |
1687 // in each View (good chance it's zero). | 1689 // in each View (good chance it's zero). |
1688 std::map<std::pair<int, int>, uint64> largest_upload_size; | 1690 std::map<std::pair<int, int>, uint64> largest_upload_size; |
1689 for (i = pending_requests_.begin(); i != pending_requests_.end(); ++i) { | 1691 for (i = pending_requests_.begin(); i != pending_requests_.end(); ++i) { |
1690 URLRequest* request = i->second; | 1692 net::URLRequest* request = i->second; |
1691 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); | 1693 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); |
1692 uint64 upload_size = info->upload_size(); | 1694 uint64 upload_size = info->upload_size(); |
1693 if (request->GetLoadState() != net::LOAD_STATE_SENDING_REQUEST) | 1695 if (request->GetLoadState() != net::LOAD_STATE_SENDING_REQUEST) |
1694 upload_size = 0; | 1696 upload_size = 0; |
1695 std::pair<int, int> key(info->child_id(), info->route_id()); | 1697 std::pair<int, int> key(info->child_id(), info->route_id()); |
1696 if (upload_size && largest_upload_size[key] < upload_size) | 1698 if (upload_size && largest_upload_size[key] < upload_size) |
1697 largest_upload_size[key] = upload_size; | 1699 largest_upload_size[key] = upload_size; |
1698 } | 1700 } |
1699 | 1701 |
1700 for (i = pending_requests_.begin(); i != pending_requests_.end(); ++i) { | 1702 for (i = pending_requests_.begin(); i != pending_requests_.end(); ++i) { |
1701 URLRequest* request = i->second; | 1703 net::URLRequest* request = i->second; |
1702 net::LoadState load_state = request->GetLoadState(); | 1704 net::LoadState load_state = request->GetLoadState(); |
1703 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); | 1705 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); |
1704 | 1706 |
1705 // We also poll for upload progress on this timer and send upload | 1707 // We also poll for upload progress on this timer and send upload |
1706 // progress ipc messages to the plugin process. | 1708 // progress ipc messages to the plugin process. |
1707 bool update_upload_progress = MaybeUpdateUploadProgress(info, request); | 1709 bool update_upload_progress = MaybeUpdateUploadProgress(info, request); |
1708 | 1710 |
1709 if (info->last_load_state() != load_state || update_upload_progress) { | 1711 if (info->last_load_state() != load_state || update_upload_progress) { |
1710 std::pair<int, int> key(info->child_id(), info->route_id()); | 1712 std::pair<int, int> key(info->child_id(), info->route_id()); |
1711 | 1713 |
(...skipping 28 matching lines...) Expand all Loading... |
1740 | 1742 |
1741 LoadInfoUpdateTask* task = new LoadInfoUpdateTask; | 1743 LoadInfoUpdateTask* task = new LoadInfoUpdateTask; |
1742 task->info_map.swap(info_map); | 1744 task->info_map.swap(info_map); |
1743 BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, task); | 1745 BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, task); |
1744 } | 1746 } |
1745 | 1747 |
1746 // Calls the ResourceHandler to send upload progress messages to the renderer. | 1748 // Calls the ResourceHandler to send upload progress messages to the renderer. |
1747 // Returns true iff an upload progress message should be sent to the UI thread. | 1749 // Returns true iff an upload progress message should be sent to the UI thread. |
1748 bool ResourceDispatcherHost::MaybeUpdateUploadProgress( | 1750 bool ResourceDispatcherHost::MaybeUpdateUploadProgress( |
1749 ResourceDispatcherHostRequestInfo *info, | 1751 ResourceDispatcherHostRequestInfo *info, |
1750 URLRequest *request) { | 1752 net::URLRequest *request) { |
1751 | 1753 |
1752 if (!info->upload_size() || info->waiting_for_upload_progress_ack()) | 1754 if (!info->upload_size() || info->waiting_for_upload_progress_ack()) |
1753 return false; | 1755 return false; |
1754 | 1756 |
1755 uint64 size = info->upload_size(); | 1757 uint64 size = info->upload_size(); |
1756 uint64 position = request->GetUploadProgress(); | 1758 uint64 position = request->GetUploadProgress(); |
1757 if (position == info->last_upload_position()) | 1759 if (position == info->last_upload_position()) |
1758 return false; // no progress made since last time | 1760 return false; // no progress made since last time |
1759 | 1761 |
1760 const uint64 kHalfPercentIncrements = 200; | 1762 const uint64 kHalfPercentIncrements = 200; |
(...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1811 | 1813 |
1812 BlockedRequestsList* requests = iter->second; | 1814 BlockedRequestsList* requests = iter->second; |
1813 | 1815 |
1814 // Removing the vector from the map unblocks any subsequent requests. | 1816 // Removing the vector from the map unblocks any subsequent requests. |
1815 blocked_requests_map_.erase(iter); | 1817 blocked_requests_map_.erase(iter); |
1816 | 1818 |
1817 for (BlockedRequestsList::iterator req_iter = requests->begin(); | 1819 for (BlockedRequestsList::iterator req_iter = requests->begin(); |
1818 req_iter != requests->end(); ++req_iter) { | 1820 req_iter != requests->end(); ++req_iter) { |
1819 // Remove the memory credit that we added when pushing the request onto | 1821 // Remove the memory credit that we added when pushing the request onto |
1820 // the blocked list. | 1822 // the blocked list. |
1821 URLRequest* request = *req_iter; | 1823 net::URLRequest* request = *req_iter; |
1822 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); | 1824 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); |
1823 IncrementOutstandingRequestsMemoryCost(-1 * info->memory_cost(), | 1825 IncrementOutstandingRequestsMemoryCost(-1 * info->memory_cost(), |
1824 info->child_id()); | 1826 info->child_id()); |
1825 if (cancel_requests) | 1827 if (cancel_requests) |
1826 delete request; | 1828 delete request; |
1827 else | 1829 else |
1828 BeginRequestInternal(request); | 1830 BeginRequestInternal(request); |
1829 } | 1831 } |
1830 | 1832 |
1831 delete requests; | 1833 delete requests; |
1832 } | 1834 } |
1833 | 1835 |
1834 bool ResourceDispatcherHost::IsValidRequest(URLRequest* request) { | 1836 bool ResourceDispatcherHost::IsValidRequest(net::URLRequest* request) { |
1835 if (!request) | 1837 if (!request) |
1836 return false; | 1838 return false; |
1837 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); | 1839 ResourceDispatcherHostRequestInfo* info = InfoForRequest(request); |
1838 return pending_requests_.find( | 1840 return pending_requests_.find( |
1839 GlobalRequestID(info->child_id(), info->request_id())) != | 1841 GlobalRequestID(info->child_id(), info->request_id())) != |
1840 pending_requests_.end(); | 1842 pending_requests_.end(); |
1841 } | 1843 } |
1842 | 1844 |
1843 // static | 1845 // static |
1844 bool ResourceDispatcherHost::IsResourceDispatcherHostMessage( | 1846 bool ResourceDispatcherHost::IsResourceDispatcherHostMessage( |
(...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1932 return is_prefetch_enabled_; | 1934 return is_prefetch_enabled_; |
1933 } | 1935 } |
1934 | 1936 |
1935 // static | 1937 // static |
1936 void ResourceDispatcherHost::set_is_prefetch_enabled(bool value) { | 1938 void ResourceDispatcherHost::set_is_prefetch_enabled(bool value) { |
1937 is_prefetch_enabled_ = value; | 1939 is_prefetch_enabled_ = value; |
1938 } | 1940 } |
1939 | 1941 |
1940 // static | 1942 // static |
1941 bool ResourceDispatcherHost::is_prefetch_enabled_ = false; | 1943 bool ResourceDispatcherHost::is_prefetch_enabled_ = false; |
OLD | NEW |