| 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) { |
| 154 if (fake_response_destination_ == STRING) { | 162 if (fake_response_destination_ == STRING) { |
| 155 response_writer_ = response_writer.Pass(); | 163 response_writer_ = response_writer.Pass(); |
| 156 int response = response_writer_->Initialize(CompletionCallback()); | 164 int response = response_writer_->Initialize(CompletionCallback()); |
| 157 // The TestURLFetcher doesn't handle asynchronous writes. | 165 // The TestURLFetcher doesn't handle asynchronous writes. |
| 158 DCHECK_EQ(OK, response); | 166 DCHECK_EQ(OK, response); |
| 159 | 167 |
| 160 scoped_refptr<IOBuffer> buffer(new StringIOBuffer(fake_response_string_)); | 168 scoped_refptr<IOBuffer> buffer(new StringIOBuffer(fake_response_string_)); |
| 161 response = response_writer_->Write(buffer.get(), | 169 response = response_writer_->Write(buffer.get(), |
| 162 fake_response_string_.size(), | 170 fake_response_string_.size(), |
| 163 CompletionCallback()); | 171 CompletionCallback()); |
| 164 DCHECK_EQ(static_cast<int>(fake_response_string_.size()), response); | 172 DCHECK_EQ(static_cast<int>(fake_response_string_.size()), response); |
| 165 response = response_writer_->Finish(CompletionCallback()); | 173 response = response_writer_->Finish(CompletionCallback()); |
| 166 DCHECK_EQ(OK, response); | 174 DCHECK_EQ(OK, response); |
| 175 } else if (fake_response_destination_ == TEMP_FILE) { |
| 176 // File saving is done in SaveResponseToFileAtPath() |
| 177 NOTREACHED(); |
| 167 } else { | 178 } else { |
| 168 NOTIMPLEMENTED(); | 179 NOTIMPLEMENTED(); |
| 169 } | 180 } |
| 170 } | 181 } |
| 171 | 182 |
| 172 HttpResponseHeaders* TestURLFetcher::GetResponseHeaders() const { | 183 HttpResponseHeaders* TestURLFetcher::GetResponseHeaders() const { |
| 173 return fake_response_headers_.get(); | 184 return fake_response_headers_.get(); |
| 174 } | 185 } |
| 175 | 186 |
| 176 HostPortPair TestURLFetcher::GetSocketAddress() const { | 187 HostPortPair TestURLFetcher::GetSocketAddress() const { |
| (...skipping 241 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 418 | 429 |
| 419 URLFetcher* URLFetcherImplFactory::CreateURLFetcher( | 430 URLFetcher* URLFetcherImplFactory::CreateURLFetcher( |
| 420 int id, | 431 int id, |
| 421 const GURL& url, | 432 const GURL& url, |
| 422 URLFetcher::RequestType request_type, | 433 URLFetcher::RequestType request_type, |
| 423 URLFetcherDelegate* d) { | 434 URLFetcherDelegate* d) { |
| 424 return new URLFetcherImpl(url, request_type, d); | 435 return new URLFetcherImpl(url, request_type, d); |
| 425 } | 436 } |
| 426 | 437 |
| 427 } // namespace net | 438 } // namespace net |
| OLD | NEW |