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> |
11 | 11 |
12 #include "base/bind.h" | 12 #include "base/bind.h" |
13 #include "base/bind_helpers.h" | 13 #include "base/bind_helpers.h" |
14 #include "base/command_line.h" | 14 #include "base/command_line.h" |
15 #include "base/compiler_specific.h" | 15 #include "base/compiler_specific.h" |
16 #include "base/debug/alias.h" | 16 #include "base/debug/alias.h" |
17 #include "base/logging.h" | 17 #include "base/logging.h" |
18 #include "base/memory/scoped_ptr.h" | 18 #include "base/memory/scoped_ptr.h" |
19 #include "base/message_loop.h" | 19 #include "base/message_loop.h" |
20 #include "base/metrics/histogram.h" | 20 #include "base/metrics/histogram.h" |
21 #include "base/shared_memory.h" | 21 #include "base/shared_memory.h" |
22 #include "base/stl_util.h" | 22 #include "base/stl_util.h" |
23 #include "base/third_party/dynamic_annotations/dynamic_annotations.h" | 23 #include "base/third_party/dynamic_annotations/dynamic_annotations.h" |
24 #include "base/threading/thread_restrictions.h" | |
25 #include "content/browser/appcache/chrome_appcache_service.h" | 24 #include "content/browser/appcache/chrome_appcache_service.h" |
26 #include "content/browser/cert_store_impl.h" | 25 #include "content/browser/cert_store_impl.h" |
27 #include "content/browser/child_process_security_policy_impl.h" | 26 #include "content/browser/child_process_security_policy_impl.h" |
28 #include "content/browser/cross_site_request_manager.h" | 27 #include "content/browser/cross_site_request_manager.h" |
29 #include "content/browser/download/download_file_manager.h" | 28 #include "content/browser/download/download_file_manager.h" |
30 #include "content/browser/download/download_resource_handler.h" | 29 #include "content/browser/download/download_resource_handler.h" |
31 #include "content/browser/download/save_file_manager.h" | 30 #include "content/browser/download/save_file_manager.h" |
32 #include "content/browser/download/save_file_resource_handler.h" | 31 #include "content/browser/download/save_file_resource_handler.h" |
33 #include "content/browser/fileapi/chrome_blob_storage_context.h" | 32 #include "content/browser/fileapi/chrome_blob_storage_context.h" |
34 #include "content/browser/plugin_service_impl.h" | 33 #include "content/browser/plugin_service_impl.h" |
(...skipping 920 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
955 } | 954 } |
956 | 955 |
957 // TODO(darin): Do we really need all of these URLRequest setters in the | 956 // TODO(darin): Do we really need all of these URLRequest setters in the |
958 // transferred navigation case? | 957 // transferred navigation case? |
959 | 958 |
960 request->set_load_flags(load_flags); | 959 request->set_load_flags(load_flags); |
961 | 960 |
962 request->set_priority(DetermineRequestPriority(request_data.resource_type)); | 961 request->set_priority(DetermineRequestPriority(request_data.resource_type)); |
963 | 962 |
964 // Set upload data. | 963 // Set upload data. |
965 uint64 upload_size = 0; | 964 if (request_data.upload_data) |
966 if (request_data.upload_data) { | |
967 request->set_upload(request_data.upload_data); | 965 request->set_upload(request_data.upload_data); |
968 // This results in performing file IO. crbug.com/112607. | |
969 base::ThreadRestrictions::ScopedAllowIO allow_io; | |
970 upload_size = request_data.upload_data->GetContentLengthSync(); | |
971 } | |
972 | 966 |
973 bool allow_download = request_data.allow_download && | 967 bool allow_download = request_data.allow_download && |
974 ResourceType::IsFrame(request_data.resource_type); | 968 ResourceType::IsFrame(request_data.resource_type); |
975 | 969 |
976 // Make extra info and read footer (contains request ID). | 970 // Make extra info and read footer (contains request ID). |
977 ResourceRequestInfoImpl* extra_info = | 971 ResourceRequestInfoImpl* extra_info = |
978 new ResourceRequestInfoImpl( | 972 new ResourceRequestInfoImpl( |
979 process_type, | 973 process_type, |
980 child_id, | 974 child_id, |
981 route_id, | 975 route_id, |
982 request_data.origin_pid, | 976 request_data.origin_pid, |
983 request_id, | 977 request_id, |
984 request_data.is_main_frame, | 978 request_data.is_main_frame, |
985 request_data.frame_id, | 979 request_data.frame_id, |
986 request_data.parent_is_main_frame, | 980 request_data.parent_is_main_frame, |
987 request_data.parent_frame_id, | 981 request_data.parent_frame_id, |
988 request_data.resource_type, | 982 request_data.resource_type, |
989 request_data.transition_type, | 983 request_data.transition_type, |
990 upload_size, | |
991 false, // is download | 984 false, // is download |
992 allow_download, | 985 allow_download, |
993 request_data.has_user_gesture, | 986 request_data.has_user_gesture, |
994 request_data.referrer_policy, | 987 request_data.referrer_policy, |
995 resource_context); | 988 resource_context); |
996 extra_info->AssociateWithRequest(request); // Request takes ownership. | 989 extra_info->AssociateWithRequest(request); // Request takes ownership. |
997 | 990 |
998 if (request->url().SchemeIs(chrome::kBlobScheme)) { | 991 if (request->url().SchemeIs(chrome::kBlobScheme)) { |
999 // Hang on to a reference to ensure the blob is not released prior | 992 // Hang on to a reference to ensure the blob is not released prior |
1000 // to the job being started. | 993 // to the job being started. |
(...skipping 179 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1180 child_id, | 1173 child_id, |
1181 route_id, | 1174 route_id, |
1182 0, | 1175 0, |
1183 request_id_, | 1176 request_id_, |
1184 false, // is_main_frame | 1177 false, // is_main_frame |
1185 -1, // frame_id | 1178 -1, // frame_id |
1186 false, // parent_is_main_frame | 1179 false, // parent_is_main_frame |
1187 -1, // parent_frame_id | 1180 -1, // parent_frame_id |
1188 ResourceType::SUB_RESOURCE, | 1181 ResourceType::SUB_RESOURCE, |
1189 PAGE_TRANSITION_LINK, | 1182 PAGE_TRANSITION_LINK, |
1190 0, // upload_size | |
1191 download, // is_download | 1183 download, // is_download |
1192 download, // allow_download | 1184 download, // allow_download |
1193 false, // has_user_gesture | 1185 false, // has_user_gesture |
1194 WebKit::WebReferrerPolicyDefault, | 1186 WebKit::WebReferrerPolicyDefault, |
1195 context); | 1187 context); |
1196 } | 1188 } |
1197 | 1189 |
1198 void ResourceDispatcherHostImpl::OnSwapOutACK( | 1190 void ResourceDispatcherHostImpl::OnSwapOutACK( |
1199 const ViewMsg_SwapOut_Params& params) { | 1191 const ViewMsg_SwapOut_Params& params) { |
1200 // Closes for cross-site transitions are handled such that the cross-site | 1192 // Closes for cross-site transitions are handled such that the cross-site |
(...skipping 386 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1587 LoadInfoMap info_map; | 1579 LoadInfoMap info_map; |
1588 | 1580 |
1589 LoaderMap::const_iterator i; | 1581 LoaderMap::const_iterator i; |
1590 | 1582 |
1591 // Determine the largest upload size of all requests | 1583 // Determine the largest upload size of all requests |
1592 // in each View (good chance it's zero). | 1584 // in each View (good chance it's zero). |
1593 std::map<std::pair<int, int>, uint64> largest_upload_size; | 1585 std::map<std::pair<int, int>, uint64> largest_upload_size; |
1594 for (i = pending_loaders_.begin(); i != pending_loaders_.end(); ++i) { | 1586 for (i = pending_loaders_.begin(); i != pending_loaders_.end(); ++i) { |
1595 net::URLRequest* request = i->second->request(); | 1587 net::URLRequest* request = i->second->request(); |
1596 ResourceRequestInfoImpl* info = i->second->GetRequestInfo(); | 1588 ResourceRequestInfoImpl* info = i->second->GetRequestInfo(); |
1597 uint64 upload_size = info->GetUploadSize(); | 1589 uint64 upload_size = i->second->upload_size(); |
1598 if (request->GetLoadState().state != net::LOAD_STATE_SENDING_REQUEST) | 1590 if (request->GetLoadState().state != net::LOAD_STATE_SENDING_REQUEST) |
1599 upload_size = 0; | 1591 upload_size = 0; |
1600 std::pair<int, int> key(info->GetChildID(), info->GetRouteID()); | 1592 std::pair<int, int> key(info->GetChildID(), info->GetRouteID()); |
1601 if (upload_size && largest_upload_size[key] < upload_size) | 1593 if (upload_size && largest_upload_size[key] < upload_size) |
1602 largest_upload_size[key] = upload_size; | 1594 largest_upload_size[key] = upload_size; |
1603 } | 1595 } |
1604 | 1596 |
1605 for (i = pending_loaders_.begin(); i != pending_loaders_.end(); ++i) { | 1597 for (i = pending_loaders_.begin(); i != pending_loaders_.end(); ++i) { |
1606 net::URLRequest* request = i->second->request(); | 1598 net::URLRequest* request = i->second->request(); |
1607 ResourceRequestInfoImpl* info = i->second->GetRequestInfo(); | 1599 ResourceRequestInfoImpl* info = i->second->GetRequestInfo(); |
1608 net::LoadStateWithParam load_state = request->GetLoadState(); | 1600 net::LoadStateWithParam load_state = request->GetLoadState(); |
1609 | 1601 |
1610 // We also poll for upload progress on this timer and send upload | 1602 // We also poll for upload progress on this timer and send upload |
1611 // progress ipc messages to the plugin process. | 1603 // progress ipc messages to the plugin process. |
1612 i->second->ReportUploadProgress(); | 1604 i->second->ReportUploadProgress(); |
1613 | 1605 |
1614 std::pair<int, int> key(info->GetChildID(), info->GetRouteID()); | 1606 std::pair<int, int> key(info->GetChildID(), info->GetRouteID()); |
1615 | 1607 |
1616 // If a request is uploading data, ignore all other requests so that the | 1608 // If a request is uploading data, ignore all other requests so that the |
1617 // upload progress takes priority for being shown in the status bar. | 1609 // upload progress takes priority for being shown in the status bar. |
1618 if (largest_upload_size.find(key) != largest_upload_size.end() && | 1610 if (largest_upload_size.find(key) != largest_upload_size.end() && |
1619 info->GetUploadSize() < largest_upload_size[key]) | 1611 i->second->upload_size() < largest_upload_size[key]) |
1620 continue; | 1612 continue; |
1621 | 1613 |
1622 net::LoadStateWithParam to_insert = load_state; | 1614 net::LoadStateWithParam to_insert = load_state; |
1623 LoadInfoMap::iterator existing = info_map.find(key); | 1615 LoadInfoMap::iterator existing = info_map.find(key); |
1624 if (existing != info_map.end()) { | 1616 if (existing != info_map.end()) { |
1625 to_insert = | 1617 to_insert = |
1626 MoreInterestingLoadState(existing->second.load_state, load_state); | 1618 MoreInterestingLoadState(existing->second.load_state, load_state); |
1627 if (to_insert.state == existing->second.load_state.state) | 1619 if (to_insert.state == existing->second.load_state.state) |
1628 continue; | 1620 continue; |
1629 } | 1621 } |
1630 LoadInfo& load_info = info_map[key]; | 1622 LoadInfo& load_info = info_map[key]; |
1631 load_info.url = request->url(); | 1623 load_info.url = request->url(); |
1632 load_info.load_state = to_insert; | 1624 load_info.load_state = to_insert; |
1633 load_info.upload_size = info->GetUploadSize(); | 1625 load_info.upload_size = i->second->upload_size(); |
1634 load_info.upload_position = request->GetUploadProgress(); | 1626 load_info.upload_position = request->GetUploadProgress(); |
1635 } | 1627 } |
1636 | 1628 |
1637 if (info_map.empty()) | 1629 if (info_map.empty()) |
1638 return; | 1630 return; |
1639 | 1631 |
1640 BrowserThread::PostTask( | 1632 BrowserThread::PostTask( |
1641 BrowserThread::UI, FROM_HERE, | 1633 BrowserThread::UI, FROM_HERE, |
1642 base::Bind(&LoadInfoUpdateCallback, info_map)); | 1634 base::Bind(&LoadInfoUpdateCallback, info_map)); |
1643 } | 1635 } |
(...skipping 86 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1730 | 1722 |
1731 return i->second.get(); | 1723 return i->second.get(); |
1732 } | 1724 } |
1733 | 1725 |
1734 ResourceLoader* ResourceDispatcherHostImpl::GetLoader(int child_id, | 1726 ResourceLoader* ResourceDispatcherHostImpl::GetLoader(int child_id, |
1735 int request_id) const { | 1727 int request_id) const { |
1736 return GetLoader(GlobalRequestID(child_id, request_id)); | 1728 return GetLoader(GlobalRequestID(child_id, request_id)); |
1737 } | 1729 } |
1738 | 1730 |
1739 } // namespace content | 1731 } // namespace content |
OLD | NEW |