| 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 2e62d5ead4cef7b83f1d0a0d7321aa6f8d507db6..fdc023b28ac5d8420c165d16d3cc5baf0530cb7b 100644
|
| --- a/net/quic/quic_stream_factory_test.cc
|
| +++ b/net/quic/quic_stream_factory_test.cc
|
| @@ -125,11 +125,6 @@ class QuicStreamFactoryPeer {
|
| factory->task_runner_ = task_runner;
|
| }
|
|
|
| - static void SetLoadServerInfoTimeout(QuicStreamFactory* factory,
|
| - size_t load_server_info_timeout) {
|
| - factory->load_server_info_timeout_ms_ = load_server_info_timeout;
|
| - }
|
| -
|
| static void SetEnableConnectionRacing(QuicStreamFactory* factory,
|
| bool enable_connection_racing) {
|
| factory->enable_connection_racing_ = enable_connection_racing;
|
| @@ -207,9 +202,7 @@ class QuicStreamFactoryTest : public ::testing::TestWithParam<TestParams> {
|
| /*enable_port_selection=*/true,
|
| /*always_require_handshake_confirmation=*/false,
|
| /*disable_connection_pooling=*/false,
|
| - /*load_server_info_timeout=*/0u,
|
| /*load_server_info_timeout_srtt_multiplier=*/0.0f,
|
| - /*enable_truncated_connection_ids=*/true,
|
| /*enable_connection_racing=*/false,
|
| /*enable_non_blocking_io=*/true,
|
| /*disable_disk_cache=*/false,
|
| @@ -1613,62 +1606,11 @@ TEST_P(QuicStreamFactoryTest, CryptoConfigWhenProofIsInvalid) {
|
| }
|
| }
|
|
|
| -TEST_P(QuicStreamFactoryTest, CancelWaitForDataReady) {
|
| - // Don't race quic connections when testing cancel reading of server config
|
| - // from disk cache.
|
| - if (GetParam().enable_connection_racing)
|
| - return;
|
| - factory_.set_quic_server_info_factory(&quic_server_info_factory_);
|
| - QuicStreamFactoryPeer::SetTaskRunner(&factory_, runner_.get());
|
| - const size_t kLoadServerInfoTimeoutMs = 50;
|
| - QuicStreamFactoryPeer::SetLoadServerInfoTimeout(
|
| - &factory_, kLoadServerInfoTimeoutMs);
|
| -
|
| - MockRead reads[] = {
|
| - MockRead(ASYNC, OK, 0) // EOF
|
| - };
|
| - DeterministicSocketData socket_data(reads, arraysize(reads), nullptr, 0);
|
| - socket_factory_.AddSocketDataProvider(&socket_data);
|
| - socket_data.StopAfter(1);
|
| -
|
| - crypto_client_stream_factory_.set_handshake_mode(
|
| - MockCryptoClientStream::ZERO_RTT);
|
| - host_resolver_.set_synchronous_mode(true);
|
| - host_resolver_.rules()->AddIPLiteralRule(host_port_pair_.host(),
|
| - "192.168.0.1", "");
|
| -
|
| - QuicStreamRequest request(&factory_);
|
| - EXPECT_EQ(ERR_IO_PENDING,
|
| - request.Request(host_port_pair_,
|
| - is_https_,
|
| - privacy_mode_,
|
| - "GET",
|
| - net_log_,
|
| - callback_.callback()));
|
| -
|
| - // Verify that the CancelWaitForDataReady task has been posted.
|
| - ASSERT_EQ(1u, runner_->GetPostedTasks().size());
|
| - EXPECT_EQ(base::TimeDelta::FromMilliseconds(kLoadServerInfoTimeoutMs),
|
| - runner_->GetPostedTasks()[0].delay);
|
| -
|
| - runner_->RunNextTask();
|
| - ASSERT_EQ(0u, runner_->GetPostedTasks().size());
|
| -
|
| - scoped_ptr<QuicHttpStream> stream = request.ReleaseStream();
|
| - EXPECT_TRUE(stream.get());
|
| - EXPECT_TRUE(socket_data.at_read_eof());
|
| - EXPECT_TRUE(socket_data.at_write_eof());
|
| -}
|
| -
|
| TEST_P(QuicStreamFactoryTest, RacingConnections) {
|
| if (!GetParam().enable_connection_racing)
|
| return;
|
| factory_.set_quic_server_info_factory(&quic_server_info_factory_);
|
| QuicStreamFactoryPeer::SetTaskRunner(&factory_, runner_.get());
|
| - const size_t kLoadServerInfoTimeoutMs = 50;
|
| - QuicStreamFactoryPeer::SetLoadServerInfoTimeout(&factory_,
|
| - kLoadServerInfoTimeoutMs);
|
| -
|
| MockRead reads[] = {
|
| MockRead(ASYNC, OK, 0) // EOF
|
| };
|
| @@ -1710,9 +1652,6 @@ TEST_P(QuicStreamFactoryTest, RacingConnections) {
|
| TEST_P(QuicStreamFactoryTest, EnableNotLoadFromDiskCache) {
|
| factory_.set_quic_server_info_factory(&quic_server_info_factory_);
|
| QuicStreamFactoryPeer::SetTaskRunner(&factory_, runner_.get());
|
| - const size_t kLoadServerInfoTimeoutMs = 50;
|
| - QuicStreamFactoryPeer::SetLoadServerInfoTimeout(&factory_,
|
| - kLoadServerInfoTimeoutMs);
|
| QuicStreamFactoryPeer::SetDisableDiskCache(&factory_, true);
|
|
|
| MockRead reads[] = {
|
|
|