| 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/audio/audio_output_controller.h" | 5 #include "media/audio/audio_output_controller.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/debug/trace_event.h" | 8 #include "base/debug/trace_event.h" |
| 9 #include "base/metrics/histogram.h" | 9 #include "base/metrics/histogram.h" |
| 10 #include "base/task_runner_util.h" | 10 #include "base/task_runner_util.h" |
| (...skipping 23 matching lines...) Expand all Loading... |
| 34 const std::string& output_device_id, | 34 const std::string& output_device_id, |
| 35 SyncReader* sync_reader) | 35 SyncReader* sync_reader) |
| 36 : audio_manager_(audio_manager), | 36 : audio_manager_(audio_manager), |
| 37 params_(params), | 37 params_(params), |
| 38 handler_(handler), | 38 handler_(handler), |
| 39 output_device_id_(output_device_id), | 39 output_device_id_(output_device_id), |
| 40 stream_(NULL), | 40 stream_(NULL), |
| 41 diverting_to_stream_(NULL), | 41 diverting_to_stream_(NULL), |
| 42 volume_(1.0), | 42 volume_(1.0), |
| 43 state_(kEmpty), | 43 state_(kEmpty), |
| 44 not_currently_in_on_more_io_data_(1), | |
| 45 sync_reader_(sync_reader), | 44 sync_reader_(sync_reader), |
| 46 message_loop_(audio_manager->GetTaskRunner()), | 45 message_loop_(audio_manager->GetTaskRunner()), |
| 47 #if defined(AUDIO_POWER_MONITORING) | 46 #if defined(AUDIO_POWER_MONITORING) |
| 48 power_monitor_( | 47 power_monitor_( |
| 49 params.sample_rate(), | 48 params.sample_rate(), |
| 50 TimeDelta::FromMilliseconds(kPowerMeasurementTimeConstantMillis)), | 49 TimeDelta::FromMilliseconds(kPowerMeasurementTimeConstantMillis)), |
| 51 #endif | 50 #endif |
| 52 on_more_io_data_called_(0) { | 51 on_more_io_data_called_(0) { |
| 53 DCHECK(audio_manager); | 52 DCHECK(audio_manager); |
| 54 DCHECK(handler_); | 53 DCHECK(handler_); |
| 55 DCHECK(sync_reader_); | 54 DCHECK(sync_reader_); |
| 56 DCHECK(message_loop_.get()); | 55 DCHECK(message_loop_.get()); |
| 57 } | 56 } |
| 58 | 57 |
| 59 AudioOutputController::~AudioOutputController() { | 58 AudioOutputController::~AudioOutputController() { |
| 60 DCHECK_EQ(kClosed, state_); | 59 DCHECK_EQ(kClosed, state_); |
| 61 // TODO(dalecurtis): Remove debugging for http://crbug.com/349651 | |
| 62 CHECK(!base::AtomicRefCountDec(¬_currently_in_on_more_io_data_)); | |
| 63 } | 60 } |
| 64 | 61 |
| 65 // static | 62 // static |
| 66 scoped_refptr<AudioOutputController> AudioOutputController::Create( | 63 scoped_refptr<AudioOutputController> AudioOutputController::Create( |
| 67 AudioManager* audio_manager, | 64 AudioManager* audio_manager, |
| 68 EventHandler* event_handler, | 65 EventHandler* event_handler, |
| 69 const AudioParameters& params, | 66 const AudioParameters& params, |
| 70 const std::string& output_device_id, | 67 const std::string& output_device_id, |
| 71 SyncReader* sync_reader) { | 68 SyncReader* sync_reader) { |
| 72 DCHECK(audio_manager); | 69 DCHECK(audio_manager); |
| (...skipping 224 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 297 } | 294 } |
| 298 | 295 |
| 299 int AudioOutputController::OnMoreData(AudioBus* dest, | 296 int AudioOutputController::OnMoreData(AudioBus* dest, |
| 300 AudioBuffersState buffers_state) { | 297 AudioBuffersState buffers_state) { |
| 301 return OnMoreIOData(NULL, dest, buffers_state); | 298 return OnMoreIOData(NULL, dest, buffers_state); |
| 302 } | 299 } |
| 303 | 300 |
| 304 int AudioOutputController::OnMoreIOData(AudioBus* source, | 301 int AudioOutputController::OnMoreIOData(AudioBus* source, |
| 305 AudioBus* dest, | 302 AudioBus* dest, |
| 306 AudioBuffersState buffers_state) { | 303 AudioBuffersState buffers_state) { |
| 307 CHECK(!base::AtomicRefCountDec(¬_currently_in_on_more_io_data_)); | |
| 308 TRACE_EVENT0("audio", "AudioOutputController::OnMoreIOData"); | 304 TRACE_EVENT0("audio", "AudioOutputController::OnMoreIOData"); |
| 309 | 305 |
| 310 // Indicate that we haven't wedged (at least not indefinitely, WedgeCheck() | 306 // Indicate that we haven't wedged (at least not indefinitely, WedgeCheck() |
| 311 // may have already fired if OnMoreIOData() took an abnormal amount of time). | 307 // may have already fired if OnMoreIOData() took an abnormal amount of time). |
| 312 // Since this thread is the only writer of |on_more_io_data_called_| once the | 308 // Since this thread is the only writer of |on_more_io_data_called_| once the |
| 313 // thread starts, its safe to compare and then increment. | 309 // thread starts, its safe to compare and then increment. |
| 314 if (base::AtomicRefCountIsZero(&on_more_io_data_called_)) | 310 if (base::AtomicRefCountIsZero(&on_more_io_data_called_)) |
| 315 base::AtomicRefCountInc(&on_more_io_data_called_); | 311 base::AtomicRefCountInc(&on_more_io_data_called_); |
| 316 | 312 |
| 317 sync_reader_->Read(source, dest); | 313 sync_reader_->Read(source, dest); |
| 318 | 314 |
| 319 const int frames = dest->frames(); | 315 const int frames = dest->frames(); |
| 320 sync_reader_->UpdatePendingBytes( | 316 sync_reader_->UpdatePendingBytes( |
| 321 buffers_state.total_bytes() + frames * params_.GetBytesPerFrame()); | 317 buffers_state.total_bytes() + frames * params_.GetBytesPerFrame()); |
| 322 | 318 |
| 323 #if defined(AUDIO_POWER_MONITORING) | 319 #if defined(AUDIO_POWER_MONITORING) |
| 324 power_monitor_.Scan(*dest, frames); | 320 power_monitor_.Scan(*dest, frames); |
| 325 #endif | 321 #endif |
| 326 | 322 |
| 327 base::AtomicRefCountInc(¬_currently_in_on_more_io_data_); | |
| 328 return frames; | 323 return frames; |
| 329 } | 324 } |
| 330 | 325 |
| 331 void AudioOutputController::OnError(AudioOutputStream* stream) { | 326 void AudioOutputController::OnError(AudioOutputStream* stream) { |
| 332 // Handle error on the audio controller thread. | 327 // Handle error on the audio controller thread. |
| 333 message_loop_->PostTask(FROM_HERE, base::Bind( | 328 message_loop_->PostTask(FROM_HERE, base::Bind( |
| 334 &AudioOutputController::DoReportError, this)); | 329 &AudioOutputController::DoReportError, this)); |
| 335 } | 330 } |
| 336 | 331 |
| 337 void AudioOutputController::DoStopCloseAndClearStream() { | 332 void AudioOutputController::DoStopCloseAndClearStream() { |
| (...skipping 108 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 446 UMA_HISTOGRAM_BOOLEAN( | 441 UMA_HISTOGRAM_BOOLEAN( |
| 447 "Media.AudioOutputControllerPlaybackStartupSuccess", playback_success); | 442 "Media.AudioOutputControllerPlaybackStartupSuccess", playback_success); |
| 448 | 443 |
| 449 // Let the AudioManager try and fix it. | 444 // Let the AudioManager try and fix it. |
| 450 if (!playback_success) | 445 if (!playback_success) |
| 451 audio_manager_->FixWedgedAudio(); | 446 audio_manager_->FixWedgedAudio(); |
| 452 } | 447 } |
| 453 } | 448 } |
| 454 | 449 |
| 455 } // namespace media | 450 } // namespace media |
| OLD | NEW |