| 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 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 48 #include "net/ssl/ssl_config_service_defaults.h" | 48 #include "net/ssl/ssl_config_service_defaults.h" |
| 49 #include "net/test/cert_test_util.h" | 49 #include "net/test/cert_test_util.h" |
| 50 #include "testing/gtest/include/gtest/gtest.h" | 50 #include "testing/gtest/include/gtest/gtest.h" |
| 51 #include "testing/platform_test.h" | 51 #include "testing/platform_test.h" |
| 52 | 52 |
| 53 namespace net { | 53 namespace net { |
| 54 namespace test { | 54 namespace test { |
| 55 | 55 |
| 56 namespace { | 56 namespace { |
| 57 | 57 |
| 58 static const char kQuicAlternateProtocolHttpHeader[] = | 58 static const char kQuicAlternateProtocolHeader[] = |
| 59 "Alternate-Protocol: 80:quic\r\n\r\n"; | 59 "Alternate-Protocol: 443:quic\r\n\r\n"; |
| 60 static const char kQuicAlternateProtocol50pctHttpHeader[] = | 60 static const char kQuicAlternateProtocol50pctHeader[] = |
| 61 "Alternate-Protocol: 80:quic,p=.5\r\n\r\n"; | 61 "Alternate-Protocol: 443:quic,p=.5\r\n\r\n"; |
| 62 static const char kQuicAlternateProtocolDifferentPortHttpHeader[] = | 62 static const char kQuicAlternateProtocolDifferentPortHeader[] = |
| 63 "Alternate-Protocol: 137:quic\r\n\r\n"; | 63 "Alternate-Protocol: 137:quic\r\n\r\n"; |
| 64 static const char kQuicAlternateProtocolHttpsHeader[] = | 64 static const char kQuicAlternativeServiceHeader[] = |
| 65 "Alternate-Protocol: 443:quic\r\n\r\n"; | 65 "Alt-Svc: quic=\":443\"\r\n\r\n"; |
| 66 static const char kQuicAlternativeServiceHttpHeader[] = | 66 static const char kQuicAlternativeService50pctHeader[] = |
| 67 "Alt-Svc: quic=\":80\"\r\n\r\n"; | 67 "Alt-Svc: quic=\":443\";p=\".5\"\r\n\r\n"; |
| 68 static const char kQuicAlternativeService50pctHttpHeader[] = | 68 static const char kQuicAlternativeServiceDifferentPortHeader[] = |
| 69 "Alt-Svc: quic=\":80\";p=\".5\"\r\n\r\n"; | |
| 70 static const char kQuicAlternativeServiceDifferentPortHttpHeader[] = | |
| 71 "Alt-Svc: quic=\":137\"\r\n\r\n"; | 69 "Alt-Svc: quic=\":137\"\r\n\r\n"; |
| 72 static const char kQuicAlternativeServiceHttpsHeader[] = | |
| 73 "Alt-Svc: quic=\":443\"\r\n\r\n"; | |
| 74 | 70 |
| 75 const char kDefaultServerHostName[] = "www.google.com"; | 71 const char kDefaultServerHostName[] = "mail.example.com"; |
| 76 | 72 |
| 77 } // namespace | 73 } // namespace |
| 78 | 74 |
| 79 // Helper class to encapsulate MockReads and MockWrites for QUIC. | 75 // Helper class to encapsulate MockReads and MockWrites for QUIC. |
| 80 // Simplify ownership issues and the interaction with the MockSocketFactory. | 76 // Simplify ownership issues and the interaction with the MockSocketFactory. |
| 81 class MockQuicData { | 77 class MockQuicData { |
| 82 public: | 78 public: |
| 83 MockQuicData() : packet_number_(0) {} | 79 MockQuicData() : packet_number_(0) {} |
| 84 | 80 |
| 85 ~MockQuicData() { | 81 ~MockQuicData() { |
| (...skipping 116 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 202 protected: | 198 protected: |
| 203 QuicNetworkTransactionTest() | 199 QuicNetworkTransactionTest() |
| 204 : clock_(new MockClock), | 200 : clock_(new MockClock), |
| 205 maker_(GetParam(), 0, clock_, kDefaultServerHostName), | 201 maker_(GetParam(), 0, clock_, kDefaultServerHostName), |
| 206 test_network_quality_estimator_(new TestNetworkQualityEstimator()), | 202 test_network_quality_estimator_(new TestNetworkQualityEstimator()), |
| 207 ssl_config_service_(new SSLConfigServiceDefaults), | 203 ssl_config_service_(new SSLConfigServiceDefaults), |
| 208 proxy_service_(ProxyService::CreateDirect()), | 204 proxy_service_(ProxyService::CreateDirect()), |
| 209 auth_handler_factory_( | 205 auth_handler_factory_( |
| 210 HttpAuthHandlerFactory::CreateDefault(&host_resolver_)), | 206 HttpAuthHandlerFactory::CreateDefault(&host_resolver_)), |
| 211 random_generator_(0), | 207 random_generator_(0), |
| 212 hanging_data_(nullptr, 0, nullptr, 0) { | 208 hanging_data_(nullptr, 0, nullptr, 0), |
| 209 ssl_data_(ASYNC, OK) { |
| 213 request_.method = "GET"; | 210 request_.method = "GET"; |
| 214 std::string url("http://"); | 211 std::string url("https://"); |
| 215 url.append(kDefaultServerHostName); | 212 url.append(kDefaultServerHostName); |
| 216 request_.url = GURL(url); | 213 request_.url = GURL(url); |
| 217 request_.load_flags = 0; | 214 request_.load_flags = 0; |
| 218 clock_->AdvanceTime(QuicTime::Delta::FromMilliseconds(20)); | 215 clock_->AdvanceTime(QuicTime::Delta::FromMilliseconds(20)); |
| 216 |
| 217 scoped_refptr<X509Certificate> cert( |
| 218 ImportCertFromFile(GetTestCertsDirectory(), "spdy_pooling.pem")); |
| 219 verify_details_.cert_verify_result.verified_cert = cert; |
| 220 verify_details_.cert_verify_result.is_issued_by_known_root = true; |
| 221 crypto_client_stream_factory_.AddProofVerifyDetails(&verify_details_); |
| 219 } | 222 } |
| 220 | 223 |
| 221 void SetUp() override { | 224 void SetUp() override { |
| 222 NetworkChangeNotifier::NotifyObserversOfIPAddressChangeForTests(); | 225 NetworkChangeNotifier::NotifyObserversOfIPAddressChangeForTests(); |
| 223 base::MessageLoop::current()->RunUntilIdle(); | 226 base::MessageLoop::current()->RunUntilIdle(); |
| 224 } | 227 } |
| 225 | 228 |
| 226 void TearDown() override { | 229 void TearDown() override { |
| 227 NetworkChangeNotifier::NotifyObserversOfIPAddressChangeForTests(); | 230 NetworkChangeNotifier::NotifyObserversOfIPAddressChangeForTests(); |
| 228 // Empty the current queue. | 231 // Empty the current queue. |
| (...skipping 141 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 370 | 373 |
| 371 void SendRequestAndExpectHttpResponse(const std::string& expected) { | 374 void SendRequestAndExpectHttpResponse(const std::string& expected) { |
| 372 scoped_ptr<HttpNetworkTransaction> trans( | 375 scoped_ptr<HttpNetworkTransaction> trans( |
| 373 new HttpNetworkTransaction(DEFAULT_PRIORITY, session_.get())); | 376 new HttpNetworkTransaction(DEFAULT_PRIORITY, session_.get())); |
| 374 RunTransaction(trans); | 377 RunTransaction(trans); |
| 375 CheckWasHttpResponse(trans); | 378 CheckWasHttpResponse(trans); |
| 376 CheckResponseData(trans, expected); | 379 CheckResponseData(trans, expected); |
| 377 } | 380 } |
| 378 | 381 |
| 379 void SendRequestAndExpectQuicResponse(const std::string& expected) { | 382 void SendRequestAndExpectQuicResponse(const std::string& expected) { |
| 380 SendRequestAndExpectQuicResponseMaybeFromProxy(expected, false, 80); | 383 SendRequestAndExpectQuicResponseMaybeFromProxy(expected, false, 443); |
| 381 } | 384 } |
| 382 | 385 |
| 383 void SendRequestAndExpectQuicResponseOnPort(const std::string& expected, | 386 void SendRequestAndExpectQuicResponseOnPort(const std::string& expected, |
| 384 uint16 port) { | 387 uint16 port) { |
| 385 SendRequestAndExpectQuicResponseMaybeFromProxy(expected, false, port); | 388 SendRequestAndExpectQuicResponseMaybeFromProxy(expected, false, port); |
| 386 } | 389 } |
| 387 | 390 |
| 388 void SendRequestAndExpectQuicResponseFromProxyOnPort( | 391 void SendRequestAndExpectQuicResponseFromProxyOnPort( |
| 389 const std::string& expected, | 392 const std::string& expected, |
| 390 uint16 port) { | 393 uint16 port) { |
| 391 SendRequestAndExpectQuicResponseMaybeFromProxy(expected, true, port); | 394 SendRequestAndExpectQuicResponseMaybeFromProxy(expected, true, port); |
| 392 } | 395 } |
| 393 | 396 |
| 394 void AddQuicAlternateProtocolMapping( | 397 void AddQuicAlternateProtocolMapping( |
| 395 MockCryptoClientStream::HandshakeMode handshake_mode) { | 398 MockCryptoClientStream::HandshakeMode handshake_mode) { |
| 396 crypto_client_stream_factory_.set_handshake_mode(handshake_mode); | 399 crypto_client_stream_factory_.set_handshake_mode(handshake_mode); |
| 397 HostPortPair host_port_pair = HostPortPair::FromURL(request_.url); | 400 HostPortPair host_port_pair = HostPortPair::FromURL(request_.url); |
| 398 AlternativeService alternative_service(QUIC, host_port_pair.host(), 80); | 401 AlternativeService alternative_service(QUIC, host_port_pair.host(), 443); |
| 399 base::Time expiration = base::Time::Now() + base::TimeDelta::FromDays(1); | 402 base::Time expiration = base::Time::Now() + base::TimeDelta::FromDays(1); |
| 400 http_server_properties_.SetAlternativeService( | 403 http_server_properties_.SetAlternativeService( |
| 401 host_port_pair, alternative_service, 1.0, expiration); | 404 host_port_pair, alternative_service, 1.0, expiration); |
| 402 } | 405 } |
| 403 | 406 |
| 404 void ExpectBrokenAlternateProtocolMapping() { | 407 void ExpectBrokenAlternateProtocolMapping() { |
| 405 const HostPortPair origin = HostPortPair::FromURL(request_.url); | 408 const HostPortPair origin = HostPortPair::FromURL(request_.url); |
| 406 const AlternativeServiceVector alternative_service_vector = | 409 const AlternativeServiceVector alternative_service_vector = |
| 407 http_server_properties_.GetAlternativeServices(origin); | 410 http_server_properties_.GetAlternativeServices(origin); |
| 408 EXPECT_EQ(1u, alternative_service_vector.size()); | 411 EXPECT_EQ(1u, alternative_service_vector.size()); |
| 409 EXPECT_TRUE(http_server_properties_.IsAlternativeServiceBroken( | 412 EXPECT_TRUE(http_server_properties_.IsAlternativeServiceBroken( |
| 410 alternative_service_vector[0])); | 413 alternative_service_vector[0])); |
| 411 } | 414 } |
| 412 | 415 |
| 413 void ExpectQuicAlternateProtocolMapping() { | 416 void ExpectQuicAlternateProtocolMapping() { |
| 414 const HostPortPair origin = HostPortPair::FromURL(request_.url); | 417 const HostPortPair origin = HostPortPair::FromURL(request_.url); |
| 415 const AlternativeServiceVector alternative_service_vector = | 418 const AlternativeServiceVector alternative_service_vector = |
| 416 http_server_properties_.GetAlternativeServices(origin); | 419 http_server_properties_.GetAlternativeServices(origin); |
| 417 EXPECT_EQ(1u, alternative_service_vector.size()); | 420 EXPECT_EQ(1u, alternative_service_vector.size()); |
| 418 EXPECT_EQ(QUIC, alternative_service_vector[0].protocol); | 421 EXPECT_EQ(QUIC, alternative_service_vector[0].protocol); |
| 419 } | 422 } |
| 420 | 423 |
| 421 void AddHangingNonAlternateProtocolSocketData() { | 424 void AddHangingNonAlternateProtocolSocketData() { |
| 422 MockConnect hanging_connect(SYNCHRONOUS, ERR_IO_PENDING); | 425 MockConnect hanging_connect(SYNCHRONOUS, ERR_IO_PENDING); |
| 423 hanging_data_.set_connect_data(hanging_connect); | 426 hanging_data_.set_connect_data(hanging_connect); |
| 424 socket_factory_.AddSocketDataProvider(&hanging_data_); | 427 socket_factory_.AddSocketDataProvider(&hanging_data_); |
| 428 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 425 } | 429 } |
| 426 | 430 |
| 427 MockClock* clock_; // Owned by QuicStreamFactory after CreateSession. | 431 MockClock* clock_; // Owned by QuicStreamFactory after CreateSession. |
| 428 QuicTestPacketMaker maker_; | 432 QuicTestPacketMaker maker_; |
| 429 scoped_ptr<HttpNetworkSession> session_; | 433 scoped_ptr<HttpNetworkSession> session_; |
| 430 MockClientSocketFactory socket_factory_; | 434 MockClientSocketFactory socket_factory_; |
| 435 ProofVerifyDetailsChromium verify_details_; |
| 431 MockCryptoClientStreamFactory crypto_client_stream_factory_; | 436 MockCryptoClientStreamFactory crypto_client_stream_factory_; |
| 432 MockHostResolver host_resolver_; | 437 MockHostResolver host_resolver_; |
| 433 MockCertVerifier cert_verifier_; | 438 MockCertVerifier cert_verifier_; |
| 434 TransportSecurityState transport_security_state_; | 439 TransportSecurityState transport_security_state_; |
| 435 scoped_ptr<TestNetworkQualityEstimator> test_network_quality_estimator_; | 440 scoped_ptr<TestNetworkQualityEstimator> test_network_quality_estimator_; |
| 436 scoped_refptr<SSLConfigServiceDefaults> ssl_config_service_; | 441 scoped_refptr<SSLConfigServiceDefaults> ssl_config_service_; |
| 437 scoped_ptr<ProxyService> proxy_service_; | 442 scoped_ptr<ProxyService> proxy_service_; |
| 438 scoped_ptr<HttpAuthHandlerFactory> auth_handler_factory_; | 443 scoped_ptr<HttpAuthHandlerFactory> auth_handler_factory_; |
| 439 MockRandom random_generator_; | 444 MockRandom random_generator_; |
| 440 HttpServerPropertiesImpl http_server_properties_; | 445 HttpServerPropertiesImpl http_server_properties_; |
| 441 HttpNetworkSession::Params params_; | 446 HttpNetworkSession::Params params_; |
| 442 HttpRequestInfo request_; | 447 HttpRequestInfo request_; |
| 443 BoundTestNetLog net_log_; | 448 BoundTestNetLog net_log_; |
| 444 StaticSocketDataProvider hanging_data_; | 449 StaticSocketDataProvider hanging_data_; |
| 450 SSLSocketDataProvider ssl_data_; |
| 445 | 451 |
| 446 private: | 452 private: |
| 447 void SendRequestAndExpectQuicResponseMaybeFromProxy( | 453 void SendRequestAndExpectQuicResponseMaybeFromProxy( |
| 448 const std::string& expected, | 454 const std::string& expected, |
| 449 bool used_proxy, | 455 bool used_proxy, |
| 450 uint16 port) { | 456 uint16 port) { |
| 451 scoped_ptr<HttpNetworkTransaction> trans( | 457 scoped_ptr<HttpNetworkTransaction> trans( |
| 452 new HttpNetworkTransaction(DEFAULT_PRIORITY, session_.get())); | 458 new HttpNetworkTransaction(DEFAULT_PRIORITY, session_.get())); |
| 453 ProxyHeadersHandler proxy_headers_handler; | 459 ProxyHeadersHandler proxy_headers_handler; |
| 454 trans->SetBeforeProxyHeadersSentCallback( | 460 trans->SetBeforeProxyHeadersSentCallback( |
| 455 base::Bind(&ProxyHeadersHandler::OnBeforeProxyHeadersSent, | 461 base::Bind(&ProxyHeadersHandler::OnBeforeProxyHeadersSent, |
| 456 base::Unretained(&proxy_headers_handler))); | 462 base::Unretained(&proxy_headers_handler))); |
| 457 RunTransaction(trans); | 463 RunTransaction(trans); |
| 458 CheckWasQuicResponse(trans); | 464 CheckWasQuicResponse(trans); |
| 459 CheckResponsePort(trans, port); | 465 CheckResponsePort(trans, port); |
| 460 CheckResponseData(trans, expected); | 466 CheckResponseData(trans, expected); |
| 461 EXPECT_EQ(used_proxy, proxy_headers_handler.was_called()); | 467 EXPECT_EQ(used_proxy, proxy_headers_handler.was_called()); |
| 462 } | 468 } |
| 463 }; | 469 }; |
| 464 | 470 |
| 465 INSTANTIATE_TEST_CASE_P(Version, QuicNetworkTransactionTest, | 471 INSTANTIATE_TEST_CASE_P(Version, QuicNetworkTransactionTest, |
| 466 ::testing::ValuesIn(QuicSupportedVersions())); | 472 ::testing::ValuesIn(QuicSupportedVersions())); |
| 467 | 473 |
| 468 TEST_P(QuicNetworkTransactionTest, ForceQuic) { | 474 TEST_P(QuicNetworkTransactionTest, ForceQuic) { |
| 469 // TODO(rch): switch these tests to use secure QUIC. | |
| 470 params_.enable_insecure_quic = true; | |
| 471 params_.origin_to_force_quic_on = | 475 params_.origin_to_force_quic_on = |
| 472 HostPortPair::FromString("www.google.com:80"); | 476 HostPortPair::FromString("mail.example.com:443"); |
| 473 | 477 |
| 474 MockQuicData mock_quic_data; | 478 MockQuicData mock_quic_data; |
| 475 mock_quic_data.AddWrite( | 479 mock_quic_data.AddWrite( |
| 476 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, | 480 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, |
| 477 GetRequestHeaders("GET", "http", "/"))); | 481 GetRequestHeaders("GET", "https", "/"))); |
| 478 mock_quic_data.AddRead( | 482 mock_quic_data.AddRead( |
| 479 ConstructResponseHeadersPacket(1, kClientDataStreamId1, false, false, | 483 ConstructResponseHeadersPacket(1, kClientDataStreamId1, false, false, |
| 480 GetResponseHeaders("200 OK"))); | 484 GetResponseHeaders("200 OK"))); |
| 481 mock_quic_data.AddRead( | 485 mock_quic_data.AddRead( |
| 482 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); | 486 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); |
| 483 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); | 487 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
| 484 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read | 488 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read |
| 485 | 489 |
| 486 mock_quic_data.AddSocketDataToFactory(&socket_factory_); | 490 mock_quic_data.AddSocketDataToFactory(&socket_factory_); |
| 487 | 491 |
| (...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 530 entries, 0, NetLog::TYPE_QUIC_SESSION_STREAM_FRAME_RECEIVED, | 534 entries, 0, NetLog::TYPE_QUIC_SESSION_STREAM_FRAME_RECEIVED, |
| 531 NetLog::PHASE_NONE); | 535 NetLog::PHASE_NONE); |
| 532 EXPECT_LT(0, pos); | 536 EXPECT_LT(0, pos); |
| 533 | 537 |
| 534 int log_stream_id; | 538 int log_stream_id; |
| 535 ASSERT_TRUE(entries[pos].GetIntegerValue("stream_id", &log_stream_id)); | 539 ASSERT_TRUE(entries[pos].GetIntegerValue("stream_id", &log_stream_id)); |
| 536 EXPECT_EQ(3, log_stream_id); | 540 EXPECT_EQ(3, log_stream_id); |
| 537 } | 541 } |
| 538 | 542 |
| 539 TEST_P(QuicNetworkTransactionTest, QuicProxy) { | 543 TEST_P(QuicNetworkTransactionTest, QuicProxy) { |
| 540 params_.enable_insecure_quic = true; | |
| 541 params_.enable_quic_for_proxies = true; | 544 params_.enable_quic_for_proxies = true; |
| 542 proxy_service_ = ProxyService::CreateFixedFromPacResult("QUIC myproxy:70"); | 545 proxy_service_ = |
| 546 ProxyService::CreateFixedFromPacResult("QUIC mail.example.com:70"); |
| 543 | 547 |
| 544 MockQuicData mock_quic_data; | 548 MockQuicData mock_quic_data; |
| 545 mock_quic_data.AddWrite( | 549 mock_quic_data.AddWrite( |
| 546 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, | 550 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, |
| 547 GetRequestHeaders("GET", "http", "/"))); | 551 GetRequestHeaders("GET", "http", "/"))); |
| 548 mock_quic_data.AddRead( | 552 mock_quic_data.AddRead( |
| 549 ConstructResponseHeadersPacket(1, kClientDataStreamId1, false, false, | 553 ConstructResponseHeadersPacket(1, kClientDataStreamId1, false, false, |
| 550 GetResponseHeaders("200 OK"))); | 554 GetResponseHeaders("200 OK"))); |
| 551 mock_quic_data.AddRead( | 555 mock_quic_data.AddRead( |
| 552 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); | 556 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); |
| 553 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); | 557 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
| 554 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read | 558 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read |
| 555 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF | 559 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF |
| 556 | 560 |
| 557 mock_quic_data.AddSocketDataToFactory(&socket_factory_); | 561 mock_quic_data.AddSocketDataToFactory(&socket_factory_); |
| 558 | 562 |
| 559 EXPECT_FALSE( | 563 EXPECT_FALSE( |
| 560 test_network_quality_estimator_->IsRTTAvailableNotificationReceived()); | 564 test_network_quality_estimator_->IsRTTAvailableNotificationReceived()); |
| 561 // There is no need to set up an alternate protocol job, because | 565 // There is no need to set up an alternate protocol job, because |
| 562 // no attempt will be made to speak to the proxy over TCP. | 566 // no attempt will be made to speak to the proxy over TCP. |
| 563 | 567 |
| 568 request_.url = GURL("http://mail.example.com/"); |
| 564 CreateSession(); | 569 CreateSession(); |
| 565 | 570 |
| 566 SendRequestAndExpectQuicResponseFromProxyOnPort("hello!", 70); | 571 SendRequestAndExpectQuicResponseFromProxyOnPort("hello!", 70); |
| 567 EXPECT_TRUE( | 572 EXPECT_TRUE( |
| 568 test_network_quality_estimator_->IsRTTAvailableNotificationReceived()); | 573 test_network_quality_estimator_->IsRTTAvailableNotificationReceived()); |
| 569 } | 574 } |
| 570 | 575 |
| 571 // Regression test for https://crbug.com/492458. Test that for an HTTP | 576 // Regression test for https://crbug.com/492458. Test that for an HTTP |
| 572 // connection through a QUIC proxy, the certificate exhibited by the proxy is | 577 // connection through a QUIC proxy, the certificate exhibited by the proxy is |
| 573 // checked against the proxy hostname, not the origin hostname. | 578 // checked against the proxy hostname, not the origin hostname. |
| 574 TEST_P(QuicNetworkTransactionTest, QuicProxyWithCert) { | 579 TEST_P(QuicNetworkTransactionTest, QuicProxyWithCert) { |
| 575 const std::string origin_host = "news.example.com"; | 580 const std::string origin_host = "news.example.com"; |
| 576 const std::string proxy_host = "www.example.org"; | 581 const std::string proxy_host = "www.example.org"; |
| 577 | 582 |
| 578 params_.enable_insecure_quic = true; | |
| 579 params_.enable_quic_for_proxies = true; | 583 params_.enable_quic_for_proxies = true; |
| 580 proxy_service_ = | 584 proxy_service_ = |
| 581 ProxyService::CreateFixedFromPacResult("QUIC " + proxy_host + ":70"); | 585 ProxyService::CreateFixedFromPacResult("QUIC " + proxy_host + ":70"); |
| 582 | 586 |
| 583 maker_.set_hostname(origin_host); | 587 maker_.set_hostname(origin_host); |
| 584 MockQuicData mock_quic_data; | 588 MockQuicData mock_quic_data; |
| 585 mock_quic_data.AddWrite( | 589 mock_quic_data.AddWrite( |
| 586 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, | 590 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, |
| 587 GetRequestHeaders("GET", "http", "/"))); | 591 GetRequestHeaders("GET", "http", "/"))); |
| 588 mock_quic_data.AddRead(ConstructResponseHeadersPacket( | 592 mock_quic_data.AddRead(ConstructResponseHeadersPacket( |
| 589 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); | 593 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); |
| 590 mock_quic_data.AddRead( | 594 mock_quic_data.AddRead( |
| 591 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); | 595 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); |
| 592 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); | 596 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
| 593 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read | 597 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read |
| 594 mock_quic_data.AddRead(SYNCHRONOUS, 0); | 598 mock_quic_data.AddRead(SYNCHRONOUS, 0); |
| 595 mock_quic_data.AddSocketDataToFactory(&socket_factory_); | 599 mock_quic_data.AddSocketDataToFactory(&socket_factory_); |
| 596 | 600 |
| 597 scoped_refptr<X509Certificate> cert( | 601 scoped_refptr<X509Certificate> cert( |
| 598 ImportCertFromFile(GetTestCertsDirectory(), "spdy_pooling.pem")); | 602 ImportCertFromFile(GetTestCertsDirectory(), "spdy_pooling.pem")); |
| 599 ASSERT_TRUE(cert.get()); | 603 ASSERT_TRUE(cert.get()); |
| 600 // This certificate is valid for the proxy, but not for the origin. | 604 // This certificate is valid for the proxy, but not for the origin. |
| 601 bool common_name_fallback_used; | 605 bool common_name_fallback_used; |
| 602 EXPECT_TRUE(cert->VerifyNameMatch(proxy_host, &common_name_fallback_used)); | 606 EXPECT_TRUE(cert->VerifyNameMatch(proxy_host, &common_name_fallback_used)); |
| 603 EXPECT_FALSE(cert->VerifyNameMatch(origin_host, &common_name_fallback_used)); | 607 EXPECT_FALSE(cert->VerifyNameMatch(origin_host, &common_name_fallback_used)); |
| 604 ProofVerifyDetailsChromium verify_details; | 608 ProofVerifyDetailsChromium verify_details; |
| 605 verify_details.cert_verify_result.verified_cert = cert; | 609 verify_details.cert_verify_result.verified_cert = cert; |
| 606 crypto_client_stream_factory_.AddProofVerifyDetails(&verify_details); | 610 crypto_client_stream_factory_.AddProofVerifyDetails(&verify_details); |
| 611 ProofVerifyDetailsChromium verify_details2; |
| 612 verify_details2.cert_verify_result.verified_cert = cert; |
| 613 crypto_client_stream_factory_.AddProofVerifyDetails(&verify_details2); |
| 607 | 614 |
| 608 request_.url = GURL("http://" + origin_host); | 615 request_.url = GURL("http://" + origin_host); |
| 609 AddHangingNonAlternateProtocolSocketData(); | 616 AddHangingNonAlternateProtocolSocketData(); |
| 610 CreateSessionWithNextProtos(); | 617 CreateSessionWithNextProtos(); |
| 611 AddQuicAlternateProtocolMapping(MockCryptoClientStream::CONFIRM_HANDSHAKE); | 618 AddQuicAlternateProtocolMapping(MockCryptoClientStream::CONFIRM_HANDSHAKE); |
| 612 SendRequestAndExpectQuicResponseFromProxyOnPort("hello!", 70); | 619 SendRequestAndExpectQuicResponseFromProxyOnPort("hello!", 70); |
| 613 } | 620 } |
| 614 | 621 |
| 615 TEST_P(QuicNetworkTransactionTest, ForceQuicWithErrorConnecting) { | 622 TEST_P(QuicNetworkTransactionTest, ForceQuicWithErrorConnecting) { |
| 616 params_.enable_insecure_quic = true; | |
| 617 params_.origin_to_force_quic_on = | 623 params_.origin_to_force_quic_on = |
| 618 HostPortPair::FromString("www.google.com:80"); | 624 HostPortPair::FromString("mail.example.com:443"); |
| 619 | 625 |
| 620 MockQuicData mock_quic_data1; | 626 MockQuicData mock_quic_data1; |
| 621 mock_quic_data1.AddRead(ASYNC, ERR_SOCKET_NOT_CONNECTED); | 627 mock_quic_data1.AddRead(ASYNC, ERR_SOCKET_NOT_CONNECTED); |
| 622 | 628 |
| 623 MockQuicData mock_quic_data2; | 629 MockQuicData mock_quic_data2; |
| 624 mock_quic_data2.AddRead(ASYNC, ERR_SOCKET_NOT_CONNECTED); | 630 mock_quic_data2.AddRead(ASYNC, ERR_SOCKET_NOT_CONNECTED); |
| 625 | 631 |
| 626 mock_quic_data1.AddSocketDataToFactory(&socket_factory_); | 632 mock_quic_data1.AddSocketDataToFactory(&socket_factory_); |
| 627 mock_quic_data2.AddSocketDataToFactory(&socket_factory_); | 633 mock_quic_data2.AddSocketDataToFactory(&socket_factory_); |
| 628 | 634 |
| 629 CreateSession(); | 635 CreateSession(); |
| 630 | 636 |
| 631 EXPECT_EQ(0U, test_network_quality_estimator_->GetWatchersCreated()); | 637 EXPECT_EQ(0U, test_network_quality_estimator_->GetWatchersCreated()); |
| 632 for (size_t i = 0; i < 2; ++i) { | 638 for (size_t i = 0; i < 2; ++i) { |
| 633 scoped_ptr<HttpNetworkTransaction> trans( | 639 scoped_ptr<HttpNetworkTransaction> trans( |
| 634 new HttpNetworkTransaction(DEFAULT_PRIORITY, session_.get())); | 640 new HttpNetworkTransaction(DEFAULT_PRIORITY, session_.get())); |
| 635 TestCompletionCallback callback; | 641 TestCompletionCallback callback; |
| 636 int rv = trans->Start(&request_, callback.callback(), net_log_.bound()); | 642 int rv = trans->Start(&request_, callback.callback(), net_log_.bound()); |
| 637 EXPECT_EQ(ERR_IO_PENDING, rv); | 643 EXPECT_EQ(ERR_IO_PENDING, rv); |
| 638 EXPECT_EQ(ERR_CONNECTION_CLOSED, callback.WaitForResult()); | 644 EXPECT_EQ(ERR_CONNECTION_CLOSED, callback.WaitForResult()); |
| 639 EXPECT_EQ(1 + i, test_network_quality_estimator_->GetWatchersCreated()); | 645 EXPECT_EQ(1 + i, test_network_quality_estimator_->GetWatchersCreated()); |
| 640 } | 646 } |
| 641 } | 647 } |
| 642 | 648 |
| 643 TEST_P(QuicNetworkTransactionTest, DoNotForceQuicForHttps) { | 649 TEST_P(QuicNetworkTransactionTest, UseAlternativeServiceForQuic) { |
| 644 // Attempt to "force" quic on 443, which will not be honored. | |
| 645 params_.origin_to_force_quic_on = | |
| 646 HostPortPair::FromString("www.google.com:443"); | |
| 647 | |
| 648 MockRead http_reads[] = { | 650 MockRead http_reads[] = { |
| 649 MockRead("HTTP/1.1 200 OK\r\n\r\n"), | 651 MockRead("HTTP/1.1 200 OK\r\n"), MockRead(kQuicAlternativeServiceHeader), |
| 650 MockRead("hello world"), | 652 MockRead("hello world"), |
| 651 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | |
| 652 MockRead(ASYNC, OK) | |
| 653 }; | |
| 654 | |
| 655 StaticSocketDataProvider data(http_reads, arraysize(http_reads), nullptr, 0); | |
| 656 socket_factory_.AddSocketDataProvider(&data); | |
| 657 SSLSocketDataProvider ssl(ASYNC, OK); | |
| 658 socket_factory_.AddSSLSocketDataProvider(&ssl); | |
| 659 | |
| 660 CreateSession(); | |
| 661 | |
| 662 SendRequestAndExpectHttpResponse("hello world"); | |
| 663 EXPECT_EQ(0U, test_network_quality_estimator_->GetWatchersCreated()); | |
| 664 } | |
| 665 | |
| 666 TEST_P(QuicNetworkTransactionTest, UseAlternativeServiceForQuic) { | |
| 667 params_.enable_insecure_quic = true; | |
| 668 | |
| 669 MockRead http_reads[] = { | |
| 670 MockRead("HTTP/1.1 200 OK\r\n"), | |
| 671 MockRead(kQuicAlternativeServiceHttpHeader), MockRead("hello world"), | |
| 672 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | 653 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
| 673 MockRead(ASYNC, OK)}; | 654 MockRead(ASYNC, OK)}; |
| 674 | 655 |
| 675 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, | 656 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, |
| 676 0); | 657 0); |
| 677 socket_factory_.AddSocketDataProvider(&http_data); | 658 socket_factory_.AddSocketDataProvider(&http_data); |
| 659 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 678 | 660 |
| 679 MockQuicData mock_quic_data; | 661 MockQuicData mock_quic_data; |
| 680 mock_quic_data.AddWrite( | 662 mock_quic_data.AddWrite( |
| 681 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, | 663 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, |
| 682 GetRequestHeaders("GET", "http", "/"))); | 664 GetRequestHeaders("GET", "https", "/"))); |
| 683 mock_quic_data.AddRead(ConstructResponseHeadersPacket( | 665 mock_quic_data.AddRead(ConstructResponseHeadersPacket( |
| 684 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); | 666 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); |
| 685 mock_quic_data.AddRead( | 667 mock_quic_data.AddRead( |
| 686 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); | 668 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); |
| 687 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); | 669 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
| 688 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read | 670 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read |
| 689 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF | 671 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF |
| 690 | 672 |
| 691 mock_quic_data.AddSocketDataToFactory(&socket_factory_); | 673 mock_quic_data.AddSocketDataToFactory(&socket_factory_); |
| 692 | 674 |
| 693 AddHangingNonAlternateProtocolSocketData(); | 675 AddHangingNonAlternateProtocolSocketData(); |
| 694 CreateSessionWithNextProtos(); | 676 CreateSessionWithNextProtos(); |
| 695 | 677 |
| 696 SendRequestAndExpectHttpResponse("hello world"); | 678 SendRequestAndExpectHttpResponse("hello world"); |
| 697 SendRequestAndExpectQuicResponse("hello!"); | 679 SendRequestAndExpectQuicResponse("hello!"); |
| 698 } | 680 } |
| 699 | 681 |
| 700 // When multiple alternative services are advertised, | 682 // When multiple alternative services are advertised, |
| 701 // HttpStreamFactoryImpl::RequestStreamInternal() only passes the first one to | 683 // HttpStreamFactoryImpl::RequestStreamInternal() only passes the first one to |
| 702 // Job. This is what the following test verifies. | 684 // Job. This is what the following test verifies. |
| 703 // TODO(bnc): Update this test when multiple alternative services are handled | 685 // TODO(bnc): Update this test when multiple alternative services are handled |
| 704 // properly. | 686 // properly. |
| 705 TEST_P(QuicNetworkTransactionTest, UseFirstAlternativeServiceForQuic) { | 687 TEST_P(QuicNetworkTransactionTest, UseFirstAlternativeServiceForQuic) { |
| 706 params_.enable_insecure_quic = true; | |
| 707 | |
| 708 MockRead http_reads[] = { | 688 MockRead http_reads[] = { |
| 709 MockRead("HTTP/1.1 200 OK\r\n"), | 689 MockRead("HTTP/1.1 200 OK\r\n"), |
| 710 MockRead("Alt-Svc: quic=\":443\", quic=\":1234\"\r\n\r\n"), | 690 MockRead("Alt-Svc: quic=\":443\", quic=\":1234\"\r\n\r\n"), |
| 711 MockRead("hello world"), | 691 MockRead("hello world"), |
| 712 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | 692 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
| 713 MockRead(ASYNC, OK)}; | 693 MockRead(ASYNC, OK)}; |
| 714 | 694 |
| 715 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, | 695 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, |
| 716 0); | 696 0); |
| 717 socket_factory_.AddSocketDataProvider(&http_data); | 697 socket_factory_.AddSocketDataProvider(&http_data); |
| 698 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 718 | 699 |
| 719 MockQuicData mock_quic_data; | 700 MockQuicData mock_quic_data; |
| 720 mock_quic_data.AddWrite( | 701 mock_quic_data.AddWrite( |
| 721 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, | 702 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, |
| 722 GetRequestHeaders("GET", "http", "/"))); | 703 GetRequestHeaders("GET", "https", "/"))); |
| 723 mock_quic_data.AddRead(ConstructResponseHeadersPacket( | 704 mock_quic_data.AddRead(ConstructResponseHeadersPacket( |
| 724 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); | 705 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); |
| 725 mock_quic_data.AddRead( | 706 mock_quic_data.AddRead( |
| 726 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); | 707 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); |
| 727 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); | 708 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
| 728 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read | 709 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read |
| 729 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF | 710 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF |
| 730 | 711 |
| 731 mock_quic_data.AddSocketDataToFactory(&socket_factory_); | 712 mock_quic_data.AddSocketDataToFactory(&socket_factory_); |
| 732 | 713 |
| 733 AddHangingNonAlternateProtocolSocketData(); | 714 AddHangingNonAlternateProtocolSocketData(); |
| 734 CreateSessionWithNextProtos(); | 715 CreateSessionWithNextProtos(); |
| 735 | 716 |
| 736 SendRequestAndExpectHttpResponse("hello world"); | 717 SendRequestAndExpectHttpResponse("hello world"); |
| 737 SendRequestAndExpectQuicResponseOnPort("hello!", 443); | 718 SendRequestAndExpectQuicResponseOnPort("hello!", 443); |
| 738 } | 719 } |
| 739 | 720 |
| 740 TEST_P(QuicNetworkTransactionTest, AlternativeServiceDifferentPort) { | 721 TEST_P(QuicNetworkTransactionTest, AlternativeServiceDifferentPort) { |
| 741 params_.enable_insecure_quic = true; | |
| 742 | |
| 743 MockRead http_reads[] = { | 722 MockRead http_reads[] = { |
| 744 MockRead("HTTP/1.1 200 OK\r\n"), | 723 MockRead("HTTP/1.1 200 OK\r\n"), |
| 745 MockRead(kQuicAlternativeServiceDifferentPortHttpHeader), | 724 MockRead(kQuicAlternativeServiceDifferentPortHeader), |
| 746 MockRead("hello world"), | 725 MockRead("hello world"), |
| 747 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | 726 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
| 748 MockRead(ASYNC, OK)}; | 727 MockRead(ASYNC, OK)}; |
| 749 | 728 |
| 750 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, | 729 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, |
| 751 0); | 730 0); |
| 752 socket_factory_.AddSocketDataProvider(&http_data); | 731 socket_factory_.AddSocketDataProvider(&http_data); |
| 732 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 753 | 733 |
| 754 MockQuicData mock_quic_data; | 734 MockQuicData mock_quic_data; |
| 755 mock_quic_data.AddWrite( | 735 mock_quic_data.AddWrite( |
| 756 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, | 736 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, |
| 757 GetRequestHeaders("GET", "http", "/"))); | 737 GetRequestHeaders("GET", "https", "/"))); |
| 758 mock_quic_data.AddRead(ConstructResponseHeadersPacket( | 738 mock_quic_data.AddRead(ConstructResponseHeadersPacket( |
| 759 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); | 739 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); |
| 760 mock_quic_data.AddRead( | 740 mock_quic_data.AddRead( |
| 761 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); | 741 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); |
| 762 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); | 742 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
| 763 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read | 743 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read |
| 764 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF | 744 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF |
| 765 | 745 |
| 766 mock_quic_data.AddSocketDataToFactory(&socket_factory_); | 746 mock_quic_data.AddSocketDataToFactory(&socket_factory_); |
| 767 | 747 |
| 768 AddHangingNonAlternateProtocolSocketData(); | 748 AddHangingNonAlternateProtocolSocketData(); |
| 769 CreateSessionWithNextProtos(); | 749 CreateSessionWithNextProtos(); |
| 770 | 750 |
| 771 SendRequestAndExpectHttpResponse("hello world"); | 751 SendRequestAndExpectHttpResponse("hello world"); |
| 772 SendRequestAndExpectQuicResponseOnPort("hello!", 137); | 752 SendRequestAndExpectQuicResponseOnPort("hello!", 137); |
| 773 } | 753 } |
| 774 | 754 |
| 775 TEST_P(QuicNetworkTransactionTest, ConfirmAlternativeService) { | 755 TEST_P(QuicNetworkTransactionTest, ConfirmAlternativeService) { |
| 776 params_.enable_insecure_quic = true; | |
| 777 | |
| 778 MockRead http_reads[] = { | 756 MockRead http_reads[] = { |
| 779 MockRead("HTTP/1.1 200 OK\r\n"), | 757 MockRead("HTTP/1.1 200 OK\r\n"), MockRead(kQuicAlternativeServiceHeader), |
| 780 MockRead(kQuicAlternativeServiceHttpHeader), MockRead("hello world"), | 758 MockRead("hello world"), |
| 781 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | 759 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
| 782 MockRead(ASYNC, OK)}; | 760 MockRead(ASYNC, OK)}; |
| 783 | 761 |
| 784 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, | 762 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, |
| 785 0); | 763 0); |
| 786 socket_factory_.AddSocketDataProvider(&http_data); | 764 socket_factory_.AddSocketDataProvider(&http_data); |
| 765 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 787 | 766 |
| 788 MockQuicData mock_quic_data; | 767 MockQuicData mock_quic_data; |
| 789 mock_quic_data.AddWrite( | 768 mock_quic_data.AddWrite( |
| 790 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, | 769 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, |
| 791 GetRequestHeaders("GET", "http", "/"))); | 770 GetRequestHeaders("GET", "https", "/"))); |
| 792 mock_quic_data.AddRead(ConstructResponseHeadersPacket( | 771 mock_quic_data.AddRead(ConstructResponseHeadersPacket( |
| 793 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); | 772 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); |
| 794 mock_quic_data.AddRead( | 773 mock_quic_data.AddRead( |
| 795 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); | 774 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); |
| 796 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); | 775 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
| 797 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read | 776 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read |
| 798 mock_quic_data.AddRead(ASYNC, 0); // EOF | 777 mock_quic_data.AddRead(ASYNC, 0); // EOF |
| 799 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF | 778 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF |
| 800 | 779 |
| 801 mock_quic_data.AddSocketDataToFactory(&socket_factory_); | 780 mock_quic_data.AddSocketDataToFactory(&socket_factory_); |
| (...skipping 11 matching lines...) Expand all Loading... |
| 813 SendRequestAndExpectHttpResponse("hello world"); | 792 SendRequestAndExpectHttpResponse("hello world"); |
| 814 SendRequestAndExpectQuicResponse("hello!"); | 793 SendRequestAndExpectQuicResponse("hello!"); |
| 815 | 794 |
| 816 mock_quic_data.CompleteRead(); | 795 mock_quic_data.CompleteRead(); |
| 817 | 796 |
| 818 EXPECT_FALSE(http_server_properties_.WasAlternativeServiceRecentlyBroken( | 797 EXPECT_FALSE(http_server_properties_.WasAlternativeServiceRecentlyBroken( |
| 819 alternative_service)); | 798 alternative_service)); |
| 820 } | 799 } |
| 821 | 800 |
| 822 TEST_P(QuicNetworkTransactionTest, UseAlternativeServiceProbabilityForQuic) { | 801 TEST_P(QuicNetworkTransactionTest, UseAlternativeServiceProbabilityForQuic) { |
| 823 params_.enable_insecure_quic = true; | |
| 824 | |
| 825 MockRead http_reads[] = { | 802 MockRead http_reads[] = { |
| 826 MockRead("HTTP/1.1 200 OK\r\n"), | 803 MockRead("HTTP/1.1 200 OK\r\n"), |
| 827 MockRead(kQuicAlternativeService50pctHttpHeader), MockRead("hello world"), | 804 MockRead(kQuicAlternativeService50pctHeader), MockRead("hello world"), |
| 828 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | 805 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
| 829 MockRead(ASYNC, OK)}; | 806 MockRead(ASYNC, OK)}; |
| 830 | 807 |
| 831 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, | 808 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, |
| 832 0); | 809 0); |
| 833 socket_factory_.AddSocketDataProvider(&http_data); | 810 socket_factory_.AddSocketDataProvider(&http_data); |
| 811 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 834 | 812 |
| 835 MockQuicData mock_quic_data; | 813 MockQuicData mock_quic_data; |
| 836 mock_quic_data.AddWrite( | 814 mock_quic_data.AddWrite( |
| 837 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, | 815 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, |
| 838 GetRequestHeaders("GET", "http", "/"))); | 816 GetRequestHeaders("GET", "https", "/"))); |
| 839 mock_quic_data.AddRead(ConstructResponseHeadersPacket( | 817 mock_quic_data.AddRead(ConstructResponseHeadersPacket( |
| 840 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); | 818 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); |
| 841 mock_quic_data.AddRead( | 819 mock_quic_data.AddRead( |
| 842 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); | 820 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); |
| 843 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); | 821 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
| 844 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read | 822 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read |
| 845 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF | 823 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF |
| 846 | 824 |
| 847 mock_quic_data.AddSocketDataToFactory(&socket_factory_); | 825 mock_quic_data.AddSocketDataToFactory(&socket_factory_); |
| 848 | 826 |
| 849 AddHangingNonAlternateProtocolSocketData(); | 827 AddHangingNonAlternateProtocolSocketData(); |
| 850 params_.alternative_service_probability_threshold = 0.25; | 828 params_.alternative_service_probability_threshold = 0.25; |
| 851 CreateSessionWithNextProtos(); | 829 CreateSessionWithNextProtos(); |
| 852 | 830 |
| 853 SendRequestAndExpectHttpResponse("hello world"); | 831 SendRequestAndExpectHttpResponse("hello world"); |
| 854 SendRequestAndExpectQuicResponse("hello!"); | 832 SendRequestAndExpectQuicResponse("hello!"); |
| 855 } | 833 } |
| 856 | 834 |
| 857 TEST_P(QuicNetworkTransactionTest, | 835 TEST_P(QuicNetworkTransactionTest, |
| 858 DontUseAlternativeServiceProbabilityForQuic) { | 836 DontUseAlternativeServiceProbabilityForQuic) { |
| 859 params_.enable_insecure_quic = true; | |
| 860 | |
| 861 MockRead http_reads[] = { | 837 MockRead http_reads[] = { |
| 862 MockRead("HTTP/1.1 200 OK\r\n"), | 838 MockRead("HTTP/1.1 200 OK\r\n"), |
| 863 MockRead(kQuicAlternativeService50pctHttpHeader), MockRead("hello world"), | 839 MockRead(kQuicAlternativeService50pctHeader), MockRead("hello world"), |
| 864 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | 840 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
| 865 MockRead(ASYNC, OK)}; | 841 MockRead(ASYNC, OK)}; |
| 866 | 842 |
| 867 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, | 843 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, |
| 868 0); | 844 0); |
| 869 socket_factory_.AddSocketDataProvider(&http_data); | 845 socket_factory_.AddSocketDataProvider(&http_data); |
| 846 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 870 socket_factory_.AddSocketDataProvider(&http_data); | 847 socket_factory_.AddSocketDataProvider(&http_data); |
| 848 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 871 | 849 |
| 872 params_.alternative_service_probability_threshold = 0.75; | 850 params_.alternative_service_probability_threshold = 0.75; |
| 873 CreateSessionWithNextProtos(); | 851 CreateSessionWithNextProtos(); |
| 874 | 852 |
| 875 SendRequestAndExpectHttpResponse("hello world"); | 853 SendRequestAndExpectHttpResponse("hello world"); |
| 876 SendRequestAndExpectHttpResponse("hello world"); | 854 SendRequestAndExpectHttpResponse("hello world"); |
| 877 } | 855 } |
| 878 | 856 |
| 879 TEST_P(QuicNetworkTransactionTest, DontUseAlternativeServiceForInsecureQuic) { | |
| 880 params_.enable_insecure_quic = true; | |
| 881 | |
| 882 MockRead http_reads[] = {MockRead("HTTP/1.1 200 OK\r\n"), | |
| 883 MockRead("Content-length: 11\r\n"), | |
| 884 MockRead("Alt-Svc: quic=\":443\"\r\n\r\n"), | |
| 885 MockRead("hello world"), | |
| 886 MockRead("HTTP/1.1 200 OK\r\n"), | |
| 887 MockRead("Content-length: 11\r\n"), | |
| 888 MockRead("Alt-Svc: quic=\":443\"\r\n\r\n"), | |
| 889 MockRead("hello world"), | |
| 890 MockRead(ASYNC, OK)}; | |
| 891 | |
| 892 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, | |
| 893 0); | |
| 894 socket_factory_.AddSocketDataProvider(&http_data); | |
| 895 socket_factory_.AddSocketDataProvider(&http_data); | |
| 896 | |
| 897 params_.enable_insecure_quic = false; | |
| 898 CreateSessionWithNextProtos(); | |
| 899 | |
| 900 SendRequestAndExpectHttpResponse("hello world"); | |
| 901 SendRequestAndExpectHttpResponse("hello world"); | |
| 902 } | |
| 903 | |
| 904 TEST_P(QuicNetworkTransactionTest, | 857 TEST_P(QuicNetworkTransactionTest, |
| 905 DontUseAlternativeServiceWithBadProbabilityForQuic) { | 858 DontUseAlternativeServiceWithBadProbabilityForQuic) { |
| 906 params_.enable_insecure_quic = true; | |
| 907 | |
| 908 MockRead http_reads[] = { | 859 MockRead http_reads[] = { |
| 909 MockRead("HTTP/1.1 200 OK\r\n"), | 860 MockRead("HTTP/1.1 200 OK\r\n"), |
| 910 MockRead("Alt-Svc: quic=\":443\";p=2\r\n\r\n"), MockRead("hello world"), | 861 MockRead("Alt-Svc: quic=\":443\";p=2\r\n\r\n"), MockRead("hello world"), |
| 911 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | 862 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
| 912 MockRead(ASYNC, OK)}; | 863 MockRead(ASYNC, OK)}; |
| 913 | 864 |
| 914 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, | 865 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, |
| 915 0); | 866 0); |
| 916 socket_factory_.AddSocketDataProvider(&http_data); | 867 socket_factory_.AddSocketDataProvider(&http_data); |
| 868 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 917 socket_factory_.AddSocketDataProvider(&http_data); | 869 socket_factory_.AddSocketDataProvider(&http_data); |
| 870 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 918 | 871 |
| 919 params_.alternative_service_probability_threshold = 0.75; | 872 params_.alternative_service_probability_threshold = 0.75; |
| 920 CreateSessionWithNextProtos(); | 873 CreateSessionWithNextProtos(); |
| 921 | 874 |
| 922 SendRequestAndExpectHttpResponse("hello world"); | 875 SendRequestAndExpectHttpResponse("hello world"); |
| 923 SendRequestAndExpectHttpResponse("hello world"); | 876 SendRequestAndExpectHttpResponse("hello world"); |
| 924 } | 877 } |
| 925 | 878 |
| 926 TEST_P(QuicNetworkTransactionTest, UseAlternativeServiceForQuicForHttps) { | 879 TEST_P(QuicNetworkTransactionTest, UseAlternativeServiceForQuicForHttps) { |
| 927 params_.enable_insecure_quic = true; | |
| 928 params_.origin_to_force_quic_on = | |
| 929 HostPortPair::FromString("www.google.com:443"); | |
| 930 | |
| 931 MockRead http_reads[] = { | 880 MockRead http_reads[] = { |
| 932 MockRead("HTTP/1.1 200 OK\r\n"), | 881 MockRead("HTTP/1.1 200 OK\r\n"), MockRead(kQuicAlternativeServiceHeader), |
| 933 MockRead(kQuicAlternativeServiceHttpsHeader), MockRead("hello world"), | 882 MockRead("hello world"), |
| 934 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | 883 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
| 935 MockRead(ASYNC, OK)}; | 884 MockRead(ASYNC, OK)}; |
| 936 | 885 |
| 937 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, | 886 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, |
| 938 0); | 887 0); |
| 939 socket_factory_.AddSocketDataProvider(&http_data); | 888 socket_factory_.AddSocketDataProvider(&http_data); |
| 889 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 940 | 890 |
| 941 MockQuicData mock_quic_data; | 891 MockQuicData mock_quic_data; |
| 942 mock_quic_data.AddWrite( | 892 mock_quic_data.AddWrite( |
| 943 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, | 893 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, |
| 944 GetRequestHeaders("GET", "http", "/"))); | 894 GetRequestHeaders("GET", "https", "/"))); |
| 945 mock_quic_data.AddRead(ConstructResponseHeadersPacket( | 895 mock_quic_data.AddRead(ConstructResponseHeadersPacket( |
| 946 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); | 896 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); |
| 947 mock_quic_data.AddRead( | 897 mock_quic_data.AddRead( |
| 948 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); | 898 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); |
| 949 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); | 899 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
| 950 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF | 900 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF |
| 951 | 901 |
| 952 mock_quic_data.AddSocketDataToFactory(&socket_factory_); | 902 mock_quic_data.AddSocketDataToFactory(&socket_factory_); |
| 953 | 903 |
| 954 AddHangingNonAlternateProtocolSocketData(); | 904 AddHangingNonAlternateProtocolSocketData(); |
| 955 CreateSessionWithNextProtos(); | 905 CreateSessionWithNextProtos(); |
| 956 | 906 |
| 957 // TODO(rtenneti): Test QUIC over HTTPS, GetSSLInfo(). | 907 // TODO(rtenneti): Test QUIC over HTTPS, GetSSLInfo(). |
| 958 SendRequestAndExpectHttpResponse("hello world"); | 908 SendRequestAndExpectHttpResponse("hello world"); |
| 959 } | 909 } |
| 960 | 910 |
| 961 TEST_P(QuicNetworkTransactionTest, UseAlternateProtocolForQuic) { | 911 TEST_P(QuicNetworkTransactionTest, UseAlternateProtocolForQuic) { |
| 962 params_.enable_insecure_quic = true; | |
| 963 | |
| 964 MockRead http_reads[] = { | 912 MockRead http_reads[] = { |
| 965 MockRead("HTTP/1.1 200 OK\r\n"), | 913 MockRead("HTTP/1.1 200 OK\r\n"), MockRead(kQuicAlternateProtocolHeader), |
| 966 MockRead(kQuicAlternateProtocolHttpHeader), | 914 MockRead("hello world"), |
| 967 MockRead("hello world"), | 915 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
| 968 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | 916 MockRead(ASYNC, OK)}; |
| 969 MockRead(ASYNC, OK) | |
| 970 }; | |
| 971 | 917 |
| 972 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), | 918 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), |
| 973 nullptr, 0); | 919 nullptr, 0); |
| 974 socket_factory_.AddSocketDataProvider(&http_data); | 920 socket_factory_.AddSocketDataProvider(&http_data); |
| 921 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 975 | 922 |
| 976 MockQuicData mock_quic_data; | 923 MockQuicData mock_quic_data; |
| 977 mock_quic_data.AddWrite( | 924 mock_quic_data.AddWrite( |
| 978 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, | 925 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, |
| 979 GetRequestHeaders("GET", "http", "/"))); | 926 GetRequestHeaders("GET", "https", "/"))); |
| 980 mock_quic_data.AddRead( | 927 mock_quic_data.AddRead( |
| 981 ConstructResponseHeadersPacket(1, kClientDataStreamId1, false, false, | 928 ConstructResponseHeadersPacket(1, kClientDataStreamId1, false, false, |
| 982 GetResponseHeaders("200 OK"))); | 929 GetResponseHeaders("200 OK"))); |
| 983 mock_quic_data.AddRead( | 930 mock_quic_data.AddRead( |
| 984 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); | 931 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); |
| 985 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); | 932 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
| 986 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read | 933 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read |
| 987 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF | 934 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF |
| 988 | 935 |
| 989 mock_quic_data.AddSocketDataToFactory(&socket_factory_); | 936 mock_quic_data.AddSocketDataToFactory(&socket_factory_); |
| 990 | 937 |
| 991 // The non-alternate protocol job needs to hang in order to guarantee that | 938 // The non-alternate protocol job needs to hang in order to guarantee that |
| 992 // the alternate-protocol job will "win". | 939 // the alternate-protocol job will "win". |
| 993 AddHangingNonAlternateProtocolSocketData(); | 940 AddHangingNonAlternateProtocolSocketData(); |
| 994 | 941 |
| 995 CreateSessionWithNextProtos(); | 942 CreateSessionWithNextProtos(); |
| 996 | 943 |
| 997 SendRequestAndExpectHttpResponse("hello world"); | 944 SendRequestAndExpectHttpResponse("hello world"); |
| 998 SendRequestAndExpectQuicResponse("hello!"); | 945 SendRequestAndExpectQuicResponse("hello!"); |
| 999 } | 946 } |
| 1000 | 947 |
| 1001 TEST_P(QuicNetworkTransactionTest, AlternateProtocolDifferentPort) { | 948 TEST_P(QuicNetworkTransactionTest, AlternateProtocolDifferentPort) { |
| 1002 params_.enable_insecure_quic = true; | |
| 1003 | |
| 1004 MockRead http_reads[] = { | 949 MockRead http_reads[] = { |
| 1005 MockRead("HTTP/1.1 200 OK\r\n"), | 950 MockRead("HTTP/1.1 200 OK\r\n"), |
| 1006 MockRead(kQuicAlternateProtocolDifferentPortHttpHeader), | 951 MockRead(kQuicAlternateProtocolDifferentPortHeader), |
| 1007 MockRead("hello world"), | 952 MockRead("hello world"), |
| 1008 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | 953 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
| 1009 MockRead(ASYNC, OK)}; | 954 MockRead(ASYNC, OK)}; |
| 1010 | 955 |
| 1011 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, | 956 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, |
| 1012 0); | 957 0); |
| 1013 socket_factory_.AddSocketDataProvider(&http_data); | 958 socket_factory_.AddSocketDataProvider(&http_data); |
| 959 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 1014 | 960 |
| 1015 MockQuicData mock_quic_data; | 961 MockQuicData mock_quic_data; |
| 1016 mock_quic_data.AddWrite( | 962 mock_quic_data.AddWrite( |
| 1017 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, | 963 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, |
| 1018 GetRequestHeaders("GET", "http", "/"))); | 964 GetRequestHeaders("GET", "https", "/"))); |
| 1019 mock_quic_data.AddRead(ConstructResponseHeadersPacket( | 965 mock_quic_data.AddRead(ConstructResponseHeadersPacket( |
| 1020 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); | 966 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); |
| 1021 mock_quic_data.AddRead( | 967 mock_quic_data.AddRead( |
| 1022 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); | 968 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); |
| 1023 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); | 969 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
| 1024 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read | 970 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read |
| 1025 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF | 971 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF |
| 1026 | 972 |
| 1027 mock_quic_data.AddSocketDataToFactory(&socket_factory_); | 973 mock_quic_data.AddSocketDataToFactory(&socket_factory_); |
| 1028 | 974 |
| 1029 // The non-alternate protocol job needs to hang in order to guarantee that | 975 // The non-alternate protocol job needs to hang in order to guarantee that |
| 1030 // the alternate-protocol job will "win". | 976 // the alternate-protocol job will "win". |
| 1031 AddHangingNonAlternateProtocolSocketData(); | 977 AddHangingNonAlternateProtocolSocketData(); |
| 1032 | 978 |
| 1033 CreateSessionWithNextProtos(); | 979 CreateSessionWithNextProtos(); |
| 1034 | 980 |
| 1035 SendRequestAndExpectHttpResponse("hello world"); | 981 SendRequestAndExpectHttpResponse("hello world"); |
| 1036 SendRequestAndExpectQuicResponseOnPort("hello!", 137); | 982 SendRequestAndExpectQuicResponseOnPort("hello!", 137); |
| 1037 } | 983 } |
| 1038 | 984 |
| 1039 TEST_P(QuicNetworkTransactionTest, ConfirmAlternateProtocol) { | 985 TEST_P(QuicNetworkTransactionTest, ConfirmAlternateProtocol) { |
| 1040 params_.enable_insecure_quic = true; | |
| 1041 | |
| 1042 MockRead http_reads[] = { | 986 MockRead http_reads[] = { |
| 1043 MockRead("HTTP/1.1 200 OK\r\n"), | 987 MockRead("HTTP/1.1 200 OK\r\n"), MockRead(kQuicAlternateProtocolHeader), |
| 1044 MockRead(kQuicAlternateProtocolHttpHeader), | |
| 1045 MockRead("hello world"), | 988 MockRead("hello world"), |
| 1046 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | 989 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
| 1047 MockRead(ASYNC, OK)}; | 990 MockRead(ASYNC, OK)}; |
| 1048 | 991 |
| 1049 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, | 992 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, |
| 1050 0); | 993 0); |
| 1051 socket_factory_.AddSocketDataProvider(&http_data); | 994 socket_factory_.AddSocketDataProvider(&http_data); |
| 995 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 1052 | 996 |
| 1053 MockQuicData mock_quic_data; | 997 MockQuicData mock_quic_data; |
| 1054 mock_quic_data.AddWrite( | 998 mock_quic_data.AddWrite( |
| 1055 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, | 999 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, |
| 1056 GetRequestHeaders("GET", "http", "/"))); | 1000 GetRequestHeaders("GET", "https", "/"))); |
| 1057 mock_quic_data.AddRead(ConstructResponseHeadersPacket( | 1001 mock_quic_data.AddRead(ConstructResponseHeadersPacket( |
| 1058 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); | 1002 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); |
| 1059 mock_quic_data.AddRead( | 1003 mock_quic_data.AddRead( |
| 1060 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); | 1004 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); |
| 1061 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); | 1005 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
| 1062 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read | 1006 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read |
| 1063 mock_quic_data.AddRead(ASYNC, 0); // EOF | 1007 mock_quic_data.AddRead(ASYNC, 0); // EOF |
| 1064 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF | 1008 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF |
| 1065 | 1009 |
| 1066 mock_quic_data.AddSocketDataToFactory(&socket_factory_); | 1010 mock_quic_data.AddSocketDataToFactory(&socket_factory_); |
| (...skipping 14 matching lines...) Expand all Loading... |
| 1081 SendRequestAndExpectHttpResponse("hello world"); | 1025 SendRequestAndExpectHttpResponse("hello world"); |
| 1082 SendRequestAndExpectQuicResponse("hello!"); | 1026 SendRequestAndExpectQuicResponse("hello!"); |
| 1083 | 1027 |
| 1084 mock_quic_data.CompleteRead(); | 1028 mock_quic_data.CompleteRead(); |
| 1085 | 1029 |
| 1086 EXPECT_FALSE(http_server_properties_.WasAlternativeServiceRecentlyBroken( | 1030 EXPECT_FALSE(http_server_properties_.WasAlternativeServiceRecentlyBroken( |
| 1087 alternative_service)); | 1031 alternative_service)); |
| 1088 } | 1032 } |
| 1089 | 1033 |
| 1090 TEST_P(QuicNetworkTransactionTest, UseAlternateProtocolProbabilityForQuic) { | 1034 TEST_P(QuicNetworkTransactionTest, UseAlternateProtocolProbabilityForQuic) { |
| 1091 params_.enable_insecure_quic = true; | |
| 1092 | |
| 1093 MockRead http_reads[] = { | 1035 MockRead http_reads[] = { |
| 1094 MockRead("HTTP/1.1 200 OK\r\n"), | 1036 MockRead("HTTP/1.1 200 OK\r\n"), |
| 1095 MockRead(kQuicAlternateProtocol50pctHttpHeader), | 1037 MockRead(kQuicAlternateProtocol50pctHeader), MockRead("hello world"), |
| 1096 MockRead("hello world"), | 1038 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
| 1097 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | 1039 MockRead(ASYNC, OK)}; |
| 1098 MockRead(ASYNC, OK) | |
| 1099 }; | |
| 1100 | 1040 |
| 1101 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), | 1041 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), |
| 1102 nullptr, 0); | 1042 nullptr, 0); |
| 1103 socket_factory_.AddSocketDataProvider(&http_data); | 1043 socket_factory_.AddSocketDataProvider(&http_data); |
| 1104 | 1044 |
| 1105 MockQuicData mock_quic_data; | 1045 MockQuicData mock_quic_data; |
| 1106 mock_quic_data.AddWrite( | 1046 mock_quic_data.AddWrite( |
| 1107 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, | 1047 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, |
| 1108 GetRequestHeaders("GET", "http", "/"))); | 1048 GetRequestHeaders("GET", "https", "/"))); |
| 1109 mock_quic_data.AddRead( | 1049 mock_quic_data.AddRead( |
| 1110 ConstructResponseHeadersPacket(1, kClientDataStreamId1, false, false, | 1050 ConstructResponseHeadersPacket(1, kClientDataStreamId1, false, false, |
| 1111 GetResponseHeaders("200 OK"))); | 1051 GetResponseHeaders("200 OK"))); |
| 1112 mock_quic_data.AddRead( | 1052 mock_quic_data.AddRead( |
| 1113 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); | 1053 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); |
| 1114 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); | 1054 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
| 1115 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read | 1055 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read |
| 1116 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF | 1056 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF |
| 1117 | 1057 |
| 1118 mock_quic_data.AddSocketDataToFactory(&socket_factory_); | 1058 mock_quic_data.AddSocketDataToFactory(&socket_factory_); |
| 1119 | 1059 |
| 1120 // The non-alternate protocol job needs to hang in order to guarantee that | 1060 // The non-alternate protocol job needs to hang in order to guarantee that |
| 1121 // the alternate-protocol job will "win". | 1061 // the alternate-protocol job will "win". |
| 1122 AddHangingNonAlternateProtocolSocketData(); | 1062 AddHangingNonAlternateProtocolSocketData(); |
| 1123 | 1063 |
| 1124 params_.alternative_service_probability_threshold = .25; | 1064 params_.alternative_service_probability_threshold = .25; |
| 1125 CreateSessionWithNextProtos(); | 1065 CreateSessionWithNextProtos(); |
| 1126 | 1066 |
| 1127 SendRequestAndExpectHttpResponse("hello world"); | 1067 SendRequestAndExpectHttpResponse("hello world"); |
| 1128 SendRequestAndExpectQuicResponse("hello!"); | 1068 SendRequestAndExpectQuicResponse("hello!"); |
| 1129 } | 1069 } |
| 1130 | 1070 |
| 1131 TEST_P(QuicNetworkTransactionTest, DontUseAlternateProtocolProbabilityForQuic) { | 1071 TEST_P(QuicNetworkTransactionTest, DontUseAlternateProtocolProbabilityForQuic) { |
| 1132 params_.enable_insecure_quic = true; | |
| 1133 | |
| 1134 MockRead http_reads[] = { | 1072 MockRead http_reads[] = { |
| 1135 MockRead("HTTP/1.1 200 OK\r\n"), | 1073 MockRead("HTTP/1.1 200 OK\r\n"), |
| 1136 MockRead(kQuicAlternateProtocol50pctHttpHeader), | 1074 MockRead(kQuicAlternateProtocol50pctHeader), MockRead("hello world"), |
| 1137 MockRead("hello world"), | 1075 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
| 1138 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | 1076 MockRead(ASYNC, OK)}; |
| 1139 MockRead(ASYNC, OK) | |
| 1140 }; | |
| 1141 | 1077 |
| 1142 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), | 1078 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), |
| 1143 nullptr, 0); | 1079 nullptr, 0); |
| 1144 socket_factory_.AddSocketDataProvider(&http_data); | 1080 socket_factory_.AddSocketDataProvider(&http_data); |
| 1081 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 1145 socket_factory_.AddSocketDataProvider(&http_data); | 1082 socket_factory_.AddSocketDataProvider(&http_data); |
| 1083 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 1146 | 1084 |
| 1147 params_.alternative_service_probability_threshold = .75; | 1085 params_.alternative_service_probability_threshold = .75; |
| 1148 CreateSessionWithNextProtos(); | 1086 CreateSessionWithNextProtos(); |
| 1149 | 1087 |
| 1150 SendRequestAndExpectHttpResponse("hello world"); | 1088 SendRequestAndExpectHttpResponse("hello world"); |
| 1151 SendRequestAndExpectHttpResponse("hello world"); | 1089 SendRequestAndExpectHttpResponse("hello world"); |
| 1152 } | 1090 } |
| 1153 | 1091 |
| 1154 TEST_P(QuicNetworkTransactionTest, DontUseAlternateProtocolForInsecureQuic) { | |
| 1155 params_.enable_insecure_quic = true; | |
| 1156 | |
| 1157 MockRead http_reads[] = {MockRead("HTTP/1.1 200 OK\r\n"), | |
| 1158 MockRead("Content-length: 11\r\n"), | |
| 1159 MockRead("Alternate-Protocol: 443:quic\r\n\r\n"), | |
| 1160 MockRead("hello world"), | |
| 1161 MockRead("HTTP/1.1 200 OK\r\n"), | |
| 1162 MockRead("Content-length: 11\r\n"), | |
| 1163 MockRead("Alternate-Protocol: 443:quic\r\n\r\n"), | |
| 1164 MockRead("hello world"), | |
| 1165 MockRead(ASYNC, OK)}; | |
| 1166 | |
| 1167 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, | |
| 1168 0); | |
| 1169 socket_factory_.AddSocketDataProvider(&http_data); | |
| 1170 socket_factory_.AddSocketDataProvider(&http_data); | |
| 1171 | |
| 1172 params_.enable_insecure_quic = false; | |
| 1173 CreateSessionWithNextProtos(); | |
| 1174 | |
| 1175 SendRequestAndExpectHttpResponse("hello world"); | |
| 1176 SendRequestAndExpectHttpResponse("hello world"); | |
| 1177 } | |
| 1178 | |
| 1179 TEST_P(QuicNetworkTransactionTest, | 1092 TEST_P(QuicNetworkTransactionTest, |
| 1180 DontUseAlternateProtocolWithBadProbabilityForQuic) { | 1093 DontUseAlternateProtocolWithBadProbabilityForQuic) { |
| 1181 params_.enable_insecure_quic = true; | |
| 1182 | |
| 1183 MockRead http_reads[] = { | 1094 MockRead http_reads[] = { |
| 1184 MockRead("HTTP/1.1 200 OK\r\n"), | 1095 MockRead("HTTP/1.1 200 OK\r\n"), |
| 1185 MockRead("Alternate-Protocol: 443:quic,p=2\r\n\r\n"), | 1096 MockRead("Alternate-Protocol: 443:quic,p=2\r\n\r\n"), |
| 1186 MockRead("hello world"), | 1097 MockRead("hello world"), |
| 1187 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | 1098 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
| 1188 MockRead(ASYNC, OK) | 1099 MockRead(ASYNC, OK) |
| 1189 }; | 1100 }; |
| 1190 | 1101 |
| 1191 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), | 1102 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), |
| 1192 nullptr, 0); | 1103 nullptr, 0); |
| 1193 socket_factory_.AddSocketDataProvider(&http_data); | 1104 socket_factory_.AddSocketDataProvider(&http_data); |
| 1105 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 1194 socket_factory_.AddSocketDataProvider(&http_data); | 1106 socket_factory_.AddSocketDataProvider(&http_data); |
| 1107 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 1195 | 1108 |
| 1196 params_.alternative_service_probability_threshold = .75; | 1109 params_.alternative_service_probability_threshold = .75; |
| 1197 CreateSessionWithNextProtos(); | 1110 CreateSessionWithNextProtos(); |
| 1198 | 1111 |
| 1199 SendRequestAndExpectHttpResponse("hello world"); | 1112 SendRequestAndExpectHttpResponse("hello world"); |
| 1200 SendRequestAndExpectHttpResponse("hello world"); | 1113 SendRequestAndExpectHttpResponse("hello world"); |
| 1201 } | 1114 } |
| 1202 | 1115 |
| 1203 TEST_P(QuicNetworkTransactionTest, UseAlternateProtocolForQuicForHttps) { | 1116 TEST_P(QuicNetworkTransactionTest, UseAlternateProtocolForQuicForHttps) { |
| 1204 params_.enable_insecure_quic = true; | |
| 1205 params_.origin_to_force_quic_on = | |
| 1206 HostPortPair::FromString("www.google.com:443"); | |
| 1207 | |
| 1208 MockRead http_reads[] = { | 1117 MockRead http_reads[] = { |
| 1209 MockRead("HTTP/1.1 200 OK\r\n"), | 1118 MockRead("HTTP/1.1 200 OK\r\n"), MockRead(kQuicAlternateProtocolHeader), |
| 1210 MockRead(kQuicAlternateProtocolHttpsHeader), | 1119 MockRead("hello world"), |
| 1211 MockRead("hello world"), | 1120 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
| 1212 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | 1121 MockRead(ASYNC, OK)}; |
| 1213 MockRead(ASYNC, OK) | |
| 1214 }; | |
| 1215 | 1122 |
| 1216 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), | 1123 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), |
| 1217 nullptr, 0); | 1124 nullptr, 0); |
| 1218 socket_factory_.AddSocketDataProvider(&http_data); | 1125 socket_factory_.AddSocketDataProvider(&http_data); |
| 1219 | 1126 |
| 1220 MockQuicData mock_quic_data; | 1127 MockQuicData mock_quic_data; |
| 1221 mock_quic_data.AddWrite( | 1128 mock_quic_data.AddWrite( |
| 1222 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, | 1129 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, |
| 1223 GetRequestHeaders("GET", "http", "/"))); | 1130 GetRequestHeaders("GET", "https", "/"))); |
| 1224 mock_quic_data.AddRead( | 1131 mock_quic_data.AddRead( |
| 1225 ConstructResponseHeadersPacket(1, kClientDataStreamId1, false, false, | 1132 ConstructResponseHeadersPacket(1, kClientDataStreamId1, false, false, |
| 1226 GetResponseHeaders("200 OK"))); | 1133 GetResponseHeaders("200 OK"))); |
| 1227 mock_quic_data.AddRead( | 1134 mock_quic_data.AddRead( |
| 1228 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); | 1135 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); |
| 1229 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); | 1136 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
| 1230 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read | 1137 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read |
| 1231 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF | 1138 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF |
| 1232 | 1139 |
| 1233 mock_quic_data.AddSocketDataToFactory(&socket_factory_); | 1140 mock_quic_data.AddSocketDataToFactory(&socket_factory_); |
| (...skipping 85 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1319 RequestSucceedsWithValidCertificate) { | 1226 RequestSucceedsWithValidCertificate) { |
| 1320 Run(true); | 1227 Run(true); |
| 1321 } | 1228 } |
| 1322 | 1229 |
| 1323 TEST_P(QuicAltSvcCertificateVerificationTest, | 1230 TEST_P(QuicAltSvcCertificateVerificationTest, |
| 1324 RequestFailsWithInvalidCertificate) { | 1231 RequestFailsWithInvalidCertificate) { |
| 1325 Run(false); | 1232 Run(false); |
| 1326 } | 1233 } |
| 1327 | 1234 |
| 1328 TEST_P(QuicNetworkTransactionTest, HungAlternateProtocol) { | 1235 TEST_P(QuicNetworkTransactionTest, HungAlternateProtocol) { |
| 1329 params_.enable_insecure_quic = true; | |
| 1330 crypto_client_stream_factory_.set_handshake_mode( | 1236 crypto_client_stream_factory_.set_handshake_mode( |
| 1331 MockCryptoClientStream::COLD_START); | 1237 MockCryptoClientStream::COLD_START); |
| 1332 | 1238 |
| 1333 MockWrite http_writes[] = { | 1239 MockWrite http_writes[] = { |
| 1334 MockWrite(SYNCHRONOUS, 0, "GET / HTTP/1.1\r\n"), | 1240 MockWrite(SYNCHRONOUS, 0, "GET / HTTP/1.1\r\n"), |
| 1335 MockWrite(SYNCHRONOUS, 1, "Host: www.google.com\r\n"), | 1241 MockWrite(SYNCHRONOUS, 1, "Host: mail.example.com\r\n"), |
| 1336 MockWrite(SYNCHRONOUS, 2, "Connection: keep-alive\r\n\r\n") | 1242 MockWrite(SYNCHRONOUS, 2, "Connection: keep-alive\r\n\r\n")}; |
| 1337 }; | |
| 1338 | 1243 |
| 1339 MockRead http_reads[] = { | 1244 MockRead http_reads[] = { |
| 1340 MockRead(SYNCHRONOUS, 3, "HTTP/1.1 200 OK\r\n"), | 1245 MockRead(SYNCHRONOUS, 3, "HTTP/1.1 200 OK\r\n"), |
| 1341 MockRead(SYNCHRONOUS, 4, kQuicAlternateProtocolHttpHeader), | 1246 MockRead(SYNCHRONOUS, 4, kQuicAlternateProtocolHeader), |
| 1342 MockRead(SYNCHRONOUS, 5, "hello world"), | 1247 MockRead(SYNCHRONOUS, 5, "hello world"), MockRead(SYNCHRONOUS, OK, 6)}; |
| 1343 MockRead(SYNCHRONOUS, OK, 6) | |
| 1344 }; | |
| 1345 | 1248 |
| 1346 DeterministicMockClientSocketFactory socket_factory; | 1249 DeterministicMockClientSocketFactory socket_factory; |
| 1347 | 1250 |
| 1348 DeterministicSocketData http_data(http_reads, arraysize(http_reads), | 1251 DeterministicSocketData http_data(http_reads, arraysize(http_reads), |
| 1349 http_writes, arraysize(http_writes)); | 1252 http_writes, arraysize(http_writes)); |
| 1350 socket_factory.AddSocketDataProvider(&http_data); | 1253 socket_factory.AddSocketDataProvider(&http_data); |
| 1254 socket_factory.AddSSLSocketDataProvider(&ssl_data_); |
| 1351 | 1255 |
| 1352 // The QUIC transaction will not be allowed to complete. | 1256 // The QUIC transaction will not be allowed to complete. |
| 1353 MockWrite quic_writes[] = { | 1257 MockWrite quic_writes[] = { |
| 1354 MockWrite(ASYNC, ERR_IO_PENDING, 0) | 1258 MockWrite(ASYNC, ERR_IO_PENDING, 0) |
| 1355 }; | 1259 }; |
| 1356 MockRead quic_reads[] = { | 1260 MockRead quic_reads[] = { |
| 1357 MockRead(ASYNC, ERR_IO_PENDING, 1), | 1261 MockRead(ASYNC, ERR_IO_PENDING, 1), |
| 1358 }; | 1262 }; |
| 1359 DeterministicSocketData quic_data(quic_reads, arraysize(quic_reads), | 1263 DeterministicSocketData quic_data(quic_reads, arraysize(quic_reads), |
| 1360 quic_writes, arraysize(quic_writes)); | 1264 quic_writes, arraysize(quic_writes)); |
| 1361 socket_factory.AddSocketDataProvider(&quic_data); | 1265 socket_factory.AddSocketDataProvider(&quic_data); |
| 1362 | 1266 |
| 1363 // The HTTP transaction will complete. | 1267 // The HTTP transaction will complete. |
| 1364 DeterministicSocketData http_data2(http_reads, arraysize(http_reads), | 1268 DeterministicSocketData http_data2(http_reads, arraysize(http_reads), |
| 1365 http_writes, arraysize(http_writes)); | 1269 http_writes, arraysize(http_writes)); |
| 1366 socket_factory.AddSocketDataProvider(&http_data2); | 1270 socket_factory.AddSocketDataProvider(&http_data2); |
| 1271 socket_factory.AddSSLSocketDataProvider(&ssl_data_); |
| 1367 | 1272 |
| 1368 CreateSessionWithFactory(&socket_factory, true); | 1273 CreateSessionWithFactory(&socket_factory, true); |
| 1369 | 1274 |
| 1370 // Run the first request. | 1275 // Run the first request. |
| 1371 http_data.StopAfter(arraysize(http_reads) + arraysize(http_writes)); | 1276 http_data.StopAfter(arraysize(http_reads) + arraysize(http_writes)); |
| 1372 SendRequestAndExpectHttpResponse("hello world"); | 1277 SendRequestAndExpectHttpResponse("hello world"); |
| 1373 ASSERT_TRUE(http_data.AllReadDataConsumed()); | 1278 ASSERT_TRUE(http_data.AllReadDataConsumed()); |
| 1374 ASSERT_TRUE(http_data.AllWriteDataConsumed()); | 1279 ASSERT_TRUE(http_data.AllWriteDataConsumed()); |
| 1375 | 1280 |
| 1376 // Now run the second request in which the QUIC socket hangs, | 1281 // Now run the second request in which the QUIC socket hangs, |
| 1377 // and verify the the transaction continues over HTTP. | 1282 // and verify the the transaction continues over HTTP. |
| 1378 http_data2.StopAfter(arraysize(http_reads) + arraysize(http_writes)); | 1283 http_data2.StopAfter(arraysize(http_reads) + arraysize(http_writes)); |
| 1379 SendRequestAndExpectHttpResponse("hello world"); | 1284 SendRequestAndExpectHttpResponse("hello world"); |
| 1380 | 1285 |
| 1381 ASSERT_TRUE(http_data2.AllReadDataConsumed()); | 1286 ASSERT_TRUE(http_data2.AllReadDataConsumed()); |
| 1382 ASSERT_TRUE(http_data2.AllWriteDataConsumed()); | 1287 ASSERT_TRUE(http_data2.AllWriteDataConsumed()); |
| 1383 ASSERT_TRUE(!quic_data.AllReadDataConsumed()); | 1288 ASSERT_TRUE(!quic_data.AllReadDataConsumed()); |
| 1384 ASSERT_TRUE(!quic_data.AllWriteDataConsumed()); | 1289 ASSERT_TRUE(!quic_data.AllWriteDataConsumed()); |
| 1385 } | 1290 } |
| 1386 | 1291 |
| 1387 TEST_P(QuicNetworkTransactionTest, ZeroRTTWithHttpRace) { | 1292 TEST_P(QuicNetworkTransactionTest, ZeroRTTWithHttpRace) { |
| 1388 params_.enable_insecure_quic = true; | |
| 1389 MockQuicData mock_quic_data; | 1293 MockQuicData mock_quic_data; |
| 1390 mock_quic_data.AddWrite( | 1294 mock_quic_data.AddWrite( |
| 1391 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, | 1295 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, |
| 1392 GetRequestHeaders("GET", "http", "/"))); | 1296 GetRequestHeaders("GET", "https", "/"))); |
| 1393 mock_quic_data.AddRead( | 1297 mock_quic_data.AddRead( |
| 1394 ConstructResponseHeadersPacket(1, kClientDataStreamId1, false, false, | 1298 ConstructResponseHeadersPacket(1, kClientDataStreamId1, false, false, |
| 1395 GetResponseHeaders("200 OK"))); | 1299 GetResponseHeaders("200 OK"))); |
| 1396 mock_quic_data.AddRead( | 1300 mock_quic_data.AddRead( |
| 1397 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); | 1301 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); |
| 1398 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); | 1302 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
| 1399 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read | 1303 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read |
| 1400 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF | 1304 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF |
| 1401 | 1305 |
| 1402 mock_quic_data.AddSocketDataToFactory(&socket_factory_); | 1306 mock_quic_data.AddSocketDataToFactory(&socket_factory_); |
| 1403 | 1307 |
| 1404 // The non-alternate protocol job needs to hang in order to guarantee that | 1308 // The non-alternate protocol job needs to hang in order to guarantee that |
| 1405 // the alternate-protocol job will "win". | 1309 // the alternate-protocol job will "win". |
| 1406 AddHangingNonAlternateProtocolSocketData(); | 1310 AddHangingNonAlternateProtocolSocketData(); |
| 1407 | 1311 |
| 1408 CreateSessionWithNextProtos(); | 1312 CreateSessionWithNextProtos(); |
| 1409 AddQuicAlternateProtocolMapping(MockCryptoClientStream::ZERO_RTT); | 1313 AddQuicAlternateProtocolMapping(MockCryptoClientStream::ZERO_RTT); |
| 1410 SendRequestAndExpectQuicResponse("hello!"); | 1314 SendRequestAndExpectQuicResponse("hello!"); |
| 1411 } | 1315 } |
| 1412 | 1316 |
| 1413 TEST_P(QuicNetworkTransactionTest, ZeroRTTWithNoHttpRace) { | 1317 TEST_P(QuicNetworkTransactionTest, ZeroRTTWithNoHttpRace) { |
| 1414 params_.enable_insecure_quic = true; | |
| 1415 MockQuicData mock_quic_data; | 1318 MockQuicData mock_quic_data; |
| 1416 mock_quic_data.AddWrite( | 1319 mock_quic_data.AddWrite( |
| 1417 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, | 1320 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, |
| 1418 GetRequestHeaders("GET", "http", "/"))); | 1321 GetRequestHeaders("GET", "https", "/"))); |
| 1419 mock_quic_data.AddRead( | 1322 mock_quic_data.AddRead( |
| 1420 ConstructResponseHeadersPacket(1, kClientDataStreamId1, false, false, | 1323 ConstructResponseHeadersPacket(1, kClientDataStreamId1, false, false, |
| 1421 GetResponseHeaders("200 OK"))); | 1324 GetResponseHeaders("200 OK"))); |
| 1422 mock_quic_data.AddRead( | 1325 mock_quic_data.AddRead( |
| 1423 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); | 1326 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); |
| 1424 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); | 1327 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
| 1425 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read | 1328 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read |
| 1426 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF | 1329 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF |
| 1427 mock_quic_data.AddSocketDataToFactory(&socket_factory_); | 1330 mock_quic_data.AddSocketDataToFactory(&socket_factory_); |
| 1428 | 1331 |
| 1429 // In order for a new QUIC session to be established via alternate-protocol | 1332 // In order for a new QUIC session to be established via alternate-protocol |
| 1430 // without racing an HTTP connection, we need the host resolution to happen | 1333 // without racing an HTTP connection, we need the host resolution to happen |
| 1431 // synchronously. | 1334 // synchronously. |
| 1432 host_resolver_.set_synchronous_mode(true); | 1335 host_resolver_.set_synchronous_mode(true); |
| 1433 host_resolver_.rules()->AddIPLiteralRule("www.google.com", "192.168.0.1", ""); | 1336 host_resolver_.rules()->AddIPLiteralRule("mail.example.com", "192.168.0.1", |
| 1434 HostResolver::RequestInfo info(HostPortPair("www.google.com", 80)); | 1337 ""); |
| 1338 HostResolver::RequestInfo info(HostPortPair("mail.example.com", 443)); |
| 1435 AddressList address; | 1339 AddressList address; |
| 1436 host_resolver_.Resolve(info, | 1340 host_resolver_.Resolve(info, |
| 1437 DEFAULT_PRIORITY, | 1341 DEFAULT_PRIORITY, |
| 1438 &address, | 1342 &address, |
| 1439 CompletionCallback(), | 1343 CompletionCallback(), |
| 1440 nullptr, | 1344 nullptr, |
| 1441 net_log_.bound()); | 1345 net_log_.bound()); |
| 1442 | 1346 |
| 1443 CreateSessionWithNextProtos(); | 1347 CreateSessionWithNextProtos(); |
| 1444 AddQuicAlternateProtocolMapping(MockCryptoClientStream::ZERO_RTT); | 1348 AddQuicAlternateProtocolMapping(MockCryptoClientStream::ZERO_RTT); |
| 1445 SendRequestAndExpectQuicResponse("hello!"); | 1349 SendRequestAndExpectQuicResponse("hello!"); |
| 1446 } | 1350 } |
| 1447 | 1351 |
| 1448 TEST_P(QuicNetworkTransactionTest, ZeroRTTWithProxy) { | 1352 TEST_P(QuicNetworkTransactionTest, ZeroRTTWithProxy) { |
| 1449 params_.enable_insecure_quic = true; | |
| 1450 proxy_service_ = ProxyService::CreateFixedFromPacResult("PROXY myproxy:70"); | 1353 proxy_service_ = ProxyService::CreateFixedFromPacResult("PROXY myproxy:70"); |
| 1451 | 1354 |
| 1452 // Since we are using a proxy, the QUIC job will not succeed. | 1355 // Since we are using a proxy, the QUIC job will not succeed. |
| 1453 MockWrite http_writes[] = { | 1356 MockWrite http_writes[] = { |
| 1454 MockWrite(SYNCHRONOUS, 0, "GET http://www.google.com/ HTTP/1.1\r\n"), | 1357 MockWrite(SYNCHRONOUS, 0, "GET http://mail.example.com/ HTTP/1.1\r\n"), |
| 1455 MockWrite(SYNCHRONOUS, 1, "Host: www.google.com\r\n"), | 1358 MockWrite(SYNCHRONOUS, 1, "Host: mail.example.com\r\n"), |
| 1456 MockWrite(SYNCHRONOUS, 2, "Proxy-Connection: keep-alive\r\n\r\n") | 1359 MockWrite(SYNCHRONOUS, 2, "Proxy-Connection: keep-alive\r\n\r\n")}; |
| 1457 }; | |
| 1458 | 1360 |
| 1459 MockRead http_reads[] = { | 1361 MockRead http_reads[] = { |
| 1460 MockRead(SYNCHRONOUS, 3, "HTTP/1.1 200 OK\r\n"), | 1362 MockRead(SYNCHRONOUS, 3, "HTTP/1.1 200 OK\r\n"), |
| 1461 MockRead(SYNCHRONOUS, 4, kQuicAlternateProtocolHttpHeader), | 1363 MockRead(SYNCHRONOUS, 4, kQuicAlternateProtocolHeader), |
| 1462 MockRead(SYNCHRONOUS, 5, "hello world"), | 1364 MockRead(SYNCHRONOUS, 5, "hello world"), MockRead(SYNCHRONOUS, OK, 6)}; |
| 1463 MockRead(SYNCHRONOUS, OK, 6) | |
| 1464 }; | |
| 1465 | 1365 |
| 1466 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), | 1366 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), |
| 1467 http_writes, arraysize(http_writes)); | 1367 http_writes, arraysize(http_writes)); |
| 1468 socket_factory_.AddSocketDataProvider(&http_data); | 1368 socket_factory_.AddSocketDataProvider(&http_data); |
| 1469 | 1369 |
| 1470 // In order for a new QUIC session to be established via alternate-protocol | 1370 // In order for a new QUIC session to be established via alternate-protocol |
| 1471 // without racing an HTTP connection, we need the host resolution to happen | 1371 // without racing an HTTP connection, we need the host resolution to happen |
| 1472 // synchronously. | 1372 // synchronously. |
| 1473 host_resolver_.set_synchronous_mode(true); | 1373 host_resolver_.set_synchronous_mode(true); |
| 1474 host_resolver_.rules()->AddIPLiteralRule("www.google.com", "192.168.0.1", ""); | 1374 host_resolver_.rules()->AddIPLiteralRule("mail.example.com", "192.168.0.1", |
| 1475 HostResolver::RequestInfo info(HostPortPair("www.google.com", 80)); | 1375 ""); |
| 1376 HostResolver::RequestInfo info(HostPortPair("mail.example.com", 443)); |
| 1476 AddressList address; | 1377 AddressList address; |
| 1477 host_resolver_.Resolve(info, | 1378 host_resolver_.Resolve(info, |
| 1478 DEFAULT_PRIORITY, | 1379 DEFAULT_PRIORITY, |
| 1479 &address, | 1380 &address, |
| 1480 CompletionCallback(), | 1381 CompletionCallback(), |
| 1481 nullptr, | 1382 nullptr, |
| 1482 net_log_.bound()); | 1383 net_log_.bound()); |
| 1483 | 1384 |
| 1385 request_.url = GURL("http://mail.example.com/"); |
| 1484 CreateSessionWithNextProtos(); | 1386 CreateSessionWithNextProtos(); |
| 1485 AddQuicAlternateProtocolMapping(MockCryptoClientStream::ZERO_RTT); | 1387 AddQuicAlternateProtocolMapping(MockCryptoClientStream::ZERO_RTT); |
| 1486 SendRequestAndExpectHttpResponse("hello world"); | 1388 SendRequestAndExpectHttpResponse("hello world"); |
| 1487 } | 1389 } |
| 1488 | 1390 |
| 1489 TEST_P(QuicNetworkTransactionTest, ZeroRTTWithConfirmationRequired) { | 1391 TEST_P(QuicNetworkTransactionTest, ZeroRTTWithConfirmationRequired) { |
| 1490 params_.enable_insecure_quic = true; | |
| 1491 MockQuicData mock_quic_data; | 1392 MockQuicData mock_quic_data; |
| 1492 mock_quic_data.AddWrite( | 1393 mock_quic_data.AddWrite( |
| 1493 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, | 1394 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, |
| 1494 GetRequestHeaders("GET", "http", "/"))); | 1395 GetRequestHeaders("GET", "https", "/"))); |
| 1495 mock_quic_data.AddRead( | 1396 mock_quic_data.AddRead( |
| 1496 ConstructResponseHeadersPacket(1, kClientDataStreamId1, false, false, | 1397 ConstructResponseHeadersPacket(1, kClientDataStreamId1, false, false, |
| 1497 GetResponseHeaders("200 OK"))); | 1398 GetResponseHeaders("200 OK"))); |
| 1498 mock_quic_data.AddRead( | 1399 mock_quic_data.AddRead( |
| 1499 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); | 1400 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); |
| 1500 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); | 1401 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
| 1501 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read | 1402 mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read |
| 1502 mock_quic_data.AddSocketDataToFactory(&socket_factory_); | 1403 mock_quic_data.AddSocketDataToFactory(&socket_factory_); |
| 1503 | 1404 |
| 1504 // The non-alternate protocol job needs to hang in order to guarantee that | 1405 // The non-alternate protocol job needs to hang in order to guarantee that |
| 1505 // the alternate-protocol job will "win". | 1406 // the alternate-protocol job will "win". |
| 1506 AddHangingNonAlternateProtocolSocketData(); | 1407 AddHangingNonAlternateProtocolSocketData(); |
| 1507 | 1408 |
| 1508 // In order for a new QUIC session to be established via alternate-protocol | 1409 // In order for a new QUIC session to be established via alternate-protocol |
| 1509 // without racing an HTTP connection, we need the host resolution to happen | 1410 // without racing an HTTP connection, we need the host resolution to happen |
| 1510 // synchronously. Of course, even though QUIC *could* perform a 0-RTT | 1411 // synchronously. Of course, even though QUIC *could* perform a 0-RTT |
| 1511 // connection to the the server, in this test we require confirmation | 1412 // connection to the the server, in this test we require confirmation |
| 1512 // before encrypting so the HTTP job will still start. | 1413 // before encrypting so the HTTP job will still start. |
| 1513 host_resolver_.set_synchronous_mode(true); | 1414 host_resolver_.set_synchronous_mode(true); |
| 1514 host_resolver_.rules()->AddIPLiteralRule("www.google.com", "192.168.0.1", ""); | 1415 host_resolver_.rules()->AddIPLiteralRule("mail.example.com", "192.168.0.1", |
| 1515 HostResolver::RequestInfo info(HostPortPair("www.google.com", 80)); | 1416 ""); |
| 1417 HostResolver::RequestInfo info(HostPortPair("mail.example.com", 443)); |
| 1516 AddressList address; | 1418 AddressList address; |
| 1517 host_resolver_.Resolve(info, DEFAULT_PRIORITY, &address, | 1419 host_resolver_.Resolve(info, DEFAULT_PRIORITY, &address, |
| 1518 CompletionCallback(), nullptr, net_log_.bound()); | 1420 CompletionCallback(), nullptr, net_log_.bound()); |
| 1519 | 1421 |
| 1520 CreateSessionWithNextProtos(); | 1422 CreateSessionWithNextProtos(); |
| 1521 session_->quic_stream_factory()->set_require_confirmation(true); | 1423 session_->quic_stream_factory()->set_require_confirmation(true); |
| 1522 AddQuicAlternateProtocolMapping(MockCryptoClientStream::ZERO_RTT); | 1424 AddQuicAlternateProtocolMapping(MockCryptoClientStream::ZERO_RTT); |
| 1523 | 1425 |
| 1524 scoped_ptr<HttpNetworkTransaction> trans( | 1426 scoped_ptr<HttpNetworkTransaction> trans( |
| 1525 new HttpNetworkTransaction(DEFAULT_PRIORITY, session_.get())); | 1427 new HttpNetworkTransaction(DEFAULT_PRIORITY, session_.get())); |
| 1526 TestCompletionCallback callback; | 1428 TestCompletionCallback callback; |
| 1527 int rv = trans->Start(&request_, callback.callback(), net_log_.bound()); | 1429 int rv = trans->Start(&request_, callback.callback(), net_log_.bound()); |
| 1528 EXPECT_EQ(ERR_IO_PENDING, rv); | 1430 EXPECT_EQ(ERR_IO_PENDING, rv); |
| 1529 | 1431 |
| 1530 crypto_client_stream_factory_.last_stream()->SendOnCryptoHandshakeEvent( | 1432 crypto_client_stream_factory_.last_stream()->SendOnCryptoHandshakeEvent( |
| 1531 QuicSession::HANDSHAKE_CONFIRMED); | 1433 QuicSession::HANDSHAKE_CONFIRMED); |
| 1532 EXPECT_EQ(OK, callback.WaitForResult()); | 1434 EXPECT_EQ(OK, callback.WaitForResult()); |
| 1533 | 1435 |
| 1534 CheckWasQuicResponse(trans); | 1436 CheckWasQuicResponse(trans); |
| 1535 CheckResponseData(trans, "hello!"); | 1437 CheckResponseData(trans, "hello!"); |
| 1536 } | 1438 } |
| 1537 | 1439 |
| 1538 TEST_P(QuicNetworkTransactionTest, BrokenAlternateProtocol) { | 1440 TEST_P(QuicNetworkTransactionTest, BrokenAlternateProtocol) { |
| 1539 params_.enable_insecure_quic = true; | |
| 1540 // Alternate-protocol job | 1441 // Alternate-protocol job |
| 1541 scoped_ptr<QuicEncryptedPacket> close(ConstructConnectionClosePacket(1)); | 1442 scoped_ptr<QuicEncryptedPacket> close(ConstructConnectionClosePacket(1)); |
| 1542 MockRead quic_reads[] = { | 1443 MockRead quic_reads[] = { |
| 1543 MockRead(ASYNC, close->data(), close->length()), | 1444 MockRead(ASYNC, close->data(), close->length()), |
| 1544 MockRead(ASYNC, ERR_IO_PENDING), // No more data to read | 1445 MockRead(ASYNC, ERR_IO_PENDING), // No more data to read |
| 1545 MockRead(ASYNC, OK), // EOF | 1446 MockRead(ASYNC, OK), // EOF |
| 1546 }; | 1447 }; |
| 1547 StaticSocketDataProvider quic_data(quic_reads, arraysize(quic_reads), | 1448 StaticSocketDataProvider quic_data(quic_reads, arraysize(quic_reads), |
| 1548 nullptr, 0); | 1449 nullptr, 0); |
| 1549 socket_factory_.AddSocketDataProvider(&quic_data); | 1450 socket_factory_.AddSocketDataProvider(&quic_data); |
| 1550 | 1451 |
| 1551 // Main job which will succeed even though the alternate job fails. | 1452 // Main job which will succeed even though the alternate job fails. |
| 1552 MockRead http_reads[] = { | 1453 MockRead http_reads[] = { |
| 1553 MockRead("HTTP/1.1 200 OK\r\n\r\n"), | 1454 MockRead("HTTP/1.1 200 OK\r\n\r\n"), |
| 1554 MockRead("hello from http"), | 1455 MockRead("hello from http"), |
| 1555 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | 1456 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
| 1556 MockRead(ASYNC, OK) | 1457 MockRead(ASYNC, OK) |
| 1557 }; | 1458 }; |
| 1558 | 1459 |
| 1559 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), | 1460 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), |
| 1560 nullptr, 0); | 1461 nullptr, 0); |
| 1561 socket_factory_.AddSocketDataProvider(&http_data); | 1462 socket_factory_.AddSocketDataProvider(&http_data); |
| 1463 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 1562 | 1464 |
| 1563 CreateSessionWithNextProtos(); | 1465 CreateSessionWithNextProtos(); |
| 1564 AddQuicAlternateProtocolMapping(MockCryptoClientStream::COLD_START); | 1466 AddQuicAlternateProtocolMapping(MockCryptoClientStream::COLD_START); |
| 1565 SendRequestAndExpectHttpResponse("hello from http"); | 1467 SendRequestAndExpectHttpResponse("hello from http"); |
| 1566 ExpectBrokenAlternateProtocolMapping(); | 1468 ExpectBrokenAlternateProtocolMapping(); |
| 1567 } | 1469 } |
| 1568 | 1470 |
| 1569 TEST_P(QuicNetworkTransactionTest, BrokenAlternateProtocolReadError) { | 1471 TEST_P(QuicNetworkTransactionTest, BrokenAlternateProtocolReadError) { |
| 1570 params_.enable_insecure_quic = true; | |
| 1571 // Alternate-protocol job | 1472 // Alternate-protocol job |
| 1572 MockRead quic_reads[] = { | 1473 MockRead quic_reads[] = { |
| 1573 MockRead(ASYNC, ERR_SOCKET_NOT_CONNECTED), | 1474 MockRead(ASYNC, ERR_SOCKET_NOT_CONNECTED), |
| 1574 }; | 1475 }; |
| 1575 StaticSocketDataProvider quic_data(quic_reads, arraysize(quic_reads), | 1476 StaticSocketDataProvider quic_data(quic_reads, arraysize(quic_reads), |
| 1576 nullptr, 0); | 1477 nullptr, 0); |
| 1577 socket_factory_.AddSocketDataProvider(&quic_data); | 1478 socket_factory_.AddSocketDataProvider(&quic_data); |
| 1578 | 1479 |
| 1579 // Main job which will succeed even though the alternate job fails. | 1480 // Main job which will succeed even though the alternate job fails. |
| 1580 MockRead http_reads[] = { | 1481 MockRead http_reads[] = { |
| 1581 MockRead("HTTP/1.1 200 OK\r\n\r\n"), | 1482 MockRead("HTTP/1.1 200 OK\r\n\r\n"), |
| 1582 MockRead("hello from http"), | 1483 MockRead("hello from http"), |
| 1583 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | 1484 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
| 1584 MockRead(ASYNC, OK) | 1485 MockRead(ASYNC, OK) |
| 1585 }; | 1486 }; |
| 1586 | 1487 |
| 1587 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), | 1488 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), |
| 1588 nullptr, 0); | 1489 nullptr, 0); |
| 1589 socket_factory_.AddSocketDataProvider(&http_data); | 1490 socket_factory_.AddSocketDataProvider(&http_data); |
| 1491 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 1590 | 1492 |
| 1591 CreateSessionWithNextProtos(); | 1493 CreateSessionWithNextProtos(); |
| 1592 | 1494 |
| 1593 AddQuicAlternateProtocolMapping(MockCryptoClientStream::COLD_START); | 1495 AddQuicAlternateProtocolMapping(MockCryptoClientStream::COLD_START); |
| 1594 SendRequestAndExpectHttpResponse("hello from http"); | 1496 SendRequestAndExpectHttpResponse("hello from http"); |
| 1595 ExpectBrokenAlternateProtocolMapping(); | 1497 ExpectBrokenAlternateProtocolMapping(); |
| 1596 } | 1498 } |
| 1597 | 1499 |
| 1598 TEST_P(QuicNetworkTransactionTest, NoBrokenAlternateProtocolIfTcpFails) { | 1500 TEST_P(QuicNetworkTransactionTest, NoBrokenAlternateProtocolIfTcpFails) { |
| 1599 params_.enable_insecure_quic = true; | |
| 1600 // Alternate-protocol job will fail when the session attempts to read. | 1501 // Alternate-protocol job will fail when the session attempts to read. |
| 1601 MockRead quic_reads[] = { | 1502 MockRead quic_reads[] = { |
| 1602 MockRead(ASYNC, ERR_SOCKET_NOT_CONNECTED), | 1503 MockRead(ASYNC, ERR_SOCKET_NOT_CONNECTED), |
| 1603 }; | 1504 }; |
| 1604 StaticSocketDataProvider quic_data(quic_reads, arraysize(quic_reads), | 1505 StaticSocketDataProvider quic_data(quic_reads, arraysize(quic_reads), |
| 1605 nullptr, 0); | 1506 nullptr, 0); |
| 1606 socket_factory_.AddSocketDataProvider(&quic_data); | 1507 socket_factory_.AddSocketDataProvider(&quic_data); |
| 1607 | 1508 |
| 1608 // Main job will also fail. | 1509 // Main job will also fail. |
| 1609 MockRead http_reads[] = { | 1510 MockRead http_reads[] = { |
| 1610 MockRead(ASYNC, ERR_SOCKET_NOT_CONNECTED), | 1511 MockRead(ASYNC, ERR_SOCKET_NOT_CONNECTED), |
| 1611 }; | 1512 }; |
| 1612 | 1513 |
| 1613 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), | 1514 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), |
| 1614 nullptr, 0); | 1515 nullptr, 0); |
| 1615 http_data.set_connect_data(MockConnect(ASYNC, ERR_SOCKET_NOT_CONNECTED)); | 1516 http_data.set_connect_data(MockConnect(ASYNC, ERR_SOCKET_NOT_CONNECTED)); |
| 1616 socket_factory_.AddSocketDataProvider(&http_data); | 1517 socket_factory_.AddSocketDataProvider(&http_data); |
| 1518 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 1617 | 1519 |
| 1618 CreateSessionWithNextProtos(); | 1520 CreateSessionWithNextProtos(); |
| 1619 | 1521 |
| 1620 AddQuicAlternateProtocolMapping(MockCryptoClientStream::COLD_START); | 1522 AddQuicAlternateProtocolMapping(MockCryptoClientStream::COLD_START); |
| 1621 scoped_ptr<HttpNetworkTransaction> trans( | 1523 scoped_ptr<HttpNetworkTransaction> trans( |
| 1622 new HttpNetworkTransaction(DEFAULT_PRIORITY, session_.get())); | 1524 new HttpNetworkTransaction(DEFAULT_PRIORITY, session_.get())); |
| 1623 TestCompletionCallback callback; | 1525 TestCompletionCallback callback; |
| 1624 int rv = trans->Start(&request_, callback.callback(), net_log_.bound()); | 1526 int rv = trans->Start(&request_, callback.callback(), net_log_.bound()); |
| 1625 EXPECT_EQ(ERR_IO_PENDING, rv); | 1527 EXPECT_EQ(ERR_IO_PENDING, rv); |
| 1626 EXPECT_EQ(ERR_SOCKET_NOT_CONNECTED, callback.WaitForResult()); | 1528 EXPECT_EQ(ERR_SOCKET_NOT_CONNECTED, callback.WaitForResult()); |
| 1627 ExpectQuicAlternateProtocolMapping(); | 1529 ExpectQuicAlternateProtocolMapping(); |
| 1628 } | 1530 } |
| 1629 | 1531 |
| 1630 TEST_P(QuicNetworkTransactionTest, FailedZeroRttBrokenAlternateProtocol) { | 1532 TEST_P(QuicNetworkTransactionTest, FailedZeroRttBrokenAlternateProtocol) { |
| 1631 params_.enable_insecure_quic = true; | |
| 1632 // Alternate-protocol job | 1533 // Alternate-protocol job |
| 1633 MockRead quic_reads[] = { | 1534 MockRead quic_reads[] = { |
| 1634 MockRead(ASYNC, ERR_SOCKET_NOT_CONNECTED), | 1535 MockRead(ASYNC, ERR_SOCKET_NOT_CONNECTED), |
| 1635 }; | 1536 }; |
| 1636 StaticSocketDataProvider quic_data(quic_reads, arraysize(quic_reads), | 1537 StaticSocketDataProvider quic_data(quic_reads, arraysize(quic_reads), |
| 1637 nullptr, 0); | 1538 nullptr, 0); |
| 1638 socket_factory_.AddSocketDataProvider(&quic_data); | 1539 socket_factory_.AddSocketDataProvider(&quic_data); |
| 1639 | 1540 |
| 1640 AddHangingNonAlternateProtocolSocketData(); | 1541 AddHangingNonAlternateProtocolSocketData(); |
| 1641 | 1542 |
| 1642 // Second Alternate-protocol job which will race with the TCP job. | 1543 // Second Alternate-protocol job which will race with the TCP job. |
| 1643 StaticSocketDataProvider quic_data2(quic_reads, arraysize(quic_reads), | 1544 StaticSocketDataProvider quic_data2(quic_reads, arraysize(quic_reads), |
| 1644 nullptr, 0); | 1545 nullptr, 0); |
| 1645 socket_factory_.AddSocketDataProvider(&quic_data2); | 1546 socket_factory_.AddSocketDataProvider(&quic_data2); |
| 1646 | 1547 |
| 1647 // Final job that will proceed when the QUIC job fails. | 1548 // Final job that will proceed when the QUIC job fails. |
| 1648 MockRead http_reads[] = { | 1549 MockRead http_reads[] = { |
| 1649 MockRead("HTTP/1.1 200 OK\r\n\r\n"), | 1550 MockRead("HTTP/1.1 200 OK\r\n\r\n"), |
| 1650 MockRead("hello from http"), | 1551 MockRead("hello from http"), |
| 1651 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | 1552 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
| 1652 MockRead(ASYNC, OK) | 1553 MockRead(ASYNC, OK) |
| 1653 }; | 1554 }; |
| 1654 | 1555 |
| 1655 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), | 1556 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), |
| 1656 nullptr, 0); | 1557 nullptr, 0); |
| 1657 socket_factory_.AddSocketDataProvider(&http_data); | 1558 socket_factory_.AddSocketDataProvider(&http_data); |
| 1559 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 1658 | 1560 |
| 1659 CreateSessionWithNextProtos(); | 1561 CreateSessionWithNextProtos(); |
| 1660 | 1562 |
| 1661 AddQuicAlternateProtocolMapping(MockCryptoClientStream::ZERO_RTT); | 1563 AddQuicAlternateProtocolMapping(MockCryptoClientStream::ZERO_RTT); |
| 1662 | 1564 |
| 1663 SendRequestAndExpectHttpResponse("hello from http"); | 1565 SendRequestAndExpectHttpResponse("hello from http"); |
| 1664 | 1566 |
| 1665 ExpectBrokenAlternateProtocolMapping(); | 1567 ExpectBrokenAlternateProtocolMapping(); |
| 1666 | 1568 |
| 1667 EXPECT_TRUE(quic_data.AllReadDataConsumed()); | 1569 EXPECT_TRUE(quic_data.AllReadDataConsumed()); |
| 1668 EXPECT_TRUE(quic_data.AllWriteDataConsumed()); | 1570 EXPECT_TRUE(quic_data.AllWriteDataConsumed()); |
| 1669 } | 1571 } |
| 1670 | 1572 |
| 1671 TEST_P(QuicNetworkTransactionTest, DISABLED_HangingZeroRttFallback) { | 1573 TEST_P(QuicNetworkTransactionTest, DISABLED_HangingZeroRttFallback) { |
| 1672 params_.enable_insecure_quic = true; | |
| 1673 // Alternate-protocol job | 1574 // Alternate-protocol job |
| 1674 MockRead quic_reads[] = { | 1575 MockRead quic_reads[] = { |
| 1675 MockRead(ASYNC, ERR_IO_PENDING), | 1576 MockRead(ASYNC, ERR_IO_PENDING), |
| 1676 }; | 1577 }; |
| 1677 StaticSocketDataProvider quic_data(quic_reads, arraysize(quic_reads), | 1578 StaticSocketDataProvider quic_data(quic_reads, arraysize(quic_reads), |
| 1678 nullptr, 0); | 1579 nullptr, 0); |
| 1679 socket_factory_.AddSocketDataProvider(&quic_data); | 1580 socket_factory_.AddSocketDataProvider(&quic_data); |
| 1680 | 1581 |
| 1681 // Main job that will proceed when the QUIC job fails. | 1582 // Main job that will proceed when the QUIC job fails. |
| 1682 MockRead http_reads[] = { | 1583 MockRead http_reads[] = { |
| 1683 MockRead("HTTP/1.1 200 OK\r\n\r\n"), | 1584 MockRead("HTTP/1.1 200 OK\r\n\r\n"), |
| 1684 MockRead("hello from http"), | 1585 MockRead("hello from http"), |
| 1685 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | 1586 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
| 1686 MockRead(ASYNC, OK) | 1587 MockRead(ASYNC, OK) |
| 1687 }; | 1588 }; |
| 1688 | 1589 |
| 1689 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), | 1590 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), |
| 1690 nullptr, 0); | 1591 nullptr, 0); |
| 1691 socket_factory_.AddSocketDataProvider(&http_data); | 1592 socket_factory_.AddSocketDataProvider(&http_data); |
| 1692 | 1593 |
| 1693 CreateSessionWithNextProtos(); | 1594 CreateSessionWithNextProtos(); |
| 1694 | 1595 |
| 1695 AddQuicAlternateProtocolMapping(MockCryptoClientStream::ZERO_RTT); | 1596 AddQuicAlternateProtocolMapping(MockCryptoClientStream::ZERO_RTT); |
| 1696 | 1597 |
| 1697 SendRequestAndExpectHttpResponse("hello from http"); | 1598 SendRequestAndExpectHttpResponse("hello from http"); |
| 1698 } | 1599 } |
| 1699 | 1600 |
| 1700 TEST_P(QuicNetworkTransactionTest, BrokenAlternateProtocolOnConnectFailure) { | 1601 TEST_P(QuicNetworkTransactionTest, BrokenAlternateProtocolOnConnectFailure) { |
| 1701 params_.enable_insecure_quic = true; | |
| 1702 // Alternate-protocol job will fail before creating a QUIC session. | 1602 // Alternate-protocol job will fail before creating a QUIC session. |
| 1703 StaticSocketDataProvider quic_data(nullptr, 0, nullptr, 0); | 1603 StaticSocketDataProvider quic_data(nullptr, 0, nullptr, 0); |
| 1704 quic_data.set_connect_data(MockConnect(SYNCHRONOUS, | 1604 quic_data.set_connect_data(MockConnect(SYNCHRONOUS, |
| 1705 ERR_INTERNET_DISCONNECTED)); | 1605 ERR_INTERNET_DISCONNECTED)); |
| 1706 socket_factory_.AddSocketDataProvider(&quic_data); | 1606 socket_factory_.AddSocketDataProvider(&quic_data); |
| 1707 | 1607 |
| 1708 // Main job which will succeed even though the alternate job fails. | 1608 // Main job which will succeed even though the alternate job fails. |
| 1709 MockRead http_reads[] = { | 1609 MockRead http_reads[] = { |
| 1710 MockRead("HTTP/1.1 200 OK\r\n\r\n"), | 1610 MockRead("HTTP/1.1 200 OK\r\n\r\n"), |
| 1711 MockRead("hello from http"), | 1611 MockRead("hello from http"), |
| 1712 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | 1612 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
| 1713 MockRead(ASYNC, OK) | 1613 MockRead(ASYNC, OK) |
| 1714 }; | 1614 }; |
| 1715 | 1615 |
| 1716 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), | 1616 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), |
| 1717 nullptr, 0); | 1617 nullptr, 0); |
| 1718 socket_factory_.AddSocketDataProvider(&http_data); | 1618 socket_factory_.AddSocketDataProvider(&http_data); |
| 1619 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 1719 | 1620 |
| 1720 CreateSessionWithNextProtos(); | 1621 CreateSessionWithNextProtos(); |
| 1721 AddQuicAlternateProtocolMapping(MockCryptoClientStream::COLD_START); | 1622 AddQuicAlternateProtocolMapping(MockCryptoClientStream::COLD_START); |
| 1722 SendRequestAndExpectHttpResponse("hello from http"); | 1623 SendRequestAndExpectHttpResponse("hello from http"); |
| 1723 | 1624 |
| 1724 ExpectBrokenAlternateProtocolMapping(); | 1625 ExpectBrokenAlternateProtocolMapping(); |
| 1725 } | 1626 } |
| 1726 | 1627 |
| 1727 TEST_P(QuicNetworkTransactionTest, ConnectionCloseDuringConnect) { | 1628 TEST_P(QuicNetworkTransactionTest, ConnectionCloseDuringConnect) { |
| 1728 params_.enable_insecure_quic = true; | |
| 1729 MockQuicData mock_quic_data; | 1629 MockQuicData mock_quic_data; |
| 1730 mock_quic_data.AddSynchronousRead(ConstructConnectionClosePacket(1)); | 1630 mock_quic_data.AddSynchronousRead(ConstructConnectionClosePacket(1)); |
| 1731 mock_quic_data.AddWrite( | 1631 mock_quic_data.AddWrite( |
| 1732 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, | 1632 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, |
| 1733 GetRequestHeaders("GET", "http", "/"))); | 1633 GetRequestHeaders("GET", "https", "/"))); |
| 1734 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); | 1634 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
| 1735 mock_quic_data.AddSocketDataToFactory(&socket_factory_); | 1635 mock_quic_data.AddSocketDataToFactory(&socket_factory_); |
| 1736 | 1636 |
| 1737 // When the QUIC connection fails, we will try the request again over HTTP. | 1637 // When the QUIC connection fails, we will try the request again over HTTP. |
| 1738 MockRead http_reads[] = { | 1638 MockRead http_reads[] = { |
| 1739 MockRead("HTTP/1.1 200 OK\r\n"), | 1639 MockRead("HTTP/1.1 200 OK\r\n"), MockRead(kQuicAlternateProtocolHeader), |
| 1740 MockRead(kQuicAlternateProtocolHttpHeader), | 1640 MockRead("hello world"), |
| 1741 MockRead("hello world"), | 1641 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
| 1742 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | 1642 MockRead(ASYNC, OK)}; |
| 1743 MockRead(ASYNC, OK) | |
| 1744 }; | |
| 1745 | 1643 |
| 1746 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), | 1644 StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), |
| 1747 nullptr, 0); | 1645 nullptr, 0); |
| 1748 socket_factory_.AddSocketDataProvider(&http_data); | 1646 socket_factory_.AddSocketDataProvider(&http_data); |
| 1647 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
| 1749 | 1648 |
| 1750 // In order for a new QUIC session to be established via alternate-protocol | 1649 // In order for a new QUIC session to be established via alternate-protocol |
| 1751 // without racing an HTTP connection, we need the host resolution to happen | 1650 // without racing an HTTP connection, we need the host resolution to happen |
| 1752 // synchronously. | 1651 // synchronously. |
| 1753 host_resolver_.set_synchronous_mode(true); | 1652 host_resolver_.set_synchronous_mode(true); |
| 1754 host_resolver_.rules()->AddIPLiteralRule("www.google.com", "192.168.0.1", ""); | 1653 host_resolver_.rules()->AddIPLiteralRule("mail.example.com", "192.168.0.1", |
| 1755 HostResolver::RequestInfo info(HostPortPair("www.google.com", 80)); | 1654 ""); |
| 1655 HostResolver::RequestInfo info(HostPortPair("mail.example.com", 443)); |
| 1756 AddressList address; | 1656 AddressList address; |
| 1757 host_resolver_.Resolve(info, | 1657 host_resolver_.Resolve(info, |
| 1758 DEFAULT_PRIORITY, | 1658 DEFAULT_PRIORITY, |
| 1759 &address, | 1659 &address, |
| 1760 CompletionCallback(), | 1660 CompletionCallback(), |
| 1761 nullptr, | 1661 nullptr, |
| 1762 net_log_.bound()); | 1662 net_log_.bound()); |
| 1763 | 1663 |
| 1764 CreateSessionWithNextProtos(); | 1664 CreateSessionWithNextProtos(); |
| 1765 AddQuicAlternateProtocolMapping(MockCryptoClientStream::ZERO_RTT); | 1665 AddQuicAlternateProtocolMapping(MockCryptoClientStream::ZERO_RTT); |
| 1766 SendRequestAndExpectHttpResponse("hello world"); | 1666 SendRequestAndExpectHttpResponse("hello world"); |
| 1767 } | 1667 } |
| 1768 | 1668 |
| 1769 // Test that a secure request over an insecure QUIC connection fails with | |
| 1770 // the appropriate error code. Note that this never happens in production, | |
| 1771 // because the handshake (which this test mocks) would fail in this scenario. | |
| 1772 TEST_P(QuicNetworkTransactionTest, SecureResourceOverInsecureQuic) { | |
| 1773 params_.enable_insecure_quic = true; | |
| 1774 maker_.set_hostname("www.example.org"); | |
| 1775 MockQuicData mock_quic_data; | |
| 1776 mock_quic_data.AddWrite( | |
| 1777 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, | |
| 1778 GetRequestHeaders("GET", "https", "/"))); | |
| 1779 mock_quic_data.AddRead(ConstructResponseHeadersPacket( | |
| 1780 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); | |
| 1781 mock_quic_data.AddRead( | |
| 1782 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); | |
| 1783 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); | |
| 1784 mock_quic_data.AddRead(SYNCHRONOUS, 0); | |
| 1785 mock_quic_data.AddSocketDataToFactory(&socket_factory_); | |
| 1786 | |
| 1787 request_.url = GURL("https://www.example.org:443"); | |
| 1788 AddHangingNonAlternateProtocolSocketData(); | |
| 1789 CreateSessionWithNextProtos(); | |
| 1790 AddQuicAlternateProtocolMapping(MockCryptoClientStream::CONFIRM_HANDSHAKE); | |
| 1791 scoped_ptr<HttpNetworkTransaction> trans( | |
| 1792 new HttpNetworkTransaction(DEFAULT_PRIORITY, session_.get())); | |
| 1793 TestCompletionCallback callback; | |
| 1794 int rv = trans->Start(&request_, callback.callback(), net_log_.bound()); | |
| 1795 EXPECT_EQ(ERR_REQUEST_FOR_SECURE_RESOURCE_OVER_INSECURE_QUIC, | |
| 1796 callback.GetResult(rv)); | |
| 1797 } | |
| 1798 | |
| 1799 TEST_P(QuicNetworkTransactionTest, SecureResourceOverSecureQuic) { | 1669 TEST_P(QuicNetworkTransactionTest, SecureResourceOverSecureQuic) { |
| 1800 params_.enable_insecure_quic = true; | |
| 1801 maker_.set_hostname("www.example.org"); | 1670 maker_.set_hostname("www.example.org"); |
| 1802 EXPECT_FALSE( | 1671 EXPECT_FALSE( |
| 1803 test_network_quality_estimator_->IsRTTAvailableNotificationReceived()); | 1672 test_network_quality_estimator_->IsRTTAvailableNotificationReceived()); |
| 1804 MockQuicData mock_quic_data; | 1673 MockQuicData mock_quic_data; |
| 1805 mock_quic_data.AddWrite( | 1674 mock_quic_data.AddWrite( |
| 1806 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, | 1675 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, |
| 1807 GetRequestHeaders("GET", "https", "/"))); | 1676 GetRequestHeaders("GET", "https", "/"))); |
| 1808 mock_quic_data.AddRead(ConstructResponseHeadersPacket( | 1677 mock_quic_data.AddRead(ConstructResponseHeadersPacket( |
| 1809 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); | 1678 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); |
| 1810 mock_quic_data.AddRead( | 1679 mock_quic_data.AddRead( |
| 1811 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); | 1680 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); |
| 1812 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); | 1681 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
| 1813 mock_quic_data.AddRead(SYNCHRONOUS, ERR_IO_PENDING); // No more read data. | 1682 mock_quic_data.AddRead(SYNCHRONOUS, ERR_IO_PENDING); // No more read data. |
| 1814 mock_quic_data.AddSocketDataToFactory(&socket_factory_); | 1683 mock_quic_data.AddSocketDataToFactory(&socket_factory_); |
| 1815 | 1684 |
| 1816 scoped_refptr<X509Certificate> cert( | |
| 1817 ImportCertFromFile(GetTestCertsDirectory(), "spdy_pooling.pem")); | |
| 1818 ASSERT_TRUE(cert.get()); | |
| 1819 bool common_name_fallback_used; | |
| 1820 EXPECT_TRUE( | |
| 1821 cert->VerifyNameMatch("www.example.org", &common_name_fallback_used)); | |
| 1822 ProofVerifyDetailsChromium verify_details; | |
| 1823 verify_details.cert_verify_result.verified_cert = cert; | |
| 1824 crypto_client_stream_factory_.AddProofVerifyDetails(&verify_details); | |
| 1825 | |
| 1826 request_.url = GURL("https://www.example.org:443"); | 1685 request_.url = GURL("https://www.example.org:443"); |
| 1827 AddHangingNonAlternateProtocolSocketData(); | 1686 AddHangingNonAlternateProtocolSocketData(); |
| 1828 CreateSessionWithNextProtos(); | 1687 CreateSessionWithNextProtos(); |
| 1829 AddQuicAlternateProtocolMapping(MockCryptoClientStream::CONFIRM_HANDSHAKE); | 1688 AddQuicAlternateProtocolMapping(MockCryptoClientStream::CONFIRM_HANDSHAKE); |
| 1830 SendRequestAndExpectQuicResponse("hello!"); | 1689 SendRequestAndExpectQuicResponse("hello!"); |
| 1831 EXPECT_TRUE( | 1690 EXPECT_TRUE( |
| 1832 test_network_quality_estimator_->IsRTTAvailableNotificationReceived()); | 1691 test_network_quality_estimator_->IsRTTAvailableNotificationReceived()); |
| 1833 } | 1692 } |
| 1834 | 1693 |
| 1835 } // namespace test | 1694 } // namespace test |
| 1836 } // namespace net | 1695 } // namespace net |
| OLD | NEW |