Use TaskScheduler instead of WorkerPool in webrtc_video_renderer_adapter.cc.

remoting/protocol/connection_unittest.cc

 // Copyright 2015 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.
 
 #define _USE_MATH_DEFINES // For VC++ to get M_PI. This has to be first.
 
 #include <utility>
 
 #include "base/bind.h"
 #include "base/macros.h"
 #include "base/memory/ptr_util.h"
 #include "base/message_loop/message_loop.h"
 #include "base/run_loop.h"
+#include "base/test/scoped_task_scheduler.h"
 #include "base/threading/thread.h"
 #include "base/threading/thread_checker.h"
 #include "remoting/base/constants.h"
 #include "remoting/proto/audio.pb.h"
 #include "remoting/protocol/audio_source.h"
 #include "remoting/protocol/audio_stream.h"
 #include "remoting/protocol/audio_stub.h"
 #include "remoting/protocol/fake_session.h"
 #include "remoting/protocol/fake_video_renderer.h"
 #include "remoting/protocol/ice_connection_to_client.h"
@@ skipping 227 matching lines @@
 
   base::WeakPtrFactory<FakeAudioPlayer> weak_factory_;
 };
 
 }  // namespace
 
 class ConnectionTest : public testing::Test,
                        public testing::WithParamInterface<bool> {
  public:
   ConnectionTest()
-      : video_encode_thread_("VideoEncode"),
+      : scoped_task_scheduler_(&message_loop_),
+        video_encode_thread_("VideoEncode"),
         audio_encode_thread_("AudioEncode"),
         audio_decode_thread_("AudioDecode") {
     video_encode_thread_.Start();
     audio_encode_thread_.Start();
     audio_decode_thread_.Start();
   }
 
   void DestroyHost() {
     host_connection_.reset();
     run_loop_->Quit();
@@ skipping 150 matching lines @@
     run_loop.Run();
     client_video_renderer_.GetFrameStatsConsumer()->set_on_stats_callback(
         base::Closure());
 
     EXPECT_FALSE(client_video_renderer_.GetFrameStatsConsumer()
                      ->received_stats()
                      .empty());
   }
 
   base::MessageLoopForIO message_loop_;
+  base::test::ScopedTaskScheduler scoped_task_scheduler_;
   std::unique_ptr<base::RunLoop> run_loop_;
 
   MockConnectionToClientEventHandler host_event_handler_;
   MockClipboardStub host_clipboard_stub_;
   MockHostStub host_stub_;
   MockInputStub host_input_stub_;
   std::unique_ptr<ConnectionToClient> host_connection_;
   FakeSession* host_session_;  // Owned by |host_connection_|.
   bool host_connected_ = false;
 
@@ skipping 228 matching lines @@
   auto capturer = base::MakeUnique<TestScreenCapturer>();
   capturer->FailNthFrame(1);
   auto video_stream = host_connection_->StartVideoStream(std::move(capturer));
 
   WaitNextVideoFrame();
   WaitNextVideoFrame();
 }
 
 }  // namespace protocol
 }  // namespace remoting