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() | |
mmenke
2014/04/29 14:11:40
I think this comment is confusing. Suggest someth
Alexander Alekseev
2014/04/29 21:42:40
Done.
| |
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 |