| 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 #include "net/url_request/test_url_fetcher_factory.h" | 5 #include "net/url_request/test_url_fetcher_factory.h" |
| 6 | 6 |
| 7 #include <string> | 7 #include <string> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/compiler_specific.h" | 10 #include "base/compiler_specific.h" |
| 11 #include "base/file_util.h" |
| 11 #include "base/memory/weak_ptr.h" | 12 #include "base/memory/weak_ptr.h" |
| 12 #include "base/message_loop/message_loop.h" | 13 #include "base/message_loop/message_loop.h" |
| 14 #include "base/threading/thread_restrictions.h" |
| 13 #include "net/base/host_port_pair.h" | 15 #include "net/base/host_port_pair.h" |
| 14 #include "net/base/io_buffer.h" | 16 #include "net/base/io_buffer.h" |
| 15 #include "net/base/net_errors.h" | 17 #include "net/base/net_errors.h" |
| 16 #include "net/http/http_response_headers.h" | 18 #include "net/http/http_response_headers.h" |
| 17 #include "net/url_request/url_fetcher_delegate.h" | 19 #include "net/url_request/url_fetcher_delegate.h" |
| 18 #include "net/url_request/url_fetcher_impl.h" | 20 #include "net/url_request/url_fetcher_impl.h" |
| 19 #include "net/url_request/url_fetcher_response_writer.h" | 21 #include "net/url_request/url_fetcher_response_writer.h" |
| 20 #include "net/url_request/url_request_status.h" | 22 #include "net/url_request/url_request_status.h" |
| 21 | 23 |
| 22 namespace net { | 24 namespace net { |
| (...skipping 113 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 136 base::TimeDelta TestURLFetcher::GetBackoffDelay() const { | 138 base::TimeDelta TestURLFetcher::GetBackoffDelay() const { |
| 137 return fake_backoff_delay_; | 139 return fake_backoff_delay_; |
| 138 } | 140 } |
| 139 | 141 |
| 140 void TestURLFetcher::SetAutomaticallyRetryOnNetworkChanges(int max_retries) { | 142 void TestURLFetcher::SetAutomaticallyRetryOnNetworkChanges(int max_retries) { |
| 141 } | 143 } |
| 142 | 144 |
| 143 void TestURLFetcher::SaveResponseToFileAtPath( | 145 void TestURLFetcher::SaveResponseToFileAtPath( |
| 144 const base::FilePath& file_path, | 146 const base::FilePath& file_path, |
| 145 scoped_refptr<base::SequencedTaskRunner> file_task_runner) { | 147 scoped_refptr<base::SequencedTaskRunner> file_task_runner) { |
| 148 SetResponseFilePath(file_path); |
| 149 // Asynchronous IO is not supported, so file_task_runner is ignored. |
| 150 base::ThreadRestrictions::ScopedAllowIO allow_io; |
| 151 const size_t written_bytes = base::WriteFile( |
| 152 file_path, fake_response_string_.c_str(), fake_response_string_.size()); |
| 153 DCHECK_EQ(written_bytes, fake_response_string_.size()); |
| 146 } | 154 } |
| 147 | 155 |
| 148 void TestURLFetcher::SaveResponseToTemporaryFile( | 156 void TestURLFetcher::SaveResponseToTemporaryFile( |
| 149 scoped_refptr<base::SequencedTaskRunner> file_task_runner) { | 157 scoped_refptr<base::SequencedTaskRunner> file_task_runner) { |
| 150 } | 158 } |
| 151 | 159 |
| 152 void TestURLFetcher::SaveResponseWithWriter( | 160 void TestURLFetcher::SaveResponseWithWriter( |
| 153 scoped_ptr<URLFetcherResponseWriter> response_writer) { | 161 scoped_ptr<URLFetcherResponseWriter> response_writer) { |
| 162 // In class URLFetcherCore this method is called by all three: |
| 163 // GetResponseAsString() / SaveResponseToFileAtPath() / |
| 164 // SaveResponseToTemporaryFile(). But here (in TestURLFetcher), this method |
| 165 // is never used by any of these three methods. So, file writing is expected |
| 166 // to be done in SaveResponseToFileAtPath(), and this method supports only |
| 167 // URLFetcherStringWriter (for testing of this method only). |
| 154 if (fake_response_destination_ == STRING) { | 168 if (fake_response_destination_ == STRING) { |
| 155 response_writer_ = response_writer.Pass(); | 169 response_writer_ = response_writer.Pass(); |
| 156 int response = response_writer_->Initialize(CompletionCallback()); | 170 int response = response_writer_->Initialize(CompletionCallback()); |
| 157 // The TestURLFetcher doesn't handle asynchronous writes. | 171 // The TestURLFetcher doesn't handle asynchronous writes. |
| 158 DCHECK_EQ(OK, response); | 172 DCHECK_EQ(OK, response); |
| 159 | 173 |
| 160 scoped_refptr<IOBuffer> buffer(new StringIOBuffer(fake_response_string_)); | 174 scoped_refptr<IOBuffer> buffer(new StringIOBuffer(fake_response_string_)); |
| 161 response = response_writer_->Write(buffer.get(), | 175 response = response_writer_->Write(buffer.get(), |
| 162 fake_response_string_.size(), | 176 fake_response_string_.size(), |
| 163 CompletionCallback()); | 177 CompletionCallback()); |
| 164 DCHECK_EQ(static_cast<int>(fake_response_string_.size()), response); | 178 DCHECK_EQ(static_cast<int>(fake_response_string_.size()), response); |
| 165 response = response_writer_->Finish(CompletionCallback()); | 179 response = response_writer_->Finish(CompletionCallback()); |
| 166 DCHECK_EQ(OK, response); | 180 DCHECK_EQ(OK, response); |
| 181 } else if (fake_response_destination_ == TEMP_FILE) { |
| 182 // SaveResponseToFileAtPath() should be called instead of this method to |
| 183 // save file. Asynchronous file writing using URLFetcherFileWriter is not |
| 184 // supported. |
| 185 NOTIMPLEMENTED(); |
| 167 } else { | 186 } else { |
| 168 NOTIMPLEMENTED(); | 187 NOTREACHED(); |
| 169 } | 188 } |
| 170 } | 189 } |
| 171 | 190 |
| 172 HttpResponseHeaders* TestURLFetcher::GetResponseHeaders() const { | 191 HttpResponseHeaders* TestURLFetcher::GetResponseHeaders() const { |
| 173 return fake_response_headers_.get(); | 192 return fake_response_headers_.get(); |
| 174 } | 193 } |
| 175 | 194 |
| 176 HostPortPair TestURLFetcher::GetSocketAddress() const { | 195 HostPortPair TestURLFetcher::GetSocketAddress() const { |
| 177 NOTIMPLEMENTED(); | 196 NOTIMPLEMENTED(); |
| 178 return HostPortPair(); | 197 return HostPortPair(); |
| (...skipping 239 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 418 | 437 |
| 419 URLFetcher* URLFetcherImplFactory::CreateURLFetcher( | 438 URLFetcher* URLFetcherImplFactory::CreateURLFetcher( |
| 420 int id, | 439 int id, |
| 421 const GURL& url, | 440 const GURL& url, |
| 422 URLFetcher::RequestType request_type, | 441 URLFetcher::RequestType request_type, |
| 423 URLFetcherDelegate* d) { | 442 URLFetcherDelegate* d) { |
| 424 return new URLFetcherImpl(url, request_type, d); | 443 return new URLFetcherImpl(url, request_type, d); |
| 425 } | 444 } |
| 426 | 445 |
| 427 } // namespace net | 446 } // namespace net |
| OLD | NEW |