| // Copyright 2013 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 "media/cast/test/fake_task_runner.h" |
| |
| #include "base/time/tick_clock.h" |
| #include "testing/gtest/include/gtest/gtest.h" |
| |
| namespace media { |
| namespace cast { |
| namespace test { |
| |
| FakeTaskRunner::FakeTaskRunner(base::SimpleTestTickClock* clock) |
| : clock_(clock) { |
| } |
| |
| FakeTaskRunner::~FakeTaskRunner() {} |
| |
| bool FakeTaskRunner::PostDelayedTask(const tracked_objects::Location& from_here, |
| const base::Closure& task, |
| base::TimeDelta delay) { |
| EXPECT_GE(delay, base::TimeDelta()); |
| PostedTask posed_task(from_here, task, clock_->NowTicks(), delay, |
| base::TestPendingTask::NESTABLE); |
| |
| tasks_.insert(std::make_pair(posed_task.GetTimeToRun(), posed_task)); |
| return false; |
| } |
| |
| bool FakeTaskRunner::RunsTasksOnCurrentThread() const { |
| return true; |
| } |
| |
| void FakeTaskRunner::RunTasks() { |
| for (;;) { |
| // Run all tasks equal or older than current time. |
| std::multimap<base::TimeTicks, PostedTask>::iterator it = tasks_.begin(); |
| if (it == tasks_.end()) return; // No more tasks. |
| |
| PostedTask task = it->second; |
| if (clock_->NowTicks() < task.GetTimeToRun()) return; |
| |
| tasks_.erase(it); |
| task.task.Run(); |
| } |
| } |
| |
| } // namespace test |
| } // namespace cast |
| } // namespace media |