storagehandler.cpp - openbmc/phosphor-host-ipmid - Gitiles

 #include <algorithm>
 #include <arpa/inet.h>
 #include <chrono>
 #include <cstdio>
 #include <experimental/filesystem>
 #include <mapper.h>
 #include <string>
 #include <systemd/sd-bus.h>

 #include <phosphor-logging/log.hpp>
 #include <phosphor-logging/elog-errors.hpp>
 #include <sdbusplus/server.hpp>

 #include "fruread.hpp"
 #include "host-ipmid/ipmid-api.h"
 #include "read_fru_data.hpp"
 #include "selutility.hpp"
 #include "storageaddsel.h"
 #include "storagehandler.h"
 #include "utils.hpp"
 #include "xyz/openbmc_project/Common/error.hpp"
 #include "sensorhandler.h"


 void register_netfn_storage_functions() __attribute__((constructor));

 unsigned int   g_sel_time    = 0xFFFFFFFF;
 extern unsigned short g_sel_reserve;
 extern const ipmi::sensor::IdInfoMap sensors;
 extern const FruMap frus;

 namespace {
 constexpr auto TIME_INTERFACE = "xyz.openbmc_project.Time.EpochTime";
 constexpr auto HOST_TIME_PATH = "/xyz/openbmc_project/time/host";
 constexpr auto DBUS_PROPERTIES = "org.freedesktop.DBus.Properties";
 constexpr auto PROPERTY_ELAPSED= "Elapsed";

 const char* getTimeString(const uint64_t& usecSinceEpoch)
 {
     using namespace std::chrono;
     system_clock::time_point tp{microseconds(usecSinceEpoch)};
     auto t = system_clock::to_time_t(tp);
     return std::ctime(&t);
 }
 }

 namespace cache
 {
     /*
      * This cache contains the object paths of the logging entries sorted in the
      * order of the filename(numeric order). The cache is initialized by
      * invoking readLoggingObjectPaths with the cache as the parameter. The
      * cache is invoked in the execution of the Get SEL info and Delete SEL
      * entry command. The Get SEL Info command is typically invoked before the
      * Get SEL entry command, so the cache is utilized for responding to Get SEL
      * entry command. The cache is invalidated by clearing after Delete SEL
      * entry and Clear SEL command.
      */
     ipmi::sel::ObjectPaths paths;

 } // namespace objectPathsCache

 using InternalFailure =
         sdbusplus::xyz::openbmc_project::Common::Error::InternalFailure;
 using namespace phosphor::logging;
 using namespace ipmi::fru;

 /**
  * @enum Device access mode
  */
 enum class AccessMode
 {
     bytes, ///< Device is accessed by bytes
     words  ///< Device is accessed by words
 };


 ipmi_ret_t ipmi_storage_wildcard(ipmi_netfn_t netfn, ipmi_cmd_t cmd,
                               ipmi_request_t request, ipmi_response_t response,
                               ipmi_data_len_t data_len, ipmi_context_t context)
 {
     printf("Handling STORAGE WILDCARD Netfn:[0x%X], Cmd:[0x%X]\n",netfn, cmd);
     // Status code.
     ipmi_ret_t rc = IPMI_CC_INVALID;
     *data_len = 0;
     return rc;
 }

 ipmi_ret_t getSELInfo(ipmi_netfn_t netfn, ipmi_cmd_t cmd,
                       ipmi_request_t request, ipmi_response_t response,
                       ipmi_data_len_t data_len, ipmi_context_t context)
 {
     std::vector<uint8_t> outPayload(sizeof(ipmi::sel::GetSELInfoResponse));
     auto responseData = reinterpret_cast<ipmi::sel::GetSELInfoResponse*>
             (outPayload.data());

     responseData->selVersion = ipmi::sel::selVersion;
     // Last erase timestamp is not available from log manager.
     responseData->eraseTimeStamp = ipmi::sel::invalidTimeStamp;
     responseData->operationSupport = ipmi::sel::operationSupport;

     ipmi::sel::readLoggingObjectPaths(cache::paths);
     responseData->entries = 0;
     responseData->addTimeStamp = ipmi::sel::invalidTimeStamp;

     if (!cache::paths.empty())
     {
         responseData->entries = static_cast<uint16_t>(cache::paths.size());

         try
         {
             responseData->addTimeStamp = static_cast<uint32_t>(
                     (ipmi::sel::getEntryTimeStamp(cache::paths.back())
                     .count()));
         }
         catch (InternalFailure& e)
         {
         }
         catch (const std::runtime_error& e)
         {
             log<level::ERR>(e.what());
         }
     }

     memcpy(response, outPayload.data(), outPayload.size());
     *data_len = outPayload.size();

     return IPMI_CC_OK;
 }

 ipmi_ret_t getSELEntry(ipmi_netfn_t netfn, ipmi_cmd_t cmd,
                        ipmi_request_t request, ipmi_response_t response,
                        ipmi_data_len_t data_len, ipmi_context_t context)
 {
     auto requestData = reinterpret_cast<const ipmi::sel::GetSELEntryRequest*>
                    (request);

     if (requestData->reservationID != 0)
     {
         if (g_sel_reserve != requestData->reservationID)
         {
             *data_len = 0;
             return IPMI_CC_INVALID_RESERVATION_ID;
         }
     }

     if (cache::paths.empty())
     {
         *data_len = 0;
         return IPMI_CC_SENSOR_INVALID;
     }

     ipmi::sel::ObjectPaths::const_iterator iter;

     // Check for the requested SEL Entry.
     if (requestData->selRecordID == ipmi::sel::firstEntry)
     {
         iter = cache::paths.begin();
     }
     else if (requestData->selRecordID == ipmi::sel::lastEntry)
     {
         iter = cache::paths.end();
     }
     else
     {
         std::string objPath = std::string(ipmi::sel::logBasePath) + "/" +
                               std::to_string(requestData->selRecordID);

         iter = std::find(cache::paths.begin(), cache::paths.end(), objPath);
         if (iter == cache::paths.end())
         {
             *data_len = 0;
             return IPMI_CC_SENSOR_INVALID;
         }
     }

     ipmi::sel::GetSELEntryResponse record {};

     // Convert the log entry into SEL record.
     try
     {
         record = ipmi::sel::convertLogEntrytoSEL(*iter);
     }
     catch (InternalFailure& e)
     {
         *data_len = 0;
         return IPMI_CC_UNSPECIFIED_ERROR;
     }
     catch (const std::runtime_error& e)
     {
         log<level::ERR>(e.what());
         *data_len = 0;
         return IPMI_CC_UNSPECIFIED_ERROR;
     }


     // Identify the next SEL record ID
     if(iter != cache::paths.end())
     {
         ++iter;
         if (iter == cache::paths.end())
         {
             record.nextRecordID = ipmi::sel::lastEntry;
         }
         else
         {
             namespace fs = std::experimental::filesystem;
             fs::path path(*iter);
             record.nextRecordID = static_cast<uint16_t>
                      (std::stoul(std::string(path.filename().c_str())));
         }
     }
     else
     {
         record.nextRecordID = ipmi::sel::lastEntry;
     }

     if (requestData->readLength == ipmi::sel::entireRecord)
     {
         memcpy(response, &record, sizeof(record));
         *data_len = sizeof(record);
     }
     else
     {
         if (requestData->offset >= ipmi::sel::selRecordSize ||
             requestData->readLength > ipmi::sel::selRecordSize)
         {
             *data_len = 0;
             return IPMI_CC_INVALID_FIELD_REQUEST;
         }

         auto diff = ipmi::sel::selRecordSize - requestData->offset;
         auto readLength = std::min(diff,
                                    static_cast<int>(requestData->readLength));

         memcpy(response, &record.nextRecordID, sizeof(record.nextRecordID));
         memcpy(static_cast<uint8_t*>(response) + sizeof(record.nextRecordID),
                &record.recordID + requestData->offset, readLength);
         *data_len = sizeof(record.nextRecordID) + readLength;
     }

     return IPMI_CC_OK;
 }

 ipmi_ret_t deleteSELEntry(ipmi_netfn_t netfn, ipmi_cmd_t cmd,
                           ipmi_request_t request, ipmi_response_t response,
                           ipmi_data_len_t data_len, ipmi_context_t context)
 {
     namespace fs = std::experimental::filesystem;
     auto requestData = reinterpret_cast<const ipmi::sel::DeleteSELEntryRequest*>
             (request);

     if (g_sel_reserve != requestData->reservationID)
     {
         *data_len = 0;
         return IPMI_CC_INVALID_RESERVATION_ID;
     }

     ipmi::sel::readLoggingObjectPaths(cache::paths);

     if (cache::paths.empty())
     {
         *data_len = 0;
         return IPMI_CC_SENSOR_INVALID;
     }

     ipmi::sel::ObjectPaths::const_iterator iter;
     uint16_t delRecordID = 0;

     if (requestData->selRecordID == ipmi::sel::firstEntry)
     {
         iter = cache::paths.begin();
         fs::path path(*iter);
         delRecordID = static_cast<uint16_t>
                 (std::stoul(std::string(path.filename().c_str())));
     }
     else if (requestData->selRecordID == ipmi::sel::lastEntry)
     {
         iter = cache::paths.end();
         fs::path path(*iter);
         delRecordID = static_cast<uint16_t>
                 (std::stoul(std::string(path.filename().c_str())));
     }
     else
     {
         std::string objPath = std::string(ipmi::sel::logBasePath) + "/" +
                               std::to_string(requestData->selRecordID);

         iter = std::find(cache::paths.begin(), cache::paths.end(), objPath);
         if (iter == cache::paths.end())
         {
             *data_len = 0;
             return IPMI_CC_SENSOR_INVALID;
         }
         delRecordID = requestData->selRecordID;
     }

     sdbusplus::bus::bus bus{ipmid_get_sd_bus_connection()};
     std::string service;

     try
     {
         service = ipmi::getService(bus, ipmi::sel::logDeleteIntf, *iter);
     }
     catch (const std::runtime_error& e)
     {
         log<level::ERR>(e.what());
         *data_len = 0;
         return IPMI_CC_UNSPECIFIED_ERROR;
     }

     auto methodCall = bus.new_method_call(service.c_str(),
                                           (*iter).c_str(),
                                           ipmi::sel::logDeleteIntf,
                                           "Delete");
     auto reply = bus.call(methodCall);
     if (reply.is_method_error())
     {
         *data_len = 0;
         return IPMI_CC_UNSPECIFIED_ERROR;
     }

     // Invalidate the cache of dbus entry objects.
     cache::paths.clear();
     memcpy(response, &delRecordID, sizeof(delRecordID));
     *data_len = sizeof(delRecordID);

     return IPMI_CC_OK;
 }

 ipmi_ret_t clearSEL(ipmi_netfn_t netfn, ipmi_cmd_t cmd, ipmi_request_t request,
                     ipmi_response_t response, ipmi_data_len_t data_len,
                     ipmi_context_t context)
 {
     auto requestData = reinterpret_cast<const ipmi::sel::ClearSELRequest*>
             (request);

     if (g_sel_reserve != requestData->reservationID)
     {
         *data_len = 0;
         return IPMI_CC_INVALID_RESERVATION_ID;
     }

     if (requestData->charC != 'C' ||
         requestData->charL != 'L' ||
         requestData->charR != 'R')
     {
         *data_len = 0;
         return IPMI_CC_INVALID_FIELD_REQUEST;
     }

     uint8_t eraseProgress = ipmi::sel::eraseComplete;

     /*
      * Erasure status cannot be fetched from DBUS, so always return erasure
      * status as `erase completed`.
      */
     if (requestData->eraseOperation == ipmi::sel::getEraseStatus)
     {
         memcpy(response, &eraseProgress, sizeof(eraseProgress));
         *data_len = sizeof(eraseProgress);
         return IPMI_CC_OK;
     }

     sdbusplus::bus::bus bus{ipmid_get_sd_bus_connection()};
     auto depth = 0;

     auto mapperCall = bus.new_method_call(ipmi::sel::mapperBusName,
                                           ipmi::sel::mapperObjPath,
                                           ipmi::sel::mapperIntf,
                                           "GetSubTreePaths");
     mapperCall.append(ipmi::sel::logBasePath);
     mapperCall.append(depth);
     mapperCall.append(ipmi::sel::ObjectPaths({ipmi::sel::logEntryIntf}));

     auto reply = bus.call(mapperCall);
     if (reply.is_method_error())
     {
         memcpy(response, &eraseProgress, sizeof(eraseProgress));
         *data_len = sizeof(eraseProgress);
         return IPMI_CC_OK;
     }

     ipmi::sel::ObjectPaths objectPaths;
     reply.read(objectPaths);
     if (objectPaths.empty())
     {
         memcpy(response, &eraseProgress, sizeof(eraseProgress));
         *data_len = sizeof(eraseProgress);
         return IPMI_CC_OK;
     }

     std::string service;

     try
     {
         service = ipmi::getService(bus,
                                    ipmi::sel::logDeleteIntf,
                                    objectPaths.front());
     }
     catch (const std::runtime_error& e)
     {
         log<level::ERR>(e.what());
         *data_len = 0;
         return IPMI_CC_UNSPECIFIED_ERROR;
     }

     for (const auto& iter : objectPaths)
     {
         auto methodCall = bus.new_method_call(service.c_str(),
                                               iter.c_str(),
                                               ipmi::sel::logDeleteIntf,
                                               "Delete");

         auto reply = bus.call(methodCall);
         if (reply.is_method_error())
         {
             *data_len = 0;
             return IPMI_CC_UNSPECIFIED_ERROR;
         }
     }

     // Invalidate the cache of dbus entry objects.
     cache::paths.clear();
     memcpy(response, &eraseProgress, sizeof(eraseProgress));
     *data_len = sizeof(eraseProgress);
     return IPMI_CC_OK;
 }

 ipmi_ret_t ipmi_storage_get_sel_time(ipmi_netfn_t netfn, ipmi_cmd_t cmd,
                               ipmi_request_t request, ipmi_response_t response,
                               ipmi_data_len_t data_len, ipmi_context_t context)
 {
     using namespace std::chrono;
     uint64_t host_time_usec = 0;
     uint32_t resp = 0;

     printf("IPMI Handling GET-SEL-TIME\n");

     try
     {
         sdbusplus::bus::bus bus{ipmid_get_sd_bus_connection()};
         auto service = ipmi::getService(bus, TIME_INTERFACE, HOST_TIME_PATH);
         sdbusplus::message::variant<uint64_t> value;

         // Get host time
         auto method = bus.new_method_call(service.c_str(),
                                           HOST_TIME_PATH,
                                           DBUS_PROPERTIES,
                                           "Get");

         method.append(TIME_INTERFACE, PROPERTY_ELAPSED);
         auto reply = bus.call(method);
         if (reply.is_method_error())
         {
             log<level::ERR>("Error getting time",
                             entry("SERVICE=%s", service.c_str()),
                             entry("PATH=%s", HOST_TIME_PATH));
             return IPMI_CC_UNSPECIFIED_ERROR;
         }
         reply.read(value);
         host_time_usec = value.get<uint64_t>();
     }
     catch (InternalFailure& e)
     {
         log<level::ERR>(e.what());
         return IPMI_CC_UNSPECIFIED_ERROR;
     }
     catch (const std::runtime_error& e)
     {
         log<level::ERR>(e.what());
         return IPMI_CC_UNSPECIFIED_ERROR;
     }

     printf("Host time: %" PRIu64 ", %s",
            host_time_usec, getTimeString(host_time_usec));

     // Time is really long int but IPMI wants just uint32. This works okay until
     // the number of seconds since 1970 overflows uint32 size.. Still a whole
     // lot of time here to even think about that.
     resp = duration_cast<seconds>(microseconds(host_time_usec)).count();
     resp = htole32(resp);

     // From the IPMI Spec 2.0, response should be a 32-bit value
     *data_len = sizeof(resp);

     // Pack the actual response
     memcpy(response, &resp, *data_len);

     return IPMI_CC_OK;
 }

 ipmi_ret_t ipmi_storage_set_sel_time(ipmi_netfn_t netfn, ipmi_cmd_t cmd,
                               ipmi_request_t request, ipmi_response_t response,
                               ipmi_data_len_t data_len, ipmi_context_t context)
 {
     using namespace std::chrono;
     ipmi_ret_t rc = IPMI_CC_OK;
     uint32_t secs = *static_cast<uint32_t*>(request);
     *data_len = 0;

     printf("Handling Set-SEL-Time:[0x%X], Cmd:[0x%X], Data:[0x%X]\n",
            netfn, cmd, secs);

     secs = le32toh(secs);
     microseconds usec{seconds(secs)};

     printf("To Set host time: %" PRIu64 ", %s",
            usec.count(), getTimeString(usec.count()));

     try
     {
         sdbusplus::bus::bus bus{ipmid_get_sd_bus_connection()};
         auto service = ipmi::getService(bus, TIME_INTERFACE, HOST_TIME_PATH);
         sdbusplus::message::variant<uint64_t> value{usec.count()};

         // Set host time
         auto method = bus.new_method_call(service.c_str(),
                                           HOST_TIME_PATH,
                                           DBUS_PROPERTIES,
                                           "Set");

         method.append(TIME_INTERFACE, PROPERTY_ELAPSED, value);
         auto reply = bus.call(method);
         if (reply.is_method_error())
         {
             log<level::ERR>("Error setting time",
                             entry("SERVICE=%s", service.c_str()),
                             entry("PATH=%s", HOST_TIME_PATH));
             rc = IPMI_CC_UNSPECIFIED_ERROR;
         }
     }
     catch (InternalFailure& e)
     {
         log<level::ERR>(e.what());
         rc = IPMI_CC_UNSPECIFIED_ERROR;
     }
     catch (const std::runtime_error& e)
     {
         log<level::ERR>(e.what());
         rc = IPMI_CC_UNSPECIFIED_ERROR;
     }

     return rc;
 }

 ipmi_ret_t ipmi_storage_reserve_sel(ipmi_netfn_t netfn, ipmi_cmd_t cmd,
                               ipmi_request_t request, ipmi_response_t response,
                               ipmi_data_len_t data_len, ipmi_context_t context)
 {
     ipmi_ret_t rc = IPMI_CC_OK;

     // IPMI spec, Reservation ID, the value simply increases against each execution of reserve_sel command.
     if( ++g_sel_reserve == 0)
         g_sel_reserve = 1;

     printf("IPMI Handling RESERVE-SEL 0x%04x\n", g_sel_reserve);

     *data_len = sizeof(g_sel_reserve);

     // Pack the actual response
     memcpy(response, &g_sel_reserve, *data_len);

     return rc;
 }

 ipmi_ret_t ipmi_storage_add_sel(ipmi_netfn_t netfn, ipmi_cmd_t cmd,
                               ipmi_request_t request, ipmi_response_t response,
                               ipmi_data_len_t data_len, ipmi_context_t context)
 {

     ipmi_ret_t rc = IPMI_CC_OK;
     ipmi_add_sel_request_t *p = (ipmi_add_sel_request_t*) request;
     uint16_t recordid;

     recordid = ((uint16_t)p->eventdata[1] << 8) | p->eventdata[2];

     printf("IPMI Handling ADD-SEL for record 0x%04x\n", recordid);

     *data_len = sizeof(g_sel_reserve);

     // Pack the actual response
     memcpy(response, &p->eventdata[1], 2);

     // Hostboot sends SEL with OEM record type 0xDE to indicate that there is
     // a maintenance procedure associated with eSEL record.
     static constexpr auto procedureType = 0xDE;
     if (p->recordtype == procedureType)
     {
         // In the OEM record type 0xDE, byte 11 in the SEL record indicate the
         // procedure number.
         createProcedureLogEntry(p->sensortype);
     }
     else
     {
         send_esel(recordid);
     }

     return rc;
 }

 //Read FRU info area
 ipmi_ret_t ipmi_storage_get_fru_inv_area_info(
         ipmi_netfn_t netfn, ipmi_cmd_t cmd, ipmi_request_t request,
         ipmi_response_t response, ipmi_data_len_t data_len,
         ipmi_context_t context)
 {
     ipmi_ret_t rc = IPMI_CC_OK;
     const FruInvenAreaInfoRequest* reqptr =
         reinterpret_cast<const FruInvenAreaInfoRequest*>(request);
     try
     {
         const auto& fruArea = getFruAreaData(reqptr->fruID);
         auto size = static_cast<uint16_t>(fruArea.size());
         FruInvenAreaInfoResponse resp;
         resp.sizems = size >> 8;
         resp.sizels = size;
         resp.access = static_cast<uint8_t>(AccessMode::bytes);

         *data_len = sizeof(resp);

         // Pack the actual response
         memcpy(response, &resp, *data_len);
     }
     catch(const InternalFailure& e)
     {
         rc = IPMI_CC_UNSPECIFIED_ERROR;
         *data_len = 0;
         log<level::ERR>(e.what());
         report<InternalFailure>();
     }
     return rc;
 }

 //Read FRU data
 ipmi_ret_t ipmi_storage_read_fru_data(
         ipmi_netfn_t netfn, ipmi_cmd_t cmd, ipmi_request_t request,
         ipmi_response_t response, ipmi_data_len_t data_len,
         ipmi_context_t context)
 {
     ipmi_ret_t rc = IPMI_CC_OK;
     const ReadFruDataRequest* reqptr =
          reinterpret_cast<const ReadFruDataRequest*>(request);
     auto offset =
         static_cast<uint16_t>(reqptr->offsetMS << 8 | reqptr->offsetLS);
     try
     {
         const auto& fruArea = getFruAreaData(reqptr->fruID);
         auto size = fruArea.size();
         if ((offset + reqptr->count) > size)
         {
             log<level::ERR>("Invalid offset and count",
                             entry("OFFSET=%s", offset),
                             entry("COUNT=%s", reqptr->count),
                             entry("SIZE_OF_FRU_AREA=%s", size));
             return IPMI_CC_INVALID;
         }

         // Write the count of requested data.
         auto buff = static_cast<uint8_t *>(response);
         *buff = reqptr->count;
         buff++;

         std::copy((fruArea.begin() + offset),
                   (fruArea.begin() + offset + reqptr->count),
                   buff);

         *data_len = reqptr->count + 1; // additional one byte for count
     }
     catch (const InternalFailure& e)
     {
         rc = IPMI_CC_UNSPECIFIED_ERROR;
         *data_len = 0;
         log<level::ERR>(e.what());
         report<InternalFailure>();
     }
     return rc;
 }

 ipmi_ret_t ipmi_get_repository_info(ipmi_netfn_t netfn, ipmi_cmd_t cmd,
                              ipmi_request_t request, ipmi_response_t response,
                              ipmi_data_len_t data_len, ipmi_context_t context)
 {
     constexpr auto sdrVersion = 0x51;
     auto responseData =
         reinterpret_cast<GetRepositoryInfoResponse*>(response);

     memset(responseData, 0 , sizeof(GetRepositoryInfoResponse));

     responseData->sdrVersion = sdrVersion;

     uint16_t records = frus.size() + sensors.size();
     responseData->recordCountMs = records >> 8;
     responseData->recordCountLs = records;

     responseData->freeSpace[0] = 0xFF;
     responseData->freeSpace[1] = 0xFF;

     *data_len = sizeof(GetRepositoryInfoResponse);

     return IPMI_CC_OK;
 }

 void register_netfn_storage_functions()
 {
     // <Wildcard Command>
     printf("Registering NetFn:[0x%X], Cmd:[0x%X]\n",NETFUN_STORAGE, IPMI_CMD_WILDCARD);
     ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_WILDCARD, NULL, ipmi_storage_wildcard,
                            PRIVILEGE_USER);

     // <Get SEL Info>
     printf("Registering NetFn:[0x%X], Cmd:[0x%X]\n",NETFUN_STORAGE, IPMI_CMD_GET_SEL_INFO);
     ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_GET_SEL_INFO, NULL, getSELInfo,
                            PRIVILEGE_USER);

     // <Get SEL Time>
     printf("Registering NetFn:[0x%X], Cmd:[0x%X]\n",NETFUN_STORAGE, IPMI_CMD_GET_SEL_TIME);
     ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_GET_SEL_TIME, NULL, ipmi_storage_get_sel_time,
                            PRIVILEGE_USER);

     // <Set SEL Time>
     printf("Registering NetFn:[0x%X], Cmd:[0x%X]\n",NETFUN_STORAGE, IPMI_CMD_SET_SEL_TIME);
     ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_SET_SEL_TIME, NULL, ipmi_storage_set_sel_time,
                            PRIVILEGE_OPERATOR);

     // <Reserve SEL>
     printf("Registering NetFn:[0x%X], Cmd:[0x%X]\n",NETFUN_STORAGE, IPMI_CMD_RESERVE_SEL);
     ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_RESERVE_SEL, NULL, ipmi_storage_reserve_sel,
                            PRIVILEGE_USER);

     // <Get SEL Entry>
     printf("Registering NetFn:[0x%X], Cmd:[0x%X]\n",NETFUN_STORAGE, IPMI_CMD_GET_SEL_ENTRY);
     ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_GET_SEL_ENTRY, NULL, getSELEntry,
                            PRIVILEGE_USER);

     // <Delete SEL Entry>
     printf("Registering NetFn:[0x%X], Cmd:[0x%X]\n",NETFUN_STORAGE, IPMI_CMD_DELETE_SEL);
     ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_DELETE_SEL, NULL, deleteSELEntry,
                            PRIVILEGE_OPERATOR);

     // <Add SEL Entry>
     printf("Registering NetFn:[0x%X], Cmd:[0x%X]\n",NETFUN_STORAGE, IPMI_CMD_ADD_SEL);
     ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_ADD_SEL, NULL, ipmi_storage_add_sel,
                            PRIVILEGE_OPERATOR);
     // <Clear SEL>
     printf("Registering NetFn:[0x%X], Cmd:[0x%X]\n",NETFUN_STORAGE, IPMI_CMD_CLEAR_SEL);
     ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_CLEAR_SEL, NULL, clearSEL,
                            PRIVILEGE_OPERATOR);
     // <Get FRU Inventory Area Info>
     printf("Registering NetFn:[0x%X], Cmd:[0x%X]\n", NETFUN_STORAGE,
             IPMI_CMD_GET_FRU_INV_AREA_INFO);
     ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_GET_FRU_INV_AREA_INFO, NULL,
             ipmi_storage_get_fru_inv_area_info, PRIVILEGE_OPERATOR);

     // <Add READ FRU Data
     printf("Registering NetFn:[0x%X], Cmd:[0x%X]\n", NETFUN_STORAGE,
             IPMI_CMD_READ_FRU_DATA);
     ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_READ_FRU_DATA, NULL,
             ipmi_storage_read_fru_data, PRIVILEGE_OPERATOR);

     // <Get Repository Info>
     ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_GET_REPOSITORY_INFO,
                            nullptr, ipmi_get_repository_info,
                            PRIVILEGE_USER);

     // <Reserve SDR Repository>
     ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_RESERVE_SDR,
                            nullptr, ipmi_sen_reserve_sdr,
                            PRIVILEGE_USER);

     // <Get SDR>
     ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_GET_SDR,
                            nullptr, ipmi_sen_get_sdr,
                            PRIVILEGE_USER);

     ipmi::fru::registerCallbackHandler();
     return;
 }
	#include <algorithm>
	#include <arpa/inet.h>
	#include <chrono>
	#include <cstdio>
	#include <experimental/filesystem>
	#include <mapper.h>
	#include <string>
	#include <systemd/sd-bus.h>

	#include <phosphor-logging/log.hpp>
	#include <phosphor-logging/elog-errors.hpp>
	#include <sdbusplus/server.hpp>

	#include "fruread.hpp"
	#include "host-ipmid/ipmid-api.h"
	#include "read_fru_data.hpp"
	#include "selutility.hpp"
	#include "storageaddsel.h"
	#include "storagehandler.h"
	#include "utils.hpp"
	#include "xyz/openbmc_project/Common/error.hpp"
	#include "sensorhandler.h"


	void register_netfn_storage_functions() __attribute__((constructor));

	unsigned int g_sel_time = 0xFFFFFFFF;
	extern unsigned short g_sel_reserve;
	extern const ipmi::sensor::IdInfoMap sensors;
	extern const FruMap frus;

	namespace {
	constexpr auto TIME_INTERFACE = "xyz.openbmc_project.Time.EpochTime";
	constexpr auto HOST_TIME_PATH = "/xyz/openbmc_project/time/host";
	constexpr auto DBUS_PROPERTIES = "org.freedesktop.DBus.Properties";
	constexpr auto PROPERTY_ELAPSED= "Elapsed";

	const char* getTimeString(const uint64_t& usecSinceEpoch)
	{
	using namespace std::chrono;
	system_clock::time_point tp{microseconds(usecSinceEpoch)};
	auto t = system_clock::to_time_t(tp);
	return std::ctime(&t);
	}
	}

	namespace cache
	{
	/*
	* This cache contains the object paths of the logging entries sorted in the
	* order of the filename(numeric order). The cache is initialized by
	* invoking readLoggingObjectPaths with the cache as the parameter. The
	* cache is invoked in the execution of the Get SEL info and Delete SEL
	* entry command. The Get SEL Info command is typically invoked before the
	* Get SEL entry command, so the cache is utilized for responding to Get SEL
	* entry command. The cache is invalidated by clearing after Delete SEL
	* entry and Clear SEL command.
	*/
	ipmi::sel::ObjectPaths paths;

	} // namespace objectPathsCache

	using InternalFailure =
	sdbusplus::xyz::openbmc_project::Common::Error::InternalFailure;
	using namespace phosphor::logging;
	using namespace ipmi::fru;

	/**
	* @enum Device access mode
	*/
	enum class AccessMode
	{
	bytes, ///< Device is accessed by bytes
	words ///< Device is accessed by words
	};


	ipmi_ret_t ipmi_storage_wildcard(ipmi_netfn_t netfn, ipmi_cmd_t cmd,
	ipmi_request_t request, ipmi_response_t response,
	ipmi_data_len_t data_len, ipmi_context_t context)
	{
	printf("Handling STORAGE WILDCARD Netfn:[0x%X], Cmd:[0x%X]\n",netfn, cmd);
	// Status code.
	ipmi_ret_t rc = IPMI_CC_INVALID;
	*data_len = 0;
	return rc;
	}

	ipmi_ret_t getSELInfo(ipmi_netfn_t netfn, ipmi_cmd_t cmd,
	ipmi_request_t request, ipmi_response_t response,
	ipmi_data_len_t data_len, ipmi_context_t context)
	{
	std::vector<uint8_t> outPayload(sizeof(ipmi::sel::GetSELInfoResponse));
	auto responseData = reinterpret_cast<ipmi::sel::GetSELInfoResponse*>
	(outPayload.data());

	responseData->selVersion = ipmi::sel::selVersion;
	// Last erase timestamp is not available from log manager.
	responseData->eraseTimeStamp = ipmi::sel::invalidTimeStamp;
	responseData->operationSupport = ipmi::sel::operationSupport;

	ipmi::sel::readLoggingObjectPaths(cache::paths);
	responseData->entries = 0;
	responseData->addTimeStamp = ipmi::sel::invalidTimeStamp;

	if (!cache::paths.empty())
	{
	responseData->entries = static_cast<uint16_t>(cache::paths.size());

	try
	{
	responseData->addTimeStamp = static_cast<uint32_t>(
	(ipmi::sel::getEntryTimeStamp(cache::paths.back())
	.count()));
	}
	catch (InternalFailure& e)
	{
	}
	catch (const std::runtime_error& e)
	{
	log<level::ERR>(e.what());
	}
	}

	memcpy(response, outPayload.data(), outPayload.size());
	*data_len = outPayload.size();

	return IPMI_CC_OK;
	}

	ipmi_ret_t getSELEntry(ipmi_netfn_t netfn, ipmi_cmd_t cmd,
	ipmi_request_t request, ipmi_response_t response,
	ipmi_data_len_t data_len, ipmi_context_t context)
	{
	auto requestData = reinterpret_cast<const ipmi::sel::GetSELEntryRequest*>
	(request);

	if (requestData->reservationID != 0)
	{
	if (g_sel_reserve != requestData->reservationID)
	{
	*data_len = 0;
	return IPMI_CC_INVALID_RESERVATION_ID;
	}
	}

	if (cache::paths.empty())
	{
	*data_len = 0;
	return IPMI_CC_SENSOR_INVALID;
	}

	ipmi::sel::ObjectPaths::const_iterator iter;

	// Check for the requested SEL Entry.
	if (requestData->selRecordID == ipmi::sel::firstEntry)
	{
	iter = cache::paths.begin();
	}
	else if (requestData->selRecordID == ipmi::sel::lastEntry)
	{
	iter = cache::paths.end();
	}
	else
	{
	std::string objPath = std::string(ipmi::sel::logBasePath) + "/" +
	std::to_string(requestData->selRecordID);

	iter = std::find(cache::paths.begin(), cache::paths.end(), objPath);
	if (iter == cache::paths.end())
	{
	*data_len = 0;
	return IPMI_CC_SENSOR_INVALID;
	}
	}

	ipmi::sel::GetSELEntryResponse record {};

	// Convert the log entry into SEL record.
	try
	{
	record = ipmi::sel::convertLogEntrytoSEL(*iter);
	}
	catch (InternalFailure& e)
	{
	*data_len = 0;
	return IPMI_CC_UNSPECIFIED_ERROR;
	}
	catch (const std::runtime_error& e)
	{
	log<level::ERR>(e.what());
	*data_len = 0;
	return IPMI_CC_UNSPECIFIED_ERROR;
	}


	// Identify the next SEL record ID
	if(iter != cache::paths.end())
	{
	++iter;
	if (iter == cache::paths.end())
	{
	record.nextRecordID = ipmi::sel::lastEntry;
	}
	else
	{
	namespace fs = std::experimental::filesystem;
	fs::path path(*iter);
	record.nextRecordID = static_cast<uint16_t>
	(std::stoul(std::string(path.filename().c_str())));
	}
	}
	else
	{
	record.nextRecordID = ipmi::sel::lastEntry;
	}

	if (requestData->readLength == ipmi::sel::entireRecord)
	{
	memcpy(response, &record, sizeof(record));
	*data_len = sizeof(record);
	}
	else
	{
	if (requestData->offset >= ipmi::sel::selRecordSize \|\|
	requestData->readLength > ipmi::sel::selRecordSize)
	{
	*data_len = 0;
	return IPMI_CC_INVALID_FIELD_REQUEST;
	}

	auto diff = ipmi::sel::selRecordSize - requestData->offset;
	auto readLength = std::min(diff,
	static_cast<int>(requestData->readLength));

	memcpy(response, &record.nextRecordID, sizeof(record.nextRecordID));
	memcpy(static_cast<uint8_t*>(response) + sizeof(record.nextRecordID),
	&record.recordID + requestData->offset, readLength);
	*data_len = sizeof(record.nextRecordID) + readLength;
	}

	return IPMI_CC_OK;
	}

	ipmi_ret_t deleteSELEntry(ipmi_netfn_t netfn, ipmi_cmd_t cmd,
	ipmi_request_t request, ipmi_response_t response,
	ipmi_data_len_t data_len, ipmi_context_t context)
	{
	namespace fs = std::experimental::filesystem;
	auto requestData = reinterpret_cast<const ipmi::sel::DeleteSELEntryRequest*>
	(request);

	if (g_sel_reserve != requestData->reservationID)
	{
	*data_len = 0;
	return IPMI_CC_INVALID_RESERVATION_ID;
	}

	ipmi::sel::readLoggingObjectPaths(cache::paths);

	if (cache::paths.empty())
	{
	*data_len = 0;
	return IPMI_CC_SENSOR_INVALID;
	}

	ipmi::sel::ObjectPaths::const_iterator iter;
	uint16_t delRecordID = 0;

	if (requestData->selRecordID == ipmi::sel::firstEntry)
	{
	iter = cache::paths.begin();
	fs::path path(*iter);
	delRecordID = static_cast<uint16_t>
	(std::stoul(std::string(path.filename().c_str())));
	}
	else if (requestData->selRecordID == ipmi::sel::lastEntry)
	{
	iter = cache::paths.end();
	fs::path path(*iter);
	delRecordID = static_cast<uint16_t>
	(std::stoul(std::string(path.filename().c_str())));
	}
	else
	{
	std::string objPath = std::string(ipmi::sel::logBasePath) + "/" +
	std::to_string(requestData->selRecordID);

	iter = std::find(cache::paths.begin(), cache::paths.end(), objPath);
	if (iter == cache::paths.end())
	{
	*data_len = 0;
	return IPMI_CC_SENSOR_INVALID;
	}
	delRecordID = requestData->selRecordID;
	}

	sdbusplus::bus::bus bus{ipmid_get_sd_bus_connection()};
	std::string service;

	try
	{
	service = ipmi::getService(bus, ipmi::sel::logDeleteIntf, *iter);
	}
	catch (const std::runtime_error& e)
	{
	log<level::ERR>(e.what());
	*data_len = 0;
	return IPMI_CC_UNSPECIFIED_ERROR;
	}

	auto methodCall = bus.new_method_call(service.c_str(),
	(*iter).c_str(),
	ipmi::sel::logDeleteIntf,
	"Delete");
	auto reply = bus.call(methodCall);
	if (reply.is_method_error())
	{
	*data_len = 0;
	return IPMI_CC_UNSPECIFIED_ERROR;
	}

	// Invalidate the cache of dbus entry objects.
	cache::paths.clear();
	memcpy(response, &delRecordID, sizeof(delRecordID));
	*data_len = sizeof(delRecordID);

	return IPMI_CC_OK;
	}

	ipmi_ret_t clearSEL(ipmi_netfn_t netfn, ipmi_cmd_t cmd, ipmi_request_t request,
	ipmi_response_t response, ipmi_data_len_t data_len,
	ipmi_context_t context)
	{
	auto requestData = reinterpret_cast<const ipmi::sel::ClearSELRequest*>
	(request);

	if (g_sel_reserve != requestData->reservationID)
	{
	*data_len = 0;
	return IPMI_CC_INVALID_RESERVATION_ID;
	}

	if (requestData->charC != 'C' \|\|
	requestData->charL != 'L' \|\|
	requestData->charR != 'R')
	{
	*data_len = 0;
	return IPMI_CC_INVALID_FIELD_REQUEST;
	}

	uint8_t eraseProgress = ipmi::sel::eraseComplete;

	/*
	* Erasure status cannot be fetched from DBUS, so always return erasure
	* status as `erase completed`.
	*/
	if (requestData->eraseOperation == ipmi::sel::getEraseStatus)
	{
	memcpy(response, &eraseProgress, sizeof(eraseProgress));
	*data_len = sizeof(eraseProgress);
	return IPMI_CC_OK;
	}

	sdbusplus::bus::bus bus{ipmid_get_sd_bus_connection()};
	auto depth = 0;

	auto mapperCall = bus.new_method_call(ipmi::sel::mapperBusName,
	ipmi::sel::mapperObjPath,
	ipmi::sel::mapperIntf,
	"GetSubTreePaths");
	mapperCall.append(ipmi::sel::logBasePath);
	mapperCall.append(depth);
	mapperCall.append(ipmi::sel::ObjectPaths({ipmi::sel::logEntryIntf}));

	auto reply = bus.call(mapperCall);
	if (reply.is_method_error())
	{
	memcpy(response, &eraseProgress, sizeof(eraseProgress));
	*data_len = sizeof(eraseProgress);
	return IPMI_CC_OK;
	}

	ipmi::sel::ObjectPaths objectPaths;
	reply.read(objectPaths);
	if (objectPaths.empty())
	{
	memcpy(response, &eraseProgress, sizeof(eraseProgress));
	*data_len = sizeof(eraseProgress);
	return IPMI_CC_OK;
	}

	std::string service;

	try
	{
	service = ipmi::getService(bus,
	ipmi::sel::logDeleteIntf,
	objectPaths.front());
	}
	catch (const std::runtime_error& e)
	{
	log<level::ERR>(e.what());
	*data_len = 0;
	return IPMI_CC_UNSPECIFIED_ERROR;
	}

	for (const auto& iter : objectPaths)
	{
	auto methodCall = bus.new_method_call(service.c_str(),
	iter.c_str(),
	ipmi::sel::logDeleteIntf,
	"Delete");

	auto reply = bus.call(methodCall);
	if (reply.is_method_error())
	{
	*data_len = 0;
	return IPMI_CC_UNSPECIFIED_ERROR;
	}
	}

	// Invalidate the cache of dbus entry objects.
	cache::paths.clear();
	memcpy(response, &eraseProgress, sizeof(eraseProgress));
	*data_len = sizeof(eraseProgress);
	return IPMI_CC_OK;
	}

	ipmi_ret_t ipmi_storage_get_sel_time(ipmi_netfn_t netfn, ipmi_cmd_t cmd,
	ipmi_request_t request, ipmi_response_t response,
	ipmi_data_len_t data_len, ipmi_context_t context)
	{
	using namespace std::chrono;
	uint64_t host_time_usec = 0;
	uint32_t resp = 0;

	printf("IPMI Handling GET-SEL-TIME\n");

	try
	{
	sdbusplus::bus::bus bus{ipmid_get_sd_bus_connection()};
	auto service = ipmi::getService(bus, TIME_INTERFACE, HOST_TIME_PATH);
	sdbusplus::message::variant<uint64_t> value;

	// Get host time
	auto method = bus.new_method_call(service.c_str(),
	HOST_TIME_PATH,
	DBUS_PROPERTIES,
	"Get");

	method.append(TIME_INTERFACE, PROPERTY_ELAPSED);
	auto reply = bus.call(method);
	if (reply.is_method_error())
	{
	log<level::ERR>("Error getting time",
	entry("SERVICE=%s", service.c_str()),
	entry("PATH=%s", HOST_TIME_PATH));
	return IPMI_CC_UNSPECIFIED_ERROR;
	}
	reply.read(value);
	host_time_usec = value.get<uint64_t>();
	}
	catch (InternalFailure& e)
	{
	log<level::ERR>(e.what());
	return IPMI_CC_UNSPECIFIED_ERROR;
	}
	catch (const std::runtime_error& e)
	{
	log<level::ERR>(e.what());
	return IPMI_CC_UNSPECIFIED_ERROR;
	}

	printf("Host time: %" PRIu64 ", %s",
	host_time_usec, getTimeString(host_time_usec));

	// Time is really long int but IPMI wants just uint32. This works okay until
	// the number of seconds since 1970 overflows uint32 size.. Still a whole
	// lot of time here to even think about that.
	resp = duration_cast<seconds>(microseconds(host_time_usec)).count();
	resp = htole32(resp);

	// From the IPMI Spec 2.0, response should be a 32-bit value
	*data_len = sizeof(resp);

	// Pack the actual response
	memcpy(response, &resp, *data_len);

	return IPMI_CC_OK;
	}

	ipmi_ret_t ipmi_storage_set_sel_time(ipmi_netfn_t netfn, ipmi_cmd_t cmd,
	ipmi_request_t request, ipmi_response_t response,
	ipmi_data_len_t data_len, ipmi_context_t context)
	{
	using namespace std::chrono;
	ipmi_ret_t rc = IPMI_CC_OK;
	uint32_t secs = static_cast<uint32_t>(request);
	*data_len = 0;

	printf("Handling Set-SEL-Time:[0x%X], Cmd:[0x%X], Data:[0x%X]\n",
	netfn, cmd, secs);

	secs = le32toh(secs);
	microseconds usec{seconds(secs)};

	printf("To Set host time: %" PRIu64 ", %s",
	usec.count(), getTimeString(usec.count()));

	try
	{
	sdbusplus::bus::bus bus{ipmid_get_sd_bus_connection()};
	auto service = ipmi::getService(bus, TIME_INTERFACE, HOST_TIME_PATH);
	sdbusplus::message::variant<uint64_t> value{usec.count()};

	// Set host time
	auto method = bus.new_method_call(service.c_str(),
	HOST_TIME_PATH,
	DBUS_PROPERTIES,
	"Set");

	method.append(TIME_INTERFACE, PROPERTY_ELAPSED, value);
	auto reply = bus.call(method);
	if (reply.is_method_error())
	{
	log<level::ERR>("Error setting time",
	entry("SERVICE=%s", service.c_str()),
	entry("PATH=%s", HOST_TIME_PATH));
	rc = IPMI_CC_UNSPECIFIED_ERROR;
	}
	}
	catch (InternalFailure& e)
	{
	log<level::ERR>(e.what());
	rc = IPMI_CC_UNSPECIFIED_ERROR;
	}
	catch (const std::runtime_error& e)
	{
	log<level::ERR>(e.what());
	rc = IPMI_CC_UNSPECIFIED_ERROR;
	}

	return rc;
	}

	ipmi_ret_t ipmi_storage_reserve_sel(ipmi_netfn_t netfn, ipmi_cmd_t cmd,
	ipmi_request_t request, ipmi_response_t response,
	ipmi_data_len_t data_len, ipmi_context_t context)
	{
	ipmi_ret_t rc = IPMI_CC_OK;

	// IPMI spec, Reservation ID, the value simply increases against each execution of reserve_sel command.
	if( ++g_sel_reserve == 0)
	g_sel_reserve = 1;

	printf("IPMI Handling RESERVE-SEL 0x%04x\n", g_sel_reserve);

	*data_len = sizeof(g_sel_reserve);

	// Pack the actual response
	memcpy(response, &g_sel_reserve, *data_len);

	return rc;
	}

	ipmi_ret_t ipmi_storage_add_sel(ipmi_netfn_t netfn, ipmi_cmd_t cmd,
	ipmi_request_t request, ipmi_response_t response,
	ipmi_data_len_t data_len, ipmi_context_t context)
	{

	ipmi_ret_t rc = IPMI_CC_OK;
	ipmi_add_sel_request_t p = (ipmi_add_sel_request_t) request;
	uint16_t recordid;

	recordid = ((uint16_t)p->eventdata[1] << 8) \| p->eventdata[2];

	printf("IPMI Handling ADD-SEL for record 0x%04x\n", recordid);

	*data_len = sizeof(g_sel_reserve);

	// Pack the actual response
	memcpy(response, &p->eventdata[1], 2);

	// Hostboot sends SEL with OEM record type 0xDE to indicate that there is
	// a maintenance procedure associated with eSEL record.
	static constexpr auto procedureType = 0xDE;
	if (p->recordtype == procedureType)
	{
	// In the OEM record type 0xDE, byte 11 in the SEL record indicate the
	// procedure number.
	createProcedureLogEntry(p->sensortype);
	}
	else
	{
	send_esel(recordid);
	}

	return rc;
	}

	//Read FRU info area
	ipmi_ret_t ipmi_storage_get_fru_inv_area_info(
	ipmi_netfn_t netfn, ipmi_cmd_t cmd, ipmi_request_t request,
	ipmi_response_t response, ipmi_data_len_t data_len,
	ipmi_context_t context)
	{
	ipmi_ret_t rc = IPMI_CC_OK;
	const FruInvenAreaInfoRequest* reqptr =
	reinterpret_cast<const FruInvenAreaInfoRequest*>(request);
	try
	{
	const auto& fruArea = getFruAreaData(reqptr->fruID);
	auto size = static_cast<uint16_t>(fruArea.size());
	FruInvenAreaInfoResponse resp;
	resp.sizems = size >> 8;
	resp.sizels = size;
	resp.access = static_cast<uint8_t>(AccessMode::bytes);

	*data_len = sizeof(resp);

	// Pack the actual response
	memcpy(response, &resp, *data_len);
	}
	catch(const InternalFailure& e)
	{
	rc = IPMI_CC_UNSPECIFIED_ERROR;
	*data_len = 0;
	log<level::ERR>(e.what());
	report<InternalFailure>();
	}
	return rc;
	}

	//Read FRU data
	ipmi_ret_t ipmi_storage_read_fru_data(
	ipmi_netfn_t netfn, ipmi_cmd_t cmd, ipmi_request_t request,
	ipmi_response_t response, ipmi_data_len_t data_len,
	ipmi_context_t context)
	{
	ipmi_ret_t rc = IPMI_CC_OK;
	const ReadFruDataRequest* reqptr =
	reinterpret_cast<const ReadFruDataRequest*>(request);
	auto offset =
	static_cast<uint16_t>(reqptr->offsetMS << 8 \| reqptr->offsetLS);
	try
	{
	const auto& fruArea = getFruAreaData(reqptr->fruID);
	auto size = fruArea.size();
	if ((offset + reqptr->count) > size)
	{
	log<level::ERR>("Invalid offset and count",
	entry("OFFSET=%s", offset),
	entry("COUNT=%s", reqptr->count),
	entry("SIZE_OF_FRU_AREA=%s", size));
	return IPMI_CC_INVALID;
	}

	// Write the count of requested data.
	auto buff = static_cast<uint8_t *>(response);
	*buff = reqptr->count;
	buff++;

	std::copy((fruArea.begin() + offset),
	(fruArea.begin() + offset + reqptr->count),
	buff);

	*data_len = reqptr->count + 1; // additional one byte for count
	}
	catch (const InternalFailure& e)
	{
	rc = IPMI_CC_UNSPECIFIED_ERROR;
	*data_len = 0;
	log<level::ERR>(e.what());
	report<InternalFailure>();
	}
	return rc;
	}

	ipmi_ret_t ipmi_get_repository_info(ipmi_netfn_t netfn, ipmi_cmd_t cmd,
	ipmi_request_t request, ipmi_response_t response,
	ipmi_data_len_t data_len, ipmi_context_t context)
	{
	constexpr auto sdrVersion = 0x51;
	auto responseData =
	reinterpret_cast<GetRepositoryInfoResponse*>(response);

	memset(responseData, 0 , sizeof(GetRepositoryInfoResponse));

	responseData->sdrVersion = sdrVersion;

	uint16_t records = frus.size() + sensors.size();
	responseData->recordCountMs = records >> 8;
	responseData->recordCountLs = records;

	responseData->freeSpace[0] = 0xFF;
	responseData->freeSpace[1] = 0xFF;

	*data_len = sizeof(GetRepositoryInfoResponse);

	return IPMI_CC_OK;
	}

	void register_netfn_storage_functions()
	{
	// <Wildcard Command>
	printf("Registering NetFn:[0x%X], Cmd:[0x%X]\n",NETFUN_STORAGE, IPMI_CMD_WILDCARD);
	ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_WILDCARD, NULL, ipmi_storage_wildcard,
	PRIVILEGE_USER);

	// <Get SEL Info>
	printf("Registering NetFn:[0x%X], Cmd:[0x%X]\n",NETFUN_STORAGE, IPMI_CMD_GET_SEL_INFO);
	ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_GET_SEL_INFO, NULL, getSELInfo,
	PRIVILEGE_USER);

	// <Get SEL Time>
	printf("Registering NetFn:[0x%X], Cmd:[0x%X]\n",NETFUN_STORAGE, IPMI_CMD_GET_SEL_TIME);
	ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_GET_SEL_TIME, NULL, ipmi_storage_get_sel_time,
	PRIVILEGE_USER);

	// <Set SEL Time>
	printf("Registering NetFn:[0x%X], Cmd:[0x%X]\n",NETFUN_STORAGE, IPMI_CMD_SET_SEL_TIME);
	ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_SET_SEL_TIME, NULL, ipmi_storage_set_sel_time,
	PRIVILEGE_OPERATOR);

	// <Reserve SEL>
	printf("Registering NetFn:[0x%X], Cmd:[0x%X]\n",NETFUN_STORAGE, IPMI_CMD_RESERVE_SEL);
	ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_RESERVE_SEL, NULL, ipmi_storage_reserve_sel,
	PRIVILEGE_USER);

	// <Get SEL Entry>
	printf("Registering NetFn:[0x%X], Cmd:[0x%X]\n",NETFUN_STORAGE, IPMI_CMD_GET_SEL_ENTRY);
	ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_GET_SEL_ENTRY, NULL, getSELEntry,
	PRIVILEGE_USER);

	// <Delete SEL Entry>
	printf("Registering NetFn:[0x%X], Cmd:[0x%X]\n",NETFUN_STORAGE, IPMI_CMD_DELETE_SEL);
	ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_DELETE_SEL, NULL, deleteSELEntry,
	PRIVILEGE_OPERATOR);

	// <Add SEL Entry>
	printf("Registering NetFn:[0x%X], Cmd:[0x%X]\n",NETFUN_STORAGE, IPMI_CMD_ADD_SEL);
	ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_ADD_SEL, NULL, ipmi_storage_add_sel,
	PRIVILEGE_OPERATOR);
	// <Clear SEL>
	printf("Registering NetFn:[0x%X], Cmd:[0x%X]\n",NETFUN_STORAGE, IPMI_CMD_CLEAR_SEL);
	ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_CLEAR_SEL, NULL, clearSEL,
	PRIVILEGE_OPERATOR);
	// <Get FRU Inventory Area Info>
	printf("Registering NetFn:[0x%X], Cmd:[0x%X]\n", NETFUN_STORAGE,
	IPMI_CMD_GET_FRU_INV_AREA_INFO);
	ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_GET_FRU_INV_AREA_INFO, NULL,
	ipmi_storage_get_fru_inv_area_info, PRIVILEGE_OPERATOR);

	// <Add READ FRU Data
	printf("Registering NetFn:[0x%X], Cmd:[0x%X]\n", NETFUN_STORAGE,
	IPMI_CMD_READ_FRU_DATA);
	ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_READ_FRU_DATA, NULL,
	ipmi_storage_read_fru_data, PRIVILEGE_OPERATOR);

	// <Get Repository Info>
	ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_GET_REPOSITORY_INFO,
	nullptr, ipmi_get_repository_info,
	PRIVILEGE_USER);

	// <Reserve SDR Repository>
	ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_RESERVE_SDR,
	nullptr, ipmi_sen_reserve_sdr,
	PRIVILEGE_USER);

	// <Get SDR>
	ipmi_register_callback(NETFUN_STORAGE, IPMI_CMD_GET_SDR,
	nullptr, ipmi_sen_get_sdr,
	PRIVILEGE_USER);

	ipmi::fru::registerCallbackHandler();
	return;
	}