implement commands for dump xfer
This commit implements the writeFile command
for dumpHandler in PLDM oem. This is for offloading
the dump from host memory to an external location
via bmc. Also it implements the newfileAvailable
notification handler in libpldmresponder.This caters
to the new dump notification coming from the Host
Change-Id: Ibf7c1facea282ec4f772dfee646cca9f7877bb7d
Signed-off-by: Sampa Misra <sampmisr@in.ibm.com>
diff --git a/oem/ibm/libpldmresponder/file_io_type_dump.cpp b/oem/ibm/libpldmresponder/file_io_type_dump.cpp
new file mode 100644
index 0000000..2360733
--- /dev/null
+++ b/oem/ibm/libpldmresponder/file_io_type_dump.cpp
@@ -0,0 +1,110 @@
+#include "file_io_type_dump.hpp"
+
+#include "utils.hpp"
+#include "xyz/openbmc_project/Common/error.hpp"
+
+#include <stdint.h>
+#include <systemd/sd-bus.h>
+#include <unistd.h>
+
+#include <exception>
+#include <filesystem>
+#include <iostream>
+#include <sdbusplus/server.hpp>
+#include <xyz/openbmc_project/Dump/NewDump/server.hpp>
+
+#include "libpldm/base.h"
+#include "oem/ibm/libpldm/file_io.h"
+
+namespace pldm
+{
+namespace responder
+{
+
+static constexpr auto nbdInterface = "/dev/nbd1";
+
+int DumpHandler::fd = -1;
+
+int DumpHandler::newFileAvailable(uint64_t length)
+{
+ static constexpr auto dumpObjPath = "/xyz/openbmc_project/dump";
+ static constexpr auto dumpInterface = "xyz.openbmc_project.Dump.NewDump";
+
+ auto& bus = pldm::utils::DBusHandler::getBus();
+
+ try
+ {
+ auto service =
+ pldm::utils::DBusHandler().getService(dumpObjPath, dumpInterface);
+ using namespace sdbusplus::xyz::openbmc_project::Dump::server;
+ auto method = bus.new_method_call(service.c_str(), dumpObjPath,
+ dumpInterface, "Notify");
+ method.append(
+ sdbusplus::xyz::openbmc_project::Dump::server::convertForMessage(
+ NewDump::DumpType::System),
+ fileHandle, length);
+ bus.call_noreply(method);
+ }
+ catch (const std::exception& e)
+ {
+ std::cerr << "failed to make a d-bus call to DUMP manager, ERROR="
+ << e.what() << "\n";
+ return PLDM_ERROR;
+ }
+
+ return PLDM_SUCCESS;
+}
+
+int DumpHandler::writeFromMemory(uint32_t offset, uint32_t length,
+ uint64_t address)
+{
+ int flags = O_WRONLY | O_CREAT | O_TRUNC | O_LARGEFILE;
+
+ if (DumpHandler::fd == -1)
+ {
+ DumpHandler::fd = open(nbdInterface, flags);
+ if (DumpHandler::fd == -1)
+ {
+ std::cerr << "NBD file does not exist at " << nbdInterface
+ << " ERROR=" << errno << "\n";
+ return PLDM_ERROR;
+ }
+ }
+ return transferFileData(DumpHandler::fd, false, offset, length, address);
+}
+
+int DumpHandler::write(const char* buffer, uint32_t offset, uint32_t& length)
+{
+ int flags = O_WRONLY | O_CREAT | O_TRUNC | O_LARGEFILE;
+ if (DumpHandler::fd == -1)
+ {
+ DumpHandler::fd = open(nbdInterface, flags);
+ if (DumpHandler::fd == -1)
+ {
+ std::cerr << "NBD file does not exist at " << nbdInterface
+ << " ERROR=" << errno << "\n";
+ return PLDM_ERROR;
+ }
+ }
+
+ int rc = lseek(DumpHandler::fd, offset, SEEK_SET);
+ if (rc == -1)
+ {
+ std::cerr << "lseek failed, ERROR=" << errno << ", OFFSET=" << offset
+ << "\n";
+ return PLDM_ERROR;
+ }
+ rc = ::write(DumpHandler::fd, buffer, length);
+ if (rc == -1)
+ {
+ std::cerr << "file write failed, ERROR=" << errno
+ << ", LENGTH=" << length << ", OFFSET=" << offset << "\n";
+ return PLDM_ERROR;
+ }
+ length = rc;
+
+ return PLDM_SUCCESS;
+}
+
+} // namespace responder
+} // namespace pldm