Index: net/quic/quic_network_transaction_unittest.cc |
diff --git a/net/quic/quic_network_transaction_unittest.cc b/net/quic/quic_network_transaction_unittest.cc |
index b5a8d6d16a3e10182619ddc09ba06b534b9faa09..15a070223d314f19061280f6389f7c604928a859 100644 |
--- a/net/quic/quic_network_transaction_unittest.cc |
+++ b/net/quic/quic_network_transaction_unittest.cc |
@@ -61,14 +61,10 @@ namespace { |
static const char kQuicAlternateProtocolHeader[] = |
"Alternate-Protocol: 443:quic\r\n\r\n"; |
-static const char kQuicAlternateProtocol50pctHeader[] = |
- "Alternate-Protocol: 443:quic,p=.5\r\n\r\n"; |
static const char kQuicAlternateProtocolDifferentPortHeader[] = |
"Alternate-Protocol: 137:quic\r\n\r\n"; |
static const char kQuicAlternativeServiceHeader[] = |
"Alt-Svc: quic=\":443\"\r\n\r\n"; |
-static const char kQuicAlternativeService50pctHeader[] = |
- "Alt-Svc: quic=\":443\";p=\".5\"\r\n\r\n"; |
static const char kQuicAlternativeServiceDifferentPortHeader[] = |
"Alt-Svc: quic=\":137\"\r\n\r\n"; |
@@ -517,7 +513,7 @@ class QuicNetworkTransactionTest |
AlternativeService alternative_service(QUIC, host_port_pair.host(), 443); |
base::Time expiration = base::Time::Now() + base::TimeDelta::FromDays(1); |
http_server_properties_.SetAlternativeService( |
- host_port_pair, alternative_service, 1.0, expiration); |
+ host_port_pair, alternative_service, expiration); |
} |
void AddQuicRemoteAlternativeServiceMapping( |
@@ -529,7 +525,7 @@ class QuicNetworkTransactionTest |
alternative.port()); |
base::Time expiration = base::Time::Now() + base::TimeDelta::FromDays(1); |
http_server_properties_.SetAlternativeService( |
- host_port_pair, alternative_service, 1.0, expiration); |
+ host_port_pair, alternative_service, expiration); |
} |
void ExpectBrokenAlternateProtocolMapping() { |
@@ -1352,84 +1348,6 @@ TEST_P(QuicNetworkTransactionTest, ConfirmAlternativeService) { |
alternative_service)); |
} |
-TEST_P(QuicNetworkTransactionTest, UseAlternativeServiceProbabilityForQuic) { |
- MockRead http_reads[] = { |
- MockRead("HTTP/1.1 200 OK\r\n"), |
- MockRead(kQuicAlternativeService50pctHeader), MockRead("hello world"), |
- MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
- MockRead(ASYNC, OK)}; |
- |
- StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, |
- 0); |
- socket_factory_.AddSocketDataProvider(&http_data); |
- socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
- |
- MockQuicData mock_quic_data; |
- mock_quic_data.AddWrite( |
- ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, |
- GetRequestHeaders("GET", "https", "/"))); |
- mock_quic_data.AddRead(ConstructResponseHeadersPacket( |
- 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); |
- mock_quic_data.AddRead( |
- ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); |
- mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
- mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read |
- mock_quic_data.AddRead(ASYNC, 0); // EOF |
- |
- mock_quic_data.AddSocketDataToFactory(&socket_factory_); |
- |
- AddHangingNonAlternateProtocolSocketData(); |
- params_.alternative_service_probability_threshold = 0.25; |
- CreateSession(); |
- |
- SendRequestAndExpectHttpResponse("hello world"); |
- SendRequestAndExpectQuicResponse("hello!"); |
-} |
- |
-TEST_P(QuicNetworkTransactionTest, |
- DontUseAlternativeServiceProbabilityForQuic) { |
- MockRead http_reads[] = { |
- MockRead("HTTP/1.1 200 OK\r\n"), |
- MockRead(kQuicAlternativeService50pctHeader), MockRead("hello world"), |
- MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
- MockRead(ASYNC, OK)}; |
- |
- StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, |
- 0); |
- socket_factory_.AddSocketDataProvider(&http_data); |
- socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
- socket_factory_.AddSocketDataProvider(&http_data); |
- socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
- |
- params_.alternative_service_probability_threshold = 0.75; |
- CreateSession(); |
- |
- SendRequestAndExpectHttpResponse("hello world"); |
- SendRequestAndExpectHttpResponse("hello world"); |
-} |
- |
-TEST_P(QuicNetworkTransactionTest, |
- DontUseAlternativeServiceWithBadProbabilityForQuic) { |
- MockRead http_reads[] = { |
- MockRead("HTTP/1.1 200 OK\r\n"), |
- MockRead("Alt-Svc: quic=\":443\";p=2\r\n\r\n"), MockRead("hello world"), |
- MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
- MockRead(ASYNC, OK)}; |
- |
- StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, |
- 0); |
- socket_factory_.AddSocketDataProvider(&http_data); |
- socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
- socket_factory_.AddSocketDataProvider(&http_data); |
- socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
- |
- params_.alternative_service_probability_threshold = 0.75; |
- CreateSession(); |
- |
- SendRequestAndExpectHttpResponse("hello world"); |
- SendRequestAndExpectHttpResponse("hello world"); |
-} |
- |
TEST_P(QuicNetworkTransactionTest, UseAlternativeServiceForQuicForHttps) { |
MockRead http_reads[] = { |
MockRead("HTTP/1.1 200 OK\r\n"), MockRead(kQuicAlternativeServiceHeader), |
@@ -1587,90 +1505,6 @@ TEST_P(QuicNetworkTransactionTest, ConfirmAlternateProtocol) { |
alternative_service)); |
} |
-TEST_P(QuicNetworkTransactionTest, UseAlternateProtocolProbabilityForQuic) { |
- params_.parse_alternative_services = false; |
- MockRead http_reads[] = { |
- MockRead("HTTP/1.1 200 OK\r\n"), |
- MockRead(kQuicAlternateProtocol50pctHeader), MockRead("hello world"), |
- MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
- MockRead(ASYNC, OK)}; |
- |
- StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, |
- 0); |
- socket_factory_.AddSocketDataProvider(&http_data); |
- |
- MockQuicData mock_quic_data; |
- mock_quic_data.AddWrite( |
- ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, |
- GetRequestHeaders("GET", "https", "/"))); |
- mock_quic_data.AddRead(ConstructResponseHeadersPacket( |
- 1, kClientDataStreamId1, false, false, GetResponseHeaders("200 OK"))); |
- mock_quic_data.AddRead( |
- ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); |
- mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
- mock_quic_data.AddRead(ASYNC, ERR_IO_PENDING); // No more data to read |
- mock_quic_data.AddRead(ASYNC, 0); // EOF |
- |
- mock_quic_data.AddSocketDataToFactory(&socket_factory_); |
- |
- // The non-alternate protocol job needs to hang in order to guarantee that |
- // the alternate-protocol job will "win". |
- AddHangingNonAlternateProtocolSocketData(); |
- |
- params_.alternative_service_probability_threshold = .25; |
- params_.parse_alternative_services = false; |
- CreateSession(); |
- |
- SendRequestAndExpectHttpResponse("hello world"); |
- SendRequestAndExpectQuicResponse("hello!"); |
-} |
- |
-TEST_P(QuicNetworkTransactionTest, DontUseAlternateProtocolProbabilityForQuic) { |
- params_.parse_alternative_services = false; |
- MockRead http_reads[] = { |
- MockRead("HTTP/1.1 200 OK\r\n"), |
- MockRead(kQuicAlternateProtocol50pctHeader), MockRead("hello world"), |
- MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
- MockRead(ASYNC, OK)}; |
- |
- StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, |
- 0); |
- socket_factory_.AddSocketDataProvider(&http_data); |
- socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
- socket_factory_.AddSocketDataProvider(&http_data); |
- socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
- |
- params_.alternative_service_probability_threshold = .75; |
- CreateSession(); |
- |
- SendRequestAndExpectHttpResponse("hello world"); |
- SendRequestAndExpectHttpResponse("hello world"); |
-} |
- |
-TEST_P(QuicNetworkTransactionTest, |
- DontUseAlternateProtocolWithBadProbabilityForQuic) { |
- params_.parse_alternative_services = false; |
- MockRead http_reads[] = { |
- MockRead("HTTP/1.1 200 OK\r\n"), |
- MockRead("Alternate-Protocol: 443:quic,p=2\r\n\r\n"), |
- MockRead("hello world"), |
- MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
- MockRead(ASYNC, OK)}; |
- |
- StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr, |
- 0); |
- socket_factory_.AddSocketDataProvider(&http_data); |
- socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
- socket_factory_.AddSocketDataProvider(&http_data); |
- socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
- |
- params_.alternative_service_probability_threshold = .75; |
- CreateSession(); |
- |
- SendRequestAndExpectHttpResponse("hello world"); |
- SendRequestAndExpectHttpResponse("hello world"); |
-} |
- |
TEST_P(QuicNetworkTransactionTest, UseAlternateProtocolForQuicForHttps) { |
params_.parse_alternative_services = false; |
MockRead http_reads[] = { |
@@ -1757,7 +1591,7 @@ class QuicAltSvcCertificateVerificationTest |
AlternativeService alternative_service(QUIC, alternative); |
base::Time expiration = base::Time::Now() + base::TimeDelta::FromDays(1); |
session_->http_server_properties()->SetAlternativeService( |
- origin, alternative_service, 1.0, expiration); |
+ origin, alternative_service, expiration); |
scoped_ptr<HttpNetworkTransaction> trans( |
new HttpNetworkTransaction(DEFAULT_PRIORITY, session_.get())); |
TestCompletionCallback callback; |