| Index: base/test/test_mock_time_task_runner.cc
|
| diff --git a/base/test/test_mock_time_task_runner.cc b/base/test/test_mock_time_task_runner.cc
|
| deleted file mode 100644
|
| index 169839124d9e29f7ea60ab4f356020ebcb5fb0f0..0000000000000000000000000000000000000000
|
| --- a/base/test/test_mock_time_task_runner.cc
|
| +++ /dev/null
|
| @@ -1,157 +0,0 @@
|
| -// 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.
|
| -
|
| -#include "base/test/test_mock_time_task_runner.h"
|
| -
|
| -#include "base/logging.h"
|
| -#include "base/memory/ref_counted.h"
|
| -
|
| -namespace base {
|
| -
|
| -namespace {
|
| -
|
| -// TickClock that always returns the then-current mock time of |task_runner| as
|
| -// the current time.
|
| -class MockTickClock : public TickClock {
|
| - public:
|
| - explicit MockTickClock(
|
| - scoped_refptr<const TestMockTimeTaskRunner> task_runner);
|
| - ~MockTickClock() override;
|
| -
|
| - // TickClock:
|
| - TimeTicks NowTicks() override;
|
| -
|
| - private:
|
| - scoped_refptr<const TestMockTimeTaskRunner> task_runner_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(MockTickClock);
|
| -};
|
| -
|
| -MockTickClock::MockTickClock(
|
| - scoped_refptr<const TestMockTimeTaskRunner> task_runner)
|
| - : task_runner_(task_runner) {
|
| -}
|
| -
|
| -MockTickClock::~MockTickClock() {
|
| -}
|
| -
|
| -TimeTicks MockTickClock::NowTicks() {
|
| - return task_runner_->GetCurrentMockTime();
|
| -}
|
| -
|
| -} // namespace
|
| -
|
| -bool TestMockTimeTaskRunner::TemporalOrder::operator()(
|
| - const TestPendingTask& first_task,
|
| - const TestPendingTask& second_task) const {
|
| - return first_task.GetTimeToRun() > second_task.GetTimeToRun();
|
| -}
|
| -
|
| -TestMockTimeTaskRunner::TestMockTimeTaskRunner() {
|
| -}
|
| -
|
| -TestMockTimeTaskRunner::~TestMockTimeTaskRunner() {
|
| -}
|
| -
|
| -void TestMockTimeTaskRunner::FastForwardBy(TimeDelta delta) {
|
| - DCHECK(thread_checker_.CalledOnValidThread());
|
| -
|
| - OnBeforeSelectingTask();
|
| -
|
| - const base::TimeTicks original_now = now_;
|
| - TestPendingTask task_info;
|
| - while (DequeueNextTask(original_now, delta, &task_info)) {
|
| - if (task_info.GetTimeToRun() - now_ > base::TimeDelta()) {
|
| - now_ = task_info.GetTimeToRun();
|
| - OnAfterTimePassed();
|
| - }
|
| -
|
| - task_info.task.Run();
|
| -
|
| - OnAfterTaskRun();
|
| - OnBeforeSelectingTask();
|
| - }
|
| -
|
| - if (!delta.is_max() && now_ - original_now < delta) {
|
| - now_ = original_now + delta;
|
| - OnAfterTimePassed();
|
| - }
|
| -}
|
| -
|
| -void TestMockTimeTaskRunner::RunUntilIdle() {
|
| - FastForwardBy(TimeDelta());
|
| -}
|
| -
|
| -void TestMockTimeTaskRunner::FastForwardUntilNoTasksRemain() {
|
| - FastForwardBy(TimeDelta::Max());
|
| -}
|
| -
|
| -TimeTicks TestMockTimeTaskRunner::GetCurrentMockTime() const {
|
| - DCHECK(thread_checker_.CalledOnValidThread());
|
| - return now_;
|
| -}
|
| -
|
| -scoped_ptr<TickClock> TestMockTimeTaskRunner::GetMockTickClock() const {
|
| - DCHECK(thread_checker_.CalledOnValidThread());
|
| - return make_scoped_ptr(new MockTickClock(this));
|
| -}
|
| -
|
| -bool TestMockTimeTaskRunner::HasPendingTask() const {
|
| - DCHECK(thread_checker_.CalledOnValidThread());
|
| - return !tasks_.empty();
|
| -}
|
| -
|
| -TimeDelta TestMockTimeTaskRunner::NextPendingTaskDelay() const {
|
| - DCHECK(thread_checker_.CalledOnValidThread());
|
| - return tasks_.empty() ? TimeDelta::Max() : tasks_.top().GetTimeToRun() - now_;
|
| -}
|
| -
|
| -bool TestMockTimeTaskRunner::RunsTasksOnCurrentThread() const {
|
| - return thread_checker_.CalledOnValidThread();
|
| -}
|
| -
|
| -bool TestMockTimeTaskRunner::PostDelayedTask(
|
| - const tracked_objects::Location& from_here,
|
| - const Closure& task,
|
| - TimeDelta delay) {
|
| - base::AutoLock scoped_lock(tasks_lock_);
|
| - tasks_.push(
|
| - TestPendingTask(from_here, task, now_, delay, TestPendingTask::NESTABLE));
|
| - return true;
|
| -}
|
| -
|
| -bool TestMockTimeTaskRunner::PostNonNestableDelayedTask(
|
| - const tracked_objects::Location& from_here,
|
| - const Closure& task,
|
| - TimeDelta delay) {
|
| - NOTREACHED();
|
| - return false;
|
| -}
|
| -
|
| -void TestMockTimeTaskRunner::OnBeforeSelectingTask() {
|
| - // Empty default implementation.
|
| -}
|
| -
|
| -void TestMockTimeTaskRunner::OnAfterTimePassed() {
|
| - // Empty default implementation.
|
| -}
|
| -
|
| -void TestMockTimeTaskRunner::OnAfterTaskRun() {
|
| - // Empty default implementation.
|
| -}
|
| -
|
| -bool TestMockTimeTaskRunner::DequeueNextTask(const base::TimeTicks& reference,
|
| - const base::TimeDelta& max_delta,
|
| - TestPendingTask* next_task) {
|
| - base::AutoLock scoped_lock(tasks_lock_);
|
| - if (!tasks_.empty() &&
|
| - (tasks_.top().GetTimeToRun() - reference) <= max_delta) {
|
| - *next_task = tasks_.top();
|
| - tasks_.pop();
|
| - return true;
|
| - }
|
| - return false;
|
| -}
|
| -
|
| -} // namespace base
|
|
|