| 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/logging.h" | 8 #include "base/logging.h" |
| 9 #include "base/message_loop/message_loop.h" | 9 #include "base/message_loop/message_loop.h" |
| 10 #include "base/threading/thread.h" | 10 #include "base/threading/thread.h" |
| (...skipping 299 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 310 error_count_(0), | 310 error_count_(0), |
| 311 created_requests_(0), | 311 created_requests_(0), |
| 312 destroyed_requests_(0), | 312 destroyed_requests_(0), |
| 313 completed_requests_(0), | 313 completed_requests_(0), |
| 314 canceled_requests_(0), | 314 canceled_requests_(0), |
| 315 cookie_options_bit_mask_(0), | 315 cookie_options_bit_mask_(0), |
| 316 blocked_get_cookies_count_(0), | 316 blocked_get_cookies_count_(0), |
| 317 blocked_set_cookie_count_(0), | 317 blocked_set_cookie_count_(0), |
| 318 set_cookie_count_(0), | 318 set_cookie_count_(0), |
| 319 observed_before_proxy_headers_sent_callbacks_(0), | 319 observed_before_proxy_headers_sent_callbacks_(0), |
| 320 before_send_headers_count_(0), |
| 321 headers_received_count_(0), |
| 320 has_load_timing_info_before_redirect_(false), | 322 has_load_timing_info_before_redirect_(false), |
| 321 has_load_timing_info_before_auth_(false), | 323 has_load_timing_info_before_auth_(false), |
| 322 can_access_files_(true), | 324 can_access_files_(true), |
| 323 can_throttle_requests_(true), | 325 can_throttle_requests_(true), |
| 324 cancel_request_with_policy_violating_referrer_(false) { | 326 cancel_request_with_policy_violating_referrer_(false), |
| 327 will_be_intercepted_on_next_error_(false) { |
| 325 } | 328 } |
| 326 | 329 |
| 327 TestNetworkDelegate::~TestNetworkDelegate() { | 330 TestNetworkDelegate::~TestNetworkDelegate() { |
| 328 for (std::map<int, int>::iterator i = next_states_.begin(); | 331 for (std::map<int, int>::iterator i = next_states_.begin(); |
| 329 i != next_states_.end(); ++i) { | 332 i != next_states_.end(); ++i) { |
| 330 event_order_[i->first] += "~TestNetworkDelegate\n"; | 333 event_order_[i->first] += "~TestNetworkDelegate\n"; |
| 331 EXPECT_TRUE(i->second & kStageDestruction) << event_order_[i->first]; | 334 EXPECT_TRUE(i->second & kStageDestruction) << event_order_[i->first]; |
| 332 } | 335 } |
| 333 } | 336 } |
| 334 | 337 |
| (...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 379 const CompletionCallback& callback, | 382 const CompletionCallback& callback, |
| 380 HttpRequestHeaders* headers) { | 383 HttpRequestHeaders* headers) { |
| 381 int req_id = request->identifier(); | 384 int req_id = request->identifier(); |
| 382 InitRequestStatesIfNew(req_id); | 385 InitRequestStatesIfNew(req_id); |
| 383 event_order_[req_id] += "OnBeforeSendHeaders\n"; | 386 event_order_[req_id] += "OnBeforeSendHeaders\n"; |
| 384 EXPECT_TRUE(next_states_[req_id] & kStageBeforeSendHeaders) << | 387 EXPECT_TRUE(next_states_[req_id] & kStageBeforeSendHeaders) << |
| 385 event_order_[req_id]; | 388 event_order_[req_id]; |
| 386 next_states_[req_id] = | 389 next_states_[req_id] = |
| 387 kStageSendHeaders | | 390 kStageSendHeaders | |
| 388 kStageCompletedError; // request canceled by delegate | 391 kStageCompletedError; // request canceled by delegate |
| 389 | 392 before_send_headers_count_++; |
| 390 return OK; | 393 return OK; |
| 391 } | 394 } |
| 392 | 395 |
| 393 void TestNetworkDelegate::OnBeforeSendProxyHeaders( | 396 void TestNetworkDelegate::OnBeforeSendProxyHeaders( |
| 394 net::URLRequest* request, | 397 net::URLRequest* request, |
| 395 const net::ProxyInfo& proxy_info, | 398 const net::ProxyInfo& proxy_info, |
| 396 net::HttpRequestHeaders* headers) { | 399 net::HttpRequestHeaders* headers) { |
| 397 ++observed_before_proxy_headers_sent_callbacks_; | 400 ++observed_before_proxy_headers_sent_callbacks_; |
| 398 last_observed_proxy_ = proxy_info.proxy_server().host_port_pair(); | 401 last_observed_proxy_ = proxy_info.proxy_server().host_port_pair(); |
| 399 } | 402 } |
| 400 | 403 |
| 401 void TestNetworkDelegate::OnSendHeaders( | 404 void TestNetworkDelegate::OnSendHeaders( |
| 402 URLRequest* request, | 405 URLRequest* request, |
| 403 const HttpRequestHeaders& headers) { | 406 const HttpRequestHeaders& headers) { |
| 404 int req_id = request->identifier(); | 407 int req_id = request->identifier(); |
| 405 InitRequestStatesIfNew(req_id); | 408 InitRequestStatesIfNew(req_id); |
| 406 event_order_[req_id] += "OnSendHeaders\n"; | 409 event_order_[req_id] += "OnSendHeaders\n"; |
| 407 EXPECT_TRUE(next_states_[req_id] & kStageSendHeaders) << | 410 EXPECT_TRUE(next_states_[req_id] & kStageSendHeaders) << |
| 408 event_order_[req_id]; | 411 event_order_[req_id]; |
| 409 next_states_[req_id] = | 412 if (!will_be_intercepted_on_next_error_) |
| 410 kStageHeadersReceived | | 413 next_states_[req_id] = kStageHeadersReceived | kStageCompletedError; |
| 411 kStageCompletedError; | 414 else |
| 415 next_states_[req_id] = kStageResponseStarted; |
| 416 will_be_intercepted_on_next_error_ = false; |
| 412 } | 417 } |
| 413 | 418 |
| 414 int TestNetworkDelegate::OnHeadersReceived( | 419 int TestNetworkDelegate::OnHeadersReceived( |
| 415 URLRequest* request, | 420 URLRequest* request, |
| 416 const CompletionCallback& callback, | 421 const CompletionCallback& callback, |
| 417 const HttpResponseHeaders* original_response_headers, | 422 const HttpResponseHeaders* original_response_headers, |
| 418 scoped_refptr<HttpResponseHeaders>* override_response_headers, | 423 scoped_refptr<HttpResponseHeaders>* override_response_headers, |
| 419 GURL* allowed_unsafe_redirect_url) { | 424 GURL* allowed_unsafe_redirect_url) { |
| 420 int req_id = request->identifier(); | 425 int req_id = request->identifier(); |
| 421 event_order_[req_id] += "OnHeadersReceived\n"; | 426 event_order_[req_id] += "OnHeadersReceived\n"; |
| (...skipping 16 matching lines...) Expand all Loading... |
| 438 (*override_response_headers)->ReplaceStatusLine("HTTP/1.1 302 Found"); | 443 (*override_response_headers)->ReplaceStatusLine("HTTP/1.1 302 Found"); |
| 439 (*override_response_headers)->RemoveHeader("Location"); | 444 (*override_response_headers)->RemoveHeader("Location"); |
| 440 (*override_response_headers)->AddHeader( | 445 (*override_response_headers)->AddHeader( |
| 441 "Location: " + redirect_on_headers_received_url_.spec()); | 446 "Location: " + redirect_on_headers_received_url_.spec()); |
| 442 | 447 |
| 443 redirect_on_headers_received_url_ = GURL(); | 448 redirect_on_headers_received_url_ = GURL(); |
| 444 | 449 |
| 445 if (!allowed_unsafe_redirect_url_.is_empty()) | 450 if (!allowed_unsafe_redirect_url_.is_empty()) |
| 446 *allowed_unsafe_redirect_url = allowed_unsafe_redirect_url_; | 451 *allowed_unsafe_redirect_url = allowed_unsafe_redirect_url_; |
| 447 } | 452 } |
| 448 | 453 headers_received_count_++; |
| 449 return OK; | 454 return OK; |
| 450 } | 455 } |
| 451 | 456 |
| 452 void TestNetworkDelegate::OnBeforeRedirect(URLRequest* request, | 457 void TestNetworkDelegate::OnBeforeRedirect(URLRequest* request, |
| 453 const GURL& new_location) { | 458 const GURL& new_location) { |
| 454 load_timing_info_before_redirect_ = LoadTimingInfo(); | 459 load_timing_info_before_redirect_ = LoadTimingInfo(); |
| 455 request->GetLoadTimingInfo(&load_timing_info_before_redirect_); | 460 request->GetLoadTimingInfo(&load_timing_info_before_redirect_); |
| 456 has_load_timing_info_before_redirect_ = true; | 461 has_load_timing_info_before_redirect_ = true; |
| 457 EXPECT_FALSE(load_timing_info_before_redirect_.request_start_time.is_null()); | 462 EXPECT_FALSE(load_timing_info_before_redirect_.request_start_time.is_null()); |
| 458 EXPECT_FALSE(load_timing_info_before_redirect_.request_start.is_null()); | 463 EXPECT_FALSE(load_timing_info_before_redirect_.request_start.is_null()); |
| (...skipping 182 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 641 URLRequestJob* job = main_intercept_job_; | 646 URLRequestJob* job = main_intercept_job_; |
| 642 main_intercept_job_ = NULL; | 647 main_intercept_job_ = NULL; |
| 643 return job; | 648 return job; |
| 644 } | 649 } |
| 645 | 650 |
| 646 void TestJobInterceptor::set_main_intercept_job(URLRequestJob* job) { | 651 void TestJobInterceptor::set_main_intercept_job(URLRequestJob* job) { |
| 647 main_intercept_job_ = job; | 652 main_intercept_job_ = job; |
| 648 } | 653 } |
| 649 | 654 |
| 650 } // namespace net | 655 } // namespace net |
| OLD | NEW |