bin/ledger/callback/synchronous_task_unittest.cc

// Copyright 2017 The Fuchsia 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 "peridot/bin/ledger/callback/synchronous_task.h"

#include <algorithm>

#include "gtest/gtest.h"
#include "lib/fsl/tasks/message_loop.h"
#include "lib/fsl/threading/create_thread.h"

// Disabled as failing on the bots, see LE-335.
TEST(SynchronousTaskTest, DISABLED_RunSynchronouslyOnOtherThread) {
  constexpr size_t nb_values = 1000;
  fxl::RefPtr<fxl::TaskRunner> task_runner;
  std::thread thread = fsl::CreateThread(&task_runner);

  bool values[nb_values];
  std::fill_n(values, nb_values, false);
  for (bool& value : values) {
    task_runner->PostTask([&value] { value = true; });
  }
  bool called = false;
  ASSERT_TRUE(callback::RunSynchronously(task_runner,
                                         [&called] { called = true; },
                                         fxl::TimeDelta::FromSeconds(1)));
  for (bool value : values) {
    EXPECT_TRUE(value);
  }
  EXPECT_TRUE(called);

  task_runner->PostTask([] { fsl::MessageLoop::GetCurrent()->PostQuitTask(); });
  thread.join();
}

TEST(SynchronousTaskTest, RunOnCurrentThreadTimeout) {
  fsl::MessageLoop loop;
  bool called = false;
  EXPECT_FALSE(callback::RunSynchronously(
      loop.task_runner(), [&called] { called = true; },
      fxl::TimeDelta::FromMilliseconds(100)));
  EXPECT_FALSE(called);
}

TEST(SynchronousTaskTest, RunOnDeletedMessageLoop) {
  fxl::RefPtr<fxl::TaskRunner> task_runner;
  {
    fsl::MessageLoop loop;
    task_runner = loop.task_runner();
  }
  bool called = false;
  EXPECT_FALSE(
      callback::RunSynchronously(task_runner, [&called] { called = true; },
                                 fxl::TimeDelta::FromMilliseconds(100)));
  EXPECT_FALSE(called);
}