Support FileDescriptorWatcher in TaskScheduler.

base/task_scheduler/scheduler_worker_stack_unittest.cc

 // Copyright 2016 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 "base/task_scheduler/scheduler_worker_stack.h"
 
 #include "base/logging.h"
 #include "base/memory/ptr_util.h"
 #include "base/memory/ref_counted.h"
+#include "base/message_loop/message_loop.h"
 #include "base/task_scheduler/scheduler_worker.h"
 #include "base/task_scheduler/sequence.h"
 #include "base/task_scheduler/task_tracker.h"
 #include "base/test/gtest_util.h"
 #include "base/threading/platform_thread.h"
 #include "base/time/time.h"
+#include "build/build_config.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 namespace base {
 namespace internal {
 
 namespace {
 
 class MockSchedulerWorkerDelegate : public SchedulerWorker::Delegate {
  public:
   void OnMainEntry(SchedulerWorker* worker,
@@ skipping 11 matching lines @@
   TimeDelta GetSleepTimeout() override {
     return TimeDelta::Max();
   }
   bool CanDetach(SchedulerWorker* worker) override {
     return false;
   }
 };
 
 class TaskSchedulerWorkerStackTest : public testing::Test {
  protected:
+  TaskSchedulerWorkerStackTest()
+#if defined(OS_POSIX) && !defined(OS_NACL_SFI)
+      : task_tracker_(&watch_file_descriptor_message_loop_)
+#endif
+  {
+  }
+
   void SetUp() override {
     worker_a_ = SchedulerWorker::Create(
         ThreadPriority::NORMAL,
         WrapUnique(new MockSchedulerWorkerDelegate), &task_tracker_,
         SchedulerWorker::InitialState::ALIVE);
     ASSERT_TRUE(worker_a_);
     worker_b_ = SchedulerWorker::Create(
         ThreadPriority::NORMAL,
         WrapUnique(new MockSchedulerWorkerDelegate), &task_tracker_,
         SchedulerWorker::InitialState::ALIVE);
     ASSERT_TRUE(worker_b_);
     worker_c_ = SchedulerWorker::Create(
         ThreadPriority::NORMAL,
         WrapUnique(new MockSchedulerWorkerDelegate), &task_tracker_,
         SchedulerWorker::InitialState::ALIVE);
     ASSERT_TRUE(worker_c_);
   }
 
   void TearDown() override {
     worker_a_->JoinForTesting();
     worker_b_->JoinForTesting();
     worker_c_->JoinForTesting();
   }
 
   std::unique_ptr<SchedulerWorker> worker_a_;
   std::unique_ptr<SchedulerWorker> worker_b_;
   std::unique_ptr<SchedulerWorker> worker_c_;
 
  private:
+#if defined(OS_POSIX) && !defined(OS_NACL_SFI)
+  MessageLoopForIO watch_file_descriptor_message_loop_;
+#endif
   TaskTracker task_tracker_;
+
+  DISALLOW_COPY_AND_ASSIGN(TaskSchedulerWorkerStackTest);
 };
 
 }  // namespace
 
 // Verify that Push() and Pop() add/remove values in FIFO order.
 TEST_F(TaskSchedulerWorkerStackTest, PushPop) {
   SchedulerWorkerStack stack;
   EXPECT_EQ(nullptr, stack.Pop());
 
   EXPECT_TRUE(stack.IsEmpty());
@@ skipping 164 matching lines @@
 
 // Verify that Push() DCHECKs when a value is inserted twice.
 TEST_F(TaskSchedulerWorkerStackTest, PushTwice) {
   SchedulerWorkerStack stack;
   stack.Push(worker_a_.get());
   EXPECT_DCHECK_DEATH({ stack.Push(worker_a_.get()); });
 }
 
 }  // namespace internal
 }  // namespace base