Introduce VideoFrameScheduler{Impl}.

media/filters/video_frame_scheduler_impl.cc

Index: media/filters/video_frame_scheduler_impl.cc
diff --git a/media/filters/video_frame_scheduler_impl.cc b/media/filters/video_frame_scheduler_impl.cc
new file mode 100644
index 0000000000000000000000000000000000000000..a50516446afeb7a7cc57e6f3ed7ac4bab1662906
--- /dev/null
+++ b/media/filters/video_frame_scheduler_impl.cc
@@ -0,0 +1,108 @@
+// Copyright 2014 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/filters/video_frame_scheduler_impl.h"
+
+#include <list>
+
+#include "base/single_thread_task_runner.h"
+#include "base/time/default_tick_clock.h"
+#include "media/base/video_frame.h"
+
+namespace media {
+
+VideoFrameSchedulerImpl::VideoFrameSchedulerImpl(
+    const scoped_refptr<base::SingleThreadTaskRunner>& task_runner,
+    const DisplayCB& display_cb)
+    : task_runner_(task_runner),
+      display_cb_(display_cb),
+      tick_clock_(new base::DefaultTickClock()) {
+}
+
+VideoFrameSchedulerImpl::~VideoFrameSchedulerImpl() {
+}
+
+void VideoFrameSchedulerImpl::ScheduleVideoFrame(
+    const scoped_refptr<VideoFrame>& frame,
+    base::TimeTicks wall_ticks,
+    const DoneCB& done_cb) {
+  DCHECK(task_runner_->BelongsToCurrentThread());
+  DCHECK(!frame->end_of_stream());
+  pending_frames_.push(PendingFrame(frame, wall_ticks, done_cb));
+  ResetTimerIfNecessary();
+}
+
+void VideoFrameSchedulerImpl::Reset() {
+  DCHECK(task_runner_->BelongsToCurrentThread());
+  while (!pending_frames_.empty()) {
+    pending_frames_.top().done_cb.Run(pending_frames_.top().frame, RESET);
+    pending_frames_.pop();
+  }
+}
+
+void VideoFrameSchedulerImpl::SetTickClockForTesting(
+    scoped_ptr<base::TickClock> tick_clock) {
+  tick_clock_.swap(tick_clock);
+}
+
+void VideoFrameSchedulerImpl::ResetTimerIfNecessary() {
+  if (pending_frames_.empty()) {
+    DCHECK(!timer_.IsRunning());
+    return;
+  }
+
+  // Negative times will schedule the callback to run immediately.
+  timer_.Stop();
+  timer_.Start(FROM_HERE,
+               pending_frames_.top().wall_ticks - tick_clock_->NowTicks(),
+               base::Bind(&VideoFrameSchedulerImpl::OnTimerFired,
+                          base::Unretained(this)));
+}
+
+void VideoFrameSchedulerImpl::OnTimerFired() {
+  base::TimeTicks now = tick_clock_->NowTicks();
+
+  // Move all frames that have reached their deadline into a separate queue.
+  std::list<PendingFrame> expired_frames;
+  while (!pending_frames_.empty() && pending_frames_.top().wall_ticks <= now) {
+    expired_frames.push_back(pending_frames_.top());
+    pending_frames_.pop();
+  }
+
+  // Signal that all frames except for the last one as dropped.
+  while (expired_frames.size() > 1) {
+    expired_frames.front().done_cb.Run(expired_frames.front().frame, DROPPED);
+    expired_frames.pop_front();
+  }
+
+  // Display the last expired frame.
+  if (!expired_frames.empty()) {
+    display_cb_.Run(expired_frames.front().frame);
+    expired_frames.front().done_cb.Run(expired_frames.front().frame, DISPLAYED);
+    expired_frames.pop_front();
+  }
+
+  ResetTimerIfNecessary();
+}
+
+VideoFrameSchedulerImpl::PendingFrame::PendingFrame(
+    const scoped_refptr<VideoFrame>& frame,
+    base::TimeTicks wall_ticks,
+    const DoneCB& done_cb)
+    : frame(frame), wall_ticks(wall_ticks), done_cb(done_cb) {
+}
+
+VideoFrameSchedulerImpl::PendingFrame::~PendingFrame() {
+}
+
+bool VideoFrameSchedulerImpl::PendingFrame::operator<(
+    const PendingFrame& other) const {
+  // Flip the comparison as std::priority_queue<T>::top() returns the largest
+  // element.
+  //
+  // Assume video frames with identical timestamps contain identical content.
+  return wall_ticks > other.wall_ticks;
+}
+
+}  // namespace media