Simplify VideoDecodeEngine interface by making everything synchronous.

content/renderer/media/capture_video_decoder.cc

 // Copyright (c) 2011 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 "content/renderer/media/capture_video_decoder.h"
 
 #include "base/bind.h"
 #include "content/renderer/media/video_capture_impl_manager.h"
 #include "media/base/filter_host.h"
 #include "media/base/limits.h"
@@ skipping 23 matching lines @@
     media::DemuxerStream* demuxer_stream,
     const base::Closure& filter_callback,
     const media::StatisticsCallback& stat_callback) {
   message_loop_proxy_->PostTask(
       FROM_HERE,
       base::Bind(&CaptureVideoDecoder::InitializeOnDecoderThread,
                  this, make_scoped_refptr(demuxer_stream),
                  filter_callback, stat_callback));
 }
 
-void CaptureVideoDecoder::ProduceVideoFrame(
-    scoped_refptr<media::VideoFrame> video_frame) {
+void CaptureVideoDecoder::Read(const FrameReadyCB& callback) {
   message_loop_proxy_->PostTask(
       FROM_HERE,
-      base::Bind(&CaptureVideoDecoder::ProduceVideoFrameOnDecoderThread,
-                 this, video_frame));
+      base::Bind(&CaptureVideoDecoder::ReadOnDecoderThread,
+                 this, callback));
 }
 
 gfx::Size CaptureVideoDecoder::natural_size() {
   return gfx::Size(capability_.width, capability_.height);
 }
 
 void CaptureVideoDecoder::Play(const base::Closure& callback) {
   message_loop_proxy_->PostTask(
       FROM_HERE,
       base::Bind(&CaptureVideoDecoder::PlayOnDecoderThread,
@@ skipping 64 matching lines @@
 
 void CaptureVideoDecoder::InitializeOnDecoderThread(
     media::DemuxerStream* demuxer_stream,
     const base::Closure& filter_callback,
     const media::StatisticsCallback& stat_callback) {
   VLOG(1) << "InitializeOnDecoderThread.";
   DCHECK(message_loop_proxy_->BelongsToCurrentThread());
 
   capture_engine_ = vc_manager_->AddDevice(video_stream_id_, this);
 
-  available_frames_.clear();
-
   statistics_callback_ = stat_callback;
   filter_callback.Run();
   state_ = kNormal;
 }
 
-void CaptureVideoDecoder::ProduceVideoFrameOnDecoderThread(
-    scoped_refptr<media::VideoFrame> video_frame) {
+void CaptureVideoDecoder::ReadOnDecoderThread(const FrameReadyCB& callback) {
   DCHECK(message_loop_proxy_->BelongsToCurrentThread());
-  available_frames_.push_back(video_frame);
+  CHECK(frame_ready_cb_.is_null());
+  frame_ready_cb_ = callback;
 }
 
 void CaptureVideoDecoder::PlayOnDecoderThread(const base::Closure& callback) {
   VLOG(1) << "PlayOnDecoderThread.";
   DCHECK(message_loop_proxy_->BelongsToCurrentThread());
   callback.Run();
 }
 
 void CaptureVideoDecoder::PauseOnDecoderThread(const base::Closure& callback) {
   VLOG(1) << "PauseOnDecoderThread.";
   DCHECK(message_loop_proxy_->BelongsToCurrentThread());
   state_ = kPaused;
   media::VideoDecoder::Pause(callback);
 }
 
 void CaptureVideoDecoder::StopOnDecoderThread(const base::Closure& callback) {
   VLOG(1) << "StopOnDecoderThread.";
   DCHECK(message_loop_proxy_->BelongsToCurrentThread());
   pending_stop_cb_ = callback;
   state_ = kStopped;
   capture_engine_->StopCapture(this);
 }
 
 void CaptureVideoDecoder::SeekOnDecoderThread(base::TimeDelta time,
                                               const media::FilterStatusCB& cb) {
   VLOG(1) << "SeekOnDecoderThread.";
   DCHECK(message_loop_proxy_->BelongsToCurrentThread());
 
-  state_ = kSeeking;
-  // Create output buffer pool and pass the frames to renderer
-  // so that the renderer can complete the seeking
-  for (size_t i = 0; i < media::Limits::kMaxVideoFrames; ++i) {
-    VideoFrameReady(media::VideoFrame::CreateBlackFrame(capability_.width,
-                                                        capability_.height));
-  }
-
-  cb.Run(media::PIPELINE_OK);
   state_ = kNormal;
   capture_engine_->StartCapture(this, capability_);
 }
 
 void CaptureVideoDecoder::OnStoppedOnDecoderThread(
     media::VideoCapture* capture) {
   VLOG(1) << "OnStoppedOnDecoderThread.";
   DCHECK(message_loop_proxy_->BelongsToCurrentThread());
   if (!pending_stop_cb_.is_null())
     media::ResetAndRunCB(&pending_stop_cb_);
   vc_manager_->RemoveDevice(video_stream_id_, this);
 }
 
 void CaptureVideoDecoder::OnBufferReadyOnDecoderThread(
     media::VideoCapture* capture,
     scoped_refptr<media::VideoCapture::VideoFrameBuffer> buf) {
   DCHECK(message_loop_proxy_->BelongsToCurrentThread());
 
-  if (available_frames_.size() == 0 || kNormal != state_) {
+  if (frame_ready_cb_.is_null() || kNormal != state_) {
     capture->FeedBuffer(buf);
     return;
   }
 
-  scoped_refptr<media::VideoFrame> video_frame = available_frames_.front();
-  available_frames_.pop_front();
-
   if (buf->width != capability_.width || buf->height != capability_.height) {
     capability_.width = buf->width;
     capability_.height = buf->height;
     host()->SetNaturalVideoSize(
         gfx::Size(capability_.width, capability_.height));
   }
 
-  // Check if there's a size change.
-  if (static_cast<int>(video_frame->width()) != capability_.width ||
-      static_cast<int>(video_frame->height()) != capability_.height) {
-    // Allocate new buffer based on the new size.
-    video_frame = media::VideoFrame::CreateFrame(media::VideoFrame::YV12,
-                                                 capability_.width,
-                                                 capability_.height,
-                                                 media::kNoTimestamp,
-                                                 media::kNoTimestamp);
-  }
-
-  video_frame->SetTimestamp(buf->timestamp - start_time_);
-  video_frame->SetDuration(base::TimeDelta::FromMilliseconds(33));
+  // Always allocate a new frame.
+  //
+  // TODO(scherkus): migrate this to proper buffer recycling.
+  scoped_refptr<media::VideoFrame> video_frame =
+      media::VideoFrame::CreateFrame(media::VideoFrame::YV12,
+                                     capability_.width,
+                                     capability_.height,
+                                     buf->timestamp - start_time_,
+                                     base::TimeDelta::FromMilliseconds(33));
 
   uint8* buffer = buf->memory_pointer;
 
   // Assume YV12 format.
   // TODO(vrk): This DCHECK fails in content_unittests ... it should not!
   // DCHECK(capability_.raw_type == media::VideoFrame::YV12);
   int y_width = capability_.width;
   int y_height = capability_.height;
   int uv_width = capability_.width / 2;
   int uv_height = capability_.height / 2;  // YV12 format.
   CopyYPlane(buffer, y_width, y_height, video_frame);
   buffer += y_width * y_height;
   CopyUPlane(buffer, uv_width, uv_height, video_frame);
   buffer += uv_width * uv_height;
   CopyVPlane(buffer, uv_width, uv_height, video_frame);
 
-  VideoFrameReady(video_frame);
+  DeliverFrame(video_frame);
   capture->FeedBuffer(buf);
 }
+
+void CaptureVideoDecoder::DeliverFrame(
+    const scoped_refptr<media::VideoFrame>& video_frame) {
+  // Reset the callback before running to protect against reentrancy.
+  FrameReadyCB frame_ready_cb = frame_ready_cb_;
+  frame_ready_cb_.Reset();
+  frame_ready_cb.Run(video_frame);
+}