| OLD | NEW |
| 1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2010 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_input_controller.h" | 5 #include "media/audio/audio_input_controller.h" |
| 6 #include "media/base/limits.h" | 6 #include "media/base/limits.h" |
| 7 | 7 |
| 8 namespace { | 8 namespace { |
| 9 | 9 |
| 10 const int kMaxInputChannels = 2; | 10 const int kMaxInputChannels = 2; |
| 11 const int kMaxSamplesPerPacket = media::Limits::kMaxSampleRate; | |
| 12 | 11 |
| 13 } // namespace | 12 } // namespace |
| 14 | 13 |
| 15 namespace media { | 14 namespace media { |
| 16 | 15 |
| 17 // static | 16 // static |
| 18 AudioInputController::Factory* AudioInputController::factory_ = NULL; | 17 AudioInputController::Factory* AudioInputController::factory_ = NULL; |
| 19 | 18 |
| 20 AudioInputController::AudioInputController(EventHandler* handler) | 19 AudioInputController::AudioInputController(EventHandler* handler) |
| 21 : handler_(handler), | 20 : handler_(handler), |
| 22 stream_(NULL), | 21 stream_(NULL), |
| 23 state_(kEmpty), | 22 state_(kEmpty), |
| 24 thread_("AudioInputControllerThread") { | 23 thread_("AudioInputControllerThread") { |
| 25 } | 24 } |
| 26 | 25 |
| 27 AudioInputController::~AudioInputController() { | 26 AudioInputController::~AudioInputController() { |
| 28 DCHECK(kClosed == state_ || kCreated == state_ || kEmpty == state_); | 27 DCHECK(kClosed == state_ || kCreated == state_ || kEmpty == state_); |
| 29 } | 28 } |
| 30 | 29 |
| 31 // static | 30 // static |
| 32 scoped_refptr<AudioInputController> AudioInputController::Create( | 31 scoped_refptr<AudioInputController> AudioInputController::Create( |
| 33 EventHandler* event_handler, | 32 EventHandler* event_handler, |
| 34 AudioParameters params, | 33 AudioParameters params) { |
| 35 int samples_per_packet) { | 34 if (!params.IsValid() || (params.channels > kMaxInputChannels)) |
| 36 if (!params.IsValid() || | |
| 37 (params.channels > kMaxInputChannels) || | |
| 38 (samples_per_packet > kMaxSamplesPerPacket) || (samples_per_packet < 0)) | |
| 39 return NULL; | 35 return NULL; |
| 40 | 36 |
| 41 if (factory_) { | 37 if (factory_) { |
| 42 return factory_->Create(event_handler, params, samples_per_packet); | 38 return factory_->Create(event_handler, params); |
| 43 } | 39 } |
| 44 | 40 |
| 45 scoped_refptr<AudioInputController> controller(new AudioInputController( | 41 scoped_refptr<AudioInputController> controller(new AudioInputController( |
| 46 event_handler)); | 42 event_handler)); |
| 47 | 43 |
| 48 // Start the thread and post a task to create the audio input stream. | 44 // Start the thread and post a task to create the audio input stream. |
| 49 controller->thread_.Start(); | 45 controller->thread_.Start(); |
| 50 controller->thread_.message_loop()->PostTask( | 46 controller->thread_.message_loop()->PostTask( |
| 51 FROM_HERE, | 47 FROM_HERE, |
| 52 NewRunnableMethod(controller.get(), &AudioInputController::DoCreate, | 48 NewRunnableMethod(controller.get(), &AudioInputController::DoCreate, |
| 53 params, samples_per_packet)); | 49 params)); |
| 54 return controller; | 50 return controller; |
| 55 } | 51 } |
| 56 | 52 |
| 57 void AudioInputController::Record() { | 53 void AudioInputController::Record() { |
| 58 DCHECK(thread_.IsRunning()); | 54 DCHECK(thread_.IsRunning()); |
| 59 thread_.message_loop()->PostTask( | 55 thread_.message_loop()->PostTask( |
| 60 FROM_HERE, | 56 FROM_HERE, |
| 61 NewRunnableMethod(this, &AudioInputController::DoRecord)); | 57 NewRunnableMethod(this, &AudioInputController::DoRecord)); |
| 62 } | 58 } |
| 63 | 59 |
| 64 void AudioInputController::Close() { | 60 void AudioInputController::Close() { |
| 65 if (!thread_.IsRunning()) { | 61 if (!thread_.IsRunning()) { |
| 66 // If the thread is not running make sure we are stopped. | 62 // If the thread is not running make sure we are stopped. |
| 67 DCHECK_EQ(kClosed, state_); | 63 DCHECK_EQ(kClosed, state_); |
| 68 return; | 64 return; |
| 69 } | 65 } |
| 70 | 66 |
| 71 // Wait for all tasks to complete on the audio thread. | 67 // Wait for all tasks to complete on the audio thread. |
| 72 thread_.message_loop()->PostTask( | 68 thread_.message_loop()->PostTask( |
| 73 FROM_HERE, | 69 FROM_HERE, |
| 74 NewRunnableMethod(this, &AudioInputController::DoClose)); | 70 NewRunnableMethod(this, &AudioInputController::DoClose)); |
| 75 thread_.Stop(); | 71 thread_.Stop(); |
| 76 } | 72 } |
| 77 | 73 |
| 78 void AudioInputController::DoCreate(AudioParameters params, | 74 void AudioInputController::DoCreate(AudioParameters params) { |
| 79 uint32 samples_per_packet) { | 75 stream_ = AudioManager::GetAudioManager()->MakeAudioInputStream(params); |
| 80 stream_ = AudioManager::GetAudioManager()->MakeAudioInputStream( | |
| 81 params, samples_per_packet); | |
| 82 | 76 |
| 83 if (!stream_) { | 77 if (!stream_) { |
| 84 // TODO(satish): Define error types. | 78 // TODO(satish): Define error types. |
| 85 handler_->OnError(this, 0); | 79 handler_->OnError(this, 0); |
| 86 return; | 80 return; |
| 87 } | 81 } |
| 88 | 82 |
| 89 if (stream_ && !stream_->Open()) { | 83 if (stream_ && !stream_->Open()) { |
| 90 stream_->Close(); | 84 stream_->Close(); |
| 91 stream_ = NULL; | 85 stream_ = NULL; |
| (...skipping 60 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 152 } | 146 } |
| 153 | 147 |
| 154 void AudioInputController::OnError(AudioInputStream* stream, int code) { | 148 void AudioInputController::OnError(AudioInputStream* stream, int code) { |
| 155 // Handle error on the audio controller thread. | 149 // Handle error on the audio controller thread. |
| 156 thread_.message_loop()->PostTask( | 150 thread_.message_loop()->PostTask( |
| 157 FROM_HERE, | 151 FROM_HERE, |
| 158 NewRunnableMethod(this, &AudioInputController::DoReportError, code)); | 152 NewRunnableMethod(this, &AudioInputController::DoReportError, code)); |
| 159 } | 153 } |
| 160 | 154 |
| 161 } // namespace media | 155 } // namespace media |
| OLD | NEW |