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/loader/resource_dispatcher_host_impl.h" | 7 #include "content/browser/loader/resource_dispatcher_host_impl.h" |
8 | 8 |
9 #include <set> | 9 #include <set> |
10 #include <vector> | 10 #include <vector> |
(...skipping 22 matching lines...) Expand all Loading... |
33 #include "content/browser/loader/async_resource_handler.h" | 33 #include "content/browser/loader/async_resource_handler.h" |
34 #include "content/browser/loader/buffered_resource_handler.h" | 34 #include "content/browser/loader/buffered_resource_handler.h" |
35 #include "content/browser/loader/cross_site_resource_handler.h" | 35 #include "content/browser/loader/cross_site_resource_handler.h" |
36 #include "content/browser/loader/detachable_resource_handler.h" | 36 #include "content/browser/loader/detachable_resource_handler.h" |
37 #include "content/browser/loader/power_save_block_resource_throttle.h" | 37 #include "content/browser/loader/power_save_block_resource_throttle.h" |
38 #include "content/browser/loader/redirect_to_file_resource_handler.h" | 38 #include "content/browser/loader/redirect_to_file_resource_handler.h" |
39 #include "content/browser/loader/resource_message_filter.h" | 39 #include "content/browser/loader/resource_message_filter.h" |
40 #include "content/browser/loader/resource_request_info_impl.h" | 40 #include "content/browser/loader/resource_request_info_impl.h" |
41 #include "content/browser/loader/stream_resource_handler.h" | 41 #include "content/browser/loader/stream_resource_handler.h" |
42 #include "content/browser/loader/sync_resource_handler.h" | 42 #include "content/browser/loader/sync_resource_handler.h" |
| 43 #include "content/browser/loader/temporary_file_stream.h" |
43 #include "content/browser/loader/throttling_resource_handler.h" | 44 #include "content/browser/loader/throttling_resource_handler.h" |
44 #include "content/browser/loader/upload_data_stream_builder.h" | 45 #include "content/browser/loader/upload_data_stream_builder.h" |
45 #include "content/browser/plugin_service_impl.h" | 46 #include "content/browser/plugin_service_impl.h" |
46 #include "content/browser/renderer_host/render_view_host_delegate.h" | 47 #include "content/browser/renderer_host/render_view_host_delegate.h" |
47 #include "content/browser/renderer_host/render_view_host_impl.h" | 48 #include "content/browser/renderer_host/render_view_host_impl.h" |
48 #include "content/browser/resource_context_impl.h" | 49 #include "content/browser/resource_context_impl.h" |
49 #include "content/browser/streams/stream.h" | 50 #include "content/browser/streams/stream.h" |
50 #include "content/browser/streams/stream_context.h" | 51 #include "content/browser/streams/stream_context.h" |
51 #include "content/browser/streams/stream_registry.h" | 52 #include "content/browser/streams/stream_registry.h" |
52 #include "content/browser/worker_host/worker_service_impl.h" | 53 #include "content/browser/worker_host/worker_service_impl.h" |
(...skipping 1087 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1140 int route_id, | 1141 int route_id, |
1141 int process_type, | 1142 int process_type, |
1142 int child_id, | 1143 int child_id, |
1143 ResourceContext* resource_context) { | 1144 ResourceContext* resource_context) { |
1144 // Construct the IPC resource handler. | 1145 // Construct the IPC resource handler. |
1145 scoped_ptr<ResourceHandler> handler; | 1146 scoped_ptr<ResourceHandler> handler; |
1146 if (sync_result) { | 1147 if (sync_result) { |
1147 handler.reset(new SyncResourceHandler(request, sync_result, this)); | 1148 handler.reset(new SyncResourceHandler(request, sync_result, this)); |
1148 } else { | 1149 } else { |
1149 handler.reset(new AsyncResourceHandler(request, this)); | 1150 handler.reset(new AsyncResourceHandler(request, this)); |
1150 if (IsDetachableResourceType(request_data.resource_type)) { | |
1151 handler.reset(new DetachableResourceHandler( | |
1152 request, | |
1153 base::TimeDelta::FromMilliseconds(kDefaultDetachableCancelDelayMs), | |
1154 handler.Pass())); | |
1155 } | |
1156 } | 1151 } |
1157 | 1152 |
1158 // The RedirectToFileResourceHandler depends on being next in the chain. | 1153 // The RedirectToFileResourceHandler depends on being next in the chain. |
1159 if (request_data.download_to_file) { | 1154 if (request_data.download_to_file) { |
1160 handler.reset( | 1155 handler.reset( |
1161 new RedirectToFileResourceHandler(handler.Pass(), request, this)); | 1156 new RedirectToFileResourceHandler( |
| 1157 handler.Pass(), request, |
| 1158 base::Bind(&CreateTemporaryFileStream))); |
| 1159 } |
| 1160 |
| 1161 // Prefetches and <a ping> requests outlive their child process. |
| 1162 if (!sync_result && IsDetachableResourceType(request_data.resource_type)) { |
| 1163 handler.reset(new DetachableResourceHandler( |
| 1164 request, |
| 1165 base::TimeDelta::FromMilliseconds(kDefaultDetachableCancelDelayMs), |
| 1166 handler.Pass())); |
1162 } | 1167 } |
1163 | 1168 |
1164 // Install a CrossSiteResourceHandler for all main frame requests. This will | 1169 // Install a CrossSiteResourceHandler for all main frame requests. This will |
1165 // let us check whether a transfer is required and pause for the unload | 1170 // let us check whether a transfer is required and pause for the unload |
1166 // handler either if so or if a cross-process navigation is already under way. | 1171 // handler either if so or if a cross-process navigation is already under way. |
1167 bool is_swappable_navigation = | 1172 bool is_swappable_navigation = |
1168 request_data.resource_type == ResourceType::MAIN_FRAME; | 1173 request_data.resource_type == ResourceType::MAIN_FRAME; |
1169 // If we are using --site-per-process, install it for subframes as well. | 1174 // If we are using --site-per-process, install it for subframes as well. |
1170 if (!is_swappable_navigation && | 1175 if (!is_swappable_navigation && |
1171 CommandLine::ForCurrentProcess()->HasSwitch(switches::kSitePerProcess)) { | 1176 CommandLine::ForCurrentProcess()->HasSwitch(switches::kSitePerProcess)) { |
(...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1206 | 1211 |
1207 void ResourceDispatcherHostImpl::OnReleaseDownloadedFile(int request_id) { | 1212 void ResourceDispatcherHostImpl::OnReleaseDownloadedFile(int request_id) { |
1208 UnregisterDownloadedTempFile(filter_->child_id(), request_id); | 1213 UnregisterDownloadedTempFile(filter_->child_id(), request_id); |
1209 } | 1214 } |
1210 | 1215 |
1211 void ResourceDispatcherHostImpl::OnDataDownloadedACK(int request_id) { | 1216 void ResourceDispatcherHostImpl::OnDataDownloadedACK(int request_id) { |
1212 // TODO(michaeln): maybe throttle DataDownloaded messages | 1217 // TODO(michaeln): maybe throttle DataDownloaded messages |
1213 } | 1218 } |
1214 | 1219 |
1215 void ResourceDispatcherHostImpl::RegisterDownloadedTempFile( | 1220 void ResourceDispatcherHostImpl::RegisterDownloadedTempFile( |
1216 int child_id, int request_id, ShareableFileReference* reference) { | 1221 int child_id, int request_id, const base::FilePath& file_path) { |
| 1222 scoped_refptr<ShareableFileReference> reference = |
| 1223 ShareableFileReference::Get(file_path); |
| 1224 if (!reference) { |
| 1225 NOTREACHED(); |
| 1226 return; |
| 1227 } |
| 1228 |
1217 registered_temp_files_[child_id][request_id] = reference; | 1229 registered_temp_files_[child_id][request_id] = reference; |
1218 ChildProcessSecurityPolicyImpl::GetInstance()->GrantReadFile( | 1230 ChildProcessSecurityPolicyImpl::GetInstance()->GrantReadFile( |
1219 child_id, reference->path()); | 1231 child_id, reference->path()); |
1220 | 1232 |
1221 // When the temp file is deleted, revoke permissions that the renderer has | 1233 // When the temp file is deleted, revoke permissions that the renderer has |
1222 // to that file. This covers an edge case where the file is deleted and then | 1234 // to that file. This covers an edge case where the file is deleted and then |
1223 // the same name is re-used for some other purpose, we don't want the old | 1235 // the same name is re-used for some other purpose, we don't want the old |
1224 // renderer to still have access to it. | 1236 // renderer to still have access to it. |
1225 // | 1237 // |
1226 // We do this when the file is deleted because the renderer can take a blob | 1238 // We do this when the file is deleted because the renderer can take a blob |
(...skipping 747 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1974 if ((load_flags & net::LOAD_REPORT_RAW_HEADERS) | 1986 if ((load_flags & net::LOAD_REPORT_RAW_HEADERS) |
1975 && !policy->CanReadRawCookies(child_id)) { | 1987 && !policy->CanReadRawCookies(child_id)) { |
1976 VLOG(1) << "Denied unauthorized request for raw headers"; | 1988 VLOG(1) << "Denied unauthorized request for raw headers"; |
1977 load_flags &= ~net::LOAD_REPORT_RAW_HEADERS; | 1989 load_flags &= ~net::LOAD_REPORT_RAW_HEADERS; |
1978 } | 1990 } |
1979 | 1991 |
1980 return load_flags; | 1992 return load_flags; |
1981 } | 1993 } |
1982 | 1994 |
1983 } // namespace content | 1995 } // namespace content |
OLD | NEW |