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/url_request_test_util.h" | 5 #include "net/url_request/url_request_test_util.h" |
6 | 6 |
7 #include "base/compiler_specific.h" | 7 #include "base/compiler_specific.h" |
8 #include "base/location.h" | 8 #include "base/location.h" |
9 #include "base/logging.h" | 9 #include "base/logging.h" |
10 #include "base/message_loop/message_loop.h" | 10 #include "base/message_loop/message_loop.h" |
(...skipping 182 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
193 bool* defer_redirect) { | 193 bool* defer_redirect) { |
194 EXPECT_TRUE(request->is_redirecting()); | 194 EXPECT_TRUE(request->is_redirecting()); |
195 | 195 |
196 have_full_request_headers_ = | 196 have_full_request_headers_ = |
197 request->GetFullRequestHeaders(&full_request_headers_); | 197 request->GetFullRequestHeaders(&full_request_headers_); |
198 | 198 |
199 received_redirect_count_++; | 199 received_redirect_count_++; |
200 if (quit_on_redirect_) { | 200 if (quit_on_redirect_) { |
201 *defer_redirect = true; | 201 *defer_redirect = true; |
202 base::ThreadTaskRunnerHandle::Get()->PostTask( | 202 base::ThreadTaskRunnerHandle::Get()->PostTask( |
203 FROM_HERE, base::MessageLoop::QuitClosure()); | 203 FROM_HERE, base::MessageLoop::QuitWhenIdleClosure()); |
204 } else if (cancel_in_rr_) { | 204 } else if (cancel_in_rr_) { |
205 request->Cancel(); | 205 request->Cancel(); |
206 } | 206 } |
207 } | 207 } |
208 | 208 |
209 void TestDelegate::OnBeforeNetworkStart(URLRequest* request, bool* defer) { | 209 void TestDelegate::OnBeforeNetworkStart(URLRequest* request, bool* defer) { |
210 received_before_network_start_count_++; | 210 received_before_network_start_count_++; |
211 if (quit_on_before_network_start_) { | 211 if (quit_on_before_network_start_) { |
212 *defer = true; | 212 *defer = true; |
213 base::ThreadTaskRunnerHandle::Get()->PostTask( | 213 base::ThreadTaskRunnerHandle::Get()->PostTask( |
214 FROM_HERE, base::MessageLoop::QuitClosure()); | 214 FROM_HERE, base::MessageLoop::QuitWhenIdleClosure()); |
215 } | 215 } |
216 } | 216 } |
217 | 217 |
218 void TestDelegate::OnAuthRequired(URLRequest* request, | 218 void TestDelegate::OnAuthRequired(URLRequest* request, |
219 AuthChallengeInfo* auth_info) { | 219 AuthChallengeInfo* auth_info) { |
220 auth_required_ = true; | 220 auth_required_ = true; |
221 if (quit_on_auth_required_) { | 221 if (quit_on_auth_required_) { |
222 base::ThreadTaskRunnerHandle::Get()->PostTask( | 222 base::ThreadTaskRunnerHandle::Get()->PostTask( |
223 FROM_HERE, base::MessageLoop::QuitClosure()); | 223 FROM_HERE, base::MessageLoop::QuitWhenIdleClosure()); |
224 return; | 224 return; |
225 } | 225 } |
226 if (!credentials_.Empty()) { | 226 if (!credentials_.Empty()) { |
227 request->SetAuth(credentials_); | 227 request->SetAuth(credentials_); |
228 } else { | 228 } else { |
229 request->CancelAuth(); | 229 request->CancelAuth(); |
230 } | 230 } |
231 } | 231 } |
232 | 232 |
233 void TestDelegate::OnSSLCertificateError(URLRequest* request, | 233 void TestDelegate::OnSSLCertificateError(URLRequest* request, |
(...skipping 69 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
303 } | 303 } |
304 if (!request->status().is_io_pending()) | 304 if (!request->status().is_io_pending()) |
305 OnResponseCompleted(request); | 305 OnResponseCompleted(request); |
306 else if (cancel_in_rd_pending_) | 306 else if (cancel_in_rd_pending_) |
307 request->Cancel(); | 307 request->Cancel(); |
308 } | 308 } |
309 | 309 |
310 void TestDelegate::OnResponseCompleted(URLRequest* request) { | 310 void TestDelegate::OnResponseCompleted(URLRequest* request) { |
311 if (quit_on_complete_) | 311 if (quit_on_complete_) |
312 base::ThreadTaskRunnerHandle::Get()->PostTask( | 312 base::ThreadTaskRunnerHandle::Get()->PostTask( |
313 FROM_HERE, base::MessageLoop::QuitClosure()); | 313 FROM_HERE, base::MessageLoop::QuitWhenIdleClosure()); |
314 } | 314 } |
315 | 315 |
316 TestNetworkDelegate::TestNetworkDelegate() | 316 TestNetworkDelegate::TestNetworkDelegate() |
317 : last_error_(0), | 317 : last_error_(0), |
318 error_count_(0), | 318 error_count_(0), |
319 created_requests_(0), | 319 created_requests_(0), |
320 destroyed_requests_(0), | 320 destroyed_requests_(0), |
321 completed_requests_(0), | 321 completed_requests_(0), |
322 canceled_requests_(0), | 322 canceled_requests_(0), |
323 cookie_options_bit_mask_(0), | 323 cookie_options_bit_mask_(0), |
(...skipping 312 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
636 URLRequestJob* job = main_intercept_job_; | 636 URLRequestJob* job = main_intercept_job_; |
637 main_intercept_job_ = NULL; | 637 main_intercept_job_ = NULL; |
638 return job; | 638 return job; |
639 } | 639 } |
640 | 640 |
641 void TestJobInterceptor::set_main_intercept_job(URLRequestJob* job) { | 641 void TestJobInterceptor::set_main_intercept_job(URLRequestJob* job) { |
642 main_intercept_job_ = job; | 642 main_intercept_job_ = job; |
643 } | 643 } |
644 | 644 |
645 } // namespace net | 645 } // namespace net |
OLD | NEW |