Chromium Code Reviews| Index: media/audio/audio_input_controller.cc |
| diff --git a/media/audio/audio_input_controller.cc b/media/audio/audio_input_controller.cc |
| index 311a54ef840581ea69ef0cd65a52e13f33f16512..1c486b562622d1cf2a44941dbf6a2b54a58f1c63 100644 |
| --- a/media/audio/audio_input_controller.cc |
| +++ b/media/audio/audio_input_controller.cc |
| @@ -10,6 +10,7 @@ |
| namespace media { |
| static const int kMaxInputChannels = 2; |
| +const int kTimerResetInterval = 1; // One second. |
|
Satish
2011/06/15 10:23:27
suggest moving both these constants to an anonymou
allanwoj
2011/06/15 11:11:17
Done.
|
| // static |
| AudioInputController::Factory* AudioInputController::factory_ = NULL; |
| @@ -18,6 +19,10 @@ AudioInputController::AudioInputController(EventHandler* handler, |
| SyncWriter* sync_writer) |
| : handler_(handler), |
| stream_(NULL), |
| + ALLOW_THIS_IN_INITIALIZER_LIST(timer_( |
| + base::TimeDelta::FromSeconds(kTimerResetInterval), |
| + this, |
| + &AudioInputController::DoReportTimeoutError)), |
| state_(kEmpty), |
| thread_("AudioInputControllerThread"), |
| sync_writer_(sync_writer) { |
| @@ -123,6 +128,9 @@ void AudioInputController::DoCreate(AudioParameters params) { |
| return; |
| } |
| + thread_.message_loop()->PostTask( |
| + FROM_HERE, |
| + NewRunnableMethod(this, &AudioInputController::DoTimerReset)); |
| state_ = kCreated; |
| handler_->OnCreated(this); |
| } |
| @@ -168,6 +176,15 @@ void AudioInputController::DoReportError(int code) { |
| handler_->OnError(this, code); |
| } |
| +void AudioInputController::DoReportTimeoutError() { |
| + handler_->OnError(this, 0); |
| +} |
| + |
| +void AudioInputController::DoTimerReset() { |
| + DCHECK_EQ(thread_.message_loop(), MessageLoop::current()); |
| + timer_.Reset(); |
| +} |
| + |
| void AudioInputController::OnData(AudioInputStream* stream, const uint8* data, |
| uint32 size) { |
| { |
| @@ -176,6 +193,10 @@ void AudioInputController::OnData(AudioInputStream* stream, const uint8* data, |
| return; |
| } |
| + thread_.message_loop()->PostTask( |
| + FROM_HERE, |
| + NewRunnableMethod(this, &AudioInputController::DoTimerReset)); |
| + |
| // Use SyncSocket if we are in a low-latency mode. |
| if (LowLatencyMode()) { |
| sync_writer_->Write(data, size); |