Throttle media decoding after excessive Android media server crashes

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/android/media_statistics.h"
 #include "media/base/demuxer_stream.h"
 #include "media/base/timestamp_constants.h"
 
 namespace media {
 
 namespace {
 const int kDelayForStandAloneEOS = 2;  // milliseconds
 }
 
 MediaCodecVideoDecoder::MediaCodecVideoDecoder(
     const scoped_refptr<base::SingleThreadTaskRunner>& media_task_runner,
     FrameStatistics* frame_statistics,
     const base::Closure& request_data_cb,
     const base::Closure& starvation_cb,
     const base::Closure& decoder_drained_cb,
     const base::Closure& stop_done_cb,
     const base::Closure& waiting_for_decryption_key_cb,
     const base::Closure& error_cb,
     const SetTimeCallback& update_current_time_cb,
-    const VideoSizeChangedCallback& video_size_changed_cb,
-    const base::Closure& codec_created_cb)
+    const VideoSizeChangedCallback& video_size_changed_cb)
     : MediaCodecDecoder("VideoDecoder",
                         media_task_runner,
                         frame_statistics,
                         request_data_cb,
                         starvation_cb,
                         decoder_drained_cb,
                         stop_done_cb,
                         waiting_for_decryption_key_cb,
                         error_cb),
       is_protected_surface_required_(false),
       update_current_time_cb_(update_current_time_cb),
-      video_size_changed_cb_(video_size_changed_cb),
-      codec_created_cb_(codec_created_cb) {
+      video_size_changed_cb_(video_size_changed_cb) {
 }
 
 MediaCodecVideoDecoder::~MediaCodecVideoDecoder() {
   DCHECK(media_task_runner_->BelongsToCurrentThread());
   DVLOG(1) << "VideoDecoder::~VideoDecoder()";
   ReleaseDecoderResources();
 }
 
 const char* MediaCodecVideoDecoder::class_name() const {
   return "VideoDecoder";
@@ skipping 125 matching lines @@
       media_crypto));
 
   if (!media_codec_bridge_) {
     DVLOG(0) << class_name() << "::" << __FUNCTION__
              << " failed: cannot create video codec";
     return kConfigFailure;
   }
 
   DVLOG(0) << class_name() << "::" << __FUNCTION__ << " succeeded";
 
-  media_task_runner_->PostTask(FROM_HERE, codec_created_cb_);
-
   if (!codec_created_for_tests_cb_.is_null())
     media_task_runner_->PostTask(FROM_HERE, codec_created_for_tests_cb_);
 
   return kConfigOk;
 }
 
 void MediaCodecVideoDecoder::AssociateCurrentTimeWithPTS(base::TimeDelta pts) {
   DCHECK(media_task_runner_->BelongsToCurrentThread());
 
   DVLOG(1) << class_name() << "::" << __FUNCTION__ << " pts:" << pts;
@@ skipping 151 matching lines @@
 
   // |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() && update_time) {
     media_task_runner_->PostTask(
         FROM_HERE, base::Bind(update_current_time_cb_, pts, pts, false));
   }
 }
 
 }  // namespace media