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 306 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
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), |
324 blocked_get_cookies_count_(0), | 324 blocked_get_cookies_count_(0), |
325 blocked_set_cookie_count_(0), | 325 blocked_set_cookie_count_(0), |
326 set_cookie_count_(0), | 326 set_cookie_count_(0), |
| 327 observed_before_proxy_headers_sent_callbacks_(0), |
327 has_load_timing_info_before_redirect_(false), | 328 has_load_timing_info_before_redirect_(false), |
328 has_load_timing_info_before_auth_(false), | 329 has_load_timing_info_before_auth_(false), |
329 can_access_files_(true), | 330 can_access_files_(true), |
330 can_throttle_requests_(true) { | 331 can_throttle_requests_(true) { |
331 } | 332 } |
332 | 333 |
333 TestNetworkDelegate::~TestNetworkDelegate() { | 334 TestNetworkDelegate::~TestNetworkDelegate() { |
334 for (std::map<int, int>::iterator i = next_states_.begin(); | 335 for (std::map<int, int>::iterator i = next_states_.begin(); |
335 i != next_states_.end(); ++i) { | 336 i != next_states_.end(); ++i) { |
336 event_order_[i->first] += "~TestNetworkDelegate\n"; | 337 event_order_[i->first] += "~TestNetworkDelegate\n"; |
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
389 event_order_[req_id] += "OnBeforeSendHeaders\n"; | 390 event_order_[req_id] += "OnBeforeSendHeaders\n"; |
390 EXPECT_TRUE(next_states_[req_id] & kStageBeforeSendHeaders) << | 391 EXPECT_TRUE(next_states_[req_id] & kStageBeforeSendHeaders) << |
391 event_order_[req_id]; | 392 event_order_[req_id]; |
392 next_states_[req_id] = | 393 next_states_[req_id] = |
393 kStageSendHeaders | | 394 kStageSendHeaders | |
394 kStageCompletedError; // request canceled by delegate | 395 kStageCompletedError; // request canceled by delegate |
395 | 396 |
396 return OK; | 397 return OK; |
397 } | 398 } |
398 | 399 |
| 400 void TestNetworkDelegate::OnBeforeSendProxyHeaders( |
| 401 net::URLRequest* request, |
| 402 const net::ProxyInfo& proxy_info, |
| 403 net::HttpRequestHeaders* headers) { |
| 404 ++observed_before_proxy_headers_sent_callbacks_; |
| 405 last_observed_proxy_ = proxy_info.proxy_server().host_port_pair(); |
| 406 } |
| 407 |
399 void TestNetworkDelegate::OnSendHeaders( | 408 void TestNetworkDelegate::OnSendHeaders( |
400 URLRequest* request, | 409 URLRequest* request, |
401 const HttpRequestHeaders& headers) { | 410 const HttpRequestHeaders& headers) { |
402 int req_id = request->identifier(); | 411 int req_id = request->identifier(); |
403 InitRequestStatesIfNew(req_id); | 412 InitRequestStatesIfNew(req_id); |
404 event_order_[req_id] += "OnSendHeaders\n"; | 413 event_order_[req_id] += "OnSendHeaders\n"; |
405 EXPECT_TRUE(next_states_[req_id] & kStageSendHeaders) << | 414 EXPECT_TRUE(next_states_[req_id] & kStageSendHeaders) << |
406 event_order_[req_id]; | 415 event_order_[req_id]; |
407 next_states_[req_id] = | 416 next_states_[req_id] = |
408 kStageHeadersReceived | | 417 kStageHeadersReceived | |
(...skipping 223 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
632 URLRequestJob* job = main_intercept_job_; | 641 URLRequestJob* job = main_intercept_job_; |
633 main_intercept_job_ = NULL; | 642 main_intercept_job_ = NULL; |
634 return job; | 643 return job; |
635 } | 644 } |
636 | 645 |
637 void TestJobInterceptor::set_main_intercept_job(URLRequestJob* job) { | 646 void TestJobInterceptor::set_main_intercept_job(URLRequestJob* job) { |
638 main_intercept_job_ = job; | 647 main_intercept_job_ = job; |
639 } | 648 } |
640 | 649 |
641 } // namespace net | 650 } // namespace net |
OLD | NEW |