phosphor-power-supply/psu_manager.cpp - openbmc/phosphor-power - Gitiles

 #include "psu_manager.hpp"

 #include "utility.hpp"

 #include <fmt/format.h>
 #include <sys/types.h>
 #include <unistd.h>

 using namespace phosphor::logging;

 namespace phosphor::power::manager
 {

 constexpr auto IBMCFFPSInterface =
     "xyz.openbmc_project.Configuration.IBMCFFPSConnector";
 constexpr auto i2cBusProp = "I2CBus";
 constexpr auto i2cAddressProp = "I2CAddress";
 constexpr auto psuNameProp = "Name";

 constexpr auto supportedConfIntf =
     "xyz.openbmc_project.Configuration.SupportedConfiguration";

 PSUManager::PSUManager(sdbusplus::bus::bus& bus, const sdeventplus::Event& e) :
     bus(bus)
 {
     // Subscribe to InterfacesAdded before doing a property read, otherwise
     // the interface could be created after the read attempt but before the
     // match is created.
     entityManagerIfacesAddedMatch = std::make_unique<sdbusplus::bus::match_t>(
         bus,
         sdbusplus::bus::match::rules::interfacesAdded() +
             sdbusplus::bus::match::rules::sender(
                 "xyz.openbmc_project.EntityManager"),
         std::bind(&PSUManager::entityManagerIfaceAdded, this,
                   std::placeholders::_1));
     getPSUConfiguration();
     getSystemProperties();

     using namespace sdeventplus;
     auto interval = std::chrono::milliseconds(1000);
     timer = std::make_unique<utility::Timer<ClockId::Monotonic>>(
         e, std::bind(&PSUManager::analyze, this), interval);

     // Subscribe to power state changes
     powerService = util::getService(POWER_OBJ_PATH, POWER_IFACE, bus);
     powerOnMatch = std::make_unique<sdbusplus::bus::match_t>(
         bus,
         sdbusplus::bus::match::rules::propertiesChanged(POWER_OBJ_PATH,
                                                         POWER_IFACE),
         [this](auto& msg) { this->powerStateChanged(msg); });

     initialize();
 }

 void PSUManager::getPSUConfiguration()
 {
     using namespace phosphor::power::util;
     auto depth = 0;
     auto objects = getSubTree(bus, "/", IBMCFFPSInterface, depth);

     psus.clear();

     // I should get a map of objects back.
     // Each object will have a path, a service, and an interface.
     // The interface should match the one passed into this function.
     for (const auto& [path, services] : objects)
     {
         auto service = services.begin()->first;

         if (path.empty() || service.empty())
         {
             continue;
         }

         // For each object in the array of objects, I want to get properties
         // from the service, path, and interface.
         auto properties =
             getAllProperties(bus, path, IBMCFFPSInterface, service);

         getPSUProperties(properties);
     }

     if (psus.empty())
     {
         // Interface or properties not found. Let the Interfaces Added callback
         // process the information once the interfaces are added to D-Bus.
         log<level::INFO>(fmt::format("No power supplies to monitor").c_str());
     }
 }

 void PSUManager::getPSUProperties(util::DbusPropertyMap& properties)
 {
     // From passed in properties, I want to get: I2CBus, I2CAddress,
     // and Name. Create a power supply object, using Name to build the inventory
     // path.
     const auto basePSUInvPath =
         "/xyz/openbmc_project/inventory/system/chassis/motherboard/powersupply";
     uint64_t* i2cbus = nullptr;
     uint64_t* i2caddr = nullptr;
     std::string* psuname = nullptr;

     for (const auto& property : properties)
     {
         try
         {
             if (property.first == i2cBusProp)
             {
                 i2cbus = std::get_if<uint64_t>(&properties[i2cBusProp]);
             }
             else if (property.first == i2cAddressProp)
             {
                 i2caddr = std::get_if<uint64_t>(&properties[i2cAddressProp]);
             }
             else if (property.first == psuNameProp)
             {
                 psuname = std::get_if<std::string>(&properties[psuNameProp]);
             }
         }
         catch (std::exception& e)
         {
         }
     }

     if ((i2cbus) && (i2caddr) && (psuname) && (!psuname->empty()))
     {
         std::string invpath = basePSUInvPath;
         invpath.push_back(psuname->back());

         log<level::DEBUG>(fmt::format("Inventory Path: {}", invpath).c_str());

         auto psu =
             std::make_unique<PowerSupply>(bus, invpath, *i2cbus, *i2caddr);
         psus.emplace_back(std::move(psu));
     }

     if (psus.empty())
     {
         log<level::INFO>(fmt::format("No power supplies to monitor").c_str());
     }
 }

 void PSUManager::populateSysProperties(const util::DbusPropertyMap& properties)
 {
     try
     {
         auto propIt = properties.find("SupportedType");
         if (propIt == properties.end())
         {
             return;
         }
         const std::string* type = std::get_if<std::string>(&(propIt->second));
         if ((type == nullptr) || (*type != "PowerSupply"))
         {
             return;
         }

         std::vector<std::string> models;
         propIt = properties.find("SupportedModel");
         if (propIt == properties.end())
         {
             return;
         }
         const std::vector<std::string>* modelsPtr =
             std::get_if<std::vector<std::string>>(&(propIt->second));
         if (modelsPtr == nullptr)
         {
             return;
         }
         models = *modelsPtr;

         sys_properties sys{0, 0};
         propIt = properties.find("RedundantCount");
         if (propIt != properties.end())
         {
             const uint64_t* count = std::get_if<uint64_t>(&(propIt->second));
             if (count != nullptr)
             {
                 sys.maxPowerSupplies = *count;
             }
         }
         propIt = properties.find("InputVoltage");
         if (propIt != properties.end())
         {
             const uint64_t* voltage = std::get_if<uint64_t>(&(propIt->second));
             if (voltage != nullptr)
             {
                 sys.inputVoltage = *voltage;
             }
         }

         for (const auto& model : models)
         {
             supportedConfigs.insert(std::make_pair(model, sys));
         }
     }
     catch (std::exception& e)
     {
     }
 }

 void PSUManager::getSystemProperties()
 {

     try
     {
         util::DbusSubtree subtree =
             util::getSubTree(bus, INVENTORY_OBJ_PATH, supportedConfIntf, 0);
         if (subtree.empty())
         {
             throw std::runtime_error("Supported Configuration Not Found");
         }

         for (const auto& [objPath, services] : subtree)
         {
             std::string service = services.begin()->first;
             if (objPath.empty() || service.empty())
             {
                 continue;
             }
             auto properties = util::getAllProperties(
                 bus, objPath, supportedConfIntf, service);
             populateSysProperties(properties);
         }
     }
     catch (std::exception& e)
     {
         // Interface or property not found. Let the Interfaces Added callback
         // process the information once the interfaces are added to D-Bus.
     }
 }

 void PSUManager::entityManagerIfaceAdded(sdbusplus::message::message& msg)
 {
     try
     {
         sdbusplus::message::object_path objPath;
         std::map<std::string, std::map<std::string, util::DbusVariant>>
             interfaces;
         msg.read(objPath, interfaces);

         auto itIntf = interfaces.find(supportedConfIntf);
         if (itIntf != interfaces.cend())
         {
             populateSysProperties(itIntf->second);
         }

         itIntf = interfaces.find(IBMCFFPSInterface);
         if (itIntf != interfaces.cend())
         {
             log<level::INFO>(
                 fmt::format("InterfacesAdded for: {}", IBMCFFPSInterface)
                     .c_str());
             getPSUProperties(itIntf->second);
         }
     }
     catch (std::exception& e)
     {
         // Ignore, the property may be of a different type than expected.
     }
 }

 void PSUManager::powerStateChanged(sdbusplus::message::message& msg)
 {
     int32_t state = 0;
     std::string msgSensor;
     std::map<std::string, std::variant<int32_t>> msgData;
     msg.read(msgSensor, msgData);

     // Check if it was the Present property that changed.
     auto valPropMap = msgData.find("state");
     if (valPropMap != msgData.end())
     {
         state = std::get<int32_t>(valPropMap->second);

         // Power is on when state=1. Clear faults.
         if (state)
         {
             powerOn = true;
             clearFaults();
         }
         else
         {
             powerOn = false;
         }
     }
 }

 void PSUManager::createError(
     const std::string& faultName,
     const std::map<std::string, std::string>& additionalData)
 {
     using namespace sdbusplus::xyz::openbmc_project;
     constexpr auto loggingObjectPath = "/xyz/openbmc_project/logging";
     constexpr auto loggingCreateInterface =
         "xyz.openbmc_project.Logging.Create";

     try
     {
         auto service =
             util::getService(loggingObjectPath, loggingCreateInterface, bus);

         if (service.empty())
         {
             log<level::ERR>("Unable to get logging manager service");
             return;
         }

         auto method = bus.new_method_call(service.c_str(), loggingObjectPath,
                                           loggingCreateInterface, "Create");

         auto level = Logging::server::Entry::Level::Error;
         method.append(faultName, level, additionalData);

         auto reply = bus.call(method);
     }
     catch (std::exception& e)
     {
         log<level::ERR>(
             fmt::format(
                 "Failed creating event log for fault {} due to error {}",
                 faultName, e.what())
                 .c_str());
     }
 }

 void PSUManager::analyze()
 {
     for (auto& psu : psus)
     {
         psu->analyze();
     }

     if (powerOn)
     {
         for (auto& psu : psus)
         {
             std::map<std::string, std::string> additionalData;
             additionalData["_PID"] = std::to_string(getpid());
             // TODO: Fault priorities #918
             if (!psu->isFaultLogged() && !psu->isPresent())
             {
                 // Create error for power supply missing.
                 additionalData["CALLOUT_INVENTORY_PATH"] =
                     psu->getInventoryPath();
                 additionalData["CALLOUT_PRIORITY"] = "H";
                 createError(
                     "xyz.openbmc_project.Power.PowerSupply.Error.Missing",
                     additionalData);
                 psu->setFaultLogged();
             }
             else if (!psu->isFaultLogged() && psu->isFaulted())
             {
                 additionalData["STATUS_WORD"] =
                     std::to_string(psu->getStatusWord());
                 additionalData["STATUS_MFR"] =
                     std::to_string(psu->getMFRFault());
                 // If there are faults being reported, they possibly could be
                 // related to a bug in the firmware version running on the power
                 // supply. Capture that data into the error as well.
                 additionalData["FW_VERSION"] = psu->getFWVersion();

                 if ((psu->hasInputFault() || psu->hasVINUVFault()))
                 {
                     /* The power supply location might be needed if the input
                      * fault is due to a problem with the power supply itself.
                      * Include the inventory path with a call out priority of
                      * low.
                      */
                     additionalData["CALLOUT_INVENTORY_PATH"] =
                         psu->getInventoryPath();
                     additionalData["CALLOUT_PRIORITY"] = "L";
                     createError("xyz.openbmc_project.Power.PowerSupply.Error."
                                 "InputFault",
                                 additionalData);
                     psu->setFaultLogged();
                 }
                 else if (psu->hasMFRFault())
                 {
                     /* This can represent a variety of faults that result in
                      * calling out the power supply for replacement: Output
                      * OverCurrent, Output Under Voltage, and potentially other
                      * faults.
                      *
                      * Also plan on putting specific fault in AdditionalData,
                      * along with register names and register values
                      * (STATUS_WORD, STATUS_MFR, etc.).*/

                     additionalData["CALLOUT_INVENTORY_PATH"] =
                         psu->getInventoryPath();

                     createError(
                         "xyz.openbmc_project.Power.PowerSupply.Error.Fault",
                         additionalData);

                     psu->setFaultLogged();
                 }
                 else if (psu->hasCommFault())
                 {
                     /* Attempts to communicate with the power supply have
                      * reached there limit. Create an error. */
                     additionalData["CALLOUT_DEVICE_PATH"] =
                         psu->getDevicePath();

                     createError(
                         "xyz.openbmc_project.Power.PowerSupply.Error.CommFault",
                         additionalData);

                     psu->setFaultLogged();
                 }
             }
         }
     }
 }

 } // namespace phosphor::power::manager
	#include "psu_manager.hpp"

	#include "utility.hpp"

	#include <fmt/format.h>
	#include <sys/types.h>
	#include <unistd.h>

	using namespace phosphor::logging;

	namespace phosphor::power::manager
	{

	constexpr auto IBMCFFPSInterface =
	"xyz.openbmc_project.Configuration.IBMCFFPSConnector";
	constexpr auto i2cBusProp = "I2CBus";
	constexpr auto i2cAddressProp = "I2CAddress";
	constexpr auto psuNameProp = "Name";

	constexpr auto supportedConfIntf =
	"xyz.openbmc_project.Configuration.SupportedConfiguration";

	PSUManager::PSUManager(sdbusplus::bus::bus& bus, const sdeventplus::Event& e) :
	bus(bus)
	{
	// Subscribe to InterfacesAdded before doing a property read, otherwise
	// the interface could be created after the read attempt but before the
	// match is created.
	entityManagerIfacesAddedMatch = std::make_unique<sdbusplus::bus::match_t>(
	bus,
	sdbusplus::bus::match::rules::interfacesAdded() +
	sdbusplus::bus::match::rules::sender(
	"xyz.openbmc_project.EntityManager"),
	std::bind(&PSUManager::entityManagerIfaceAdded, this,
	std::placeholders::_1));
	getPSUConfiguration();
	getSystemProperties();

	using namespace sdeventplus;
	auto interval = std::chrono::milliseconds(1000);
	timer = std::make_unique<utility::Timer<ClockId::Monotonic>>(
	e, std::bind(&PSUManager::analyze, this), interval);

	// Subscribe to power state changes
	powerService = util::getService(POWER_OBJ_PATH, POWER_IFACE, bus);
	powerOnMatch = std::make_unique<sdbusplus::bus::match_t>(
	bus,
	sdbusplus::bus::match::rules::propertiesChanged(POWER_OBJ_PATH,
	POWER_IFACE),
	[this](auto& msg) { this->powerStateChanged(msg); });

	initialize();
	}

	void PSUManager::getPSUConfiguration()
	{
	using namespace phosphor::power::util;
	auto depth = 0;
	auto objects = getSubTree(bus, "/", IBMCFFPSInterface, depth);

	psus.clear();

	// I should get a map of objects back.
	// Each object will have a path, a service, and an interface.
	// The interface should match the one passed into this function.
	for (const auto& [path, services] : objects)
	{
	auto service = services.begin()->first;

	if (path.empty() \|\| service.empty())
	{
	continue;
	}

	// For each object in the array of objects, I want to get properties
	// from the service, path, and interface.
	auto properties =
	getAllProperties(bus, path, IBMCFFPSInterface, service);

	getPSUProperties(properties);
	}

	if (psus.empty())
	{
	// Interface or properties not found. Let the Interfaces Added callback
	// process the information once the interfaces are added to D-Bus.
	log<level::INFO>(fmt::format("No power supplies to monitor").c_str());
	}
	}

	void PSUManager::getPSUProperties(util::DbusPropertyMap& properties)
	{
	// From passed in properties, I want to get: I2CBus, I2CAddress,
	// and Name. Create a power supply object, using Name to build the inventory
	// path.
	const auto basePSUInvPath =
	"/xyz/openbmc_project/inventory/system/chassis/motherboard/powersupply";
	uint64_t* i2cbus = nullptr;
	uint64_t* i2caddr = nullptr;
	std::string* psuname = nullptr;

	for (const auto& property : properties)
	{
	try
	{
	if (property.first == i2cBusProp)
	{
	i2cbus = std::get_if<uint64_t>(&properties[i2cBusProp]);
	}
	else if (property.first == i2cAddressProp)
	{
	i2caddr = std::get_if<uint64_t>(&properties[i2cAddressProp]);
	}
	else if (property.first == psuNameProp)
	{
	psuname = std::get_if<std::string>(&properties[psuNameProp]);
	}
	}
	catch (std::exception& e)
	{
	}
	}

	if ((i2cbus) && (i2caddr) && (psuname) && (!psuname->empty()))
	{
	std::string invpath = basePSUInvPath;
	invpath.push_back(psuname->back());

	log<level::DEBUG>(fmt::format("Inventory Path: {}", invpath).c_str());

	auto psu =
	std::make_unique<PowerSupply>(bus, invpath, i2cbus, i2caddr);
	psus.emplace_back(std::move(psu));
	}

	if (psus.empty())
	{
	log<level::INFO>(fmt::format("No power supplies to monitor").c_str());
	}
	}

	void PSUManager::populateSysProperties(const util::DbusPropertyMap& properties)
	{
	try
	{
	auto propIt = properties.find("SupportedType");
	if (propIt == properties.end())
	{
	return;
	}
	const std::string* type = std::get_if<std::string>(&(propIt->second));
	if ((type == nullptr) \|\| (*type != "PowerSupply"))
	{
	return;
	}

	std::vector<std::string> models;
	propIt = properties.find("SupportedModel");
	if (propIt == properties.end())
	{
	return;
	}
	const std::vector<std::string>* modelsPtr =
	std::get_if<std::vector<std::string>>(&(propIt->second));
	if (modelsPtr == nullptr)
	{
	return;
	}
	models = *modelsPtr;

	sys_properties sys{0, 0};
	propIt = properties.find("RedundantCount");
	if (propIt != properties.end())
	{
	const uint64_t* count = std::get_if<uint64_t>(&(propIt->second));
	if (count != nullptr)
	{
	sys.maxPowerSupplies = *count;
	}
	}
	propIt = properties.find("InputVoltage");
	if (propIt != properties.end())
	{
	const uint64_t* voltage = std::get_if<uint64_t>(&(propIt->second));
	if (voltage != nullptr)
	{
	sys.inputVoltage = *voltage;
	}
	}

	for (const auto& model : models)
	{
	supportedConfigs.insert(std::make_pair(model, sys));
	}
	}
	catch (std::exception& e)
	{
	}
	}

	void PSUManager::getSystemProperties()
	{

	try
	{
	util::DbusSubtree subtree =
	util::getSubTree(bus, INVENTORY_OBJ_PATH, supportedConfIntf, 0);
	if (subtree.empty())
	{
	throw std::runtime_error("Supported Configuration Not Found");
	}

	for (const auto& [objPath, services] : subtree)
	{
	std::string service = services.begin()->first;
	if (objPath.empty() \|\| service.empty())
	{
	continue;
	}
	auto properties = util::getAllProperties(
	bus, objPath, supportedConfIntf, service);
	populateSysProperties(properties);
	}
	}
	catch (std::exception& e)
	{
	// Interface or property not found. Let the Interfaces Added callback
	// process the information once the interfaces are added to D-Bus.
	}
	}

	void PSUManager::entityManagerIfaceAdded(sdbusplus::message::message& msg)
	{
	try
	{
	sdbusplus::message::object_path objPath;
	std::map<std::string, std::map<std::string, util::DbusVariant>>
	interfaces;
	msg.read(objPath, interfaces);

	auto itIntf = interfaces.find(supportedConfIntf);
	if (itIntf != interfaces.cend())
	{
	populateSysProperties(itIntf->second);
	}

	itIntf = interfaces.find(IBMCFFPSInterface);
	if (itIntf != interfaces.cend())
	{
	log<level::INFO>(
	fmt::format("InterfacesAdded for: {}", IBMCFFPSInterface)
	.c_str());
	getPSUProperties(itIntf->second);
	}
	}
	catch (std::exception& e)
	{
	// Ignore, the property may be of a different type than expected.
	}
	}

	void PSUManager::powerStateChanged(sdbusplus::message::message& msg)
	{
	int32_t state = 0;
	std::string msgSensor;
	std::map<std::string, std::variant<int32_t>> msgData;
	msg.read(msgSensor, msgData);

	// Check if it was the Present property that changed.
	auto valPropMap = msgData.find("state");
	if (valPropMap != msgData.end())
	{
	state = std::get<int32_t>(valPropMap->second);

	// Power is on when state=1. Clear faults.
	if (state)
	{
	powerOn = true;
	clearFaults();
	}
	else
	{
	powerOn = false;
	}
	}
	}

	void PSUManager::createError(
	const std::string& faultName,
	const std::map<std::string, std::string>& additionalData)
	{
	using namespace sdbusplus::xyz::openbmc_project;
	constexpr auto loggingObjectPath = "/xyz/openbmc_project/logging";
	constexpr auto loggingCreateInterface =
	"xyz.openbmc_project.Logging.Create";

	try
	{
	auto service =
	util::getService(loggingObjectPath, loggingCreateInterface, bus);

	if (service.empty())
	{
	log<level::ERR>("Unable to get logging manager service");
	return;
	}

	auto method = bus.new_method_call(service.c_str(), loggingObjectPath,
	loggingCreateInterface, "Create");

	auto level = Logging::server::Entry::Level::Error;
	method.append(faultName, level, additionalData);

	auto reply = bus.call(method);
	}
	catch (std::exception& e)
	{
	log<level::ERR>(
	fmt::format(
	"Failed creating event log for fault {} due to error {}",
	faultName, e.what())
	.c_str());
	}
	}

	void PSUManager::analyze()
	{
	for (auto& psu : psus)
	{
	psu->analyze();
	}

	if (powerOn)
	{
	for (auto& psu : psus)
	{
	std::map<std::string, std::string> additionalData;
	additionalData["_PID"] = std::to_string(getpid());
	// TODO: Fault priorities #918
	if (!psu->isFaultLogged() && !psu->isPresent())
	{
	// Create error for power supply missing.
	additionalData["CALLOUT_INVENTORY_PATH"] =
	psu->getInventoryPath();
	additionalData["CALLOUT_PRIORITY"] = "H";
	createError(
	"xyz.openbmc_project.Power.PowerSupply.Error.Missing",
	additionalData);
	psu->setFaultLogged();
	}
	else if (!psu->isFaultLogged() && psu->isFaulted())
	{
	additionalData["STATUS_WORD"] =
	std::to_string(psu->getStatusWord());
	additionalData["STATUS_MFR"] =
	std::to_string(psu->getMFRFault());
	// If there are faults being reported, they possibly could be
	// related to a bug in the firmware version running on the power
	// supply. Capture that data into the error as well.
	additionalData["FW_VERSION"] = psu->getFWVersion();

	if ((psu->hasInputFault() \|\| psu->hasVINUVFault()))
	{
	/* The power supply location might be needed if the input
	* fault is due to a problem with the power supply itself.
	* Include the inventory path with a call out priority of
	* low.
	*/
	additionalData["CALLOUT_INVENTORY_PATH"] =
	psu->getInventoryPath();
	additionalData["CALLOUT_PRIORITY"] = "L";
	createError("xyz.openbmc_project.Power.PowerSupply.Error."
	"InputFault",
	additionalData);
	psu->setFaultLogged();
	}
	else if (psu->hasMFRFault())
	{
	/* This can represent a variety of faults that result in
	* calling out the power supply for replacement: Output
	* OverCurrent, Output Under Voltage, and potentially other
	* faults.
	*
	* Also plan on putting specific fault in AdditionalData,
	* along with register names and register values
	* (STATUS_WORD, STATUS_MFR, etc.).*/

	additionalData["CALLOUT_INVENTORY_PATH"] =
	psu->getInventoryPath();

	createError(
	"xyz.openbmc_project.Power.PowerSupply.Error.Fault",
	additionalData);

	psu->setFaultLogged();
	}
	else if (psu->hasCommFault())
	{
	/* Attempts to communicate with the power supply have
	* reached there limit. Create an error. */
	additionalData["CALLOUT_DEVICE_PATH"] =
	psu->getDevicePath();

	createError(
	"xyz.openbmc_project.Power.PowerSupply.Error.CommFault",
	additionalData);

	psu->setFaultLogged();
	}
	}
	}
	}
	}

	} // namespace phosphor::power::manager