MediaCodecPlayer implementation (stage 4 - preroll)

media/base/android/media_codec_video_decoder.cc

 // 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 "media/base/android/media_codec_video_decoder.h"
 
 #include "base/bind.h"
 #include "base/logging.h"
 #include "media/base/android/media_codec_bridge.h"
 #include "media/base/buffers.h"
@@ skipping 19 matching lines @@
                         starvation_cb,
                         stop_done_cb,
                         error_cb,
                         "VideoDecoder"),
       update_current_time_cb_(update_current_time_cb),
       video_size_changed_cb_(video_size_changed_cb),
       codec_created_cb_(codec_created_cb) {
 }
 
 MediaCodecVideoDecoder::~MediaCodecVideoDecoder() {
+  DCHECK(media_task_runner_->BelongsToCurrentThread());
   DVLOG(1) << "VideoDecoder::~VideoDecoder()";
   ReleaseDecoderResources();
 }
 
 const char* MediaCodecVideoDecoder::class_name() const {
   return "VideoDecoder";
 }
 
 bool MediaCodecVideoDecoder::HasStream() const {
   DCHECK(media_task_runner_->BelongsToCurrentThread());
@@ skipping 10 matching lines @@
 
   if (video_size_.IsEmpty()) {
     video_size_ = configs_.video_size;
     media_task_runner_->PostTask(
         FROM_HERE, base::Bind(video_size_changed_cb_, video_size_));
   }
 }
 
 void MediaCodecVideoDecoder::ReleaseDecoderResources() {
   DCHECK(media_task_runner_->BelongsToCurrentThread());
-
   DVLOG(1) << class_name() << "::" << __FUNCTION__;
 
-  MediaCodecDecoder::ReleaseDecoderResources();
+  DoEmergencyStop();
+
+  ReleaseMediaCodec();
+
   surface_ = gfx::ScopedJavaSurface();
+}
+
+void MediaCodecVideoDecoder::ReleaseMediaCodec() {
+  DCHECK(media_task_runner_->BelongsToCurrentThread());
+
+  MediaCodecDecoder::ReleaseMediaCodec();
   delayed_buffers_.clear();
 }
 
 void MediaCodecVideoDecoder::SetVideoSurface(gfx::ScopedJavaSurface surface) {
   DCHECK(media_task_runner_->BelongsToCurrentThread());
 
   DVLOG(1) << class_name() << "::" << __FUNCTION__
            << (surface.IsEmpty() ? " empty" : " non-empty");
 
   surface_ = surface.Pass();
@@ skipping 68 matching lines @@
     return kConfigFailure;
   }
 
   DVLOG(0) << class_name() << "::" << __FUNCTION__ << " succeeded";
 
   media_task_runner_->PostTask(FROM_HERE, codec_created_cb_);
 
   return kConfigOk;
 }
 
-void MediaCodecVideoDecoder::SynchronizePTSWithTime(
-    base::TimeDelta current_time) {
+void MediaCodecVideoDecoder::AssociateCurrentTimeWithPTS(base::TimeDelta pts) {
   DCHECK(media_task_runner_->BelongsToCurrentThread());
 
+  DVLOG(1) << class_name() << "::" << __FUNCTION__ << " pts:" << pts;
+
   start_time_ticks_ = base::TimeTicks::Now();
-  start_pts_ = current_time;
-  last_seen_pts_ = current_time;
+  start_pts_ = pts;
+  last_seen_pts_ = pts;
+}
+
+void MediaCodecVideoDecoder::DissociatePTSFromTime() {
+  DCHECK(media_task_runner_->BelongsToCurrentThread());
+
+  start_pts_ = last_seen_pts_ = kNoTimestamp();
 }
 
 void MediaCodecVideoDecoder::OnOutputFormatChanged() {
   DCHECK(decoder_thread_.task_runner()->BelongsToCurrentThread());
 
   gfx::Size prev_size = video_size_;
 
   // See b/18224769. The values reported from MediaCodecBridge::GetOutputFormat
   // correspond to the actual video frame size, but this is not necessarily the
   // size that should be output.
   video_size_ = configs_.video_size;
   if (video_size_ != prev_size) {
     media_task_runner_->PostTask(
         FROM_HERE, base::Bind(video_size_changed_cb_, video_size_));
   }
 }
 
 void MediaCodecVideoDecoder::Render(int buffer_index,
                                     size_t offset,
                                     size_t size,
-                                    bool render_output,
+                                    RenderMode render_mode,
                                     base::TimeDelta pts,
                                     bool eos_encountered) {
   DCHECK(decoder_thread_.task_runner()->BelongsToCurrentThread());
 
   DVLOG(2) << class_name() << "::" << __FUNCTION__ << " pts:" << pts
            << " index:" << buffer_index << " size:" << size
-           << (eos_encountered ? " EOS" : "");
+           << (eos_encountered ? " EOS " : " ") << AsString(render_mode);
 
   // Normally EOS comes as a separate access unit that does not have data,
   // the corresponding |size| will be 0.
   if (!size && eos_encountered) {
     // Stand-alone EOS
     // Discard the PTS that comes with it and ensure it is released last.
     pts = last_seen_pts_ +
           base::TimeDelta::FromMilliseconds(kDelayForStandAloneEOS);
   } else {
     // Keep track of last seen PTS
     last_seen_pts_ = pts;
   }
 
-  if (!render_output) {
-    ReleaseOutputBuffer(buffer_index, pts, size, false, eos_encountered);
-    return;
+  // Do not update time for stand-alone EOS.
+  const bool update_time = !(eos_encountered && size == 0u);
+
+  // For video we simplify the preroll operation and render the first frame
+  // after preroll during the preroll phase, i.e. without waiting for audio
+  // stream to finish prerolling.
+  switch (render_mode) {
+    case kRenderSkip:
+      ReleaseOutputBuffer(buffer_index, pts, false, false, eos_encountered);
+      return;
+    case kRenderAfterPreroll:
+      // We get here in the preroll phase. Render now as explained above.
+      // |start_pts_| is not set yet, thus we cannot calculate |time_to_render|.
+      ReleaseOutputBuffer(buffer_index, pts, (size > 0), update_time,
+                          eos_encountered);
+      return;
+    case kRenderNow:
+      break;
   }
 
+  DCHECK_EQ(kRenderNow, render_mode);
+  DCHECK_NE(kNoTimestamp(), start_pts_);  // start_pts_ must be set
+
   base::TimeDelta time_to_render =
       pts - (base::TimeTicks::Now() - start_time_ticks_ + start_pts_);
 
+  DVLOG(2) << class_name() << "::" << __FUNCTION__ << " pts:" << pts
+           << " ticks delta:" << (base::TimeTicks::Now() - start_time_ticks_)
+           << " time_to_render:" << time_to_render;
+
   if (time_to_render < base::TimeDelta()) {
     // Skip late frames
-    ReleaseOutputBuffer(buffer_index, pts, size, false, eos_encountered);
+    ReleaseOutputBuffer(buffer_index, pts, false, update_time, eos_encountered);
     return;
   }
 
   delayed_buffers_.insert(buffer_index);
 
-  bool do_render = size > 0;
+  const bool render = (size > 0);
   decoder_thread_.task_runner()->PostDelayedTask(
       FROM_HERE, base::Bind(&MediaCodecVideoDecoder::ReleaseOutputBuffer,
-                            base::Unretained(this), buffer_index, pts,
-                            size, do_render, eos_encountered),
+                            base::Unretained(this), buffer_index, pts, render,
+                            update_time, eos_encountered),
       time_to_render);
 }
 
 int MediaCodecVideoDecoder::NumDelayedRenderTasks() const {
   DCHECK(decoder_thread_.task_runner()->BelongsToCurrentThread());
 
   return delayed_buffers_.size();
 }
 
-void MediaCodecVideoDecoder::ClearDelayedBuffers(bool release) {
+void MediaCodecVideoDecoder::ReleaseDelayedBuffers() {
   // Media thread
   // Called when there is no decoder thread
-  if (release) {
-    for (int index : delayed_buffers_)
-      media_codec_bridge_->ReleaseOutputBuffer(index, false);
-  }
+  for (int index : delayed_buffers_)
+    media_codec_bridge_->ReleaseOutputBuffer(index, false);
 
   delayed_buffers_.clear();
 }
 
 #ifndef NDEBUG
 void MediaCodecVideoDecoder::VerifyUnitIsKeyFrame(
     const AccessUnit* unit) const {
   // The first video frame in a sequence must be a key frame or stand-alone EOS.
   DCHECK(unit);
   bool stand_alone_eos = unit->is_end_of_stream && unit->data.empty();
   DCHECK(stand_alone_eos || unit->is_key_frame);
 }
 #endif
 
 void MediaCodecVideoDecoder::ReleaseOutputBuffer(int buffer_index,
                                                  base::TimeDelta pts,
-                                                 size_t size,
                                                  bool render,
+                                                 bool update_time,
                                                  bool eos_encountered) {
   DCHECK(decoder_thread_.task_runner()->BelongsToCurrentThread());
 
   DVLOG(2) << class_name() << "::" << __FUNCTION__ << " pts:" << pts;
 
   // Do not render if we are in emergency stop, there might be no surface.
   if (InEmergencyStop())
     render = false;
 
   media_codec_bridge_->ReleaseOutputBuffer(buffer_index, render);
 
   delayed_buffers_.erase(buffer_index);
 
   CheckLastFrame(eos_encountered, !delayed_buffers_.empty());
 
   // |update_current_time_cb_| might be null if there is audio stream.
   // Do not update current time for stand-alone EOS frames.
-  if (!update_current_time_cb_.is_null() && !(eos_encountered && !size)) {
+  if (!update_current_time_cb_.is_null() && update_time) {
     media_task_runner_->PostTask(FROM_HERE,
                                  base::Bind(update_current_time_cb_, pts, pts));
   }
 }
 
 }  // namespace media