activation.cpp - openbmc/openpower-pnor-code-mgmt - Gitiles

 #include <experimental/filesystem>
 #include "activation.hpp"
 #include "config.h"
 #include "item_updater.hpp"
 #include "serialize.hpp"
 #include <phosphor-logging/log.hpp>
 #include <sdbusplus/exception.hpp>

 #ifdef WANT_SIGNATURE_VERIFY
 #include <sdbusplus/server.hpp>
 #include <phosphor-logging/elog.hpp>
 #include <phosphor-logging/elog-errors.hpp>
 #include <xyz/openbmc_project/Common/error.hpp>
 #include "image_verify.hpp"
 #endif

 namespace openpower
 {
 namespace software
 {
 namespace updater
 {

 namespace fs = std::experimental::filesystem;
 namespace softwareServer = sdbusplus::xyz::openbmc_project::Software::server;

 using namespace phosphor::logging;
 using sdbusplus::exception::SdBusError;

 #ifdef WANT_SIGNATURE_VERIFY
 using InternalFailure =
     sdbusplus::xyz::openbmc_project::Common::Error::InternalFailure;

 // Field mode path and interface.
 constexpr auto FIELDMODE_PATH("/xyz/openbmc_project/software");
 constexpr auto FIELDMODE_INTERFACE("xyz.openbmc_project.Control.FieldMode");
 #endif

 constexpr auto SYSTEMD_SERVICE = "org.freedesktop.systemd1";
 constexpr auto SYSTEMD_OBJ_PATH = "/org/freedesktop/systemd1";

 void Activation::subscribeToSystemdSignals()
 {
     auto method = this->bus.new_method_call(SYSTEMD_SERVICE, SYSTEMD_OBJ_PATH,
                                             SYSTEMD_INTERFACE, "Subscribe");
     try
     {
         this->bus.call_noreply(method);
     }
     catch (const SdBusError& e)
     {
         if (e.name() != nullptr &&
             strcmp("org.freedesktop.systemd1.AlreadySubscribed", e.name()) == 0)
         {
             // If an Activation attempt fails, the Unsubscribe method is not
             // called. This may lead to an AlreadySubscribed error if the
             // Activation is re-attempted.
         }
         else
         {
             log<level::ERR>("Error subscribing to systemd",
                             entry("ERROR=%s", e.what()));
         }
     }
     return;
 }

 void Activation::unsubscribeFromSystemdSignals()
 {
     auto method = this->bus.new_method_call(SYSTEMD_SERVICE, SYSTEMD_OBJ_PATH,
                                             SYSTEMD_INTERFACE, "Unsubscribe");
     this->bus.call_noreply(method);

     return;
 }

 void Activation::startActivation()
 {
     // Since the squashfs image has not yet been loaded to pnor and the
     // RW volumes have not yet been created, we need to start the
     // service files for each of those actions.

     if (!activationProgress)
     {
         activationProgress = std::make_unique<ActivationProgress>(bus, path);
     }

     if (!activationBlocksTransition)
     {
         activationBlocksTransition =
             std::make_unique<ActivationBlocksTransition>(bus, path);
     }

     constexpr auto ubimountService = "obmc-flash-bios-ubimount@";
     auto ubimountServiceFile =
         std::string(ubimountService) + versionId + ".service";
     auto method = bus.new_method_call(SYSTEMD_BUSNAME, SYSTEMD_PATH,
                                       SYSTEMD_INTERFACE, "StartUnit");
     method.append(ubimountServiceFile, "replace");
     bus.call_noreply(method);

     activationProgress->progress(10);
 }

 void Activation::finishActivation()
 {
     activationProgress->progress(90);

     // Set Redundancy Priority before setting to Active
     if (!redundancyPriority)
     {
         redundancyPriority =
             std::make_unique<RedundancyPriority>(bus, path, *this, 0);
     }

     activationProgress->progress(100);

     activationBlocksTransition.reset(nullptr);
     activationProgress.reset(nullptr);

     ubiVolumesCreated = false;
     Activation::unsubscribeFromSystemdSignals();
     // Remove version object from image manager
     Activation::deleteImageManagerObject();
     // Create active association
     parent.createActiveAssociation(path);
 }

 auto Activation::activation(Activations value) -> Activations
 {

     if (value != softwareServer::Activation::Activations::Active)
     {
         redundancyPriority.reset(nullptr);
     }

     if (value == softwareServer::Activation::Activations::Activating)
     {
         parent.freeSpace();
         softwareServer::Activation::activation(value);

         if (ubiVolumesCreated == false)
         {
             // Enable systemd signals
             Activation::subscribeToSystemdSignals();

 #ifdef WANT_SIGNATURE_VERIFY
             // Validate the signed image.
             if (!validateSignature())
             {
                 // Cleanup
                 activationBlocksTransition.reset(nullptr);
                 activationProgress.reset(nullptr);

                 return softwareServer::Activation::activation(
                     softwareServer::Activation::Activations::Failed);
             }
 #endif
             Activation::startActivation();
             return softwareServer::Activation::activation(value);
         }
         else if (ubiVolumesCreated == true)
         {
             // Only when the squashfs image is finished loading AND the RW
             // volumes have been created do we proceed with activation. To
             // verify that this happened, we check for the mount dirs PNOR_PRSV
             // and PNOR_RW_PREFIX_<versionid>, as well as the image dir R0.

             if ((fs::is_directory(PNOR_PRSV)) &&
                 (fs::is_directory(PNOR_RW_PREFIX + versionId)) &&
                 (fs::is_directory(PNOR_RO_PREFIX + versionId)))
             {
                 Activation::finishActivation();
                 return softwareServer::Activation::activation(
                     softwareServer::Activation::Activations::Active);
             }
             else
             {
                 activationBlocksTransition.reset(nullptr);
                 activationProgress.reset(nullptr);
                 return softwareServer::Activation::activation(
                     softwareServer::Activation::Activations::Failed);
             }
         }
     }
     else
     {
         activationBlocksTransition.reset(nullptr);
         activationProgress.reset(nullptr);
     }

     return softwareServer::Activation::activation(value);
 }

 auto Activation::requestedActivation(RequestedActivations value)
     -> RequestedActivations
 {
     ubiVolumesCreated = false;

     if ((value == softwareServer::Activation::RequestedActivations::Active) &&
         (softwareServer::Activation::requestedActivation() !=
          softwareServer::Activation::RequestedActivations::Active))
     {
         if ((softwareServer::Activation::activation() ==
              softwareServer::Activation::Activations::Ready) ||
             (softwareServer::Activation::activation() ==
              softwareServer::Activation::Activations::Failed))
         {
             Activation::activation(
                 softwareServer::Activation::Activations::Activating);
         }
     }
     return softwareServer::Activation::requestedActivation(value);
 }

 void Activation::deleteImageManagerObject()
 {
     // Get the Delete object for <versionID> inside image_manager
     auto method = this->bus.new_method_call(MAPPER_BUSNAME, MAPPER_PATH,
                                             MAPPER_INTERFACE, "GetObject");

     method.append(path);
     method.append(
         std::vector<std::string>({"xyz.openbmc_project.Object.Delete"}));
     auto mapperResponseMsg = bus.call(method);
     if (mapperResponseMsg.is_method_error())
     {
         log<level::ERR>("Error in Get Delete Object",
                         entry("VERSIONPATH=%s", path.c_str()));
         return;
     }
     std::map<std::string, std::vector<std::string>> mapperResponse;
     mapperResponseMsg.read(mapperResponse);
     if (mapperResponse.begin() == mapperResponse.end())
     {
         log<level::ERR>("ERROR in reading the mapper response",
                         entry("VERSIONPATH=%s", path.c_str()));
         return;
     }

     // Call the Delete object for <versionID> inside image_manager
     method = this->bus.new_method_call(
         (mapperResponse.begin()->first).c_str(), path.c_str(),
         "xyz.openbmc_project.Object.Delete", "Delete");
     try
     {
         auto mapperResponseMsg = bus.call(method);

         // Check that the bus call didn't result in an error
         if (mapperResponseMsg.is_method_error())
         {
             log<level::ERR>("Error in Deleting image from image manager",
                             entry("VERSIONPATH=%s", path.c_str()));
             return;
         }
     }
     catch (const SdBusError& e)
     {
         if (e.name() != nullptr && strcmp("System.Error.ELOOP", e.name()) == 0)
         {
             // TODO: Error being tracked with openbmc/openbmc#3311
         }
         else
         {
             log<level::ERR>("Error performing call to Delete object path",
                             entry("ERROR=%s", e.what()),
                             entry("PATH=%s", path.c_str()));
         }
         return;
     }
 }

 uint8_t RedundancyPriority::priority(uint8_t value)
 {
     parent.parent.freePriority(value, parent.versionId);
     storeToFile(parent.versionId, value);
     return softwareServer::RedundancyPriority::priority(value);
 }

 void Activation::unitStateChange(sdbusplus::message::message& msg)
 {
     uint32_t newStateID{};
     sdbusplus::message::object_path newStateObjPath;
     std::string newStateUnit{};
     std::string newStateResult{};

     // Read the msg and populate each variable
     msg.read(newStateID, newStateObjPath, newStateUnit, newStateResult);

     auto ubimountServiceFile =
         "obmc-flash-bios-ubimount@" + versionId + ".service";

     if (newStateUnit == ubimountServiceFile && newStateResult == "done")
     {
         ubiVolumesCreated = true;
         activationProgress->progress(activationProgress->progress() + 50);
     }

     if (ubiVolumesCreated)
     {
         Activation::activation(
             softwareServer::Activation::Activations::Activating);
     }

     if ((newStateUnit == ubimountServiceFile) &&
         (newStateResult == "failed" || newStateResult == "dependency"))
     {
         Activation::activation(softwareServer::Activation::Activations::Failed);
     }

     return;
 }

 #ifdef WANT_SIGNATURE_VERIFY
 inline bool Activation::validateSignature()
 {
     using Signature = openpower::software::image::Signature;
     fs::path imageDir(IMG_DIR);

     Signature signature(imageDir / versionId, PNOR_SIGNED_IMAGE_CONF_PATH);

     // Validate the signed image.
     if (signature.verify())
     {
         return true;
     }
     // Log error and continue activation process, if field mode disabled.
     log<level::ERR>("Error occurred during image validation");
     report<InternalFailure>();

     try
     {
         if (!fieldModeEnabled())
         {
             return true;
         }
     }
     catch (const InternalFailure& e)
     {
         report<InternalFailure>();
     }
     return false;
 }

 bool Activation::fieldModeEnabled()
 {
     auto fieldModeSvc = getService(bus, FIELDMODE_PATH, FIELDMODE_INTERFACE);

     auto method = bus.new_method_call(fieldModeSvc.c_str(), FIELDMODE_PATH,
                                       "org.freedesktop.DBus.Properties", "Get");

     method.append(FIELDMODE_INTERFACE, "FieldModeEnabled");
     auto reply = bus.call(method);
     if (reply.is_method_error())
     {
         log<level::ERR>("Error in fieldModeEnabled getValue");
         elog<InternalFailure>();
     }
     sdbusplus::message::variant<bool> fieldMode;
     reply.read(fieldMode);

     return (fieldMode.get<bool>());
 }

 std::string Activation::getService(sdbusplus::bus::bus& bus,
                                    const std::string& path,
                                    const std::string& intf)
 {
     auto mapperCall = bus.new_method_call(MAPPER_BUSNAME, MAPPER_PATH,
                                           MAPPER_INTERFACE, "GetObject");

     mapperCall.append(path);
     mapperCall.append(std::vector<std::string>({intf}));

     auto mapperResponseMsg = bus.call(mapperCall);

     if (mapperResponseMsg.is_method_error())
     {
         log<level::ERR>("ERROR in getting service",
                         entry("PATH=%s", path.c_str()),
                         entry("INTERFACE=%s", intf.c_str()));

         elog<InternalFailure>();
     }

     std::map<std::string, std::vector<std::string>> mapperResponse;
     mapperResponseMsg.read(mapperResponse);

     if (mapperResponse.begin() == mapperResponse.end())
     {
         log<level::ERR>("ERROR reading mapper response",
                         entry("PATH=%s", path.c_str()),
                         entry("INTERFACE=%s", intf.c_str()));

         elog<InternalFailure>();
     }
     return mapperResponse.begin()->first;
 }
 #endif

 } // namespace updater
 } // namespace software
 } // namespace openpower
	#include <experimental/filesystem>
	#include "activation.hpp"
	#include "config.h"
	#include "item_updater.hpp"
	#include "serialize.hpp"
	#include <phosphor-logging/log.hpp>
	#include <sdbusplus/exception.hpp>

	#ifdef WANT_SIGNATURE_VERIFY
	#include <sdbusplus/server.hpp>
	#include <phosphor-logging/elog.hpp>
	#include <phosphor-logging/elog-errors.hpp>
	#include <xyz/openbmc_project/Common/error.hpp>
	#include "image_verify.hpp"
	#endif

	namespace openpower
	{
	namespace software
	{
	namespace updater
	{

	namespace fs = std::experimental::filesystem;
	namespace softwareServer = sdbusplus::xyz::openbmc_project::Software::server;

	using namespace phosphor::logging;
	using sdbusplus::exception::SdBusError;

	#ifdef WANT_SIGNATURE_VERIFY
	using InternalFailure =
	sdbusplus::xyz::openbmc_project::Common::Error::InternalFailure;

	// Field mode path and interface.
	constexpr auto FIELDMODE_PATH("/xyz/openbmc_project/software");
	constexpr auto FIELDMODE_INTERFACE("xyz.openbmc_project.Control.FieldMode");
	#endif

	constexpr auto SYSTEMD_SERVICE = "org.freedesktop.systemd1";
	constexpr auto SYSTEMD_OBJ_PATH = "/org/freedesktop/systemd1";

	void Activation::subscribeToSystemdSignals()
	{
	auto method = this->bus.new_method_call(SYSTEMD_SERVICE, SYSTEMD_OBJ_PATH,
	SYSTEMD_INTERFACE, "Subscribe");
	try
	{
	this->bus.call_noreply(method);
	}
	catch (const SdBusError& e)
	{
	if (e.name() != nullptr &&
	strcmp("org.freedesktop.systemd1.AlreadySubscribed", e.name()) == 0)
	{
	// If an Activation attempt fails, the Unsubscribe method is not
	// called. This may lead to an AlreadySubscribed error if the
	// Activation is re-attempted.
	}
	else
	{
	log<level::ERR>("Error subscribing to systemd",
	entry("ERROR=%s", e.what()));
	}
	}
	return;
	}

	void Activation::unsubscribeFromSystemdSignals()
	{
	auto method = this->bus.new_method_call(SYSTEMD_SERVICE, SYSTEMD_OBJ_PATH,
	SYSTEMD_INTERFACE, "Unsubscribe");
	this->bus.call_noreply(method);

	return;
	}

	void Activation::startActivation()
	{
	// Since the squashfs image has not yet been loaded to pnor and the
	// RW volumes have not yet been created, we need to start the
	// service files for each of those actions.

	if (!activationProgress)
	{
	activationProgress = std::make_unique<ActivationProgress>(bus, path);
	}

	if (!activationBlocksTransition)
	{
	activationBlocksTransition =
	std::make_unique<ActivationBlocksTransition>(bus, path);
	}

	constexpr auto ubimountService = "obmc-flash-bios-ubimount@";
	auto ubimountServiceFile =
	std::string(ubimountService) + versionId + ".service";
	auto method = bus.new_method_call(SYSTEMD_BUSNAME, SYSTEMD_PATH,
	SYSTEMD_INTERFACE, "StartUnit");
	method.append(ubimountServiceFile, "replace");
	bus.call_noreply(method);

	activationProgress->progress(10);
	}

	void Activation::finishActivation()
	{
	activationProgress->progress(90);

	// Set Redundancy Priority before setting to Active
	if (!redundancyPriority)
	{
	redundancyPriority =
	std::make_unique<RedundancyPriority>(bus, path, *this, 0);
	}

	activationProgress->progress(100);

	activationBlocksTransition.reset(nullptr);
	activationProgress.reset(nullptr);

	ubiVolumesCreated = false;
	Activation::unsubscribeFromSystemdSignals();
	// Remove version object from image manager
	Activation::deleteImageManagerObject();
	// Create active association
	parent.createActiveAssociation(path);
	}

	auto Activation::activation(Activations value) -> Activations
	{

	if (value != softwareServer::Activation::Activations::Active)
	{
	redundancyPriority.reset(nullptr);
	}

	if (value == softwareServer::Activation::Activations::Activating)
	{
	parent.freeSpace();
	softwareServer::Activation::activation(value);

	if (ubiVolumesCreated == false)
	{
	// Enable systemd signals
	Activation::subscribeToSystemdSignals();

	#ifdef WANT_SIGNATURE_VERIFY
	// Validate the signed image.
	if (!validateSignature())
	{
	// Cleanup
	activationBlocksTransition.reset(nullptr);
	activationProgress.reset(nullptr);

	return softwareServer::Activation::activation(
	softwareServer::Activation::Activations::Failed);
	}
	#endif
	Activation::startActivation();
	return softwareServer::Activation::activation(value);
	}
	else if (ubiVolumesCreated == true)
	{
	// Only when the squashfs image is finished loading AND the RW
	// volumes have been created do we proceed with activation. To
	// verify that this happened, we check for the mount dirs PNOR_PRSV
	// and PNOR_RW_PREFIX_<versionid>, as well as the image dir R0.

	if ((fs::is_directory(PNOR_PRSV)) &&
	(fs::is_directory(PNOR_RW_PREFIX + versionId)) &&
	(fs::is_directory(PNOR_RO_PREFIX + versionId)))
	{
	Activation::finishActivation();
	return softwareServer::Activation::activation(
	softwareServer::Activation::Activations::Active);
	}
	else
	{
	activationBlocksTransition.reset(nullptr);
	activationProgress.reset(nullptr);
	return softwareServer::Activation::activation(
	softwareServer::Activation::Activations::Failed);
	}
	}
	}
	else
	{
	activationBlocksTransition.reset(nullptr);
	activationProgress.reset(nullptr);
	}

	return softwareServer::Activation::activation(value);
	}

	auto Activation::requestedActivation(RequestedActivations value)
	-> RequestedActivations
	{
	ubiVolumesCreated = false;

	if ((value == softwareServer::Activation::RequestedActivations::Active) &&
	(softwareServer::Activation::requestedActivation() !=
	softwareServer::Activation::RequestedActivations::Active))
	{
	if ((softwareServer::Activation::activation() ==
	softwareServer::Activation::Activations::Ready) \|\|
	(softwareServer::Activation::activation() ==
	softwareServer::Activation::Activations::Failed))
	{
	Activation::activation(
	softwareServer::Activation::Activations::Activating);
	}
	}
	return softwareServer::Activation::requestedActivation(value);
	}

	void Activation::deleteImageManagerObject()
	{
	// Get the Delete object for <versionID> inside image_manager
	auto method = this->bus.new_method_call(MAPPER_BUSNAME, MAPPER_PATH,
	MAPPER_INTERFACE, "GetObject");

	method.append(path);
	method.append(
	std::vector<std::string>({"xyz.openbmc_project.Object.Delete"}));
	auto mapperResponseMsg = bus.call(method);
	if (mapperResponseMsg.is_method_error())
	{
	log<level::ERR>("Error in Get Delete Object",
	entry("VERSIONPATH=%s", path.c_str()));
	return;
	}
	std::map<std::string, std::vector<std::string>> mapperResponse;
	mapperResponseMsg.read(mapperResponse);
	if (mapperResponse.begin() == mapperResponse.end())
	{
	log<level::ERR>("ERROR in reading the mapper response",
	entry("VERSIONPATH=%s", path.c_str()));
	return;
	}

	// Call the Delete object for <versionID> inside image_manager
	method = this->bus.new_method_call(
	(mapperResponse.begin()->first).c_str(), path.c_str(),
	"xyz.openbmc_project.Object.Delete", "Delete");
	try
	{
	auto mapperResponseMsg = bus.call(method);

	// Check that the bus call didn't result in an error
	if (mapperResponseMsg.is_method_error())
	{
	log<level::ERR>("Error in Deleting image from image manager",
	entry("VERSIONPATH=%s", path.c_str()));
	return;
	}
	}
	catch (const SdBusError& e)
	{
	if (e.name() != nullptr && strcmp("System.Error.ELOOP", e.name()) == 0)
	{
	// TODO: Error being tracked with openbmc/openbmc#3311
	}
	else
	{
	log<level::ERR>("Error performing call to Delete object path",
	entry("ERROR=%s", e.what()),
	entry("PATH=%s", path.c_str()));
	}
	return;
	}
	}

	uint8_t RedundancyPriority::priority(uint8_t value)
	{
	parent.parent.freePriority(value, parent.versionId);
	storeToFile(parent.versionId, value);
	return softwareServer::RedundancyPriority::priority(value);
	}

	void Activation::unitStateChange(sdbusplus::message::message& msg)
	{
	uint32_t newStateID{};
	sdbusplus::message::object_path newStateObjPath;
	std::string newStateUnit{};
	std::string newStateResult{};

	// Read the msg and populate each variable
	msg.read(newStateID, newStateObjPath, newStateUnit, newStateResult);

	auto ubimountServiceFile =
	"obmc-flash-bios-ubimount@" + versionId + ".service";

	if (newStateUnit == ubimountServiceFile && newStateResult == "done")
	{
	ubiVolumesCreated = true;
	activationProgress->progress(activationProgress->progress() + 50);
	}

	if (ubiVolumesCreated)
	{
	Activation::activation(
	softwareServer::Activation::Activations::Activating);
	}

	if ((newStateUnit == ubimountServiceFile) &&
	(newStateResult == "failed" \|\| newStateResult == "dependency"))
	{
	Activation::activation(softwareServer::Activation::Activations::Failed);
	}

	return;
	}

	#ifdef WANT_SIGNATURE_VERIFY
	inline bool Activation::validateSignature()
	{
	using Signature = openpower::software::image::Signature;
	fs::path imageDir(IMG_DIR);

	Signature signature(imageDir / versionId, PNOR_SIGNED_IMAGE_CONF_PATH);

	// Validate the signed image.
	if (signature.verify())
	{
	return true;
	}
	// Log error and continue activation process, if field mode disabled.
	log<level::ERR>("Error occurred during image validation");
	report<InternalFailure>();

	try
	{
	if (!fieldModeEnabled())
	{
	return true;
	}
	}
	catch (const InternalFailure& e)
	{
	report<InternalFailure>();
	}
	return false;
	}

	bool Activation::fieldModeEnabled()
	{
	auto fieldModeSvc = getService(bus, FIELDMODE_PATH, FIELDMODE_INTERFACE);

	auto method = bus.new_method_call(fieldModeSvc.c_str(), FIELDMODE_PATH,
	"org.freedesktop.DBus.Properties", "Get");

	method.append(FIELDMODE_INTERFACE, "FieldModeEnabled");
	auto reply = bus.call(method);
	if (reply.is_method_error())
	{
	log<level::ERR>("Error in fieldModeEnabled getValue");
	elog<InternalFailure>();
	}
	sdbusplus::message::variant<bool> fieldMode;
	reply.read(fieldMode);

	return (fieldMode.get<bool>());
	}

	std::string Activation::getService(sdbusplus::bus::bus& bus,
	const std::string& path,
	const std::string& intf)
	{
	auto mapperCall = bus.new_method_call(MAPPER_BUSNAME, MAPPER_PATH,
	MAPPER_INTERFACE, "GetObject");

	mapperCall.append(path);
	mapperCall.append(std::vector<std::string>({intf}));

	auto mapperResponseMsg = bus.call(mapperCall);

	if (mapperResponseMsg.is_method_error())
	{
	log<level::ERR>("ERROR in getting service",
	entry("PATH=%s", path.c_str()),
	entry("INTERFACE=%s", intf.c_str()));

	elog<InternalFailure>();
	}

	std::map<std::string, std::vector<std::string>> mapperResponse;
	mapperResponseMsg.read(mapperResponse);

	if (mapperResponse.begin() == mapperResponse.end())
	{
	log<level::ERR>("ERROR reading mapper response",
	entry("PATH=%s", path.c_str()),
	entry("INTERFACE=%s", intf.c_str()));

	elog<InternalFailure>();
	}
	return mapperResponse.begin()->first;
	}
	#endif

	} // namespace updater
	} // namespace software
	} // namespace openpower