| 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.
|
|
|