Backport some tests in /mojo to SingleThreadTaskEnvironment

These tests were previously migrated from single-threaded MessageLoop to
a multi-threaded TaskEnvironment (then named ScopedTaskEnvironment) as
part of crbug.com/891670.

//base OWNERS decided in retrospect that it was better to keep a
single-threaded option for TaskEnvironment and introduced
SingleThreadTaskEnvironment. This CL retrofits that decision for
/mojo.

This CL is a no-op if it passes CQ.

This CL was uploaded by git cl split.

R=sky@chromium.org

Bug: 891670
Change-Id: If1ba8688539709b8e28ce009e3483a1aac36fc4d
Reviewed-on: https://chromium-review.googlesource.com/c/chromium/src/+/1786977
Auto-Submit: Gabriel Charette <gab@chromium.org>
Reviewed-by: Scott Violet <sky@chromium.org>
Commit-Queue: Scott Violet <sky@chromium.org>
Cr-Commit-Position: refs/heads/master@{#693918}

mojo/core/data_pipe_unittest.cc

@@ -1986,7 +1986,7 @@ DEFINE_TEST_CLIENT_TEST_WITH_PIPE(DataPipeStatusChangeInTransitClient,
   EXPECT_EQ(MOJO_RESULT_OK,
             WaitForSignals(consumers[0], MOJO_HANDLE_SIGNAL_PEER_CLOSED));
 
-  base::test::TaskEnvironment task_environment;
+  base::test::SingleThreadTaskEnvironment task_environment;
 
   // Wait on producer 1 and consumer 1 using SimpleWatchers.
   {

mojo/core/multiprocess_message_pipe_unittest.cc

@@ -1275,7 +1275,7 @@ DEFINE_TEST_CLIENT_TEST_WITH_PIPE(MessagePipeStatusChangeInTransitClient,
   EXPECT_EQ(MOJO_RESULT_OK,
             WaitForSignals(handles[0], MOJO_HANDLE_SIGNAL_PEER_CLOSED));
 
-  base::test::TaskEnvironment task_environment;
+  base::test::SingleThreadTaskEnvironment task_environment;
 
   // Wait on handle 1 using a SimpleWatcher.
   {

mojo/public/cpp/bindings/tests/bind_task_runner_unittest.cc

@@ -197,7 +197,7 @@ class BindTaskRunnerTest : public testing::Test {
     impl_.reset(new ImplType(std::move(receiver), receiver_task_runner_));
   }
 
-  base::test::TaskEnvironment task_environment_;
+  base::test::SingleThreadTaskEnvironment task_environment_;
   scoped_refptr<TestTaskRunner> receiver_task_runner_;
   scoped_refptr<TestTaskRunner> remote_task_runner_;
 
@@ -235,7 +235,7 @@ class AssociatedBindTaskRunnerTest : public testing::Test {
 
   void QuitTaskRunner() { connection_receiver_task_runner_->Quit(); }
 
-  base::test::TaskEnvironment task_environment_;
+  base::test::SingleThreadTaskEnvironment task_environment_;
   scoped_refptr<TestTaskRunner> connection_receiver_task_runner_;
   scoped_refptr<TestTaskRunner> connection_remote_task_runner_;
   scoped_refptr<TestTaskRunner> sender_receiver_task_runner_;

mojo/public/cpp/bindings/tests/bindings_perftest.cc

@@ -93,7 +93,7 @@ class MojoBindingsPerftest : public testing::Test {
   MojoBindingsPerftest() = default;
 
  protected:
-  base::test::TaskEnvironment task_environment_;
+  base::test::SingleThreadTaskEnvironment task_environment_;
 };
 
 TEST_F(MojoBindingsPerftest, InProcessPingPong) {

mojo/public/cpp/bindings/tests/connector_unittest.cc

@@ -109,7 +109,7 @@ class ConnectorTest : public testing::Test {
   ScopedMessagePipeHandle handle1_;
 
  private:
-  base::test::TaskEnvironment task_environment_;
+  base::test::SingleThreadTaskEnvironment task_environment_;
 };
 
 TEST_F(ConnectorTest, Basic) {

mojo/public/cpp/bindings/tests/data_view_unittest.cc

@@ -23,7 +23,7 @@ namespace {
 
 class DataViewTest : public testing::Test {
  private:
-  base::test::TaskEnvironment task_environment_;
+  base::test::SingleThreadTaskEnvironment task_environment_;
 };
 
 struct DataViewHolder {

mojo/public/cpp/bindings/tests/e2e_perftest.cc

@@ -130,7 +130,7 @@ class MojoE2EPerftest : public core::test::MojoTestBase {
   }
 
  protected:
-  base::test::TaskEnvironment task_environment_;
+  base::test::SingleThreadTaskEnvironment task_environment_;
 
  private:
   void RunTests(MojoHandle client_mp, const std::string& test_name) {

mojo/public/cpp/bindings/tests/multiplex_router_unittest.cc

@@ -61,7 +61,7 @@ class MultiplexRouterTest : public testing::Test {
   ScopedInterfaceEndpointHandle endpoint1_;
 
  private:
-  base::test::TaskEnvironment task_environment_;
+  base::test::SingleThreadTaskEnvironment task_environment_;
 };
 
 TEST_F(MultiplexRouterTest, BasicRequestResponse) {

mojo/public/cpp/bindings/tests/pickle_unittest.cc

@@ -191,7 +191,7 @@ class PickleTest : public testing::Test {
   };
 
  private:
-  base::test::TaskEnvironment task_environment_;
+  base::test::SingleThreadTaskEnvironment task_environment_;
   ChromiumPicklePasserImpl chromium_service_;
   ReceiverSet<PicklePasser> chromium_receivers_;
   BlinkPicklePasserImpl blink_service_;

mojo/public/cpp/bindings/tests/receiver_callback_unittest.cc

@@ -109,7 +109,7 @@ class ReceiverCallbackTest : public testing::Test {
   void PumpMessages() { base::RunLoop().RunUntilIdle(); }
 
  private:
-  base::test::TaskEnvironment task_environment_;
+  base::test::SingleThreadTaskEnvironment task_environment_;
 };
 
 // Tests that the Remote and the Receiver can communicate with each other

mojo/public/cpp/bindings/tests/remote_unittest.cc

@@ -502,7 +502,7 @@ class StrongMathCalculatorImpl : public math::Calculator {
 };
 
 TEST(StrongConnectorTest, Math) {
-  base::test::TaskEnvironment task_environment;
+  base::test::SingleThreadTaskEnvironment task_environment;
 
   bool disconnected = false;
   bool destroyed = false;
@@ -578,7 +578,7 @@ class WeakMathCalculatorImpl : public math::Calculator {
 };
 
 TEST(WeakConnectorTest, Math) {
-  base::test::TaskEnvironment task_environment;
+  base::test::SingleThreadTaskEnvironment task_environment;
 
   bool disconnected = false;
   bool destroyed = false;

mojo/public/cpp/bindings/tests/struct_traits_unittest.cc

@@ -188,7 +188,7 @@ class StructTraitsTest : public testing::Test,
     std::move(callback).Run(std::move(u));
   }
 
-  base::test::TaskEnvironment task_environment_;
+  base::test::SingleThreadTaskEnvironment task_environment_;
 
   ChromiumRectServiceImpl chromium_service_;
   ReceiverSet<RectService> chromium_receivers_;

mojo/public/cpp/bindings/tests/union_unittest.cc

@@ -1148,7 +1148,7 @@ class SmallCacheImpl : public SmallCache {
 };
 
 TEST(UnionTest, InterfaceInUnion) {
-  base::test::TaskEnvironment task_environment;
+  base::test::SingleThreadTaskEnvironment task_environment;
   base::RunLoop run_loop;
   SmallCacheImpl impl(run_loop.QuitClosure());
   Remote<SmallCache> remote;
@@ -1164,7 +1164,7 @@ TEST(UnionTest, InterfaceInUnion) {
 }
 
 TEST(UnionTest, InterfaceInUnionFactoryFunction) {
-  base::test::TaskEnvironment task_environment;
+  base::test::SingleThreadTaskEnvironment task_environment;
   base::RunLoop run_loop;
   SmallCacheImpl impl(run_loop.QuitClosure());
   Remote<SmallCache> remote;
@@ -1178,7 +1178,7 @@ TEST(UnionTest, InterfaceInUnionFactoryFunction) {
 }
 
 TEST(UnionTest, InterfaceInUnionSerialization) {
-  base::test::TaskEnvironment task_environment;
+  base::test::SingleThreadTaskEnvironment task_environment;
   base::RunLoop run_loop;
   SmallCacheImpl impl(run_loop.QuitClosure());
   Remote<SmallCache> remote;
@@ -1215,7 +1215,7 @@ class UnionInterfaceImpl : public UnionInterface {
 };
 
 TEST(UnionTest, UnionInInterface) {
-  base::test::TaskEnvironment task_environment;
+  base::test::SingleThreadTaskEnvironment task_environment;
   UnionInterfaceImpl impl;
   Remote<UnionInterface> remote;
   Receiver<UnionInterface> receiver(&impl, remote.BindNewPipeAndPassReceiver());

mojo/public/cpp/bindings/tests/validation_unittest.cc

@@ -220,7 +220,7 @@ class ValidationTest : public testing::Test {
   ValidationTest() {}
 
  protected:
-  base::test::TaskEnvironment task_environment_;
+  base::test::SingleThreadTaskEnvironment task_environment_;
 };
 
 class ValidationIntegrationTest : public ValidationTest {

mojo/public/cpp/bindings/tests/wtf_types_unittest.cc

@@ -59,7 +59,7 @@ class WTFTypesTest : public testing::Test {
   WTFTypesTest() {}
 
  private:
-  base::test::TaskEnvironment task_environment_;
+  base::test::SingleThreadTaskEnvironment task_environment_;
 };
 
 WTF::Vector<WTF::String> ConstructStringArray() {

mojo/public/cpp/system/tests/data_pipe_drainer_unittest.cc

@@ -38,7 +38,7 @@ class DataPipeDrainerTest : public testing::Test,
 
   void OnDataComplete() override { completion_callback_.Run(); }
 
-  base::test::TaskEnvironment task_environment_;
+  base::test::SingleThreadTaskEnvironment task_environment_;
   std::string data_;
   std::unique_ptr<DataPipeDrainer> drainer_;
 

mojo/public/cpp/system/tests/simple_watcher_unittest.cc

@@ -40,7 +40,7 @@ class SimpleWatcherTest : public testing::Test {
   ~SimpleWatcherTest() override {}
 
  private:
-  base::test::TaskEnvironment task_environment_;
+  base::test::SingleThreadTaskEnvironment task_environment_;
 
   DISALLOW_COPY_AND_ASSIGN(SimpleWatcherTest);
 };