1 // Copyright 2013 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
5 #include "base/message_loop/message_loop.h"
6 #include "base/run_loop.h"
7 #include "content/renderer/media/webaudiosourceprovider_impl.h"
8 #include "media/audio/audio_parameters.h"
9 #include "media/base/fake_audio_render_callback.h"
10 #include "media/base/mock_audio_renderer_sink.h"
11 #include "testing/gmock/include/gmock/gmock.h"
12 #include "testing/gtest/include/gtest/gtest.h"
13 #include "third_party/WebKit/public/platform/WebAudioSourceProviderClient.h"
18 const float kTestVolume
= 0.25;
21 class WebAudioSourceProviderImplTest
22 : public testing::Test
,
23 public blink::WebAudioSourceProviderClient
{
25 WebAudioSourceProviderImplTest()
26 : params_(media::AudioParameters::AUDIO_PCM_LINEAR
,
27 media::CHANNEL_LAYOUT_STEREO
, 48000, 16, 64),
29 mock_sink_(new media::MockAudioRendererSink()),
30 wasp_impl_(new WebAudioSourceProviderImpl(mock_sink_
)) {
33 virtual ~WebAudioSourceProviderImplTest() {}
35 void CallAllSinkMethodsAndVerify(bool verify
) {
36 testing::InSequence s
;
38 EXPECT_CALL(*mock_sink_
.get(), Start()).Times(verify
);
41 EXPECT_CALL(*mock_sink_
.get(), Play()).Times(verify
);
44 EXPECT_CALL(*mock_sink_
.get(), Pause()).Times(verify
);
47 EXPECT_CALL(*mock_sink_
.get(), SetVolume(kTestVolume
)).Times(verify
);
48 wasp_impl_
->SetVolume(kTestVolume
);
50 EXPECT_CALL(*mock_sink_
.get(), Stop()).Times(verify
);
53 testing::Mock::VerifyAndClear(mock_sink_
.get());
56 void SetClient(blink::WebAudioSourceProviderClient
* client
) {
57 testing::InSequence s
;
60 EXPECT_CALL(*mock_sink_
.get(), Stop());
61 EXPECT_CALL(*this, setFormat(params_
.channels(), params_
.sample_rate()));
63 wasp_impl_
->setClient(client
);
64 base::RunLoop().RunUntilIdle();
66 testing::Mock::VerifyAndClear(mock_sink_
.get());
67 testing::Mock::VerifyAndClear(this);
70 bool CompareBusses(const media::AudioBus
* bus1
, const media::AudioBus
* bus2
) {
71 EXPECT_EQ(bus1
->channels(), bus2
->channels());
72 EXPECT_EQ(bus1
->frames(), bus2
->frames());
73 for (int ch
= 0; ch
< bus1
->channels(); ++ch
) {
74 if (memcmp(bus1
->channel(ch
), bus2
->channel(ch
),
75 sizeof(*bus1
->channel(ch
)) * bus1
->frames()) != 0) {
82 // blink::WebAudioSourceProviderClient implementation.
83 MOCK_METHOD2(setFormat
, void(size_t numberOfChannels
, float sampleRate
));
86 media::AudioParameters params_
;
87 media::FakeAudioRenderCallback fake_callback_
;
88 scoped_refptr
<media::MockAudioRendererSink
> mock_sink_
;
89 scoped_refptr
<WebAudioSourceProviderImpl
> wasp_impl_
;
90 base::MessageLoop message_loop_
;
92 DISALLOW_COPY_AND_ASSIGN(WebAudioSourceProviderImplTest
);
95 TEST_F(WebAudioSourceProviderImplTest
, SetClientBeforeInitialize
) {
96 // setClient() with a NULL client should do nothing if no client is set.
97 wasp_impl_
->setClient(NULL
);
99 EXPECT_CALL(*mock_sink_
.get(), Stop());
100 wasp_impl_
->setClient(this);
101 base::RunLoop().RunUntilIdle();
103 // When Initialize() is called after setClient(), the params should propagate
104 // to the client via setFormat() during the call.
105 EXPECT_CALL(*this, setFormat(params_
.channels(), params_
.sample_rate()));
106 wasp_impl_
->Initialize(params_
, &fake_callback_
);
107 base::RunLoop().RunUntilIdle();
109 // setClient() with the same client should do nothing.
110 wasp_impl_
->setClient(this);
111 base::RunLoop().RunUntilIdle();
114 // Verify AudioRendererSink functionality w/ and w/o a client.
115 TEST_F(WebAudioSourceProviderImplTest
, SinkMethods
) {
116 wasp_impl_
->Initialize(params_
, &fake_callback_
);
117 ASSERT_EQ(mock_sink_
->callback(), &fake_callback_
);
119 // Without a client all WASP calls should fall through to the underlying sink.
120 CallAllSinkMethodsAndVerify(true);
122 // With a client no calls should reach the Stop()'d sink. Also, setClient()
123 // should propagate the params provided during Initialize() at call time.
125 CallAllSinkMethodsAndVerify(false);
127 // Removing the client should cause WASP to revert to the underlying sink.
128 EXPECT_CALL(*mock_sink_
.get(), SetVolume(kTestVolume
));
130 CallAllSinkMethodsAndVerify(true);
133 // Verify underlying sink state is restored after client removal.
134 TEST_F(WebAudioSourceProviderImplTest
, SinkStateRestored
) {
135 wasp_impl_
->Initialize(params_
, &fake_callback_
);
137 // Verify state set before the client is set propagates back afterward.
138 EXPECT_CALL(*mock_sink_
.get(), Start());
142 EXPECT_CALL(*mock_sink_
.get(), SetVolume(1.0));
143 EXPECT_CALL(*mock_sink_
.get(), Start());
146 // Verify state set while the client was attached propagates back afterward.
149 wasp_impl_
->SetVolume(kTestVolume
);
151 EXPECT_CALL(*mock_sink_
.get(), SetVolume(kTestVolume
));
152 EXPECT_CALL(*mock_sink_
.get(), Start());
153 EXPECT_CALL(*mock_sink_
.get(), Play());
157 // Test the AudioRendererSink state machine and its effects on provideInput().
158 TEST_F(WebAudioSourceProviderImplTest
, ProvideInput
) {
159 scoped_ptr
<media::AudioBus
> bus1
= media::AudioBus::Create(params_
);
160 scoped_ptr
<media::AudioBus
> bus2
= media::AudioBus::Create(params_
);
162 // Point the WebVector into memory owned by |bus1|.
163 blink::WebVector
<float*> audio_data(static_cast<size_t>(bus1
->channels()));
164 for (size_t i
= 0; i
< audio_data
.size(); ++i
)
165 audio_data
[i
] = bus1
->channel(i
);
167 // Verify provideInput() works before Initialize() and returns silence.
168 bus1
->channel(0)[0] = 1;
170 wasp_impl_
->provideInput(audio_data
, params_
.frames_per_buffer());
171 ASSERT_TRUE(CompareBusses(bus1
.get(), bus2
.get()));
173 wasp_impl_
->Initialize(params_
, &fake_callback_
);
176 // Verify provideInput() is muted prior to Start() and no calls to the render
177 // callback have occurred.
178 bus1
->channel(0)[0] = 1;
180 wasp_impl_
->provideInput(audio_data
, params_
.frames_per_buffer());
181 ASSERT_TRUE(CompareBusses(bus1
.get(), bus2
.get()));
182 ASSERT_EQ(fake_callback_
.last_audio_delay_milliseconds(), -1);
187 bus1
->channel(0)[0] = 1;
188 wasp_impl_
->provideInput(audio_data
, params_
.frames_per_buffer());
189 ASSERT_TRUE(CompareBusses(bus1
.get(), bus2
.get()));
190 ASSERT_EQ(fake_callback_
.last_audio_delay_milliseconds(), -1);
194 // Now we should get real audio data.
195 wasp_impl_
->provideInput(audio_data
, params_
.frames_per_buffer());
196 ASSERT_FALSE(CompareBusses(bus1
.get(), bus2
.get()));
198 // Ensure volume adjustment is working.
199 fake_callback_
.reset();
200 fake_callback_
.Render(bus2
.get(), 0);
201 bus2
->Scale(kTestVolume
);
203 fake_callback_
.reset();
204 wasp_impl_
->SetVolume(kTestVolume
);
205 wasp_impl_
->provideInput(audio_data
, params_
.frames_per_buffer());
206 ASSERT_TRUE(CompareBusses(bus1
.get(), bus2
.get()));
208 // Pause should return to silence.
210 bus1
->channel(0)[0] = 1;
212 wasp_impl_
->provideInput(audio_data
, params_
.frames_per_buffer());
213 ASSERT_TRUE(CompareBusses(bus1
.get(), bus2
.get()));
215 // Ensure if a renderer properly fill silence for partial Render() calls by
216 // configuring the fake callback to return half the data. After these calls
217 // bus1 is full of junk data, and bus2 is partially filled.
218 wasp_impl_
->SetVolume(1);
219 fake_callback_
.Render(bus1
.get(), 0);
220 fake_callback_
.reset();
221 fake_callback_
.Render(bus2
.get(), 0);
222 bus2
->ZeroFramesPartial(bus2
->frames() / 2,
223 bus2
->frames() - bus2
->frames() / 2);
224 fake_callback_
.reset();
225 fake_callback_
.set_half_fill(true);
228 // Play should return real audio data again, but the last half should be zero.
229 wasp_impl_
->provideInput(audio_data
, params_
.frames_per_buffer());
230 ASSERT_TRUE(CompareBusses(bus1
.get(), bus2
.get()));
232 // Stop() should return silence.
234 bus1
->channel(0)[0] = 1;
236 wasp_impl_
->provideInput(audio_data
, params_
.frames_per_buffer());
237 ASSERT_TRUE(CompareBusses(bus1
.get(), bus2
.get()));
240 } // namespace content