blob: 4df71e900bf2d389ab5cb20b010dfab3b803eeb7 [file] [log] [blame]
#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 "platform-mc/manager.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 "oem_ibm.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 to add response header for processing Rx, error - {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<platform_config::Handler> platformConfigHandler{};
platformConfigHandler = std::make_unique<platform_config::Handler>();
if (hostEID)
{
hostPDRHandler = std::make_shared<HostPDRHandler>(
pldmTransport.getEventSource(), hostEID, event, pdrRepo.get(),
EVENTS_JSONS_DIR, entityTree.get(), bmcEntityTree.get(),
instanceIdDb, &reqHandler);
// 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 fruHandler = std::make_unique<fru::Handler>(
FRU_JSONS_DIR, FRU_MASTER_JSON, pdrRepo.get(), entityTree.get(),
bmcEntityTree.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(),
platformConfigHandler.get(), &reqHandler, event, true);
auto biosHandler = std::make_unique<bios::Handler>(
pldmTransport.getEventSource(), hostEID, &instanceIdDb, &reqHandler,
platformConfigHandler.get(), requestPLDMServiceName);
auto baseHandler = std::make_unique<base::Handler>(event);
#ifdef OEM_IBM
pldm::oem_ibm::OemIBM oemIBM(&dbusHandler, pldmTransport.getEventSource(),
hostEID, pdrRepo.get(), instanceIdDb, event,
invoker, hostPDRHandler.get(),
platformHandler.get(), fruHandler.get(),
baseHandler.get(), &reqHandler);
#endif
invoker.registerHandler(PLDM_BIOS, std::move(biosHandler));
invoker.registerHandler(PLDM_PLATFORM, std::move(platformHandler));
invoker.registerHandler(PLDM_FRU, std::move(fruHandler));
invoker.registerHandler(PLDM_BASE, std::move(baseHandler));
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<platform_mc::Manager> platformManager =
std::make_unique<platform_mc::Manager>(event, reqHandler, instanceIdDb);
std::unique_ptr<MctpDiscovery> mctpDiscoveryHandler =
std::make_unique<MctpDiscovery>(
bus, std::initializer_list<MctpDiscoveryHandlerIntf*>{
fwManager.get(), platformManager.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 pldmTransport message for TID '{TID}', response code '{RETURN_CODE}'",
"TID", TID, "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(
"MCTP daemon closed the socket, IO exiting with response code '{RC}'",
"RC", returnCode);
io.get_event().exit(0);
}
else
{
warning(
"Failed to receive PLDM request for pldmTransport, response code '{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);
}