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 { | 67 class AudioRendererImplTest : public ::testing::Test { |
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 240 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
356 return renderer_->splicer_->HasNextBuffer(); | 358 return renderer_->splicer_->HasNextBuffer(); |
357 } | 359 } |
358 | 360 |
359 base::TimeDelta CurrentMediaTime() { | 361 base::TimeDelta CurrentMediaTime() { |
360 return renderer_->CurrentMediaTime(); | 362 return renderer_->CurrentMediaTime(); |
361 } | 363 } |
362 | 364 |
363 bool ended() const { return ended_; } | 365 bool ended() const { return ended_; } |
364 | 366 |
365 // Fixture members. | 367 // Fixture members. |
| 368 AudioParameters hardware_params_; |
366 base::MessageLoop message_loop_; | 369 base::MessageLoop message_loop_; |
367 std::unique_ptr<AudioRendererImpl> renderer_; | 370 std::unique_ptr<AudioRendererImpl> renderer_; |
368 scoped_refptr<FakeAudioRendererSink> sink_; | 371 scoped_refptr<FakeAudioRendererSink> sink_; |
369 AudioHardwareConfig hardware_config_; | |
370 base::SimpleTestTickClock* tick_clock_; | 372 base::SimpleTestTickClock* tick_clock_; |
371 PipelineStatistics last_statistics_; | 373 PipelineStatistics last_statistics_; |
372 | 374 |
373 private: | 375 private: |
374 void DecodeDecoder(const scoped_refptr<DecoderBuffer>& buffer, | 376 void DecodeDecoder(const scoped_refptr<DecoderBuffer>& buffer, |
375 const AudioDecoder::DecodeCB& decode_cb) { | 377 const AudioDecoder::DecodeCB& decode_cb) { |
376 // TODO(scherkus): Make this a DCHECK after threading semantics are fixed. | 378 // TODO(scherkus): Make this a DCHECK after threading semantics are fixed. |
377 if (base::MessageLoop::current() != &message_loop_) { | 379 if (base::MessageLoop::current() != &message_loop_) { |
378 message_loop_.PostTask(FROM_HERE, base::Bind( | 380 message_loop_.PostTask(FROM_HERE, base::Bind( |
379 &AudioRendererImplTest::DecodeDecoder, | 381 &AudioRendererImplTest::DecodeDecoder, |
(...skipping 334 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
714 timestamp_helper.AddFrames(frames_to_consume.value); | 716 timestamp_helper.AddFrames(frames_to_consume.value); |
715 EXPECT_EQ(timestamp_helper.GetTimestamp(), CurrentMediaTime()); | 717 EXPECT_EQ(timestamp_helper.GetTimestamp(), CurrentMediaTime()); |
716 } | 718 } |
717 | 719 |
718 TEST_F(AudioRendererImplTest, RenderingDelayedForEarlyStartTime) { | 720 TEST_F(AudioRendererImplTest, RenderingDelayedForEarlyStartTime) { |
719 Initialize(); | 721 Initialize(); |
720 | 722 |
721 // Choose a first timestamp a few buffers into the future, which ends halfway | 723 // Choose a first timestamp a few buffers into the future, which ends halfway |
722 // through the desired output buffer; this allows for maximum test coverage. | 724 // through the desired output buffer; this allows for maximum test coverage. |
723 const double kBuffers = 4.5; | 725 const double kBuffers = 4.5; |
724 const base::TimeDelta first_timestamp = base::TimeDelta::FromSecondsD( | 726 const base::TimeDelta first_timestamp = |
725 hardware_config_.GetOutputBufferSize() * kBuffers / | 727 base::TimeDelta::FromSecondsD(hardware_params_.frames_per_buffer() * |
726 hardware_config_.GetOutputSampleRate()); | 728 kBuffers / hardware_params_.sample_rate()); |
727 | 729 |
728 Preroll(base::TimeDelta(), first_timestamp, PIPELINE_OK); | 730 Preroll(base::TimeDelta(), first_timestamp, PIPELINE_OK); |
729 StartTicking(); | 731 StartTicking(); |
730 | 732 |
731 // Verify the first few buffers are silent. | 733 // Verify the first few buffers are silent. |
732 std::unique_ptr<AudioBus> bus = | 734 std::unique_ptr<AudioBus> bus = AudioBus::Create(hardware_params_); |
733 AudioBus::Create(hardware_config_.GetOutputConfig()); | |
734 int frames_read = 0; | 735 int frames_read = 0; |
735 for (int i = 0; i < std::floor(kBuffers); ++i) { | 736 for (int i = 0; i < std::floor(kBuffers); ++i) { |
736 EXPECT_TRUE(sink_->Render(bus.get(), 0, &frames_read)); | 737 EXPECT_TRUE(sink_->Render(bus.get(), 0, &frames_read)); |
737 EXPECT_EQ(frames_read, bus->frames()); | 738 EXPECT_EQ(frames_read, bus->frames()); |
738 for (int j = 0; j < bus->frames(); ++j) | 739 for (int j = 0; j < bus->frames(); ++j) |
739 ASSERT_FLOAT_EQ(0.0f, bus->channel(0)[j]); | 740 ASSERT_FLOAT_EQ(0.0f, bus->channel(0)[j]); |
740 WaitForPendingRead(); | 741 WaitForPendingRead(); |
741 DeliverRemainingAudio(); | 742 DeliverRemainingAudio(); |
742 } | 743 } |
743 | 744 |
(...skipping 203 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
947 // Advance far enough that we shouldn't be clamped to current time (tested | 948 // Advance far enough that we shouldn't be clamped to current time (tested |
948 // already above). | 949 // already above). |
949 tick_clock_->Advance(kOneSecond); | 950 tick_clock_->Advance(kOneSecond); |
950 EXPECT_EQ( | 951 EXPECT_EQ( |
951 current_time + timestamp_helper.GetFrameDuration(frames_to_consume.value), | 952 current_time + timestamp_helper.GetFrameDuration(frames_to_consume.value), |
952 CurrentMediaWallClockTime(&is_time_moving)); | 953 CurrentMediaWallClockTime(&is_time_moving)); |
953 EXPECT_TRUE(is_time_moving); | 954 EXPECT_TRUE(is_time_moving); |
954 } | 955 } |
955 | 956 |
956 } // namespace media | 957 } // namespace media |
OLD | NEW |