xref: /openbmc/pldm/libpldmresponder/fru.cpp (revision 5079ac4a)
1 #include "fru.hpp"
2 
3 #include "libpldm/entity.h"
4 #include "libpldm/utils.h"
5 
6 #include "common/utils.hpp"
7 
8 #include <systemd/sd-journal.h>
9 
10 #include <sdbusplus/bus.hpp>
11 
12 #include <iostream>
13 #include <set>
14 
15 namespace pldm
16 {
17 
18 namespace responder
19 {
20 
21 void FruImpl::buildFRUTable()
22 {
23 
24     if (isBuilt)
25     {
26         return;
27     }
28 
29     fru_parser::DBusLookupInfo dbusInfo;
30     // Read the all the inventory D-Bus objects
31     auto& bus = pldm::utils::DBusHandler::getBus();
32     dbus::ObjectValueTree objects;
33 
34     try
35     {
36         dbusInfo = parser.inventoryLookup();
37         auto method = bus.new_method_call(
38             std::get<0>(dbusInfo).c_str(), std::get<1>(dbusInfo).c_str(),
39             "org.freedesktop.DBus.ObjectManager", "GetManagedObjects");
40         auto reply = bus.call(method);
41         reply.read(objects);
42     }
43     catch (const std::exception& e)
44     {
45         std::cerr << "Look up of inventory objects failed and PLDM FRU table "
46                      "creation failed\n";
47         return;
48     }
49 
50     auto itemIntfsLookup = std::get<2>(dbusInfo);
51 
52     for (const auto& object : objects)
53     {
54         const auto& interfaces = object.second;
55 
56         for (const auto& interface : interfaces)
57         {
58             if (itemIntfsLookup.find(interface.first) != itemIntfsLookup.end())
59             {
60                 // An exception will be thrown by getRecordInfo, if the item
61                 // D-Bus interface name specified in FRU_Master.json does
62                 // not have corresponding config jsons
63                 try
64                 {
65                     pldm_entity entity{};
66                     entity.entity_type = parser.getEntityType(interface.first);
67                     pldm_entity_node* parent = nullptr;
68                     auto parentObj = pldm::utils::findParent(object.first.str);
69                     // To add a FRU to the entity association tree, we need to
70                     // determine if the FRU has a parent (D-Bus object). For eg
71                     // /system/backplane's parent is /system. /system has no
72                     // parent. Some D-Bus pathnames might just be namespaces
73                     // (not D-Bus objects), so we need to iterate upwards until
74                     // a parent is found, or we reach the root ("/").
75                     // Parents are always added first before children in the
76                     // entity association tree. We're relying on the fact that
77                     // the std::map containing object paths from the
78                     // GetManagedObjects call will have a sorted pathname list.
79                     do
80                     {
81                         auto iter = objToEntityNode.find(parentObj);
82                         if (iter != objToEntityNode.end())
83                         {
84                             parent = iter->second;
85                             break;
86                         }
87                         parentObj = pldm::utils::findParent(parentObj);
88                     } while (parentObj != "/");
89 
90                     auto node = pldm_entity_association_tree_add(
91                         entityTree, &entity, 0xFFFF, parent,
92                         PLDM_ENTITY_ASSOCIAION_PHYSICAL);
93                     objToEntityNode[object.first.str] = node;
94 
95                     auto recordInfos = parser.getRecordInfo(interface.first);
96                     populateRecords(interfaces, recordInfos, entity);
97 
98                     associatedEntityMap.emplace(object.first, entity);
99                     break;
100                 }
101                 catch (const std::exception& e)
102                 {
103                     std::cout << "Config JSONs missing for the item "
104                                  "interface type, interface = "
105                               << interface.first << "\n";
106                     break;
107                 }
108             }
109         }
110     }
111 
112     pldm_entity_association_pdr_add(entityTree, pdrRepo, false);
113     // save a copy of bmc's entity association tree
114     pldm_entity_association_tree_copy_root(entityTree, bmcEntityTree);
115 
116     if (table.size())
117     {
118         padBytes = utils::getNumPadBytes(table.size());
119         table.resize(table.size() + padBytes, 0);
120 
121         // Calculate the checksum
122         checksum = crc32(table.data(), table.size());
123     }
124     isBuilt = true;
125 }
126 std::string FruImpl::populatefwVersion()
127 {
128     static constexpr auto fwFunctionalObjPath =
129         "/xyz/openbmc_project/software/functional";
130     auto& bus = pldm::utils::DBusHandler::getBus();
131     std::string currentBmcVersion;
132     try
133     {
134         auto method =
135             bus.new_method_call(pldm::utils::mapperService, fwFunctionalObjPath,
136                                 pldm::utils::dbusProperties, "Get");
137         method.append("xyz.openbmc_project.Association", "endpoints");
138         std::variant<std::vector<std::string>> paths;
139         auto reply = bus.call(method);
140         reply.read(paths);
141         auto fwRunningVersion = std::get<std::vector<std::string>>(paths)[0];
142         constexpr auto versionIntf = "xyz.openbmc_project.Software.Version";
143         auto version = pldm::utils::DBusHandler().getDbusPropertyVariant(
144             fwRunningVersion.c_str(), "Version", versionIntf);
145         currentBmcVersion = std::get<std::string>(version);
146     }
147     catch (const std::exception& e)
148     {
149         std::cerr << "failed to make a d-bus call "
150                      "Asociation, ERROR= "
151                   << e.what() << "\n";
152         return {};
153     }
154     return currentBmcVersion;
155 }
156 void FruImpl::populateRecords(
157     const pldm::responder::dbus::InterfaceMap& interfaces,
158     const fru_parser::FruRecordInfos& recordInfos, const pldm_entity& entity)
159 {
160     // recordSetIdentifier for the FRU will be set when the first record gets
161     // added for the FRU
162     uint16_t recordSetIdentifier = 0;
163     auto numRecsCount = numRecs;
164     static uint32_t bmc_record_handle = 0;
165 
166     for (auto const& [recType, encType, fieldInfos] : recordInfos)
167     {
168         std::vector<uint8_t> tlvs;
169         uint8_t numFRUFields = 0;
170         for (auto const& [intf, prop, propType, fieldTypeNum] : fieldInfos)
171         {
172 
173             try
174             {
175                 pldm::responder::dbus::Value propValue;
176                 if (entity.entity_type == PLDM_ENTITY_SYSTEM_LOGICAL &&
177                     prop == "Version")
178                 {
179                     propValue = populatefwVersion();
180                 }
181                 else
182                 {
183                     propValue = interfaces.at(intf).at(prop);
184                 }
185                 if (propType == "bytearray")
186                 {
187                     auto byteArray = std::get<std::vector<uint8_t>>(propValue);
188                     if (!byteArray.size())
189                     {
190                         continue;
191                     }
192 
193                     numFRUFields++;
194                     tlvs.emplace_back(fieldTypeNum);
195                     tlvs.emplace_back(byteArray.size());
196                     std::move(std::begin(byteArray), std::end(byteArray),
197                               std::back_inserter(tlvs));
198                 }
199                 else if (propType == "string")
200                 {
201                     auto str = std::get<std::string>(propValue);
202                     if (!str.size())
203                     {
204                         continue;
205                     }
206 
207                     numFRUFields++;
208                     tlvs.emplace_back(fieldTypeNum);
209                     tlvs.emplace_back(str.size());
210                     std::move(std::begin(str), std::end(str),
211                               std::back_inserter(tlvs));
212                 }
213             }
214             catch (const std::out_of_range& e)
215             {
216                 continue;
217             }
218         }
219 
220         if (tlvs.size())
221         {
222             if (numRecs == numRecsCount)
223             {
224                 recordSetIdentifier = nextRSI();
225                 bmc_record_handle = nextRecordHandle();
226                 pldm_pdr_add_fru_record_set(
227                     pdrRepo, 0, recordSetIdentifier, entity.entity_type,
228                     entity.entity_instance_num, entity.entity_container_id,
229                     bmc_record_handle);
230             }
231             auto curSize = table.size();
232             table.resize(curSize + recHeaderSize + tlvs.size());
233             encode_fru_record(table.data(), table.size(), &curSize,
234                               recordSetIdentifier, recType, numFRUFields,
235                               encType, tlvs.data(), tlvs.size());
236             numRecs++;
237         }
238     }
239 }
240 
241 void FruImpl::getFRUTable(Response& response)
242 {
243     auto hdrSize = response.size();
244 
245     response.resize(hdrSize + table.size() + sizeof(checksum), 0);
246     std::copy(table.begin(), table.end(), response.begin() + hdrSize);
247 
248     // Copy the checksum to response data
249     auto iter = response.begin() + hdrSize + table.size();
250     std::copy_n(reinterpret_cast<const uint8_t*>(&checksum), sizeof(checksum),
251                 iter);
252 }
253 
254 int FruImpl::getFRURecordByOption(std::vector<uint8_t>& fruData,
255                                   uint16_t /* fruTableHandle */,
256                                   uint16_t recordSetIdentifer,
257                                   uint8_t recordType, uint8_t fieldType)
258 {
259     // FRU table is built lazily, build if not done.
260     buildFRUTable();
261 
262     /* 7 is sizeof(checksum,4) + padBytesMax(3)
263      * We can not know size of the record table got by options in advance, but
264      * it must be less than the source table. So it's safe to use sizeof the
265      * source table + 7 as the buffer length
266      */
267     size_t recordTableSize = table.size() - padBytes + 7;
268     fruData.resize(recordTableSize, 0);
269 
270     get_fru_record_by_option(table.data(), table.size() - padBytes,
271                              fruData.data(), &recordTableSize,
272                              recordSetIdentifer, recordType, fieldType);
273 
274     if (recordTableSize == 0)
275     {
276         return PLDM_FRU_DATA_STRUCTURE_TABLE_UNAVAILABLE;
277     }
278 
279     auto pads = utils::getNumPadBytes(recordTableSize);
280     auto sum = crc32(fruData.data(), recordTableSize + pads);
281 
282     auto iter = fruData.begin() + recordTableSize + pads;
283     std::copy_n(reinterpret_cast<const uint8_t*>(&checksum), sizeof(checksum),
284                 iter);
285     fruData.resize(recordTableSize + pads + sizeof(sum));
286 
287     return PLDM_SUCCESS;
288 }
289 
290 namespace fru
291 {
292 
293 Response Handler::getFRURecordTableMetadata(const pldm_msg* request,
294                                             size_t /*payloadLength*/)
295 {
296     // FRU table is built lazily, build if not done.
297     buildFRUTable();
298 
299     constexpr uint8_t major = 0x01;
300     constexpr uint8_t minor = 0x00;
301     constexpr uint32_t maxSize = 0xFFFFFFFF;
302 
303     Response response(sizeof(pldm_msg_hdr) +
304                           PLDM_GET_FRU_RECORD_TABLE_METADATA_RESP_BYTES,
305                       0);
306     auto responsePtr = reinterpret_cast<pldm_msg*>(response.data());
307 
308     auto rc = encode_get_fru_record_table_metadata_resp(
309         request->hdr.instance_id, PLDM_SUCCESS, major, minor, maxSize,
310         impl.size(), impl.numRSI(), impl.numRecords(), impl.checkSum(),
311         responsePtr);
312     if (rc != PLDM_SUCCESS)
313     {
314         return ccOnlyResponse(request, rc);
315     }
316 
317     return response;
318 }
319 
320 Response Handler::getFRURecordTable(const pldm_msg* request,
321                                     size_t payloadLength)
322 {
323     // FRU table is built lazily, build if not done.
324     buildFRUTable();
325 
326     if (payloadLength != PLDM_GET_FRU_RECORD_TABLE_REQ_BYTES)
327     {
328         return ccOnlyResponse(request, PLDM_ERROR_INVALID_LENGTH);
329     }
330 
331     Response response(
332         sizeof(pldm_msg_hdr) + PLDM_GET_FRU_RECORD_TABLE_MIN_RESP_BYTES, 0);
333     auto responsePtr = reinterpret_cast<pldm_msg*>(response.data());
334 
335     auto rc =
336         encode_get_fru_record_table_resp(request->hdr.instance_id, PLDM_SUCCESS,
337                                          0, PLDM_START_AND_END, responsePtr);
338     if (rc != PLDM_SUCCESS)
339     {
340         return ccOnlyResponse(request, rc);
341     }
342 
343     impl.getFRUTable(response);
344 
345     return response;
346 }
347 
348 Response Handler::getFRURecordByOption(const pldm_msg* request,
349                                        size_t payloadLength)
350 {
351     if (payloadLength != sizeof(pldm_get_fru_record_by_option_req))
352     {
353         return ccOnlyResponse(request, PLDM_ERROR_INVALID_LENGTH);
354     }
355 
356     uint32_t retDataTransferHandle{};
357     uint16_t retFruTableHandle{};
358     uint16_t retRecordSetIdentifier{};
359     uint8_t retRecordType{};
360     uint8_t retFieldType{};
361     uint8_t retTransferOpFlag{};
362 
363     auto rc = decode_get_fru_record_by_option_req(
364         request, payloadLength, &retDataTransferHandle, &retFruTableHandle,
365         &retRecordSetIdentifier, &retRecordType, &retFieldType,
366         &retTransferOpFlag);
367 
368     if (rc != PLDM_SUCCESS)
369     {
370         return ccOnlyResponse(request, rc);
371     }
372 
373     std::vector<uint8_t> fruData;
374     rc = impl.getFRURecordByOption(fruData, retFruTableHandle,
375                                    retRecordSetIdentifier, retRecordType,
376                                    retFieldType);
377     if (rc != PLDM_SUCCESS)
378     {
379         return ccOnlyResponse(request, rc);
380     }
381 
382     auto respPayloadLength =
383         PLDM_GET_FRU_RECORD_BY_OPTION_MIN_RESP_BYTES + fruData.size();
384     Response response(sizeof(pldm_msg_hdr) + respPayloadLength, 0);
385     auto responsePtr = reinterpret_cast<pldm_msg*>(response.data());
386 
387     rc = encode_get_fru_record_by_option_resp(
388         request->hdr.instance_id, PLDM_SUCCESS, 0, PLDM_START_AND_END,
389         fruData.data(), fruData.size(), responsePtr, respPayloadLength);
390 
391     if (rc != PLDM_SUCCESS)
392     {
393         return ccOnlyResponse(request, rc);
394     }
395 
396     return response;
397 }
398 
399 } // namespace fru
400 
401 } // namespace responder
402 
403 } // namespace pldm
404