diff options
Diffstat (limited to 'fault-monitor/fru-fault-monitor.cpp')
| -rw-r--r-- | fault-monitor/fru-fault-monitor.cpp | 196 |
1 files changed, 195 insertions, 1 deletions
diff --git a/fault-monitor/fru-fault-monitor.cpp b/fault-monitor/fru-fault-monitor.cpp index 1213128..e21727b 100644 --- a/fault-monitor/fru-fault-monitor.cpp +++ b/fault-monitor/fru-fault-monitor.cpp @@ -1,4 +1,9 @@ +#include <phosphor-logging/elog.hpp> +#include "xyz/openbmc_project/Led/Fru/Monitor/error.hpp" +#include "xyz/openbmc_project/Led/Mapper/error.hpp" +#include "elog-errors.hpp" #include "fru-fault-monitor.hpp" + namespace phosphor { namespace led @@ -10,10 +15,105 @@ namespace fault namespace monitor { +using namespace phosphor::logging; + +constexpr auto MAPPER_BUSNAME = "xyz.openbmc_project.ObjectMapper"; +constexpr auto MAPPER_OBJ_PATH = "/xyz/openbmc_project/object_mapper"; +constexpr auto MAPPER_IFACE = "xyz.openbmc_project.ObjectMapper"; +constexpr auto OBJMGR_IFACE = "org.freedesktop.DBus.ObjectManager"; +constexpr auto LED_GROUPS = "/xyz/openbmc_project/led/groups/"; +constexpr auto LOG_PATH = "/xyz/openbmc_project/logging"; + +using AssociationList = std::vector<std::tuple< + std::string, std::string, std::string>>; +using MethodErr = + sdbusplus::xyz::openbmc_project::Led::Mapper::Error::MethodError; +using ObjectNotFoundErr = + sdbusplus::xyz::openbmc_project::Led::Mapper::Error::ObjectNotFoundError; +using AssociationRetrieveErr = + sdbusplus::xyz::openbmc_project:: + Led::Fru::Monitor::Error::AssociationRetrieveError; +using InventoryPathErr = + sdbusplus::xyz::openbmc_project:: + Led::Fru::Monitor::Error::InventoryPathError; + +std::string getService(sdbusplus::bus::bus& bus, + const std::string& path) +{ + auto mapper = bus.new_method_call(MAPPER_BUSNAME, + MAPPER_OBJ_PATH, + MAPPER_IFACE, "GetObject"); + mapper.append(path.c_str(), std::vector<std::string>({OBJMGR_IFACE})); + auto mapperResponseMsg = bus.call(mapper); + if (mapperResponseMsg.is_method_error()) + { + using namespace xyz::openbmc_project::Led::Mapper; + elog<MethodErr>( + MethodError::METHOD_NAME("GetObject"), + MethodError::PATH(path.c_str()), + MethodError::INTERFACE( + OBJMGR_IFACE)); + } + + std::map<std::string, std::vector<std::string>> mapperResponse; + mapperResponseMsg.read(mapperResponse); + if (mapperResponse.empty()) + { + using namespace xyz::openbmc_project::Led::Mapper; + elog<ObjectNotFoundErr>( + ObjectNotFoundError::METHOD_NAME("GetObject"), + ObjectNotFoundError::PATH(path.c_str()), + ObjectNotFoundError::INTERFACE( + OBJMGR_IFACE)); + } + + return mapperResponse.cbegin()->first; +} + void action(sdbusplus::bus::bus& bus, - const std::string& unit, + const std::string& path, bool assert) { + std::string service; + try + { + service = getService(bus, LED_GROUPS); + } + catch (MethodErr& e) + { + commit<MethodErr>(); + return; + } + catch (ObjectNotFoundErr& e) + { + commit<ObjectNotFoundErr>(); + return; + } + + auto pos = path.rfind("/"); + if (pos == std::string::npos) + { + using namespace xyz::openbmc_project::Led::Fru::Monitor; + report<InventoryPathErr>( + InventoryPathError::PATH( + path.c_str())); + return; + } + auto unit = path.substr(pos + 1); + + std::string ledPath = LED_GROUPS + + unit + '_' + LED_FAULT; + + auto method = bus.new_method_call(service.c_str(), + ledPath.c_str(), + "org.freedesktop.DBus.Properties", + "Set"); + method.append("xyz.openbmc_project.Led.Group"); + method.append("Asserted"); + + method.append(sdbusplus::message::variant<bool>(assert)); + bus.call_noreply(method); + return; } @@ -21,6 +121,72 @@ int Add::created(sd_bus_message* msg, void* data, sd_bus_error* retError) { + auto m = sdbusplus::message::message(msg); + auto bus = m.get_bus(); + + sdbusplus::message::object_path obPath; + m.read(obPath); + std::string objectPath(std::move(obPath)); + + std::size_t found = objectPath.find(ELOG_ENTRY); + if (found == std::string::npos) + { + //Not a new error entry skip + return 0; + } + + std::string service; + try + { + service = getService(bus, LOG_PATH); + } + catch (MethodErr& e) + { + commit<MethodErr>(); + return 0; + } + catch (ObjectNotFoundErr& e) + { + commit<ObjectNotFoundErr>(); + return 0; + } + + auto method = bus.new_method_call(service.c_str(), objectPath.c_str(), + "org.freedesktop.DBus.Properties", + "Get"); + + method.append("org.openbmc.Associations"); + method.append("associations"); + auto reply = bus.call(method); + if (reply.is_method_error()) + { + using namespace xyz::openbmc_project::Led::Fru::Monitor; + report<AssociationRetrieveErr>( + AssociationRetrieveError::ELOG_ENTRY_PATH( + objectPath.c_str())); + return 0; + } + + sdbusplus::message::variant<AssociationList> assoc; + reply.read(assoc); + + auto assocs = + sdbusplus::message::variant_ns::get<AssociationList>(assoc); + if (assocs.empty()) + { + //No associations skip + return 0; + } + + for (const auto& item : assocs) + { + if (std::get<1>(item).compare(CALLOUT_REV_ASSOCIATION) == 0) + { + action(bus, std::get<2>(item), true); + static_cast<Add*>(data)->removeWatches.emplace_back( + std::make_unique<Remove>(bus, std::get<2>(item))); + } + } return 0; } @@ -28,6 +194,34 @@ int Remove::removed(sd_bus_message* msg, void* data, sd_bus_error* retError) { + auto m = sdbusplus::message::message(msg); + auto bus = m.get_bus(); + std::string assoc; + m.read(assoc); + + if (assoc.compare("org.openbmc.Association")) + { + //Skip if not about association + return 0; + } + + std::map<std::string, std::vector<std::string>> endPoints; + m.read(endPoints); + auto it = endPoints.find("endpoints"); + + if (it == endPoints.end()) + { + //No end points,skip + return 0; + } + + if (!((*it).second.empty())) + { + //Skip, end points are not empty + return 0; + } + + action(bus, static_cast<Remove*>(data)->inventoryPath, false); return 0; } |
