| 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 |