| 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_manager.h" | 5 #include "media/audio/audio_manager.h" |
| 6 | 6 |
| 7 #include <stdint.h> | 7 #include <stdint.h> |
| 8 | 8 |
| 9 #include <utility> | 9 #include <utility> |
| 10 | 10 |
| (...skipping 223 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 234 DISALLOW_COPY_AND_ASSIGN(AudioManagerHelper); | 234 DISALLOW_COPY_AND_ASSIGN(AudioManagerHelper); |
| 235 }; | 235 }; |
| 236 | 236 |
| 237 AudioManagerHelper* GetHelper() { | 237 AudioManagerHelper* GetHelper() { |
| 238 static AudioManagerHelper* helper = new AudioManagerHelper(); | 238 static AudioManagerHelper* helper = new AudioManagerHelper(); |
| 239 return helper; | 239 return helper; |
| 240 } | 240 } |
| 241 | 241 |
| 242 } // namespace | 242 } // namespace |
| 243 | 243 |
| 244 void AudioManagerDeleter::operator()(const AudioManager* instance) const { | |
| 245 CHECK(instance); | |
| 246 // We reset g_last_created here instead of in the destructor of AudioManager | |
| 247 // because the destructor runs on the audio thread. We want to always change | |
| 248 // g_last_created from the main thread. | |
| 249 if (g_last_created == instance) { | |
| 250 g_last_created = nullptr; | |
| 251 } else { | |
| 252 // We create multiple instances of AudioManager only when testing. | |
| 253 // We should not encounter this case in production. | |
| 254 LOG(WARNING) << "Multiple instances of AudioManager detected"; | |
| 255 } | |
| 256 | |
| 257 #if defined(OS_MACOSX) | |
| 258 // If we are on Mac, tasks after this point are not executed, hence this is | |
| 259 // the only chance to delete the audio manager (which on Mac lives on the | |
| 260 // main browser thread instead of a dedicated audio thread). If we don't | |
| 261 // delete here, the CoreAudio thread can keep providing callbacks, which | |
| 262 // uses a state that is destroyed in ~BrowserMainLoop(). | |
| 263 // See http://crbug.com/623703 for more details. | |
| 264 DCHECK(instance->GetTaskRunner()->BelongsToCurrentThread()); | |
| 265 delete instance; | |
| 266 #else | |
| 267 // AudioManager must be destroyed on the audio thread. | |
| 268 if (!instance->GetTaskRunner()->DeleteSoon(FROM_HERE, instance)) { | |
| 269 LOG(WARNING) << "Failed to delete AudioManager instance."; | |
| 270 } | |
| 271 #endif | |
| 272 } | |
| 273 | |
| 274 // Forward declaration of the platform specific AudioManager factory function. | 244 // Forward declaration of the platform specific AudioManager factory function. |
| 275 ScopedAudioManagerPtr CreateAudioManager( | 245 std::unique_ptr<AudioManager> CreateAudioManager( |
| 276 scoped_refptr<base::SingleThreadTaskRunner> task_runner, | 246 scoped_refptr<base::SingleThreadTaskRunner> task_runner, |
| 277 scoped_refptr<base::SingleThreadTaskRunner> worker_task_runner, | 247 scoped_refptr<base::SingleThreadTaskRunner> worker_task_runner, |
| 278 AudioLogFactory* audio_log_factory); | 248 AudioLogFactory* audio_log_factory); |
| 279 | 249 |
| 280 void AudioManager::SetMaxStreamCountForTesting(int max_input, int max_output) { | 250 void AudioManager::SetMaxStreamCountForTesting(int max_input, int max_output) { |
| 281 NOTREACHED(); | 251 NOTREACHED(); |
| 282 } | 252 } |
| 283 | 253 |
| 284 AudioManager::AudioManager( | 254 AudioManager::AudioManager( |
| 285 scoped_refptr<base::SingleThreadTaskRunner> task_runner, | 255 scoped_refptr<base::SingleThreadTaskRunner> task_runner, |
| 286 scoped_refptr<base::SingleThreadTaskRunner> worker_task_runner) | 256 scoped_refptr<base::SingleThreadTaskRunner> worker_task_runner) |
| 287 : task_runner_(std::move(task_runner)), | 257 : task_runner_(std::move(task_runner)), |
| 288 worker_task_runner_(std::move(worker_task_runner)) { | 258 worker_task_runner_(std::move(worker_task_runner)) { |
| 289 DCHECK(task_runner_); | 259 DCHECK(task_runner_); |
| 290 DCHECK(worker_task_runner_); | 260 DCHECK(worker_task_runner_); |
| 291 | 261 |
| 292 if (g_last_created) { | 262 if (g_last_created) { |
| 293 // We create multiple instances of AudioManager only when testing. | 263 // We create multiple instances of AudioManager only when testing. |
| 294 // We should not encounter this case in production. | 264 // We should not encounter this case in production. |
| 295 LOG(WARNING) << "Multiple instances of AudioManager detected"; | 265 LOG(WARNING) << "Multiple instances of AudioManager detected"; |
| 296 } | 266 } |
| 297 // We always override |g_last_created| irrespective of whether it is already | 267 // We always override |g_last_created| irrespective of whether it is already |
| 298 // set or not becuase it represents the last created instance. | 268 // set or not becuase it represents the last created instance. |
| 299 g_last_created = this; | 269 g_last_created = this; |
| 300 } | 270 } |
| 301 | 271 |
| 302 AudioManager::~AudioManager() { | 272 AudioManager::~AudioManager() { |
| 303 DCHECK(task_runner_->BelongsToCurrentThread()); | 273 DCHECK(thread_checker_.CalledOnValidThread()); |
| 274 |
| 275 if (g_last_created == this) { |
| 276 g_last_created = nullptr; |
| 277 } else { |
| 278 // We create multiple instances of AudioManager only when testing. |
| 279 // We should not encounter this case in production. |
| 280 LOG(WARNING) << "Multiple instances of AudioManager detected"; |
| 281 } |
| 304 } | 282 } |
| 305 | 283 |
| 306 // static | 284 // static |
| 307 ScopedAudioManagerPtr AudioManager::Create( | 285 std::unique_ptr<AudioManager> AudioManager::Create( |
| 308 scoped_refptr<base::SingleThreadTaskRunner> task_runner, | 286 scoped_refptr<base::SingleThreadTaskRunner> task_runner, |
| 309 scoped_refptr<base::SingleThreadTaskRunner> worker_task_runner, | 287 scoped_refptr<base::SingleThreadTaskRunner> worker_task_runner, |
| 310 scoped_refptr<base::SingleThreadTaskRunner> file_task_runner, | 288 scoped_refptr<base::SingleThreadTaskRunner> file_task_runner, |
| 311 AudioLogFactory* audio_log_factory) { | 289 AudioLogFactory* audio_log_factory) { |
| 312 DCHECK(task_runner); | 290 DCHECK(task_runner); |
| 313 DCHECK(worker_task_runner); | 291 DCHECK(worker_task_runner); |
| 314 ScopedAudioManagerPtr manager = CreateAudioManager( | 292 std::unique_ptr<AudioManager> manager = CreateAudioManager( |
| 315 std::move(task_runner), std::move(worker_task_runner), audio_log_factory); | 293 std::move(task_runner), std::move(worker_task_runner), audio_log_factory); |
| 316 #if BUILDFLAG(ENABLE_WEBRTC) | 294 #if BUILDFLAG(ENABLE_WEBRTC) |
| 317 manager->InitializeOutputDebugRecording(std::move(file_task_runner)); | 295 manager->InitializeOutputDebugRecording(std::move(file_task_runner)); |
| 318 #endif | 296 #endif |
| 319 return manager; | 297 return manager; |
| 320 } | 298 } |
| 321 | 299 |
| 322 // static | 300 // static |
| 323 ScopedAudioManagerPtr AudioManager::CreateForTesting( | 301 std::unique_ptr<AudioManager> AudioManager::CreateForTesting( |
| 324 scoped_refptr<base::SingleThreadTaskRunner> task_runner) { | 302 scoped_refptr<base::SingleThreadTaskRunner> task_runner) { |
| 325 #if defined(OS_WIN) | 303 #if defined(OS_WIN) |
| 326 GetHelper()->InitializeCOMForTesting(); | 304 GetHelper()->InitializeCOMForTesting(); |
| 327 #endif | 305 #endif |
| 328 return Create(task_runner, task_runner, task_runner, | 306 return Create(task_runner, task_runner, task_runner, |
| 329 GetHelper()->fake_log_factory()); | 307 GetHelper()->fake_log_factory()); |
| 330 } | 308 } |
| 331 | 309 |
| 332 // static | 310 // static |
| 333 void AudioManager::StartHangMonitorIfNeeded( | 311 void AudioManager::StartHangMonitorIfNeeded( |
| (...skipping 19 matching lines...) Expand all Loading... |
| 353 return GetHelper()->app_name(); | 331 return GetHelper()->app_name(); |
| 354 } | 332 } |
| 355 #endif | 333 #endif |
| 356 | 334 |
| 357 // static | 335 // static |
| 358 AudioManager* AudioManager::Get() { | 336 AudioManager* AudioManager::Get() { |
| 359 return g_last_created; | 337 return g_last_created; |
| 360 } | 338 } |
| 361 | 339 |
| 362 } // namespace media | 340 } // namespace media |
| OLD | NEW |