blob: bf4ba387cb6c68ae23ab01e8ac769ab0492d983a [file] [log] [blame]
#include <string>
#include <experimental/filesystem>
#include <fstream>
#include <phosphor-logging/log.hpp>
#include <xyz/openbmc_project/Software/Version/server.hpp>
#include "config.h"
#include "item_updater.hpp"
#include "activation.hpp"
namespace openpower
{
namespace software
{
namespace updater
{
// When you see server:: you know we're referencing our base class
namespace server = sdbusplus::xyz::openbmc_project::Software::server;
namespace fs = std::experimental::filesystem;
using namespace phosphor::logging;
constexpr auto squashFSImage = "pnor.xz.squashfs";
void ItemUpdater::createActivation(sdbusplus::message::message& m)
{
using SVersion = server::Version;
using VersionPurpose = SVersion::VersionPurpose;
namespace msg = sdbusplus::message;
namespace variant_ns = msg::variant_ns;
sdbusplus::message::object_path objPath;
std::map<std::string,
std::map<std::string, msg::variant<std::string>>> interfaces;
m.read(objPath, interfaces);
std::string path(std::move(objPath));
std::string filePath;
auto purpose = VersionPurpose::Unknown;
std::string version;
for (const auto& intf : interfaces)
{
if (intf.first == VERSION_IFACE)
{
for (const auto& property : intf.second)
{
if (property.first == "Purpose")
{
// Only process the Host and System images
auto value = SVersion::convertVersionPurposeFromString(
variant_ns::get<std::string>(property.second));
if (value == VersionPurpose::Host ||
value == VersionPurpose::System)
{
purpose = value;
}
}
else if (property.first == "Version")
{
version = variant_ns::get<std::string>(property.second);
}
}
}
else if (intf.first == FILEPATH_IFACE)
{
for (const auto& property : intf.second)
{
if (property.first == "Path")
{
filePath = variant_ns::get<std::string>(property.second);
}
}
}
}
if ((filePath.empty()) || (purpose == VersionPurpose::Unknown))
{
return;
}
// Version id is the last item in the path
auto pos = path.rfind("/");
if (pos == std::string::npos)
{
log<level::ERR>("No version id found in object path",
entry("OBJPATH=%s", path));
return;
}
auto versionId = path.substr(pos + 1);
if (activations.find(versionId) == activations.end())
{
// Determine the Activation state by processing the given image dir.
auto activationState = server::Activation::Activations::Invalid;
if (ItemUpdater::validateSquashFSImage(filePath) == 0)
{
activationState = server::Activation::Activations::Ready;
}
fs::path manifestPath(filePath);
manifestPath /= MANIFEST_FILE;
auto extendedVersion = ItemUpdater::getExtendedVersion(manifestPath);
activations.insert(std::make_pair(
versionId,
std::make_unique<Activation>(
bus,
path,
*this,
versionId,
extendedVersion,
activationState)));
}
versions.insert(std::make_pair(
versionId,
std::make_unique<Version>(
bus,
path,
version,
purpose,
filePath)));
return;
}
std::string ItemUpdater::getExtendedVersion(const std::string& manifestFilePath)
{
constexpr auto extendedVersionKey = "extended_version=";
constexpr auto extendedVersionKeySize = strlen(extendedVersionKey);
if (manifestFilePath.empty())
{
log<level::ERR>("Error MANIFESTFilePath is empty");
throw std::runtime_error("MANIFESTFilePath is empty");
}
std::string extendedVersion{};
std::ifstream efile;
std::string line;
efile.exceptions(std::ifstream::failbit
| std::ifstream::badbit
| std::ifstream::eofbit);
try
{
efile.open(manifestFilePath);
while (getline(efile, line))
{
if (line.compare(0, extendedVersionKeySize,
extendedVersionKey) == 0)
{
extendedVersion = line.substr(extendedVersionKeySize);
break;
}
}
efile.close();
}
catch (const std::exception& e)
{
log<level::ERR>("Error in reading Host MANIFEST file");
}
return extendedVersion;
}
int ItemUpdater::validateSquashFSImage(const std::string& filePath)
{
fs::path file(filePath);
file /= squashFSImage;
std::ifstream efile(file.c_str());
if (efile.good() == 1)
{
return 0;
}
else
{
log<level::ERR>("Failed to find the SquashFS image.");
return -1;
}
}
void ItemUpdater::reset()
{
for(const auto& it : activations)
{
auto serviceFile = "obmc-flash-bios-ubiumount-rw@" + it.first +
".service";
// Remove the read-write partitions.
auto method = bus.new_method_call(
SYSTEMD_BUSNAME,
SYSTEMD_PATH,
SYSTEMD_INTERFACE,
"StartUnit");
method.append(serviceFile, "replace");
bus.call_noreply(method);
}
// Remove the preserved partition.
auto method = bus.new_method_call(
SYSTEMD_BUSNAME,
SYSTEMD_PATH,
SYSTEMD_INTERFACE,
"StartUnit");
method.append("obmc-flash-bios-ubiumount-prsv.service", "replace");
bus.call_noreply(method);
return;
}
void ItemUpdater::freePriority(uint8_t value)
{
//TODO openbmc/openbmc#1896 Improve the performance of this function
for (const auto& intf : activations)
{
if(intf.second->redundancyPriority)
{
if (intf.second->redundancyPriority.get()->priority() == value)
{
intf.second->redundancyPriority.get()->priority(value+1);
}
}
}
}
} // namespace updater
} // namespace software
} // namespace openpower