OLD | NEW |
1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2013 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 "chrome/browser/chromeos/system/automatic_reboot_manager.h" | 5 #include "chrome/browser/chromeos/system/automatic_reboot_manager.h" |
6 | 6 |
7 #include <fcntl.h> | 7 #include <fcntl.h> |
8 #include <sys/stat.h> | 8 #include <sys/stat.h> |
9 #include <sys/types.h> | 9 #include <sys/types.h> |
10 | 10 |
11 #include <algorithm> | 11 #include <algorithm> |
12 #include <string> | 12 #include <string> |
13 | 13 |
14 #include "ash/shell.h" | |
15 #include "base/bind.h" | 14 #include "base/bind.h" |
16 #include "base/bind_helpers.h" | 15 #include "base/bind_helpers.h" |
17 #include "base/callback.h" | 16 #include "base/callback.h" |
18 #include "base/files/file_path.h" | 17 #include "base/files/file_path.h" |
19 #include "base/files/file_util.h" | 18 #include "base/files/file_util.h" |
20 #include "base/files/scoped_file.h" | 19 #include "base/files/scoped_file.h" |
21 #include "base/location.h" | 20 #include "base/location.h" |
22 #include "base/logging.h" | 21 #include "base/logging.h" |
23 #include "base/memory/ref_counted.h" | 22 #include "base/memory/ref_counted.h" |
24 #include "base/path_service.h" | 23 #include "base/path_service.h" |
(...skipping 140 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
165 content::NotificationService::AllSources()); | 164 content::NotificationService::AllSources()); |
166 | 165 |
167 DBusThreadManager* dbus_thread_manager = DBusThreadManager::Get(); | 166 DBusThreadManager* dbus_thread_manager = DBusThreadManager::Get(); |
168 dbus_thread_manager->GetPowerManagerClient()->AddObserver(this); | 167 dbus_thread_manager->GetPowerManagerClient()->AddObserver(this); |
169 dbus_thread_manager->GetUpdateEngineClient()->AddObserver(this); | 168 dbus_thread_manager->GetUpdateEngineClient()->AddObserver(this); |
170 | 169 |
171 // If no user is logged in, a reboot may be performed whenever the user is | 170 // If no user is logged in, a reboot may be performed whenever the user is |
172 // idle. Start listening for user activity to determine whether the user is | 171 // idle. Start listening for user activity to determine whether the user is |
173 // idle or not. | 172 // idle or not. |
174 if (!user_manager::UserManager::Get()->IsUserLoggedIn()) { | 173 if (!user_manager::UserManager::Get()->IsUserLoggedIn()) { |
175 if (ash::Shell::HasInstance()) | 174 if (wm::UserActivityDetector::Get()) |
176 ash::Shell::GetInstance()->user_activity_detector()->AddObserver(this); | 175 wm::UserActivityDetector::Get()->AddObserver(this); |
177 notification_registrar_.Add(this, chrome::NOTIFICATION_LOGIN_USER_CHANGED, | 176 notification_registrar_.Add(this, chrome::NOTIFICATION_LOGIN_USER_CHANGED, |
178 content::NotificationService::AllSources()); | 177 content::NotificationService::AllSources()); |
179 login_screen_idle_timer_.reset( | 178 login_screen_idle_timer_.reset( |
180 new base::OneShotTimer<AutomaticRebootManager>); | 179 new base::OneShotTimer<AutomaticRebootManager>); |
181 OnUserActivity(NULL); | 180 OnUserActivity(NULL); |
182 } | 181 } |
183 | 182 |
184 // In a regular browser, base::ThreadTaskRunnerHandle::Get() and | 183 // In a regular browser, base::ThreadTaskRunnerHandle::Get() and |
185 // base::MessageLoopProxy::current() return pointers to the same object. | 184 // base::MessageLoopProxy::current() return pointers to the same object. |
186 // In unit tests, using base::ThreadTaskRunnerHandle::Get() has the advantage | 185 // In unit tests, using base::ThreadTaskRunnerHandle::Get() has the advantage |
187 // that it allows a custom base::SingleThreadTaskRunner to be injected. | 186 // that it allows a custom base::SingleThreadTaskRunner to be injected. |
188 content::BrowserThread::GetBlockingPool()->PostWorkerTaskWithShutdownBehavior( | 187 content::BrowserThread::GetBlockingPool()->PostWorkerTaskWithShutdownBehavior( |
189 FROM_HERE, | 188 FROM_HERE, |
190 base::Bind(&GetSystemEventTimes, | 189 base::Bind(&GetSystemEventTimes, |
191 base::ThreadTaskRunnerHandle::Get(), | 190 base::ThreadTaskRunnerHandle::Get(), |
192 base::Bind(&AutomaticRebootManager::Init, | 191 base::Bind(&AutomaticRebootManager::Init, |
193 weak_ptr_factory_.GetWeakPtr())), | 192 weak_ptr_factory_.GetWeakPtr())), |
194 base::SequencedWorkerPool::SKIP_ON_SHUTDOWN); | 193 base::SequencedWorkerPool::SKIP_ON_SHUTDOWN); |
195 } | 194 } |
196 | 195 |
197 AutomaticRebootManager::~AutomaticRebootManager() { | 196 AutomaticRebootManager::~AutomaticRebootManager() { |
198 FOR_EACH_OBSERVER(AutomaticRebootManagerObserver, | 197 FOR_EACH_OBSERVER(AutomaticRebootManagerObserver, |
199 observers_, | 198 observers_, |
200 WillDestroyAutomaticRebootManager()); | 199 WillDestroyAutomaticRebootManager()); |
201 | 200 |
202 DBusThreadManager* dbus_thread_manager = DBusThreadManager::Get(); | 201 DBusThreadManager* dbus_thread_manager = DBusThreadManager::Get(); |
203 dbus_thread_manager->GetPowerManagerClient()->RemoveObserver(this); | 202 dbus_thread_manager->GetPowerManagerClient()->RemoveObserver(this); |
204 dbus_thread_manager->GetUpdateEngineClient()->RemoveObserver(this); | 203 dbus_thread_manager->GetUpdateEngineClient()->RemoveObserver(this); |
205 if (ash::Shell::HasInstance()) | 204 if (wm::UserActivityDetector::Get()) |
206 ash::Shell::GetInstance()->user_activity_detector()->RemoveObserver(this); | 205 wm::UserActivityDetector::Get()->RemoveObserver(this); |
207 } | 206 } |
208 | 207 |
209 void AutomaticRebootManager::AddObserver( | 208 void AutomaticRebootManager::AddObserver( |
210 AutomaticRebootManagerObserver* observer) { | 209 AutomaticRebootManagerObserver* observer) { |
211 observers_.AddObserver(observer); | 210 observers_.AddObserver(observer); |
212 } | 211 } |
213 | 212 |
214 void AutomaticRebootManager::RemoveObserver( | 213 void AutomaticRebootManager::RemoveObserver( |
215 AutomaticRebootManagerObserver* observer) { | 214 AutomaticRebootManagerObserver* observer) { |
216 observers_.RemoveObserver(observer); | 215 observers_.RemoveObserver(observer); |
(...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
263 const content::NotificationDetails& details) { | 262 const content::NotificationDetails& details) { |
264 if (type == chrome::NOTIFICATION_APP_TERMINATING) { | 263 if (type == chrome::NOTIFICATION_APP_TERMINATING) { |
265 if (user_manager::UserManager::Get()->IsUserLoggedIn()) { | 264 if (user_manager::UserManager::Get()->IsUserLoggedIn()) { |
266 // The browser is terminating during a session, either because the session | 265 // The browser is terminating during a session, either because the session |
267 // is ending or because the browser is being restarted. | 266 // is ending or because the browser is being restarted. |
268 MaybeReboot(true); | 267 MaybeReboot(true); |
269 } | 268 } |
270 } else if (type == chrome::NOTIFICATION_LOGIN_USER_CHANGED) { | 269 } else if (type == chrome::NOTIFICATION_LOGIN_USER_CHANGED) { |
271 // A session is starting. Stop listening for user activity as it no longer | 270 // A session is starting. Stop listening for user activity as it no longer |
272 // is a relevant criterion. | 271 // is a relevant criterion. |
273 if (ash::Shell::HasInstance()) | 272 if (wm::UserActivityDetector::Get()) |
274 ash::Shell::GetInstance()->user_activity_detector()->RemoveObserver(this); | 273 wm::UserActivityDetector::Get()->RemoveObserver(this); |
275 notification_registrar_.Remove( | 274 notification_registrar_.Remove( |
276 this, chrome::NOTIFICATION_LOGIN_USER_CHANGED, | 275 this, chrome::NOTIFICATION_LOGIN_USER_CHANGED, |
277 content::NotificationService::AllSources()); | 276 content::NotificationService::AllSources()); |
278 login_screen_idle_timer_.reset(); | 277 login_screen_idle_timer_.reset(); |
279 } else { | 278 } else { |
280 NOTREACHED(); | 279 NOTREACHED(); |
281 } | 280 } |
282 } | 281 } |
283 | 282 |
284 // static | 283 // static |
(...skipping 125 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
410 } | 409 } |
411 | 410 |
412 login_screen_idle_timer_.reset(); | 411 login_screen_idle_timer_.reset(); |
413 grace_start_timer_.reset(); | 412 grace_start_timer_.reset(); |
414 grace_end_timer_.reset(); | 413 grace_end_timer_.reset(); |
415 DBusThreadManager::Get()->GetPowerManagerClient()->RequestRestart(); | 414 DBusThreadManager::Get()->GetPowerManagerClient()->RequestRestart(); |
416 } | 415 } |
417 | 416 |
418 } // namespace system | 417 } // namespace system |
419 } // namespace chromeos | 418 } // namespace chromeos |
OLD | NEW |