MediaCodecPlayer implementation (stage 5 - reconfiguration)

media/base/android/media_codec_decoder_unittest.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 "base/bind.h"
 #include "base/logging.h"
 #include "base/thread_task_runner_handle.h"
 #include "base/timer/timer.h"
 #include "media/base/android/media_codec_audio_decoder.h"
 #include "media/base/android/media_codec_bridge.h"
@@ skipping 131 matching lines @@
   void CreateAudioDecoder();
   void CreateVideoDecoder();
   void SetVideoSurface();
   void SetStopRequestAtTime(const base::TimeDelta& time) {
     stop_request_time_ = time;
   }
 
   // Decoder callbacks.
   void OnDataRequested();
   void OnStarvation() { is_starved_ = true; }
+  void OnDecoderDrained() {}
   void OnStopDone() { is_stopped_ = true; }
   void OnError() { DVLOG(0) << "MediaCodecDecoderTest::" << __FUNCTION__; }
   void OnUpdateCurrentTime(base::TimeDelta now_playing,
                            base::TimeDelta last_buffered,
                            bool postpone) {
     // Add the |last_buffered| value for PTS. For video it is the same as
     // |now_playing| and is equal to PTS, for audio |last_buffered| should
     // exceed PTS.
     if (postpone)
       return;
 
     pts_stat_.AddValue(last_buffered);
 
     if (stop_request_time_ != kNoTimestamp() &&
         now_playing >= stop_request_time_) {
       stop_request_time_ = kNoTimestamp();
       decoder_->RequestToStop();
     }
   }
 
-  void OnVideoSizeChanged(const gfx::Size& video_size) {}
+  void OnVideoSizeChanged(const gfx::Size& video_size) {
+    video_size_ = video_size;
+  }
+
   void OnVideoCodecCreated() {}
 
   scoped_ptr<MediaCodecDecoder> decoder_;
   scoped_ptr<TestDataFactory> data_factory_;
   Minimax<base::TimeDelta> pts_stat_;
+  gfx::Size video_size_;
 
  private:
   bool is_timeout_expired() const { return is_timeout_expired_; }
   void SetTimeoutExpired(bool value) { is_timeout_expired_ = value; }
 
   base::MessageLoop message_loop_;
   bool is_timeout_expired_;
 
   bool is_prefetched_;
   bool is_stopped_;
@@ skipping 40 matching lines @@
 
   DCHECK(!timer.IsRunning());
   return false;
 }
 
 void MediaCodecDecoderTest::CreateAudioDecoder() {
   decoder_ = scoped_ptr<MediaCodecDecoder>(new MediaCodecAudioDecoder(
       task_runner_, base::Bind(&MediaCodecDecoderTest::OnDataRequested,
                                base::Unretained(this)),
       base::Bind(&MediaCodecDecoderTest::OnStarvation, base::Unretained(this)),
+      base::Bind(&MediaCodecDecoderTest::OnDecoderDrained,
+                 base::Unretained(this)),
       base::Bind(&MediaCodecDecoderTest::OnStopDone, base::Unretained(this)),
       base::Bind(&MediaCodecDecoderTest::OnError, base::Unretained(this)),
       base::Bind(&MediaCodecDecoderTest::OnUpdateCurrentTime,
                  base::Unretained(this))));
 
   data_available_cb_ = base::Bind(&MediaCodecDecoder::OnDemuxerDataAvailable,
                                   base::Unretained(decoder_.get()));
 }
 
 void MediaCodecDecoderTest::CreateVideoDecoder() {
   decoder_ = scoped_ptr<MediaCodecDecoder>(new MediaCodecVideoDecoder(
       task_runner_, base::Bind(&MediaCodecDecoderTest::OnDataRequested,
                                base::Unretained(this)),
       base::Bind(&MediaCodecDecoderTest::OnStarvation, base::Unretained(this)),
+      base::Bind(&MediaCodecDecoderTest::OnDecoderDrained,
+                 base::Unretained(this)),
       base::Bind(&MediaCodecDecoderTest::OnStopDone, base::Unretained(this)),
       base::Bind(&MediaCodecDecoderTest::OnError, base::Unretained(this)),
       base::Bind(&MediaCodecDecoderTest::OnUpdateCurrentTime,
                  base::Unretained(this)),
       base::Bind(&MediaCodecDecoderTest::OnVideoSizeChanged,
                  base::Unretained(this)),
       base::Bind(&MediaCodecDecoderTest::OnVideoCodecCreated,
                  base::Unretained(this))));
 
   data_available_cb_ = base::Bind(&MediaCodecDecoder::OnDemuxerDataAvailable,
@@ skipping 391 matching lines @@
   // After starvation we should be able to stop decoder.
   decoder_->RequestToStop();
 
   EXPECT_TRUE(WaitForCondition(
       base::Bind(&MediaCodecDecoderTest::is_stopped, base::Unretained(this))));
 
   EXPECT_TRUE(decoder_->IsStopped());
   EXPECT_FALSE(decoder_->IsCompleted());
 }
 
+TEST_F(MediaCodecDecoderTest, VideoFirstUnitIsReconfig) {
+  SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE();
+
+  // Test that the kConfigChanged unit that comes before the first data unit
+  // gets processed, i.e. is not lost.
+
+  CreateVideoDecoder();
+
+  base::TimeDelta duration = base::TimeDelta::FromMilliseconds(200);
+  base::TimeDelta timeout = base::TimeDelta::FromMilliseconds(1000);
+  SetDataFactory(scoped_ptr<VideoFactory>(new VideoFactory(duration)));
+
+  // Ask factory to produce initial configuration unit. The configuraton will
+  // be factory.GetConfigs().
+  data_factory_->RequestInitialConfigs();
+
+  // Create am alternative configuration (we just alter video size).
+  DemuxerConfigs alt_configs = data_factory_->GetConfigs();
+  alt_configs.video_size = gfx::Size(100, 100);
+
+  // Pass the alternative configuration to decoder.
+  decoder_->SetDemuxerConfigs(alt_configs);
+
+  // Prefetch.
+  decoder_->Prefetch(base::Bind(&MediaCodecDecoderTest::SetPrefetched,
+                                base::Unretained(this), true));
+
+  EXPECT_TRUE(WaitForCondition(base::Bind(&MediaCodecDecoderTest::is_prefetched,
+                                          base::Unretained(this))));
+
+  // Current implementation reports the new video size after
+  // SetDemuxerConfigs(), verify that it is alt size.
+  EXPECT_EQ(alt_configs.video_size, video_size_);
+
+  SetVideoSurface();
+
+  // Configure.
+  EXPECT_EQ(MediaCodecDecoder::kConfigOk, decoder_->Configure());
+
+  // Start.
+  EXPECT_TRUE(decoder_->Start(base::TimeDelta::FromMilliseconds(0)));
+
+  // Wait for completion.
+  EXPECT_TRUE(WaitForCondition(
+      base::Bind(&MediaCodecDecoderTest::is_stopped, base::Unretained(this)),
+      timeout));
+
+  EXPECT_TRUE(decoder_->IsStopped());
+  EXPECT_TRUE(decoder_->IsCompleted());
+  EXPECT_EQ(data_factory_->last_pts(), pts_stat_.max());
+
+  // Check that the reported video size is the one from the in-stream configs.
+  EXPECT_EQ(data_factory_->GetConfigs().video_size, video_size_);
+}
+
 }  // namespace media