blob: 410ddc841d804127e0469818848c03cd7737cf0a [file] [log] [blame]
#include "utils.hpp"
#include <unistd.h>
#include <phosphor-logging/lg2.hpp>
namespace utils
{
PHOSPHOR_LOG2_USING;
std::string getService(sdbusplus::bus::bus& bus, const std::string& path,
const std::string& interface)
{
auto method = bus.new_method_call(MAPPER_BUSNAME, MAPPER_PATH,
MAPPER_BUSNAME, "GetObject");
method.append(path);
method.append(std::vector<std::string>({interface}));
std::vector<std::pair<std::string, std::vector<std::string>>> response;
try
{
auto reply = bus.call(method);
reply.read(response);
if (response.empty())
{
error(
"Empty response from mapper for getting service name: {PATH} {INTERFACE}",
"PATH", path, "INTERFACE", interface);
return std::string{};
}
}
catch (const sdbusplus::exception::exception& e)
{
error("Error in mapper method call for ({PATH}, {INTERFACE}: {ERROR}",
"ERROR", e, "PATH", path, "INTERFACE", interface);
return std::string{};
}
return response[0].first;
}
const PropertyValue getProperty(sdbusplus::bus::bus& bus,
const std::string& objectPath,
const std::string& interface,
const std::string& propertyName)
{
PropertyValue value{};
auto service = getService(bus, objectPath, interface);
if (service.empty())
{
return value;
}
auto method = bus.new_method_call(service.c_str(), objectPath.c_str(),
"org.freedesktop.DBus.Properties", "Get");
method.append(interface, propertyName);
auto reply = bus.call(method);
reply.read(value);
return value;
}
void setProperty(sdbusplus::bus::bus& bus, const std::string& objectPath,
const std::string& interface, const std::string& propertyName,
const PropertyValue& value)
{
auto service = getService(bus, objectPath, interface);
if (service.empty())
{
return;
}
auto method = bus.new_method_call(service.c_str(), objectPath.c_str(),
"org.freedesktop.DBus.Properties", "Set");
method.append(interface.c_str(), propertyName.c_str(), value);
bus.call_noreply(method);
}
void mergeFiles(std::vector<std::string>& srcFiles, std::string& dstFile)
{
std::ofstream outFile(dstFile, std::ios::out);
for (auto& file : srcFiles)
{
std::ifstream inFile;
inFile.open(file, std::ios_base::in);
if (!inFile)
{
continue;
}
inFile.peek();
if (inFile.eof())
{
inFile.close();
continue;
}
outFile << inFile.rdbuf();
inFile.close();
}
outFile.close();
}
namespace internal
{
/* @brief Helper function to build a string from command arguments */
static std::string buildCommandStr(const char* name, char** args)
{
std::string command = name;
for (int i = 0; args[i]; i++)
{
command += " ";
command += args[i];
}
return command;
}
int executeCmd(const char* path, char** args)
{
pid_t pid = fork();
if (pid == 0)
{
execv(path, args);
// execv only retruns on err
auto err = errno;
auto command = buildCommandStr(path, args);
error("Failed ({ERRNO}) to execute command: {COMMAND}", "ERRNO", err,
"COMMAND", command);
return -1;
}
else if (pid > 0)
{
int status;
if (waitpid(pid, &status, 0) < 0)
{
error("Error ({ERRNO}) during waitpid.", "ERRNO", errno);
return -1;
}
else if (WEXITSTATUS(status) != 0)
{
auto command = buildCommandStr(path, args);
error("Error ({STATUS}) occurred when executing command: {COMMAND}",
"STATUS", status, "COMMAND", command);
return -1;
}
}
else
{
error("Error ({ERRNO}) during fork.", "ERRNO", errno);
return -1;
}
return 0;
}
} // namespace internal
} // namespace utils