OLD | NEW |
1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 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/url_loader_factory_impl.h" | 5 #include "content/browser/loader/url_loader_factory_impl.h" |
6 | 6 |
7 #include "content/browser/loader/resource_dispatcher_host_impl.h" | 7 #include "content/browser/loader/resource_dispatcher_host_impl.h" |
8 #include "content/browser/loader/resource_message_filter.h" | 8 #include "content/browser/loader/resource_requester_info.h" |
9 #include "content/common/resource_request.h" | 9 #include "content/common/resource_request.h" |
10 #include "content/common/url_loader.mojom.h" | 10 #include "content/common/url_loader.mojom.h" |
11 #include "content/public/browser/browser_thread.h" | 11 #include "content/public/browser/browser_thread.h" |
12 #include "mojo/public/cpp/bindings/strong_binding.h" | 12 #include "mojo/public/cpp/bindings/strong_binding.h" |
13 | 13 |
14 namespace content { | 14 namespace content { |
15 | 15 |
16 namespace { | 16 namespace { |
17 | 17 |
18 void DispatchSyncLoadResult( | 18 void DispatchSyncLoadResult( |
19 const URLLoaderFactoryImpl::SyncLoadCallback& callback, | 19 const URLLoaderFactoryImpl::SyncLoadCallback& callback, |
20 const SyncLoadResult* result) { | 20 const SyncLoadResult* result) { |
21 // |result| can be null when a loading task is aborted unexpectedly. Reply | 21 // |result| can be null when a loading task is aborted unexpectedly. Reply |
22 // with a failure result on that case. | 22 // with a failure result on that case. |
23 // TODO(tzik): Test null-result case. | 23 // TODO(tzik): Test null-result case. |
24 if (!result) { | 24 if (!result) { |
25 SyncLoadResult failure; | 25 SyncLoadResult failure; |
26 failure.error_code = net::ERR_FAILED; | 26 failure.error_code = net::ERR_FAILED; |
27 callback.Run(failure); | 27 callback.Run(failure); |
28 return; | 28 return; |
29 } | 29 } |
30 | 30 |
31 callback.Run(*result); | 31 callback.Run(*result); |
32 } | 32 } |
33 | 33 |
34 } // namespace | 34 } // namespace |
35 | 35 |
36 URLLoaderFactoryImpl::URLLoaderFactoryImpl( | 36 URLLoaderFactoryImpl::URLLoaderFactoryImpl( |
37 scoped_refptr<ResourceMessageFilter> resource_message_filter) | 37 std::unique_ptr<ResourceRequesterInfo> requester_info) |
38 : resource_message_filter_(std::move(resource_message_filter)) { | 38 : requester_info_(std::move(requester_info)) { |
39 DCHECK(resource_message_filter_); | 39 DCHECK(requester_info_->IsRenderer()); |
| 40 DCHECK(requester_info_->GetFilter()); |
40 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 41 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
41 } | 42 } |
42 | 43 |
43 URLLoaderFactoryImpl::~URLLoaderFactoryImpl() { | 44 URLLoaderFactoryImpl::~URLLoaderFactoryImpl() { |
44 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 45 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
45 } | 46 } |
46 | 47 |
47 void URLLoaderFactoryImpl::CreateLoaderAndStart( | 48 void URLLoaderFactoryImpl::CreateLoaderAndStart( |
48 mojom::URLLoaderAssociatedRequest request, | 49 mojom::URLLoaderAssociatedRequest request, |
49 int32_t routing_id, | 50 int32_t routing_id, |
50 int32_t request_id, | 51 int32_t request_id, |
51 const ResourceRequest& url_request, | 52 const ResourceRequest& url_request, |
52 mojom::URLLoaderClientAssociatedPtrInfo client_ptr_info) { | 53 mojom::URLLoaderClientAssociatedPtrInfo client_ptr_info) { |
53 CreateLoaderAndStart(std::move(request), routing_id, request_id, url_request, | 54 CreateLoaderAndStart(std::move(request), routing_id, request_id, url_request, |
54 std::move(client_ptr_info), | 55 std::move(client_ptr_info), requester_info_->clone()); |
55 resource_message_filter_.get()); | |
56 } | 56 } |
57 | 57 |
58 void URLLoaderFactoryImpl::SyncLoad(int32_t routing_id, | 58 void URLLoaderFactoryImpl::SyncLoad(int32_t routing_id, |
59 int32_t request_id, | 59 int32_t request_id, |
60 const ResourceRequest& url_request, | 60 const ResourceRequest& url_request, |
61 const SyncLoadCallback& callback) { | 61 const SyncLoadCallback& callback) { |
62 SyncLoad(routing_id, request_id, url_request, callback, | 62 SyncLoad(routing_id, request_id, url_request, callback, |
63 resource_message_filter_.get()); | 63 requester_info_->clone()); |
64 } | 64 } |
65 | 65 |
66 // static | 66 // static |
67 void URLLoaderFactoryImpl::CreateLoaderAndStart( | 67 void URLLoaderFactoryImpl::CreateLoaderAndStart( |
68 mojom::URLLoaderAssociatedRequest request, | 68 mojom::URLLoaderAssociatedRequest request, |
69 int32_t routing_id, | 69 int32_t routing_id, |
70 int32_t request_id, | 70 int32_t request_id, |
71 const ResourceRequest& url_request, | 71 const ResourceRequest& url_request, |
72 mojom::URLLoaderClientAssociatedPtrInfo client_ptr_info, | 72 mojom::URLLoaderClientAssociatedPtrInfo client_ptr_info, |
73 ResourceMessageFilter* filter) { | 73 std::unique_ptr<ResourceRequesterInfo> requester_info) { |
74 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 74 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
75 | 75 |
76 mojom::URLLoaderClientAssociatedPtr client; | 76 mojom::URLLoaderClientAssociatedPtr client; |
77 client.Bind(std::move(client_ptr_info)); | 77 client.Bind(std::move(client_ptr_info)); |
78 | 78 |
79 ResourceDispatcherHostImpl* rdh = ResourceDispatcherHostImpl::Get(); | 79 ResourceDispatcherHostImpl* rdh = ResourceDispatcherHostImpl::Get(); |
80 rdh->OnRequestResourceWithMojo(routing_id, request_id, url_request, | 80 rdh->OnRequestResourceWithMojo(routing_id, request_id, url_request, |
81 std::move(request), std::move(client), filter); | 81 std::move(request), std::move(client), |
| 82 std::move(requester_info)); |
82 } | 83 } |
83 | 84 |
84 // static | 85 // static |
85 void URLLoaderFactoryImpl::SyncLoad(int32_t routing_id, | 86 void URLLoaderFactoryImpl::SyncLoad( |
86 int32_t request_id, | 87 int32_t routing_id, |
87 const ResourceRequest& url_request, | 88 int32_t request_id, |
88 const SyncLoadCallback& callback, | 89 const ResourceRequest& url_request, |
89 ResourceMessageFilter* filter) { | 90 const SyncLoadCallback& callback, |
| 91 std::unique_ptr<ResourceRequesterInfo> requester_info) { |
90 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 92 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
91 | 93 |
92 ResourceDispatcherHostImpl* rdh = ResourceDispatcherHostImpl::Get(); | 94 ResourceDispatcherHostImpl* rdh = ResourceDispatcherHostImpl::Get(); |
93 rdh->OnSyncLoadWithMojo(routing_id, request_id, url_request, filter, | 95 rdh->OnSyncLoadWithMojo(routing_id, request_id, url_request, |
| 96 std::move(requester_info), |
94 base::Bind(&DispatchSyncLoadResult, callback)); | 97 base::Bind(&DispatchSyncLoadResult, callback)); |
95 } | 98 } |
96 | 99 |
97 void URLLoaderFactoryImpl::Create( | 100 void URLLoaderFactoryImpl::Create( |
98 scoped_refptr<ResourceMessageFilter> filter, | 101 std::unique_ptr<ResourceRequesterInfo> requester_info, |
99 mojo::InterfaceRequest<mojom::URLLoaderFactory> request) { | 102 mojo::InterfaceRequest<mojom::URLLoaderFactory> request) { |
100 mojo::MakeStrongBinding( | 103 mojo::MakeStrongBinding( |
101 base::WrapUnique(new URLLoaderFactoryImpl(std::move(filter))), | 104 base::WrapUnique(new URLLoaderFactoryImpl(std::move(requester_info))), |
102 std::move(request)); | 105 std::move(request)); |
103 } | 106 } |
104 | 107 |
105 } // namespace content | 108 } // namespace content |
OLD | NEW |