OLD | NEW |
1 // Copyright 2017 The Chromium Authors. All rights reserved. | 1 // Copyright 2017 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/navigation_url_loader_network_service.h" | 5 #include "content/browser/loader/navigation_url_loader_network_service.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/bind_helpers.h" | 8 #include "base/bind_helpers.h" |
9 #include "base/memory/ptr_util.h" | 9 #include "base/memory/ptr_util.h" |
10 #include "base/trace_event/trace_event.h" | 10 #include "base/trace_event/trace_event.h" |
11 #include "content/browser/appcache/appcache_navigation_handle.h" | 11 #include "content/browser/appcache/appcache_navigation_handle.h" |
12 #include "content/browser/appcache/appcache_navigation_handle_core.h" | |
13 #include "content/browser/appcache/appcache_request_handler.h" | |
14 #include "content/browser/blob_storage/chrome_blob_storage_context.h" | 12 #include "content/browser/blob_storage/chrome_blob_storage_context.h" |
15 #include "content/browser/frame_host/frame_tree_node.h" | 13 #include "content/browser/frame_host/frame_tree_node.h" |
16 #include "content/browser/frame_host/navigation_request_info.h" | 14 #include "content/browser/frame_host/navigation_request_info.h" |
17 #include "content/browser/loader/navigation_resource_handler.h" | 15 #include "content/browser/loader/navigation_resource_handler.h" |
18 #include "content/browser/loader/navigation_resource_throttle.h" | 16 #include "content/browser/loader/navigation_resource_throttle.h" |
19 #include "content/browser/loader/navigation_url_loader_delegate.h" | 17 #include "content/browser/loader/navigation_url_loader_delegate.h" |
20 #include "content/browser/resource_context_impl.h" | 18 #include "content/browser/resource_context_impl.h" |
21 #include "content/browser/service_worker/service_worker_navigation_handle.h" | 19 #include "content/browser/service_worker/service_worker_navigation_handle.h" |
22 #include "content/browser/service_worker/service_worker_navigation_handle_core.h
" | 20 #include "content/browser/service_worker/service_worker_navigation_handle_core.h
" |
23 #include "content/browser/service_worker/service_worker_request_handler.h" | 21 #include "content/browser/service_worker/service_worker_request_handler.h" |
(...skipping 11 matching lines...) Expand all Loading... |
35 #include "content/public/browser/stream_handle.h" | 33 #include "content/public/browser/stream_handle.h" |
36 #include "content/public/common/referrer.h" | 34 #include "content/public/common/referrer.h" |
37 #include "content/public/common/url_constants.h" | 35 #include "content/public/common/url_constants.h" |
38 #include "net/base/load_flags.h" | 36 #include "net/base/load_flags.h" |
39 #include "net/url_request/url_request_context.h" | 37 #include "net/url_request/url_request_context.h" |
40 | 38 |
41 namespace content { | 39 namespace content { |
42 | 40 |
43 namespace { | 41 namespace { |
44 | 42 |
| 43 // Request ID for browser initiated requests. We start at -2 on the same lines |
| 44 // as ResourceDispatcherHostImpl. |
| 45 int g_next_request_id = -2; |
| 46 |
45 WebContents* GetWebContentsFromFrameTreeNodeID(int frame_tree_node_id) { | 47 WebContents* GetWebContentsFromFrameTreeNodeID(int frame_tree_node_id) { |
46 DCHECK_CURRENTLY_ON(BrowserThread::UI); | 48 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
47 FrameTreeNode* frame_tree_node = | 49 FrameTreeNode* frame_tree_node = |
48 FrameTreeNode::GloballyFindByID(frame_tree_node_id); | 50 FrameTreeNode::GloballyFindByID(frame_tree_node_id); |
49 if (!frame_tree_node) | 51 if (!frame_tree_node) |
50 return nullptr; | 52 return nullptr; |
51 | 53 |
52 return WebContentsImpl::FromFrameTreeNode(frame_tree_node); | 54 return WebContentsImpl::FromFrameTreeNode(frame_tree_node); |
53 } | 55 } |
54 | 56 |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
86 url_loader_factory_ptr = | 88 url_loader_factory_ptr = |
87 ServiceWorkerRequestHandler::InitializeForNavigationNetworkService( | 89 ServiceWorkerRequestHandler::InitializeForNavigationNetworkService( |
88 *resource_request, resource_context, | 90 *resource_request, resource_context, |
89 service_worker_navigation_handle_core, blob_storage_context, | 91 service_worker_navigation_handle_core, blob_storage_context, |
90 request_info->begin_params.skip_service_worker, resource_type, | 92 request_info->begin_params.skip_service_worker, resource_type, |
91 request_info->begin_params.request_context_type, frame_type, | 93 request_info->begin_params.request_context_type, frame_type, |
92 request_info->are_ancestors_secure, | 94 request_info->are_ancestors_secure, |
93 request_info->common_params.post_data, web_contents_getter); | 95 request_info->common_params.post_data, web_contents_getter); |
94 } | 96 } |
95 | 97 |
96 // TODO(scottmg): We need to rework AppCache to have it return a | |
97 // URLLoaderFactoryPtr[Info] here. We should also try to have it return | |
98 // synchronously in as many cases as possible (especially when there's no | |
99 // AppCache) to simplify and speed the common case. | |
100 if (false /*appcache_handle_core*/) { | |
101 AppCacheRequestHandler::InitializeForNavigationNetworkService( | |
102 std::move(resource_request), resource_context, appcache_handle_core, | |
103 resource_type, | |
104 base::Callback<void( | |
105 mojom::URLLoaderFactoryPtrInfo, | |
106 std::unique_ptr<ResourceRequest>)>() /* TODO(ananta) */); | |
107 return; | |
108 } | |
109 | |
110 // If we haven't gotten one from the above, then use the one the UI thread | 98 // If we haven't gotten one from the above, then use the one the UI thread |
111 // gave us, or otherwise fallback to the default. | 99 // gave us, or otherwise fallback to the default. |
112 mojom::URLLoaderFactory* factory; | 100 mojom::URLLoaderFactory* factory; |
113 if (url_loader_factory_ptr) { | 101 if (url_loader_factory_ptr) { |
114 factory = url_loader_factory_ptr.get(); | 102 factory = url_loader_factory_ptr.get(); |
115 } else { | 103 } else { |
116 if (factory_from_ui.is_valid()) { | 104 if (factory_from_ui.is_valid()) { |
117 url_loader_factory_ptr.Bind(std::move(factory_from_ui)); | 105 url_loader_factory_ptr.Bind(std::move(factory_from_ui)); |
118 factory = url_loader_factory_ptr.get(); | 106 factory = url_loader_factory_ptr.get(); |
119 } else { | 107 } else { |
120 factory = url_loader_factory_getter->GetNetworkFactory()->get(); | 108 if (appcache_handle_core) { |
| 109 factory = url_loader_factory_getter->GetAppCacheFactory()->get(); |
| 110 } else { |
| 111 factory = url_loader_factory_getter->GetNetworkFactory()->get(); |
| 112 } |
121 } | 113 } |
122 } | 114 } |
123 | 115 |
124 factory->CreateLoaderAndStart( | 116 factory->CreateLoaderAndStart( |
125 std::move(url_loader_request), 0 /* routing_id? */, 0 /* request_id? */, | 117 std::move(url_loader_request), 0 /* routing_id? */, 0 /* request_id? */, |
126 mojom::kURLLoadOptionSendSSLInfo, *resource_request, | 118 mojom::kURLLoadOptionSendSSLInfo, *resource_request, |
127 std::move(url_loader_client_to_pass)); | 119 std::move(url_loader_client_to_pass)); |
128 } | 120 } |
129 | 121 |
130 } // namespace | 122 } // namespace |
(...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
186 mojom::URLLoaderFactoryPtrInfo factory_ptr_info; | 178 mojom::URLLoaderFactoryPtrInfo factory_ptr_info; |
187 | 179 |
188 const auto& schemes = URLDataManagerBackend::GetWebUISchemes(); | 180 const auto& schemes = URLDataManagerBackend::GetWebUISchemes(); |
189 if (std::find(schemes.begin(), schemes.end(), new_request->url.scheme()) != | 181 if (std::find(schemes.begin(), schemes.end(), new_request->url.scheme()) != |
190 schemes.end()) { | 182 schemes.end()) { |
191 FrameTreeNode* frame_tree_node = | 183 FrameTreeNode* frame_tree_node = |
192 FrameTreeNode::GloballyFindByID(request_info_->frame_tree_node_id); | 184 FrameTreeNode::GloballyFindByID(request_info_->frame_tree_node_id); |
193 factory_ptr_info = GetWebUIURLLoader(frame_tree_node).PassInterface(); | 185 factory_ptr_info = GetWebUIURLLoader(frame_tree_node).PassInterface(); |
194 } | 186 } |
195 | 187 |
| 188 g_next_request_id--; |
| 189 |
196 BrowserThread::PostTask( | 190 BrowserThread::PostTask( |
197 BrowserThread::IO, FROM_HERE, | 191 BrowserThread::IO, FROM_HERE, |
198 base::Bind(&PrepareNavigationStartOnIO, | 192 base::Bind(&PrepareNavigationStartOnIO, |
199 base::Passed(std::move(new_request)), resource_context, | 193 base::Passed(std::move(new_request)), resource_context, |
200 service_worker_navigation_handle | 194 service_worker_navigation_handle |
201 ? service_worker_navigation_handle->core() | 195 ? service_worker_navigation_handle->core() |
202 : nullptr, | 196 : nullptr, |
203 appcache_handle ? appcache_handle->core() : nullptr, | 197 appcache_handle ? appcache_handle->core() : nullptr, |
204 request_info_.get(), base::Passed(std::move(factory_ptr_info)), | 198 request_info_.get(), base::Passed(std::move(factory_ptr_info)), |
205 static_cast<StoragePartitionImpl*>(storage_partition) | 199 static_cast<StoragePartitionImpl*>(storage_partition) |
(...skipping 58 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
264 | 258 |
265 TRACE_EVENT_ASYNC_END2("navigation", "Navigation timeToResponseStarted", this, | 259 TRACE_EVENT_ASYNC_END2("navigation", "Navigation timeToResponseStarted", this, |
266 "&NavigationURLLoaderNetworkService", this, "success", | 260 "&NavigationURLLoaderNetworkService", this, "success", |
267 true); | 261 true); |
268 | 262 |
269 // Temporarily, we pass both a stream (null) and the data pipe to the | 263 // Temporarily, we pass both a stream (null) and the data pipe to the |
270 // delegate until PlzNavigate has shipped and we can be comfortable fully | 264 // delegate until PlzNavigate has shipped and we can be comfortable fully |
271 // switching to the data pipe. | 265 // switching to the data pipe. |
272 delegate_->OnResponseStarted(response_, nullptr, std::move(body), ssl_status_, | 266 delegate_->OnResponseStarted(response_, nullptr, std::move(body), ssl_status_, |
273 std::unique_ptr<NavigationData>(), | 267 std::unique_ptr<NavigationData>(), |
274 GlobalRequestID() /* request_id? */, | 268 GlobalRequestID(-1, g_next_request_id), |
275 false /* is_download? */, false /* is_stream */); | 269 false /* is_download? */, false /* is_stream */); |
276 } | 270 } |
277 | 271 |
278 void NavigationURLLoaderNetworkService::OnComplete( | 272 void NavigationURLLoaderNetworkService::OnComplete( |
279 const ResourceRequestCompletionStatus& completion_status) { | 273 const ResourceRequestCompletionStatus& completion_status) { |
280 if (completion_status.error_code != net::OK) { | 274 if (completion_status.error_code != net::OK) { |
281 TRACE_EVENT_ASYNC_END2("navigation", "Navigation timeToResponseStarted", | 275 TRACE_EVENT_ASYNC_END2("navigation", "Navigation timeToResponseStarted", |
282 this, "&NavigationURLLoaderNetworkService", this, | 276 this, "&NavigationURLLoaderNetworkService", this, |
283 "success", false); | 277 "success", false); |
284 | 278 |
285 delegate_->OnRequestFailed(completion_status.exists_in_cache, | 279 delegate_->OnRequestFailed(completion_status.exists_in_cache, |
286 completion_status.error_code); | 280 completion_status.error_code); |
287 } | 281 } |
288 } | 282 } |
289 | 283 |
290 } // namespace content | 284 } // namespace content |
OLD | NEW |