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 #ifndef CONTENT_CHILD_RESOURCE_DISPATCHER_H_ | 7 #ifndef CONTENT_CHILD_RESOURCE_DISPATCHER_H_ |
8 #define CONTENT_CHILD_RESOURCE_DISPATCHER_H_ | 8 #define CONTENT_CHILD_RESOURCE_DISPATCHER_H_ |
9 | 9 |
10 #include <stdint.h> | 10 #include <stdint.h> |
11 | 11 |
12 #include <deque> | 12 #include <deque> |
| 13 #include <map> |
13 #include <string> | 14 #include <string> |
14 | 15 |
15 #include "base/containers/hash_tables.h" | 16 #include "base/containers/hash_tables.h" |
16 #include "base/macros.h" | 17 #include "base/macros.h" |
17 #include "base/memory/linked_ptr.h" | 18 #include "base/memory/linked_ptr.h" |
18 #include "base/memory/scoped_ptr.h" | 19 #include "base/memory/scoped_ptr.h" |
19 #include "base/memory/shared_memory.h" | 20 #include "base/memory/shared_memory.h" |
20 #include "base/memory/weak_ptr.h" | 21 #include "base/memory/weak_ptr.h" |
21 #include "base/single_thread_task_runner.h" | 22 #include "base/single_thread_task_runner.h" |
22 #include "base/time/time.h" | 23 #include "base/time/time.h" |
(...skipping 111 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
134 } | 135 } |
135 | 136 |
136 void SetResourceSchedulingFilter( | 137 void SetResourceSchedulingFilter( |
137 scoped_refptr<ResourceSchedulingFilter> resource_scheduling_filter); | 138 scoped_refptr<ResourceSchedulingFilter> resource_scheduling_filter); |
138 | 139 |
139 private: | 140 private: |
140 friend class ResourceDispatcherTest; | 141 friend class ResourceDispatcherTest; |
141 | 142 |
142 typedef std::deque<IPC::Message*> MessageQueue; | 143 typedef std::deque<IPC::Message*> MessageQueue; |
143 struct PendingRequestInfo { | 144 struct PendingRequestInfo { |
144 PendingRequestInfo(); | |
145 | |
146 PendingRequestInfo(RequestPeer* peer, | 145 PendingRequestInfo(RequestPeer* peer, |
147 ResourceType resource_type, | 146 ResourceType resource_type, |
148 int origin_pid, | 147 int origin_pid, |
149 const GURL& frame_origin, | 148 const GURL& frame_origin, |
150 const GURL& request_url, | 149 const GURL& request_url, |
151 bool download_to_file); | 150 bool download_to_file); |
152 | 151 |
153 ~PendingRequestInfo(); | 152 ~PendingRequestInfo(); |
154 | 153 |
155 RequestPeer* peer; | 154 RequestPeer* peer; |
156 ThreadedDataProvider* threaded_data_provider; | 155 ThreadedDataProvider* threaded_data_provider = nullptr; |
157 ResourceType resource_type; | 156 ResourceType resource_type; |
158 // The PID of the original process which issued this request. This gets | 157 // The PID of the original process which issued this request. This gets |
159 // non-zero only for a request proxied by another renderer, particularly | 158 // non-zero only for a request proxied by another renderer, particularly |
160 // requests from plugins. | 159 // requests from plugins. |
161 int origin_pid; | 160 int origin_pid; |
162 MessageQueue deferred_message_queue; | 161 MessageQueue deferred_message_queue; |
163 bool is_deferred; | 162 bool is_deferred = false; |
164 // Original requested url. | 163 // Original requested url. |
165 GURL url; | 164 GURL url; |
166 // The security origin of the frame that initiates this request. | 165 // The security origin of the frame that initiates this request. |
167 GURL frame_origin; | 166 GURL frame_origin; |
168 // The url of the latest response even in case of redirection. | 167 // The url of the latest response even in case of redirection. |
169 GURL response_url; | 168 GURL response_url; |
170 bool download_to_file; | 169 bool download_to_file; |
171 linked_ptr<IPC::Message> pending_redirect_message; | 170 scoped_ptr<IPC::Message> pending_redirect_message; |
172 base::TimeTicks request_start; | 171 base::TimeTicks request_start; |
173 base::TimeTicks response_start; | 172 base::TimeTicks response_start; |
174 base::TimeTicks completion_time; | 173 base::TimeTicks completion_time; |
175 linked_ptr<base::SharedMemory> buffer; | 174 linked_ptr<base::SharedMemory> buffer; |
176 scoped_refptr<SharedMemoryReceivedDataFactory> received_data_factory; | 175 scoped_refptr<SharedMemoryReceivedDataFactory> received_data_factory; |
177 linked_ptr<SiteIsolationResponseMetaData> site_isolation_metadata; | 176 scoped_ptr<SiteIsolationResponseMetaData> site_isolation_metadata; |
178 int buffer_size; | 177 int buffer_size; |
179 | 178 |
180 // Debugging for https://code.google.com/p/chromium/issues/detail?id=527588. | 179 // Debugging for https://code.google.com/p/chromium/issues/detail?id=527588. |
181 int data_offset; | 180 int data_offset = -1; |
182 }; | 181 }; |
183 typedef base::hash_map<int, PendingRequestInfo> PendingRequestList; | 182 using PendingRequestMap = std::map<int, scoped_ptr<PendingRequestInfo>>; |
184 | 183 |
185 // Helper to lookup the info based on the request_id. | 184 // Helper to lookup the info based on the request_id. |
186 // May return NULL if the request as been canceled from the client side. | 185 // May return NULL if the request as been canceled from the client side. |
187 PendingRequestInfo* GetPendingRequestInfo(int request_id); | 186 PendingRequestInfo* GetPendingRequestInfo(int request_id); |
188 | 187 |
189 // Follows redirect, if any, for the given request. | 188 // Follows redirect, if any, for the given request. |
190 void FollowPendingRedirect(int request_id, PendingRequestInfo& request_info); | 189 void FollowPendingRedirect(int request_id, PendingRequestInfo* request_info); |
191 | 190 |
192 // Message response handlers, called by the message handler for this process. | 191 // Message response handlers, called by the message handler for this process. |
193 void OnUploadProgress(int request_id, int64_t position, int64_t size); | 192 void OnUploadProgress(int request_id, int64_t position, int64_t size); |
194 void OnReceivedResponse(int request_id, const ResourceResponseHead&); | 193 void OnReceivedResponse(int request_id, const ResourceResponseHead&); |
195 void OnReceivedCachedMetadata(int request_id, const std::vector<char>& data); | 194 void OnReceivedCachedMetadata(int request_id, const std::vector<char>& data); |
196 void OnReceivedRedirect(int request_id, | 195 void OnReceivedRedirect(int request_id, |
197 const net::RedirectInfo& redirect_info, | 196 const net::RedirectInfo& redirect_info, |
198 const ResourceResponseHead& response_head); | 197 const ResourceResponseHead& response_head); |
199 void OnSetDataBuffer(int request_id, | 198 void OnSetDataBuffer(int request_id, |
200 base::SharedMemoryHandle shm_handle, | 199 base::SharedMemoryHandle shm_handle, |
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
245 static void ReleaseResourcesInMessageQueue(MessageQueue* queue); | 244 static void ReleaseResourcesInMessageQueue(MessageQueue* queue); |
246 | 245 |
247 scoped_ptr<ResourceHostMsg_Request> CreateRequest( | 246 scoped_ptr<ResourceHostMsg_Request> CreateRequest( |
248 const RequestInfo& request_info, | 247 const RequestInfo& request_info, |
249 ResourceRequestBody* request_body, | 248 ResourceRequestBody* request_body, |
250 GURL* frame_origin); | 249 GURL* frame_origin); |
251 | 250 |
252 IPC::Sender* message_sender_; | 251 IPC::Sender* message_sender_; |
253 | 252 |
254 // All pending requests issued to the host | 253 // All pending requests issued to the host |
255 PendingRequestList pending_requests_; | 254 PendingRequestMap pending_requests_; |
256 | 255 |
257 ResourceDispatcherDelegate* delegate_; | 256 ResourceDispatcherDelegate* delegate_; |
258 | 257 |
259 // IO thread timestamp for ongoing IPC message. | 258 // IO thread timestamp for ongoing IPC message. |
260 base::TimeTicks io_timestamp_; | 259 base::TimeTicks io_timestamp_; |
261 | 260 |
262 scoped_refptr<base::SingleThreadTaskRunner> main_thread_task_runner_; | 261 scoped_refptr<base::SingleThreadTaskRunner> main_thread_task_runner_; |
263 scoped_refptr<ResourceSchedulingFilter> resource_scheduling_filter_; | 262 scoped_refptr<ResourceSchedulingFilter> resource_scheduling_filter_; |
264 | 263 |
265 base::WeakPtrFactory<ResourceDispatcher> weak_factory_; | 264 base::WeakPtrFactory<ResourceDispatcher> weak_factory_; |
266 | 265 |
267 DISALLOW_COPY_AND_ASSIGN(ResourceDispatcher); | 266 DISALLOW_COPY_AND_ASSIGN(ResourceDispatcher); |
268 }; | 267 }; |
269 | 268 |
270 } // namespace content | 269 } // namespace content |
271 | 270 |
272 #endif // CONTENT_CHILD_RESOURCE_DISPATCHER_H_ | 271 #endif // CONTENT_CHILD_RESOURCE_DISPATCHER_H_ |
OLD | NEW |