Index: net/quic/quic_stream_factory_test.cc |
diff --git a/net/quic/quic_stream_factory_test.cc b/net/quic/quic_stream_factory_test.cc |
index abe601201bf52ec7a82494ffa59f019e17c4977b..63e80ff1f4fbd3c58d3f4e85b3a233f1676c5876 100644 |
--- a/net/quic/quic_stream_factory_test.cc |
+++ b/net/quic/quic_stream_factory_test.cc |
@@ -298,7 +298,8 @@ class QuicStreamFactoryTest : public ::testing::TestWithParam<TestParams> { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(destination, privacy_mode_, |
/*cert_verify_flags=*/0, destination.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
@@ -441,7 +442,8 @@ TEST_P(QuicStreamFactoryTest, Create) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
@@ -457,7 +459,8 @@ TEST_P(QuicStreamFactoryTest, Create) { |
EXPECT_EQ(OK, |
request2.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
stream = request2.ReleaseStream(); // Will reset stream 5. |
stream.reset(); // Will reset stream 7. |
@@ -483,7 +486,8 @@ TEST_P(QuicStreamFactoryTest, CreateZeroRtt) { |
QuicStreamRequest request(factory_.get()); |
EXPECT_EQ(OK, request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
EXPECT_TRUE(stream.get()); |
@@ -511,7 +515,8 @@ TEST_P(QuicStreamFactoryTest, CreateZeroRttPost) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "POST", net_log_, callback_.callback())); |
+ "POST", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
// Confirm the handshake and verify that the stream is created. |
crypto_client_stream_factory_.last_stream()->SendOnCryptoHandshakeEvent( |
@@ -540,9 +545,9 @@ TEST_P(QuicStreamFactoryTest, NoZeroRttForDifferentHost) { |
"192.168.0.1", ""); |
QuicStreamRequest request(factory_.get()); |
- int rv = |
- request.Request(host_port_pair_, privacy_mode_, /*cert_verify_flags=*/0, |
- kServer2HostName, "GET", net_log_, callback_.callback()); |
+ int rv = request.Request( |
+ host_port_pair_, privacy_mode_, /*cert_verify_flags=*/0, kServer2HostName, |
+ "GET", net_log_, callback_.callback(), /*for_bidirectional=*/false); |
// If server and origin have different hostnames, then handshake confirmation |
// should be required, so Request will return asynchronously. |
EXPECT_EQ(ERR_IO_PENDING, rv); |
@@ -570,7 +575,8 @@ TEST_P(QuicStreamFactoryTest, GoAway) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
@@ -606,7 +612,8 @@ TEST_P(QuicStreamFactoryTest, Pooling) { |
QuicStreamRequest request(factory_.get()); |
EXPECT_EQ(OK, request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
EXPECT_TRUE(stream.get()); |
@@ -614,7 +621,8 @@ TEST_P(QuicStreamFactoryTest, Pooling) { |
QuicStreamRequest request2(factory_.get()); |
EXPECT_EQ(OK, request2.Request(server2, privacy_mode_, |
/*cert_verify_flags=*/0, server2.host(), "GET", |
- net_log_, callback.callback())); |
+ net_log_, callback.callback(), |
+ /*for_bidirectional=*/false)); |
scoped_ptr<QuicHttpStream> stream2 = request2.ReleaseStream(); |
EXPECT_TRUE(stream2.get()); |
@@ -648,7 +656,8 @@ TEST_P(QuicStreamFactoryTest, NoPoolingIfDisabled) { |
QuicStreamRequest request(factory_.get()); |
EXPECT_EQ(OK, request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
EXPECT_TRUE(stream.get()); |
@@ -656,7 +665,8 @@ TEST_P(QuicStreamFactoryTest, NoPoolingIfDisabled) { |
QuicStreamRequest request2(factory_.get()); |
EXPECT_EQ(OK, request2.Request(server2, privacy_mode_, |
/*cert_verify_flags=*/0, server2.host(), "GET", |
- net_log_, callback.callback())); |
+ net_log_, callback.callback(), |
+ /*for_bidirectional=*/false)); |
scoped_ptr<QuicHttpStream> stream2 = request2.ReleaseStream(); |
EXPECT_TRUE(stream2.get()); |
@@ -691,7 +701,8 @@ TEST_P(QuicStreamFactoryTest, NoPoolingAfterGoAway) { |
QuicStreamRequest request(factory_.get()); |
EXPECT_EQ(OK, request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
EXPECT_TRUE(stream.get()); |
@@ -699,7 +710,8 @@ TEST_P(QuicStreamFactoryTest, NoPoolingAfterGoAway) { |
QuicStreamRequest request2(factory_.get()); |
EXPECT_EQ(OK, request2.Request(server2, privacy_mode_, |
/*cert_verify_flags=*/0, server2.host(), "GET", |
- net_log_, callback.callback())); |
+ net_log_, callback.callback(), |
+ /*for_bidirectional=*/false)); |
scoped_ptr<QuicHttpStream> stream2 = request2.ReleaseStream(); |
EXPECT_TRUE(stream2.get()); |
@@ -714,7 +726,8 @@ TEST_P(QuicStreamFactoryTest, NoPoolingAfterGoAway) { |
QuicStreamRequest request3(factory_.get()); |
EXPECT_EQ(OK, request3.Request(server2, privacy_mode_, |
/*cert_verify_flags=*/0, server2.host(), "GET", |
- net_log_, callback3.callback())); |
+ net_log_, callback3.callback(), |
+ /*for_bidirectional=*/false)); |
scoped_ptr<QuicHttpStream> stream3 = request3.ReleaseStream(); |
EXPECT_TRUE(stream3.get()); |
@@ -746,7 +759,8 @@ TEST_P(QuicStreamFactoryTest, HttpsPooling) { |
QuicStreamRequest request(factory_.get()); |
EXPECT_EQ(OK, request.Request(server1, privacy_mode_, |
/*cert_verify_flags=*/0, server1.host(), "GET", |
- net_log_, callback_.callback())); |
+ net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
EXPECT_TRUE(stream.get()); |
@@ -754,7 +768,8 @@ TEST_P(QuicStreamFactoryTest, HttpsPooling) { |
QuicStreamRequest request2(factory_.get()); |
EXPECT_EQ(OK, request2.Request(server2, privacy_mode_, |
/*cert_verify_flags=*/0, server2.host(), "GET", |
- net_log_, callback_.callback())); |
+ net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
scoped_ptr<QuicHttpStream> stream2 = request2.ReleaseStream(); |
EXPECT_TRUE(stream2.get()); |
@@ -789,7 +804,8 @@ TEST_P(QuicStreamFactoryTest, NoHttpsPoolingIfDisabled) { |
QuicStreamRequest request(factory_.get()); |
EXPECT_EQ(OK, request.Request(server1, privacy_mode_, |
/*cert_verify_flags=*/0, server1.host(), "GET", |
- net_log_, callback_.callback())); |
+ net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
EXPECT_TRUE(stream.get()); |
@@ -797,7 +813,8 @@ TEST_P(QuicStreamFactoryTest, NoHttpsPoolingIfDisabled) { |
QuicStreamRequest request2(factory_.get()); |
EXPECT_EQ(OK, request2.Request(server2, privacy_mode_, |
/*cert_verify_flags=*/0, server2.host(), "GET", |
- net_log_, callback_.callback())); |
+ net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
scoped_ptr<QuicHttpStream> stream2 = request2.ReleaseStream(); |
EXPECT_TRUE(stream2.get()); |
@@ -842,14 +859,16 @@ class QuicAlternativeServiceCertificateValidationPooling |
QuicStreamRequest request1(factory_.get()); |
EXPECT_EQ(OK, request1.Request(alternative, privacy_mode_, |
/*cert_verify_flags=*/0, alternative.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
scoped_ptr<QuicHttpStream> stream1 = request1.ReleaseStream(); |
EXPECT_TRUE(stream1.get()); |
QuicStreamRequest request2(factory_.get()); |
- int rv = request2.Request(alternative, privacy_mode_, |
- /*cert_verify_flags=*/0, origin_host, "GET", |
- net_log_, callback_.callback()); |
+ int rv = |
+ request2.Request(alternative, privacy_mode_, |
+ /*cert_verify_flags=*/0, origin_host, "GET", net_log_, |
+ callback_.callback(), /*for_bidirectional=*/false); |
if (valid) { |
// Alternative service of origin to |alternative| should pool to session |
// of |stream1| even if origin is different. Since only one |
@@ -906,7 +925,8 @@ TEST_P(QuicStreamFactoryTest, HttpsPoolingWithMatchingPins) { |
QuicStreamRequest request(factory_.get()); |
EXPECT_EQ(OK, request.Request(server1, privacy_mode_, |
/*cert_verify_flags=*/0, server1.host(), "GET", |
- net_log_, callback_.callback())); |
+ net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
EXPECT_TRUE(stream.get()); |
@@ -914,7 +934,8 @@ TEST_P(QuicStreamFactoryTest, HttpsPoolingWithMatchingPins) { |
QuicStreamRequest request2(factory_.get()); |
EXPECT_EQ(OK, request2.Request(server2, privacy_mode_, |
/*cert_verify_flags=*/0, server2.host(), "GET", |
- net_log_, callback_.callback())); |
+ net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
scoped_ptr<QuicHttpStream> stream2 = request2.ReleaseStream(); |
EXPECT_TRUE(stream2.get()); |
@@ -955,7 +976,8 @@ TEST_P(QuicStreamFactoryTest, NoHttpsPoolingWithMatchingPinsIfDisabled) { |
QuicStreamRequest request(factory_.get()); |
EXPECT_EQ(OK, request.Request(server1, privacy_mode_, |
/*cert_verify_flags=*/0, server1.host(), "GET", |
- net_log_, callback_.callback())); |
+ net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
EXPECT_TRUE(stream.get()); |
@@ -963,7 +985,8 @@ TEST_P(QuicStreamFactoryTest, NoHttpsPoolingWithMatchingPinsIfDisabled) { |
QuicStreamRequest request2(factory_.get()); |
EXPECT_EQ(OK, request2.Request(server2, privacy_mode_, |
/*cert_verify_flags=*/0, server2.host(), "GET", |
- net_log_, callback_.callback())); |
+ net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
scoped_ptr<QuicHttpStream> stream2 = request2.ReleaseStream(); |
EXPECT_TRUE(stream2.get()); |
@@ -1009,7 +1032,8 @@ TEST_P(QuicStreamFactoryTest, NoHttpsPoolingWithDifferentPins) { |
QuicStreamRequest request(factory_.get()); |
EXPECT_EQ(OK, request.Request(server1, privacy_mode_, |
/*cert_verify_flags=*/0, server1.host(), "GET", |
- net_log_, callback_.callback())); |
+ net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
EXPECT_TRUE(stream.get()); |
@@ -1017,7 +1041,8 @@ TEST_P(QuicStreamFactoryTest, NoHttpsPoolingWithDifferentPins) { |
QuicStreamRequest request2(factory_.get()); |
EXPECT_EQ(OK, request2.Request(server2, privacy_mode_, |
/*cert_verify_flags=*/0, server2.host(), "GET", |
- net_log_, callback_.callback())); |
+ net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
scoped_ptr<QuicHttpStream> stream2 = request2.ReleaseStream(); |
EXPECT_TRUE(stream2.get()); |
@@ -1046,7 +1071,8 @@ TEST_P(QuicStreamFactoryTest, Goaway) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
@@ -1069,7 +1095,8 @@ TEST_P(QuicStreamFactoryTest, Goaway) { |
EXPECT_EQ(ERR_IO_PENDING, |
request2.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream2 = request2.ReleaseStream(); |
EXPECT_TRUE(stream2.get()); |
@@ -1118,7 +1145,8 @@ TEST_P(QuicStreamFactoryTest, MaxOpenStream) { |
QuicStreamRequest request(factory_.get()); |
int rv = request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback()); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false); |
if (i == 0) { |
EXPECT_EQ(ERR_IO_PENDING, rv); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
@@ -1135,7 +1163,8 @@ TEST_P(QuicStreamFactoryTest, MaxOpenStream) { |
QuicStreamRequest request(factory_.get()); |
EXPECT_EQ(OK, request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, CompletionCallback())); |
+ "GET", net_log_, CompletionCallback(), |
+ /*for_bidirectional=*/false)); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
EXPECT_TRUE(stream); |
EXPECT_EQ(ERR_IO_PENDING, |
@@ -1173,7 +1202,8 @@ TEST_P(QuicStreamFactoryTest, ResolutionErrorInCreate) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(ERR_NAME_NOT_RESOLVED, callback_.WaitForResult()); |
@@ -1192,7 +1222,8 @@ TEST_P(QuicStreamFactoryTest, ConnectErrorInCreate) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(ERR_ADDRESS_IN_USE, callback_.WaitForResult()); |
@@ -1210,7 +1241,8 @@ TEST_P(QuicStreamFactoryTest, CancelCreate) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
} |
base::RunLoop().RunUntilIdle(); |
@@ -1281,7 +1313,8 @@ TEST_P(QuicStreamFactoryTest, CloseAllSessions) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
@@ -1301,7 +1334,8 @@ TEST_P(QuicStreamFactoryTest, CloseAllSessions) { |
EXPECT_EQ(ERR_IO_PENDING, |
request2.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
stream = request2.ReleaseStream(); |
@@ -1337,7 +1371,8 @@ TEST_P(QuicStreamFactoryTest, OnIPAddressChanged) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
@@ -1358,7 +1393,8 @@ TEST_P(QuicStreamFactoryTest, OnIPAddressChanged) { |
EXPECT_EQ(ERR_IO_PENDING, |
request2.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
stream = request2.ReleaseStream(); |
@@ -1391,7 +1427,8 @@ TEST_P(QuicStreamFactoryTest, OnNetworkChangeSoonToDisconnect) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
EXPECT_TRUE(stream.get()); |
@@ -1456,7 +1493,8 @@ TEST_P(QuicStreamFactoryTest, OnNetworkChangeSoonToDisconnect) { |
EXPECT_EQ(ERR_IO_PENDING, |
request2.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream2 = request2.ReleaseStream(); |
EXPECT_TRUE(stream2.get()); |
@@ -1506,7 +1544,8 @@ TEST_P(QuicStreamFactoryTest, OnNetworkChangeDisconnected) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
EXPECT_TRUE(stream.get()); |
@@ -1567,7 +1606,8 @@ TEST_P(QuicStreamFactoryTest, OnNetworkChangeDisconnected) { |
EXPECT_EQ(ERR_IO_PENDING, |
request2.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream2 = request2.ReleaseStream(); |
EXPECT_TRUE(stream2.get()); |
@@ -1608,7 +1648,8 @@ TEST_P(QuicStreamFactoryTest, OnNetworkChangeSoonToDisconnectNoNetworks) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
EXPECT_TRUE(stream.get()); |
@@ -1662,7 +1703,8 @@ TEST_P(QuicStreamFactoryTest, OnNetworkChangeDisconnectedNoNetworks) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
EXPECT_TRUE(stream.get()); |
@@ -1711,7 +1753,8 @@ TEST_P(QuicStreamFactoryTest, OnNetworkChangeSoonToDisconnectNoNewNetwork) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
EXPECT_TRUE(stream.get()); |
@@ -1763,7 +1806,8 @@ TEST_P(QuicStreamFactoryTest, OnNetworkChangeDisconnectedNoNewNetwork) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
EXPECT_TRUE(stream.get()); |
@@ -1807,7 +1851,8 @@ TEST_P(QuicStreamFactoryTest, OnNetworkChangeSoonToDisconnectNoOpenStreams) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
EXPECT_TRUE(stream.get()); |
@@ -1845,7 +1890,8 @@ TEST_P(QuicStreamFactoryTest, OnNetworkChangeDisconnectedNoOpenStreams) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
EXPECT_TRUE(stream.get()); |
@@ -1889,7 +1935,8 @@ TEST_P(QuicStreamFactoryTest, MigrateSessionEarly) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
EXPECT_TRUE(stream.get()); |
@@ -1957,7 +2004,8 @@ TEST_P(QuicStreamFactoryTest, MigrateSessionEarly) { |
EXPECT_EQ(ERR_IO_PENDING, |
request2.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream2 = request2.ReleaseStream(); |
EXPECT_TRUE(stream2.get()); |
@@ -2012,7 +2060,8 @@ TEST_P(QuicStreamFactoryTest, MigrateSessionEarlyNoNewNetwork) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
EXPECT_TRUE(stream.get()); |
@@ -2070,7 +2119,8 @@ TEST_P(QuicStreamFactoryTest, OnSSLConfigChanged) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
@@ -2090,7 +2140,8 @@ TEST_P(QuicStreamFactoryTest, OnSSLConfigChanged) { |
EXPECT_EQ(ERR_IO_PENDING, |
request2.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
stream = request2.ReleaseStream(); |
@@ -2125,7 +2176,8 @@ TEST_P(QuicStreamFactoryTest, OnCertAdded) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
@@ -2146,7 +2198,8 @@ TEST_P(QuicStreamFactoryTest, OnCertAdded) { |
EXPECT_EQ(ERR_IO_PENDING, |
request2.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
stream = request2.ReleaseStream(); |
@@ -2181,7 +2234,8 @@ TEST_P(QuicStreamFactoryTest, OnCACertChanged) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
scoped_ptr<QuicHttpStream> stream = request.ReleaseStream(); |
@@ -2202,7 +2256,8 @@ TEST_P(QuicStreamFactoryTest, OnCACertChanged) { |
EXPECT_EQ(ERR_IO_PENDING, |
request2.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(OK, callback_.WaitForResult()); |
stream = request2.ReleaseStream(); |
@@ -2326,7 +2381,8 @@ TEST_P(QuicStreamFactoryTest, RacingConnections) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
EXPECT_EQ(2u, QuicStreamFactoryPeer::GetNumberOfActiveJobs(factory_.get(), |
server_id)); |
@@ -2361,7 +2417,8 @@ TEST_P(QuicStreamFactoryTest, EnableNotLoadFromDiskCache) { |
QuicStreamRequest request(factory_.get()); |
EXPECT_EQ(OK, request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
// If we are waiting for disk cache, we would have posted a task. Verify that |
// the CancelWaitForDataReady task hasn't been posted. |
@@ -2419,7 +2476,8 @@ TEST_P(QuicStreamFactoryTest, BadPacketLoss) { |
QuicStreamRequest request(factory_.get()); |
EXPECT_EQ(OK, request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), host_port_pair_); |
@@ -2457,7 +2515,8 @@ TEST_P(QuicStreamFactoryTest, BadPacketLoss) { |
QuicStreamRequest request2(factory_.get()); |
EXPECT_EQ(OK, request2.Request(server2, privacy_mode_, |
/*cert_verify_flags=*/0, server2.host(), "GET", |
- net_log_, callback2.callback())); |
+ net_log_, callback2.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session2 = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), server2); |
@@ -2489,7 +2548,8 @@ TEST_P(QuicStreamFactoryTest, BadPacketLoss) { |
QuicStreamRequest request3(factory_.get()); |
EXPECT_EQ(OK, request3.Request(server3, privacy_mode_, |
/*cert_verify_flags=*/0, server3.host(), "GET", |
- net_log_, callback3.callback())); |
+ net_log_, callback3.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session3 = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), server3); |
@@ -2498,7 +2558,8 @@ TEST_P(QuicStreamFactoryTest, BadPacketLoss) { |
QuicStreamRequest request4(factory_.get()); |
EXPECT_EQ(OK, request4.Request(server4, privacy_mode_, |
/*cert_verify_flags=*/0, server4.host(), "GET", |
- net_log_, callback4.callback())); |
+ net_log_, callback4.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session4 = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), server4); |
@@ -2579,7 +2640,8 @@ TEST_P(QuicStreamFactoryTest, PublicResetPostHandshakeTwoOfTwo) { |
QuicStreamRequest request(factory_.get()); |
EXPECT_EQ(OK, request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), host_port_pair_); |
@@ -2603,7 +2665,8 @@ TEST_P(QuicStreamFactoryTest, PublicResetPostHandshakeTwoOfTwo) { |
QuicStreamRequest request2(factory_.get()); |
EXPECT_EQ(OK, request2.Request(server2, privacy_mode_, |
/*cert_verify_flags=*/0, server2.host(), "GET", |
- net_log_, callback2.callback())); |
+ net_log_, callback2.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session2 = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), server2); |
@@ -2664,7 +2727,8 @@ TEST_P(QuicStreamFactoryTest, TimeoutsWithOpenStreamsTwoOfTwo) { |
QuicStreamRequest request(factory_.get()); |
EXPECT_EQ(OK, request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), host_port_pair_); |
@@ -2695,7 +2759,8 @@ TEST_P(QuicStreamFactoryTest, TimeoutsWithOpenStreamsTwoOfTwo) { |
QuicStreamRequest request2(factory_.get()); |
EXPECT_EQ(OK, request2.Request(server2, privacy_mode_, |
/*cert_verify_flags=*/0, server2.host(), "GET", |
- net_log_, callback2.callback())); |
+ net_log_, callback2.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session2 = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), server2); |
@@ -2762,7 +2827,8 @@ TEST_P(QuicStreamFactoryTest, PublicResetPostHandshakeTwoOfThree) { |
QuicStreamRequest request(factory_.get()); |
EXPECT_EQ(OK, request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), host_port_pair_); |
@@ -2785,7 +2851,8 @@ TEST_P(QuicStreamFactoryTest, PublicResetPostHandshakeTwoOfThree) { |
QuicStreamRequest request2(factory_.get()); |
EXPECT_EQ(OK, request2.Request(server2, privacy_mode_, |
/*cert_verify_flags=*/0, server2.host(), "GET", |
- net_log_, callback2.callback())); |
+ net_log_, callback2.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session2 = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), server2); |
@@ -2806,7 +2873,8 @@ TEST_P(QuicStreamFactoryTest, PublicResetPostHandshakeTwoOfThree) { |
QuicStreamRequest request3(factory_.get()); |
EXPECT_EQ(OK, request3.Request(server3, privacy_mode_, |
/*cert_verify_flags=*/0, server3.host(), "GET", |
- net_log_, callback3.callback())); |
+ net_log_, callback3.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session3 = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), server3); |
@@ -2880,7 +2948,8 @@ TEST_P(QuicStreamFactoryTest, TimeoutsWithOpenStreamsTwoOfThree) { |
QuicStreamRequest request(factory_.get()); |
EXPECT_EQ(OK, request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), host_port_pair_); |
@@ -2911,7 +2980,8 @@ TEST_P(QuicStreamFactoryTest, TimeoutsWithOpenStreamsTwoOfThree) { |
QuicStreamRequest request2(factory_.get()); |
EXPECT_EQ(OK, request2.Request(server2, privacy_mode_, |
/*cert_verify_flags=*/0, server2.host(), "GET", |
- net_log_, callback2.callback())); |
+ net_log_, callback2.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session2 = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), server2); |
@@ -2933,7 +3003,8 @@ TEST_P(QuicStreamFactoryTest, TimeoutsWithOpenStreamsTwoOfThree) { |
QuicStreamRequest request3(factory_.get()); |
EXPECT_EQ(OK, request3.Request(server3, privacy_mode_, |
/*cert_verify_flags=*/0, server3.host(), "GET", |
- net_log_, callback3.callback())); |
+ net_log_, callback3.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session3 = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), server3); |
@@ -2991,7 +3062,8 @@ TEST_P(QuicStreamFactoryTest, DisableQuicWhenTimeoutsWithOpenStreams) { |
QuicStreamRequest request(factory_.get()); |
EXPECT_EQ(OK, request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), host_port_pair_); |
@@ -3070,7 +3142,8 @@ TEST_P(QuicStreamFactoryTest, PublicResetPostHandshakeTwoOfFour) { |
QuicStreamRequest request(factory_.get()); |
EXPECT_EQ(OK, request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), host_port_pair_); |
@@ -3093,7 +3166,8 @@ TEST_P(QuicStreamFactoryTest, PublicResetPostHandshakeTwoOfFour) { |
QuicStreamRequest request2(factory_.get()); |
EXPECT_EQ(OK, request2.Request(server2, privacy_mode_, |
/*cert_verify_flags=*/0, server2.host(), "GET", |
- net_log_, callback2.callback())); |
+ net_log_, callback2.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session2 = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), server2); |
@@ -3112,7 +3186,8 @@ TEST_P(QuicStreamFactoryTest, PublicResetPostHandshakeTwoOfFour) { |
QuicStreamRequest request3(factory_.get()); |
EXPECT_EQ(OK, request3.Request(server3, privacy_mode_, |
/*cert_verify_flags=*/0, server3.host(), "GET", |
- net_log_, callback3.callback())); |
+ net_log_, callback3.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session3 = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), server3); |
@@ -3133,7 +3208,8 @@ TEST_P(QuicStreamFactoryTest, PublicResetPostHandshakeTwoOfFour) { |
QuicStreamRequest request4(factory_.get()); |
EXPECT_EQ(OK, request4.Request(server4, privacy_mode_, |
/*cert_verify_flags=*/0, server4.host(), "GET", |
- net_log_, callback4.callback())); |
+ net_log_, callback4.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session4 = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), server4); |
@@ -3214,7 +3290,8 @@ TEST_P(QuicStreamFactoryTest, TimeoutsWithOpenStreamsTwoOfFour) { |
QuicStreamRequest request(factory_.get()); |
EXPECT_EQ(OK, request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), host_port_pair_); |
@@ -3244,7 +3321,8 @@ TEST_P(QuicStreamFactoryTest, TimeoutsWithOpenStreamsTwoOfFour) { |
QuicStreamRequest request2(factory_.get()); |
EXPECT_EQ(OK, request2.Request(server2, privacy_mode_, |
/*cert_verify_flags=*/0, server2.host(), "GET", |
- net_log_, callback2.callback())); |
+ net_log_, callback2.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session2 = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), server2); |
@@ -3263,7 +3341,8 @@ TEST_P(QuicStreamFactoryTest, TimeoutsWithOpenStreamsTwoOfFour) { |
QuicStreamRequest request3(factory_.get()); |
EXPECT_EQ(OK, request3.Request(server3, privacy_mode_, |
/*cert_verify_flags=*/0, server3.host(), "GET", |
- net_log_, callback3.callback())); |
+ net_log_, callback3.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session3 = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), server3); |
@@ -3285,7 +3364,8 @@ TEST_P(QuicStreamFactoryTest, TimeoutsWithOpenStreamsTwoOfFour) { |
QuicStreamRequest request4(factory_.get()); |
EXPECT_EQ(OK, request4.Request(server4, privacy_mode_, |
/*cert_verify_flags=*/0, server4.host(), "GET", |
- net_log_, callback4.callback())); |
+ net_log_, callback4.callback(), |
+ /*for_bidirectional=*/false)); |
QuicChromiumClientSession* session4 = |
QuicStreamFactoryPeer::GetActiveSession(factory_.get(), server4); |
@@ -3342,7 +3422,8 @@ TEST_P(QuicStreamFactoryTest, EnableDelayTcpRace) { |
EXPECT_EQ(ERR_IO_PENDING, |
request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "POST", net_log_, callback_.callback())); |
+ "POST", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
// If we don't delay TCP connection, then time delay should be 0. |
EXPECT_FALSE(factory_->delay_tcp_race()); |
@@ -3494,7 +3575,8 @@ TEST_P(QuicStreamFactoryTest, YieldAfterPackets) { |
QuicStreamRequest request(factory_.get()); |
EXPECT_EQ(OK, request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
// Call run_loop so that QuicChromiumPacketReader::OnReadComplete() gets |
// called. |
@@ -3543,7 +3625,8 @@ TEST_P(QuicStreamFactoryTest, YieldAfterDuration) { |
QuicStreamRequest request(factory_.get()); |
EXPECT_EQ(OK, request.Request(host_port_pair_, privacy_mode_, |
/*cert_verify_flags=*/0, host_port_pair_.host(), |
- "GET", net_log_, callback_.callback())); |
+ "GET", net_log_, callback_.callback(), |
+ /*for_bidirectional=*/false)); |
// Call run_loop so that QuicChromiumPacketReader::OnReadComplete() gets |
// called. |