| #include "config.h" |
| |
| #include "dump_manager_resource.hpp" |
| |
| #include "dump_utils.hpp" |
| #include "op_dump_consts.hpp" |
| #include "resource_dump_entry.hpp" |
| #include "xyz/openbmc_project/Common/error.hpp" |
| |
| #include <fmt/core.h> |
| |
| #include <phosphor-logging/elog-errors.hpp> |
| #include <phosphor-logging/elog.hpp> |
| |
| namespace openpower |
| { |
| namespace dump |
| { |
| namespace resource |
| { |
| |
| using namespace phosphor::logging; |
| using InternalFailure = |
| sdbusplus::xyz::openbmc_project::Common::Error::InternalFailure; |
| |
| void Manager::notify(uint32_t dumpId, uint64_t size) |
| { |
| // Get the timestamp |
| uint64_t timeStamp = |
| std::chrono::duration_cast<std::chrono::microseconds>( |
| std::chrono::system_clock::now().time_since_epoch()) |
| .count(); |
| |
| // If there is an entry with invalid id update that. |
| // If there a completed one with same source id ignore it |
| // if there is no invalid id, create new entry |
| openpower::dump::resource::Entry* upEntry = NULL; |
| for (auto& entry : entries) |
| { |
| openpower::dump::resource::Entry* resEntry = |
| dynamic_cast<openpower::dump::resource::Entry*>(entry.second.get()); |
| |
| // If there is already a completed entry with input source id then |
| // ignore this notification. |
| if ((resEntry->sourceDumpId() == dumpId) && |
| (resEntry->status() == phosphor::dump::OperationStatus::Completed)) |
| { |
| log<level::INFO>( |
| fmt::format("Resource dump entry with source dump id({}) is " |
| "already present with entry id({})", |
| dumpId, resEntry->getDumpId()) |
| .c_str()); |
| return; |
| } |
| |
| // Save the first entry with INVALID_SOURCE_ID |
| // but continue in the loop to make sure the |
| // new entry is not duplicate |
| if ((resEntry->status() == |
| phosphor::dump::OperationStatus::InProgress) && |
| (resEntry->sourceDumpId() == INVALID_SOURCE_ID) && |
| (upEntry == NULL)) |
| { |
| upEntry = resEntry; |
| } |
| } |
| if (upEntry != NULL) |
| { |
| log<level::INFO>( |
| fmt::format("Resource Dump Notify: Updating dumpId({}) " |
| "with source Id({}) Size({})", |
| upEntry->getDumpId(), dumpId, size) |
| .c_str()); |
| upEntry->update(timeStamp, size, dumpId); |
| return; |
| } |
| |
| // Get the id |
| auto id = lastEntryId + 1; |
| auto idString = std::to_string(id); |
| auto objPath = std::filesystem::path(baseEntryPath) / idString; |
| |
| // TODO: Get the originator Id, type from the persisted file. |
| // For now replacing it with null |
| |
| try |
| { |
| log<level::INFO>(fmt::format("Resouce Dump Notify: creating new dump " |
| "entry dumpId({}) Id({}) Size({})", |
| id, dumpId, size) |
| .c_str()); |
| entries.insert(std::make_pair( |
| id, std::make_unique<resource::Entry>( |
| bus, objPath.c_str(), id, timeStamp, size, dumpId, |
| std::string(), std::string(), |
| phosphor::dump::OperationStatus::Completed, std::string(), |
| originatorTypes::Internal, *this))); |
| } |
| catch (const std::invalid_argument& e) |
| { |
| log<level::ERR>(fmt::format("Error in creating resource dump entry, " |
| "errormsg({}),OBJECTPATH({}),ID({})," |
| "TIMESTAMP({}),SIZE({}),SOURCEID({})", |
| e.what(), objPath.c_str(), id, timeStamp, |
| size, dumpId) |
| .c_str()); |
| report<InternalFailure>(); |
| return; |
| } |
| lastEntryId++; |
| } |
| |
| sdbusplus::message::object_path |
| Manager::createDump(phosphor::dump::DumpCreateParams params) |
| { |
| using NotAllowed = |
| sdbusplus::xyz::openbmc_project::Common::Error::NotAllowed; |
| using Reason = xyz::openbmc_project::Common::NotAllowed::REASON; |
| |
| // Allow creating resource dump only when the host is up. |
| if (!phosphor::dump::isHostRunning()) |
| { |
| elog<NotAllowed>( |
| Reason("Resource dump can be initiated only when the host is up")); |
| return std::string(); |
| } |
| |
| using InvalidArgument = |
| sdbusplus::xyz::openbmc_project::Common::Error::InvalidArgument; |
| using Argument = xyz::openbmc_project::Common::InvalidArgument; |
| using CreateParameters = |
| sdbusplus::com::ibm::Dump::server::Create::CreateParameters; |
| |
| auto id = lastEntryId + 1; |
| auto idString = std::to_string(id); |
| auto objPath = std::filesystem::path(baseEntryPath) / idString; |
| uint64_t timeStamp = |
| std::chrono::duration_cast<std::chrono::microseconds>( |
| std::chrono::system_clock::now().time_since_epoch()) |
| .count(); |
| |
| std::string vspString; |
| auto iter = params.find( |
| sdbusplus::com::ibm::Dump::server::Create:: |
| convertCreateParametersToString(CreateParameters::VSPString)); |
| if (iter == params.end()) |
| { |
| // Host will generate a default dump if no resource selector string |
| // is provided. The default dump will be a non-disruptive system dump. |
| log<level::INFO>( |
| "VSP string is not provided, a non-disruptive system dump will be " |
| "generated by the host"); |
| } |
| else |
| { |
| try |
| { |
| vspString = std::get<std::string>(iter->second); |
| } |
| catch (const std::bad_variant_access& e) |
| { |
| // Exception will be raised if the input is not string |
| log<level::ERR>( |
| fmt::format("An invalid vsp string is passed errormsg({})", |
| e.what()) |
| .c_str()); |
| elog<InvalidArgument>(Argument::ARGUMENT_NAME("VSP_STRING"), |
| Argument::ARGUMENT_VALUE("INVALID INPUT")); |
| } |
| } |
| |
| std::string pwd; |
| iter = params.find( |
| sdbusplus::com::ibm::Dump::server::Create:: |
| convertCreateParametersToString(CreateParameters::Password)); |
| if (iter == params.end()) |
| { |
| log<level::INFO>("Password is not provided for resource dump"); |
| } |
| else |
| { |
| try |
| { |
| pwd = std::get<std::string>(iter->second); |
| } |
| catch (const std::bad_variant_access& e) |
| { |
| // Exception will be raised if the input is not string |
| log<level::ERR>( |
| fmt::format("An invalid password string is passed errormsg({})", |
| e.what()) |
| .c_str()); |
| elog<InvalidArgument>(Argument::ARGUMENT_NAME("PASSWORD"), |
| Argument::ARGUMENT_VALUE("INVALID INPUT")); |
| } |
| } |
| |
| // Get the originator id and type from params |
| std::string originatorId; |
| originatorTypes originatorType; |
| |
| phosphor::dump::extractOriginatorProperties(params, originatorId, |
| originatorType); |
| |
| try |
| { |
| entries.insert(std::make_pair( |
| id, std::make_unique<resource::Entry>( |
| bus, objPath.c_str(), id, timeStamp, 0, INVALID_SOURCE_ID, |
| vspString, pwd, phosphor::dump::OperationStatus::InProgress, |
| originatorId, originatorType, *this))); |
| } |
| catch (const std::invalid_argument& e) |
| { |
| log<level::ERR>( |
| fmt::format( |
| "Error in creating resource dump " |
| "entry,errormsg({}),OBJECTPATH({}), VSPSTRING({}), ID({})", |
| e.what(), objPath.c_str(), vspString, id) |
| .c_str()); |
| elog<InternalFailure>(); |
| return std::string(); |
| } |
| lastEntryId++; |
| return objPath.string(); |
| } |
| |
| } // namespace resource |
| } // namespace dump |
| } // namespace openpower |