Google Git
Sign in
cos / mirrors / cros / chromiumos / platform2 / refs/heads/stabilize-6812.34.B / . / power_manager / powerd / daemon.cc
blob: 7d14f49b5619eb347c50622c7f752301e5c071c4 [file] [log] [blame]
// Copyright (c) 2012 The Chromium OS Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "power_manager/powerd/daemon.h"
#include <algorithm>
#include <cmath>
#include <base/bind.h>
#include <base/files/file_util.h>
#include <base/format_macros.h>
#include <base/logging.h>
#include <base/strings/string_number_conversions.h>
#include <base/strings/string_util.h>
#include <base/strings/stringprintf.h>
#include <chromeos/dbus/service_constants.h>
#include <metrics/metrics_library.h>
#include "cryptohome/proto_bindings/rpc.pb.h"
#include "power_manager/common/dbus_sender.h"
#include "power_manager/common/metrics_sender.h"
#include "power_manager/common/power_constants.h"
#include "power_manager/common/prefs.h"
#include "power_manager/common/util.h"
#include "power_manager/powerd/metrics_collector.h"
#include "power_manager/powerd/policy/external_backlight_controller.h"
#include "power_manager/powerd/policy/internal_backlight_controller.h"
#include "power_manager/powerd/policy/keyboard_backlight_controller.h"
#include "power_manager/powerd/policy/state_controller.h"
#include "power_manager/powerd/policy/wakeup_controller.h"
#include "power_manager/powerd/system/acpi_wakeup_helper.h"
#include "power_manager/powerd/system/ambient_light_sensor.h"
#include "power_manager/powerd/system/audio_client.h"
#include "power_manager/powerd/system/dark_resume.h"
#include "power_manager/powerd/system/display/display_power_setter.h"
#include "power_manager/powerd/system/display/display_watcher.h"
#include "power_manager/powerd/system/event_device.h"
#include "power_manager/powerd/system/input_watcher.h"
#include "power_manager/powerd/system/internal_backlight.h"
#include "power_manager/powerd/system/peripheral_battery_watcher.h"
#include "power_manager/powerd/system/power_supply.h"
#include "power_manager/powerd/system/udev.h"
#include "power_manager/proto_bindings/policy.pb.h"
#include "power_manager/proto_bindings/power_supply_properties.pb.h"
namespace power_manager {
namespace {
// Path to file that's touched before the system suspends and unlinked
// after it resumes. Used by crash-reporter to avoid reporting unclean
// shutdowns that occur while the system is suspended (i.e. probably due to
// the battery charge reaching zero).
const char kSuspendedStatePath[] = "/var/lib/power_manager/powerd_suspended";
// Basename appended to |run_dir| (see Daemon's c'tor) to produce
// |suspend_announced_path_|.
const char kSuspendAnnouncedFile[] = "suspend_announced";
// Strings for states that powerd cares about from the session manager's
// SessionStateChanged signal.
const char kSessionStarted[] = "started";
// Path containing the number of wakeup events.
const char kWakeupCountPath[] = "/sys/power/wakeup_count";
// Program used to run code as root.
const char kSetuidHelperPath[] = "/usr/bin/powerd_setuid_helper";
// File that's created once the out-of-box experience has been completed.
const char kOobeCompletedPath[] = "/home/chronos/.oobe_completed";
// File where flashrom's PID is stored while flashrom is performing a
// potentially-destructive action that powerd shouldn't interrupt by suspending
// or shutting down the system.
const char kFlashromLockPath[] = "/var/lock/flashrom_powerd.lock";
// Interval between attempts to retry shutting the system down while
// kFlashromLockPath exists, in seconds.
const int kRetryShutdownForFlashromSec = 5;
// Maximum amount of time to wait for responses to D-Bus method calls to other
// processes.
const int kSessionManagerDBusTimeoutMs = 3000;
const int kUpdateEngineDBusTimeoutMs = 3000;
const int kCryptohomedDBusTimeoutMs = 2 * 60 * 1000; // Two minutes.
// If we go from a dark resume directly to a full resume several devices will be
// left in an awkward state. This won't be a problem once selective resume is
// ready but until then we need to fake it by using the pm_test mechanism to
// make sure all the drivers go through the proper resume path.
// TODO(chirantan): Remove these once selective resume is ready.
const char kPMTestPath[] = "/sys/power/pm_test";
const char kPMTestDevices[] = "devices";
const char kPMTestNone[] = "none";
const char kPowerStatePath[] = "/sys/power/state";
const char kPowerStateMem[] = "mem";
// TODO(chirantan): We use the existence of this file to determine if the system
// can safely exit dark resume. However, this file will go away once selective
// resume lands, at which point we are probably going to have to use a pref file
// instead.
const char kPMTestDelayPath[] = "/sys/power/pm_test_delay";
// Exits dark resume so that we can transition to fully resumed. Returns true
// if the transititon was successful.
bool ExitDarkResume() {
LOG(INFO) << "Transitioning from dark resume to fully resumed.";
// Set up the pm_test down to devices level.
if (!util::WriteFileFully(base::FilePath(kPMTestPath),
kPMTestDevices,
strlen(kPMTestDevices))) {
PLOG(ERROR) << "Unable to set up the pm_test level to properly exit dark "
<< "resume.";
return false;
}
// Do the pm_test suspend.
if (!util::WriteFileFully(base::FilePath(kPowerStatePath),
kPowerStateMem,
strlen(kPowerStateMem))) {
PLOG(ERROR) << "Error while performing a pm_test suspend to exit dark "
<< "resume";
return false;
}
// Turn off pm_test so that we do a regular suspend next time.
if (!util::WriteFileFully(base::FilePath(kPMTestPath),
kPMTestNone,
strlen(kPMTestNone))) {
PLOG(ERROR) << "Unable to restore pm_test level after attempting to exit "
<< "dark resume.";
return false;
}
return true;
}
// Passes |method_call| to |handler| and passes the response to
// |response_sender|. If |handler| returns NULL, an empty response is created
// and sent.
void HandleSynchronousDBusMethodCall(
base::Callback<scoped_ptr<dbus::Response>(dbus::MethodCall*)> handler,
dbus::MethodCall* method_call,
dbus::ExportedObject::ResponseSender response_sender) {
scoped_ptr<dbus::Response> response = handler.Run(method_call);
if (!response)
response = dbus::Response::FromMethodCall(method_call);
response_sender.Run(response.Pass());
}
// Creates a new "not supported" reply to |method_call|.
scoped_ptr<dbus::Response> CreateNotSupportedError(
dbus::MethodCall* method_call,
std::string message) {
return scoped_ptr<dbus::Response>(
dbus::ErrorResponse::FromMethodCall(
method_call, DBUS_ERROR_NOT_SUPPORTED, message));
}
// Creates a new "invalid args" reply to |method_call|.
scoped_ptr<dbus::Response> CreateInvalidArgsError(
dbus::MethodCall* method_call,
std::string message) {
return scoped_ptr<dbus::Response>(
dbus::ErrorResponse::FromMethodCall(
method_call, DBUS_ERROR_INVALID_ARGS, message));
}
// Runs powerd_setuid_helper. |action| is passed via --action. If
// |additional_args| is non-empty, it will be appended to the command. If
// |wait_for_completion| is true, this function will block until the helper
// finishes and return the helper's exit code; otherwise it will return 0
// immediately.
int RunSetuidHelper(const std::string& action,
const std::string& additional_args,
bool wait_for_completion) {
std::string command = kSetuidHelperPath + std::string(" --action=" + action);
if (!additional_args.empty())
command += " " + additional_args;
if (wait_for_completion) {
return util::Run(command.c_str());
} else {
util::Launch(command.c_str());
return 0;
}
}
// Returns true if flashrom's PID file exists and contains a valid PID.
bool FlashromIsRunning() {
std::string pid;
if (!base::ReadFileToString(base::FilePath(kFlashromLockPath), &pid))
return false;
base::TrimWhitespaceASCII(pid, base::TRIM_TRAILING, &pid);
if (!base::DirectoryExists(base::FilePath("/proc").Append(pid))) {
LOG(WARNING) << kFlashromLockPath << " contains stale/invalid PID "
<< "\"" << pid << "\"";
return false;
}
return true;
}
} // namespace
// Performs actions requested by |state_controller_|. The reason that
// this is a nested class of Daemon rather than just being implemented as
// part of Daemon is to avoid method naming conflicts.
class Daemon::StateControllerDelegate
: public policy::StateController::Delegate {
public:
explicit StateControllerDelegate(Daemon* daemon) : daemon_(daemon) {}
virtual ~StateControllerDelegate() {
daemon_ = NULL;
}
// Overridden from policy::StateController::Delegate:
bool IsUsbInputDeviceConnected() override {
return daemon_->input_watcher_->IsUSBInputDeviceConnected();
}
bool IsOobeCompleted() override {
return base::PathExists(base::FilePath(kOobeCompletedPath));
}
bool IsHdmiAudioActive() override {
return daemon_->audio_client_ ?
daemon_->audio_client_->hdmi_active() : false;
}
bool IsHeadphoneJackPlugged() override {
return daemon_->audio_client_ ?
daemon_->audio_client_->headphone_jack_plugged() : false;
}
LidState QueryLidState() override {
return daemon_->input_watcher_->QueryLidState();
}
void DimScreen() override {
daemon_->SetBacklightsDimmedForInactivity(true);
}
void UndimScreen() override {
daemon_->SetBacklightsDimmedForInactivity(false);
}
void TurnScreenOff() override {
daemon_->SetBacklightsOffForInactivity(true);
}
void TurnScreenOn() override {
daemon_->SetBacklightsOffForInactivity(false);
}
void LockScreen() override {
dbus::MethodCall method_call(
login_manager::kSessionManagerInterface,
login_manager::kSessionManagerLockScreen);
scoped_ptr<dbus::Response> response(
daemon_->session_manager_dbus_proxy_->CallMethodAndBlock(
&method_call, kSessionManagerDBusTimeoutMs));
}
void Suspend() override {
daemon_->Suspend(false, 0);
}
void StopSession() override {
// This session manager method takes a string argument, although it
// doesn't currently do anything with it.
dbus::MethodCall method_call(
login_manager::kSessionManagerInterface,
login_manager::kSessionManagerStopSession);
dbus::MessageWriter writer(&method_call);
writer.AppendString("");
scoped_ptr<dbus::Response> response(
daemon_->session_manager_dbus_proxy_->CallMethodAndBlock(
&method_call, kSessionManagerDBusTimeoutMs));
}
void ShutDown() override {
daemon_->ShutDown(SHUTDOWN_MODE_POWER_OFF,
SHUTDOWN_REASON_STATE_TRANSITION);
}
void UpdatePanelForDockedMode(bool docked) override {
daemon_->SetBacklightsDocked(docked);
}
void EmitIdleActionImminent(
base::TimeDelta time_until_idle_action) override {
IdleActionImminent proto;
proto.set_time_until_idle_action(time_until_idle_action.ToInternalValue());
daemon_->dbus_sender_->EmitSignalWithProtocolBuffer(
kIdleActionImminentSignal, proto);
}
void EmitIdleActionDeferred() override {
daemon_->dbus_sender_->EmitBareSignal(kIdleActionDeferredSignal);
}
void ReportUserActivityMetrics() override {
daemon_->metrics_collector_->GenerateUserActivityMetrics();
}
private:
Daemon* daemon_; // weak
DISALLOW_COPY_AND_ASSIGN(StateControllerDelegate);
};
Daemon::Daemon(const base::FilePath& read_write_prefs_dir,
const base::FilePath& read_only_prefs_dir,
const base::FilePath& run_dir)
: prefs_(new Prefs),
powerd_dbus_object_(NULL),
chrome_dbus_proxy_(NULL),
session_manager_dbus_proxy_(NULL),
cras_dbus_proxy_(NULL),
update_engine_dbus_proxy_(NULL),
cryptohomed_dbus_proxy_(NULL),
state_controller_delegate_(new StateControllerDelegate(this)),
dbus_sender_(new DBusSender),
display_watcher_(new system::DisplayWatcher),
display_power_setter_(new system::DisplayPowerSetter),
udev_(new system::Udev),
input_watcher_(new system::InputWatcher),
state_controller_(new policy::StateController),
input_controller_(new policy::InputController),
acpi_wakeup_helper_(new system::AcpiWakeupHelper),
wakeup_controller_(new policy::WakeupController),
peripheral_battery_watcher_(new system::PeripheralBatteryWatcher),
power_supply_(new system::PowerSupply),
dark_resume_(new system::DarkResume),
suspender_(new policy::Suspender),
metrics_collector_(new MetricsCollector),
shutting_down_(false),
retry_shutdown_for_flashrom_timer_(false /* retain_user_task */,
true /* is_repeating */),
suspend_announced_path_(run_dir.Append(kSuspendAnnouncedFile)),
session_state_(SESSION_STOPPED),
created_suspended_state_file_(false),
lock_vt_before_suspend_(false),
log_suspend_with_mosys_eventlog_(false),
can_safely_exit_dark_resume_(
base::PathExists(base::FilePath(kPMTestDelayPath))),
weak_ptr_factory_(this) {
scoped_ptr<MetricsLibrary> metrics_lib(new MetricsLibrary);
metrics_lib->Init();
metrics_sender_.reset(new MetricsSender(metrics_lib.Pass()));
CHECK(prefs_->Init(util::GetPrefPaths(
base::FilePath(read_write_prefs_dir),
base::FilePath(read_only_prefs_dir))));
power_supply_->AddObserver(this);
if (BoolPrefIsTrue(kUseCrasPref)) {
audio_client_.reset(new system::AudioClient);
audio_client_->AddObserver(this);
}
}
Daemon::~Daemon() {
if (audio_client_)
audio_client_->RemoveObserver(this);
if (display_backlight_controller_)
display_backlight_controller_->RemoveObserver(this);
power_supply_->RemoveObserver(this);
}
void Daemon::Init() {
InitDBus();
CHECK(udev_->Init());
if (BoolPrefIsTrue(kHasAmbientLightSensorPref)) {
light_sensor_.reset(new system::AmbientLightSensor);
light_sensor_->Init();
}
display_watcher_->Init(udev_.get());
display_power_setter_->Init(chrome_dbus_proxy_);
if (BoolPrefIsTrue(kExternalDisplayOnlyPref)) {
display_backlight_controller_.reset(
new policy::ExternalBacklightController);
static_cast<policy::ExternalBacklightController*>(
display_backlight_controller_.get())->Init(display_watcher_.get(),
display_power_setter_.get());
} else {
display_backlight_.reset(new system::InternalBacklight);
if (!display_backlight_->Init(base::FilePath(kInternalBacklightPath),
kInternalBacklightPattern)) {
LOG(ERROR) << "Cannot initialize display backlight";
display_backlight_.reset();
} else {
display_backlight_controller_.reset(
new policy::InternalBacklightController);
static_cast<policy::InternalBacklightController*>(
display_backlight_controller_.get())->Init(
display_backlight_.get(), prefs_.get(), light_sensor_.get(),
display_power_setter_.get());
}
}
if (display_backlight_controller_)
display_backlight_controller_->AddObserver(this);
if (BoolPrefIsTrue(kHasKeyboardBacklightPref)) {
keyboard_backlight_.reset(new system::InternalBacklight);
if (!keyboard_backlight_->Init(base::FilePath(kKeyboardBacklightPath),
kKeyboardBacklightPattern)) {
LOG(ERROR) << "Cannot initialize keyboard backlight";
keyboard_backlight_.reset();
} else {
keyboard_backlight_controller_.reset(
new policy::KeyboardBacklightController);
keyboard_backlight_controller_->Init(
keyboard_backlight_.get(), prefs_.get(), light_sensor_.get(),
display_backlight_controller_.get());
}
}
prefs_->GetBool(kLockVTBeforeSuspendPref, &lock_vt_before_suspend_);
prefs_->GetBool(kMosysEventlogPref, &log_suspend_with_mosys_eventlog_);
power_supply_->Init(base::FilePath(kPowerStatusPath),
prefs_.get(), udev_.get(),
true /* log_shutdown_thresholds */);
if (!power_supply_->RefreshImmediately())
LOG(ERROR) << "Initial power supply refresh failed; brace for weirdness";
const system::PowerStatus power_status = power_supply_->GetPowerStatus();
metrics_collector_->Init(prefs_.get(), display_backlight_controller_.get(),
keyboard_backlight_controller_.get(), power_status);
dark_resume_->Init(power_supply_.get(), prefs_.get());
suspender_->Init(this, dbus_sender_.get(), dark_resume_.get(), prefs_.get());
CHECK(input_watcher_->Init(
scoped_ptr<system::EventDeviceFactoryInterface>(
new system::EventDeviceFactory),
prefs_.get(), udev_.get()));
input_controller_->Init(input_watcher_.get(), this, display_watcher_.get(),
dbus_sender_.get(), prefs_.get());
const LidState lid_state = input_watcher_->QueryLidState();
wakeup_controller_->Init(udev_.get(), acpi_wakeup_helper_.get(), lid_state,
DISPLAY_NORMAL, prefs_.get());
const PowerSource power_source =
power_status.line_power_on ? POWER_AC : POWER_BATTERY;
state_controller_->Init(state_controller_delegate_.get(), prefs_.get(),
power_source, lid_state);
if (audio_client_) {
DCHECK(cras_dbus_proxy_);
audio_client_->Init(cras_dbus_proxy_);
}
peripheral_battery_watcher_->Init(dbus_sender_.get());
// Call this last to ensure that all of our members are already initialized.
OnPowerStatusUpdate();
}
bool Daemon::BoolPrefIsTrue(const std::string& name) const {
bool value = false;
return prefs_->GetBool(name, &value) && value;
}
void Daemon::AdjustKeyboardBrightness(int direction) {
if (!keyboard_backlight_controller_)
return;
if (direction > 0)
keyboard_backlight_controller_->IncreaseUserBrightness();
else if (direction < 0)
keyboard_backlight_controller_->DecreaseUserBrightness(
true /* allow_off */);
}
void Daemon::SendBrightnessChangedSignal(
double brightness_percent,
policy::BacklightController::BrightnessChangeCause cause,
const std::string& signal_name) {
dbus::Signal signal(kPowerManagerInterface, signal_name);
dbus::MessageWriter writer(&signal);
writer.AppendInt32(round(brightness_percent));
writer.AppendBool(cause ==
policy::BacklightController::BRIGHTNESS_CHANGE_USER_INITIATED);
powerd_dbus_object_->SendSignal(&signal);
}
void Daemon::OnBrightnessChanged(
double brightness_percent,
policy::BacklightController::BrightnessChangeCause cause,
policy::BacklightController* source) {
if (source == display_backlight_controller_ &&
display_backlight_controller_) {
SendBrightnessChangedSignal(brightness_percent, cause,
kBrightnessChangedSignal);
} else if (source == keyboard_backlight_controller_.get() &&
keyboard_backlight_controller_) {
SendBrightnessChangedSignal(brightness_percent, cause,
kKeyboardBrightnessChangedSignal);
} else {
NOTREACHED() << "Received a brightness change callback from an unknown "
<< "backlight controller";
}
}
void Daemon::HandleLidClosed() {
LOG(INFO) << "Lid closed";
// It is important that we notify WakeupController first so that it can
// inhibit input devices quickly. StateController will issue a blocking call
// to Chrome which can take longer than a second.
wakeup_controller_->SetLidState(LID_CLOSED);
state_controller_->HandleLidStateChange(LID_CLOSED);
}
void Daemon::HandleLidOpened() {
LOG(INFO) << "Lid opened";
suspender_->HandleLidOpened();
state_controller_->HandleLidStateChange(LID_OPEN);
wakeup_controller_->SetLidState(LID_OPEN);
}
void Daemon::HandlePowerButtonEvent(ButtonState state) {
// Don't log spammy repeat events if we see them.
if (state != BUTTON_REPEAT)
LOG(INFO) << "Power button " << ButtonStateToString(state);
metrics_collector_->HandlePowerButtonEvent(state);
if (state == BUTTON_DOWN && display_backlight_controller_)
display_backlight_controller_->HandlePowerButtonPress();
}
void Daemon::HandleHoverStateChanged(bool hovering) {
LOG(INFO) << "Hovering " << (hovering ? "on" : "off");
if (keyboard_backlight_controller_)
keyboard_backlight_controller_->HandleHoverStateChanged(hovering);
}
void Daemon::DeferInactivityTimeoutForVT2() {
LOG(INFO) << "Reporting synthetic user activity since VT2 is active";
state_controller_->HandleUserActivity();
}
void Daemon::ShutDownForPowerButtonWithNoDisplay() {
LOG(INFO) << "Shutting down due to power button press while no display is "
<< "connected";
metrics_collector_->HandlePowerButtonEvent(BUTTON_DOWN);
ShutDown(SHUTDOWN_MODE_POWER_OFF, SHUTDOWN_REASON_USER_REQUEST);
}
void Daemon::HandleMissingPowerButtonAcknowledgment() {
LOG(INFO) << "Didn't receive power button acknowledgment from Chrome";
util::Launch("sync");
}
void Daemon::ReportPowerButtonAcknowledgmentDelay(base::TimeDelta delay) {
metrics_collector_->SendPowerButtonAcknowledgmentDelayMetric(delay);
}
int Daemon::GetInitialSuspendId() {
// Take powerd's PID modulo 2**15 (/proc/sys/kernel/pid_max is currently
// 2**15, but just in case...) and multiply it by 2**16, leaving it able to
// fit in a signed 32-bit int. This allows for 2**16 suspend attempts and
// suspend delays per powerd run before wrapping or intruding on another
// run's ID range (neither of which should be particularly problematic, but
// doing this reduces the chances of a confused client that's using stale
// IDs from a previous powerd run being able to conflict with the new run's
// IDs).
return (getpid() % 32768) * 65536 + 1;
}
int Daemon::GetInitialDarkSuspendId() {
// We use the upper half of the suspend ID space for dark suspend attempts.
// Assuming that we will go through dark suspend IDs faster than the regular
// suspend IDs, we should never have a collision between the suspend ID and
// the dark suspend ID until the dark suspend IDs wrap around.
return GetInitialSuspendId() + 32768;
}
bool Daemon::IsLidClosedForSuspend() {
return input_watcher_->QueryLidState() == LID_CLOSED;
}
bool Daemon::ReadSuspendWakeupCount(uint64_t* wakeup_count) {
DCHECK(wakeup_count);
base::FilePath path(kWakeupCountPath);
std::string buf;
if (base::ReadFileToString(path, &buf)) {
base::TrimWhitespaceASCII(buf, base::TRIM_TRAILING, &buf);
if (base::StringToUint64(buf, wakeup_count))
return true;
LOG(ERROR) << "Could not parse wakeup count from \"" << buf << "\"";
} else {
LOG(ERROR) << "Could not read " << kWakeupCountPath;
}
return false;
}
void Daemon::SetSuspendAnnounced(bool announced) {
if (announced) {
if (base::WriteFile(suspend_announced_path_, NULL, 0) < 0)
PLOG(ERROR) << "Couldn't create " << suspend_announced_path_.value();
} else {
if (!base::DeleteFile(suspend_announced_path_, false))
PLOG(ERROR) << "Couldn't delete " << suspend_announced_path_.value();
}
}
bool Daemon::GetSuspendAnnounced() {
return base::PathExists(suspend_announced_path_);
}
void Daemon::PrepareToSuspend() {
// Before announcing the suspend request, notify the backlight controller so
// it can turn the backlight off and tell the kernel to resume the current
// level after resuming. This must occur before Chrome is told that the
// system is going to suspend (Chrome turns the display back on while leaving
// the backlight off).
SetBacklightsSuspended(true);
// Do not let suspend change the console terminal.
if (lock_vt_before_suspend_)
RunSetuidHelper("lock_vt", "", true);
power_supply_->SetSuspended(true);
if (audio_client_)
audio_client_->MuteSystem();
metrics_collector_->PrepareForSuspend();
}
policy::Suspender::Delegate::SuspendResult Daemon::DoSuspend(
uint64_t wakeup_count,
bool wakeup_count_valid,
base::TimeDelta duration) {
if (FlashromIsRunning()) {
LOG(INFO) << "Aborting suspend attempt for flashrom";
return SUSPEND_FAILED;
}
// Touch a file that crash-reporter can inspect later to determine
// whether the system was suspended while an unclean shutdown occurred.
// If the file already exists, assume that crash-reporter hasn't seen it
// yet and avoid unlinking it after resume.
created_suspended_state_file_ = false;
const base::FilePath kStatePath(kSuspendedStatePath);
if (!base::PathExists(kStatePath)) {
if (base::WriteFile(kStatePath, NULL, 0) == 0)
created_suspended_state_file_ = true;
else
PLOG(ERROR) << "Unable to create " << kSuspendedStatePath;
}
// This command is run synchronously to ensure that it finishes before the
// system is suspended.
// TODO(derat): Remove this once it's logged by the kernel:
// http://crosbug.com/p/16132
if (log_suspend_with_mosys_eventlog_)
RunSetuidHelper("mosys_eventlog", "--mosys_eventlog_code=0xa7", true);
std::string args;
if (wakeup_count_valid) {
args += base::StringPrintf(" --suspend_wakeup_count_valid"
" --suspend_wakeup_count=%" PRIu64,
wakeup_count);
}
if (duration != base::TimeDelta()) {
args += base::StringPrintf(" --suspend_duration=%" PRId64,
duration.InSeconds());
}
const int exit_code = RunSetuidHelper("suspend", args, true);
LOG(INFO) << "powerd_suspend returned " << exit_code;
// TODO(derat): Remove this once it's logged by the kernel:
// http://crosbug.com/p/16132
if (log_suspend_with_mosys_eventlog_)
RunSetuidHelper("mosys_eventlog", "--mosys_eventlog_code=0xa8", false);
if (created_suspended_state_file_) {
if (!base::DeleteFile(base::FilePath(kSuspendedStatePath), false))
PLOG(ERROR) << "Failed to delete " << kSuspendedStatePath;
}
// These exit codes are defined in powerd/powerd_suspend.
switch (exit_code) {
case 0:
return SUSPEND_SUCCESSFUL;
case 1:
return SUSPEND_FAILED;
case 2: // Wakeup event received before write to wakeup_count.
case 3: // Wakeup event received after write to wakeup_count.
return SUSPEND_CANCELED;
default:
LOG(ERROR) << "Treating unexpected exit code " << exit_code
<< " as suspend failure";
return SUSPEND_FAILED;
}
}
void Daemon::UndoPrepareToSuspend(bool success,
int num_suspend_attempts,
bool canceled_while_in_dark_resume) {
if (canceled_while_in_dark_resume && !ExitDarkResume())
ShutDown(SHUTDOWN_MODE_POWER_OFF, SHUTDOWN_REASON_EXIT_DARK_RESUME_FAILED);
if (audio_client_)
audio_client_->RestoreMutedState();
power_supply_->SetSuspended(false);
// Allow virtual terminal switching again.
if (lock_vt_before_suspend_)
RunSetuidHelper("unlock_vt", "", true);
SetBacklightsSuspended(false);
state_controller_->HandleResume();
if (success)
metrics_collector_->HandleResume(num_suspend_attempts);
else if (num_suspend_attempts > 0)
metrics_collector_->HandleCanceledSuspendRequest(num_suspend_attempts);
}
void Daemon::GenerateDarkResumeMetrics(
const std::vector<base::TimeDelta>& dark_resume_wake_durations,
base::TimeDelta suspend_duration) {
metrics_collector_->GenerateDarkResumeMetrics(dark_resume_wake_durations,
suspend_duration);
}
void Daemon::ShutDownForFailedSuspend() {
ShutDown(SHUTDOWN_MODE_POWER_OFF, SHUTDOWN_REASON_SUSPEND_FAILED);
}
void Daemon::ShutDownForDarkResume() {
ShutDown(SHUTDOWN_MODE_POWER_OFF, SHUTDOWN_REASON_DARK_RESUME);
}
bool Daemon::CanSafelyExitDarkResume() {
return can_safely_exit_dark_resume_;
}
void Daemon::OnAudioStateChange(bool active) {
LOG(INFO) << "Audio is " << (active ? "active" : "inactive");
state_controller_->HandleAudioStateChange(active);
}
void Daemon::OnPowerStatusUpdate() {
const system::PowerStatus status = power_supply_->GetPowerStatus();
if (status.battery_is_present)
LOG(INFO) << system::GetPowerStatusBatteryDebugString(status);
metrics_collector_->HandlePowerStatusUpdate(status);
const PowerSource power_source =
status.line_power_on ? POWER_AC : POWER_BATTERY;
if (display_backlight_controller_)
display_backlight_controller_->HandlePowerSourceChange(power_source);
if (keyboard_backlight_controller_)
keyboard_backlight_controller_->HandlePowerSourceChange(power_source);
state_controller_->HandlePowerSourceChange(power_source);
if (status.battery_is_present && status.battery_below_shutdown_threshold) {
LOG(INFO) << "Shutting down due to low battery ("
<< base::StringPrintf("%0.2f", status.battery_percentage) << "%, "
<< util::TimeDeltaToString(status.battery_time_to_empty)
<< " until empty, "
<< base::StringPrintf(
"%0.3f", status.observed_battery_charge_rate)
<< "A observed charge rate)";
ShutDown(SHUTDOWN_MODE_POWER_OFF, SHUTDOWN_REASON_LOW_BATTERY);
}
PowerSupplyProperties protobuf;
system::CopyPowerStatusToProtocolBuffer(status, &protobuf);
dbus_sender_->EmitSignalWithProtocolBuffer(kPowerSupplyPollSignal, protobuf);
}
void Daemon::InitDBus() {
dbus::Bus::Options options;
options.bus_type = dbus::Bus::SYSTEM;
bus_ = new dbus::Bus(options);
CHECK(bus_->Connect());
chrome_dbus_proxy_ = bus_->GetObjectProxy(
chromeos::kLibCrosServiceName,
dbus::ObjectPath(chromeos::kLibCrosServicePath));
chrome_dbus_proxy_->WaitForServiceToBeAvailable(
base::Bind(&Daemon::HandleChromeAvailableOrRestarted,
weak_ptr_factory_.GetWeakPtr()));
session_manager_dbus_proxy_ = bus_->GetObjectProxy(
login_manager::kSessionManagerServiceName,
dbus::ObjectPath(login_manager::kSessionManagerServicePath));
session_manager_dbus_proxy_->WaitForServiceToBeAvailable(
base::Bind(&Daemon::HandleSessionManagerAvailableOrRestarted,
weak_ptr_factory_.GetWeakPtr()));
session_manager_dbus_proxy_->ConnectToSignal(
login_manager::kSessionManagerInterface,
login_manager::kSessionStateChangedSignal,
base::Bind(&Daemon::HandleSessionStateChangedSignal,
weak_ptr_factory_.GetWeakPtr()),
base::Bind(&Daemon::HandleDBusSignalConnected,
weak_ptr_factory_.GetWeakPtr()));
if (audio_client_) {
cras_dbus_proxy_ = bus_->GetObjectProxy(
cras::kCrasServiceName,
dbus::ObjectPath(cras::kCrasServicePath));
cras_dbus_proxy_->WaitForServiceToBeAvailable(
base::Bind(&Daemon::HandleCrasAvailableOrRestarted,
weak_ptr_factory_.GetWeakPtr()));
cras_dbus_proxy_->ConnectToSignal(
cras::kCrasControlInterface,
cras::kNodesChanged,
base::Bind(&Daemon::HandleCrasNodesChangedSignal,
weak_ptr_factory_.GetWeakPtr()),
base::Bind(&Daemon::HandleDBusSignalConnected,
weak_ptr_factory_.GetWeakPtr()));
cras_dbus_proxy_->ConnectToSignal(
cras::kCrasControlInterface,
cras::kActiveOutputNodeChanged,
base::Bind(&Daemon::HandleCrasActiveOutputNodeChangedSignal,
weak_ptr_factory_.GetWeakPtr()),
base::Bind(&Daemon::HandleDBusSignalConnected,
weak_ptr_factory_.GetWeakPtr()));
cras_dbus_proxy_->ConnectToSignal(
cras::kCrasControlInterface,
cras::kNumberOfActiveStreamsChanged,
base::Bind(&Daemon::HandleCrasNumberOfActiveStreamsChanged,
weak_ptr_factory_.GetWeakPtr()),
base::Bind(&Daemon::HandleDBusSignalConnected,
weak_ptr_factory_.GetWeakPtr()));
}
update_engine_dbus_proxy_ = bus_->GetObjectProxy(
update_engine::kUpdateEngineServiceName,
dbus::ObjectPath(update_engine::kUpdateEngineServicePath));
update_engine_dbus_proxy_->WaitForServiceToBeAvailable(
base::Bind(&Daemon::HandleUpdateEngineAvailable,
weak_ptr_factory_.GetWeakPtr()));
update_engine_dbus_proxy_->ConnectToSignal(
update_engine::kUpdateEngineInterface,
update_engine::kStatusUpdate,
base::Bind(&Daemon::HandleUpdateEngineStatusUpdateSignal,
weak_ptr_factory_.GetWeakPtr()),
base::Bind(&Daemon::HandleDBusSignalConnected,
weak_ptr_factory_.GetWeakPtr()));
int64 tpm_threshold = 0;
prefs_->GetInt64(kTpmCounterSuspendThresholdPref, &tpm_threshold);
if (tpm_threshold > 0) {
cryptohomed_dbus_proxy_ = bus_->GetObjectProxy(
cryptohome::kCryptohomeServiceName,
dbus::ObjectPath(cryptohome::kCryptohomeServicePath));
cryptohomed_dbus_proxy_->WaitForServiceToBeAvailable(
base::Bind(&Daemon::HandleCryptohomedAvailable,
weak_ptr_factory_.GetWeakPtr()));
}
powerd_dbus_object_ = bus_->GetExportedObject(
dbus::ObjectPath(kPowerManagerServicePath));
ExportDBusMethod(kRequestShutdownMethod,
&Daemon::HandleRequestShutdownMethod);
ExportDBusMethod(kRequestRestartMethod,
&Daemon::HandleRequestRestartMethod);
ExportDBusMethod(kRequestSuspendMethod,
&Daemon::HandleRequestSuspendMethod);
ExportDBusMethod(kDecreaseScreenBrightnessMethod,
&Daemon::HandleDecreaseScreenBrightnessMethod);
ExportDBusMethod(kIncreaseScreenBrightnessMethod,
&Daemon::HandleIncreaseScreenBrightnessMethod);
ExportDBusMethod(kGetScreenBrightnessPercentMethod,
&Daemon::HandleGetScreenBrightnessMethod);
ExportDBusMethod(kSetScreenBrightnessPercentMethod,
&Daemon::HandleSetScreenBrightnessMethod);
ExportDBusMethod(kDecreaseKeyboardBrightnessMethod,
&Daemon::HandleDecreaseKeyboardBrightnessMethod);
ExportDBusMethod(kIncreaseKeyboardBrightnessMethod,
&Daemon::HandleIncreaseKeyboardBrightnessMethod);
ExportDBusMethod(kGetPowerSupplyPropertiesMethod,
&Daemon::HandleGetPowerSupplyPropertiesMethod);
ExportDBusMethod(kHandleVideoActivityMethod,
&Daemon::HandleVideoActivityMethod);
ExportDBusMethod(kHandleUserActivityMethod,
&Daemon::HandleUserActivityMethod);
ExportDBusMethod(kSetIsProjectingMethod,
&Daemon::HandleSetIsProjectingMethod);
ExportDBusMethod(kSetPolicyMethod,
&Daemon::HandleSetPolicyMethod);
ExportDBusMethod(kSetPowerSourceMethod,
&Daemon::HandleSetPowerSourceMethod);
ExportDBusMethod(kHandlePowerButtonAcknowledgmentMethod,
&Daemon::HandlePowerButtonAcknowledgment);
CHECK(powerd_dbus_object_->ExportMethodAndBlock(
kPowerManagerInterface, kRegisterSuspendDelayMethod,
base::Bind(&policy::Suspender::RegisterSuspendDelay,
base::Unretained(suspender_.get()))));
CHECK(powerd_dbus_object_->ExportMethodAndBlock(
kPowerManagerInterface, kUnregisterSuspendDelayMethod,
base::Bind(&policy::Suspender::UnregisterSuspendDelay,
base::Unretained(suspender_.get()))));
CHECK(powerd_dbus_object_->ExportMethodAndBlock(
kPowerManagerInterface, kHandleSuspendReadinessMethod,
base::Bind(&policy::Suspender::HandleSuspendReadiness,
base::Unretained(suspender_.get()))));
CHECK(powerd_dbus_object_->ExportMethodAndBlock(
kPowerManagerInterface, kRegisterDarkSuspendDelayMethod,
base::Bind(&policy::Suspender::RegisterDarkSuspendDelay,
base::Unretained(suspender_.get()))));
CHECK(powerd_dbus_object_->ExportMethodAndBlock(
kPowerManagerInterface, kUnregisterDarkSuspendDelayMethod,
base::Bind(&policy::Suspender::UnregisterDarkSuspendDelay,
base::Unretained(suspender_.get()))));
CHECK(powerd_dbus_object_->ExportMethodAndBlock(
kPowerManagerInterface, kHandleDarkSuspendReadinessMethod,
base::Bind(&policy::Suspender::HandleDarkSuspendReadiness,
base::Unretained(suspender_.get()))));
// Note that this needs to happen *after* the above methods are exported
// (http://crbug.com/331431).
CHECK(bus_->RequestOwnershipAndBlock(kPowerManagerServiceName,
dbus::Bus::REQUIRE_PRIMARY))
<< "Unable to take ownership of " << kPowerManagerServiceName;
// Listen for NameOwnerChanged signals from the bus itself. Register for all
// of these signals instead of calling individual proxies'
// SetNameOwnerChangedCallback() methods so that Suspender can get notified
// when clients with suspend delays for which Daemon doesn't have proxies
// disconnect.
const char kBusServiceName[] = "org.freedesktop.DBus";
const char kBusServicePath[] = "/org/freedesktop/DBus";
const char kBusInterface[] = "org.freedesktop.DBus";
const char kNameOwnerChangedSignal[] = "NameOwnerChanged";
dbus::ObjectProxy* proxy = bus_->GetObjectProxy(
kBusServiceName, dbus::ObjectPath(kBusServicePath));
proxy->ConnectToSignal(kBusInterface, kNameOwnerChangedSignal,
base::Bind(&Daemon::HandleDBusNameOwnerChanged,
weak_ptr_factory_.GetWeakPtr()),
base::Bind(&Daemon::HandleDBusSignalConnected,
weak_ptr_factory_.GetWeakPtr()));
dbus_sender_->Init(powerd_dbus_object_, kPowerManagerInterface);
}
void Daemon::HandleChromeAvailableOrRestarted(bool available) {
if (!available) {
LOG(ERROR) << "Failed waiting for Chrome to become available";
return;
}
if (display_backlight_controller_)
display_backlight_controller_->HandleChromeStart();
}
void Daemon::HandleSessionManagerAvailableOrRestarted(bool available) {
if (!available) {
LOG(ERROR) << "Failed waiting for session manager to become available";
return;
}
dbus::MethodCall method_call(
login_manager::kSessionManagerInterface,
login_manager::kSessionManagerRetrieveSessionState);
scoped_ptr<dbus::Response> response(
session_manager_dbus_proxy_->CallMethodAndBlock(
&method_call, kSessionManagerDBusTimeoutMs));
if (!response)
return;
std::string state;
dbus::MessageReader reader(response.get());
if (!reader.PopString(&state)) {
LOG(ERROR) << "Unable to read "
<< login_manager::kSessionManagerRetrieveSessionState << " args";
return;
}
OnSessionStateChange(state);
}
void Daemon::HandleCrasAvailableOrRestarted(bool available) {
if (!available) {
LOG(ERROR) << "Failed waiting for CRAS to become available";
return;
}
if (audio_client_)
audio_client_->LoadInitialState();
}
void Daemon::HandleUpdateEngineAvailable(bool available) {
if (!available) {
LOG(ERROR) << "Failed waiting for update engine to become available";
return;
}
dbus::MethodCall method_call(update_engine::kUpdateEngineInterface,
update_engine::kGetStatus);
scoped_ptr<dbus::Response> response(
update_engine_dbus_proxy_->CallMethodAndBlock(
&method_call, kUpdateEngineDBusTimeoutMs));
if (!response)
return;
dbus::MessageReader reader(response.get());
int64_t last_checked_time = 0;
double progress = 0.0;
std::string operation;
if (!reader.PopInt64(&last_checked_time) ||
!reader.PopDouble(&progress) ||
!reader.PopString(&operation)) {
LOG(ERROR) << "Unable to read " << update_engine::kGetStatus << " args";
return;
}
OnUpdateOperation(operation);
}
void Daemon::HandleCryptohomedAvailable(bool available) {
if (!available) {
LOG(ERROR) << "Failed waiting for cryptohomed to become available";
return;
}
if (cryptohomed_dbus_proxy_) {
dbus::MethodCall method_call(cryptohome::kCryptohomeInterface,
cryptohome::kCryptohomeGetTpmStatus);
dbus::MessageWriter writer(&method_call);
writer.AppendProtoAsArrayOfBytes(cryptohome::GetTpmStatusRequest());
cryptohomed_dbus_proxy_->CallMethod(
&method_call, kCryptohomedDBusTimeoutMs,
base::Bind(&Daemon::HandleGetTpmStatusResponse,
weak_ptr_factory_.GetWeakPtr()));
}
}
void Daemon::HandleDBusNameOwnerChanged(dbus::Signal* signal) {
dbus::MessageReader reader(signal);
std::string name, old_owner, new_owner;
if (!reader.PopString(&name) ||
!reader.PopString(&old_owner) ||
!reader.PopString(&new_owner)) {
LOG(ERROR) << "Unable to parse NameOwnerChanged signal";
return;
}
if (name == login_manager::kSessionManagerServiceName && !new_owner.empty()) {
LOG(INFO) << "D-Bus " << name << " ownership changed to " << new_owner;
HandleSessionManagerAvailableOrRestarted(true);
} else if (name == cras::kCrasServiceName && !new_owner.empty()) {
LOG(INFO) << "D-Bus " << name << " ownership changed to " << new_owner;
HandleCrasAvailableOrRestarted(true);
} else if (name == chromeos::kLibCrosServiceName && !new_owner.empty()) {
LOG(INFO) << "D-Bus " << name << " ownership changed to " << new_owner;
HandleChromeAvailableOrRestarted(true);
}
suspender_->HandleDBusNameOwnerChanged(name, old_owner, new_owner);
}
void Daemon::HandleDBusSignalConnected(const std::string& interface,
const std::string& signal,
bool success) {
if (!success)
LOG(ERROR) << "Failed to connect to " << interface << "." << signal;
}
void Daemon::ExportDBusMethod(const std::string& method_name,
DBusMethodCallMemberFunction member) {
DCHECK(powerd_dbus_object_);
CHECK(powerd_dbus_object_->ExportMethodAndBlock(
kPowerManagerInterface, method_name,
base::Bind(&HandleSynchronousDBusMethodCall,
base::Bind(member, base::Unretained(this)))));
}
void Daemon::HandleSessionStateChangedSignal(dbus::Signal* signal) {
dbus::MessageReader reader(signal);
std::string state;
if (reader.PopString(&state)) {
OnSessionStateChange(state);
} else {
LOG(ERROR) << "Unable to read "
<< login_manager::kSessionStateChangedSignal << " args";
}
}
void Daemon::HandleUpdateEngineStatusUpdateSignal(dbus::Signal* signal) {
dbus::MessageReader reader(signal);
int64_t last_checked_time = 0;
double progress = 0.0;
std::string operation;
if (!reader.PopInt64(&last_checked_time) ||
!reader.PopDouble(&progress) ||
!reader.PopString(&operation)) {
LOG(ERROR) << "Unable to read " << update_engine::kStatusUpdate << " args";
return;
}
OnUpdateOperation(operation);
}
void Daemon::HandleCrasNodesChangedSignal(dbus::Signal* signal) {
DCHECK(audio_client_);
audio_client_->UpdateDevices();
}
void Daemon::HandleCrasActiveOutputNodeChangedSignal(dbus::Signal* signal) {
DCHECK(audio_client_);
audio_client_->UpdateDevices();
}
void Daemon::HandleCrasNumberOfActiveStreamsChanged(dbus::Signal* signal) {
DCHECK(audio_client_);
audio_client_->UpdateNumActiveStreams();
}
void Daemon::HandleGetTpmStatusResponse(dbus::Response* response) {
if (!response) {
LOG(ERROR) << cryptohome::kCryptohomeGetTpmStatus << " call failed";
return;
}
cryptohome::BaseReply base_reply;
dbus::MessageReader reader(response);
if (!reader.PopArrayOfBytesAsProto(&base_reply)) {
LOG(ERROR) << "Unable to parse " << cryptohome::kCryptohomeGetTpmStatus
<< "response";
return;
}
if (base_reply.has_error()) {
LOG(ERROR) << cryptohome::kCryptohomeGetTpmStatus << " response contains "
<< "error code " << base_reply.error();
return;
}
if (!base_reply.HasExtension(cryptohome::GetTpmStatusReply::reply)) {
LOG(ERROR) << cryptohome::kCryptohomeGetTpmStatus << " response doesn't "
<< "contain nested reply";
return;
}
cryptohome::GetTpmStatusReply tpm_reply =
base_reply.GetExtension(cryptohome::GetTpmStatusReply::reply);
LOG(INFO) << "Received " << cryptohome::kCryptohomeGetTpmStatus
<< " response with dictionary attack count "
<< tpm_reply.dictionary_attack_counter();
state_controller_->HandleTpmStatus(tpm_reply.dictionary_attack_counter());
}
scoped_ptr<dbus::Response> Daemon::HandleRequestShutdownMethod(
dbus::MethodCall* method_call) {
LOG(INFO) << "Got " << kRequestShutdownMethod << " message from "
<< method_call->GetSender();
ShutDown(SHUTDOWN_MODE_POWER_OFF, SHUTDOWN_REASON_USER_REQUEST);
return scoped_ptr<dbus::Response>();
}
scoped_ptr<dbus::Response> Daemon::HandleRequestRestartMethod(
dbus::MethodCall* method_call) {
LOG(INFO) << "Got " << kRequestRestartMethod << " message from "
<< method_call->GetSender();
ShutdownReason shutdown_reason = SHUTDOWN_REASON_USER_REQUEST;
dbus::MessageReader reader(method_call);
int32_t arg = 0;
if (reader.PopInt32(&arg)) {
switch (static_cast<RequestRestartReason>(arg)) {
case REQUEST_RESTART_FOR_USER:
shutdown_reason = SHUTDOWN_REASON_USER_REQUEST;
break;
case REQUEST_RESTART_FOR_UPDATE:
shutdown_reason = SHUTDOWN_REASON_SYSTEM_UPDATE;
break;
default:
LOG(WARNING) << "Got unknown restart reason " << arg;
}
}
ShutDown(SHUTDOWN_MODE_REBOOT, shutdown_reason);
return scoped_ptr<dbus::Response>();
}
scoped_ptr<dbus::Response> Daemon::HandleRequestSuspendMethod(
dbus::MethodCall* method_call) {
// Read an optional uint64_t argument specifying the wakeup count that is
// expected.
dbus::MessageReader reader(method_call);
uint64_t external_wakeup_count = 0;
const bool got_external_wakeup_count = reader.PopUint64(
&external_wakeup_count);
LOG(INFO) << "Got " << kRequestSuspendMethod << " message"
<< (got_external_wakeup_count ?
base::StringPrintf(" with external wakeup count %" PRIu64,
external_wakeup_count).c_str() : "")
<< " from " << method_call->GetSender();
Suspend(got_external_wakeup_count, external_wakeup_count);
return scoped_ptr<dbus::Response>();
}
scoped_ptr<dbus::Response> Daemon::HandleDecreaseScreenBrightnessMethod(
dbus::MethodCall* method_call) {
if (!display_backlight_controller_)
return CreateNotSupportedError(method_call, "Backlight uninitialized");
bool allow_off = false;
dbus::MessageReader reader(method_call);
if (!reader.PopBool(&allow_off))
LOG(ERROR) << "Missing " << kDecreaseScreenBrightnessMethod << " arg";
bool changed =
display_backlight_controller_->DecreaseUserBrightness(allow_off);
double percent = 0.0;
if (!changed &&
display_backlight_controller_->GetBrightnessPercent(&percent)) {
SendBrightnessChangedSignal(
percent, policy::BacklightController::BRIGHTNESS_CHANGE_USER_INITIATED,
kBrightnessChangedSignal);
}
return scoped_ptr<dbus::Response>();
}
scoped_ptr<dbus::Response> Daemon::HandleIncreaseScreenBrightnessMethod(
dbus::MethodCall* method_call) {
if (!display_backlight_controller_)
return CreateNotSupportedError(method_call, "Backlight uninitialized");
bool changed = display_backlight_controller_->IncreaseUserBrightness();
double percent = 0.0;
if (!changed &&
display_backlight_controller_->GetBrightnessPercent(&percent)) {
SendBrightnessChangedSignal(
percent, policy::BacklightController::BRIGHTNESS_CHANGE_USER_INITIATED,
kBrightnessChangedSignal);
}
return scoped_ptr<dbus::Response>();
}
scoped_ptr<dbus::Response> Daemon::HandleSetScreenBrightnessMethod(
dbus::MethodCall* method_call) {
if (!display_backlight_controller_)
return CreateNotSupportedError(method_call, "Backlight uninitialized");
double percent = 0.0;
int dbus_style = 0;
dbus::MessageReader reader(method_call);
if (!reader.PopDouble(&percent) || !reader.PopInt32(&dbus_style)) {
LOG(ERROR) << "Missing " << kSetScreenBrightnessPercentMethod << " args";
return CreateInvalidArgsError(method_call, "Expected percent and style");
}
policy::BacklightController::TransitionStyle style =
policy::BacklightController::TRANSITION_FAST;
switch (dbus_style) {
case kBrightnessTransitionGradual:
style = policy::BacklightController::TRANSITION_FAST;
break;
case kBrightnessTransitionInstant:
style = policy::BacklightController::TRANSITION_INSTANT;
break;
default:
LOG(ERROR) << "Invalid transition style (" << dbus_style << ")";
}
display_backlight_controller_->SetUserBrightnessPercent(percent, style);
return scoped_ptr<dbus::Response>();
}
scoped_ptr<dbus::Response> Daemon::HandleGetScreenBrightnessMethod(
dbus::MethodCall* method_call) {
if (!display_backlight_controller_)
return CreateNotSupportedError(method_call, "Backlight uninitialized");
double percent = 0.0;
if (!display_backlight_controller_->GetBrightnessPercent(&percent)) {
return scoped_ptr<dbus::Response>(dbus::ErrorResponse::FromMethodCall(
method_call, DBUS_ERROR_FAILED, "Couldn't fetch brightness"));
}
scoped_ptr<dbus::Response> response(
dbus::Response::FromMethodCall(method_call));
dbus::MessageWriter writer(response.get());
writer.AppendDouble(percent);
return response.Pass();
}
scoped_ptr<dbus::Response> Daemon::HandleDecreaseKeyboardBrightnessMethod(
dbus::MethodCall* method_call) {
AdjustKeyboardBrightness(-1);
return scoped_ptr<dbus::Response>();
}
scoped_ptr<dbus::Response> Daemon::HandleIncreaseKeyboardBrightnessMethod(
dbus::MethodCall* method_call) {
AdjustKeyboardBrightness(1);
return scoped_ptr<dbus::Response>();
}
scoped_ptr<dbus::Response> Daemon::HandleGetPowerSupplyPropertiesMethod(
dbus::MethodCall* method_call) {
PowerSupplyProperties protobuf;
system::CopyPowerStatusToProtocolBuffer(power_supply_->GetPowerStatus(),
&protobuf);
scoped_ptr<dbus::Response> response(
dbus::Response::FromMethodCall(method_call));
dbus::MessageWriter writer(response.get());
writer.AppendProtoAsArrayOfBytes(protobuf);
return response.Pass();
}
scoped_ptr<dbus::Response> Daemon::HandleVideoActivityMethod(
dbus::MethodCall* method_call) {
bool fullscreen = false;
dbus::MessageReader reader(method_call);
if (!reader.PopBool(&fullscreen))
LOG(ERROR) << "Unable to read " << kHandleVideoActivityMethod << " args";
LOG(INFO) << "Saw " << (fullscreen ? "fullscreen" : "normal")
<< " video activity";
if (keyboard_backlight_controller_)
keyboard_backlight_controller_->HandleVideoActivity(fullscreen);
state_controller_->HandleVideoActivity();
return scoped_ptr<dbus::Response>();
}
scoped_ptr<dbus::Response> Daemon::HandleUserActivityMethod(
dbus::MethodCall* method_call) {
int type_int = USER_ACTIVITY_OTHER;
dbus::MessageReader reader(method_call);
if (!reader.PopInt32(&type_int))
LOG(ERROR) << "Unable to read " << kHandleUserActivityMethod << " args";
UserActivityType type = static_cast<UserActivityType>(type_int);
LOG(INFO) << "Saw user activity";
suspender_->HandleUserActivity();
state_controller_->HandleUserActivity();
if (display_backlight_controller_)
display_backlight_controller_->HandleUserActivity(type);
if (keyboard_backlight_controller_)
keyboard_backlight_controller_->HandleUserActivity(type);
return scoped_ptr<dbus::Response>();
}
scoped_ptr<dbus::Response> Daemon::HandleSetIsProjectingMethod(
dbus::MethodCall* method_call) {
bool is_projecting = false;
dbus::MessageReader reader(method_call);
if (!reader.PopBool(&is_projecting)) {
LOG(ERROR) << "Unable to read " << kSetIsProjectingMethod << " args";
return CreateInvalidArgsError(method_call, "Expected boolean state");
}
DisplayMode mode = is_projecting ? DISPLAY_PRESENTATION : DISPLAY_NORMAL;
LOG(INFO) << "Chrome is using " << DisplayModeToString(mode)
<< " display mode";
state_controller_->HandleDisplayModeChange(mode);
wakeup_controller_->SetDisplayMode(mode);
if (display_backlight_controller_)
display_backlight_controller_->HandleDisplayModeChange(mode);
return scoped_ptr<dbus::Response>();
}
scoped_ptr<dbus::Response> Daemon::HandleSetPolicyMethod(
dbus::MethodCall* method_call) {
PowerManagementPolicy policy;
dbus::MessageReader reader(method_call);
if (!reader.PopArrayOfBytesAsProto(&policy)) {
LOG(ERROR) << "Unable to parse " << kSetPolicyMethod << " request";
return CreateInvalidArgsError(method_call, "Expected protobuf");
}
LOG(INFO) << "Received updated external policy: "
<< policy::StateController::GetPolicyDebugString(policy);
state_controller_->HandlePolicyChange(policy);
if (display_backlight_controller_)
display_backlight_controller_->HandlePolicyChange(policy);
return scoped_ptr<dbus::Response>();
}
scoped_ptr<dbus::Response> Daemon::HandleSetPowerSourceMethod(
dbus::MethodCall* method_call) {
std::string id;
dbus::MessageReader reader(method_call);
if (!reader.PopString(&id)) {
LOG(ERROR) << "Unable to read " << kSetPowerSourceMethod << " args";
return CreateInvalidArgsError(method_call, "Expected string");
}
LOG(INFO) << "Received request to switch to power source " << id;
if (!power_supply_->SetPowerSource(id)) {
return scoped_ptr<dbus::Response>(dbus::ErrorResponse::FromMethodCall(
method_call, DBUS_ERROR_FAILED, "Couldn't set power source"));
}
return scoped_ptr<dbus::Response>();
}
scoped_ptr<dbus::Response> Daemon::HandlePowerButtonAcknowledgment(
dbus::MethodCall* method_call) {
int64_t timestamp_internal = 0;
dbus::MessageReader reader(method_call);
if (!reader.PopInt64(&timestamp_internal)) {
LOG(ERROR) << "Unable to parse " << kHandlePowerButtonAcknowledgmentMethod
<< " request";
return CreateInvalidArgsError(method_call, "Expected int64_t timestamp");
}
input_controller_->HandlePowerButtonAcknowledgment(
base::TimeTicks::FromInternalValue(timestamp_internal));
return scoped_ptr<dbus::Response>();
}
void Daemon::OnSessionStateChange(const std::string& state_str) {
SessionState state = (state_str == kSessionStarted) ?
SESSION_STARTED : SESSION_STOPPED;
if (state == session_state_)
return;
LOG(INFO) << "Session state changed to " << SessionStateToString(state);
session_state_ = state;
metrics_collector_->HandleSessionStateChange(state);
state_controller_->HandleSessionStateChange(state);
if (display_backlight_controller_)
display_backlight_controller_->HandleSessionStateChange(state);
if (keyboard_backlight_controller_)
keyboard_backlight_controller_->HandleSessionStateChange(state);
}
void Daemon::OnUpdateOperation(const std::string& operation) {
LOG(INFO) << "Update operation is " << operation;
UpdaterState state = UPDATER_IDLE;
if (operation == update_engine::kUpdateStatusDownloading ||
operation == update_engine::kUpdateStatusVerifying ||
operation == update_engine::kUpdateStatusFinalizing) {
state = UPDATER_UPDATING;
} else if (operation == update_engine::kUpdateStatusUpdatedNeedReboot) {
state = UPDATER_UPDATED;
}
state_controller_->HandleUpdaterStateChange(state);
}
void Daemon::ShutDown(ShutdownMode mode, ShutdownReason reason) {
if (shutting_down_) {
LOG(WARNING) << "Shutdown already initiated";
return;
}
if (FlashromIsRunning()) {
LOG(INFO) << "Postponing shutdown for flashrom";
if (!retry_shutdown_for_flashrom_timer_.IsRunning()) {
retry_shutdown_for_flashrom_timer_.Start(
FROM_HERE, base::TimeDelta::FromSeconds(kRetryShutdownForFlashromSec),
base::Bind(&Daemon::ShutDown, weak_ptr_factory_.GetWeakPtr(), mode,
reason));
}
return;
}
shutting_down_ = true;
retry_shutdown_for_flashrom_timer_.Stop();
suspender_->HandleShutdown();
metrics_collector_->HandleShutdown(reason);
// If we want to display a low-battery alert while shutting down, don't turn
// the screen off immediately.
if (reason != SHUTDOWN_REASON_LOW_BATTERY) {
if (display_backlight_controller_)
display_backlight_controller_->SetShuttingDown(true);
if (keyboard_backlight_controller_)
keyboard_backlight_controller_->SetShuttingDown(true);
}
const std::string reason_str = ShutdownReasonToString(reason);
switch (mode) {
case SHUTDOWN_MODE_POWER_OFF:
LOG(INFO) << "Shutting down, reason: " << reason_str;
RunSetuidHelper("shut_down", "--shutdown_reason=" + reason_str, false);
break;
case SHUTDOWN_MODE_REBOOT:
LOG(INFO) << "Restarting, reason: " << reason_str;
RunSetuidHelper("reboot", "", false);
break;
}
}
void Daemon::Suspend(bool use_external_wakeup_count,
uint64_t external_wakeup_count) {
if (shutting_down_) {
LOG(INFO) << "Ignoring request for suspend with outstanding shutdown";
return;
}
if (use_external_wakeup_count)
suspender_->RequestSuspendWithExternalWakeupCount(external_wakeup_count);
else
suspender_->RequestSuspend();
}
void Daemon::SetBacklightsDimmedForInactivity(bool dimmed) {
if (display_backlight_controller_)
display_backlight_controller_->SetDimmedForInactivity(dimmed);
if (keyboard_backlight_controller_)
keyboard_backlight_controller_->SetDimmedForInactivity(dimmed);
metrics_collector_->HandleScreenDimmedChange(
dimmed, state_controller_->last_user_activity_time());
}
void Daemon::SetBacklightsOffForInactivity(bool off) {
if (display_backlight_controller_)
display_backlight_controller_->SetOffForInactivity(off);
if (keyboard_backlight_controller_)
keyboard_backlight_controller_->SetOffForInactivity(off);
metrics_collector_->HandleScreenOffChange(
off, state_controller_->last_user_activity_time());
}
void Daemon::SetBacklightsSuspended(bool suspended) {
if (display_backlight_controller_)
display_backlight_controller_->SetSuspended(suspended);
if (keyboard_backlight_controller_)
keyboard_backlight_controller_->SetSuspended(suspended);
}
void Daemon::SetBacklightsDocked(bool docked) {
if (display_backlight_controller_)
display_backlight_controller_->SetDocked(docked);
if (keyboard_backlight_controller_)
keyboard_backlight_controller_->SetDocked(docked);
}
} // namespace power_manager