14f0d1de6SSteve Foreman // Copyright 2022 Google LLC 2a2056e9cSWilly Tu // 3a2056e9cSWilly Tu // Licensed under the Apache License, Version 2.0 (the "License"); 4a2056e9cSWilly Tu // you may not use this file except in compliance with the License. 5a2056e9cSWilly Tu // You may obtain a copy of the License at 6a2056e9cSWilly Tu // 7a2056e9cSWilly Tu // http://www.apache.org/licenses/LICENSE-2.0 8a2056e9cSWilly Tu // 9a2056e9cSWilly Tu // Unless required by applicable law or agreed to in writing, software 10a2056e9cSWilly Tu // distributed under the License is distributed on an "AS IS" BASIS, 11a2056e9cSWilly Tu // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12a2056e9cSWilly Tu // See the License for the specific language governing permissions and 13a2056e9cSWilly Tu // limitations under the License. 14f085d91dSPatrick Venture #include "handler.hpp" 15f085d91dSPatrick Venture 16d2037c6aSPatrick Venture #include "errors.hpp" 17c87de558SPatrick Venture #include "handler_impl.hpp" 18ab650004SPatrick Venture #include "util.hpp" 19d2037c6aSPatrick Venture 203b1b427cSWilly Tu #include <fcntl.h> 21d2037c6aSPatrick Venture #include <ipmid/api.h> 223b1b427cSWilly Tu #include <mtd/mtd-abi.h> 233b1b427cSWilly Tu #include <mtd/mtd-user.h> 243b1b427cSWilly Tu #include <sys/ioctl.h> 253b1b427cSWilly Tu #include <unistd.h> 26d2037c6aSPatrick Venture 27bb90d4fdSPatrick Venture #include <cinttypes> 28d2037c6aSPatrick Venture #include <cstdio> 29d2037c6aSPatrick Venture #include <filesystem> 30d2037c6aSPatrick Venture #include <fstream> 3107f85150SPatrick Venture #include <map> 3207f85150SPatrick Venture #include <nlohmann/json.hpp> 3307f85150SPatrick Venture #include <phosphor-logging/elog-errors.hpp> 34aa374120SPatrick Venture #include <phosphor-logging/log.hpp> 35aa374120SPatrick Venture #include <sdbusplus/bus.hpp> 36d2037c6aSPatrick Venture #include <sstream> 37d2037c6aSPatrick Venture #include <string> 3829f35bceSWilliam A. Kennington III #include <string_view> 39d2037c6aSPatrick Venture #include <tuple> 404f0d1de6SSteve Foreman #include <variant> 4107f85150SPatrick Venture #include <xyz/openbmc_project/Common/error.hpp> 42d2037c6aSPatrick Venture 43*5e70dc8cSNikhil Namjoshi #include "bm_config.h" 44*5e70dc8cSNikhil Namjoshi 45f085d91dSPatrick Venture #ifndef NCSI_IF_NAME 46f085d91dSPatrick Venture #define NCSI_IF_NAME eth0 47f085d91dSPatrick Venture #endif 48f085d91dSPatrick Venture 49f085d91dSPatrick Venture // To deal with receiving a string without quotes. 50f085d91dSPatrick Venture #define QUOTE(name) #name 51f085d91dSPatrick Venture #define STR(macro) QUOTE(macro) 52f085d91dSPatrick Venture #define NCSI_IF_NAME_STR STR(NCSI_IF_NAME) 53f085d91dSPatrick Venture 548d3d46a2SWilliam A. Kennington III namespace ipmi 558d3d46a2SWilliam A. Kennington III { 568d3d46a2SWilliam A. Kennington III std::uint8_t getChannelByName(const std::string& chName); 578d3d46a2SWilliam A. Kennington III } 588d3d46a2SWilliam A. Kennington III 59f085d91dSPatrick Venture namespace google 60f085d91dSPatrick Venture { 61f085d91dSPatrick Venture namespace ipmi 62f085d91dSPatrick Venture { 63d2037c6aSPatrick Venture namespace fs = std::filesystem; 6407f85150SPatrick Venture using Json = nlohmann::json; 6507f85150SPatrick Venture using namespace phosphor::logging; 6607f85150SPatrick Venture using InternalFailure = 6707f85150SPatrick Venture sdbusplus::xyz::openbmc_project::Common::Error::InternalFailure; 68f085d91dSPatrick Venture 69*5e70dc8cSNikhil Namjoshi enum class BmcMode : uint8_t 70*5e70dc8cSNikhil Namjoshi { 71*5e70dc8cSNikhil Namjoshi NON_BM_MODE = 0, 72*5e70dc8cSNikhil Namjoshi BM_MODE, 73*5e70dc8cSNikhil Namjoshi BM_CLEANING_MODE 74*5e70dc8cSNikhil Namjoshi }; 75*5e70dc8cSNikhil Namjoshi 76*5e70dc8cSNikhil Namjoshi uint8_t isBmcInBareMetalMode() 77*5e70dc8cSNikhil Namjoshi { 78*5e70dc8cSNikhil Namjoshi #if BARE_METAL 79*5e70dc8cSNikhil Namjoshi return static_cast<uint8_t>(BmcMode::BM_MODE); 80*5e70dc8cSNikhil Namjoshi #else 81*5e70dc8cSNikhil Namjoshi return static_cast<uint8_t>(BmcMode::NON_BM_MODE); 82*5e70dc8cSNikhil Namjoshi #endif 83*5e70dc8cSNikhil Namjoshi } 84*5e70dc8cSNikhil Namjoshi 85*5e70dc8cSNikhil Namjoshi uint8_t Handler::getBmcMode() 86*5e70dc8cSNikhil Namjoshi { 87*5e70dc8cSNikhil Namjoshi // BM_CLEANING_MODE is not implemented yet 88*5e70dc8cSNikhil Namjoshi return isBmcInBareMetalMode(); 89*5e70dc8cSNikhil Namjoshi } 90*5e70dc8cSNikhil Namjoshi 91b69209b4SWilliam A. Kennington III std::tuple<std::uint8_t, std::string> 92b69209b4SWilliam A. Kennington III Handler::getEthDetails(std::string intf) const 93f085d91dSPatrick Venture { 94b69209b4SWilliam A. Kennington III if (intf.empty()) 95b69209b4SWilliam A. Kennington III { 96b69209b4SWilliam A. Kennington III intf = NCSI_IF_NAME_STR; 97b69209b4SWilliam A. Kennington III } 98b69209b4SWilliam A. Kennington III return std::make_tuple(::ipmi::getChannelByName(intf), std::move(intf)); 99f085d91dSPatrick Venture } 100f085d91dSPatrick Venture 101d2037c6aSPatrick Venture std::int64_t Handler::getRxPackets(const std::string& name) const 102d2037c6aSPatrick Venture { 103d2037c6aSPatrick Venture std::ostringstream opath; 104d2037c6aSPatrick Venture opath << "/sys/class/net/" << name << "/statistics/rx_packets"; 105d2037c6aSPatrick Venture std::string path = opath.str(); 106d2037c6aSPatrick Venture 107d2037c6aSPatrick Venture // Minor sanity & security check (of course, I'm less certain if unicode 108d2037c6aSPatrick Venture // comes into play here. 109d2037c6aSPatrick Venture // 110d2037c6aSPatrick Venture // Basically you can't easily inject ../ or /../ into the path below. 111d2037c6aSPatrick Venture if (name.find("/") != std::string::npos) 112d2037c6aSPatrick Venture { 113d2037c6aSPatrick Venture std::fprintf(stderr, "Invalid or illegal name: '%s'\n", name.c_str()); 114e5a06675SMichael Shen throw IpmiException(::ipmi::ccInvalidFieldRequest); 115d2037c6aSPatrick Venture } 116d2037c6aSPatrick Venture 117d2037c6aSPatrick Venture std::error_code ec; 118d2037c6aSPatrick Venture if (!fs::exists(path, ec)) 119d2037c6aSPatrick Venture { 120d2037c6aSPatrick Venture std::fprintf(stderr, "Path: '%s' doesn't exist.\n", path.c_str()); 121e5a06675SMichael Shen throw IpmiException(::ipmi::ccInvalidFieldRequest); 122d2037c6aSPatrick Venture } 123d2037c6aSPatrick Venture // We're uninterested in the state of ec. 124d2037c6aSPatrick Venture 125d2037c6aSPatrick Venture int64_t count = 0; 126d2037c6aSPatrick Venture std::ifstream ifs; 127d2037c6aSPatrick Venture ifs.exceptions(std::ifstream::failbit); 128d2037c6aSPatrick Venture try 129d2037c6aSPatrick Venture { 130d2037c6aSPatrick Venture ifs.open(path); 131d2037c6aSPatrick Venture ifs >> count; 132d2037c6aSPatrick Venture } 133d2037c6aSPatrick Venture catch (std::ios_base::failure& fail) 134d2037c6aSPatrick Venture { 135e5a06675SMichael Shen throw IpmiException(::ipmi::ccUnspecifiedError); 136d2037c6aSPatrick Venture } 137d2037c6aSPatrick Venture 138d2037c6aSPatrick Venture return count; 139d2037c6aSPatrick Venture } 140d2037c6aSPatrick Venture 141bb90d4fdSPatrick Venture VersionTuple Handler::getCpldVersion(unsigned int id) const 142bb90d4fdSPatrick Venture { 143bb90d4fdSPatrick Venture std::ostringstream opath; 144bb90d4fdSPatrick Venture opath << "/run/cpld" << id << ".version"; 145bb90d4fdSPatrick Venture // Check for file 146bb90d4fdSPatrick Venture 147bb90d4fdSPatrick Venture std::error_code ec; 148bb90d4fdSPatrick Venture if (!fs::exists(opath.str(), ec)) 149bb90d4fdSPatrick Venture { 150bb90d4fdSPatrick Venture std::fprintf(stderr, "Path: '%s' doesn't exist.\n", 151bb90d4fdSPatrick Venture opath.str().c_str()); 152e5a06675SMichael Shen throw IpmiException(::ipmi::ccInvalidFieldRequest); 153bb90d4fdSPatrick Venture } 154bb90d4fdSPatrick Venture // We're uninterested in the state of ec. 155bb90d4fdSPatrick Venture 156bb90d4fdSPatrick Venture // If file exists, read. 157bb90d4fdSPatrick Venture std::ifstream ifs; 158bb90d4fdSPatrick Venture ifs.exceptions(std::ifstream::failbit); 159bb90d4fdSPatrick Venture std::string value; 160bb90d4fdSPatrick Venture try 161bb90d4fdSPatrick Venture { 162bb90d4fdSPatrick Venture ifs.open(opath.str()); 163bb90d4fdSPatrick Venture ifs >> value; 164bb90d4fdSPatrick Venture } 165bb90d4fdSPatrick Venture catch (std::ios_base::failure& fail) 166bb90d4fdSPatrick Venture { 167e5a06675SMichael Shen throw IpmiException(::ipmi::ccUnspecifiedError); 168bb90d4fdSPatrick Venture } 169bb90d4fdSPatrick Venture 170bb90d4fdSPatrick Venture // If value parses as expected, return version. 171bb90d4fdSPatrick Venture VersionTuple version = std::make_tuple(0, 0, 0, 0); 172bb90d4fdSPatrick Venture 173bb90d4fdSPatrick Venture int num_fields = 174bb90d4fdSPatrick Venture std::sscanf(value.c_str(), "%" SCNu8 ".%" SCNu8 ".%" SCNu8 ".%" SCNu8, 175bb90d4fdSPatrick Venture &std::get<0>(version), &std::get<1>(version), 176bb90d4fdSPatrick Venture &std::get<2>(version), &std::get<3>(version)); 177bb90d4fdSPatrick Venture if (num_fields == 0) 178bb90d4fdSPatrick Venture { 179bb90d4fdSPatrick Venture std::fprintf(stderr, "Invalid version.\n"); 180e5a06675SMichael Shen throw IpmiException(::ipmi::ccUnspecifiedError); 181bb90d4fdSPatrick Venture } 182bb90d4fdSPatrick Venture 183bb90d4fdSPatrick Venture return version; 184bb90d4fdSPatrick Venture } 185bb90d4fdSPatrick Venture 186aa374120SPatrick Venture static constexpr auto TIME_DELAY_FILENAME = "/run/psu_timedelay"; 187aa374120SPatrick Venture static constexpr auto SYSTEMD_SERVICE = "org.freedesktop.systemd1"; 188aa374120SPatrick Venture static constexpr auto SYSTEMD_ROOT = "/org/freedesktop/systemd1"; 189aa374120SPatrick Venture static constexpr auto SYSTEMD_INTERFACE = "org.freedesktop.systemd1.Manager"; 190aa374120SPatrick Venture static constexpr auto PSU_HARDRESET_TARGET = "gbmc-psu-hardreset.target"; 191aa374120SPatrick Venture 192aa374120SPatrick Venture void Handler::psuResetDelay(std::uint32_t delay) const 193aa374120SPatrick Venture { 194aa374120SPatrick Venture std::ofstream ofs; 195aa374120SPatrick Venture ofs.open(TIME_DELAY_FILENAME, std::ofstream::out); 196aa374120SPatrick Venture if (!ofs.good()) 197aa374120SPatrick Venture { 198aa374120SPatrick Venture std::fprintf(stderr, "Unable to open file for output.\n"); 199e5a06675SMichael Shen throw IpmiException(::ipmi::ccUnspecifiedError); 200aa374120SPatrick Venture } 201aa374120SPatrick Venture 202aa374120SPatrick Venture ofs << "PSU_HARDRESET_DELAY=" << delay << std::endl; 203aa374120SPatrick Venture if (ofs.fail()) 204aa374120SPatrick Venture { 205aa374120SPatrick Venture std::fprintf(stderr, "Write failed\n"); 206aa374120SPatrick Venture ofs.close(); 207e5a06675SMichael Shen throw IpmiException(::ipmi::ccUnspecifiedError); 208aa374120SPatrick Venture } 209aa374120SPatrick Venture 210aa374120SPatrick Venture // Write succeeded, please continue. 211aa374120SPatrick Venture ofs.flush(); 212aa374120SPatrick Venture ofs.close(); 213aa374120SPatrick Venture 214aa374120SPatrick Venture auto bus = sdbusplus::bus::new_default(); 215aa374120SPatrick Venture auto method = bus.new_method_call(SYSTEMD_SERVICE, SYSTEMD_ROOT, 216aa374120SPatrick Venture SYSTEMD_INTERFACE, "StartUnit"); 217aa374120SPatrick Venture 218aa374120SPatrick Venture method.append(PSU_HARDRESET_TARGET); 219aa374120SPatrick Venture method.append("replace"); 220aa374120SPatrick Venture 221aa374120SPatrick Venture try 222aa374120SPatrick Venture { 223aa374120SPatrick Venture bus.call_noreply(method); 224aa374120SPatrick Venture } 225aa374120SPatrick Venture catch (const sdbusplus::exception::SdBusError& ex) 226aa374120SPatrick Venture { 227aa374120SPatrick Venture log<level::ERR>("Failed to call PSU hard reset"); 228e5a06675SMichael Shen throw IpmiException(::ipmi::ccUnspecifiedError); 229aa374120SPatrick Venture } 230aa374120SPatrick Venture } 231aa374120SPatrick Venture 232ac4a16f7SShounak Mitra static constexpr auto RESET_ON_SHUTDOWN_FILENAME = "/run/powercycle_on_s5"; 233ac4a16f7SShounak Mitra 234ac4a16f7SShounak Mitra void Handler::psuResetOnShutdown() const 235ac4a16f7SShounak Mitra { 236ac4a16f7SShounak Mitra std::ofstream ofs; 237ac4a16f7SShounak Mitra ofs.open(RESET_ON_SHUTDOWN_FILENAME, std::ofstream::out); 238ac4a16f7SShounak Mitra if (!ofs.good()) 239ac4a16f7SShounak Mitra { 240ac4a16f7SShounak Mitra std::fprintf(stderr, "Unable to open file for output.\n"); 241e5a06675SMichael Shen throw IpmiException(::ipmi::ccUnspecifiedError); 242ac4a16f7SShounak Mitra } 243ac4a16f7SShounak Mitra ofs.close(); 244ac4a16f7SShounak Mitra } 245ac4a16f7SShounak Mitra 2463b1b427cSWilly Tu uint32_t Handler::getFlashSize() 2473b1b427cSWilly Tu { 2483b1b427cSWilly Tu mtd_info_t info; 2493b1b427cSWilly Tu int fd = open("/dev/mtd0", O_RDONLY); 2503b1b427cSWilly Tu int err = ioctl(fd, MEMGETINFO, &info); 2513b1b427cSWilly Tu close(fd); 2523b1b427cSWilly Tu 2533b1b427cSWilly Tu if (err) 2543b1b427cSWilly Tu { 255e5a06675SMichael Shen throw IpmiException(::ipmi::ccUnspecifiedError); 2563b1b427cSWilly Tu } 2573b1b427cSWilly Tu return info.size; 2583b1b427cSWilly Tu } 2593b1b427cSWilly Tu 260ab650004SPatrick Venture std::string Handler::getEntityName(std::uint8_t id, std::uint8_t instance) 26107f85150SPatrick Venture { 262ab650004SPatrick Venture // Check if we support this Entity ID. 263ab650004SPatrick Venture auto it = _entityIdToName.find(id); 264ab650004SPatrick Venture if (it == _entityIdToName.end()) 26507f85150SPatrick Venture { 266ab650004SPatrick Venture log<level::ERR>("Unknown Entity ID", entry("ENTITY_ID=%d", id)); 267e5a06675SMichael Shen throw IpmiException(::ipmi::ccInvalidFieldRequest); 26807f85150SPatrick Venture } 26907f85150SPatrick Venture 270ab650004SPatrick Venture std::string entityName; 271ab650004SPatrick Venture try 27207f85150SPatrick Venture { 273ab650004SPatrick Venture // Parse the JSON config file. 274ab650004SPatrick Venture if (!_entityConfigParsed) 275ab650004SPatrick Venture { 276ab650004SPatrick Venture _entityConfig = parseConfig(_configFile); 277ab650004SPatrick Venture _entityConfigParsed = true; 27807f85150SPatrick Venture } 27907f85150SPatrick Venture 280ab650004SPatrick Venture // Find the "entity id:entity instance" mapping to entity name. 281ab650004SPatrick Venture entityName = readNameFromConfig(it->second, instance, _entityConfig); 282ab650004SPatrick Venture if (entityName.empty()) 283ab650004SPatrick Venture { 284e5a06675SMichael Shen throw IpmiException(::ipmi::ccInvalidFieldRequest); 285ab650004SPatrick Venture } 286ab650004SPatrick Venture } 287ab650004SPatrick Venture catch (InternalFailure& e) 288ab650004SPatrick Venture { 289e5a06675SMichael Shen throw IpmiException(::ipmi::ccUnspecifiedError); 29007f85150SPatrick Venture } 29107f85150SPatrick Venture 292ab650004SPatrick Venture return entityName; 293ab650004SPatrick Venture } 294ab650004SPatrick Venture 29529f35bceSWilliam A. Kennington III std::string Handler::getMachineName() 29629f35bceSWilliam A. Kennington III { 29729f35bceSWilliam A. Kennington III const char* path = "/etc/os-release"; 29829f35bceSWilliam A. Kennington III std::ifstream ifs(path); 29929f35bceSWilliam A. Kennington III if (ifs.fail()) 30029f35bceSWilliam A. Kennington III { 30129f35bceSWilliam A. Kennington III std::fprintf(stderr, "Failed to open: %s\n", path); 302e5a06675SMichael Shen throw IpmiException(::ipmi::ccUnspecifiedError); 30329f35bceSWilliam A. Kennington III } 30429f35bceSWilliam A. Kennington III 30529f35bceSWilliam A. Kennington III std::string line; 30629f35bceSWilliam A. Kennington III while (true) 30729f35bceSWilliam A. Kennington III { 30829f35bceSWilliam A. Kennington III std::getline(ifs, line); 30929f35bceSWilliam A. Kennington III if (ifs.eof()) 31029f35bceSWilliam A. Kennington III { 31129f35bceSWilliam A. Kennington III std::fprintf(stderr, "Failed to find OPENBMC_TARGET_MACHINE: %s\n", 31229f35bceSWilliam A. Kennington III path); 313e5a06675SMichael Shen throw IpmiException(::ipmi::ccInvalidCommand); 31429f35bceSWilliam A. Kennington III } 31529f35bceSWilliam A. Kennington III if (ifs.fail()) 31629f35bceSWilliam A. Kennington III { 31729f35bceSWilliam A. Kennington III std::fprintf(stderr, "Failed to read: %s\n", path); 318e5a06675SMichael Shen throw IpmiException(::ipmi::ccUnspecifiedError); 31929f35bceSWilliam A. Kennington III } 32029f35bceSWilliam A. Kennington III std::string_view lineView(line); 32129f35bceSWilliam A. Kennington III constexpr std::string_view prefix = "OPENBMC_TARGET_MACHINE="; 32229f35bceSWilliam A. Kennington III if (lineView.substr(0, prefix.size()) != prefix) 32329f35bceSWilliam A. Kennington III { 32429f35bceSWilliam A. Kennington III continue; 32529f35bceSWilliam A. Kennington III } 32629f35bceSWilliam A. Kennington III lineView.remove_prefix(prefix.size()); 32729f35bceSWilliam A. Kennington III lineView.remove_prefix( 32829f35bceSWilliam A. Kennington III std::min(lineView.find_first_not_of('"'), lineView.size())); 32929f35bceSWilliam A. Kennington III lineView.remove_suffix( 33029f35bceSWilliam A. Kennington III lineView.size() - 1 - 33129f35bceSWilliam A. Kennington III std::min(lineView.find_last_not_of('"'), lineView.size() - 1)); 33229f35bceSWilliam A. Kennington III return std::string(lineView); 33329f35bceSWilliam A. Kennington III } 33429f35bceSWilliam A. Kennington III } 33529f35bceSWilliam A. Kennington III 3368cfa4c44Slinyuny static constexpr auto HOST_TIME_DELAY_FILENAME = "/run/host_poweroff_delay"; 3378cfa4c44Slinyuny static constexpr auto HOST_POWEROFF_TARGET = "gbmc-host-poweroff.target"; 3388cfa4c44Slinyuny 3398cfa4c44Slinyuny void Handler::hostPowerOffDelay(std::uint32_t delay) const 3408cfa4c44Slinyuny { 3418cfa4c44Slinyuny // Set time delay 3428cfa4c44Slinyuny std::ofstream ofs; 3438cfa4c44Slinyuny ofs.open(HOST_TIME_DELAY_FILENAME, std::ofstream::out); 3448cfa4c44Slinyuny if (!ofs.good()) 3458cfa4c44Slinyuny { 3468cfa4c44Slinyuny std::fprintf(stderr, "Unable to open file for output.\n"); 347e5a06675SMichael Shen throw IpmiException(::ipmi::ccUnspecifiedError); 3488cfa4c44Slinyuny } 3498cfa4c44Slinyuny 3508cfa4c44Slinyuny ofs << "HOST_POWEROFF_DELAY=" << delay << std::endl; 3518cfa4c44Slinyuny ofs.close(); 3528cfa4c44Slinyuny if (ofs.fail()) 3538cfa4c44Slinyuny { 3548cfa4c44Slinyuny std::fprintf(stderr, "Write failed\n"); 355e5a06675SMichael Shen throw IpmiException(::ipmi::ccUnspecifiedError); 3568cfa4c44Slinyuny } 3578cfa4c44Slinyuny 3588cfa4c44Slinyuny // Write succeeded, please continue. 3598cfa4c44Slinyuny auto bus = sdbusplus::bus::new_default(); 3608cfa4c44Slinyuny auto method = bus.new_method_call(SYSTEMD_SERVICE, SYSTEMD_ROOT, 3618cfa4c44Slinyuny SYSTEMD_INTERFACE, "StartUnit"); 3628cfa4c44Slinyuny 3638cfa4c44Slinyuny method.append(HOST_POWEROFF_TARGET); 3648cfa4c44Slinyuny method.append("replace"); 3658cfa4c44Slinyuny 3668cfa4c44Slinyuny try 3678cfa4c44Slinyuny { 3688cfa4c44Slinyuny bus.call_noreply(method); 3698cfa4c44Slinyuny } 3708cfa4c44Slinyuny catch (const sdbusplus::exception::SdBusError& ex) 3718cfa4c44Slinyuny { 3728cfa4c44Slinyuny log<level::ERR>("Failed to call Power Off", 3738cfa4c44Slinyuny entry("WHAT=%s", ex.what())); 374e5a06675SMichael Shen throw IpmiException(::ipmi::ccUnspecifiedError); 3758cfa4c44Slinyuny } 3768cfa4c44Slinyuny } 3778cfa4c44Slinyuny 378ab650004SPatrick Venture std::string readNameFromConfig(const std::string& type, uint8_t instance, 379ab650004SPatrick Venture const Json& config) 38007f85150SPatrick Venture { 38107f85150SPatrick Venture static const std::vector<Json> empty{}; 38207f85150SPatrick Venture std::vector<Json> readings = config.value(type, empty); 38307f85150SPatrick Venture std::string name = ""; 384ab650004SPatrick Venture 38507f85150SPatrick Venture for (const auto& j : readings) 38607f85150SPatrick Venture { 38707f85150SPatrick Venture uint8_t instanceNum = j.value("instance", 0); 38807f85150SPatrick Venture // Not the instance we're interested in 38907f85150SPatrick Venture if (instanceNum != instance) 39007f85150SPatrick Venture { 39107f85150SPatrick Venture continue; 39207f85150SPatrick Venture } 39307f85150SPatrick Venture 39407f85150SPatrick Venture // Found the instance we're interested in 39507f85150SPatrick Venture name = j.value("name", ""); 39607f85150SPatrick Venture 39707f85150SPatrick Venture break; 39807f85150SPatrick Venture } 399ab650004SPatrick Venture 40007f85150SPatrick Venture return name; 40107f85150SPatrick Venture } 40207f85150SPatrick Venture 40349f23ad9SPatrick Venture void Handler::buildI2cPcieMapping() 40449f23ad9SPatrick Venture { 40549f23ad9SPatrick Venture _pcie_i2c_map = buildPcieMap(); 40649f23ad9SPatrick Venture } 40749f23ad9SPatrick Venture 40849f23ad9SPatrick Venture size_t Handler::getI2cPcieMappingSize() const 40949f23ad9SPatrick Venture { 41049f23ad9SPatrick Venture return _pcie_i2c_map.size(); 41149f23ad9SPatrick Venture } 41249f23ad9SPatrick Venture 41349f23ad9SPatrick Venture std::tuple<std::uint32_t, std::string> 41449f23ad9SPatrick Venture Handler::getI2cEntry(unsigned int entry) const 41549f23ad9SPatrick Venture { 41649f23ad9SPatrick Venture return _pcie_i2c_map[entry]; 41749f23ad9SPatrick Venture } 41849f23ad9SPatrick Venture 4194f0d1de6SSteve Foreman namespace 4204f0d1de6SSteve Foreman { 4214f0d1de6SSteve Foreman 4224f0d1de6SSteve Foreman static constexpr std::string_view ACCEL_OOB_ROOT = "/com/google/customAccel/"; 4234f0d1de6SSteve Foreman static constexpr char ACCEL_OOB_SERVICE[] = "com.google.custom_accel"; 4244f0d1de6SSteve Foreman static constexpr char ACCEL_OOB_INTERFACE[] = "com.google.custom_accel.BAR"; 4254f0d1de6SSteve Foreman 4264f0d1de6SSteve Foreman // C type for "a{oa{sa{sv}}}" from DBus.ObjectManager::GetManagedObjects() 4274f0d1de6SSteve Foreman using AnyType = std::variant<std::string, uint8_t, uint32_t, uint64_t>; 4284f0d1de6SSteve Foreman using AnyTypeList = std::vector<std::pair<std::string, AnyType>>; 4294f0d1de6SSteve Foreman using NamedArrayOfAnyTypeLists = 4304f0d1de6SSteve Foreman std::vector<std::pair<std::string, AnyTypeList>>; 4314f0d1de6SSteve Foreman using ArrayOfObjectPathsAndTieredAnyTypeLists = std::vector< 4324f0d1de6SSteve Foreman std::pair<sdbusplus::message::object_path, NamedArrayOfAnyTypeLists>>; 4334f0d1de6SSteve Foreman 4344f0d1de6SSteve Foreman } // namespace 4354f0d1de6SSteve Foreman 4360e928ac6SMichael Shen sdbusplus::bus::bus Handler::getDbus() const 4374f0d1de6SSteve Foreman { 4384f0d1de6SSteve Foreman return sdbusplus::bus::new_default(); 4394f0d1de6SSteve Foreman } 4404f0d1de6SSteve Foreman 4414f0d1de6SSteve Foreman uint32_t Handler::accelOobDeviceCount() const 4424f0d1de6SSteve Foreman { 4434f0d1de6SSteve Foreman ArrayOfObjectPathsAndTieredAnyTypeLists data; 4444f0d1de6SSteve Foreman 4454f0d1de6SSteve Foreman try 4464f0d1de6SSteve Foreman { 4470e928ac6SMichael Shen auto bus = getDbus(); 4484f0d1de6SSteve Foreman auto method = bus.new_method_call(ACCEL_OOB_SERVICE, "/", 4494f0d1de6SSteve Foreman "org.freedesktop.DBus.ObjectManager", 4504f0d1de6SSteve Foreman "GetManagedObjects"); 4514f0d1de6SSteve Foreman bus.call(method).read(data); 4524f0d1de6SSteve Foreman } 4534f0d1de6SSteve Foreman catch (const sdbusplus::exception::SdBusError& ex) 4544f0d1de6SSteve Foreman { 4554f0d1de6SSteve Foreman log<level::ERR>( 4564f0d1de6SSteve Foreman "Failed to call GetManagedObjects on com.google.custom_accel", 4574f0d1de6SSteve Foreman entry("WHAT=%s", ex.what())); 458e5a06675SMichael Shen throw IpmiException(::ipmi::ccUnspecifiedError); 4594f0d1de6SSteve Foreman } 4604f0d1de6SSteve Foreman 4614f0d1de6SSteve Foreman return data.size(); 4624f0d1de6SSteve Foreman } 4634f0d1de6SSteve Foreman 4644f0d1de6SSteve Foreman std::string Handler::accelOobDeviceName(size_t index) const 4654f0d1de6SSteve Foreman { 4664f0d1de6SSteve Foreman ArrayOfObjectPathsAndTieredAnyTypeLists data; 4674f0d1de6SSteve Foreman 4684f0d1de6SSteve Foreman try 4694f0d1de6SSteve Foreman { 4700e928ac6SMichael Shen auto bus = getDbus(); 4714f0d1de6SSteve Foreman auto method = bus.new_method_call(ACCEL_OOB_SERVICE, "/", 4724f0d1de6SSteve Foreman "org.freedesktop.DBus.ObjectManager", 4734f0d1de6SSteve Foreman "GetManagedObjects"); 4744f0d1de6SSteve Foreman bus.call(method).read(data); 4754f0d1de6SSteve Foreman } 4764f0d1de6SSteve Foreman catch (const sdbusplus::exception::SdBusError& ex) 4774f0d1de6SSteve Foreman { 4784f0d1de6SSteve Foreman log<level::ERR>( 4794f0d1de6SSteve Foreman "Failed to call GetManagedObjects on com.google.custom_accel", 4804f0d1de6SSteve Foreman entry("WHAT=%s", ex.what())); 481e5a06675SMichael Shen throw IpmiException(::ipmi::ccUnspecifiedError); 4824f0d1de6SSteve Foreman } 4834f0d1de6SSteve Foreman 4844f0d1de6SSteve Foreman if (index >= data.size()) 4854f0d1de6SSteve Foreman { 4864f0d1de6SSteve Foreman log<level::WARNING>( 4874f0d1de6SSteve Foreman "Requested index is larger than the number of entries.", 4884f0d1de6SSteve Foreman entry("INDEX=%zu", index), entry("NUM_NAMES=%zu", data.size())); 489e5a06675SMichael Shen throw IpmiException(::ipmi::ccParmOutOfRange); 4904f0d1de6SSteve Foreman } 4914f0d1de6SSteve Foreman 4924f0d1de6SSteve Foreman std::string_view name(data[index].first.str); 4934f0d1de6SSteve Foreman if (!name.starts_with(ACCEL_OOB_ROOT)) 4944f0d1de6SSteve Foreman { 495e5a06675SMichael Shen throw IpmiException(::ipmi::ccInvalidCommand); 4964f0d1de6SSteve Foreman } 4974f0d1de6SSteve Foreman name.remove_prefix(ACCEL_OOB_ROOT.length()); 4984f0d1de6SSteve Foreman return std::string(name); 4994f0d1de6SSteve Foreman } 5004f0d1de6SSteve Foreman 5014f0d1de6SSteve Foreman uint64_t Handler::accelOobRead(std::string_view name, uint64_t address, 5024f0d1de6SSteve Foreman uint8_t num_bytes) const 5034f0d1de6SSteve Foreman { 5044f0d1de6SSteve Foreman static constexpr char ACCEL_OOB_METHOD[] = "Read"; 5054f0d1de6SSteve Foreman 5064f0d1de6SSteve Foreman std::string object_name(ACCEL_OOB_ROOT); 5074f0d1de6SSteve Foreman object_name.append(name); 5084f0d1de6SSteve Foreman 5090e928ac6SMichael Shen auto bus = getDbus(); 5104f0d1de6SSteve Foreman auto method = bus.new_method_call(ACCEL_OOB_SERVICE, object_name.c_str(), 5114f0d1de6SSteve Foreman ACCEL_OOB_INTERFACE, ACCEL_OOB_METHOD); 5124f0d1de6SSteve Foreman method.append(address, static_cast<uint64_t>(num_bytes)); 5134f0d1de6SSteve Foreman 5144f0d1de6SSteve Foreman std::vector<uint8_t> bytes; 5154f0d1de6SSteve Foreman 5164f0d1de6SSteve Foreman try 5174f0d1de6SSteve Foreman { 5184f0d1de6SSteve Foreman bus.call(method).read(bytes); 5194f0d1de6SSteve Foreman } 5204f0d1de6SSteve Foreman catch (const sdbusplus::exception::SdBusError& ex) 5214f0d1de6SSteve Foreman { 5224f0d1de6SSteve Foreman log<level::ERR>("Failed to call Read on com.google.custom_accel", 5234f0d1de6SSteve Foreman entry("WHAT=%s", ex.what()), 5244f0d1de6SSteve Foreman entry("DBUS_SERVICE=%s", ACCEL_OOB_SERVICE), 5254f0d1de6SSteve Foreman entry("DBUS_OBJECT=%s", object_name.c_str()), 5264f0d1de6SSteve Foreman entry("DBUS_INTERFACE=%s", ACCEL_OOB_INTERFACE), 5274f0d1de6SSteve Foreman entry("DBUS_METHOD=%s", ACCEL_OOB_METHOD), 5284f0d1de6SSteve Foreman entry("DBUS_ARG_ADDRESS=%016llx", address), 5294f0d1de6SSteve Foreman entry("DBUS_ARG_NUM_BYTES=%zu", (size_t)num_bytes)); 530e5a06675SMichael Shen throw IpmiException(::ipmi::ccUnspecifiedError); 5314f0d1de6SSteve Foreman } 5324f0d1de6SSteve Foreman 5334f0d1de6SSteve Foreman if (bytes.size() < num_bytes) 5344f0d1de6SSteve Foreman { 5354f0d1de6SSteve Foreman log<level::ERR>( 5364f0d1de6SSteve Foreman "Call to Read on com.google.custom_accel didn't return the expected" 5374f0d1de6SSteve Foreman " number of bytes.", 5384f0d1de6SSteve Foreman entry("DBUS_SERVICE=%s", ACCEL_OOB_SERVICE), 5394f0d1de6SSteve Foreman entry("DBUS_OBJECT=%s", object_name.c_str()), 5404f0d1de6SSteve Foreman entry("DBUS_INTERFACE=%s", ACCEL_OOB_INTERFACE), 5414f0d1de6SSteve Foreman entry("DBUS_METHOD=%s", ACCEL_OOB_METHOD), 5424f0d1de6SSteve Foreman entry("DBUS_ARG_ADDRESS=%016llx", address), 5434f0d1de6SSteve Foreman entry("DBUS_ARG_NUM_BYTES=%zu", (size_t)num_bytes), 5444f0d1de6SSteve Foreman entry("DBUS_RETURN_SIZE=%zu", bytes.size())); 545e5a06675SMichael Shen throw IpmiException(::ipmi::ccUnspecifiedError); 5464f0d1de6SSteve Foreman } 5474f0d1de6SSteve Foreman 5484f0d1de6SSteve Foreman if (bytes.size() > sizeof(uint64_t)) 5494f0d1de6SSteve Foreman { 5504f0d1de6SSteve Foreman log<level::ERR>( 5514f0d1de6SSteve Foreman "Call to Read on com.google.custom_accel returned more than 8B.", 5524f0d1de6SSteve Foreman entry("DBUS_SERVICE=%s", ACCEL_OOB_SERVICE), 5534f0d1de6SSteve Foreman entry("DBUS_OBJECT=%s", object_name.c_str()), 5544f0d1de6SSteve Foreman entry("DBUS_INTERFACE=%s", ACCEL_OOB_INTERFACE), 5554f0d1de6SSteve Foreman entry("DBUS_METHOD=%s", ACCEL_OOB_METHOD), 5564f0d1de6SSteve Foreman entry("DBUS_ARG_ADDRESS=%016llx", address), 5574f0d1de6SSteve Foreman entry("DBUS_ARG_NUM_BYTES=%zu", (size_t)num_bytes), 5584f0d1de6SSteve Foreman entry("DBUS_RETURN_SIZE=%zu", bytes.size())); 559e5a06675SMichael Shen throw IpmiException(::ipmi::ccReqDataTruncated); 5604f0d1de6SSteve Foreman } 5614f0d1de6SSteve Foreman 5624f0d1de6SSteve Foreman uint64_t data = 0; 5634f0d1de6SSteve Foreman for (size_t i = 0; i < num_bytes; ++i) 5644f0d1de6SSteve Foreman { 5654f0d1de6SSteve Foreman data = (data << 8) | bytes[i]; 5664f0d1de6SSteve Foreman } 5674f0d1de6SSteve Foreman 5684f0d1de6SSteve Foreman return data; 5694f0d1de6SSteve Foreman } 5704f0d1de6SSteve Foreman 5714f0d1de6SSteve Foreman void Handler::accelOobWrite(std::string_view name, uint64_t address, 5724f0d1de6SSteve Foreman uint8_t num_bytes, uint64_t data) const 5734f0d1de6SSteve Foreman { 5744f0d1de6SSteve Foreman static constexpr std::string_view ACCEL_OOB_METHOD = "Write"; 5754f0d1de6SSteve Foreman 5764f0d1de6SSteve Foreman std::string object_name(ACCEL_OOB_ROOT); 5774f0d1de6SSteve Foreman object_name.append(name); 5784f0d1de6SSteve Foreman 5794f0d1de6SSteve Foreman if (num_bytes > sizeof(data)) 5804f0d1de6SSteve Foreman { 5814f0d1de6SSteve Foreman log<level::ERR>( 5824f0d1de6SSteve Foreman "Call to Write on com.google.custom_accel requested more than 8B.", 5834f0d1de6SSteve Foreman entry("DBUS_SERVICE=%s", ACCEL_OOB_SERVICE), 5844f0d1de6SSteve Foreman entry("DBUS_OBJECT=%s", object_name.c_str()), 5854f0d1de6SSteve Foreman entry("DBUS_INTERFACE=%s", ACCEL_OOB_INTERFACE), 5864f0d1de6SSteve Foreman entry("DBUS_METHOD=%s", ACCEL_OOB_METHOD.data()), 5874f0d1de6SSteve Foreman entry("DBUS_ARG_ADDRESS=%016llx", address), 5884f0d1de6SSteve Foreman entry("DBUS_ARG_NUM_BYTES=%zu", (size_t)num_bytes), 5894f0d1de6SSteve Foreman entry("DBUS_ARG_DATA=%016llx", data)); 590e5a06675SMichael Shen throw IpmiException(::ipmi::ccParmOutOfRange); 5914f0d1de6SSteve Foreman } 5924f0d1de6SSteve Foreman 5934f0d1de6SSteve Foreman std::vector<uint8_t> bytes; 5944f0d1de6SSteve Foreman bytes.reserve(num_bytes); 5954f0d1de6SSteve Foreman for (size_t i = 0; i < num_bytes; ++i) 5964f0d1de6SSteve Foreman { 5974f0d1de6SSteve Foreman bytes.emplace_back(data & 0xff); 5984f0d1de6SSteve Foreman data >>= 8; 5994f0d1de6SSteve Foreman } 6004f0d1de6SSteve Foreman 6014f0d1de6SSteve Foreman try 6024f0d1de6SSteve Foreman { 6030e928ac6SMichael Shen auto bus = getDbus(); 6044f0d1de6SSteve Foreman auto method = 6054f0d1de6SSteve Foreman bus.new_method_call(ACCEL_OOB_SERVICE, object_name.c_str(), 6064f0d1de6SSteve Foreman ACCEL_OOB_INTERFACE, ACCEL_OOB_METHOD.data()); 6074f0d1de6SSteve Foreman method.append(address, bytes); 6084f0d1de6SSteve Foreman bus.call_noreply(method); 6094f0d1de6SSteve Foreman } 6104f0d1de6SSteve Foreman catch (const sdbusplus::exception::SdBusError& ex) 6114f0d1de6SSteve Foreman { 6124f0d1de6SSteve Foreman log<level::ERR>("Failed to call Write on com.google.custom_accel", 6134f0d1de6SSteve Foreman entry("WHAT=%s", ex.what()), 6144f0d1de6SSteve Foreman entry("DBUS_SERVICE=%s", ACCEL_OOB_SERVICE), 6154f0d1de6SSteve Foreman entry("DBUS_OBJECT=%s", object_name.c_str()), 6164f0d1de6SSteve Foreman entry("DBUS_INTERFACE=%s", ACCEL_OOB_INTERFACE), 6174f0d1de6SSteve Foreman entry("DBUS_METHOD=%s", ACCEL_OOB_METHOD.data()), 6184f0d1de6SSteve Foreman entry("DBUS_ARG_ADDRESS=%016llx", address), 6194f0d1de6SSteve Foreman entry("DBUS_ARG_NUM_BYTES=%zu", (size_t)num_bytes), 6204f0d1de6SSteve Foreman entry("DBUS_ARG_DATA=%016llx", data)); 621e5a06675SMichael Shen throw IpmiException(::ipmi::ccUnspecifiedError); 6224f0d1de6SSteve Foreman } 6234f0d1de6SSteve Foreman } 6244f0d1de6SSteve Foreman 6256c71b0f9SWilly Tu std::vector<uint8_t> Handler::pcieBifurcation(uint8_t index) 6266c71b0f9SWilly Tu { 6276c71b0f9SWilly Tu return bifurcationHelper.get().getBifurcation(index).value_or( 6286c71b0f9SWilly Tu std::vector<uint8_t>{}); 6296c71b0f9SWilly Tu } 6306c71b0f9SWilly Tu 631f085d91dSPatrick Venture } // namespace ipmi 632f085d91dSPatrick Venture } // namespace google 633