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 851371d7e0cc634891621cd924ffa9af31fdb768..8831adc6ee82f23188f04aeec8740d21c3ebfc81 100644 |
--- a/net/quic/quic_network_transaction_unittest.cc |
+++ b/net/quic/quic_network_transaction_unittest.cc |
@@ -54,6 +54,9 @@ static const char kQuicAlternateProtocolHttpHeader[] = |
static const char kQuicAlternateProtocolHttpsHeader[] = |
"Alternate-Protocol: 443:quic\r\n\r\n"; |
+// Used by the QuicNetworkTransactionTest unit tests. |
+const net::QuicStreamId kStreamId5 = 5; |
+ |
} // namespace |
namespace net { |
@@ -158,21 +161,10 @@ class QuicNetworkTransactionTest |
return maker_.GetRequestHeaders(method, scheme, path); |
} |
- std::string GetRequestString(const std::string& method, |
- const std::string& scheme, |
- const std::string& path) { |
- return maker_.GetRequestString(method, scheme, path); |
- } |
- |
SpdyHeaderBlock GetResponseHeaders(const std::string& status) { |
return maker_.GetResponseHeaders(status); |
} |
- std::string GetResponseString(const std::string& status, |
- const std::string& body) { |
- return maker_.GetResponseString(status, body); |
- } |
- |
scoped_ptr<QuicEncryptedPacket> ConstructDataPacket( |
QuicPacketSequenceNumber sequence_number, |
QuicStreamId stream_id, |
@@ -327,27 +319,16 @@ TEST_P(QuicNetworkTransactionTest, ForceQuic) { |
params_.origin_to_force_quic_on = |
HostPortPair::FromString("www.google.com:80"); |
- QuicStreamId stream_id = GetParam() > QUIC_VERSION_12 ? 5 : 3; |
MockQuicData mock_quic_data; |
- if (GetParam() > QUIC_VERSION_12) { |
- mock_quic_data.AddWrite( |
- ConstructRequestHeadersPacket(1, stream_id, true, true, |
- GetRequestHeaders("GET", "http", "/"))); |
- mock_quic_data.AddRead( |
- ConstructResponseHeadersPacket(1, stream_id, false, false, |
- GetResponseHeaders("200 OK"))); |
- mock_quic_data.AddRead( |
- ConstructDataPacket(2, stream_id, false, true, 0, "hello!")); |
- mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
- } else { |
- mock_quic_data.AddWrite( |
- ConstructDataPacket(1, stream_id, true, true, 0, |
- GetRequestString("GET", "http", "/"))); |
- mock_quic_data.AddRead( |
- ConstructDataPacket(1, stream_id, false, true, 0, |
- GetResponseString("200 OK", "hello!"))); |
- mock_quic_data.AddWrite(ConstructAckPacket(1, 0)); |
- } |
+ mock_quic_data.AddWrite( |
+ ConstructRequestHeadersPacket(1, kStreamId5, true, true, |
+ GetRequestHeaders("GET", "http", "/"))); |
+ mock_quic_data.AddRead( |
+ ConstructResponseHeadersPacket(1, kStreamId5, false, false, |
+ GetResponseHeaders("200 OK"))); |
+ mock_quic_data.AddRead( |
+ ConstructDataPacket(2, kStreamId5, false, true, 0, "hello!")); |
+ mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF |
mock_quic_data.AddDelayedSocketDataToFactory(&socket_factory_, 1); |
@@ -400,27 +381,16 @@ TEST_P(QuicNetworkTransactionTest, QuicProxy) { |
proxy_service_.reset( |
ProxyService::CreateFixedFromPacResult("QUIC myproxy:70")); |
- QuicStreamId stream_id = GetParam() > QUIC_VERSION_12 ? 5 : 3; |
MockQuicData mock_quic_data; |
- if (GetParam() > QUIC_VERSION_12) { |
- mock_quic_data.AddWrite( |
- ConstructRequestHeadersPacket(1, stream_id, true, true, |
- GetRequestHeaders("GET", "http", "/"))); |
- mock_quic_data.AddRead( |
- ConstructResponseHeadersPacket(1, stream_id, false, false, |
- GetResponseHeaders("200 OK"))); |
- mock_quic_data.AddRead( |
- ConstructDataPacket(2, stream_id, false, true, 0, "hello!")); |
- mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
- } else { |
- mock_quic_data.AddWrite( |
- ConstructDataPacket(1, stream_id, true, true, 0, |
- GetRequestString("GET", "http", "/"))); |
- mock_quic_data.AddRead( |
- ConstructDataPacket(1, stream_id, false, true, 0, |
- GetResponseString("200 OK", "hello!"))); |
- mock_quic_data.AddWrite(ConstructAckPacket(1, 0)); |
- } |
+ mock_quic_data.AddWrite( |
+ ConstructRequestHeadersPacket(1, kStreamId5, true, true, |
+ GetRequestHeaders("GET", "http", "/"))); |
+ mock_quic_data.AddRead( |
+ ConstructResponseHeadersPacket(1, kStreamId5, false, false, |
+ GetResponseHeaders("200 OK"))); |
+ mock_quic_data.AddRead( |
+ ConstructDataPacket(2, kStreamId5, false, true, 0, "hello!")); |
+ mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF |
mock_quic_data.AddDelayedSocketDataToFactory(&socket_factory_, 1); |
@@ -489,27 +459,16 @@ TEST_P(QuicNetworkTransactionTest, UseAlternateProtocolForQuic) { |
NULL, 0); |
socket_factory_.AddSocketDataProvider(&http_data); |
- QuicStreamId stream_id = GetParam() > QUIC_VERSION_12 ? 5 : 3; |
MockQuicData mock_quic_data; |
- if (GetParam() > QUIC_VERSION_12) { |
- mock_quic_data.AddWrite( |
- ConstructRequestHeadersPacket(1, stream_id, true, true, |
- GetRequestHeaders("GET", "http", "/"))); |
- mock_quic_data.AddRead( |
- ConstructResponseHeadersPacket(1, stream_id, false, false, |
- GetResponseHeaders("200 OK"))); |
- mock_quic_data.AddRead( |
- ConstructDataPacket(2, stream_id, false, true, 0, "hello!")); |
- mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
- } else { |
- mock_quic_data.AddWrite( |
- ConstructDataPacket(1, stream_id, true, true, 0, |
- GetRequestString("GET", "http", "/"))); |
- mock_quic_data.AddRead( |
- ConstructDataPacket(1, stream_id, false, true, 0, |
- GetResponseString("200 OK", "hello!"))); |
- mock_quic_data.AddWrite(ConstructAckPacket(1, 0)); |
- } |
+ mock_quic_data.AddWrite( |
+ ConstructRequestHeadersPacket(1, kStreamId5, true, true, |
+ GetRequestHeaders("GET", "http", "/"))); |
+ mock_quic_data.AddRead( |
+ ConstructResponseHeadersPacket(1, kStreamId5, false, false, |
+ GetResponseHeaders("200 OK"))); |
+ mock_quic_data.AddRead( |
+ ConstructDataPacket(2, kStreamId5, false, true, 0, "hello!")); |
+ mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF |
mock_quic_data.AddDelayedSocketDataToFactory(&socket_factory_, 1); |
@@ -542,27 +501,16 @@ TEST_P(QuicNetworkTransactionTest, UseAlternateProtocolForQuicForHttps) { |
NULL, 0); |
socket_factory_.AddSocketDataProvider(&http_data); |
- QuicStreamId stream_id = GetParam() > QUIC_VERSION_12 ? 5 : 3; |
MockQuicData mock_quic_data; |
- if (GetParam() > QUIC_VERSION_12) { |
- mock_quic_data.AddWrite( |
- ConstructRequestHeadersPacket(1, stream_id, true, true, |
- GetRequestHeaders("GET", "http", "/"))); |
- mock_quic_data.AddRead( |
- ConstructResponseHeadersPacket(1, stream_id, false, false, |
- GetResponseHeaders("200 OK"))); |
- mock_quic_data.AddRead( |
- ConstructDataPacket(2, stream_id, false, true, 0, "hello!")); |
- mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
- } else { |
- mock_quic_data.AddWrite( |
- ConstructDataPacket(1, stream_id, true, true, 0, |
- GetRequestString("GET", "http", "/"))); |
- mock_quic_data.AddRead( |
- ConstructDataPacket(1, stream_id, false, true, 0, |
- GetResponseString("200 OK", "hello!"))); |
- mock_quic_data.AddWrite(ConstructAckPacket(1, 0)); |
- } |
+ mock_quic_data.AddWrite( |
+ ConstructRequestHeadersPacket(1, kStreamId5, true, true, |
+ GetRequestHeaders("GET", "http", "/"))); |
+ mock_quic_data.AddRead( |
+ ConstructResponseHeadersPacket(1, kStreamId5, false, false, |
+ GetResponseHeaders("200 OK"))); |
+ mock_quic_data.AddRead( |
+ ConstructDataPacket(2, kStreamId5, false, true, 0, "hello!")); |
+ mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF |
mock_quic_data.AddDelayedSocketDataToFactory(&socket_factory_, 1); |
@@ -639,27 +587,16 @@ TEST_P(QuicNetworkTransactionTest, HungAlternateProtocol) { |
TEST_P(QuicNetworkTransactionTest, ZeroRTTWithHttpRace) { |
HttpStreamFactory::EnableNpnSpdy3(); // Enables QUIC too. |
- QuicStreamId stream_id = GetParam() > QUIC_VERSION_12 ? 5 : 3; |
MockQuicData mock_quic_data; |
- if (GetParam() > QUIC_VERSION_12) { |
- mock_quic_data.AddWrite( |
- ConstructRequestHeadersPacket(1, stream_id, true, true, |
- GetRequestHeaders("GET", "http", "/"))); |
- mock_quic_data.AddRead( |
- ConstructResponseHeadersPacket(1, stream_id, false, false, |
- GetResponseHeaders("200 OK"))); |
- mock_quic_data.AddRead( |
- ConstructDataPacket(2, stream_id, false, true, 0, "hello!")); |
- mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
- } else { |
- mock_quic_data.AddWrite( |
- ConstructDataPacket(1, stream_id, true, true, 0, |
- GetRequestString("GET", "http", "/"))); |
- mock_quic_data.AddRead( |
- ConstructDataPacket(1, stream_id, false, true, 0, |
- GetResponseString("200 OK", "hello!"))); |
- mock_quic_data.AddWrite(ConstructAckPacket(1, 0)); |
- } |
+ mock_quic_data.AddWrite( |
+ ConstructRequestHeadersPacket(1, kStreamId5, true, true, |
+ GetRequestHeaders("GET", "http", "/"))); |
+ mock_quic_data.AddRead( |
+ ConstructResponseHeadersPacket(1, kStreamId5, false, false, |
+ GetResponseHeaders("200 OK"))); |
+ mock_quic_data.AddRead( |
+ ConstructDataPacket(2, kStreamId5, false, true, 0, "hello!")); |
+ mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF |
mock_quic_data.AddDelayedSocketDataToFactory(&socket_factory_, 1); |
@@ -676,27 +613,16 @@ TEST_P(QuicNetworkTransactionTest, ZeroRTTWithHttpRace) { |
TEST_P(QuicNetworkTransactionTest, ZeroRTTWithNoHttpRace) { |
HttpStreamFactory::EnableNpnSpdy3(); // Enables QUIC too. |
- QuicStreamId stream_id = GetParam() > QUIC_VERSION_12 ? 5 : 3; |
MockQuicData mock_quic_data; |
- if (GetParam() > QUIC_VERSION_12) { |
- mock_quic_data.AddWrite( |
- ConstructRequestHeadersPacket(1, stream_id, true, true, |
- GetRequestHeaders("GET", "http", "/"))); |
- mock_quic_data.AddRead( |
- ConstructResponseHeadersPacket(1, stream_id, false, false, |
- GetResponseHeaders("200 OK"))); |
- mock_quic_data.AddRead( |
- ConstructDataPacket(2, stream_id, false, true, 0, "hello!")); |
- mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
- } else { |
- mock_quic_data.AddWrite( |
- ConstructDataPacket(1, stream_id, true, true, 0, |
- GetRequestString("GET", "http", "/"))); |
- mock_quic_data.AddRead( |
- ConstructDataPacket(1, stream_id, false, true, 0, |
- GetResponseString("200 OK", "hello!"))); |
- mock_quic_data.AddWrite(ConstructAckPacket(1, 0)); |
- } |
+ mock_quic_data.AddWrite( |
+ ConstructRequestHeadersPacket(1, kStreamId5, true, true, |
+ GetRequestHeaders("GET", "http", "/"))); |
+ mock_quic_data.AddRead( |
+ ConstructResponseHeadersPacket(1, kStreamId5, false, false, |
+ GetResponseHeaders("200 OK"))); |
+ mock_quic_data.AddRead( |
+ ConstructDataPacket(2, kStreamId5, false, true, 0, "hello!")); |
+ mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF |
mock_quic_data.AddDelayedSocketDataToFactory(&socket_factory_, 1); |
@@ -722,27 +648,16 @@ TEST_P(QuicNetworkTransactionTest, ZeroRTTWithNoHttpRace) { |
TEST_P(QuicNetworkTransactionTest, ZeroRTTWithConfirmationRequired) { |
HttpStreamFactory::EnableNpnSpdy3(); // Enables QUIC too. |
- QuicStreamId stream_id = GetParam() > QUIC_VERSION_12 ? 5 : 3; |
MockQuicData mock_quic_data; |
- if (GetParam() > QUIC_VERSION_12) { |
- mock_quic_data.AddWrite( |
- ConstructRequestHeadersPacket(1, stream_id, true, true, |
- GetRequestHeaders("GET", "http", "/"))); |
- mock_quic_data.AddRead( |
- ConstructResponseHeadersPacket(1, stream_id, false, false, |
- GetResponseHeaders("200 OK"))); |
- mock_quic_data.AddRead( |
- ConstructDataPacket(2, stream_id, false, true, 0, "hello!")); |
- mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
- } else { |
- mock_quic_data.AddWrite( |
- ConstructDataPacket(1, stream_id, true, true, 0, |
- GetRequestString("GET", "http", "/"))); |
- mock_quic_data.AddRead( |
- ConstructDataPacket(1, stream_id, false, true, 0, |
- GetResponseString("200 OK", "hello!"))); |
- mock_quic_data.AddWrite(ConstructAckPacket(1, 0)); |
- } |
+ mock_quic_data.AddWrite( |
+ ConstructRequestHeadersPacket(1, kStreamId5, true, true, |
+ GetRequestHeaders("GET", "http", "/"))); |
+ mock_quic_data.AddRead( |
+ ConstructResponseHeadersPacket(1, kStreamId5, false, false, |
+ GetResponseHeaders("200 OK"))); |
+ mock_quic_data.AddRead( |
+ ConstructDataPacket(2, kStreamId5, false, true, 0, "hello!")); |
+ mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF |
mock_quic_data.AddDelayedSocketDataToFactory(&socket_factory_, 1); |
@@ -878,20 +793,12 @@ TEST_P(QuicNetworkTransactionTest, FailedZeroRttBrokenAlternateProtocol) { |
TEST_P(QuicNetworkTransactionTest, ConnectionCloseDuringConnect) { |
HttpStreamFactory::EnableNpnSpdy3(); // Enables QUIC too. |
- QuicStreamId stream_id = GetParam() > QUIC_VERSION_12 ? 5 : 3; |
MockQuicData mock_quic_data; |
mock_quic_data.AddRead(ConstructConnectionClosePacket(1)); |
- if (GetParam() > QUIC_VERSION_12) { |
- mock_quic_data.AddWrite( |
- ConstructRequestHeadersPacket(1, stream_id, true, true, |
- GetRequestHeaders("GET", "http", "/"))); |
- mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
- } else { |
- mock_quic_data.AddWrite( |
- ConstructDataPacket(1, stream_id, true, true, 0, |
- GetRequestString("GET", "http", "/"))); |
- mock_quic_data.AddWrite(ConstructAckPacket(1, 0)); |
- } |
+ mock_quic_data.AddWrite( |
+ ConstructRequestHeadersPacket(1, kStreamId5, true, true, |
+ GetRequestHeaders("GET", "http", "/"))); |
+ mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
mock_quic_data.AddDelayedSocketDataToFactory(&socket_factory_, 0); |
// When the QUIC connection fails, we will try the request again over HTTP. |