Gary Morain | 43bc627 | 2012-01-30 14:01:15 -0800 | [diff] [blame] | 1 | // Copyright (c) 2012 The Chromium OS Authors. All rights reserved. |
| 2 | // Use of this source code is governed by a BSD-style license that can be |
| 3 | // found in the LICENSE file. |
| 4 | |
| 5 | #include "shill/power_manager.h" |
| 6 | |
| 7 | #include <map> |
| 8 | #include <string> |
| 9 | |
Eric Shienbrood | 3e20a23 | 2012-02-16 11:35:56 -0500 | [diff] [blame] | 10 | #include <base/stl_util.h> |
Gary Morain | 43bc627 | 2012-01-30 14:01:15 -0800 | [diff] [blame] | 11 | |
Darin Petkov | 3ec5534 | 2012-09-28 14:04:44 +0200 | [diff] [blame] | 12 | #include "shill/event_dispatcher.h" |
Christopher Wiley | b691efd | 2012-08-09 13:51:51 -0700 | [diff] [blame] | 13 | #include "shill/logging.h" |
Gary Morain | 43bc627 | 2012-01-30 14:01:15 -0800 | [diff] [blame] | 14 | #include "shill/power_manager_proxy_interface.h" |
| 15 | #include "shill/proxy_factory.h" |
| 16 | |
Gary Morain | 52fabab | 2012-08-22 09:27:31 -0700 | [diff] [blame] | 17 | using std::map; |
Gary Morain | 43bc627 | 2012-01-30 14:01:15 -0800 | [diff] [blame] | 18 | using std::string; |
| 19 | |
| 20 | namespace shill { |
| 21 | |
Darin Petkov | 3ec5534 | 2012-09-28 14:04:44 +0200 | [diff] [blame] | 22 | const int PowerManager::kSuspendTimeoutMilliseconds = 15 * 1000; |
| 23 | |
| 24 | PowerManager::PowerManager(EventDispatcher *dispatcher, |
| 25 | ProxyFactory *proxy_factory) |
| 26 | : dispatcher_(dispatcher), |
| 27 | power_manager_proxy_(proxy_factory->CreatePowerManagerProxy(this)), |
Darin Petkov | ca62154 | 2012-07-25 14:25:56 +0200 | [diff] [blame] | 28 | power_state_(kUnknown) {} |
Gary Morain | 43bc627 | 2012-01-30 14:01:15 -0800 | [diff] [blame] | 29 | |
| 30 | PowerManager::~PowerManager() { |
Gary Morain | 43bc627 | 2012-01-30 14:01:15 -0800 | [diff] [blame] | 31 | } |
| 32 | |
| 33 | void PowerManager::AddStateChangeCallback(const string &key, |
Eric Shienbrood | 3e20a23 | 2012-02-16 11:35:56 -0500 | [diff] [blame] | 34 | const PowerStateCallback &callback) { |
Ben Chan | fad4a0b | 2012-04-18 15:49:59 -0700 | [diff] [blame] | 35 | SLOG(Power, 2) << __func__ << " key " << key; |
Gary Morain | 52fabab | 2012-08-22 09:27:31 -0700 | [diff] [blame] | 36 | AddCallback(key, callback, &state_change_callbacks_); |
| 37 | } |
| 38 | |
| 39 | void PowerManager::AddSuspendDelayCallback( |
| 40 | const string &key, const SuspendDelayCallback &callback) { |
| 41 | SLOG(Power, 2) << __func__ << " key " << key; |
| 42 | AddCallback(key, callback, &suspend_delay_callbacks_); |
Gary Morain | 43bc627 | 2012-01-30 14:01:15 -0800 | [diff] [blame] | 43 | } |
| 44 | |
| 45 | void PowerManager::RemoveStateChangeCallback(const string &key) { |
Ben Chan | fad4a0b | 2012-04-18 15:49:59 -0700 | [diff] [blame] | 46 | SLOG(Power, 2) << __func__ << " key " << key; |
Gary Morain | 52fabab | 2012-08-22 09:27:31 -0700 | [diff] [blame] | 47 | RemoveCallback(key, &state_change_callbacks_); |
Gary Morain | 43bc627 | 2012-01-30 14:01:15 -0800 | [diff] [blame] | 48 | } |
| 49 | |
Gary Morain | 52fabab | 2012-08-22 09:27:31 -0700 | [diff] [blame] | 50 | void PowerManager::RemoveSuspendDelayCallback(const string &key) { |
| 51 | SLOG(Power, 2) << __func__ << " key " << key; |
| 52 | RemoveCallback(key, &suspend_delay_callbacks_); |
| 53 | } |
| 54 | |
| 55 | void PowerManager::OnSuspendDelay(uint32 sequence_number) { |
Darin Petkov | 3ec5534 | 2012-09-28 14:04:44 +0200 | [diff] [blame] | 56 | LOG(INFO) << __func__ << "(" << sequence_number << ")"; |
| 57 | // Change the power state to suspending as soon as this signal is received so |
| 58 | // that the manager can suppress auto-connect, for example. Schedules a |
| 59 | // suspend timeout in case the suspend attempt failed or got interrupted, and |
| 60 | // there's no proper notification from the power manager. |
| 61 | power_state_ = kSuspending; |
| 62 | suspend_timeout_.Reset( |
| 63 | base::Bind(&PowerManager::OnSuspendTimeout, base::Unretained(this))); |
| 64 | dispatcher_->PostDelayedTask(suspend_timeout_.callback(), |
| 65 | kSuspendTimeoutMilliseconds); |
Gary Morain | 52fabab | 2012-08-22 09:27:31 -0700 | [diff] [blame] | 66 | OnEvent(sequence_number, &suspend_delay_callbacks_); |
Gary Morain | 43bc627 | 2012-01-30 14:01:15 -0800 | [diff] [blame] | 67 | } |
| 68 | |
| 69 | void PowerManager::OnPowerStateChanged(SuspendState new_power_state) { |
Darin Petkov | ca62154 | 2012-07-25 14:25:56 +0200 | [diff] [blame] | 70 | LOG(INFO) << "Power state changed: " |
| 71 | << power_state_ << "->" << new_power_state; |
Darin Petkov | 3ec5534 | 2012-09-28 14:04:44 +0200 | [diff] [blame] | 72 | suspend_timeout_.Cancel(); |
Darin Petkov | ca62154 | 2012-07-25 14:25:56 +0200 | [diff] [blame] | 73 | power_state_ = new_power_state; |
Gary Morain | 52fabab | 2012-08-22 09:27:31 -0700 | [diff] [blame] | 74 | OnEvent(new_power_state, &state_change_callbacks_); |
| 75 | } |
| 76 | |
Darin Petkov | 3ec5534 | 2012-09-28 14:04:44 +0200 | [diff] [blame] | 77 | void PowerManager::RegisterSuspendDelay(uint32 delay_ms) { |
Gary Morain | 52fabab | 2012-08-22 09:27:31 -0700 | [diff] [blame] | 78 | power_manager_proxy_->RegisterSuspendDelay(delay_ms); |
| 79 | } |
| 80 | |
Darin Petkov | 3ec5534 | 2012-09-28 14:04:44 +0200 | [diff] [blame] | 81 | void PowerManager::UnregisterSuspendDelay() { |
| 82 | power_manager_proxy_->UnregisterSuspendDelay(); |
| 83 | } |
| 84 | |
| 85 | void PowerManager::SuspendReady(uint32 sequence_number) { |
| 86 | power_manager_proxy_->SuspendReady(sequence_number); |
| 87 | } |
| 88 | |
| 89 | void PowerManager::OnSuspendTimeout() { |
| 90 | LOG(ERROR) << "Suspend timed out -- assuming power-on state."; |
| 91 | OnPowerStateChanged(kOn); |
| 92 | } |
| 93 | |
Gary Morain | 52fabab | 2012-08-22 09:27:31 -0700 | [diff] [blame] | 94 | template<class Callback> |
| 95 | void PowerManager::AddCallback(const string &key, const Callback &callback, |
| 96 | map<const string, Callback> *callback_map) { |
| 97 | CHECK(callback_map != NULL); |
| 98 | CHECK(!callback.is_null()); |
| 99 | if (ContainsKey(*callback_map, key)) { |
| 100 | LOG(DFATAL) << "Inserting duplicate key " << key; |
| 101 | LOG(INFO) << "Removing previous callback for key " << key; |
| 102 | RemoveCallback(key, callback_map); |
| 103 | } |
| 104 | (*callback_map)[key] = callback; |
| 105 | } |
| 106 | |
| 107 | template<class Callback> |
| 108 | void PowerManager::RemoveCallback(const string &key, |
| 109 | map<const string, Callback> *callback_map) { |
| 110 | CHECK(callback_map != NULL); |
| 111 | DCHECK(ContainsKey(*callback_map, key)) << "Removing unknown key " << key; |
| 112 | typename map<const std::string, Callback>::iterator it = |
| 113 | callback_map->find(key); |
| 114 | if (it != callback_map->end()) { |
| 115 | callback_map->erase(it); |
Gary Morain | 43bc627 | 2012-01-30 14:01:15 -0800 | [diff] [blame] | 116 | } |
| 117 | } |
| 118 | |
Gary Morain | 52fabab | 2012-08-22 09:27:31 -0700 | [diff] [blame] | 119 | template<class Param, class Callback> |
| 120 | void PowerManager::OnEvent(const Param ¶m, |
| 121 | map<const string, Callback> *callback_map) const { |
| 122 | CHECK(callback_map != NULL); |
| 123 | for (typename map<const string, Callback>::const_iterator it = |
| 124 | callback_map->begin(); |
| 125 | it != callback_map->end(); ++it) { |
| 126 | CHECK(!it->second.is_null()); |
| 127 | it->second.Run(param); |
| 128 | } |
Gary Morain | 43bc627 | 2012-01-30 14:01:15 -0800 | [diff] [blame] | 129 | } |
| 130 | |
Gary Morain | 52fabab | 2012-08-22 09:27:31 -0700 | [diff] [blame] | 131 | |
| 132 | |
Gary Morain | 43bc627 | 2012-01-30 14:01:15 -0800 | [diff] [blame] | 133 | } // namespace shill |