blob: 48cd9c8b8c62c13568550677924a5c042b84cc08 [file] [log] [blame]
#pragma once
#include <cstring>
#include <vector>
#include <experimental/filesystem>
#include <functional>
#include <sdbusplus/bus.hpp>
#include "occ_pass_through.hpp"
#include "occ_status.hpp"
#include "config.h"
#include <powercap.hpp>
namespace sdbusRule = sdbusplus::bus::match::rules;
namespace open_power
{
namespace occ
{
/** @class Manager
* @brief Builds and manages OCC objects
*/
struct Manager
{
public:
Manager() = delete;
Manager(const Manager&) = delete;
Manager& operator=(const Manager&) = delete;
Manager(Manager&&) = default;
Manager& operator=(Manager&&) = default;
~Manager() = default;
/** @brief Adds OCC pass-through and status objects on the bus
* when corresponding CPU inventory is created.
* @param[in] bus - handle to the bus
*/
Manager(sdbusplus::bus::bus& bus):
bus(bus)
{
for (auto id = 0; id < MAX_CPUS; ++id)
{
auto path = std::string(CPU_PATH) + std::to_string(id);
cpuMatches.emplace_back(
bus,
sdbusRule::interfacesAdded() +
sdbusRule::argNpath(0, path),
std::bind(std::mem_fn(&Manager::cpuCreated),
this, std::placeholders::_1));
}
}
/** @brief Callback that responds to cpu creation in the inventory -
* by creating the occ passthrough and status objects.
*
* @param[in] msg - bus message
*
* @returns 0 to indicate success
*/
int cpuCreated(sdbusplus::message::message& msg)
{
namespace fs = std::experimental::filesystem;
sdbusplus::message::object_path o;
msg.read(o);
fs::path cpuPath(std::string(std::move(o)));
auto cpu = cpuPath.filename();
std::string name{cpu.c_str()};
auto index = name.find(CPU_NAME);
name.replace(index, std::strlen(CPU_NAME), OCC_NAME);
auto path = fs::path(OCC_CONTROL_ROOT) / name;
passThroughObjects.emplace_back(
std::make_unique<PassThrough>(
bus,
path.c_str()));
statusObjects.emplace_back(
std::make_unique<Status>(
bus,
path.c_str()));
// Create the power cap monitor object for master occ (0)
if(!pcap && (index == 0))
{
pcap = std::make_unique<open_power::occ::powercap::PowerCap>(
bus,
*statusObjects[index]);
}
return 0;
}
private:
/** @brief reference to the bus */
sdbusplus::bus::bus& bus;
/** @brief OCC pass-through objects */
std::vector<std::unique_ptr<PassThrough>> passThroughObjects;
/** @brief OCC Status objects */
std::vector<std::unique_ptr<Status>> statusObjects;
/** @brief Power cap monitor and occ notification object */
std::unique_ptr<open_power::occ::powercap::PowerCap> pcap;
/** @brief sbdbusplus match objects */
std::vector<sdbusplus::bus::match_t> cpuMatches;
};
} // namespace occ
} // namespace open_power