host_state_manager.cpp - openbmc/phosphor-state-manager - Gitiles

 #include <iostream>
 #include <map>
 #include <string>
 #include <systemd/sd-bus.h>
 #include <sdbusplus/server.hpp>
 #include <phosphor-logging/log.hpp>
 #include <phosphor-logging/elog-errors.hpp>
 #include <experimental/filesystem>
 #include <xyz/openbmc_project/Control/Power/RestorePolicy/server.hpp>
 #include <xyz/openbmc_project/Common/error.hpp>
 #include "host_state_manager.hpp"
 #include "host_state_serialize.hpp"
 #include "config.h"


 namespace phosphor
 {
 namespace state
 {
 namespace manager
 {

 // When you see server:: or reboot:: you know we're referencing our base class
 namespace server = sdbusplus::xyz::openbmc_project::State::server;
 namespace reboot = sdbusplus::xyz::openbmc_project::Control::Boot::server;
 namespace bootprogress = sdbusplus::xyz::openbmc_project::State::Boot::server;
 namespace osstatus =
     sdbusplus::xyz::openbmc_project::State::OperatingSystem::server;
 using namespace phosphor::logging;
 namespace fs = std::experimental::filesystem;

 // host-shutdown notifies host of shutdown and that leads to host-stop being
 // called so initiate a host shutdown with the -shutdown target and consider the
 // host shut down when the -stop target is complete
 constexpr auto HOST_STATE_SOFT_POWEROFF_TGT = "obmc-host-shutdown@0.target";
 constexpr auto HOST_STATE_POWEROFF_TGT = "obmc-host-stop@0.target";
 constexpr auto HOST_STATE_POWERON_TGT = "obmc-host-start@0.target";
 constexpr auto HOST_STATE_REBOOT_TGT = "obmc-host-reboot@0.target";
 constexpr auto HOST_STATE_QUIESCE_TGT = "obmc-host-quiesce@0.target";

 constexpr auto ACTIVE_STATE = "active";
 constexpr auto ACTIVATING_STATE = "activating";

 /* Map a transition to it's systemd target */
 const std::map<server::Host::Transition,std::string> SYSTEMD_TARGET_TABLE =
 {
         {server::Host::Transition::Off, HOST_STATE_SOFT_POWEROFF_TGT},
         {server::Host::Transition::On, HOST_STATE_POWERON_TGT},
         {server::Host::Transition::Reboot, HOST_STATE_REBOOT_TGT}
 };

 constexpr auto SYSTEMD_SERVICE   = "org.freedesktop.systemd1";
 constexpr auto SYSTEMD_OBJ_PATH  = "/org/freedesktop/systemd1";
 constexpr auto SYSTEMD_INTERFACE = "org.freedesktop.systemd1.Manager";

 constexpr auto MAPPER_BUSNAME = "xyz.openbmc_project.ObjectMapper";
 constexpr auto MAPPER_PATH = "/xyz/openbmc_project/object_mapper";
 constexpr auto MAPPER_INTERFACE = "xyz.openbmc_project.ObjectMapper";

 constexpr auto SYSTEMD_PROPERTY_IFACE = "org.freedesktop.DBus.Properties";
 constexpr auto SYSTEMD_INTERFACE_UNIT = "org.freedesktop.systemd1.Unit";

 /* Map a system state to the HostState */
 const std::map<std::string, server::Host::HostState> SYS_HOST_STATE_TABLE = {
         {"HOST_BOOTING", server::Host::HostState::Running},
         {"HOST_POWERED_OFF", server::Host::HostState::Off},
         {"HOST_QUIESCED", server::Host::HostState::Quiesced}
 };

 void Host::subscribeToSystemdSignals()
 {
     auto method = this->bus.new_method_call(SYSTEMD_SERVICE,
                                             SYSTEMD_OBJ_PATH,
                                             SYSTEMD_INTERFACE,
                                             "Subscribe");
     this->bus.call_noreply(method);

     return;
 }

 void Host::determineInitialState()
 {

     if(stateActive(HOST_STATE_POWERON_TGT))
     {
         log<level::INFO>("Initial Host State will be Running",
                          entry("CURRENT_HOST_STATE=%s",
                                convertForMessage(HostState::Running).c_str()));
         server::Host::currentHostState(HostState::Running);
         server::Host::requestedHostTransition(Transition::On);
     }
     else
     {
         log<level::INFO>("Initial Host State will be Off",
                          entry("CURRENT_HOST_STATE=%s",
                                convertForMessage(HostState::Off).c_str()));
         server::Host::currentHostState(HostState::Off);
         server::Host::requestedHostTransition(Transition::Off);
     }

     auto restore = getStateRestoreSetting();

     if ((!restore) || (!deserialize(HOST_STATE_PERSIST_PATH, *this)))
     {
         //set to default value.
         server::Host::requestedHostTransition(Transition::Off);
     }

     return;
 }

 bool Host::getStateRestoreSetting() const
 {
     using namespace settings;
     using namespace sdbusplus::xyz::openbmc_project::Common::Error;
     using namespace sdbusplus::xyz::openbmc_project::Control::Power::server;

     auto method =
         bus.new_method_call(
                 settings.service(settings.powerRestorePolicy,
                     powerRestoreIntf).c_str(),
                 settings.powerRestorePolicy.c_str(),
                 "org.freedesktop.DBus.Properties",
                 "Get");

     method.append(powerRestoreIntf, "PowerRestorePolicy");
     auto reply = bus.call(method);
     if (reply.is_method_error())
     {
         log<level::ERR>("Error in PowerRestorePolicy Get");
         elog<InternalFailure>();
     }

     sdbusplus::message::variant<std::string> result;
     reply.read(result);
     auto powerPolicy = result.get<std::string>();

     if (RestorePolicy::Policy::Restore ==
         RestorePolicy::convertPolicyFromString(powerPolicy))
     {
         return true;
     }
     return false;
 }

 void Host::executeTransition(Transition tranReq)
 {
     auto sysdUnit = SYSTEMD_TARGET_TABLE.find(tranReq)->second;

     auto method = this->bus.new_method_call(SYSTEMD_SERVICE,
                                             SYSTEMD_OBJ_PATH,
                                             SYSTEMD_INTERFACE,
                                             "StartUnit");

     method.append(sysdUnit);
     method.append("replace");

     this->bus.call_noreply(method);

     return;
 }

 bool Host::stateActive(const std::string& target)
 {
     sdbusplus::message::variant<std::string> currentState;
     sdbusplus::message::object_path unitTargetPath;

     auto method = this->bus.new_method_call(SYSTEMD_SERVICE,
                                             SYSTEMD_OBJ_PATH,
                                             SYSTEMD_INTERFACE,
                                             "GetUnit");

     method.append(target);
     auto result = this->bus.call(method);

     //Check that the bus call didn't result in an error
     if (result.is_method_error())
     {
         log<level::ERR>("Error in bus call - could not resolve GetUnit for:",
                         entry(" %s", SYSTEMD_INTERFACE));
         return false;
     }

     result.read(unitTargetPath);

     method = this->bus.new_method_call(SYSTEMD_SERVICE,
                                        static_cast<const std::string&>
                                            (unitTargetPath).c_str(),
                                        SYSTEMD_PROPERTY_IFACE,
                                        "Get");

     method.append(SYSTEMD_INTERFACE_UNIT, "ActiveState");
     result = this->bus.call(method);

     //Check that the bus call didn't result in an error
     if (result.is_method_error())
     {
         log<level::ERR>("Error in bus call - could not resolve Get for:",
                         entry(" %s", SYSTEMD_PROPERTY_IFACE));
         return false;
     }

     result.read(currentState);

     if (currentState != ACTIVE_STATE && currentState != ACTIVATING_STATE)
     {
         //False - not active
         return false;
     }
     //True - active
     return true;
 }

 bool Host::isAutoReboot()
 {
     using namespace settings;

     auto method =
         bus.new_method_call(
                 settings.service(settings.autoReboot, autoRebootIntf).c_str(),
                 settings.autoReboot.c_str(),
                 "org.freedesktop.DBus.Properties",
                 "Get");
     method.append(autoRebootIntf, "AutoReboot");
     auto reply = bus.call(method);
     if (reply.is_method_error())
     {
         log<level::ERR>("Error in AutoReboot Get");
         return false;
     }

     sdbusplus::message::variant<bool> result;
     reply.read(result);
     auto autoReboot = result.get<bool>();
     auto rebootCounterParam = reboot::RebootAttempts::attemptsLeft();

     if (autoReboot)
     {
         if (rebootCounterParam > 0)
         {
             // Reduce BOOTCOUNT by 1
             log<level::INFO>("Auto reboot enabled, rebooting");
             return true;
         }
         else if(rebootCounterParam == 0)
         {
             // Reset reboot counter and go to quiesce state
             log<level::INFO>("Auto reboot enabled. "
                              "HOST BOOTCOUNT already set to 0.");
             attemptsLeft(BOOT_COUNT_MAX_ALLOWED);
             return false;
         }
         else
         {
             log<level::INFO>("Auto reboot enabled. "
                              "HOST BOOTCOUNT has an invalid value.");
             return false;
         }
     }
     else
     {
         log<level::INFO>("Auto reboot disabled.");
         return false;
     }
 }

 void Host::sysStateChange(sdbusplus::message::message& msg)
 {
     uint32_t newStateID {};
     sdbusplus::message::object_path newStateObjPath;
     std::string newStateUnit{};
     std::string newStateResult{};

     //Read the msg and populate each variable
     msg.read(newStateID, newStateObjPath, newStateUnit, newStateResult);

     if((newStateUnit == HOST_STATE_POWEROFF_TGT) &&
        (newStateResult == "done") &&
        (!stateActive(HOST_STATE_POWERON_TGT)))
     {
         log<level::INFO>("Received signal that host is off");
         this->currentHostState(server::Host::HostState::Off);
         this->bootProgress(bootprogress::Progress::ProgressStages::Unspecified);
         this->operatingSystemState(osstatus::Status::OSStatus::Inactive);

     }
     else if((newStateUnit == HOST_STATE_POWERON_TGT) &&
             (newStateResult == "done") &&
             (stateActive(HOST_STATE_POWERON_TGT)))
      {
          log<level::INFO>("Received signal that host is running");
          this->currentHostState(server::Host::HostState::Running);
      }
      else if((newStateUnit == HOST_STATE_QUIESCE_TGT) &&
              (newStateResult == "done") &&
              (stateActive(HOST_STATE_QUIESCE_TGT)))
      {
          if (Host::isAutoReboot())
          {
              log<level::INFO>("Beginning reboot...");
              Host::requestedHostTransition(server::Host::Transition::Reboot);
          }
          else
          {
              log<level::INFO>("Maintaining quiesce");
              this->currentHostState(server::Host::HostState::Quiesced);
          }

      }
 }

 uint32_t Host::decrementRebootCount()
 {
     auto rebootCount = reboot::RebootAttempts::attemptsLeft();
     if(rebootCount > 0)
     {
         return(reboot::RebootAttempts::attemptsLeft(rebootCount - 1));
     }
     return rebootCount;
 }

 Host::Transition Host::requestedHostTransition(Transition value)
 {
     log<level::INFO>(
             "Host State transaction request",
             entry("REQUESTED_HOST_TRANSITION=%s",
                   convertForMessage(value).c_str()));

     // If this is not a power off request then we need to
     // decrement the reboot counter.  This code should
     // never prevent a power on, it should just decrement
     // the count to 0.  The quiesce handling is where the
     // check of this count will occur
     if(value != server::Host::Transition::Off)
     {
         decrementRebootCount();
     }

     executeTransition(value);

     auto retVal =  server::Host::requestedHostTransition(value);
     serialize(*this);
     return retVal;
 }

 Host::HostState Host::currentHostState(HostState value)
 {
     log<level::INFO>("Change to Host State",
                      entry("CURRENT_HOST_STATE=%s",
                            convertForMessage(value).c_str()));
     return server::Host::currentHostState(value);
 }

 } // namespace manager
 } // namespace state
 } // namepsace phosphor
	#include <iostream>
	#include <map>
	#include <string>
	#include <systemd/sd-bus.h>
	#include <sdbusplus/server.hpp>
	#include <phosphor-logging/log.hpp>
	#include <phosphor-logging/elog-errors.hpp>
	#include <experimental/filesystem>
	#include <xyz/openbmc_project/Control/Power/RestorePolicy/server.hpp>
	#include <xyz/openbmc_project/Common/error.hpp>
	#include "host_state_manager.hpp"
	#include "host_state_serialize.hpp"
	#include "config.h"


	namespace phosphor
	{
	namespace state
	{
	namespace manager
	{

	// When you see server:: or reboot:: you know we're referencing our base class
	namespace server = sdbusplus::xyz::openbmc_project::State::server;
	namespace reboot = sdbusplus::xyz::openbmc_project::Control::Boot::server;
	namespace bootprogress = sdbusplus::xyz::openbmc_project::State::Boot::server;
	namespace osstatus =
	sdbusplus::xyz::openbmc_project::State::OperatingSystem::server;
	using namespace phosphor::logging;
	namespace fs = std::experimental::filesystem;

	// host-shutdown notifies host of shutdown and that leads to host-stop being
	// called so initiate a host shutdown with the -shutdown target and consider the
	// host shut down when the -stop target is complete
	constexpr auto HOST_STATE_SOFT_POWEROFF_TGT = "obmc-host-shutdown@0.target";
	constexpr auto HOST_STATE_POWEROFF_TGT = "obmc-host-stop@0.target";
	constexpr auto HOST_STATE_POWERON_TGT = "obmc-host-start@0.target";
	constexpr auto HOST_STATE_REBOOT_TGT = "obmc-host-reboot@0.target";
	constexpr auto HOST_STATE_QUIESCE_TGT = "obmc-host-quiesce@0.target";

	constexpr auto ACTIVE_STATE = "active";
	constexpr auto ACTIVATING_STATE = "activating";

	/* Map a transition to it's systemd target */
	const std::map<server::Host::Transition,std::string> SYSTEMD_TARGET_TABLE =
	{
	{server::Host::Transition::Off, HOST_STATE_SOFT_POWEROFF_TGT},
	{server::Host::Transition::On, HOST_STATE_POWERON_TGT},
	{server::Host::Transition::Reboot, HOST_STATE_REBOOT_TGT}
	};

	constexpr auto SYSTEMD_SERVICE = "org.freedesktop.systemd1";
	constexpr auto SYSTEMD_OBJ_PATH = "/org/freedesktop/systemd1";
	constexpr auto SYSTEMD_INTERFACE = "org.freedesktop.systemd1.Manager";

	constexpr auto MAPPER_BUSNAME = "xyz.openbmc_project.ObjectMapper";
	constexpr auto MAPPER_PATH = "/xyz/openbmc_project/object_mapper";
	constexpr auto MAPPER_INTERFACE = "xyz.openbmc_project.ObjectMapper";

	constexpr auto SYSTEMD_PROPERTY_IFACE = "org.freedesktop.DBus.Properties";
	constexpr auto SYSTEMD_INTERFACE_UNIT = "org.freedesktop.systemd1.Unit";

	/* Map a system state to the HostState */
	const std::map<std::string, server::Host::HostState> SYS_HOST_STATE_TABLE = {
	{"HOST_BOOTING", server::Host::HostState::Running},
	{"HOST_POWERED_OFF", server::Host::HostState::Off},
	{"HOST_QUIESCED", server::Host::HostState::Quiesced}
	};

	void Host::subscribeToSystemdSignals()
	{
	auto method = this->bus.new_method_call(SYSTEMD_SERVICE,
	SYSTEMD_OBJ_PATH,
	SYSTEMD_INTERFACE,
	"Subscribe");
	this->bus.call_noreply(method);

	return;
	}

	void Host::determineInitialState()
	{

	if(stateActive(HOST_STATE_POWERON_TGT))
	{
	log<level::INFO>("Initial Host State will be Running",
	entry("CURRENT_HOST_STATE=%s",
	convertForMessage(HostState::Running).c_str()));
	server::Host::currentHostState(HostState::Running);
	server::Host::requestedHostTransition(Transition::On);
	}
	else
	{
	log<level::INFO>("Initial Host State will be Off",
	entry("CURRENT_HOST_STATE=%s",
	convertForMessage(HostState::Off).c_str()));
	server::Host::currentHostState(HostState::Off);
	server::Host::requestedHostTransition(Transition::Off);
	}

	auto restore = getStateRestoreSetting();

	if ((!restore) \|\| (!deserialize(HOST_STATE_PERSIST_PATH, *this)))
	{
	//set to default value.
	server::Host::requestedHostTransition(Transition::Off);
	}

	return;
	}

	bool Host::getStateRestoreSetting() const
	{
	using namespace settings;
	using namespace sdbusplus::xyz::openbmc_project::Common::Error;
	using namespace sdbusplus::xyz::openbmc_project::Control::Power::server;

	auto method =
	bus.new_method_call(
	settings.service(settings.powerRestorePolicy,
	powerRestoreIntf).c_str(),
	settings.powerRestorePolicy.c_str(),
	"org.freedesktop.DBus.Properties",
	"Get");

	method.append(powerRestoreIntf, "PowerRestorePolicy");
	auto reply = bus.call(method);
	if (reply.is_method_error())
	{
	log<level::ERR>("Error in PowerRestorePolicy Get");
	elog<InternalFailure>();
	}

	sdbusplus::message::variant<std::string> result;
	reply.read(result);
	auto powerPolicy = result.get<std::string>();

	if (RestorePolicy::Policy::Restore ==
	RestorePolicy::convertPolicyFromString(powerPolicy))
	{
	return true;
	}
	return false;
	}

	void Host::executeTransition(Transition tranReq)
	{
	auto sysdUnit = SYSTEMD_TARGET_TABLE.find(tranReq)->second;

	auto method = this->bus.new_method_call(SYSTEMD_SERVICE,
	SYSTEMD_OBJ_PATH,
	SYSTEMD_INTERFACE,
	"StartUnit");

	method.append(sysdUnit);
	method.append("replace");

	this->bus.call_noreply(method);

	return;
	}

	bool Host::stateActive(const std::string& target)
	{
	sdbusplus::message::variant<std::string> currentState;
	sdbusplus::message::object_path unitTargetPath;

	auto method = this->bus.new_method_call(SYSTEMD_SERVICE,
	SYSTEMD_OBJ_PATH,
	SYSTEMD_INTERFACE,
	"GetUnit");

	method.append(target);
	auto result = this->bus.call(method);

	//Check that the bus call didn't result in an error
	if (result.is_method_error())
	{
	log<level::ERR>("Error in bus call - could not resolve GetUnit for:",
	entry(" %s", SYSTEMD_INTERFACE));
	return false;
	}

	result.read(unitTargetPath);

	method = this->bus.new_method_call(SYSTEMD_SERVICE,
	static_cast<const std::string&>
	(unitTargetPath).c_str(),
	SYSTEMD_PROPERTY_IFACE,
	"Get");

	method.append(SYSTEMD_INTERFACE_UNIT, "ActiveState");
	result = this->bus.call(method);

	//Check that the bus call didn't result in an error
	if (result.is_method_error())
	{
	log<level::ERR>("Error in bus call - could not resolve Get for:",
	entry(" %s", SYSTEMD_PROPERTY_IFACE));
	return false;
	}

	result.read(currentState);

	if (currentState != ACTIVE_STATE && currentState != ACTIVATING_STATE)
	{
	//False - not active
	return false;
	}
	//True - active
	return true;
	}

	bool Host::isAutoReboot()
	{
	using namespace settings;

	auto method =
	bus.new_method_call(
	settings.service(settings.autoReboot, autoRebootIntf).c_str(),
	settings.autoReboot.c_str(),
	"org.freedesktop.DBus.Properties",
	"Get");
	method.append(autoRebootIntf, "AutoReboot");
	auto reply = bus.call(method);
	if (reply.is_method_error())
	{
	log<level::ERR>("Error in AutoReboot Get");
	return false;
	}

	sdbusplus::message::variant<bool> result;
	reply.read(result);
	auto autoReboot = result.get<bool>();
	auto rebootCounterParam = reboot::RebootAttempts::attemptsLeft();

	if (autoReboot)
	{
	if (rebootCounterParam > 0)
	{
	// Reduce BOOTCOUNT by 1
	log<level::INFO>("Auto reboot enabled, rebooting");
	return true;
	}
	else if(rebootCounterParam == 0)
	{
	// Reset reboot counter and go to quiesce state
	log<level::INFO>("Auto reboot enabled. "
	"HOST BOOTCOUNT already set to 0.");
	attemptsLeft(BOOT_COUNT_MAX_ALLOWED);
	return false;
	}
	else
	{
	log<level::INFO>("Auto reboot enabled. "
	"HOST BOOTCOUNT has an invalid value.");
	return false;
	}
	}
	else
	{
	log<level::INFO>("Auto reboot disabled.");
	return false;
	}
	}

	void Host::sysStateChange(sdbusplus::message::message& msg)
	{
	uint32_t newStateID {};
	sdbusplus::message::object_path newStateObjPath;
	std::string newStateUnit{};
	std::string newStateResult{};

	//Read the msg and populate each variable
	msg.read(newStateID, newStateObjPath, newStateUnit, newStateResult);

	if((newStateUnit == HOST_STATE_POWEROFF_TGT) &&
	(newStateResult == "done") &&
	(!stateActive(HOST_STATE_POWERON_TGT)))
	{
	log<level::INFO>("Received signal that host is off");
	this->currentHostState(server::Host::HostState::Off);
	this->bootProgress(bootprogress::Progress::ProgressStages::Unspecified);
	this->operatingSystemState(osstatus::Status::OSStatus::Inactive);

	}
	else if((newStateUnit == HOST_STATE_POWERON_TGT) &&
	(newStateResult == "done") &&
	(stateActive(HOST_STATE_POWERON_TGT)))
	{
	log<level::INFO>("Received signal that host is running");
	this->currentHostState(server::Host::HostState::Running);
	}
	else if((newStateUnit == HOST_STATE_QUIESCE_TGT) &&
	(newStateResult == "done") &&
	(stateActive(HOST_STATE_QUIESCE_TGT)))
	{
	if (Host::isAutoReboot())
	{
	log<level::INFO>("Beginning reboot...");
	Host::requestedHostTransition(server::Host::Transition::Reboot);
	}
	else
	{
	log<level::INFO>("Maintaining quiesce");
	this->currentHostState(server::Host::HostState::Quiesced);
	}

	}
	}

	uint32_t Host::decrementRebootCount()
	{
	auto rebootCount = reboot::RebootAttempts::attemptsLeft();
	if(rebootCount > 0)
	{
	return(reboot::RebootAttempts::attemptsLeft(rebootCount - 1));
	}
	return rebootCount;
	}

	Host::Transition Host::requestedHostTransition(Transition value)
	{
	log<level::INFO>(
	"Host State transaction request",
	entry("REQUESTED_HOST_TRANSITION=%s",
	convertForMessage(value).c_str()));

	// If this is not a power off request then we need to
	// decrement the reboot counter. This code should
	// never prevent a power on, it should just decrement
	// the count to 0. The quiesce handling is where the
	// check of this count will occur
	if(value != server::Host::Transition::Off)
	{
	decrementRebootCount();
	}

	executeTransition(value);

	auto retVal = server::Host::requestedHostTransition(value);
	serialize(*this);
	return retVal;
	}

	Host::HostState Host::currentHostState(HostState value)
	{
	log<level::INFO>("Change to Host State",
	entry("CURRENT_HOST_STATE=%s",
	convertForMessage(value).c_str()));
	return server::Host::currentHostState(value);
	}

	} // namespace manager
	} // namespace state
	} // namepsace phosphor