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 // 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 "content/browser/renderer_host/resource_dispatcher_host_impl.h" | 7 #include "content/browser/renderer_host/resource_dispatcher_host_impl.h" |
8 | 8 |
9 #include <set> | 9 #include <set> |
10 #include <vector> | 10 #include <vector> |
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
49 #include "content/common/ssl_status_serialization.h" | 49 #include "content/common/ssl_status_serialization.h" |
50 #include "content/common/view_messages.h" | 50 #include "content/common/view_messages.h" |
51 #include "content/public/browser/browser_thread.h" | 51 #include "content/public/browser/browser_thread.h" |
52 #include "content/public/browser/content_browser_client.h" | 52 #include "content/public/browser/content_browser_client.h" |
53 #include "content/public/browser/download_manager.h" | 53 #include "content/public/browser/download_manager.h" |
54 #include "content/public/browser/global_request_id.h" | 54 #include "content/public/browser/global_request_id.h" |
55 #include "content/public/browser/notification_service.h" | 55 #include "content/public/browser/notification_service.h" |
56 #include "content/public/browser/resource_dispatcher_host_delegate.h" | 56 #include "content/public/browser/resource_dispatcher_host_delegate.h" |
57 #include "content/public/browser/resource_request_details.h" | 57 #include "content/public/browser/resource_request_details.h" |
58 #include "content/public/browser/resource_throttle.h" | 58 #include "content/public/browser/resource_throttle.h" |
| 59 #include "content/public/browser/storage_partition.h" |
59 #include "content/public/browser/user_metrics.h" | 60 #include "content/public/browser/user_metrics.h" |
60 #include "content/public/common/content_switches.h" | 61 #include "content/public/common/content_switches.h" |
61 #include "content/public/common/process_type.h" | 62 #include "content/public/common/process_type.h" |
62 #include "content/public/common/url_constants.h" | 63 #include "content/public/common/url_constants.h" |
63 #include "net/base/auth.h" | 64 #include "net/base/auth.h" |
64 #include "net/base/cert_status_flags.h" | 65 #include "net/base/cert_status_flags.h" |
65 #include "net/base/load_flags.h" | 66 #include "net/base/load_flags.h" |
66 #include "net/base/mime_util.h" | 67 #include "net/base/mime_util.h" |
67 #include "net/base/net_errors.h" | 68 #include "net/base/net_errors.h" |
68 #include "net/base/registry_controlled_domains/registry_controlled_domain.h" | 69 #include "net/base/registry_controlled_domains/registry_controlled_domain.h" |
(...skipping 883 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
952 // transferred navigation case? | 953 // transferred navigation case? |
953 | 954 |
954 request->set_load_flags(load_flags); | 955 request->set_load_flags(load_flags); |
955 | 956 |
956 request->set_priority(DetermineRequestPriority(request_data.resource_type)); | 957 request->set_priority(DetermineRequestPriority(request_data.resource_type)); |
957 | 958 |
958 // Resolve elements from request_body and prepare upload data. | 959 // Resolve elements from request_body and prepare upload data. |
959 if (request_data.request_body) { | 960 if (request_data.request_body) { |
960 request->set_upload( | 961 request->set_upload( |
961 request_data.request_body->ResolveElementsAndCreateUploadData( | 962 request_data.request_body->ResolveElementsAndCreateUploadData( |
962 GetBlobStorageControllerForResourceContext(resource_context))); | 963 filter_->blob_storage_context()->controller())); |
963 } | 964 } |
964 | 965 |
965 bool allow_download = request_data.allow_download && | 966 bool allow_download = request_data.allow_download && |
966 ResourceType::IsFrame(request_data.resource_type); | 967 ResourceType::IsFrame(request_data.resource_type); |
967 | 968 |
968 // Make extra info and read footer (contains request ID). | 969 // Make extra info and read footer (contains request ID). |
969 ResourceRequestInfoImpl* extra_info = | 970 ResourceRequestInfoImpl* extra_info = |
970 new ResourceRequestInfoImpl( | 971 new ResourceRequestInfoImpl( |
971 process_type, | 972 process_type, |
972 child_id, | 973 child_id, |
973 route_id, | 974 route_id, |
974 request_data.origin_pid, | 975 request_data.origin_pid, |
975 request_id, | 976 request_id, |
976 request_data.is_main_frame, | 977 request_data.is_main_frame, |
977 request_data.frame_id, | 978 request_data.frame_id, |
978 request_data.parent_is_main_frame, | 979 request_data.parent_is_main_frame, |
979 request_data.parent_frame_id, | 980 request_data.parent_frame_id, |
980 request_data.resource_type, | 981 request_data.resource_type, |
981 request_data.transition_type, | 982 request_data.transition_type, |
982 false, // is download | 983 false, // is download |
983 allow_download, | 984 allow_download, |
984 request_data.has_user_gesture, | 985 request_data.has_user_gesture, |
985 request_data.referrer_policy, | 986 request_data.referrer_policy, |
986 resource_context); | 987 resource_context); |
987 extra_info->AssociateWithRequest(request); // Request takes ownership. | 988 extra_info->AssociateWithRequest(request); // Request takes ownership. |
988 | 989 |
989 if (request->url().SchemeIs(chrome::kBlobScheme)) { | 990 if (request->url().SchemeIs(chrome::kBlobScheme)) { |
990 // Hang on to a reference to ensure the blob is not released prior | 991 // Hang on to a reference to ensure the blob is not released prior |
991 // to the job being started. | 992 // to the job being started. |
992 webkit_blob::BlobStorageController* controller = | |
993 GetBlobStorageControllerForResourceContext(resource_context); | |
994 extra_info->set_requested_blob_data( | 993 extra_info->set_requested_blob_data( |
995 controller->GetBlobDataFromUrl(request->url())); | 994 filter_->blob_storage_context()->controller()-> |
| 995 GetBlobDataFromUrl(request->url())); |
996 } | 996 } |
997 | 997 |
998 // Have the appcache associate its extra info with the request. | 998 // Have the appcache associate its extra info with the request. |
999 appcache::AppCacheInterceptor::SetExtraRequestInfo( | 999 appcache::AppCacheInterceptor::SetExtraRequestInfo( |
1000 request, ResourceContext::GetAppCacheService(resource_context), child_id, | 1000 request, filter_->appcache_service(), child_id, |
1001 request_data.appcache_host_id, request_data.resource_type); | 1001 request_data.appcache_host_id, request_data.resource_type); |
1002 | 1002 |
1003 // Construct the IPC resource handler. | 1003 // Construct the IPC resource handler. |
1004 scoped_ptr<ResourceHandler> handler; | 1004 scoped_ptr<ResourceHandler> handler; |
1005 if (sync_result) { | 1005 if (sync_result) { |
1006 handler.reset(new SyncResourceHandler( | 1006 handler.reset(new SyncResourceHandler( |
1007 filter_, request, sync_result, this)); | 1007 filter_, request, sync_result, this)); |
1008 } else { | 1008 } else { |
1009 handler.reset(new AsyncResourceHandler( | 1009 handler.reset(new AsyncResourceHandler( |
1010 filter_, route_id, request, this)); | 1010 filter_, route_id, request, this)); |
(...skipping 710 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1721 | 1721 |
1722 return i->second.get(); | 1722 return i->second.get(); |
1723 } | 1723 } |
1724 | 1724 |
1725 ResourceLoader* ResourceDispatcherHostImpl::GetLoader(int child_id, | 1725 ResourceLoader* ResourceDispatcherHostImpl::GetLoader(int child_id, |
1726 int request_id) const { | 1726 int request_id) const { |
1727 return GetLoader(GlobalRequestID(child_id, request_id)); | 1727 return GetLoader(GlobalRequestID(child_id, request_id)); |
1728 } | 1728 } |
1729 | 1729 |
1730 } // namespace content | 1730 } // namespace content |
OLD | NEW |