include/sdrutils.hpp - openbmc/intel-ipmi-oem - Gitiles

 /*
 // Copyright (c) 2018 Intel Corporation
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
 // You may obtain a copy of the License at
 //
 //      http://www.apache.org/licenses/LICENSE-2.0
 //
 // Unless required by applicable law or agreed to in writing, software
 // distributed under the License is distributed on an "AS IS" BASIS,
 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 // See the License for the specific language governing permissions and
 // limitations under the License.
 */

 #include "commandutils.hpp"
 #include "types.hpp"

 #include <boost/algorithm/string.hpp>
 #include <boost/bimap.hpp>
 #include <boost/container/flat_map.hpp>
 #include <phosphor-logging/log.hpp>
 #include <sdbusplus/bus/match.hpp>

 #include <cstdio>
 #include <cstring>
 #include <exception>
 #include <filesystem>
 #include <map>
 #include <string>
 #include <string_view>
 #include <vector>

 #pragma once

 struct CmpStrVersion
 {
     bool operator()(std::string a, std::string b) const
     {
         return strverscmp(a.c_str(), b.c_str()) < 0;
     }
 };

 using SensorSubTree = boost::container::flat_map<
     std::string,
     boost::container::flat_map<std::string, std::vector<std::string>>,
     CmpStrVersion>;

 using SensorNumMap = boost::bimap<int, std::string>;

 static constexpr uint16_t maxSensorsPerLUN = 255;
 static constexpr uint16_t maxIPMISensors = (maxSensorsPerLUN * 3);
 static constexpr uint16_t lun1Sensor0 = 0x100;
 static constexpr uint16_t lun3Sensor0 = 0x300;
 static constexpr uint16_t invalidSensorNumber = 0xFFFF;
 static constexpr uint8_t reservedSensorNumber = 0xFF;

 namespace details
 {

 // Enable/disable the logging of stats instrumentation
 static constexpr bool enableInstrumentation = false;

 class IPMIStatsEntry
 {
   private:
     int numReadings = 0;
     int numMissings = 0;
     int numStreakRead = 0;
     int numStreakMiss = 0;
     double minValue = 0.0;
     double maxValue = 0.0;
     std::string sensorName;

   public:
     const std::string& getName(void) const
     {
         return sensorName;
     }

     void updateName(std::string_view name)
     {
         sensorName = name;
     }

     // Returns true if this is the first successful reading
     // This is so the caller can log the coefficients used
     bool updateReading(double reading, int raw)
     {
         if constexpr (!enableInstrumentation)
         {
             return false;
         }

         bool first = ((numReadings == 0) && (numMissings == 0));

         // Sensors can use "nan" to indicate unavailable reading
         if (!(std::isfinite(reading)))
         {
             // Only show this if beginning a new streak
             if (numStreakMiss == 0)
             {
                 std::cerr << "IPMI sensor " << sensorName
                           << ": Missing reading, byte=" << raw
                           << ", Reading counts good=" << numReadings
                           << " miss=" << numMissings
                           << ", Prior good streak=" << numStreakRead << "\n";
             }

             numStreakRead = 0;
             ++numMissings;
             ++numStreakMiss;

             return first;
         }

         // Only show this if beginning a new streak and not the first time
         if ((numStreakRead == 0) && (numReadings != 0))
         {
             std::cerr << "IPMI sensor " << sensorName
                       << ": Recovered reading, value=" << reading
                       << " byte=" << raw
                       << ", Reading counts good=" << numReadings
                       << " miss=" << numMissings
                       << ", Prior miss streak=" << numStreakMiss << "\n";
         }

         // Initialize min/max if the first successful reading
         if (numReadings == 0)
         {
             std::cerr << "IPMI sensor " << sensorName
                       << ": First reading, value=" << reading << " byte=" << raw
                       << "\n";

             minValue = reading;
             maxValue = reading;
         }

         numStreakMiss = 0;
         ++numReadings;
         ++numStreakRead;

         // Only provide subsequent output if new min/max established
         if (reading < minValue)
         {
             std::cerr << "IPMI sensor " << sensorName
                       << ": Lowest reading, value=" << reading
                       << " byte=" << raw << "\n";

             minValue = reading;
         }

         if (reading > maxValue)
         {
             std::cerr << "IPMI sensor " << sensorName
                       << ": Highest reading, value=" << reading
                       << " byte=" << raw << "\n";

             maxValue = reading;
         }

         return first;
     }
 };

 class IPMIStatsTable
 {
   private:
     std::vector<IPMIStatsEntry> entries;

   private:
     void padEntries(size_t index)
     {
         char hexbuf[16];

         // Pad vector until entries[index] becomes a valid index
         while (entries.size() <= index)
         {
             // As name not known yet, use human-readable hex as name
             IPMIStatsEntry newEntry;
             sprintf(hexbuf, "0x%02zX", entries.size());
             newEntry.updateName(hexbuf);

             entries.push_back(std::move(newEntry));
         }
     }

   public:
     void wipeTable(void)
     {
         entries.clear();
     }

     const std::string& getName(size_t index)
     {
         padEntries(index);
         return entries[index].getName();
     }

     void updateName(size_t index, std::string_view name)
     {
         padEntries(index);
         entries[index].updateName(name);
     }

     bool updateReading(size_t index, double reading, int raw)
     {
         padEntries(index);
         return entries[index].updateReading(reading, raw);
     }
 };

 // This object is global singleton, used from a variety of places
 inline IPMIStatsTable sdrStatsTable;

 inline static uint16_t getSensorSubtree(std::shared_ptr<SensorSubTree>& subtree)
 {
     static std::shared_ptr<SensorSubTree> sensorTreePtr;
     static uint16_t sensorUpdatedIndex = 0;
     sd_bus* bus = NULL;
     int ret = sd_bus_default_system(&bus);
     if (ret < 0)
     {
         phosphor::logging::log<phosphor::logging::level::ERR>(
             "Failed to connect to system bus",
             phosphor::logging::entry("ERRNO=0x%X", -ret));
         sd_bus_unref(bus);
         return sensorUpdatedIndex;
     }
     sdbusplus::bus::bus dbus(bus);
     static sdbusplus::bus::match::match sensorAdded(
         dbus,
         "type='signal',member='InterfacesAdded',arg0path='/xyz/openbmc_project/"
         "sensors/'",
         [](sdbusplus::message::message& m) { sensorTreePtr.reset(); });

     static sdbusplus::bus::match::match sensorRemoved(
         dbus,
         "type='signal',member='InterfacesRemoved',arg0path='/xyz/"
         "openbmc_project/sensors/'",
         [](sdbusplus::message::message& m) { sensorTreePtr.reset(); });

     if (sensorTreePtr)
     {
         subtree = sensorTreePtr;
         return sensorUpdatedIndex;
     }

     sensorTreePtr = std::make_shared<SensorSubTree>();

     auto mapperCall =
         dbus.new_method_call("xyz.openbmc_project.ObjectMapper",
                              "/xyz/openbmc_project/object_mapper",
                              "xyz.openbmc_project.ObjectMapper", "GetSubTree");
     static constexpr const auto depth = 2;
     static constexpr std::array<const char*, 3> interfaces = {
         "xyz.openbmc_project.Sensor.Value",
         "xyz.openbmc_project.Sensor.Threshold.Warning",
         "xyz.openbmc_project.Sensor.Threshold.Critical"};
     mapperCall.append("/xyz/openbmc_project/sensors", depth, interfaces);

     try
     {
         auto mapperReply = dbus.call(mapperCall);
         mapperReply.read(*sensorTreePtr);
     }
     catch (sdbusplus::exception_t& e)
     {
         phosphor::logging::log<phosphor::logging::level::ERR>(e.what());
         return sensorUpdatedIndex;
     }
     subtree = sensorTreePtr;
     sensorUpdatedIndex++;
     // The SDR is being regenerated, wipe the old stats
     sdrStatsTable.wipeTable();
     return sensorUpdatedIndex;
 }

 inline static bool getSensorNumMap(std::shared_ptr<SensorNumMap>& sensorNumMap)
 {
     static std::shared_ptr<SensorNumMap> sensorNumMapPtr;
     bool sensorNumMapUpated = false;
     static uint16_t prevSensorUpdatedIndex = 0;
     std::shared_ptr<SensorSubTree> sensorTree;
     uint16_t curSensorUpdatedIndex = details::getSensorSubtree(sensorTree);
     if (!sensorTree)
     {
         return sensorNumMapUpated;
     }

     if ((curSensorUpdatedIndex == prevSensorUpdatedIndex) && sensorNumMapPtr)
     {
         sensorNumMap = sensorNumMapPtr;
         return sensorNumMapUpated;
     }
     prevSensorUpdatedIndex = curSensorUpdatedIndex;

     sensorNumMapPtr = std::make_shared<SensorNumMap>();

     uint16_t sensorNum = 0;
     uint16_t sensorIndex = 0;
     for (const auto& sensor : *sensorTree)
     {
         sensorNumMapPtr->insert(
             SensorNumMap::value_type(sensorNum, sensor.first));
         sensorIndex++;
         if (sensorIndex == maxSensorsPerLUN)
         {
             sensorIndex = lun1Sensor0;
         }
         else if (sensorIndex == (lun1Sensor0 | maxSensorsPerLUN))
         {
             // Skip assigning LUN 0x2 any sensors
             sensorIndex = lun3Sensor0;
         }
         else if (sensorIndex == (lun3Sensor0 | maxSensorsPerLUN))
         {
             // this is an error, too many IPMI sensors
             throw std::out_of_range("Maximum number of IPMI sensors exceeded.");
         }
         sensorNum = sensorIndex;
     }
     sensorNumMap = sensorNumMapPtr;
     sensorNumMapUpated = true;
     return sensorNumMapUpated;
 }
 } // namespace details

 inline static bool getSensorSubtree(SensorSubTree& subtree)
 {
     std::shared_ptr<SensorSubTree> sensorTree;
     details::getSensorSubtree(sensorTree);
     if (!sensorTree)
     {
         return false;
     }

     subtree = *sensorTree;
     return true;
 }

 struct CmpStr
 {
     bool operator()(const char* a, const char* b) const
     {
         return std::strcmp(a, b) < 0;
     }
 };

 enum class SensorTypeCodes : uint8_t
 {
     reserved = 0x0,
     temperature = 0x1,
     voltage = 0x2,
     current = 0x3,
     fan = 0x4,
     other = 0xB,
 };

 const static boost::container::flat_map<const char*, SensorTypeCodes, CmpStr>
     sensorTypes{{{"temperature", SensorTypeCodes::temperature},
                  {"voltage", SensorTypeCodes::voltage},
                  {"current", SensorTypeCodes::current},
                  {"fan_tach", SensorTypeCodes::fan},
                  {"fan_pwm", SensorTypeCodes::fan},
                  {"power", SensorTypeCodes::other}}};

 inline static std::string getSensorTypeStringFromPath(const std::string& path)
 {
     // get sensor type string from path, path is defined as
     // /xyz/openbmc_project/sensors/<type>/label
     size_t typeEnd = path.rfind("/");
     if (typeEnd == std::string::npos)
     {
         return path;
     }
     size_t typeStart = path.rfind("/", typeEnd - 1);
     if (typeStart == std::string::npos)
     {
         return path;
     }
     // Start at the character after the '/'
     typeStart++;
     return path.substr(typeStart, typeEnd - typeStart);
 }

 inline static uint8_t getSensorTypeFromPath(const std::string& path)
 {
     uint8_t sensorType = 0;
     std::string type = getSensorTypeStringFromPath(path);
     auto findSensor = sensorTypes.find(type.c_str());
     if (findSensor != sensorTypes.end())
     {
         sensorType = static_cast<uint8_t>(findSensor->second);
     } // else default 0x0 RESERVED

     return sensorType;
 }

 inline static uint16_t getSensorNumberFromPath(const std::string& path)
 {
     std::shared_ptr<SensorNumMap> sensorNumMapPtr;
     details::getSensorNumMap(sensorNumMapPtr);
     if (!sensorNumMapPtr)
     {
         return invalidSensorNumber;
     }

     try
     {
         return sensorNumMapPtr->right.at(path);
     }
     catch (std::out_of_range& e)
     {
         phosphor::logging::log<phosphor::logging::level::ERR>(e.what());
         return invalidSensorNumber;
     }
 }

 inline static uint8_t getSensorEventTypeFromPath(const std::string& path)
 {
     // TODO: Add support for additional reading types as needed
     return 0x1; // reading type = threshold
 }

 inline static std::string getPathFromSensorNumber(uint16_t sensorNum)
 {
     std::shared_ptr<SensorNumMap> sensorNumMapPtr;
     details::getSensorNumMap(sensorNumMapPtr);
     if (!sensorNumMapPtr)
     {
         return std::string();
     }

     try
     {
         return sensorNumMapPtr->left.at(sensorNum);
     }
     catch (std::out_of_range& e)
     {
         phosphor::logging::log<phosphor::logging::level::ERR>(e.what());
         return std::string();
     }
 }

 namespace ipmi
 {

 static inline std::map<std::string, std::vector<std::string>>
     getObjectInterfaces(const char* path)
 {
     std::map<std::string, std::vector<std::string>> interfacesResponse;
     std::vector<std::string> interfaces;
     std::shared_ptr<sdbusplus::asio::connection> dbus = getSdBus();

     sdbusplus::message::message getObjectMessage =
         dbus->new_method_call("xyz.openbmc_project.ObjectMapper",
                               "/xyz/openbmc_project/object_mapper",
                               "xyz.openbmc_project.ObjectMapper", "GetObject");
     getObjectMessage.append(path, interfaces);

     try
     {
         sdbusplus::message::message response = dbus->call(getObjectMessage);
         response.read(interfacesResponse);
     }
     catch (const std::exception& e)
     {
         phosphor::logging::log<phosphor::logging::level::ERR>(
             "Failed to GetObject", phosphor::logging::entry("PATH=%s", path),
             phosphor::logging::entry("WHAT=%s", e.what()));
     }

     return interfacesResponse;
 }

 static inline std::map<std::string, DbusVariant>
     getEntityManagerProperties(const char* path, const char* interface)
 {
     std::map<std::string, DbusVariant> properties;
     std::shared_ptr<sdbusplus::asio::connection> dbus = getSdBus();

     sdbusplus::message::message getProperties =
         dbus->new_method_call("xyz.openbmc_project.EntityManager", path,
                               "org.freedesktop.DBus.Properties", "GetAll");
     getProperties.append(interface);

     try
     {
         sdbusplus::message::message response = dbus->call(getProperties);
         response.read(properties);
     }
     catch (const std::exception& e)
     {
         phosphor::logging::log<phosphor::logging::level::ERR>(
             "Failed to GetAll", phosphor::logging::entry("PATH=%s", path),
             phosphor::logging::entry("INTF=%s", interface),
             phosphor::logging::entry("WHAT=%s", e.what()));
     }

     return properties;
 }

 static inline const std::string* getSensorConfigurationInterface(
     const std::map<std::string, std::vector<std::string>>&
         sensorInterfacesResponse)
 {
     auto entityManagerService =
         sensorInterfacesResponse.find("xyz.openbmc_project.EntityManager");
     if (entityManagerService == sensorInterfacesResponse.end())
     {
         return nullptr;
     }

     // Find the fan configuration first (fans can have multiple configuration
     // interfaces).
     for (const auto& entry : entityManagerService->second)
     {
         if (entry == "xyz.openbmc_project.Configuration.AspeedFan" ||
             entry == "xyz.openbmc_project.Configuration.I2CFan" ||
             entry == "xyz.openbmc_project.Configuration.NuvotonFan")
         {
             return &entry;
         }
     }

     for (const auto& entry : entityManagerService->second)
     {
         if (boost::algorithm::starts_with(entry,
                                           "xyz.openbmc_project.Configuration."))
         {
             return &entry;
         }
     }

     return nullptr;
 }

 // Follow Association properties for Sensor back to the Board dbus object to
 // check for an EntityId and EntityInstance property.
 static inline void updateIpmiFromAssociation(const std::string& path,
                                              const SensorMap& sensorMap,
                                              uint8_t& entityId,
                                              uint8_t& entityInstance)
 {
     namespace fs = std::filesystem;

     auto sensorAssociationObject =
         sensorMap.find("xyz.openbmc_project.Association.Definitions");
     if (sensorAssociationObject == sensorMap.end())
     {
         if constexpr (debug)
         {
             std::fprintf(stderr, "path=%s, no association interface found\n",
                          path.c_str());
         }

         return;
     }

     auto associationObject =
         sensorAssociationObject->second.find("Associations");
     if (associationObject == sensorAssociationObject->second.end())
     {
         if constexpr (debug)
         {
             std::fprintf(stderr, "path=%s, no association records found\n",
                          path.c_str());
         }

         return;
     }

     std::vector<Association> associationValues =
         std::get<std::vector<Association>>(associationObject->second);

     // loop through the Associations looking for the right one:
     for (const auto& entry : associationValues)
     {
         // forward, reverse, endpoint
         const std::string& forward = std::get<0>(entry);
         const std::string& reverse = std::get<1>(entry);
         const std::string& endpoint = std::get<2>(entry);

         // We only currently concern ourselves with chassis+all_sensors.
         if (!(forward == "chassis" && reverse == "all_sensors"))
         {
             continue;
         }

         // the endpoint is the board entry provided by
         // Entity-Manager. so let's grab its properties if it has
         // the right interface.

         // just try grabbing the properties first.
         std::map<std::string, DbusVariant> ipmiProperties =
             getEntityManagerProperties(
                 endpoint.c_str(),
                 "xyz.openbmc_project.Inventory.Decorator.Ipmi");

         auto entityIdProp = ipmiProperties.find("EntityId");
         auto entityInstanceProp = ipmiProperties.find("EntityInstance");
         if (entityIdProp != ipmiProperties.end())
         {
             entityId =
                 static_cast<uint8_t>(std::get<uint64_t>(entityIdProp->second));
         }
         if (entityInstanceProp != ipmiProperties.end())
         {
             entityInstance = static_cast<uint8_t>(
                 std::get<uint64_t>(entityInstanceProp->second));
         }

         // Now check the entity-manager entry for this sensor to see
         // if it has its own value and use that instead.
         //
         // In theory, checking this first saves us from checking
         // both, except in most use-cases identified, there won't be
         // a per sensor override, so we need to always check both.
         std::string sensorNameFromPath = fs::path(path).filename();

         std::string sensorConfigPath = endpoint + "/" + sensorNameFromPath;

         // Download the interfaces for the sensor from
         // Entity-Manager to find the name of the configuration
         // interface.
         std::map<std::string, std::vector<std::string>>
             sensorInterfacesResponse =
                 getObjectInterfaces(sensorConfigPath.c_str());

         const std::string* configurationInterface =
             getSensorConfigurationInterface(sensorInterfacesResponse);

         // We didnt' find a configuration interface for this sensor, but we
         // followed the Association property to get here, so we're done
         // searching.
         if (!configurationInterface)
         {
             break;
         }

         // We found a configuration interface.
         std::map<std::string, DbusVariant> configurationProperties =
             getEntityManagerProperties(sensorConfigPath.c_str(),
                                        configurationInterface->c_str());

         entityIdProp = configurationProperties.find("EntityId");
         entityInstanceProp = configurationProperties.find("EntityInstance");
         if (entityIdProp != configurationProperties.end())
         {
             entityId =
                 static_cast<uint8_t>(std::get<uint64_t>(entityIdProp->second));
         }
         if (entityInstanceProp != configurationProperties.end())
         {
             entityInstance = static_cast<uint8_t>(
                 std::get<uint64_t>(entityInstanceProp->second));
         }

         // stop searching Association records.
         break;
     } // end for Association vectors.

     if constexpr (debug)
     {
         std::fprintf(stderr, "path=%s, entityId=%d, entityInstance=%d\n",
                      path.c_str(), entityId, entityInstance);
     }
 }

 } // namespace ipmi
	/*
	// Copyright (c) 2018 Intel Corporation
	//
	// Licensed under the Apache License, Version 2.0 (the "License");
	// you may not use this file except in compliance with the License.
	// You may obtain a copy of the License at
	//
	// http://www.apache.org/licenses/LICENSE-2.0
	//
	// Unless required by applicable law or agreed to in writing, software
	// distributed under the License is distributed on an "AS IS" BASIS,
	// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	// See the License for the specific language governing permissions and
	// limitations under the License.
	*/

	#include "commandutils.hpp"
	#include "types.hpp"

	#include <boost/algorithm/string.hpp>
	#include <boost/bimap.hpp>
	#include <boost/container/flat_map.hpp>
	#include <phosphor-logging/log.hpp>
	#include <sdbusplus/bus/match.hpp>

	#include <cstdio>
	#include <cstring>
	#include <exception>
	#include <filesystem>
	#include <map>
	#include <string>
	#include <string_view>
	#include <vector>

	#pragma once

	struct CmpStrVersion
	{
	bool operator()(std::string a, std::string b) const
	{
	return strverscmp(a.c_str(), b.c_str()) < 0;
	}
	};

	using SensorSubTree = boost::container::flat_map<
	std::string,
	boost::container::flat_map<std::string, std::vector<std::string>>,
	CmpStrVersion>;

	using SensorNumMap = boost::bimap<int, std::string>;

	static constexpr uint16_t maxSensorsPerLUN = 255;
	static constexpr uint16_t maxIPMISensors = (maxSensorsPerLUN * 3);
	static constexpr uint16_t lun1Sensor0 = 0x100;
	static constexpr uint16_t lun3Sensor0 = 0x300;
	static constexpr uint16_t invalidSensorNumber = 0xFFFF;
	static constexpr uint8_t reservedSensorNumber = 0xFF;

	namespace details
	{

	// Enable/disable the logging of stats instrumentation
	static constexpr bool enableInstrumentation = false;

	class IPMIStatsEntry
	{
	private:
	int numReadings = 0;
	int numMissings = 0;
	int numStreakRead = 0;
	int numStreakMiss = 0;
	double minValue = 0.0;
	double maxValue = 0.0;
	std::string sensorName;

	public:
	const std::string& getName(void) const
	{
	return sensorName;
	}

	void updateName(std::string_view name)
	{
	sensorName = name;
	}

	// Returns true if this is the first successful reading
	// This is so the caller can log the coefficients used
	bool updateReading(double reading, int raw)
	{
	if constexpr (!enableInstrumentation)
	{
	return false;
	}

	bool first = ((numReadings == 0) && (numMissings == 0));

	// Sensors can use "nan" to indicate unavailable reading
	if (!(std::isfinite(reading)))
	{
	// Only show this if beginning a new streak
	if (numStreakMiss == 0)
	{
	std::cerr << "IPMI sensor " << sensorName
	<< ": Missing reading, byte=" << raw
	<< ", Reading counts good=" << numReadings
	<< " miss=" << numMissings
	<< ", Prior good streak=" << numStreakRead << "\n";
	}

	numStreakRead = 0;
	++numMissings;
	++numStreakMiss;

	return first;
	}

	// Only show this if beginning a new streak and not the first time
	if ((numStreakRead == 0) && (numReadings != 0))
	{
	std::cerr << "IPMI sensor " << sensorName
	<< ": Recovered reading, value=" << reading
	<< " byte=" << raw
	<< ", Reading counts good=" << numReadings
	<< " miss=" << numMissings
	<< ", Prior miss streak=" << numStreakMiss << "\n";
	}

	// Initialize min/max if the first successful reading
	if (numReadings == 0)
	{
	std::cerr << "IPMI sensor " << sensorName
	<< ": First reading, value=" << reading << " byte=" << raw
	<< "\n";

	minValue = reading;
	maxValue = reading;
	}

	numStreakMiss = 0;
	++numReadings;
	++numStreakRead;

	// Only provide subsequent output if new min/max established
	if (reading < minValue)
	{
	std::cerr << "IPMI sensor " << sensorName
	<< ": Lowest reading, value=" << reading
	<< " byte=" << raw << "\n";

	minValue = reading;
	}

	if (reading > maxValue)
	{
	std::cerr << "IPMI sensor " << sensorName
	<< ": Highest reading, value=" << reading
	<< " byte=" << raw << "\n";

	maxValue = reading;
	}

	return first;
	}
	};

	class IPMIStatsTable
	{
	private:
	std::vector<IPMIStatsEntry> entries;

	private:
	void padEntries(size_t index)
	{
	char hexbuf[16];

	// Pad vector until entries[index] becomes a valid index
	while (entries.size() <= index)
	{
	// As name not known yet, use human-readable hex as name
	IPMIStatsEntry newEntry;
	sprintf(hexbuf, "0x%02zX", entries.size());
	newEntry.updateName(hexbuf);

	entries.push_back(std::move(newEntry));
	}
	}

	public:
	void wipeTable(void)
	{
	entries.clear();
	}

	const std::string& getName(size_t index)
	{
	padEntries(index);
	return entries[index].getName();
	}

	void updateName(size_t index, std::string_view name)
	{
	padEntries(index);
	entries[index].updateName(name);
	}

	bool updateReading(size_t index, double reading, int raw)
	{
	padEntries(index);
	return entries[index].updateReading(reading, raw);
	}
	};

	// This object is global singleton, used from a variety of places
	inline IPMIStatsTable sdrStatsTable;

	inline static uint16_t getSensorSubtree(std::shared_ptr<SensorSubTree>& subtree)
	{
	static std::shared_ptr<SensorSubTree> sensorTreePtr;
	static uint16_t sensorUpdatedIndex = 0;
	sd_bus* bus = NULL;
	int ret = sd_bus_default_system(&bus);
	if (ret < 0)
	{
	phosphor::logging::log<phosphor::logging::level::ERR>(
	"Failed to connect to system bus",
	phosphor::logging::entry("ERRNO=0x%X", -ret));
	sd_bus_unref(bus);
	return sensorUpdatedIndex;
	}
	sdbusplus::bus::bus dbus(bus);
	static sdbusplus::bus::match::match sensorAdded(
	dbus,
	"type='signal',member='InterfacesAdded',arg0path='/xyz/openbmc_project/"
	"sensors/'",
	[](sdbusplus::message::message& m) { sensorTreePtr.reset(); });

	static sdbusplus::bus::match::match sensorRemoved(
	dbus,
	"type='signal',member='InterfacesRemoved',arg0path='/xyz/"
	"openbmc_project/sensors/'",
	[](sdbusplus::message::message& m) { sensorTreePtr.reset(); });

	if (sensorTreePtr)
	{
	subtree = sensorTreePtr;
	return sensorUpdatedIndex;
	}

	sensorTreePtr = std::make_shared<SensorSubTree>();

	auto mapperCall =
	dbus.new_method_call("xyz.openbmc_project.ObjectMapper",
	"/xyz/openbmc_project/object_mapper",
	"xyz.openbmc_project.ObjectMapper", "GetSubTree");
	static constexpr const auto depth = 2;
	static constexpr std::array<const char*, 3> interfaces = {
	"xyz.openbmc_project.Sensor.Value",
	"xyz.openbmc_project.Sensor.Threshold.Warning",
	"xyz.openbmc_project.Sensor.Threshold.Critical"};
	mapperCall.append("/xyz/openbmc_project/sensors", depth, interfaces);

	try
	{
	auto mapperReply = dbus.call(mapperCall);
	mapperReply.read(*sensorTreePtr);
	}
	catch (sdbusplus::exception_t& e)
	{
	phosphor::logging::log<phosphor::logging::level::ERR>(e.what());
	return sensorUpdatedIndex;
	}
	subtree = sensorTreePtr;
	sensorUpdatedIndex++;
	// The SDR is being regenerated, wipe the old stats
	sdrStatsTable.wipeTable();
	return sensorUpdatedIndex;
	}

	inline static bool getSensorNumMap(std::shared_ptr<SensorNumMap>& sensorNumMap)
	{
	static std::shared_ptr<SensorNumMap> sensorNumMapPtr;
	bool sensorNumMapUpated = false;
	static uint16_t prevSensorUpdatedIndex = 0;
	std::shared_ptr<SensorSubTree> sensorTree;
	uint16_t curSensorUpdatedIndex = details::getSensorSubtree(sensorTree);
	if (!sensorTree)
	{
	return sensorNumMapUpated;
	}

	if ((curSensorUpdatedIndex == prevSensorUpdatedIndex) && sensorNumMapPtr)
	{
	sensorNumMap = sensorNumMapPtr;
	return sensorNumMapUpated;
	}
	prevSensorUpdatedIndex = curSensorUpdatedIndex;

	sensorNumMapPtr = std::make_shared<SensorNumMap>();

	uint16_t sensorNum = 0;
	uint16_t sensorIndex = 0;
	for (const auto& sensor : *sensorTree)
	{
	sensorNumMapPtr->insert(
	SensorNumMap::value_type(sensorNum, sensor.first));
	sensorIndex++;
	if (sensorIndex == maxSensorsPerLUN)
	{
	sensorIndex = lun1Sensor0;
	}
	else if (sensorIndex == (lun1Sensor0 \| maxSensorsPerLUN))
	{
	// Skip assigning LUN 0x2 any sensors
	sensorIndex = lun3Sensor0;
	}
	else if (sensorIndex == (lun3Sensor0 \| maxSensorsPerLUN))
	{
	// this is an error, too many IPMI sensors
	throw std::out_of_range("Maximum number of IPMI sensors exceeded.");
	}
	sensorNum = sensorIndex;
	}
	sensorNumMap = sensorNumMapPtr;
	sensorNumMapUpated = true;
	return sensorNumMapUpated;
	}
	} // namespace details

	inline static bool getSensorSubtree(SensorSubTree& subtree)
	{
	std::shared_ptr<SensorSubTree> sensorTree;
	details::getSensorSubtree(sensorTree);
	if (!sensorTree)
	{
	return false;
	}

	subtree = *sensorTree;
	return true;
	}

	struct CmpStr
	{
	bool operator()(const char* a, const char* b) const
	{
	return std::strcmp(a, b) < 0;
	}
	};

	enum class SensorTypeCodes : uint8_t
	{
	reserved = 0x0,
	temperature = 0x1,
	voltage = 0x2,
	current = 0x3,
	fan = 0x4,
	other = 0xB,
	};

	const static boost::container::flat_map<const char*, SensorTypeCodes, CmpStr>
	sensorTypes{{{"temperature", SensorTypeCodes::temperature},
	{"voltage", SensorTypeCodes::voltage},
	{"current", SensorTypeCodes::current},
	{"fan_tach", SensorTypeCodes::fan},
	{"fan_pwm", SensorTypeCodes::fan},
	{"power", SensorTypeCodes::other}}};

	inline static std::string getSensorTypeStringFromPath(const std::string& path)
	{
	// get sensor type string from path, path is defined as
	// /xyz/openbmc_project/sensors/<type>/label
	size_t typeEnd = path.rfind("/");
	if (typeEnd == std::string::npos)
	{
	return path;
	}
	size_t typeStart = path.rfind("/", typeEnd - 1);
	if (typeStart == std::string::npos)
	{
	return path;
	}
	// Start at the character after the '/'
	typeStart++;
	return path.substr(typeStart, typeEnd - typeStart);
	}

	inline static uint8_t getSensorTypeFromPath(const std::string& path)
	{
	uint8_t sensorType = 0;
	std::string type = getSensorTypeStringFromPath(path);
	auto findSensor = sensorTypes.find(type.c_str());
	if (findSensor != sensorTypes.end())
	{
	sensorType = static_cast<uint8_t>(findSensor->second);
	} // else default 0x0 RESERVED

	return sensorType;
	}

	inline static uint16_t getSensorNumberFromPath(const std::string& path)
	{
	std::shared_ptr<SensorNumMap> sensorNumMapPtr;
	details::getSensorNumMap(sensorNumMapPtr);
	if (!sensorNumMapPtr)
	{
	return invalidSensorNumber;
	}

	try
	{
	return sensorNumMapPtr->right.at(path);
	}
	catch (std::out_of_range& e)
	{
	phosphor::logging::log<phosphor::logging::level::ERR>(e.what());
	return invalidSensorNumber;
	}
	}

	inline static uint8_t getSensorEventTypeFromPath(const std::string& path)
	{
	// TODO: Add support for additional reading types as needed
	return 0x1; // reading type = threshold
	}

	inline static std::string getPathFromSensorNumber(uint16_t sensorNum)
	{
	std::shared_ptr<SensorNumMap> sensorNumMapPtr;
	details::getSensorNumMap(sensorNumMapPtr);
	if (!sensorNumMapPtr)
	{
	return std::string();
	}

	try
	{
	return sensorNumMapPtr->left.at(sensorNum);
	}
	catch (std::out_of_range& e)
	{
	phosphor::logging::log<phosphor::logging::level::ERR>(e.what());
	return std::string();
	}
	}

	namespace ipmi
	{

	static inline std::map<std::string, std::vector<std::string>>
	getObjectInterfaces(const char* path)
	{
	std::map<std::string, std::vector<std::string>> interfacesResponse;
	std::vector<std::string> interfaces;
	std::shared_ptr<sdbusplus::asio::connection> dbus = getSdBus();

	sdbusplus::message::message getObjectMessage =
	dbus->new_method_call("xyz.openbmc_project.ObjectMapper",
	"/xyz/openbmc_project/object_mapper",
	"xyz.openbmc_project.ObjectMapper", "GetObject");
	getObjectMessage.append(path, interfaces);

	try
	{
	sdbusplus::message::message response = dbus->call(getObjectMessage);
	response.read(interfacesResponse);
	}
	catch (const std::exception& e)
	{
	phosphor::logging::log<phosphor::logging::level::ERR>(
	"Failed to GetObject", phosphor::logging::entry("PATH=%s", path),
	phosphor::logging::entry("WHAT=%s", e.what()));
	}

	return interfacesResponse;
	}

	static inline std::map<std::string, DbusVariant>
	getEntityManagerProperties(const char* path, const char* interface)
	{
	std::map<std::string, DbusVariant> properties;
	std::shared_ptr<sdbusplus::asio::connection> dbus = getSdBus();

	sdbusplus::message::message getProperties =
	dbus->new_method_call("xyz.openbmc_project.EntityManager", path,
	"org.freedesktop.DBus.Properties", "GetAll");
	getProperties.append(interface);

	try
	{
	sdbusplus::message::message response = dbus->call(getProperties);
	response.read(properties);
	}
	catch (const std::exception& e)
	{
	phosphor::logging::log<phosphor::logging::level::ERR>(
	"Failed to GetAll", phosphor::logging::entry("PATH=%s", path),
	phosphor::logging::entry("INTF=%s", interface),
	phosphor::logging::entry("WHAT=%s", e.what()));
	}

	return properties;
	}

	static inline const std::string* getSensorConfigurationInterface(
	const std::map<std::string, std::vector<std::string>>&
	sensorInterfacesResponse)
	{
	auto entityManagerService =
	sensorInterfacesResponse.find("xyz.openbmc_project.EntityManager");
	if (entityManagerService == sensorInterfacesResponse.end())
	{
	return nullptr;
	}

	// Find the fan configuration first (fans can have multiple configuration
	// interfaces).
	for (const auto& entry : entityManagerService->second)
	{
	if (entry == "xyz.openbmc_project.Configuration.AspeedFan" \|\|
	entry == "xyz.openbmc_project.Configuration.I2CFan" \|\|
	entry == "xyz.openbmc_project.Configuration.NuvotonFan")
	{
	return &entry;
	}
	}

	for (const auto& entry : entityManagerService->second)
	{
	if (boost::algorithm::starts_with(entry,
	"xyz.openbmc_project.Configuration."))
	{
	return &entry;
	}
	}

	return nullptr;
	}

	// Follow Association properties for Sensor back to the Board dbus object to
	// check for an EntityId and EntityInstance property.
	static inline void updateIpmiFromAssociation(const std::string& path,
	const SensorMap& sensorMap,
	uint8_t& entityId,
	uint8_t& entityInstance)
	{
	namespace fs = std::filesystem;

	auto sensorAssociationObject =
	sensorMap.find("xyz.openbmc_project.Association.Definitions");
	if (sensorAssociationObject == sensorMap.end())
	{
	if constexpr (debug)
	{
	std::fprintf(stderr, "path=%s, no association interface found\n",
	path.c_str());
	}

	return;
	}

	auto associationObject =
	sensorAssociationObject->second.find("Associations");
	if (associationObject == sensorAssociationObject->second.end())
	{
	if constexpr (debug)
	{
	std::fprintf(stderr, "path=%s, no association records found\n",
	path.c_str());
	}

	return;
	}

	std::vector<Association> associationValues =
	std::get<std::vector<Association>>(associationObject->second);

	// loop through the Associations looking for the right one:
	for (const auto& entry : associationValues)
	{
	// forward, reverse, endpoint
	const std::string& forward = std::get<0>(entry);
	const std::string& reverse = std::get<1>(entry);
	const std::string& endpoint = std::get<2>(entry);

	// We only currently concern ourselves with chassis+all_sensors.
	if (!(forward == "chassis" && reverse == "all_sensors"))
	{
	continue;
	}

	// the endpoint is the board entry provided by
	// Entity-Manager. so let's grab its properties if it has
	// the right interface.

	// just try grabbing the properties first.
	std::map<std::string, DbusVariant> ipmiProperties =
	getEntityManagerProperties(
	endpoint.c_str(),
	"xyz.openbmc_project.Inventory.Decorator.Ipmi");

	auto entityIdProp = ipmiProperties.find("EntityId");
	auto entityInstanceProp = ipmiProperties.find("EntityInstance");
	if (entityIdProp != ipmiProperties.end())
	{
	entityId =
	static_cast<uint8_t>(std::get<uint64_t>(entityIdProp->second));
	}
	if (entityInstanceProp != ipmiProperties.end())
	{
	entityInstance = static_cast<uint8_t>(
	std::get<uint64_t>(entityInstanceProp->second));
	}

	// Now check the entity-manager entry for this sensor to see
	// if it has its own value and use that instead.
	//
	// In theory, checking this first saves us from checking
	// both, except in most use-cases identified, there won't be
	// a per sensor override, so we need to always check both.
	std::string sensorNameFromPath = fs::path(path).filename();

	std::string sensorConfigPath = endpoint + "/" + sensorNameFromPath;

	// Download the interfaces for the sensor from
	// Entity-Manager to find the name of the configuration
	// interface.
	std::map<std::string, std::vector<std::string>>
	sensorInterfacesResponse =
	getObjectInterfaces(sensorConfigPath.c_str());

	const std::string* configurationInterface =
	getSensorConfigurationInterface(sensorInterfacesResponse);

	// We didnt' find a configuration interface for this sensor, but we
	// followed the Association property to get here, so we're done
	// searching.
	if (!configurationInterface)
	{
	break;
	}

	// We found a configuration interface.
	std::map<std::string, DbusVariant> configurationProperties =
	getEntityManagerProperties(sensorConfigPath.c_str(),
	configurationInterface->c_str());

	entityIdProp = configurationProperties.find("EntityId");
	entityInstanceProp = configurationProperties.find("EntityInstance");
	if (entityIdProp != configurationProperties.end())
	{
	entityId =
	static_cast<uint8_t>(std::get<uint64_t>(entityIdProp->second));
	}
	if (entityInstanceProp != configurationProperties.end())
	{
	entityInstance = static_cast<uint8_t>(
	std::get<uint64_t>(entityInstanceProp->second));
	}

	// stop searching Association records.
	break;
	} // end for Association vectors.

	if constexpr (debug)
	{
	std::fprintf(stderr, "path=%s, entityId=%d, entityInstance=%d\n",
	path.c_str(), entityId, entityInstance);
	}
	}

	} // namespace ipmi