| 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 |