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 "content/renderer/media/audio_renderer_mixer_manager.h" | 5 #include "content/renderer/media/audio_renderer_mixer_manager.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/bind_helpers.h" | 8 #include "base/bind_helpers.h" |
9 #include "content/renderer/media/audio_device_factory.h" | 9 #include "content/renderer/media/audio_message_filter.h" |
| 10 #include "content/renderer/render_thread_impl.h" |
| 11 #include "media/audio/audio_output_device.h" |
10 #include "media/base/audio_renderer_mixer.h" | 12 #include "media/base/audio_renderer_mixer.h" |
11 #include "media/base/audio_renderer_mixer_input.h" | 13 #include "media/base/audio_renderer_mixer_input.h" |
12 | 14 |
13 namespace content { | 15 namespace content { |
14 | 16 |
15 AudioRendererMixerManager::AudioRendererMixerManager(int hardware_sample_rate, | 17 AudioRendererMixerManager::AudioRendererMixerManager(int hardware_sample_rate, |
16 int hardware_buffer_size) | 18 int hardware_buffer_size) |
17 : hardware_sample_rate_(hardware_sample_rate), | 19 : hardware_sample_rate_(hardware_sample_rate), |
18 hardware_buffer_size_(hardware_buffer_size) { | 20 hardware_buffer_size_(hardware_buffer_size), |
| 21 sink_for_testing_(NULL) { |
19 } | 22 } |
20 | 23 |
21 AudioRendererMixerManager::~AudioRendererMixerManager() { | 24 AudioRendererMixerManager::~AudioRendererMixerManager() { |
22 DCHECK(mixers_.empty()); | 25 DCHECK(mixers_.empty()); |
23 } | 26 } |
24 | 27 |
25 media::AudioRendererMixerInput* AudioRendererMixerManager::CreateInput() { | 28 media::AudioRendererMixerInput* AudioRendererMixerManager::CreateInput() { |
26 return new media::AudioRendererMixerInput( | 29 return new media::AudioRendererMixerInput( |
27 base::Bind( | 30 base::Bind( |
28 &AudioRendererMixerManager::GetMixer, base::Unretained(this)), | 31 &AudioRendererMixerManager::GetMixer, base::Unretained(this)), |
29 base::Bind( | 32 base::Bind( |
30 &AudioRendererMixerManager::RemoveMixer, base::Unretained(this))); | 33 &AudioRendererMixerManager::RemoveMixer, base::Unretained(this))); |
31 } | 34 } |
32 | 35 |
| 36 void AudioRendererMixerManager::SetAudioRendererSinkForTesting( |
| 37 media::AudioRendererSink* sink) { |
| 38 sink_for_testing_ = sink; |
| 39 } |
| 40 |
33 media::AudioRendererMixer* AudioRendererMixerManager::GetMixer( | 41 media::AudioRendererMixer* AudioRendererMixerManager::GetMixer( |
34 const media::AudioParameters& params) { | 42 const media::AudioParameters& params) { |
35 base::AutoLock auto_lock(mixers_lock_); | 43 base::AutoLock auto_lock(mixers_lock_); |
36 | 44 |
37 AudioRendererMixerMap::iterator it = mixers_.find(params); | 45 AudioRendererMixerMap::iterator it = mixers_.find(params); |
38 if (it != mixers_.end()) { | 46 if (it != mixers_.end()) { |
39 it->second.ref_count++; | 47 it->second.ref_count++; |
40 return it->second.mixer; | 48 return it->second.mixer; |
41 } | 49 } |
42 | 50 |
43 // Create output parameters based on the audio hardware configuration for | 51 // Create output parameters based on the audio hardware configuration for |
44 // passing on to the output sink. Force to 16-bit output for now since we | 52 // passing on to the output sink. Force to 16-bit output for now since we |
45 // know that works well for WebAudio and WebRTC. | 53 // know that works well for WebAudio and WebRTC. |
46 media::AudioParameters output_params( | 54 media::AudioParameters output_params( |
47 media::AudioParameters::AUDIO_PCM_LOW_LATENCY, params.channel_layout(), | 55 media::AudioParameters::AUDIO_PCM_LOW_LATENCY, params.channel_layout(), |
48 hardware_sample_rate_, 16, hardware_buffer_size_); | 56 hardware_sample_rate_, 16, hardware_buffer_size_); |
49 | 57 |
50 // If we've created invalid output parameters, simply pass on the input params | 58 // If we've created invalid output parameters, simply pass on the input params |
51 // and let the browser side handle automatic fallback. | 59 // and let the browser side handle automatic fallback. |
52 if (!output_params.IsValid()) | 60 if (!output_params.IsValid()) |
53 output_params = params; | 61 output_params = params; |
54 | 62 |
55 media::AudioRendererMixer* mixer = new media::AudioRendererMixer( | 63 media::AudioRendererMixer* mixer = new media::AudioRendererMixer( |
56 params, output_params, AudioDeviceFactory::NewOutputDevice()); | 64 params, output_params, |
| 65 sink_for_testing_ ? |
| 66 sink_for_testing_ : |
| 67 new media::AudioOutputDevice( |
| 68 RenderThreadImpl::current()->audio_message_filter(), |
| 69 RenderThreadImpl::current()->GetIOMessageLoopProxy())); |
57 | 70 |
58 AudioRendererMixerReference mixer_reference = { mixer, 1 }; | 71 AudioRendererMixerReference mixer_reference = { mixer, 1 }; |
59 mixers_[params] = mixer_reference; | 72 mixers_[params] = mixer_reference; |
60 return mixer; | 73 return mixer; |
61 } | 74 } |
62 | 75 |
63 void AudioRendererMixerManager::RemoveMixer( | 76 void AudioRendererMixerManager::RemoveMixer( |
64 const media::AudioParameters& params) { | 77 const media::AudioParameters& params) { |
65 base::AutoLock auto_lock(mixers_lock_); | 78 base::AutoLock auto_lock(mixers_lock_); |
66 | 79 |
67 AudioRendererMixerMap::iterator it = mixers_.find(params); | 80 AudioRendererMixerMap::iterator it = mixers_.find(params); |
68 DCHECK(it != mixers_.end()); | 81 DCHECK(it != mixers_.end()); |
69 | 82 |
70 // Only remove the mixer if AudioRendererMixerManager is the last owner. | 83 // Only remove the mixer if AudioRendererMixerManager is the last owner. |
71 it->second.ref_count--; | 84 it->second.ref_count--; |
72 if (it->second.ref_count == 0) { | 85 if (it->second.ref_count == 0) { |
73 delete it->second.mixer; | 86 delete it->second.mixer; |
74 mixers_.erase(it); | 87 mixers_.erase(it); |
75 } | 88 } |
76 } | 89 } |
77 | 90 |
78 } // namespace content | 91 } // namespace content |
OLD | NEW |