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 "base/basictypes.h" | 9 #include "base/basictypes.h" |
10 #include "base/bind.h" | 10 #include "base/bind.h" |
11 #include "base/compiler_specific.h" | 11 #include "base/compiler_specific.h" |
12 #include "base/debug/alias.h" | 12 #include "base/debug/alias.h" |
13 #include "base/files/file_path.h" | 13 #include "base/files/file_path.h" |
14 #include "base/memory/shared_memory.h" | 14 #include "base/memory/shared_memory.h" |
15 #include "base/message_loop/message_loop.h" | 15 #include "base/message_loop/message_loop.h" |
16 #include "base/metrics/histogram.h" | 16 #include "base/metrics/histogram.h" |
17 #include "base/strings/string_util.h" | 17 #include "base/strings/string_util.h" |
18 #include "content/child/request_extra_data.h" | 18 #include "content/child/request_extra_data.h" |
| 19 #include "content/child/request_info.h" |
19 #include "content/child/site_isolation_policy.h" | 20 #include "content/child/site_isolation_policy.h" |
20 #include "content/common/inter_process_time_ticks_converter.h" | 21 #include "content/common/inter_process_time_ticks_converter.h" |
21 #include "content/common/resource_messages.h" | 22 #include "content/common/resource_messages.h" |
22 #include "content/common/service_worker/service_worker_types.h" | 23 #include "content/common/service_worker/service_worker_types.h" |
23 #include "content/public/child/resource_dispatcher_delegate.h" | 24 #include "content/public/child/resource_dispatcher_delegate.h" |
24 #include "content/public/common/resource_response.h" | 25 #include "content/public/common/resource_response.h" |
25 #include "net/base/net_errors.h" | 26 #include "net/base/net_errors.h" |
26 #include "net/base/net_util.h" | 27 #include "net/base/net_util.h" |
27 #include "net/base/request_priority.h" | 28 #include "net/base/request_priority.h" |
28 #include "net/http/http_response_headers.h" | 29 #include "net/http/http_response_headers.h" |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
62 // screwed value), while the renderer process counts up. | 63 // screwed value), while the renderer process counts up. |
63 static int next_request_id = 0; | 64 static int next_request_id = 0; |
64 return next_request_id++; | 65 return next_request_id++; |
65 } | 66 } |
66 | 67 |
67 // ResourceLoaderBridge implementation ---------------------------------------- | 68 // ResourceLoaderBridge implementation ---------------------------------------- |
68 | 69 |
69 class IPCResourceLoaderBridge : public ResourceLoaderBridge { | 70 class IPCResourceLoaderBridge : public ResourceLoaderBridge { |
70 public: | 71 public: |
71 IPCResourceLoaderBridge(ResourceDispatcher* dispatcher, | 72 IPCResourceLoaderBridge(ResourceDispatcher* dispatcher, |
72 const ResourceLoaderBridge::RequestInfo& request_info); | 73 const RequestInfo& request_info); |
73 virtual ~IPCResourceLoaderBridge(); | 74 virtual ~IPCResourceLoaderBridge(); |
74 | 75 |
75 // ResourceLoaderBridge | 76 // ResourceLoaderBridge |
76 virtual void SetRequestBody(ResourceRequestBody* request_body) OVERRIDE; | 77 virtual void SetRequestBody(ResourceRequestBody* request_body) OVERRIDE; |
77 virtual bool Start(Peer* peer) OVERRIDE; | 78 virtual bool Start(Peer* peer) OVERRIDE; |
78 virtual void Cancel() OVERRIDE; | 79 virtual void Cancel() OVERRIDE; |
79 virtual void SetDefersLoading(bool value) OVERRIDE; | 80 virtual void SetDefersLoading(bool value) OVERRIDE; |
80 virtual void DidChangePriority(net::RequestPriority new_priority) OVERRIDE; | 81 virtual void DidChangePriority(net::RequestPriority new_priority) OVERRIDE; |
81 virtual void SyncLoad(SyncLoadResponse* response) OVERRIDE; | 82 virtual void SyncLoad(SyncLoadResponse* response) OVERRIDE; |
82 | 83 |
(...skipping 15 matching lines...) Expand all Loading... |
98 int routing_id_; | 99 int routing_id_; |
99 | 100 |
100 // The security origin of the frame that initiates this request. | 101 // The security origin of the frame that initiates this request. |
101 GURL frame_origin_; | 102 GURL frame_origin_; |
102 | 103 |
103 bool is_synchronous_request_; | 104 bool is_synchronous_request_; |
104 }; | 105 }; |
105 | 106 |
106 IPCResourceLoaderBridge::IPCResourceLoaderBridge( | 107 IPCResourceLoaderBridge::IPCResourceLoaderBridge( |
107 ResourceDispatcher* dispatcher, | 108 ResourceDispatcher* dispatcher, |
108 const ResourceLoaderBridge::RequestInfo& request_info) | 109 const RequestInfo& request_info) |
109 : peer_(NULL), | 110 : peer_(NULL), |
110 dispatcher_(dispatcher), | 111 dispatcher_(dispatcher), |
111 request_id_(-1), | 112 request_id_(-1), |
112 routing_id_(request_info.routing_id), | 113 routing_id_(request_info.routing_id), |
113 is_synchronous_request_(false) { | 114 is_synchronous_request_(false) { |
114 DCHECK(dispatcher_) << "no resource dispatcher"; | 115 DCHECK(dispatcher_) << "no resource dispatcher"; |
115 request_.method = request_info.method; | 116 request_.method = request_info.method; |
116 request_.url = request_info.url; | 117 request_.url = request_info.url; |
117 request_.first_party_for_cookies = request_info.first_party_for_cookies; | 118 request_.first_party_for_cookies = request_info.first_party_for_cookies; |
118 request_.referrer = request_info.referrer; | 119 request_.referrer = request_info.referrer; |
(...skipping 574 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
693 PendingRequestInfo& pending_request = index->second; | 694 PendingRequestInfo& pending_request = index->second; |
694 if (pending_request.is_deferred) { | 695 if (pending_request.is_deferred) { |
695 pending_request.deferred_message_queue.swap(q); | 696 pending_request.deferred_message_queue.swap(q); |
696 return; | 697 return; |
697 } | 698 } |
698 } | 699 } |
699 } | 700 } |
700 } | 701 } |
701 | 702 |
702 ResourceLoaderBridge* ResourceDispatcher::CreateBridge( | 703 ResourceLoaderBridge* ResourceDispatcher::CreateBridge( |
703 const ResourceLoaderBridge::RequestInfo& request_info) { | 704 const RequestInfo& request_info) { |
704 return new IPCResourceLoaderBridge(this, request_info); | 705 return new IPCResourceLoaderBridge(this, request_info); |
705 } | 706 } |
706 | 707 |
707 void ResourceDispatcher::ToResourceResponseInfo( | 708 void ResourceDispatcher::ToResourceResponseInfo( |
708 const PendingRequestInfo& request_info, | 709 const PendingRequestInfo& request_info, |
709 const ResourceResponseHead& browser_info, | 710 const ResourceResponseHead& browser_info, |
710 ResourceResponseInfo* renderer_info) const { | 711 ResourceResponseInfo* renderer_info) const { |
711 *renderer_info = browser_info; | 712 *renderer_info = browser_info; |
712 if (request_info.request_start.is_null() || | 713 if (request_info.request_start.is_null() || |
713 request_info.response_start.is_null() || | 714 request_info.response_start.is_null() || |
(...skipping 96 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
810 void ResourceDispatcher::ReleaseResourcesInMessageQueue(MessageQueue* queue) { | 811 void ResourceDispatcher::ReleaseResourcesInMessageQueue(MessageQueue* queue) { |
811 while (!queue->empty()) { | 812 while (!queue->empty()) { |
812 IPC::Message* message = queue->front(); | 813 IPC::Message* message = queue->front(); |
813 ReleaseResourcesInDataMessage(*message); | 814 ReleaseResourcesInDataMessage(*message); |
814 queue->pop_front(); | 815 queue->pop_front(); |
815 delete message; | 816 delete message; |
816 } | 817 } |
817 } | 818 } |
818 | 819 |
819 } // namespace content | 820 } // namespace content |
OLD | NEW |