Create pcap object and log monitored events
Change-Id: I2d7b3a449e2c9c1d5a0627161f8e85dcaca1e087
Signed-off-by: Andrew Geissler <andrewg@us.ibm.com>
diff --git a/powercap.cpp b/powercap.cpp
index 2d5362d..2ecad0c 100644
--- a/powercap.cpp
+++ b/powercap.cpp
@@ -8,18 +8,148 @@
namespace powercap
{
+constexpr auto PCAP_PATH = "/xyz/openbmc_project/control/host0/power_cap";
+constexpr auto PCAP_INTERFACE = "xyz.openbmc_project.Control.Power.Cap";
+
+constexpr auto MAPPER_BUSNAME = "xyz.openbmc_project.ObjectMapper";
+constexpr auto MAPPER_PATH = "/xyz/openbmc_project/object_mapper";
+constexpr auto MAPPER_INTERFACE = "xyz.openbmc_project.ObjectMapper";
+
+constexpr auto POWER_CAP_PROP = "PowerCap";
+constexpr auto POWER_CAP_ENABLE_PROP = "PowerCapEnable";
+
using namespace phosphor::logging;
+std::string PowerCap::getService(std::string path,
+ std::string interface)
+{
+ auto mapper = bus.new_method_call(MAPPER_BUSNAME,
+ MAPPER_PATH,
+ MAPPER_INTERFACE,
+ "GetObject");
+
+ mapper.append(path, std::vector<std::string>({interface}));
+ auto mapperResponseMsg = bus.call(mapper);
+
+ if (mapperResponseMsg.is_method_error())
+ {
+ log<level::ERR>("Error in mapper call",
+ entry("PATH=%s", path.c_str()),
+ entry("INTERFACE=%s", interface.c_str()));
+ // TODO openbmc/openbmc#851 - Once available, throw returned error
+ throw std::runtime_error("Error in mapper call");
+ }
+
+ std::map<std::string, std::vector<std::string>> mapperResponse;
+ mapperResponseMsg.read(mapperResponse);
+ if (mapperResponse.empty())
+ {
+ log<level::ERR>("Error reading mapper response",
+ entry("PATH=%s", path.c_str()),
+ entry("INTERFACE=%s", interface.c_str()));
+ // TODO openbmc/openbmc#1712 - Handle empty mapper resp. consistently
+ throw std::runtime_error("Error reading mapper response");
+ }
+
+ return mapperResponse.begin()->first;
+}
+
+uint32_t PowerCap::getPcap()
+{
+ auto settingService = getService(PCAP_PATH,PCAP_INTERFACE);
+
+ auto method = this->bus.new_method_call(settingService.c_str(),
+ PCAP_PATH,
+ "org.freedesktop.DBus.Properties",
+ "Get");
+
+ method.append(PCAP_INTERFACE, POWER_CAP_PROP);
+ auto reply = this->bus.call(method);
+
+ if (reply.is_method_error())
+ {
+ log<level::ERR>("Error in getPcap prop");
+ return 0;
+ }
+ sdbusplus::message::variant<uint32_t> pcap;
+ reply.read(pcap);
+
+ return pcap.get<uint32_t>();
+}
+
+bool PowerCap::getPcapEnabled()
+{
+ auto settingService = getService(PCAP_PATH,PCAP_INTERFACE);
+
+ auto method = this->bus.new_method_call(settingService.c_str(),
+ PCAP_PATH,
+ "org.freedesktop.DBus.Properties",
+ "Get");
+
+ method.append(PCAP_INTERFACE, POWER_CAP_ENABLE_PROP);
+ auto reply = this->bus.call(method);
+
+ if (reply.is_method_error())
+ {
+ log<level::ERR>("Error in getPcapEnabled prop");
+ return 0;
+ }
+ sdbusplus::message::variant<bool> pcapEnabled;
+ reply.read(pcapEnabled);
+
+ return pcapEnabled.get<bool>();
+}
void PowerCap::pcapChanged(sdbusplus::message::message& msg)
{
- log<level::DEBUG>("Power Cap Change Detected");
if (!occStatus.occActive())
{
// Nothing to do
return;
}
- // TODO - Process this change
+
+ uint32_t pcap = 0;
+ bool pcapEnabled = false;
+
+ std::string msgSensor;
+ std::map<std::string, sdbusplus::message::variant<uint32_t, bool>> msgData;
+ msg.read(msgSensor, msgData);
+
+ // Retrieve which property changed via the msg and read the other one
+ auto valPropMap = msgData.find(POWER_CAP_PROP);
+ if (valPropMap != msgData.end())
+ {
+ pcap = sdbusplus::message::variant_ns::get<uint32_t>(
+ valPropMap->second);
+ pcapEnabled = getPcapEnabled();
+ }
+ else
+ {
+ valPropMap = msgData.find(POWER_CAP_ENABLE_PROP);
+ if (valPropMap != msgData.end())
+ {
+ pcapEnabled = sdbusplus::message::variant_ns::get<bool>(
+ valPropMap->second);
+ pcap = getPcap();
+ }
+ else
+ {
+ log<level::INFO>("Unknown power cap property changed");
+ return;
+ }
+ }
+
+ log<level::INFO>("Power Cap Property Change",
+ entry("PCAP=%u",pcap),
+ entry("PCAP_ENABLED=%u",pcapEnabled));
+
+ // Determine desired action to write to occ
+ // TODO
+
+ // Write action to occ
+ // TODO
+
+ return;
}
} // namespace open_power