| 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 "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/bind_helpers.h" | 8 #include "base/bind_helpers.h" |
| 9 #include "base/command_line.h" | 9 #include "base/command_line.h" |
| 10 #include "base/debug/alias.h" | 10 #include "base/debug/alias.h" |
| 11 #include "base/lazy_instance.h" | 11 #include "base/lazy_instance.h" |
| 12 #include "base/logging.h" | 12 #include "base/logging.h" |
| 13 #include "base/message_loop/message_loop.h" | 13 #include "base/message_loop/message_loop.h" |
| 14 #include "base/power_monitor/power_monitor.h" | 14 #include "base/power_monitor/power_monitor.h" |
| 15 #include "build/build_config.h" | 15 #include "build/build_config.h" |
| 16 #include "media/audio/audio_manager_factory.h" | 16 #include "media/audio/audio_manager_factory.h" |
| 17 #include "media/audio/fake_audio_log_factory.h" | 17 #include "media/audio/fake_audio_log_factory.h" |
| 18 #include "media/base/media_switches.h" | 18 #include "media/base/media_switches.h" |
| 19 | 19 |
| 20 #if defined(OS_WIN) |
| 21 #include "base/win/scoped_com_initializer.h" |
| 22 #endif |
| 23 |
| 20 namespace media { | 24 namespace media { |
| 21 namespace { | 25 namespace { |
| 22 | 26 |
| 23 // The singleton instance of AudioManager. This is set when Create() is called. | 27 // The singleton instance of AudioManager. This is set when Create() is called. |
| 24 AudioManager* g_last_created = NULL; | 28 AudioManager* g_last_created = NULL; |
| 25 | 29 |
| 26 // The singleton instance of AudioManagerFactory. This is only set if | 30 // The singleton instance of AudioManagerFactory. This is only set if |
| 27 // SetFactory() is called. If it is set when Create() is called, its | 31 // SetFactory() is called. If it is set when Create() is called, its |
| 28 // CreateInstance() function is used to set |g_last_created|. Otherwise, the | 32 // CreateInstance() function is used to set |g_last_created|. Otherwise, the |
| 29 // linked implementation of media::CreateAudioManager is used to set | 33 // linked implementation of media::CreateAudioManager is used to set |
| (...skipping 82 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 112 // Don't hold the lock while posting the next task. | 116 // Don't hold the lock while posting the next task. |
| 113 g_last_created->GetTaskRunner()->PostDelayedTask( | 117 g_last_created->GetTaskRunner()->PostDelayedTask( |
| 114 FROM_HERE, | 118 FROM_HERE, |
| 115 base::Bind(&AudioManagerHelper::UpdateLastAudioThreadTimeTick, | 119 base::Bind(&AudioManagerHelper::UpdateLastAudioThreadTimeTick, |
| 116 base::Unretained(this)), | 120 base::Unretained(this)), |
| 117 max_hung_task_time_ / 10); | 121 max_hung_task_time_ / 10); |
| 118 } | 122 } |
| 119 | 123 |
| 120 AudioLogFactory* fake_log_factory() { return &fake_log_factory_; } | 124 AudioLogFactory* fake_log_factory() { return &fake_log_factory_; } |
| 121 | 125 |
| 126 #if defined(OS_WIN) |
| 127 // This should be called before creating an AudioManager in tests to ensure |
| 128 // that the creating thread is COM initialized. |
| 129 void InitializeCOMForTesting() { |
| 130 com_initializer_for_testing_.reset(new base::win::ScopedCOMInitializer()); |
| 131 } |
| 132 #endif |
| 133 |
| 122 private: | 134 private: |
| 123 FakeAudioLogFactory fake_log_factory_; | 135 FakeAudioLogFactory fake_log_factory_; |
| 124 | 136 |
| 125 const base::TimeDelta max_hung_task_time_; | 137 const base::TimeDelta max_hung_task_time_; |
| 126 scoped_refptr<base::SingleThreadTaskRunner> monitor_task_runner_; | 138 scoped_refptr<base::SingleThreadTaskRunner> monitor_task_runner_; |
| 127 | 139 |
| 128 base::Lock hang_lock_; | 140 base::Lock hang_lock_; |
| 129 bool hang_detection_enabled_; | 141 bool hang_detection_enabled_; |
| 130 base::TimeTicks last_audio_thread_timer_tick_; | 142 base::TimeTicks last_audio_thread_timer_tick_; |
| 131 int hang_failures_; | 143 int hang_failures_; |
| 132 | 144 |
| 145 #if defined(OS_WIN) |
| 146 scoped_ptr<base::win::ScopedCOMInitializer> com_initializer_for_testing_; |
| 147 #endif |
| 148 |
| 133 DISALLOW_COPY_AND_ASSIGN(AudioManagerHelper); | 149 DISALLOW_COPY_AND_ASSIGN(AudioManagerHelper); |
| 134 }; | 150 }; |
| 135 | 151 |
| 136 static bool g_hang_monitor_enabled = false; | 152 static bool g_hang_monitor_enabled = false; |
| 137 | 153 |
| 138 static base::LazyInstance<AudioManagerHelper>::Leaky g_helper = | 154 static base::LazyInstance<AudioManagerHelper>::Leaky g_helper = |
| 139 LAZY_INSTANCE_INITIALIZER; | 155 LAZY_INSTANCE_INITIALIZER; |
| 140 } // namespace | 156 } // namespace |
| 141 | 157 |
| 142 // Forward declaration of the platform specific AudioManager factory function. | 158 // Forward declaration of the platform specific AudioManager factory function. |
| (...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 184 if (g_hang_monitor_enabled || | 200 if (g_hang_monitor_enabled || |
| 185 base::CommandLine::ForCurrentProcess()->HasSwitch( | 201 base::CommandLine::ForCurrentProcess()->HasSwitch( |
| 186 switches::kEnableAudioHangMonitor)) { | 202 switches::kEnableAudioHangMonitor)) { |
| 187 g_helper.Pointer()->StartHangTimer(monitor_task_runner); | 203 g_helper.Pointer()->StartHangTimer(monitor_task_runner); |
| 188 } | 204 } |
| 189 return manager; | 205 return manager; |
| 190 } | 206 } |
| 191 | 207 |
| 192 // static | 208 // static |
| 193 AudioManager* AudioManager::CreateForTesting() { | 209 AudioManager* AudioManager::CreateForTesting() { |
| 210 #if defined(OS_WIN) |
| 211 g_helper.Pointer()->InitializeCOMForTesting(); |
| 212 #endif |
| 194 return Create(g_helper.Pointer()->fake_log_factory()); | 213 return Create(g_helper.Pointer()->fake_log_factory()); |
| 195 } | 214 } |
| 196 | 215 |
| 197 // static | 216 // static |
| 198 void AudioManager::EnableHangMonitor() { | 217 void AudioManager::EnableHangMonitor() { |
| 199 CHECK(!g_last_created); | 218 CHECK(!g_last_created); |
| 200 // On OSX the audio thread is the UI thread, for which a hang monitor is not | 219 // On OSX the audio thread is the UI thread, for which a hang monitor is not |
| 201 // necessary or recommended. If it's manually requested, we should allow it | 220 // necessary or recommended. If it's manually requested, we should allow it |
| 202 // to start though. | 221 // to start though. |
| 203 #if !defined(OS_MACOSX) | 222 #if !defined(OS_MACOSX) |
| 204 g_hang_monitor_enabled = true; | 223 g_hang_monitor_enabled = true; |
| 205 #endif | 224 #endif |
| 206 } | 225 } |
| 207 | 226 |
| 208 // static | 227 // static |
| 209 AudioManager* AudioManager::Get() { | 228 AudioManager* AudioManager::Get() { |
| 210 return g_last_created; | 229 return g_last_created; |
| 211 } | 230 } |
| 212 | 231 |
| 213 } // namespace media | 232 } // namespace media |
| OLD | NEW |