OLD | NEW |
| (Empty) |
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 | |
3 // found in the LICENSE file. | |
4 | |
5 #include "content/browser/renderer_host/sync_resource_handler.h" | |
6 | |
7 #include "base/logging.h" | |
8 #include "content/browser/debugger/devtools_netlog_observer.h" | |
9 #include "content/browser/renderer_host/resource_dispatcher_host_impl.h" | |
10 #include "content/browser/renderer_host/resource_message_filter.h" | |
11 #include "content/common/resource_messages.h" | |
12 #include "content/public/browser/global_request_id.h" | |
13 #include "content/public/browser/resource_dispatcher_host_delegate.h" | |
14 #include "net/base/io_buffer.h" | |
15 #include "net/http/http_response_headers.h" | |
16 | |
17 namespace content { | |
18 | |
19 SyncResourceHandler::SyncResourceHandler( | |
20 ResourceMessageFilter* filter, | |
21 net::URLRequest* request, | |
22 IPC::Message* result_message, | |
23 ResourceDispatcherHostImpl* resource_dispatcher_host) | |
24 : read_buffer_(new net::IOBuffer(kReadBufSize)), | |
25 filter_(filter), | |
26 request_(request), | |
27 result_message_(result_message), | |
28 rdh_(resource_dispatcher_host) { | |
29 result_.final_url = request_->url(); | |
30 } | |
31 | |
32 SyncResourceHandler::~SyncResourceHandler() { | |
33 if (result_message_) { | |
34 result_message_->set_reply_error(); | |
35 filter_->Send(result_message_); | |
36 } | |
37 } | |
38 | |
39 bool SyncResourceHandler::OnUploadProgress(int request_id, | |
40 uint64 position, | |
41 uint64 size) { | |
42 return true; | |
43 } | |
44 | |
45 bool SyncResourceHandler::OnRequestRedirected( | |
46 int request_id, | |
47 const GURL& new_url, | |
48 ResourceResponse* response, | |
49 bool* defer) { | |
50 if (rdh_->delegate()) { | |
51 rdh_->delegate()->OnRequestRedirected(new_url, request_, | |
52 filter_->resource_context(), | |
53 response); | |
54 } | |
55 | |
56 DevToolsNetLogObserver::PopulateResponseInfo(request_, response); | |
57 // TODO(darin): It would be much better if this could live in WebCore, but | |
58 // doing so requires API changes at all levels. Similar code exists in | |
59 // WebCore/platform/network/cf/ResourceHandleCFNet.cpp :-( | |
60 if (new_url.GetOrigin() != result_.final_url.GetOrigin()) { | |
61 LOG(ERROR) << "Cross origin redirect denied"; | |
62 return false; | |
63 } | |
64 result_.final_url = new_url; | |
65 return true; | |
66 } | |
67 | |
68 bool SyncResourceHandler::OnResponseStarted( | |
69 int request_id, | |
70 ResourceResponse* response, | |
71 bool* defer) { | |
72 if (rdh_->delegate()) { | |
73 rdh_->delegate()->OnResponseStarted(request_, filter_->resource_context(), | |
74 response, filter_); | |
75 } | |
76 | |
77 DevToolsNetLogObserver::PopulateResponseInfo(request_, response); | |
78 | |
79 // We don't care about copying the status here. | |
80 result_.headers = response->head.headers; | |
81 result_.mime_type = response->head.mime_type; | |
82 result_.charset = response->head.charset; | |
83 result_.download_file_path = response->head.download_file_path; | |
84 result_.request_time = response->head.request_time; | |
85 result_.response_time = response->head.response_time; | |
86 result_.connection_id = response->head.connection_id; | |
87 result_.connection_reused = response->head.connection_reused; | |
88 result_.load_timing = response->head.load_timing; | |
89 result_.devtools_info = response->head.devtools_info; | |
90 return true; | |
91 } | |
92 | |
93 bool SyncResourceHandler::OnWillStart(int request_id, | |
94 const GURL& url, | |
95 bool* defer) { | |
96 return true; | |
97 } | |
98 | |
99 bool SyncResourceHandler::OnWillRead(int request_id, net::IOBuffer** buf, | |
100 int* buf_size, int min_size) { | |
101 DCHECK(min_size == -1); | |
102 *buf = read_buffer_.get(); | |
103 *buf_size = kReadBufSize; | |
104 return true; | |
105 } | |
106 | |
107 bool SyncResourceHandler::OnReadCompleted(int request_id, int bytes_read, | |
108 bool* defer) { | |
109 if (!bytes_read) | |
110 return true; | |
111 result_.data.append(read_buffer_->data(), bytes_read); | |
112 return true; | |
113 } | |
114 | |
115 bool SyncResourceHandler::OnResponseCompleted( | |
116 int request_id, | |
117 const net::URLRequestStatus& status, | |
118 const std::string& security_info) { | |
119 result_.error_code = status.error(); | |
120 | |
121 result_.encoded_data_length = | |
122 DevToolsNetLogObserver::GetAndResetEncodedDataLength(request_); | |
123 | |
124 ResourceHostMsg_SyncLoad::WriteReplyParams(result_message_, result_); | |
125 filter_->Send(result_message_); | |
126 result_message_ = NULL; | |
127 return true; | |
128 } | |
129 | |
130 } // namespace content | |
OLD | NEW |