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 "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/bind_helpers.h" | 10 #include "base/bind_helpers.h" |
(...skipping 27 matching lines...) Expand all Loading... |
38 // The singleton instance of AudioManager. This is set when Create() is called. | 38 // The singleton instance of AudioManager. This is set when Create() is called. |
39 AudioManager* g_last_created = nullptr; | 39 AudioManager* g_last_created = nullptr; |
40 | 40 |
41 // Maximum number of failed pings to the audio thread allowed. A UMA will be | 41 // Maximum number of failed pings to the audio thread allowed. A UMA will be |
42 // recorded once this count is reached; if enabled, a non-crash dump will be | 42 // recorded once this count is reached; if enabled, a non-crash dump will be |
43 // captured as well. We require at least three failed pings before recording to | 43 // captured as well. We require at least three failed pings before recording to |
44 // ensure unobservable power events aren't mistakenly caught (e.g., the system | 44 // ensure unobservable power events aren't mistakenly caught (e.g., the system |
45 // suspends before a OnSuspend() event can be fired). | 45 // suspends before a OnSuspend() event can be fired). |
46 const int kMaxFailedPingsCount = 3; | 46 const int kMaxFailedPingsCount = 3; |
47 | 47 |
| 48 // Dummy function for creating debug writer. |
| 49 std::unique_ptr<AudioFileWriter> CreateAudioFileWriterDummy( |
| 50 const AudioParameters& params) { |
| 51 return nullptr; |
| 52 } |
| 53 |
48 // Helper class for managing global AudioManager data and hang monitor. If the | 54 // Helper class for managing global AudioManager data and hang monitor. If the |
49 // audio thread is hung for > |kMaxFailedPingsCount| * |max_hung_task_time_|, we | 55 // audio thread is hung for > |kMaxFailedPingsCount| * |max_hung_task_time_|, we |
50 // want to record a UMA and optionally a non-crash dump to find offenders in the | 56 // want to record a UMA and optionally a non-crash dump to find offenders in the |
51 // field. | 57 // field. |
52 class AudioManagerHelper : public base::PowerObserver { | 58 class AudioManagerHelper : public base::PowerObserver { |
53 public: | 59 public: |
54 // These values are histogrammed over time; do not change their ordinal | 60 // These values are histogrammed over time; do not change their ordinal |
55 // values. | 61 // values. |
56 enum ThreadStatus { | 62 enum ThreadStatus { |
57 THREAD_NONE = 0, | 63 THREAD_NONE = 0, |
(...skipping 236 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
294 if (!instance->GetTaskRunner()->DeleteSoon(FROM_HERE, instance)) { | 300 if (!instance->GetTaskRunner()->DeleteSoon(FROM_HERE, instance)) { |
295 LOG(WARNING) << "Failed to delete AudioManager instance."; | 301 LOG(WARNING) << "Failed to delete AudioManager instance."; |
296 } | 302 } |
297 #endif | 303 #endif |
298 } | 304 } |
299 | 305 |
300 // Forward declaration of the platform specific AudioManager factory function. | 306 // Forward declaration of the platform specific AudioManager factory function. |
301 ScopedAudioManagerPtr CreateAudioManager( | 307 ScopedAudioManagerPtr CreateAudioManager( |
302 scoped_refptr<base::SingleThreadTaskRunner> task_runner, | 308 scoped_refptr<base::SingleThreadTaskRunner> task_runner, |
303 scoped_refptr<base::SingleThreadTaskRunner> worker_task_runner, | 309 scoped_refptr<base::SingleThreadTaskRunner> worker_task_runner, |
304 AudioLogFactory* audio_log_factory); | 310 AudioLogFactory* audio_log_factory, |
| 311 CreateAudioFileWriterCallback create_audio_file_writer_callback); |
305 | 312 |
306 void AudioManager::SetMaxStreamCountForTesting(int max_input, int max_output) { | 313 void AudioManager::SetMaxStreamCountForTesting(int max_input, int max_output) { |
307 NOTREACHED(); | 314 NOTREACHED(); |
308 } | 315 } |
309 | 316 |
310 AudioManager::AudioManager( | 317 AudioManager::AudioManager( |
311 scoped_refptr<base::SingleThreadTaskRunner> task_runner, | 318 scoped_refptr<base::SingleThreadTaskRunner> task_runner, |
312 scoped_refptr<base::SingleThreadTaskRunner> worker_task_runner) | 319 scoped_refptr<base::SingleThreadTaskRunner> worker_task_runner) |
313 : task_runner_(std::move(task_runner)), | 320 : task_runner_(std::move(task_runner)), |
314 worker_task_runner_(std::move(worker_task_runner)) { | 321 worker_task_runner_(std::move(worker_task_runner)) { |
(...skipping 11 matching lines...) Expand all Loading... |
326 } | 333 } |
327 | 334 |
328 AudioManager::~AudioManager() { | 335 AudioManager::~AudioManager() { |
329 DCHECK(task_runner_->BelongsToCurrentThread()); | 336 DCHECK(task_runner_->BelongsToCurrentThread()); |
330 } | 337 } |
331 | 338 |
332 // static | 339 // static |
333 ScopedAudioManagerPtr AudioManager::Create( | 340 ScopedAudioManagerPtr AudioManager::Create( |
334 scoped_refptr<base::SingleThreadTaskRunner> task_runner, | 341 scoped_refptr<base::SingleThreadTaskRunner> task_runner, |
335 scoped_refptr<base::SingleThreadTaskRunner> worker_task_runner, | 342 scoped_refptr<base::SingleThreadTaskRunner> worker_task_runner, |
336 AudioLogFactory* audio_log_factory) { | 343 AudioLogFactory* audio_log_factory, |
| 344 CreateAudioFileWriterCallback create_audio_file_writer_callback) { |
337 DCHECK(task_runner); | 345 DCHECK(task_runner); |
338 DCHECK(worker_task_runner); | 346 DCHECK(worker_task_runner); |
339 return CreateAudioManager(std::move(task_runner), | 347 return CreateAudioManager(std::move(task_runner), |
340 std::move(worker_task_runner), audio_log_factory); | 348 std::move(worker_task_runner), audio_log_factory, |
| 349 std::move(create_audio_file_writer_callback)); |
341 } | 350 } |
342 | 351 |
343 // static | 352 // static |
344 ScopedAudioManagerPtr AudioManager::CreateForTesting( | 353 ScopedAudioManagerPtr AudioManager::CreateForTesting( |
345 scoped_refptr<base::SingleThreadTaskRunner> task_runner) { | 354 scoped_refptr<base::SingleThreadTaskRunner> task_runner) { |
346 #if defined(OS_WIN) | 355 #if defined(OS_WIN) |
347 g_helper.Pointer()->InitializeCOMForTesting(); | 356 g_helper.Pointer()->InitializeCOMForTesting(); |
348 #endif | 357 #endif |
349 return Create(task_runner, task_runner, | 358 return Create(task_runner, task_runner, |
350 g_helper.Pointer()->fake_log_factory()); | 359 g_helper.Pointer()->fake_log_factory(), |
| 360 base::Bind(&CreateAudioFileWriterDummy)); |
351 } | 361 } |
352 | 362 |
353 // static | 363 // static |
354 void AudioManager::StartHangMonitorIfNeeded( | 364 void AudioManager::StartHangMonitorIfNeeded( |
355 scoped_refptr<base::SingleThreadTaskRunner> task_runner) { | 365 scoped_refptr<base::SingleThreadTaskRunner> task_runner) { |
356 if (g_helper.Pointer()->monitor_task_runner()) | 366 if (g_helper.Pointer()->monitor_task_runner()) |
357 return; | 367 return; |
358 | 368 |
359 DCHECK(AudioManager::Get()); | 369 DCHECK(AudioManager::Get()); |
360 DCHECK(task_runner); | 370 DCHECK(task_runner); |
(...skipping 19 matching lines...) Expand all Loading... |
380 return g_helper.Pointer()->app_name(); | 390 return g_helper.Pointer()->app_name(); |
381 } | 391 } |
382 #endif | 392 #endif |
383 | 393 |
384 // static | 394 // static |
385 AudioManager* AudioManager::Get() { | 395 AudioManager* AudioManager::Get() { |
386 return g_last_created; | 396 return g_last_created; |
387 } | 397 } |
388 | 398 |
389 } // namespace media | 399 } // namespace media |
OLD | NEW |