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 |