| |
| #include "common/flight_recorder.hpp" |
| #include "common/instance_id.hpp" |
| #include "common/transport.hpp" |
| #include "common/utils.hpp" |
| #include "dbus_impl_requester.hpp" |
| #include "fw-update/manager.hpp" |
| #include "invoker.hpp" |
| #include "requester/handler.hpp" |
| #include "requester/mctp_endpoint_discovery.hpp" |
| #include "requester/request.hpp" |
| |
| #include <err.h> |
| #include <getopt.h> |
| #include <libpldm/base.h> |
| #include <libpldm/bios.h> |
| #include <libpldm/pdr.h> |
| #include <libpldm/platform.h> |
| #include <libpldm/transport.h> |
| #include <poll.h> |
| #include <stdlib.h> |
| #include <sys/socket.h> |
| #include <sys/types.h> |
| #include <sys/un.h> |
| #include <unistd.h> |
| |
| #include <phosphor-logging/lg2.hpp> |
| #include <sdeventplus/event.hpp> |
| #include <sdeventplus/source/io.hpp> |
| #include <sdeventplus/source/signal.hpp> |
| #include <stdplus/signal.hpp> |
| |
| #include <cstdio> |
| #include <cstring> |
| #include <fstream> |
| #include <iomanip> |
| #include <iterator> |
| #include <memory> |
| #include <ranges> |
| #include <sstream> |
| #include <stdexcept> |
| #include <string> |
| #include <vector> |
| |
| PHOSPHOR_LOG2_USING; |
| |
| #ifdef LIBPLDMRESPONDER |
| #include "dbus_impl_pdr.hpp" |
| #include "host-bmc/dbus_to_event_handler.hpp" |
| #include "host-bmc/dbus_to_host_effecters.hpp" |
| #include "host-bmc/host_condition.hpp" |
| #include "host-bmc/host_pdr_handler.hpp" |
| #include "libpldmresponder/base.hpp" |
| #include "libpldmresponder/bios.hpp" |
| #include "libpldmresponder/fru.hpp" |
| #include "libpldmresponder/oem_handler.hpp" |
| #include "libpldmresponder/platform.hpp" |
| #include "libpldmresponder/platform_config.hpp" |
| #include "xyz/openbmc_project/PLDM/Event/server.hpp" |
| #endif |
| |
| #ifdef OEM_IBM |
| #include "libpldmresponder/file_io.hpp" |
| #include "libpldmresponder/fru_oem_ibm.hpp" |
| #include "libpldmresponder/oem_ibm_handler.hpp" |
| #endif |
| |
| constexpr uint8_t MCTP_MSG_TYPE_PLDM = 1; |
| |
| using namespace pldm; |
| using namespace sdeventplus; |
| using namespace sdeventplus::source; |
| using namespace pldm::responder; |
| using namespace pldm::utils; |
| using sdeventplus::source::Signal; |
| using namespace pldm::flightrecorder; |
| |
| void interruptFlightRecorderCallBack(Signal& /*signal*/, |
| const struct signalfd_siginfo*) |
| { |
| error("Received SIGUR1(10) Signal interrupt"); |
| // obtain the flight recorder instance and dump the recorder |
| FlightRecorder::GetInstance().playRecorder(); |
| } |
| |
| void requestPLDMServiceName() |
| { |
| auto& bus = pldm::utils::DBusHandler::getBus(); |
| bus.request_name("xyz.openbmc_project.PLDM"); |
| } |
| |
| static std::optional<Response> |
| processRxMsg(const std::vector<uint8_t>& requestMsg, Invoker& invoker, |
| requester::Handler<requester::Request>& handler, |
| fw_update::Manager* fwManager, pldm_tid_t tid) |
| { |
| uint8_t eid = tid; |
| |
| pldm_header_info hdrFields{}; |
| auto hdr = reinterpret_cast<const pldm_msg_hdr*>(requestMsg.data()); |
| if (PLDM_SUCCESS != unpack_pldm_header(hdr, &hdrFields)) |
| { |
| error("Empty PLDM request header"); |
| return std::nullopt; |
| } |
| |
| if (PLDM_RESPONSE != hdrFields.msg_type) |
| { |
| Response response; |
| auto request = reinterpret_cast<const pldm_msg*>(hdr); |
| size_t requestLen = requestMsg.size() - sizeof(struct pldm_msg_hdr); |
| try |
| { |
| if (hdrFields.pldm_type != PLDM_FWUP) |
| { |
| response = invoker.handle(tid, hdrFields.pldm_type, |
| hdrFields.command, request, |
| requestLen); |
| } |
| else |
| { |
| response = fwManager->handleRequest(eid, hdrFields.command, |
| request, requestLen); |
| } |
| } |
| catch (const std::out_of_range& e) |
| { |
| uint8_t completion_code = PLDM_ERROR_UNSUPPORTED_PLDM_CMD; |
| response.resize(sizeof(pldm_msg_hdr)); |
| auto responseHdr = reinterpret_cast<pldm_msg_hdr*>(response.data()); |
| pldm_header_info header{}; |
| header.msg_type = PLDM_RESPONSE; |
| header.instance = hdrFields.instance; |
| header.pldm_type = hdrFields.pldm_type; |
| header.command = hdrFields.command; |
| if (PLDM_SUCCESS != pack_pldm_header(&header, responseHdr)) |
| { |
| error("Failed adding response header: {ERROR}", "ERROR", e); |
| return std::nullopt; |
| } |
| response.insert(response.end(), completion_code); |
| } |
| return response; |
| } |
| else if (PLDM_RESPONSE == hdrFields.msg_type) |
| { |
| auto response = reinterpret_cast<const pldm_msg*>(hdr); |
| size_t responseLen = requestMsg.size() - sizeof(struct pldm_msg_hdr); |
| handler.handleResponse(eid, hdrFields.instance, hdrFields.pldm_type, |
| hdrFields.command, response, responseLen); |
| } |
| return std::nullopt; |
| } |
| |
| void optionUsage(void) |
| { |
| info("Usage: pldmd [options]"); |
| info("Options:"); |
| info(" [--verbose] - would enable verbosity"); |
| } |
| |
| int main(int argc, char** argv) |
| { |
| bool verbose = false; |
| static struct option long_options[] = {{"verbose", no_argument, 0, 'v'}, |
| {0, 0, 0, 0}}; |
| |
| auto argflag = getopt_long(argc, argv, "v", long_options, nullptr); |
| switch (argflag) |
| { |
| case 'v': |
| verbose = true; |
| break; |
| case -1: |
| break; |
| default: |
| optionUsage(); |
| exit(EXIT_FAILURE); |
| } |
| // Setup PLDM requester transport |
| auto hostEID = pldm::utils::readHostEID(); |
| /* To maintain current behaviour until we have the infrastructure to find |
| * and use the correct TIDs */ |
| pldm_tid_t TID = hostEID; |
| PldmTransport pldmTransport{}; |
| auto event = Event::get_default(); |
| auto& bus = pldm::utils::DBusHandler::getBus(); |
| sdbusplus::server::manager_t objManager(bus, |
| "/xyz/openbmc_project/software"); |
| |
| InstanceIdDb instanceIdDb; |
| dbus_api::Requester dbusImplReq(bus, "/xyz/openbmc_project/pldm", |
| instanceIdDb); |
| sdbusplus::server::manager_t inventoryManager( |
| bus, "/xyz/openbmc_project/inventory"); |
| |
| Invoker invoker{}; |
| requester::Handler<requester::Request> reqHandler(&pldmTransport, event, |
| instanceIdDb, verbose); |
| |
| #ifdef LIBPLDMRESPONDER |
| using namespace pldm::state_sensor; |
| dbus_api::Host dbusImplHost(bus, "/xyz/openbmc_project/pldm"); |
| std::unique_ptr<pldm_pdr, decltype(&pldm_pdr_destroy)> pdrRepo( |
| pldm_pdr_init(), pldm_pdr_destroy); |
| if (!pdrRepo) |
| { |
| throw std::runtime_error("Failed to instantiate PDR repository"); |
| } |
| std::unique_ptr<pldm_entity_association_tree, |
| decltype(&pldm_entity_association_tree_destroy)> |
| entityTree(pldm_entity_association_tree_init(), |
| pldm_entity_association_tree_destroy); |
| if (!entityTree) |
| { |
| throw std::runtime_error( |
| "Failed to instantiate general PDR entity association tree"); |
| } |
| std::unique_ptr<pldm_entity_association_tree, |
| decltype(&pldm_entity_association_tree_destroy)> |
| bmcEntityTree(pldm_entity_association_tree_init(), |
| pldm_entity_association_tree_destroy); |
| if (!bmcEntityTree) |
| { |
| throw std::runtime_error( |
| "Failed to instantiate BMC PDR entity association tree"); |
| } |
| std::shared_ptr<HostPDRHandler> hostPDRHandler; |
| std::unique_ptr<pldm::host_effecters::HostEffecterParser> |
| hostEffecterParser; |
| std::unique_ptr<DbusToPLDMEvent> dbusToPLDMEventHandler; |
| DBusHandler dbusHandler; |
| std::unique_ptr<oem_platform::Handler> oemPlatformHandler{}; |
| std::unique_ptr<platform_config::Handler> platformConfigHandler{}; |
| platformConfigHandler = std::make_unique<platform_config::Handler>(); |
| std::unique_ptr<oem_fru::Handler> oemFruHandler{}; |
| |
| #ifdef OEM_IBM |
| std::unique_ptr<pldm::responder::CodeUpdate> codeUpdate = |
| std::make_unique<pldm::responder::CodeUpdate>(&dbusHandler); |
| codeUpdate->clearDirPath(LID_STAGING_DIR); |
| oemPlatformHandler = std::make_unique<oem_ibm_platform::Handler>( |
| &dbusHandler, codeUpdate.get(), pldmTransport.getEventSource(), hostEID, |
| instanceIdDb, event, &reqHandler); |
| codeUpdate->setOemPlatformHandler(oemPlatformHandler.get()); |
| oemFruHandler = std::make_unique<oem_ibm_fru::Handler>(pdrRepo.get()); |
| invoker.registerHandler(PLDM_OEM, std::make_unique<oem_ibm::Handler>( |
| oemPlatformHandler.get(), |
| pldmTransport.getEventSource(), |
| hostEID, &instanceIdDb, &reqHandler)); |
| #endif |
| if (hostEID) |
| { |
| hostPDRHandler = std::make_shared<HostPDRHandler>( |
| pldmTransport.getEventSource(), hostEID, event, pdrRepo.get(), |
| EVENTS_JSONS_DIR, entityTree.get(), bmcEntityTree.get(), |
| instanceIdDb, &reqHandler, oemPlatformHandler.get()); |
| // HostFirmware interface needs access to hostPDR to know if host |
| // is running |
| dbusImplHost.setHostPdrObj(hostPDRHandler); |
| |
| hostEffecterParser = |
| std::make_unique<pldm::host_effecters::HostEffecterParser>( |
| &instanceIdDb, pldmTransport.getEventSource(), pdrRepo.get(), |
| &dbusHandler, HOST_JSONS_DIR, &reqHandler); |
| dbusToPLDMEventHandler = std::make_unique<DbusToPLDMEvent>( |
| pldmTransport.getEventSource(), hostEID, instanceIdDb, &reqHandler); |
| } |
| auto biosHandler = std::make_unique<bios::Handler>( |
| pldmTransport.getEventSource(), hostEID, &instanceIdDb, &reqHandler, |
| platformConfigHandler.get(), requestPLDMServiceName); |
| |
| auto fruHandler = std::make_unique<fru::Handler>( |
| FRU_JSONS_DIR, FRU_MASTER_JSON, pdrRepo.get(), entityTree.get(), |
| bmcEntityTree.get(), oemFruHandler.get()); |
| |
| // FRU table is built lazily when a FRU command or Get PDR command is |
| // handled. To enable building FRU table, the FRU handler is passed to the |
| // Platform handler. |
| auto platformHandler = std::make_unique<platform::Handler>( |
| &dbusHandler, hostEID, &instanceIdDb, PDR_JSONS_DIR, pdrRepo.get(), |
| hostPDRHandler.get(), dbusToPLDMEventHandler.get(), fruHandler.get(), |
| oemPlatformHandler.get(), platformConfigHandler.get(), &reqHandler, |
| event, true); |
| #ifdef OEM_IBM |
| pldm::responder::oem_ibm_platform::Handler* oemIbmPlatformHandler = |
| dynamic_cast<pldm::responder::oem_ibm_platform::Handler*>( |
| oemPlatformHandler.get()); |
| oemIbmPlatformHandler->setPlatformHandler(platformHandler.get()); |
| |
| pldm::responder::oem_ibm_fru::Handler* oemIbmFruHandler = |
| dynamic_cast<pldm::responder::oem_ibm_fru::Handler*>( |
| oemFruHandler.get()); |
| oemIbmFruHandler->setIBMFruHandler(fruHandler.get()); |
| #endif |
| |
| invoker.registerHandler(PLDM_BIOS, std::move(biosHandler)); |
| invoker.registerHandler(PLDM_PLATFORM, std::move(platformHandler)); |
| invoker.registerHandler(PLDM_BASE, std::make_unique<base::Handler>( |
| event, oemPlatformHandler.get())); |
| invoker.registerHandler(PLDM_FRU, std::move(fruHandler)); |
| dbus_api::Pdr dbusImplPdr(bus, "/xyz/openbmc_project/pldm", pdrRepo.get()); |
| sdbusplus::xyz::openbmc_project::PLDM::server::Event dbusImplEvent( |
| bus, "/xyz/openbmc_project/pldm"); |
| |
| #endif |
| |
| std::unique_ptr<fw_update::Manager> fwManager = |
| std::make_unique<fw_update::Manager>(event, reqHandler, instanceIdDb); |
| std::unique_ptr<MctpDiscovery> mctpDiscoveryHandler = |
| std::make_unique<MctpDiscovery>(bus, fwManager.get()); |
| auto callback = [verbose, &invoker, &reqHandler, &fwManager, &pldmTransport, |
| TID](IO& io, int fd, uint32_t revents) mutable { |
| if (!(revents & EPOLLIN)) |
| { |
| return; |
| } |
| if (fd < 0) |
| { |
| return; |
| } |
| |
| int returnCode = 0; |
| void* requestMsg; |
| size_t recvDataLength; |
| returnCode = pldmTransport.recvMsg(TID, requestMsg, recvDataLength); |
| |
| if (returnCode == PLDM_REQUESTER_SUCCESS) |
| { |
| std::vector<uint8_t> requestMsgVec( |
| static_cast<uint8_t*>(requestMsg), |
| static_cast<uint8_t*>(requestMsg) + recvDataLength); |
| FlightRecorder::GetInstance().saveRecord(requestMsgVec, false); |
| if (verbose) |
| { |
| printBuffer(Rx, requestMsgVec); |
| } |
| // process message and send response |
| auto response = processRxMsg(requestMsgVec, invoker, reqHandler, |
| fwManager.get(), TID); |
| if (response.has_value()) |
| { |
| FlightRecorder::GetInstance().saveRecord(*response, true); |
| if (verbose) |
| { |
| printBuffer(Tx, *response); |
| } |
| |
| returnCode = pldmTransport.sendMsg(TID, (*response).data(), |
| (*response).size()); |
| if (returnCode != PLDM_REQUESTER_SUCCESS) |
| { |
| warning("Failed to send PLDM response: {RETURN_CODE}", |
| "RETURN_CODE", returnCode); |
| } |
| } |
| } |
| // TODO check that we get here if mctp-demux dies? |
| else if (returnCode == PLDM_REQUESTER_RECV_FAIL) |
| { |
| // MCTP daemon has closed the socket this daemon is connected to. |
| // This may or may not be an error scenario, in either case the |
| // recovery mechanism for this daemon is to restart, and hence exit |
| // the event loop, that will cause this daemon to exit with a |
| // failure code. |
| error("io exiting"); |
| io.get_event().exit(0); |
| } |
| else |
| { |
| warning("Failed to receive PLDM request: {RETURN_CODE}", |
| "RETURN_CODE", returnCode); |
| } |
| /* Free requestMsg after using */ |
| free(requestMsg); |
| }; |
| |
| bus.attach_event(event.get(), SD_EVENT_PRIORITY_NORMAL); |
| #ifndef SYSTEM_SPECIFIC_BIOS_JSON |
| bus.request_name("xyz.openbmc_project.PLDM"); |
| #endif |
| IO io(event, pldmTransport.getEventSource(), EPOLLIN, std::move(callback)); |
| #ifdef LIBPLDMRESPONDER |
| if (hostPDRHandler) |
| { |
| hostPDRHandler->setHostFirmwareCondition(); |
| } |
| #endif |
| stdplus::signal::block(SIGUSR1); |
| sdeventplus::source::Signal sigUsr1( |
| event, SIGUSR1, std::bind_front(&interruptFlightRecorderCallBack)); |
| int returnCode = event.loop(); |
| if (returnCode) |
| { |
| exit(EXIT_FAILURE); |
| } |
| |
| exit(EXIT_SUCCESS); |
| } |