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/debug/alias.h" | 10 #include "base/debug/alias.h" |
10 #include "base/lazy_instance.h" | 11 #include "base/lazy_instance.h" |
11 #include "base/logging.h" | 12 #include "base/logging.h" |
12 #include "base/message_loop/message_loop.h" | 13 #include "base/message_loop/message_loop.h" |
13 #include "base/power_monitor/power_monitor.h" | 14 #include "base/power_monitor/power_monitor.h" |
14 #include "base/synchronization/waitable_event.h" | 15 #include "base/synchronization/waitable_event.h" |
15 #include "build/build_config.h" | 16 #include "build/build_config.h" |
16 #include "media/audio/fake_audio_log_factory.h" | 17 #include "media/audio/fake_audio_log_factory.h" |
| 18 #include "media/base/media_switches.h" |
17 | 19 |
18 namespace media { | 20 namespace media { |
19 namespace { | 21 namespace { |
20 AudioManager* g_last_created = NULL; | 22 AudioManager* g_last_created = NULL; |
21 | 23 |
22 // Maximum number of failed pings to the audio thread allowed. A crash will be | 24 // Maximum number of failed pings to the audio thread allowed. A crash will be |
23 // issued once this count is reached. We require at least two pings before | 25 // issued once this count is reached. We require at least two pings before |
24 // crashing to ensure unobservable power events aren't mistakenly caught (e.g., | 26 // crashing to ensure unobservable power events aren't mistakenly caught (e.g., |
25 // the system suspends before a OnSuspend() event can be fired.). | 27 // the system suspends before a OnSuspend() event can be fired.). |
26 const int kMaxHangFailureCount = 2; | 28 const int kMaxHangFailureCount = 2; |
(...skipping 88 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
115 scoped_refptr<base::SingleThreadTaskRunner> monitor_task_runner_; | 117 scoped_refptr<base::SingleThreadTaskRunner> monitor_task_runner_; |
116 | 118 |
117 base::Lock hang_lock_; | 119 base::Lock hang_lock_; |
118 bool hang_detection_enabled_; | 120 bool hang_detection_enabled_; |
119 base::TimeTicks last_audio_thread_timer_tick_; | 121 base::TimeTicks last_audio_thread_timer_tick_; |
120 int hang_failures_; | 122 int hang_failures_; |
121 | 123 |
122 DISALLOW_COPY_AND_ASSIGN(AudioManagerHelper); | 124 DISALLOW_COPY_AND_ASSIGN(AudioManagerHelper); |
123 }; | 125 }; |
124 | 126 |
| 127 static bool g_hang_monitor_enabled = false; |
| 128 |
125 static base::LazyInstance<AudioManagerHelper>::Leaky g_helper = | 129 static base::LazyInstance<AudioManagerHelper>::Leaky g_helper = |
126 LAZY_INSTANCE_INITIALIZER; | 130 LAZY_INSTANCE_INITIALIZER; |
127 } | 131 } |
128 | 132 |
129 // Forward declaration of the platform specific AudioManager factory function. | 133 // Forward declaration of the platform specific AudioManager factory function. |
130 AudioManager* CreateAudioManager(AudioLogFactory* audio_log_factory); | 134 AudioManager* CreateAudioManager(AudioLogFactory* audio_log_factory); |
131 | 135 |
132 AudioManager::AudioManager() {} | 136 AudioManager::AudioManager() {} |
133 | 137 |
134 AudioManager::~AudioManager() { | 138 AudioManager::~AudioManager() { |
135 CHECK(!g_last_created || g_last_created == this); | 139 CHECK(!g_last_created || g_last_created == this); |
136 g_last_created = NULL; | 140 g_last_created = NULL; |
137 } | 141 } |
138 | 142 |
139 // static | 143 // static |
140 AudioManager* AudioManager::Create(AudioLogFactory* audio_log_factory) { | 144 AudioManager* AudioManager::Create(AudioLogFactory* audio_log_factory) { |
141 CHECK(!g_last_created); | 145 CHECK(!g_last_created); |
142 g_last_created = CreateAudioManager(audio_log_factory); | 146 g_last_created = CreateAudioManager(audio_log_factory); |
143 return g_last_created; | 147 return g_last_created; |
144 } | 148 } |
145 | 149 |
146 // static | 150 // static |
147 AudioManager* AudioManager::CreateWithHangTimer( | 151 AudioManager* AudioManager::CreateWithHangTimer( |
148 AudioLogFactory* audio_log_factory, | 152 AudioLogFactory* audio_log_factory, |
149 const scoped_refptr<base::SingleThreadTaskRunner>& monitor_task_runner) { | 153 const scoped_refptr<base::SingleThreadTaskRunner>& monitor_task_runner) { |
150 AudioManager* manager = Create(audio_log_factory); | 154 AudioManager* manager = Create(audio_log_factory); |
151 // On OSX the audio thread is the UI thread, for which a hang monitor is not | 155 if (g_hang_monitor_enabled || |
152 // necessary. | 156 base::CommandLine::ForCurrentProcess()->HasSwitch( |
153 #if !defined(OS_MACOSX) | 157 switches::kEnableAudioHangMonitor)) { |
154 g_helper.Pointer()->StartHangTimer(monitor_task_runner); | 158 g_helper.Pointer()->StartHangTimer(monitor_task_runner); |
155 #endif | 159 } |
156 return manager; | 160 return manager; |
157 } | 161 } |
158 | 162 |
159 // static | 163 // static |
160 AudioManager* AudioManager::CreateForTesting() { | 164 AudioManager* AudioManager::CreateForTesting() { |
161 AudioManager* manager = Create(g_helper.Pointer()->fake_log_factory()); | 165 AudioManager* manager = Create(g_helper.Pointer()->fake_log_factory()); |
162 | 166 |
163 // When created for testing, always ensure all methods are ready to run (even | 167 // When created for testing, always ensure all methods are ready to run (even |
164 // if they end up called from other threads. | 168 // if they end up called from other threads. |
165 if (!manager->GetTaskRunner()->BelongsToCurrentThread()) { | 169 if (!manager->GetTaskRunner()->BelongsToCurrentThread()) { |
166 base::WaitableEvent event(false, false); | 170 base::WaitableEvent event(false, false); |
167 manager->GetTaskRunner()->PostTask( | 171 manager->GetTaskRunner()->PostTask( |
168 FROM_HERE, | 172 FROM_HERE, |
169 base::Bind(&base::WaitableEvent::Signal, base::Unretained(&event))); | 173 base::Bind(&base::WaitableEvent::Signal, base::Unretained(&event))); |
170 event.Wait(); | 174 event.Wait(); |
171 } | 175 } |
172 | 176 |
173 return manager; | 177 return manager; |
174 } | 178 } |
175 | 179 |
176 // static | 180 // static |
| 181 void AudioManager::EnableHangMonitor() { |
| 182 CHECK(!g_last_created); |
| 183 // On OSX the audio thread is the UI thread, for which a hang monitor is not |
| 184 // necessary or recommended. If it's manually requested, we should allow it |
| 185 // to start though. |
| 186 #if !defined(OS_MACOSX) |
| 187 g_hang_monitor_enabled = true; |
| 188 #endif |
| 189 } |
| 190 |
| 191 // static |
177 AudioManager* AudioManager::Get() { | 192 AudioManager* AudioManager::Get() { |
178 return g_last_created; | 193 return g_last_created; |
179 } | 194 } |
180 | 195 |
181 } // namespace media | 196 } // namespace media |
OLD | NEW |