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.cpp b/oem/ibm/libpldmresponder/file_io.cpp
index bf622c3..9322d9d 100644
--- a/oem/ibm/libpldmresponder/file_io.cpp
+++ b/oem/ibm/libpldmresponder/file_io.cpp
@@ -611,6 +611,56 @@
payloadLength);
}
+Response Handler::writeFileByType(const pldm_msg* request, size_t payloadLength)
+{
+ Response response(sizeof(pldm_msg_hdr) + PLDM_RW_FILE_BY_TYPE_RESP_BYTES);
+ auto responsePtr = reinterpret_cast<pldm_msg*>(response.data());
+
+ if (payloadLength != PLDM_RW_FILE_BY_TYPE_REQ_BYTES)
+ {
+ encode_rw_file_by_type_resp(request->hdr.instance_id,
+ PLDM_WRITE_FILE_BY_TYPE,
+ PLDM_ERROR_INVALID_LENGTH, 0, responsePtr);
+ return response;
+ }
+ uint16_t fileType{};
+ uint32_t fileHandle{};
+ uint32_t offset{};
+ uint32_t length{};
+
+ auto rc = decode_rw_file_by_type_req(request, payloadLength, &fileType,
+ &fileHandle, &offset, &length);
+ if (rc != PLDM_SUCCESS)
+ {
+ encode_rw_file_by_type_resp(request->hdr.instance_id,
+ PLDM_WRITE_FILE_BY_TYPE, rc, 0,
+ responsePtr);
+ return response;
+ }
+
+ std::unique_ptr<FileHandler> handler{};
+ try
+ {
+ handler = getHandlerByType(fileType, fileHandle);
+ }
+ catch (const InternalFailure& e)
+ {
+ std::cerr << "unknown file type, TYPE=" << fileType << "\n";
+ encode_rw_file_by_type_resp(request->hdr.instance_id,
+ PLDM_WRITE_FILE_BY_TYPE,
+ PLDM_INVALID_FILE_TYPE, 0, responsePtr);
+ return response;
+ }
+
+ rc = handler->write(reinterpret_cast<const char*>(
+ request->payload + PLDM_RW_FILE_BY_TYPE_RESP_BYTES),
+ offset, length);
+ encode_rw_file_by_type_resp(request->hdr.instance_id,
+ PLDM_WRITE_FILE_BY_TYPE, rc, length,
+ responsePtr);
+ return response;
+}
+
Response Handler::readFileByType(const pldm_msg* request, size_t payloadLength)
{
Response response(sizeof(pldm_msg_hdr) + PLDM_RW_FILE_BY_TYPE_RESP_BYTES);
@@ -687,6 +737,7 @@
{
handler = getHandlerByType(fileType, fileHandle);
}
+
catch (const InternalFailure& e)
{
encode_file_ack_resp(request->hdr.instance_id, PLDM_INVALID_FILE_TYPE,
@@ -735,6 +786,44 @@
return response;
}
+Response Handler::newFileAvailable(const pldm_msg* request,
+ size_t payloadLength)
+{
+ Response response(sizeof(pldm_msg_hdr) + PLDM_NEW_FILE_RESP_BYTES);
+
+ if (payloadLength != PLDM_NEW_FILE_REQ_BYTES)
+ {
+ return CmdHandler::ccOnlyResponse(request, PLDM_ERROR_INVALID_LENGTH);
+ }
+ uint16_t fileType{};
+ uint32_t fileHandle{};
+ uint64_t length{};
+
+ auto rc = decode_new_file_req(request, payloadLength, &fileType,
+ &fileHandle, &length);
+
+ if (rc != PLDM_SUCCESS)
+ {
+ return CmdHandler::ccOnlyResponse(request, rc);
+ }
+
+ std::unique_ptr<FileHandler> handler{};
+ try
+ {
+ handler = getHandlerByType(fileType, fileHandle);
+ }
+ catch (const InternalFailure& e)
+ {
+ std::cerr << "unknown file type, TYPE=" << fileType << "\n";
+ return CmdHandler::ccOnlyResponse(request, PLDM_INVALID_FILE_TYPE);
+ }
+
+ rc = handler->newFileAvailable(length);
+ auto responsePtr = reinterpret_cast<pldm_msg*>(response.data());
+ encode_new_file_resp(request->hdr.instance_id, rc, responsePtr);
+ return response;
+}
+
} // namespace oem_ibm
} // namespace responder
} // namespace pldm