Split Closure part of TestPendingTask out of the struct

net/quic/chromium/quic_stream_factory_test.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "net/quic/chromium/quic_stream_factory.h"
 
 #include <memory>
 #include <ostream>
 #include <utility>
 
@@ skipping 4611 matching lines @@
 
   DVLOG(1)
       << "Created 1st session and initialized a stream. Now trigger timeout."
       << "Will disable QUIC.";
   session->connection()->CloseConnection(QUIC_NETWORK_IDLE_TIMEOUT, "test",
                                          ConnectionCloseBehavior::SILENT_CLOSE);
   EXPECT_TRUE(QuicStreamFactoryPeer::IsQuicDisabled(factory_.get()));
 
   ASSERT_EQ(1u, runner_->GetPostedTasks().size());
   ASSERT_EQ(clock_->NowInTicks() + base::TimeDelta::FromMinutes(5),
-            runner_->GetPostedTasks()[0].GetTimeToRun());
+            runner_->GetPostedTasks()[0].first.GetTimeToRun());
   runner_->RunNextTask();
 
   // Need to spin the loop now to ensure that
   // QuicStreamFactory::OnSessionClosed() runs.
   base::RunLoop run_loop;
   run_loop.RunUntilIdle();
 
   EXPECT_FALSE(QuicStreamFactoryPeer::IsQuicDisabled(factory_.get()));
 
   ASSERT_TRUE(runner_->GetPostedTasks().empty());
 
   // Create a new session which will cause a task to be posted to
   // clear the exponential backoff.
   QuicStreamRequest request2(factory_.get());
   EXPECT_EQ(OK, request2.Request(host_port_pair_, privacy_mode_,
                                  /*cert_verify_flags=*/0, url_, "GET", net_log_,
                                  callback_.callback()));
   QuicChromiumClientSession* session2 = GetActiveSession(host_port_pair_);
   std::unique_ptr<QuicHttpStream> stream2 = request2.CreateStream();
   EXPECT_TRUE(stream2.get());
   HttpRequestInfo request_info2;
   EXPECT_EQ(OK, stream2->InitializeStream(&request_info2, DEFAULT_PRIORITY,
                                           net_log_, CompletionCallback()));
 
   // Check that the clear task has been posted.
   ASSERT_EQ(1u, runner_->GetPostedTasks().size());
   ASSERT_EQ(clock_->NowInTicks() + base::TimeDelta::FromMinutes(5),
-            runner_->GetPostedTasks()[0].GetTimeToRun());
+            runner_->GetPostedTasks()[0].first.GetTimeToRun());
 
   session2->connection()->CloseConnection(
       QUIC_NETWORK_IDLE_TIMEOUT, "test", ConnectionCloseBehavior::SILENT_CLOSE);
   EXPECT_TRUE(QuicStreamFactoryPeer::IsQuicDisabled(factory_.get()));
 
   ASSERT_EQ(2u, runner_->GetPostedTasks().size());
   ASSERT_EQ(clock_->NowInTicks() + base::TimeDelta::FromMinutes(10),
-            runner_->GetPostedTasks()[1].GetTimeToRun());
+            runner_->GetPostedTasks()[1].first.GetTimeToRun());
   runner_->RunNextTask();
 
   EXPECT_TRUE(QuicStreamFactoryPeer::IsQuicDisabled(factory_.get()));
 
   EXPECT_TRUE(socket_data.AllReadDataConsumed());
   EXPECT_TRUE(socket_data.AllWriteDataConsumed());
 }
 
 TEST_P(QuicStreamFactoryTest,
        DisableQuicWhenTimeoutsWithOpenStreamsExponentialBackoffReset) {
@@ skipping 43 matching lines @@
 
   DVLOG(1)
       << "Created 1st session and initialized a stream. Now trigger timeout."
       << "Will disable QUIC.";
   session->connection()->CloseConnection(QUIC_NETWORK_IDLE_TIMEOUT, "test",
                                          ConnectionCloseBehavior::SILENT_CLOSE);
   EXPECT_TRUE(QuicStreamFactoryPeer::IsQuicDisabled(factory_.get()));
 
   ASSERT_EQ(1u, runner_->GetPostedTasks().size());
   ASSERT_EQ(clock_->NowInTicks() + base::TimeDelta::FromMinutes(5),
-            runner_->GetPostedTasks()[0].GetTimeToRun());
+            runner_->GetPostedTasks()[0].first.GetTimeToRun());
   runner_->RunNextTask();
 
   // Need to spin the loop now to ensure that
   // QuicStreamFactory::OnSessionClosed() runs.
   base::RunLoop run_loop;
   run_loop.RunUntilIdle();
 
   EXPECT_FALSE(QuicStreamFactoryPeer::IsQuicDisabled(factory_.get()));
 
   ASSERT_TRUE(runner_->GetPostedTasks().empty());
@@ skipping 17 matching lines @@
 
   // QUIC should still be enabled.
   EXPECT_FALSE(QuicStreamFactoryPeer::IsQuicDisabled(factory_.get()));
 
   session2->connection()->CloseConnection(
       QUIC_NETWORK_IDLE_TIMEOUT, "test", ConnectionCloseBehavior::SILENT_CLOSE);
   EXPECT_TRUE(QuicStreamFactoryPeer::IsQuicDisabled(factory_.get()));
 
   ASSERT_EQ(1u, runner_->GetPostedTasks().size());
   ASSERT_EQ(clock_->NowInTicks() + base::TimeDelta::FromMinutes(5),
-            runner_->GetPostedTasks()[0].GetTimeToRun());
+            runner_->GetPostedTasks()[0].first.GetTimeToRun());
   runner_->RunNextTask();
 
   EXPECT_FALSE(QuicStreamFactoryPeer::IsQuicDisabled(factory_.get()));
 
   EXPECT_TRUE(socket_data.AllReadDataConsumed());
   EXPECT_TRUE(socket_data.AllWriteDataConsumed());
 }
 
 TEST_P(QuicStreamFactoryTest, EnableDelayTcpRace) {
   Initialize();
@@ skipping 776 matching lines @@
   // Clear all cached states.
   factory_->ClearCachedStatesInCryptoConfig(
       base::Callback<bool(const GURL&)>());
   EXPECT_TRUE(test_cases[0].state->certs().empty());
   EXPECT_TRUE(test_cases[1].state->certs().empty());
   EXPECT_TRUE(test_cases[2].state->certs().empty());
 }
 
 }  // namespace test
 }  // namespace net