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_input_controller.h" | 5 #include "media/audio/audio_input_controller.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/strings/stringprintf.h" | 8 #include "base/strings/stringprintf.h" |
9 #include "base/threading/thread_restrictions.h" | 9 #include "base/threading/thread_restrictions.h" |
10 #include "base/time/time.h" | 10 #include "base/time/time.h" |
(...skipping 102 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
113 return factory_->Create( | 113 return factory_->Create( |
114 audio_manager, event_handler, params, user_input_monitor); | 114 audio_manager, event_handler, params, user_input_monitor); |
115 } | 115 } |
116 scoped_refptr<AudioInputController> controller( | 116 scoped_refptr<AudioInputController> controller( |
117 new AudioInputController(event_handler, NULL, user_input_monitor)); | 117 new AudioInputController(event_handler, NULL, user_input_monitor)); |
118 | 118 |
119 controller->task_runner_ = audio_manager->GetTaskRunner(); | 119 controller->task_runner_ = audio_manager->GetTaskRunner(); |
120 | 120 |
121 // Create and open a new audio input stream from the existing | 121 // Create and open a new audio input stream from the existing |
122 // audio-device thread. | 122 // audio-device thread. |
123 if (!controller->task_runner_->PostTask(FROM_HERE, | 123 if (!controller->task_runner_->PostTask( |
124 base::Bind(&AudioInputController::DoCreate, controller, | 124 FROM_HERE, |
125 base::Unretained(audio_manager), params, device_id))) { | 125 base::Bind(&AudioInputController::DoCreate, |
| 126 controller, |
| 127 base::Unretained(audio_manager), |
| 128 params, |
| 129 device_id))) { |
126 controller = NULL; | 130 controller = NULL; |
127 } | 131 } |
128 | 132 |
129 return controller; | 133 return controller; |
130 } | 134 } |
131 | 135 |
132 // static | 136 // static |
133 scoped_refptr<AudioInputController> AudioInputController::CreateLowLatency( | 137 scoped_refptr<AudioInputController> AudioInputController::CreateLowLatency( |
134 AudioManager* audio_manager, | 138 AudioManager* audio_manager, |
135 EventHandler* event_handler, | 139 EventHandler* event_handler, |
136 const AudioParameters& params, | 140 const AudioParameters& params, |
137 const std::string& device_id, | 141 const std::string& device_id, |
138 SyncWriter* sync_writer, | 142 SyncWriter* sync_writer, |
139 UserInputMonitor* user_input_monitor) { | 143 UserInputMonitor* user_input_monitor) { |
140 DCHECK(audio_manager); | 144 DCHECK(audio_manager); |
141 DCHECK(sync_writer); | 145 DCHECK(sync_writer); |
142 | 146 |
143 if (!params.IsValid() || (params.channels() > kMaxInputChannels)) | 147 if (!params.IsValid() || (params.channels() > kMaxInputChannels)) |
144 return NULL; | 148 return NULL; |
145 | 149 |
146 // Create the AudioInputController object and ensure that it runs on | 150 // Create the AudioInputController object and ensure that it runs on |
147 // the audio-manager thread. | 151 // the audio-manager thread. |
148 scoped_refptr<AudioInputController> controller( | 152 scoped_refptr<AudioInputController> controller( |
149 new AudioInputController(event_handler, sync_writer, user_input_monitor)); | 153 new AudioInputController(event_handler, sync_writer, user_input_monitor)); |
150 controller->task_runner_ = audio_manager->GetTaskRunner(); | 154 controller->task_runner_ = audio_manager->GetTaskRunner(); |
151 | 155 |
152 // Create and open a new audio input stream from the existing | 156 // Create and open a new audio input stream from the existing |
153 // audio-device thread. Use the provided audio-input device. | 157 // audio-device thread. Use the provided audio-input device. |
154 if (!controller->task_runner_->PostTask(FROM_HERE, | 158 if (!controller->task_runner_->PostTask( |
155 base::Bind(&AudioInputController::DoCreateForLowLatency, controller, | 159 FROM_HERE, |
156 base::Unretained(audio_manager), params, device_id))) { | 160 base::Bind(&AudioInputController::DoCreateForLowLatency, |
| 161 controller, |
| 162 base::Unretained(audio_manager), |
| 163 params, |
| 164 device_id))) { |
157 controller = NULL; | 165 controller = NULL; |
158 } | 166 } |
159 | 167 |
160 return controller; | 168 return controller; |
161 } | 169 } |
162 | 170 |
163 // static | 171 // static |
164 scoped_refptr<AudioInputController> AudioInputController::CreateForStream( | 172 scoped_refptr<AudioInputController> AudioInputController::CreateForStream( |
165 const scoped_refptr<base::SingleThreadTaskRunner>& task_runner, | 173 const scoped_refptr<base::SingleThreadTaskRunner>& task_runner, |
166 EventHandler* event_handler, | 174 EventHandler* event_handler, |
(...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
213 void AudioInputController::SetAutomaticGainControl(bool enabled) { | 221 void AudioInputController::SetAutomaticGainControl(bool enabled) { |
214 task_runner_->PostTask(FROM_HERE, base::Bind( | 222 task_runner_->PostTask(FROM_HERE, base::Bind( |
215 &AudioInputController::DoSetAutomaticGainControl, this, enabled)); | 223 &AudioInputController::DoSetAutomaticGainControl, this, enabled)); |
216 } | 224 } |
217 | 225 |
218 void AudioInputController::DoCreate(AudioManager* audio_manager, | 226 void AudioInputController::DoCreate(AudioManager* audio_manager, |
219 const AudioParameters& params, | 227 const AudioParameters& params, |
220 const std::string& device_id) { | 228 const std::string& device_id) { |
221 DCHECK(task_runner_->BelongsToCurrentThread()); | 229 DCHECK(task_runner_->BelongsToCurrentThread()); |
222 SCOPED_UMA_HISTOGRAM_TIMER("Media.AudioInputController.CreateTime"); | 230 SCOPED_UMA_HISTOGRAM_TIMER("Media.AudioInputController.CreateTime"); |
| 231 if (handler_) |
| 232 handler_->OnLog(this, "AIC::DoCreate"); |
223 | 233 |
224 #if defined(AUDIO_POWER_MONITORING) | 234 #if defined(AUDIO_POWER_MONITORING) |
225 // Create the audio (power) level meter given the provided audio parameters. | 235 // Create the audio (power) level meter given the provided audio parameters. |
226 // An AudioBus is also needed to wrap the raw data buffer from the native | 236 // An AudioBus is also needed to wrap the raw data buffer from the native |
227 // layer to match AudioPowerMonitor::Scan(). | 237 // layer to match AudioPowerMonitor::Scan(). |
228 // TODO(henrika): Remove use of extra AudioBus. See http://crbug.com/375155. | 238 // TODO(henrika): Remove use of extra AudioBus. See http://crbug.com/375155. |
| 239 last_audio_level_log_time_ = base::TimeTicks::Now(); |
229 audio_level_.reset(new media::AudioPowerMonitor( | 240 audio_level_.reset(new media::AudioPowerMonitor( |
230 params.sample_rate(), | 241 params.sample_rate(), |
231 TimeDelta::FromMilliseconds(kPowerMeasurementTimeConstantMilliseconds))); | 242 TimeDelta::FromMilliseconds(kPowerMeasurementTimeConstantMilliseconds))); |
232 audio_params_ = params; | 243 audio_params_ = params; |
233 silence_state_ = SILENCE_STATE_NO_MEASUREMENT; | 244 silence_state_ = SILENCE_STATE_NO_MEASUREMENT; |
234 #endif | 245 #endif |
235 | 246 |
236 // TODO(miu): See TODO at top of file. Until that's resolved, assume all | 247 // TODO(miu): See TODO at top of file. Until that's resolved, assume all |
237 // platform audio input requires the |no_data_timer_| be used to auto-detect | 248 // platform audio input requires the |no_data_timer_| be used to auto-detect |
238 // errors. In reality, probably only Windows needs to be treated as | 249 // errors. In reality, probably only Windows needs to be treated as |
(...skipping 69 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
308 SCOPED_UMA_HISTOGRAM_TIMER("Media.AudioInputController.RecordTime"); | 319 SCOPED_UMA_HISTOGRAM_TIMER("Media.AudioInputController.RecordTime"); |
309 | 320 |
310 if (state_ != CREATED) | 321 if (state_ != CREATED) |
311 return; | 322 return; |
312 | 323 |
313 { | 324 { |
314 base::AutoLock auto_lock(lock_); | 325 base::AutoLock auto_lock(lock_); |
315 state_ = RECORDING; | 326 state_ = RECORDING; |
316 } | 327 } |
317 | 328 |
| 329 if (handler_) |
| 330 handler_->OnLog(this, "AIC::DoRecord"); |
| 331 |
318 if (no_data_timer_) { | 332 if (no_data_timer_) { |
319 // Start the data timer. Once |kTimerResetIntervalSeconds| have passed, | 333 // Start the data timer. Once |kTimerResetIntervalSeconds| have passed, |
320 // a callback to FirstCheckForNoData() is made. | 334 // a callback to FirstCheckForNoData() is made. |
321 no_data_timer_->Reset(); | 335 no_data_timer_->Reset(); |
322 } | 336 } |
323 | 337 |
324 stream_->Start(this); | 338 stream_->Start(this); |
325 if (handler_) | 339 if (handler_) |
326 handler_->OnRecording(this); | 340 handler_->OnRecording(this); |
327 } | 341 } |
328 | 342 |
329 void AudioInputController::DoClose() { | 343 void AudioInputController::DoClose() { |
330 DCHECK(task_runner_->BelongsToCurrentThread()); | 344 DCHECK(task_runner_->BelongsToCurrentThread()); |
331 SCOPED_UMA_HISTOGRAM_TIMER("Media.AudioInputController.CloseTime"); | 345 SCOPED_UMA_HISTOGRAM_TIMER("Media.AudioInputController.CloseTime"); |
332 | 346 |
333 if (state_ == CLOSED) | 347 if (state_ == CLOSED) |
334 return; | 348 return; |
335 | 349 |
| 350 if (handler_) |
| 351 handler_->OnLog(this, "AIC::DoClose"); |
| 352 |
336 // Delete the timer on the same thread that created it. | 353 // Delete the timer on the same thread that created it. |
337 no_data_timer_.reset(); | 354 no_data_timer_.reset(); |
338 | 355 |
339 DoStopCloseAndClearStream(); | 356 DoStopCloseAndClearStream(); |
340 SetDataIsActive(false); | 357 SetDataIsActive(false); |
341 | 358 |
342 if (SharedMemoryAndSyncSocketMode()) | 359 if (SharedMemoryAndSyncSocketMode()) |
343 sync_writer_->Close(); | 360 sync_writer_->Close(); |
344 | 361 |
345 if (user_input_monitor_) | 362 if (user_input_monitor_) |
(...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
393 return; | 410 return; |
394 | 411 |
395 stream_->SetAutomaticGainControl(enabled); | 412 stream_->SetAutomaticGainControl(enabled); |
396 } | 413 } |
397 | 414 |
398 void AudioInputController::FirstCheckForNoData() { | 415 void AudioInputController::FirstCheckForNoData() { |
399 DCHECK(task_runner_->BelongsToCurrentThread()); | 416 DCHECK(task_runner_->BelongsToCurrentThread()); |
400 LogCaptureStartupResult(GetDataIsActive() ? | 417 LogCaptureStartupResult(GetDataIsActive() ? |
401 CAPTURE_STARTUP_OK : | 418 CAPTURE_STARTUP_OK : |
402 CAPTURE_STARTUP_NO_DATA_CALLBACK); | 419 CAPTURE_STARTUP_NO_DATA_CALLBACK); |
| 420 if (handler_) { |
| 421 handler_->OnLog(this, GetDataIsActive() ? |
| 422 "AIC::FirstCheckForNoData => data is active" : |
| 423 "AIC::FirstCheckForNoData => data is NOT active"); |
| 424 } |
403 DoCheckForNoData(); | 425 DoCheckForNoData(); |
404 } | 426 } |
405 | 427 |
406 void AudioInputController::DoCheckForNoData() { | 428 void AudioInputController::DoCheckForNoData() { |
407 DCHECK(task_runner_->BelongsToCurrentThread()); | 429 DCHECK(task_runner_->BelongsToCurrentThread()); |
408 | 430 |
409 if (!GetDataIsActive()) { | 431 if (!GetDataIsActive()) { |
410 // The data-is-active marker will be false only if it has been more than | 432 // The data-is-active marker will be false only if it has been more than |
411 // one second since a data packet was recorded. This can happen if a | 433 // one second since a data packet was recorded. This can happen if a |
412 // capture device has been removed or disabled. | 434 // capture device has been removed or disabled. |
(...skipping 167 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
580 } | 602 } |
581 | 603 |
582 void AudioInputController::LogSilenceState(SilenceState value) { | 604 void AudioInputController::LogSilenceState(SilenceState value) { |
583 UMA_HISTOGRAM_ENUMERATION("Media.AudioInputControllerSessionSilenceReport", | 605 UMA_HISTOGRAM_ENUMERATION("Media.AudioInputControllerSessionSilenceReport", |
584 value, | 606 value, |
585 SILENCE_STATE_MAX + 1); | 607 SILENCE_STATE_MAX + 1); |
586 } | 608 } |
587 #endif | 609 #endif |
588 | 610 |
589 } // namespace media | 611 } // namespace media |
OLD | NEW |