| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "media/renderers/audio_renderer_impl.h" | 5 #include "media/renderers/audio_renderer_impl.h" |
| 6 | 6 |
| 7 #include <memory> | 7 #include <memory> |
| 8 #include <utility> | 8 #include <utility> |
| 9 | 9 |
| 10 #include "base/bind.h" | 10 #include "base/bind.h" |
| 11 #include "base/callback_helpers.h" | 11 #include "base/callback_helpers.h" |
| 12 #include "base/format_macros.h" | 12 #include "base/format_macros.h" |
| 13 #include "base/macros.h" | 13 #include "base/macros.h" |
| 14 #include "base/run_loop.h" | 14 #include "base/run_loop.h" |
| 15 #include "base/strings/stringprintf.h" | 15 #include "base/strings/stringprintf.h" |
| 16 #include "base/test/simple_test_tick_clock.h" | 16 #include "base/test/simple_test_tick_clock.h" |
| 17 #include "media/base/audio_buffer_converter.h" | 17 #include "media/base/audio_buffer_converter.h" |
| 18 #include "media/base/audio_hardware_config.h" | |
| 19 #include "media/base/audio_splicer.h" | 18 #include "media/base/audio_splicer.h" |
| 20 #include "media/base/fake_audio_renderer_sink.h" | 19 #include "media/base/fake_audio_renderer_sink.h" |
| 21 #include "media/base/gmock_callback_support.h" | 20 #include "media/base/gmock_callback_support.h" |
| 22 #include "media/base/media_util.h" | 21 #include "media/base/media_util.h" |
| 23 #include "media/base/mock_filters.h" | 22 #include "media/base/mock_filters.h" |
| 24 #include "media/base/test_helpers.h" | 23 #include "media/base/test_helpers.h" |
| 25 #include "testing/gtest/include/gtest/gtest.h" | 24 #include "testing/gtest/include/gtest/gtest.h" |
| 26 | 25 |
| 27 using ::base::TimeDelta; | 26 using ::base::TimeDelta; |
| 28 using ::testing::_; | 27 using ::testing::_; |
| (...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 62 kOutputSamplesPerSecond; | 61 kOutputSamplesPerSecond; |
| 63 | 62 |
| 64 ACTION_P(EnterPendingDecoderInitStateAction, test) { | 63 ACTION_P(EnterPendingDecoderInitStateAction, test) { |
| 65 test->EnterPendingDecoderInitState(arg2); | 64 test->EnterPendingDecoderInitState(arg2); |
| 66 } | 65 } |
| 67 | 66 |
| 68 class AudioRendererImplTest : public ::testing::Test, public RendererClient { | 67 class AudioRendererImplTest : public ::testing::Test, public RendererClient { |
| 69 public: | 68 public: |
| 70 // Give the decoder some non-garbage media properties. | 69 // Give the decoder some non-garbage media properties. |
| 71 AudioRendererImplTest() | 70 AudioRendererImplTest() |
| 72 : hardware_config_(AudioParameters(), AudioParameters()), | 71 : hardware_params_(AudioParameters::AUDIO_PCM_LOW_LATENCY, |
| 72 kChannelLayout, |
| 73 kOutputSamplesPerSecond, |
| 74 SampleFormatToBytesPerChannel(kSampleFormat) * 8, |
| 75 512), |
| 76 sink_(new FakeAudioRendererSink(hardware_params_)), |
| 73 tick_clock_(new base::SimpleTestTickClock()), | 77 tick_clock_(new base::SimpleTestTickClock()), |
| 74 demuxer_stream_(DemuxerStream::AUDIO), | 78 demuxer_stream_(DemuxerStream::AUDIO), |
| 75 decoder_(new MockAudioDecoder()), | 79 decoder_(new MockAudioDecoder()), |
| 76 ended_(false) { | 80 ended_(false) { |
| 77 AudioDecoderConfig audio_config(kCodec, kSampleFormat, kChannelLayout, | 81 AudioDecoderConfig audio_config(kCodec, kSampleFormat, kChannelLayout, |
| 78 kInputSamplesPerSecond, EmptyExtraData(), | 82 kInputSamplesPerSecond, EmptyExtraData(), |
| 79 Unencrypted()); | 83 Unencrypted()); |
| 80 demuxer_stream_.set_audio_decoder_config(audio_config); | 84 demuxer_stream_.set_audio_decoder_config(audio_config); |
| 81 | 85 |
| 82 // Used to save callbacks and run them at a later time. | 86 // Used to save callbacks and run them at a later time. |
| 83 EXPECT_CALL(*decoder_, Decode(_, _)) | 87 EXPECT_CALL(*decoder_, Decode(_, _)) |
| 84 .WillRepeatedly(Invoke(this, &AudioRendererImplTest::DecodeDecoder)); | 88 .WillRepeatedly(Invoke(this, &AudioRendererImplTest::DecodeDecoder)); |
| 85 EXPECT_CALL(*decoder_, Reset(_)) | 89 EXPECT_CALL(*decoder_, Reset(_)) |
| 86 .WillRepeatedly(Invoke(this, &AudioRendererImplTest::ResetDecoder)); | 90 .WillRepeatedly(Invoke(this, &AudioRendererImplTest::ResetDecoder)); |
| 87 | 91 |
| 88 // Mock out demuxer reads. | 92 // Mock out demuxer reads. |
| 89 EXPECT_CALL(demuxer_stream_, Read(_)).WillRepeatedly( | 93 EXPECT_CALL(demuxer_stream_, Read(_)).WillRepeatedly( |
| 90 RunCallback<0>(DemuxerStream::kOk, | 94 RunCallback<0>(DemuxerStream::kOk, |
| 91 scoped_refptr<DecoderBuffer>(new DecoderBuffer(0)))); | 95 scoped_refptr<DecoderBuffer>(new DecoderBuffer(0)))); |
| 92 EXPECT_CALL(demuxer_stream_, SupportsConfigChanges()) | 96 EXPECT_CALL(demuxer_stream_, SupportsConfigChanges()) |
| 93 .WillRepeatedly(Return(true)); | 97 .WillRepeatedly(Return(true)); |
| 94 AudioParameters out_params(AudioParameters::AUDIO_PCM_LOW_LATENCY, | 98 AudioParameters out_params(AudioParameters::AUDIO_PCM_LOW_LATENCY, |
| 95 kChannelLayout, | 99 kChannelLayout, |
| 96 kOutputSamplesPerSecond, | 100 kOutputSamplesPerSecond, |
| 97 SampleFormatToBytesPerChannel(kSampleFormat) * 8, | 101 SampleFormatToBytesPerChannel(kSampleFormat) * 8, |
| 98 512); | 102 512); |
| 99 hardware_config_.UpdateOutputConfig(out_params); | |
| 100 ScopedVector<AudioDecoder> decoders; | 103 ScopedVector<AudioDecoder> decoders; |
| 101 decoders.push_back(decoder_); | 104 decoders.push_back(decoder_); |
| 102 sink_ = new FakeAudioRendererSink(); | |
| 103 renderer_.reset(new AudioRendererImpl(message_loop_.task_runner(), | 105 renderer_.reset(new AudioRendererImpl(message_loop_.task_runner(), |
| 104 sink_.get(), std::move(decoders), | 106 sink_.get(), std::move(decoders), |
| 105 hardware_config_, new MediaLog())); | 107 new MediaLog())); |
| 106 renderer_->tick_clock_.reset(tick_clock_); | 108 renderer_->tick_clock_.reset(tick_clock_); |
| 107 tick_clock_->Advance(base::TimeDelta::FromSeconds(1)); | 109 tick_clock_->Advance(base::TimeDelta::FromSeconds(1)); |
| 108 } | 110 } |
| 109 | 111 |
| 110 virtual ~AudioRendererImplTest() { | 112 virtual ~AudioRendererImplTest() { |
| 111 SCOPED_TRACE("~AudioRendererImplTest()"); | 113 SCOPED_TRACE("~AudioRendererImplTest()"); |
| 112 } | 114 } |
| 113 | 115 |
| 114 void ExpectUnsupportedAudioDecoder() { | 116 void ExpectUnsupportedAudioDecoder() { |
| 115 EXPECT_CALL(*decoder_, Initialize(_, _, _, _)) | 117 EXPECT_CALL(*decoder_, Initialize(_, _, _, _)) |
| (...skipping 239 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 355 return renderer_->splicer_->HasNextBuffer(); | 357 return renderer_->splicer_->HasNextBuffer(); |
| 356 } | 358 } |
| 357 | 359 |
| 358 base::TimeDelta CurrentMediaTime() { | 360 base::TimeDelta CurrentMediaTime() { |
| 359 return renderer_->CurrentMediaTime(); | 361 return renderer_->CurrentMediaTime(); |
| 360 } | 362 } |
| 361 | 363 |
| 362 bool ended() const { return ended_; } | 364 bool ended() const { return ended_; } |
| 363 | 365 |
| 364 // Fixture members. | 366 // Fixture members. |
| 367 AudioParameters hardware_params_; |
| 365 base::MessageLoop message_loop_; | 368 base::MessageLoop message_loop_; |
| 366 std::unique_ptr<AudioRendererImpl> renderer_; | 369 std::unique_ptr<AudioRendererImpl> renderer_; |
| 367 scoped_refptr<FakeAudioRendererSink> sink_; | 370 scoped_refptr<FakeAudioRendererSink> sink_; |
| 368 AudioHardwareConfig hardware_config_; | |
| 369 base::SimpleTestTickClock* tick_clock_; | 371 base::SimpleTestTickClock* tick_clock_; |
| 370 PipelineStatistics last_statistics_; | 372 PipelineStatistics last_statistics_; |
| 371 | 373 |
| 372 private: | 374 private: |
| 373 void DecodeDecoder(const scoped_refptr<DecoderBuffer>& buffer, | 375 void DecodeDecoder(const scoped_refptr<DecoderBuffer>& buffer, |
| 374 const AudioDecoder::DecodeCB& decode_cb) { | 376 const AudioDecoder::DecodeCB& decode_cb) { |
| 375 // TODO(scherkus): Make this a DCHECK after threading semantics are fixed. | 377 // TODO(scherkus): Make this a DCHECK after threading semantics are fixed. |
| 376 if (base::MessageLoop::current() != &message_loop_) { | 378 if (base::MessageLoop::current() != &message_loop_) { |
| 377 message_loop_.PostTask(FROM_HERE, base::Bind( | 379 message_loop_.PostTask(FROM_HERE, base::Bind( |
| 378 &AudioRendererImplTest::DecodeDecoder, | 380 &AudioRendererImplTest::DecodeDecoder, |
| (...skipping 329 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 708 timestamp_helper.AddFrames(frames_to_consume.value); | 710 timestamp_helper.AddFrames(frames_to_consume.value); |
| 709 EXPECT_EQ(timestamp_helper.GetTimestamp(), CurrentMediaTime()); | 711 EXPECT_EQ(timestamp_helper.GetTimestamp(), CurrentMediaTime()); |
| 710 } | 712 } |
| 711 | 713 |
| 712 TEST_F(AudioRendererImplTest, RenderingDelayedForEarlyStartTime) { | 714 TEST_F(AudioRendererImplTest, RenderingDelayedForEarlyStartTime) { |
| 713 Initialize(); | 715 Initialize(); |
| 714 | 716 |
| 715 // Choose a first timestamp a few buffers into the future, which ends halfway | 717 // Choose a first timestamp a few buffers into the future, which ends halfway |
| 716 // through the desired output buffer; this allows for maximum test coverage. | 718 // through the desired output buffer; this allows for maximum test coverage. |
| 717 const double kBuffers = 4.5; | 719 const double kBuffers = 4.5; |
| 718 const base::TimeDelta first_timestamp = base::TimeDelta::FromSecondsD( | 720 const base::TimeDelta first_timestamp = |
| 719 hardware_config_.GetOutputBufferSize() * kBuffers / | 721 base::TimeDelta::FromSecondsD(hardware_params_.frames_per_buffer() * |
| 720 hardware_config_.GetOutputSampleRate()); | 722 kBuffers / hardware_params_.sample_rate()); |
| 721 | 723 |
| 722 Preroll(base::TimeDelta(), first_timestamp, PIPELINE_OK); | 724 Preroll(base::TimeDelta(), first_timestamp, PIPELINE_OK); |
| 723 StartTicking(); | 725 StartTicking(); |
| 724 | 726 |
| 725 // Verify the first few buffers are silent. | 727 // Verify the first few buffers are silent. |
| 726 std::unique_ptr<AudioBus> bus = | 728 std::unique_ptr<AudioBus> bus = AudioBus::Create(hardware_params_); |
| 727 AudioBus::Create(hardware_config_.GetOutputConfig()); | |
| 728 int frames_read = 0; | 729 int frames_read = 0; |
| 729 for (int i = 0; i < std::floor(kBuffers); ++i) { | 730 for (int i = 0; i < std::floor(kBuffers); ++i) { |
| 730 EXPECT_TRUE(sink_->Render(bus.get(), 0, &frames_read)); | 731 EXPECT_TRUE(sink_->Render(bus.get(), 0, &frames_read)); |
| 731 EXPECT_EQ(frames_read, bus->frames()); | 732 EXPECT_EQ(frames_read, bus->frames()); |
| 732 for (int j = 0; j < bus->frames(); ++j) | 733 for (int j = 0; j < bus->frames(); ++j) |
| 733 ASSERT_FLOAT_EQ(0.0f, bus->channel(0)[j]); | 734 ASSERT_FLOAT_EQ(0.0f, bus->channel(0)[j]); |
| 734 WaitForPendingRead(); | 735 WaitForPendingRead(); |
| 735 DeliverRemainingAudio(); | 736 DeliverRemainingAudio(); |
| 736 } | 737 } |
| 737 | 738 |
| (...skipping 203 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 941 // Advance far enough that we shouldn't be clamped to current time (tested | 942 // Advance far enough that we shouldn't be clamped to current time (tested |
| 942 // already above). | 943 // already above). |
| 943 tick_clock_->Advance(kOneSecond); | 944 tick_clock_->Advance(kOneSecond); |
| 944 EXPECT_EQ( | 945 EXPECT_EQ( |
| 945 current_time + timestamp_helper.GetFrameDuration(frames_to_consume.value), | 946 current_time + timestamp_helper.GetFrameDuration(frames_to_consume.value), |
| 946 CurrentMediaWallClockTime(&is_time_moving)); | 947 CurrentMediaWallClockTime(&is_time_moving)); |
| 947 EXPECT_TRUE(is_time_moving); | 948 EXPECT_TRUE(is_time_moving); |
| 948 } | 949 } |
| 949 | 950 |
| 950 } // namespace media | 951 } // namespace media |
| OLD | NEW |