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 <vector> | 5 #include <vector> |
6 | 6 |
7 #include "base/basictypes.h" | 7 #include "base/basictypes.h" |
8 #include "base/compiler_specific.h" | 8 #include "base/compiler_specific.h" |
9 #include "base/memory/scoped_ptr.h" | 9 #include "base/memory/scoped_ptr.h" |
10 #include "base/stl_util.h" | 10 #include "base/stl_util.h" |
(...skipping 301 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
312 params_.ssl_config_service = ssl_config_service_.get(); | 312 params_.ssl_config_service = ssl_config_service_.get(); |
313 params_.http_auth_handler_factory = auth_handler_factory_.get(); | 313 params_.http_auth_handler_factory = auth_handler_factory_.get(); |
314 params_.http_server_properties = http_server_properties_.GetWeakPtr(); | 314 params_.http_server_properties = http_server_properties_.GetWeakPtr(); |
315 params_.quic_supported_versions = SupportedVersions(GetParam()); | 315 params_.quic_supported_versions = SupportedVersions(GetParam()); |
316 | 316 |
317 if (use_next_protos) { | 317 if (use_next_protos) { |
318 params_.use_alternative_services = true; | 318 params_.use_alternative_services = true; |
319 params_.next_protos = NextProtosWithSpdyAndQuic(true, true); | 319 params_.next_protos = NextProtosWithSpdyAndQuic(true, true); |
320 } | 320 } |
321 | 321 |
322 session_ = new HttpNetworkSession(params_); | 322 session_.reset(new HttpNetworkSession(params_)); |
323 session_->quic_stream_factory()->set_require_confirmation(false); | 323 session_->quic_stream_factory()->set_require_confirmation(false); |
324 ASSERT_EQ(params_.quic_socket_receive_buffer_size, | 324 ASSERT_EQ(params_.quic_socket_receive_buffer_size, |
325 session_->quic_stream_factory()->socket_receive_buffer_size()); | 325 session_->quic_stream_factory()->socket_receive_buffer_size()); |
326 } | 326 } |
327 | 327 |
328 void CheckWasQuicResponse(const scoped_ptr<HttpNetworkTransaction>& trans) { | 328 void CheckWasQuicResponse(const scoped_ptr<HttpNetworkTransaction>& trans) { |
329 const HttpResponseInfo* response = trans->GetResponseInfo(); | 329 const HttpResponseInfo* response = trans->GetResponseInfo(); |
330 ASSERT_TRUE(response != nullptr); | 330 ASSERT_TRUE(response != nullptr); |
331 ASSERT_TRUE(response->headers.get() != nullptr); | 331 ASSERT_TRUE(response->headers.get() != nullptr); |
332 EXPECT_EQ("HTTP/1.1 200 OK", response->headers->GetStatusLine()); | 332 EXPECT_EQ("HTTP/1.1 200 OK", response->headers->GetStatusLine()); |
(...skipping 86 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
419 } | 419 } |
420 | 420 |
421 void AddHangingNonAlternateProtocolSocketData() { | 421 void AddHangingNonAlternateProtocolSocketData() { |
422 MockConnect hanging_connect(SYNCHRONOUS, ERR_IO_PENDING); | 422 MockConnect hanging_connect(SYNCHRONOUS, ERR_IO_PENDING); |
423 hanging_data_.set_connect_data(hanging_connect); | 423 hanging_data_.set_connect_data(hanging_connect); |
424 socket_factory_.AddSocketDataProvider(&hanging_data_); | 424 socket_factory_.AddSocketDataProvider(&hanging_data_); |
425 } | 425 } |
426 | 426 |
427 MockClock* clock_; // Owned by QuicStreamFactory after CreateSession. | 427 MockClock* clock_; // Owned by QuicStreamFactory after CreateSession. |
428 QuicTestPacketMaker maker_; | 428 QuicTestPacketMaker maker_; |
429 scoped_refptr<HttpNetworkSession> session_; | 429 scoped_ptr<HttpNetworkSession> session_; |
430 MockClientSocketFactory socket_factory_; | 430 MockClientSocketFactory socket_factory_; |
431 MockCryptoClientStreamFactory crypto_client_stream_factory_; | 431 MockCryptoClientStreamFactory crypto_client_stream_factory_; |
432 MockHostResolver host_resolver_; | 432 MockHostResolver host_resolver_; |
433 MockCertVerifier cert_verifier_; | 433 MockCertVerifier cert_verifier_; |
434 TransportSecurityState transport_security_state_; | 434 TransportSecurityState transport_security_state_; |
435 scoped_ptr<TestNetworkQualityEstimator> test_network_quality_estimator_; | 435 scoped_ptr<TestNetworkQualityEstimator> test_network_quality_estimator_; |
436 scoped_refptr<SSLConfigServiceDefaults> ssl_config_service_; | 436 scoped_refptr<SSLConfigServiceDefaults> ssl_config_service_; |
437 scoped_ptr<ProxyService> proxy_service_; | 437 scoped_ptr<ProxyService> proxy_service_; |
438 scoped_ptr<HttpAuthHandlerFactory> auth_handler_factory_; | 438 scoped_ptr<HttpAuthHandlerFactory> auth_handler_factory_; |
439 MockRandom random_generator_; | 439 MockRandom random_generator_; |
(...skipping 1387 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1827 AddHangingNonAlternateProtocolSocketData(); | 1827 AddHangingNonAlternateProtocolSocketData(); |
1828 CreateSessionWithNextProtos(); | 1828 CreateSessionWithNextProtos(); |
1829 AddQuicAlternateProtocolMapping(MockCryptoClientStream::CONFIRM_HANDSHAKE); | 1829 AddQuicAlternateProtocolMapping(MockCryptoClientStream::CONFIRM_HANDSHAKE); |
1830 SendRequestAndExpectQuicResponse("hello!"); | 1830 SendRequestAndExpectQuicResponse("hello!"); |
1831 EXPECT_TRUE( | 1831 EXPECT_TRUE( |
1832 test_network_quality_estimator_->IsRTTAvailableNotificationReceived()); | 1832 test_network_quality_estimator_->IsRTTAvailableNotificationReceived()); |
1833 } | 1833 } |
1834 | 1834 |
1835 } // namespace test | 1835 } // namespace test |
1836 } // namespace net | 1836 } // namespace net |
OLD | NEW |