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/child/resource_dispatcher.h" | 7 #include "content/child/resource_dispatcher.h" |
8 | 8 |
9 #include <utility> | 9 #include <utility> |
10 | 10 |
(...skipping 652 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
663 } | 663 } |
664 | 664 |
665 if (ipc_type == blink::WebURLRequest::LoadingIPCType::kMojo) { | 665 if (ipc_type == blink::WebURLRequest::LoadingIPCType::kMojo) { |
666 scoped_refptr<base::SingleThreadTaskRunner> task_runner = | 666 scoped_refptr<base::SingleThreadTaskRunner> task_runner = |
667 loading_task_runner ? loading_task_runner : thread_task_runner_; | 667 loading_task_runner ? loading_task_runner : thread_task_runner_; |
668 std::unique_ptr<URLLoaderClientImpl> client( | 668 std::unique_ptr<URLLoaderClientImpl> client( |
669 new URLLoaderClientImpl(request_id, this, task_runner)); | 669 new URLLoaderClientImpl(request_id, this, task_runner)); |
670 std::unique_ptr<ThrottlingURLLoader> url_loader = | 670 std::unique_ptr<ThrottlingURLLoader> url_loader = |
671 ThrottlingURLLoader::CreateLoaderAndStart( | 671 ThrottlingURLLoader::CreateLoaderAndStart( |
672 url_loader_factory, std::move(throttles), routing_id, request_id, | 672 url_loader_factory, std::move(throttles), routing_id, request_id, |
673 mojom::kURLLoadOptionNone, std::move(request), client.get(), | 673 mojom::kURLLoadOptionNone, *request, client.get(), |
674 net::MutableNetworkTrafficAnnotationTag(NO_TRAFFIC_ANNOTATION_YET), | 674 net::MutableNetworkTrafficAnnotationTag(NO_TRAFFIC_ANNOTATION_YET), |
675 std::move(task_runner)); | 675 std::move(task_runner)); |
676 pending_requests_[request_id]->url_loader = std::move(url_loader); | 676 pending_requests_[request_id]->url_loader = std::move(url_loader); |
677 pending_requests_[request_id]->url_loader_client = std::move(client); | 677 pending_requests_[request_id]->url_loader_client = std::move(client); |
678 } else { | 678 } else { |
679 message_sender_->Send( | 679 message_sender_->Send( |
680 new ResourceHostMsg_RequestResource(routing_id, request_id, *request)); | 680 new ResourceHostMsg_RequestResource(routing_id, request_id, *request)); |
681 } | 681 } |
682 | 682 |
683 return request_id; | 683 return request_id; |
(...skipping 163 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
847 delete message; | 847 delete message; |
848 } | 848 } |
849 } | 849 } |
850 | 850 |
851 void ResourceDispatcher::SetResourceSchedulingFilter( | 851 void ResourceDispatcher::SetResourceSchedulingFilter( |
852 scoped_refptr<ResourceSchedulingFilter> resource_scheduling_filter) { | 852 scoped_refptr<ResourceSchedulingFilter> resource_scheduling_filter) { |
853 resource_scheduling_filter_ = resource_scheduling_filter; | 853 resource_scheduling_filter_ = resource_scheduling_filter; |
854 } | 854 } |
855 | 855 |
856 } // namespace content | 856 } // namespace content |
OLD | NEW |