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_device.h" | 5 #include "content/renderer/media/audio_device.h" |
6 | 6 |
7 #include "base/debug/trace_event.h" | 7 #include "base/debug/trace_event.h" |
8 #include "base/message_loop.h" | 8 #include "base/message_loop.h" |
9 #include "base/threading/thread_restrictions.h" | 9 #include "base/threading/thread_restrictions.h" |
10 #include "base/time.h" | 10 #include "base/time.h" |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
42 AudioDevice::AudioDevice() | 42 AudioDevice::AudioDevice() |
43 : ScopedLoopObserver(ChildProcess::current()->io_message_loop()), | 43 : ScopedLoopObserver(ChildProcess::current()->io_message_loop()), |
44 callback_(NULL), | 44 callback_(NULL), |
45 volume_(1.0), | 45 volume_(1.0), |
46 stream_id_(0), | 46 stream_id_(0), |
47 play_on_start_(true), | 47 play_on_start_(true), |
48 is_started_(false) { | 48 is_started_(false) { |
49 filter_ = RenderThreadImpl::current()->audio_message_filter(); | 49 filter_ = RenderThreadImpl::current()->audio_message_filter(); |
50 } | 50 } |
51 | 51 |
52 AudioDevice::AudioDevice(size_t buffer_size, | 52 AudioDevice::AudioDevice(const AudioParameters& params, |
53 int channels, | |
54 double sample_rate, | |
55 RenderCallback* callback) | 53 RenderCallback* callback) |
56 : ScopedLoopObserver(ChildProcess::current()->io_message_loop()), | 54 : ScopedLoopObserver(ChildProcess::current()->io_message_loop()), |
57 callback_(NULL), | 55 audio_parameters_(params), |
| 56 callback_(callback), |
58 volume_(1.0), | 57 volume_(1.0), |
59 stream_id_(0), | 58 stream_id_(0), |
60 play_on_start_(true), | 59 play_on_start_(true), |
61 is_started_(false) { | 60 is_started_(false) { |
62 filter_ = RenderThreadImpl::current()->audio_message_filter(); | 61 filter_ = RenderThreadImpl::current()->audio_message_filter(); |
63 Initialize(buffer_size, | |
64 channels, | |
65 sample_rate, | |
66 AudioParameters::AUDIO_PCM_LOW_LATENCY, | |
67 callback); | |
68 } | 62 } |
69 | 63 |
70 void AudioDevice::Initialize(size_t buffer_size, | 64 void AudioDevice::Initialize(const AudioParameters& params, |
71 int channels, | |
72 double sample_rate, | |
73 AudioParameters::Format latency_format, | |
74 RenderCallback* callback) { | 65 RenderCallback* callback) { |
75 CHECK_EQ(0, stream_id_) << | 66 CHECK_EQ(0, stream_id_) << |
76 "AudioDevice::Initialize() must be called before Start()"; | 67 "AudioDevice::Initialize() must be called before Start()"; |
77 | 68 |
78 CHECK(!callback_); // Calling Initialize() twice? | 69 CHECK(!callback_); // Calling Initialize() twice? |
79 | 70 |
80 audio_parameters_.format = latency_format; | 71 audio_parameters_ = params; |
81 audio_parameters_.channels = channels; | |
82 audio_parameters_.sample_rate = static_cast<int>(sample_rate); | |
83 audio_parameters_.bits_per_sample = 16; | |
84 audio_parameters_.samples_per_packet = buffer_size; | |
85 | |
86 callback_ = callback; | 72 callback_ = callback; |
87 } | 73 } |
88 | 74 |
89 AudioDevice::~AudioDevice() { | 75 AudioDevice::~AudioDevice() { |
90 // The current design requires that the user calls Stop() before deleting | 76 // The current design requires that the user calls Stop() before deleting |
91 // this class. | 77 // this class. |
92 CHECK_EQ(0, stream_id_); | 78 CHECK_EQ(0, stream_id_); |
93 } | 79 } |
94 | 80 |
95 void AudioDevice::Start() { | 81 void AudioDevice::Start() { |
(...skipping 117 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
213 callback_->OnRenderError(); | 199 callback_->OnRenderError(); |
214 } | 200 } |
215 } | 201 } |
216 | 202 |
217 void AudioDevice::OnStreamCreated( | 203 void AudioDevice::OnStreamCreated( |
218 base::SharedMemoryHandle handle, | 204 base::SharedMemoryHandle handle, |
219 base::SyncSocket::Handle socket_handle, | 205 base::SyncSocket::Handle socket_handle, |
220 uint32 length) { | 206 uint32 length) { |
221 DCHECK(message_loop()->BelongsToCurrentThread()); | 207 DCHECK(message_loop()->BelongsToCurrentThread()); |
222 DCHECK_GE(length, | 208 DCHECK_GE(length, |
223 audio_parameters_.samples_per_packet * sizeof(int16) * | 209 audio_parameters_.frames_per_buffer() * sizeof(int16) * |
224 audio_parameters_.channels); | 210 audio_parameters_.channels()); |
225 #if defined(OS_WIN) | 211 #if defined(OS_WIN) |
226 DCHECK(handle); | 212 DCHECK(handle); |
227 DCHECK(socket_handle); | 213 DCHECK(socket_handle); |
228 #else | 214 #else |
229 DCHECK_GE(handle.fd, 0); | 215 DCHECK_GE(handle.fd, 0); |
230 DCHECK_GE(socket_handle, 0); | 216 DCHECK_GE(socket_handle, 0); |
231 #endif | 217 #endif |
232 | 218 |
233 base::AutoLock auto_lock(audio_thread_lock_); | 219 base::AutoLock auto_lock(audio_thread_lock_); |
234 | 220 |
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
288 } | 274 } |
289 | 275 |
290 // Convert the number of pending bytes in the render buffer | 276 // Convert the number of pending bytes in the render buffer |
291 // into milliseconds. | 277 // into milliseconds. |
292 int audio_delay_milliseconds = pending_data / bytes_per_ms_; | 278 int audio_delay_milliseconds = pending_data / bytes_per_ms_; |
293 | 279 |
294 TRACE_EVENT0("audio", "AudioDevice::FireRenderCallback"); | 280 TRACE_EVENT0("audio", "AudioDevice::FireRenderCallback"); |
295 | 281 |
296 // Update the audio-delay measurement then ask client to render audio. | 282 // Update the audio-delay measurement then ask client to render audio. |
297 size_t num_frames = render_callback_->Render(audio_data_, | 283 size_t num_frames = render_callback_->Render(audio_data_, |
298 audio_parameters_.samples_per_packet, audio_delay_milliseconds); | 284 audio_parameters_.frames_per_buffer(), audio_delay_milliseconds); |
299 | 285 |
300 // Interleave, scale, and clip to int16. | 286 // Interleave, scale, and clip to int16. |
301 // TODO(crogers): avoid converting to integer here, and pass the data | 287 // TODO(crogers): avoid converting to integer here, and pass the data |
302 // to the browser process as float, so we don't lose precision for | 288 // to the browser process as float, so we don't lose precision for |
303 // audio hardware which has better than 16bit precision. | 289 // audio hardware which has better than 16bit precision. |
304 int16* data = reinterpret_cast<int16*>(shared_memory_.memory()); | 290 int16* data = reinterpret_cast<int16*>(shared_memory_.memory()); |
305 media::InterleaveFloatToInt16(audio_data_, data, | 291 media::InterleaveFloatToInt16(audio_data_, data, |
306 audio_parameters_.samples_per_packet); | 292 audio_parameters_.frames_per_buffer()); |
307 | 293 |
308 // Let the host know we are done. | 294 // Let the host know we are done. |
309 media::SetActualDataSizeInBytes(&shared_memory_, memory_length_, | 295 media::SetActualDataSizeInBytes(&shared_memory_, memory_length_, |
310 num_frames * audio_parameters_.channels * sizeof(data[0])); | 296 num_frames * audio_parameters_.channels() * sizeof(data[0])); |
311 } | 297 } |
OLD | NEW |