blob: f2a6354154d646b34c2deb2b511275260c47f4c9 [file] [log] [blame]
AppaRao Puli071f3f22018-05-24 16:45:30 +05301/*
2// Copyright (c) 2018 Intel Corporation
3//
4// Licensed under the Apache License, Version 2.0 (the "License");
5// you may not use this file except in compliance with the License.
6// You may obtain a copy of the License at
7//
8// http://www.apache.org/licenses/LICENSE-2.0
9//
10// Unless required by applicable law or agreed to in writing, software
11// distributed under the License is distributed on an "AS IS" BASIS,
12// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13// See the License for the specific language governing permissions and
14// limitations under the License.
15*/
16
17#include "channel_mgmt.hpp"
18
19#include "apphandler.hpp"
20
21#include <sys/stat.h>
22#include <unistd.h>
23
24#include <boost/interprocess/sync/scoped_lock.hpp>
25#include <cerrno>
AppaRao Puli9613ed72018-09-01 23:46:44 +053026#include <exception>
AppaRao Puli071f3f22018-05-24 16:45:30 +053027#include <experimental/filesystem>
28#include <fstream>
29#include <phosphor-logging/log.hpp>
AppaRao Puli9613ed72018-09-01 23:46:44 +053030#include <sdbusplus/bus/match.hpp>
31#include <sdbusplus/server/object.hpp>
AppaRao Puli071f3f22018-05-24 16:45:30 +053032#include <unordered_map>
33
34namespace ipmi
35{
36
37using namespace phosphor::logging;
38
39static constexpr const char* channelAccessDefaultFilename =
40 "/usr/share/ipmi-providers/channel_access.json";
41static constexpr const char* channelConfigDefaultFilename =
42 "/usr/share/ipmi-providers/channel_config.json";
43static constexpr const char* channelNvDataFilename =
44 "/var/lib/ipmi/channel_access_nv.json";
45static constexpr const char* channelVolatileDataFilename =
46 "/run/ipmi/channel_access_volatile.json";
47
AppaRao Puli9613ed72018-09-01 23:46:44 +053048// TODO: Get the service name dynamically..
49static constexpr const char* networkIntfServiceName =
50 "xyz.openbmc_project.Network";
51static constexpr const char* networkIntfObjectBasePath =
52 "/xyz/openbmc_project/network";
53static constexpr const char* networkChConfigIntfName =
54 "xyz.openbmc_project.Channel.ChannelAccess";
55static constexpr const char* privilegePropertyString = "MaxPrivilege";
56static constexpr const char* dBusPropertiesInterface =
57 "org.freedesktop.DBus.Properties";
58static constexpr const char* propertiesChangedSignal = "PropertiesChanged";
59
AppaRao Puli071f3f22018-05-24 16:45:30 +053060// STRING DEFINES: Should sync with key's in JSON
61static constexpr const char* nameString = "name";
62static constexpr const char* isValidString = "is_valid";
63static constexpr const char* activeSessionsString = "active_sessions";
Vernon Mauery58317122018-11-28 11:02:43 -080064static constexpr const char* maxTransferSizeString = "max_transfer_size";
AppaRao Puli071f3f22018-05-24 16:45:30 +053065static constexpr const char* channelInfoString = "channel_info";
66static constexpr const char* mediumTypeString = "medium_type";
67static constexpr const char* protocolTypeString = "protocol_type";
68static constexpr const char* sessionSupportedString = "session_supported";
69static constexpr const char* isIpmiString = "is_ipmi";
70static constexpr const char* authTypeSupportedString = "auth_type_supported";
71static constexpr const char* accessModeString = "access_mode";
72static constexpr const char* userAuthDisabledString = "user_auth_disabled";
73static constexpr const char* perMsgAuthDisabledString = "per_msg_auth_disabled";
74static constexpr const char* alertingDisabledString = "alerting_disabled";
75static constexpr const char* privLimitString = "priv_limit";
76static constexpr const char* authTypeEnabledString = "auth_type_enabled";
77
78// Default values
79static constexpr const char* defaultChannelName = "RESERVED";
80static constexpr const uint8_t defaultMediumType =
81 static_cast<uint8_t>(EChannelMediumType::reserved);
82static constexpr const uint8_t defaultProtocolType =
83 static_cast<uint8_t>(EChannelProtocolType::reserved);
84static constexpr const uint8_t defaultSessionSupported =
85 static_cast<uint8_t>(EChannelSessSupported::none);
86static constexpr const uint8_t defaultAuthType =
87 static_cast<uint8_t>(EAuthType::none);
88static constexpr const bool defaultIsIpmiState = false;
Vernon Mauery58317122018-11-28 11:02:43 -080089static constexpr size_t smallChannelSize = 64;
AppaRao Puli071f3f22018-05-24 16:45:30 +053090
Lei YU4b0ddb62019-01-25 16:43:50 +080091std::unique_ptr<sdbusplus::bus::match_t> chPropertiesSignal
92 __attribute__((init_priority(101)));
AppaRao Puli9613ed72018-09-01 23:46:44 +053093
AppaRao Puli071f3f22018-05-24 16:45:30 +053094// String mappings use in JSON config file
95static std::unordered_map<std::string, EChannelMediumType> mediumTypeMap = {
96 {"reserved", EChannelMediumType::reserved},
97 {"ipmb", EChannelMediumType::ipmb},
98 {"icmb-v1.0", EChannelMediumType::icmbV10},
99 {"icmb-v0.9", EChannelMediumType::icmbV09},
100 {"lan-802.3", EChannelMediumType::lan8032},
101 {"serial", EChannelMediumType::serial},
102 {"other-lan", EChannelMediumType::otherLan},
103 {"pci-smbus", EChannelMediumType::pciSmbus},
104 {"smbus-v1.0", EChannelMediumType::smbusV11},
105 {"smbus-v2.0", EChannelMediumType::smbusV20},
106 {"usb-1x", EChannelMediumType::usbV1x},
107 {"usb-2x", EChannelMediumType::usbV2x},
108 {"system-interface", EChannelMediumType::systemInterface},
109 {"oem", EChannelMediumType::oem},
110 {"unknown", EChannelMediumType::unknown}};
111
ssekarf4b2b092018-07-25 18:49:08 +0530112static std::unordered_map<EInterfaceIndex, std::string> interfaceMap = {
Richard Marian Thomaiyar43cb1282018-12-08 17:22:53 +0530113 {interfaceKCS, "SMS"},
Richard Marian Thomaiyar73906b92019-01-04 23:48:02 +0530114 {interfaceLAN1, "eth0"},
ssekarf4b2b092018-07-25 18:49:08 +0530115 {interfaceUnknown, "unknown"}};
116
AppaRao Puli071f3f22018-05-24 16:45:30 +0530117static std::unordered_map<std::string, EChannelProtocolType> protocolTypeMap = {
118 {"na", EChannelProtocolType::na},
119 {"ipmb-1.0", EChannelProtocolType::ipmbV10},
120 {"icmb-2.0", EChannelProtocolType::icmbV11},
121 {"reserved", EChannelProtocolType::reserved},
122 {"ipmi-smbus", EChannelProtocolType::ipmiSmbus},
123 {"kcs", EChannelProtocolType::kcs},
124 {"smic", EChannelProtocolType::smic},
125 {"bt-10", EChannelProtocolType::bt10},
126 {"bt-15", EChannelProtocolType::bt15},
127 {"tmode", EChannelProtocolType::tMode},
128 {"oem", EChannelProtocolType::oem}};
129
130static std::array<std::string, 4> accessModeList = {
131 "disabled", "pre-boot", "always_available", "shared"};
132
133static std::array<std::string, 4> sessionSupportList = {
134 "session-less", "single-session", "multi-session", "session-based"};
135
136static std::array<std::string, PRIVILEGE_OEM + 1> privList = {
137 "priv-reserved", "priv-callback", "priv-user",
138 "priv-operator", "priv-admin", "priv-oem"};
139
Richard Marian Thomaiyar55768e32019-03-02 22:54:37 +0530140std::string ChannelConfig::getChannelName(const uint8_t chNum)
Johnathan Mantey74a21022018-12-13 13:17:56 -0800141{
142 if (!isValidChannel(chNum))
143 {
144 log<level::ERR>("Invalid channel number.",
145 entry("ChannelID:%d", chNum));
146 throw std::invalid_argument("Invalid channel number");
147 }
148
149 return channelData[chNum].chName;
150}
151
152int ChannelConfig::convertToChannelNumberFromChannelName(
153 const std::string& chName)
154{
155 for (const auto& it : channelData)
156 {
157 if (it.chName == chName)
158 {
159 return it.chID;
160 }
161 }
162 log<level::ERR>("Invalid channel name.",
163 entry("Channel:%s", chName.c_str()));
164 throw std::invalid_argument("Invalid channel name");
165
166 return -1;
167}
168
169std::string ChannelConfig::getChannelNameFromPath(const std::string& path)
AppaRao Puli9613ed72018-09-01 23:46:44 +0530170{
171 std::size_t pos = path.find(networkIntfObjectBasePath);
172 if (pos == std::string::npos)
173 {
174 log<level::ERR>("Invalid interface path.",
175 entry("PATH:%s", path.c_str()));
176 throw std::invalid_argument("Invalid interface path");
177 }
Johnathan Mantey74a21022018-12-13 13:17:56 -0800178 std::string chName =
AppaRao Puli9613ed72018-09-01 23:46:44 +0530179 path.substr(pos + strlen(networkIntfObjectBasePath) + 1);
Johnathan Mantey74a21022018-12-13 13:17:56 -0800180 return chName;
AppaRao Puli9613ed72018-09-01 23:46:44 +0530181}
182
Johnathan Manteye5c4f1d2018-12-10 16:24:26 -0800183void ChannelConfig::processChAccessPropChange(
184 const std::string& path, const DbusChObjProperties& chProperties)
AppaRao Puli9613ed72018-09-01 23:46:44 +0530185{
186 // Get interface name from path. ex: '/xyz/openbmc_project/network/eth0'
Johnathan Mantey74a21022018-12-13 13:17:56 -0800187 std::string chName;
AppaRao Puli9613ed72018-09-01 23:46:44 +0530188 try
189 {
Johnathan Mantey74a21022018-12-13 13:17:56 -0800190 chName = getChannelNameFromPath(path);
AppaRao Puli9613ed72018-09-01 23:46:44 +0530191 }
192 catch (const std::invalid_argument& e)
193 {
194 log<level::ERR>("Exception: ", entry("MSG: %s", e.what()));
195 return;
196 }
197
198 // Get the MaxPrivilege property value from the signal
199 std::string intfPrivStr;
200 std::string propName;
201 for (const auto& prop : chProperties)
202 {
203 if (prop.first == privilegePropertyString)
204 {
205 propName = privilegePropertyString;
Vernon Maueryf442e112019-04-09 11:44:36 -0700206 intfPrivStr = std::get<std::string>(prop.second);
AppaRao Puli9613ed72018-09-01 23:46:44 +0530207 break;
208 }
209 }
210
211 if (propName != privilegePropertyString)
212 {
213 log<level::ERR>("Unknown signal caught.");
214 return;
215 }
216
217 if (intfPrivStr.empty())
218 {
219 log<level::ERR>("Invalid privilege string.",
Johnathan Mantey74a21022018-12-13 13:17:56 -0800220 entry("INTF:%s", chName.c_str()));
AppaRao Puli9613ed72018-09-01 23:46:44 +0530221 return;
222 }
223
224 uint8_t intfPriv = 0;
Johnathan Mantey74a21022018-12-13 13:17:56 -0800225 int chNum;
AppaRao Puli9613ed72018-09-01 23:46:44 +0530226 try
227 {
Johnathan Manteye5c4f1d2018-12-10 16:24:26 -0800228 intfPriv = static_cast<uint8_t>(convertToPrivLimitIndex(intfPrivStr));
Johnathan Mantey74a21022018-12-13 13:17:56 -0800229 chNum = convertToChannelNumberFromChannelName(chName);
AppaRao Puli9613ed72018-09-01 23:46:44 +0530230 }
231 catch (const std::invalid_argument& e)
232 {
233 log<level::ERR>("Exception: ", entry("MSG: %s", e.what()));
234 return;
235 }
236
237 boost::interprocess::scoped_lock<boost::interprocess::named_recursive_mutex>
Johnathan Manteye5c4f1d2018-12-10 16:24:26 -0800238 channelLock{*channelMutex};
AppaRao Puli9613ed72018-09-01 23:46:44 +0530239 // skip updating the values, if this property change originated from IPMI.
Johnathan Manteye5c4f1d2018-12-10 16:24:26 -0800240 if (signalFlag & (1 << chNum))
AppaRao Puli9613ed72018-09-01 23:46:44 +0530241 {
Johnathan Manteye5c4f1d2018-12-10 16:24:26 -0800242 signalFlag &= ~(1 << chNum);
AppaRao Puli9613ed72018-09-01 23:46:44 +0530243 log<level::DEBUG>("Request originated from IPMI so ignoring signal");
244 return;
245 }
246
247 // Update both volatile & Non-volatile, if there is mismatch.
248 // as property change other than IPMI, has to update both volatile &
249 // non-volatile data.
Johnathan Manteye5c4f1d2018-12-10 16:24:26 -0800250 checkAndReloadVolatileData();
251 checkAndReloadNVData();
252 if (channelData[chNum].chAccess.chNonVolatileData.privLimit != intfPriv)
AppaRao Puli9613ed72018-09-01 23:46:44 +0530253 {
254 // Update NV data
Johnathan Manteye5c4f1d2018-12-10 16:24:26 -0800255 channelData[chNum].chAccess.chNonVolatileData.privLimit = intfPriv;
256 if (writeChannelPersistData() != 0)
AppaRao Puli9613ed72018-09-01 23:46:44 +0530257 {
258 log<level::ERR>("Failed to update the persist data file");
259 return;
260 }
261
262 // Update Volatile data
Johnathan Manteye5c4f1d2018-12-10 16:24:26 -0800263 if (channelData[chNum].chAccess.chVolatileData.privLimit != intfPriv)
AppaRao Puli9613ed72018-09-01 23:46:44 +0530264 {
Johnathan Manteye5c4f1d2018-12-10 16:24:26 -0800265 channelData[chNum].chAccess.chVolatileData.privLimit = intfPriv;
266 if (writeChannelVolatileData() != 0)
AppaRao Puli9613ed72018-09-01 23:46:44 +0530267 {
268 log<level::ERR>("Failed to update the volatile data file");
269 return;
270 }
271 }
272 }
273
274 return;
275}
276
AppaRao Puli071f3f22018-05-24 16:45:30 +0530277ChannelConfig& getChannelConfigObject()
278{
279 static ChannelConfig channelConfig;
280 return channelConfig;
281}
282
AppaRao Puli9613ed72018-09-01 23:46:44 +0530283ChannelConfig::~ChannelConfig()
284{
285 if (signalHndlrObjectState)
286 {
287 chPropertiesSignal.reset();
288 sigHndlrLock.unlock();
289 }
290}
291
AppaRao Puli071f3f22018-05-24 16:45:30 +0530292ChannelConfig::ChannelConfig() : bus(ipmid_get_sd_bus_connection())
293{
294 std::ofstream mutexCleanUpFile;
295 mutexCleanUpFile.open(ipmiChMutexCleanupLockFile,
296 std::ofstream::out | std::ofstream::app);
297 if (!mutexCleanUpFile.good())
298 {
299 log<level::DEBUG>("Unable to open mutex cleanup file");
300 return;
301 }
302 mutexCleanUpFile.close();
303 mutexCleanupLock =
304 boost::interprocess::file_lock(ipmiChMutexCleanupLockFile);
305 if (mutexCleanupLock.try_lock())
306 {
307 boost::interprocess::named_recursive_mutex::remove(ipmiChannelMutex);
308 channelMutex =
309 std::make_unique<boost::interprocess::named_recursive_mutex>(
310 boost::interprocess::open_or_create, ipmiChannelMutex);
311 mutexCleanupLock.lock_sharable();
312 }
313 else
314 {
315 mutexCleanupLock.lock_sharable();
316 channelMutex =
317 std::make_unique<boost::interprocess::named_recursive_mutex>(
318 boost::interprocess::open_or_create, ipmiChannelMutex);
319 }
320
321 initChannelPersistData();
AppaRao Puli9613ed72018-09-01 23:46:44 +0530322
323 sigHndlrLock = boost::interprocess::file_lock(channelNvDataFilename);
324 // Register it for single object and single process either netipimd /
325 // host-ipmid
326 if (chPropertiesSignal == nullptr && sigHndlrLock.try_lock())
327 {
328 log<level::DEBUG>("Registering channel signal handler.");
329 chPropertiesSignal = std::make_unique<sdbusplus::bus::match_t>(
330 bus,
331 sdbusplus::bus::match::rules::path_namespace(
332 networkIntfObjectBasePath) +
333 sdbusplus::bus::match::rules::type::signal() +
334 sdbusplus::bus::match::rules::member(propertiesChangedSignal) +
335 sdbusplus::bus::match::rules::interface(
336 dBusPropertiesInterface) +
337 sdbusplus::bus::match::rules::argN(0, networkChConfigIntfName),
338 [&](sdbusplus::message::message& msg) {
339 DbusChObjProperties props;
340 std::string iface;
341 std::string path = msg.get_path();
342 msg.read(iface, props);
Johnathan Manteye5c4f1d2018-12-10 16:24:26 -0800343 processChAccessPropChange(path, props);
AppaRao Puli9613ed72018-09-01 23:46:44 +0530344 });
345 signalHndlrObjectState = true;
346 }
347}
348
Richard Marian Thomaiyara45cb342018-12-03 15:08:59 +0530349bool ChannelConfig::isValidChannel(const uint8_t chNum)
AppaRao Puli071f3f22018-05-24 16:45:30 +0530350{
351 if (chNum > maxIpmiChannels)
352 {
353 log<level::DEBUG>("Invalid channel ID - Out of range");
354 return false;
355 }
356
357 if (channelData[chNum].isChValid == false)
358 {
359 log<level::DEBUG>("Channel is not valid");
AppaRao Puli071f3f22018-05-24 16:45:30 +0530360 }
361
Johnathan Manteye5c4f1d2018-12-10 16:24:26 -0800362 return channelData[chNum].isChValid;
AppaRao Puli071f3f22018-05-24 16:45:30 +0530363}
364
365EChannelSessSupported
Richard Marian Thomaiyara45cb342018-12-03 15:08:59 +0530366 ChannelConfig::getChannelSessionSupport(const uint8_t chNum)
AppaRao Puli071f3f22018-05-24 16:45:30 +0530367{
368 EChannelSessSupported chSessSupport =
369 (EChannelSessSupported)channelData[chNum].chInfo.sessionSupported;
370 return chSessSupport;
371}
372
Richard Marian Thomaiyara45cb342018-12-03 15:08:59 +0530373bool ChannelConfig::isValidAuthType(const uint8_t chNum,
AppaRao Puli071f3f22018-05-24 16:45:30 +0530374 const EAuthType& authType)
375{
376 if ((authType < EAuthType::md2) || (authType > EAuthType::oem))
377 {
378 log<level::DEBUG>("Invalid authentication type");
379 return false;
380 }
381
382 uint8_t authTypeSupported = channelData[chNum].chInfo.authTypeSupported;
383 if (!(authTypeSupported & (1 << static_cast<uint8_t>(authType))))
384 {
385 log<level::DEBUG>("Authentication type is not supported.");
386 return false;
387 }
388
389 return true;
390}
391
Richard Marian Thomaiyara45cb342018-12-03 15:08:59 +0530392int ChannelConfig::getChannelActiveSessions(const uint8_t chNum)
AppaRao Puli071f3f22018-05-24 16:45:30 +0530393{
394 // TODO: TEMPORARY FIX
Johnathan Mantey4c0435a2018-12-11 13:17:55 -0800395 // Channels active session count is managed separately
AppaRao Puli071f3f22018-05-24 16:45:30 +0530396 // by monitoring channel session which includes LAN and
397 // RAKP layer changes. This will be updated, once the
398 // authentication part is implemented.
399 return channelData[chNum].activeSessCount;
400}
401
Vernon Mauery58317122018-11-28 11:02:43 -0800402size_t ChannelConfig::getChannelMaxTransferSize(uint8_t chNum)
403{
404 return channelData[chNum].maxTransferSize;
405}
406
Richard Marian Thomaiyara45cb342018-12-03 15:08:59 +0530407ipmi_ret_t ChannelConfig::getChannelInfo(const uint8_t chNum,
AppaRao Puli071f3f22018-05-24 16:45:30 +0530408 ChannelInfo& chInfo)
409{
410 if (!isValidChannel(chNum))
411 {
412 log<level::DEBUG>("Invalid channel");
413 return IPMI_CC_INVALID_FIELD_REQUEST;
414 }
415
416 std::copy_n(reinterpret_cast<uint8_t*>(&channelData[chNum].chInfo),
417 sizeof(channelData[chNum].chInfo),
418 reinterpret_cast<uint8_t*>(&chInfo));
419
420 return IPMI_CC_OK;
421}
422
Richard Marian Thomaiyara45cb342018-12-03 15:08:59 +0530423ipmi_ret_t ChannelConfig::getChannelAccessData(const uint8_t chNum,
AppaRao Puli071f3f22018-05-24 16:45:30 +0530424 ChannelAccess& chAccessData)
425{
426 if (!isValidChannel(chNum))
427 {
428 log<level::DEBUG>("Invalid channel");
429 return IPMI_CC_INVALID_FIELD_REQUEST;
430 }
431
432 if (getChannelSessionSupport(chNum) == EChannelSessSupported::none)
433 {
434 log<level::DEBUG>("Session-less channel doesn't have access data.");
435 return IPMI_CC_ACTION_NOT_SUPPORTED_FOR_CHANNEL;
436 }
437
438 if (checkAndReloadVolatileData() != 0)
439 {
440 return IPMI_CC_UNSPECIFIED_ERROR;
441 }
442
443 std::copy_n(
444 reinterpret_cast<uint8_t*>(&channelData[chNum].chAccess.chVolatileData),
445 sizeof(channelData[chNum].chAccess.chVolatileData),
446 reinterpret_cast<uint8_t*>(&chAccessData));
447
448 return IPMI_CC_OK;
449}
450
451ipmi_ret_t
Richard Marian Thomaiyara45cb342018-12-03 15:08:59 +0530452 ChannelConfig::setChannelAccessData(const uint8_t chNum,
AppaRao Puli071f3f22018-05-24 16:45:30 +0530453 const ChannelAccess& chAccessData,
Richard Marian Thomaiyara45cb342018-12-03 15:08:59 +0530454 const uint8_t setFlag)
AppaRao Puli071f3f22018-05-24 16:45:30 +0530455{
456 if (!isValidChannel(chNum))
457 {
458 log<level::DEBUG>("Invalid channel");
459 return IPMI_CC_INVALID_FIELD_REQUEST;
460 }
461
462 if (getChannelSessionSupport(chNum) == EChannelSessSupported::none)
463 {
464 log<level::DEBUG>("Session-less channel doesn't have access data.");
465 return IPMI_CC_ACTION_NOT_SUPPORTED_FOR_CHANNEL;
466 }
467
Richard Marian Thomaiyar93411602019-01-29 10:56:57 +0530468 if (((setFlag & setAccessMode) &&
469 (!isValidAccessMode(chAccessData.accessMode))) ||
470 ((setFlag & setPrivLimit) &&
471 (!isValidPrivLimit(chAccessData.privLimit))))
AppaRao Puli071f3f22018-05-24 16:45:30 +0530472 {
Richard Marian Thomaiyar93411602019-01-29 10:56:57 +0530473 log<level::DEBUG>("Invalid access mode / privilege limit specified");
AppaRao Puli071f3f22018-05-24 16:45:30 +0530474 return IPMI_CC_INVALID_FIELD_REQUEST;
475 }
476
477 boost::interprocess::scoped_lock<boost::interprocess::named_recursive_mutex>
478 channelLock{*channelMutex};
479
480 if (checkAndReloadVolatileData() != 0)
481 {
482 return IPMI_CC_UNSPECIFIED_ERROR;
483 }
484
485 if (setFlag & setAccessMode)
486 {
487 channelData[chNum].chAccess.chVolatileData.accessMode =
488 chAccessData.accessMode;
489 }
490 if (setFlag & setUserAuthEnabled)
491 {
492 channelData[chNum].chAccess.chVolatileData.userAuthDisabled =
493 chAccessData.userAuthDisabled;
494 }
495 if (setFlag & setMsgAuthEnabled)
496 {
497 channelData[chNum].chAccess.chVolatileData.perMsgAuthDisabled =
498 chAccessData.perMsgAuthDisabled;
499 }
500 if (setFlag & setAlertingEnabled)
501 {
502 channelData[chNum].chAccess.chVolatileData.alertingDisabled =
503 chAccessData.alertingDisabled;
504 }
505 if (setFlag & setPrivLimit)
506 {
507 channelData[chNum].chAccess.chVolatileData.privLimit =
508 chAccessData.privLimit;
509 }
510
511 // Write Volatile data to file
512 if (writeChannelVolatileData() != 0)
513 {
514 log<level::DEBUG>("Failed to update the channel volatile data");
515 return IPMI_CC_UNSPECIFIED_ERROR;
516 }
517 return IPMI_CC_OK;
518}
519
520ipmi_ret_t
Richard Marian Thomaiyara45cb342018-12-03 15:08:59 +0530521 ChannelConfig::getChannelAccessPersistData(const uint8_t chNum,
AppaRao Puli071f3f22018-05-24 16:45:30 +0530522 ChannelAccess& chAccessData)
523{
524 if (!isValidChannel(chNum))
525 {
526 log<level::DEBUG>("Invalid channel");
527 return IPMI_CC_INVALID_FIELD_REQUEST;
528 }
529
530 if (getChannelSessionSupport(chNum) == EChannelSessSupported::none)
531 {
532 log<level::DEBUG>("Session-less channel doesn't have access data.");
533 return IPMI_CC_ACTION_NOT_SUPPORTED_FOR_CHANNEL;
534 }
535
536 if (checkAndReloadNVData() != 0)
537 {
538 return IPMI_CC_UNSPECIFIED_ERROR;
539 }
540
541 std::copy_n(reinterpret_cast<uint8_t*>(
542 &channelData[chNum].chAccess.chNonVolatileData),
543 sizeof(channelData[chNum].chAccess.chNonVolatileData),
544 reinterpret_cast<uint8_t*>(&chAccessData));
545
546 return IPMI_CC_OK;
547}
548
549ipmi_ret_t ChannelConfig::setChannelAccessPersistData(
Richard Marian Thomaiyara45cb342018-12-03 15:08:59 +0530550 const uint8_t chNum, const ChannelAccess& chAccessData,
551 const uint8_t setFlag)
AppaRao Puli071f3f22018-05-24 16:45:30 +0530552{
553 if (!isValidChannel(chNum))
554 {
555 log<level::DEBUG>("Invalid channel");
556 return IPMI_CC_INVALID_FIELD_REQUEST;
557 }
558
559 if (getChannelSessionSupport(chNum) == EChannelSessSupported::none)
560 {
561 log<level::DEBUG>("Session-less channel doesn't have access data.");
562 return IPMI_CC_ACTION_NOT_SUPPORTED_FOR_CHANNEL;
563 }
564
Richard Marian Thomaiyar93411602019-01-29 10:56:57 +0530565 if (((setFlag & setAccessMode) &&
566 (!isValidAccessMode(chAccessData.accessMode))) ||
567 ((setFlag & setPrivLimit) &&
568 (!isValidPrivLimit(chAccessData.privLimit))))
AppaRao Puli071f3f22018-05-24 16:45:30 +0530569 {
Richard Marian Thomaiyar93411602019-01-29 10:56:57 +0530570 log<level::DEBUG>("Invalid access mode / privilege limit specified");
AppaRao Puli071f3f22018-05-24 16:45:30 +0530571 return IPMI_CC_INVALID_FIELD_REQUEST;
572 }
573
574 boost::interprocess::scoped_lock<boost::interprocess::named_recursive_mutex>
575 channelLock{*channelMutex};
576
577 if (checkAndReloadNVData() != 0)
578 {
579 return IPMI_CC_UNSPECIFIED_ERROR;
580 }
581
582 if (setFlag & setAccessMode)
583 {
584 channelData[chNum].chAccess.chNonVolatileData.accessMode =
585 chAccessData.accessMode;
586 }
587 if (setFlag & setUserAuthEnabled)
588 {
589 channelData[chNum].chAccess.chNonVolatileData.userAuthDisabled =
590 chAccessData.userAuthDisabled;
591 }
592 if (setFlag & setMsgAuthEnabled)
593 {
594 channelData[chNum].chAccess.chNonVolatileData.perMsgAuthDisabled =
595 chAccessData.perMsgAuthDisabled;
596 }
597 if (setFlag & setAlertingEnabled)
598 {
599 channelData[chNum].chAccess.chNonVolatileData.alertingDisabled =
600 chAccessData.alertingDisabled;
601 }
602 if (setFlag & setPrivLimit)
603 {
AppaRao Puli9613ed72018-09-01 23:46:44 +0530604 // Send Update to network channel config interfaces over dbus
AppaRao Puli9613ed72018-09-01 23:46:44 +0530605 std::string privStr = convertToPrivLimitString(chAccessData.privLimit);
Richard Marian Thomaiyar73906b92019-01-04 23:48:02 +0530606 std::string networkIntfObj = std::string(networkIntfObjectBasePath) +
607 "/" + channelData[chNum].chName;
AppaRao Puli9613ed72018-09-01 23:46:44 +0530608 try
609 {
Johnathan Manteyf92261d2018-12-10 15:49:34 -0800610 if (0 != setDbusProperty(networkIntfServiceName, networkIntfObj,
611 networkChConfigIntfName,
AppaRao Puli9613ed72018-09-01 23:46:44 +0530612 privilegePropertyString, privStr))
613 {
Richard Marian Thomaiyar73906b92019-01-04 23:48:02 +0530614 log<level::DEBUG>(
615 "Network interface does not exist",
616 entry("INTERFACE:%s", channelData[chNum].chName.c_str()));
AppaRao Puli9613ed72018-09-01 23:46:44 +0530617 return IPMI_CC_UNSPECIFIED_ERROR;
618 }
619 }
620 catch (const sdbusplus::exception::SdBusError& e)
621 {
622 log<level::ERR>("Exception: Network interface does not exist");
623 return IPMI_CC_INVALID_FIELD_REQUEST;
624 }
625 signalFlag |= (1 << chNum);
AppaRao Puli071f3f22018-05-24 16:45:30 +0530626 channelData[chNum].chAccess.chNonVolatileData.privLimit =
627 chAccessData.privLimit;
628 }
629
630 // Write persistent data to file
631 if (writeChannelPersistData() != 0)
632 {
633 log<level::DEBUG>("Failed to update the presist data file");
634 return IPMI_CC_UNSPECIFIED_ERROR;
635 }
636 return IPMI_CC_OK;
637}
638
639ipmi_ret_t
Richard Marian Thomaiyara45cb342018-12-03 15:08:59 +0530640 ChannelConfig::getChannelAuthTypeSupported(const uint8_t chNum,
AppaRao Puli071f3f22018-05-24 16:45:30 +0530641 uint8_t& authTypeSupported)
642{
643 if (!isValidChannel(chNum))
644 {
645 log<level::DEBUG>("Invalid channel");
646 return IPMI_CC_INVALID_FIELD_REQUEST;
647 }
648
649 authTypeSupported = channelData[chNum].chInfo.authTypeSupported;
650 return IPMI_CC_OK;
651}
652
Richard Marian Thomaiyara45cb342018-12-03 15:08:59 +0530653ipmi_ret_t ChannelConfig::getChannelEnabledAuthType(const uint8_t chNum,
654 const uint8_t priv,
AppaRao Puli071f3f22018-05-24 16:45:30 +0530655 EAuthType& authType)
656{
657 if (!isValidChannel(chNum))
658 {
659 log<level::DEBUG>("Invalid channel");
660 return IPMI_CC_INVALID_FIELD_REQUEST;
661 }
662
663 if (getChannelSessionSupport(chNum) == EChannelSessSupported::none)
664 {
665 log<level::DEBUG>("Sessionless channel doesn't have access data.");
666 return IPMI_CC_INVALID_FIELD_REQUEST;
667 }
668
669 if (!isValidPrivLimit(priv))
670 {
671 log<level::DEBUG>("Invalid privilege specified.");
672 return IPMI_CC_INVALID_FIELD_REQUEST;
673 }
674
675 // TODO: Hardcoded for now. Need to implement.
676 authType = EAuthType::none;
677
678 return IPMI_CC_OK;
679}
680
681std::time_t ChannelConfig::getUpdatedFileTime(const std::string& fileName)
682{
683 struct stat fileStat;
684 if (stat(fileName.c_str(), &fileStat) != 0)
685 {
686 log<level::DEBUG>("Error in getting last updated time stamp");
687 return -EIO;
688 }
689 return fileStat.st_mtime;
690}
691
692EChannelAccessMode
693 ChannelConfig::convertToAccessModeIndex(const std::string& mode)
694{
695 auto iter = std::find(accessModeList.begin(), accessModeList.end(), mode);
696 if (iter == accessModeList.end())
697 {
698 log<level::ERR>("Invalid access mode.",
699 entry("MODE_STR=%s", mode.c_str()));
700 throw std::invalid_argument("Invalid access mode.");
701 }
702
703 return static_cast<EChannelAccessMode>(
704 std::distance(accessModeList.begin(), iter));
705}
706
Richard Marian Thomaiyara45cb342018-12-03 15:08:59 +0530707std::string ChannelConfig::convertToAccessModeString(const uint8_t value)
AppaRao Puli071f3f22018-05-24 16:45:30 +0530708{
709 if (accessModeList.size() <= value)
710 {
711 log<level::ERR>("Invalid access mode.", entry("MODE_IDX=%d", value));
712 throw std::invalid_argument("Invalid access mode.");
713 }
714
715 return accessModeList.at(value);
716}
717
718CommandPrivilege
719 ChannelConfig::convertToPrivLimitIndex(const std::string& value)
720{
721 auto iter = std::find(privList.begin(), privList.end(), value);
722 if (iter == privList.end())
723 {
724 log<level::ERR>("Invalid privilege.",
725 entry("PRIV_STR=%s", value.c_str()));
726 throw std::invalid_argument("Invalid privilege.");
727 }
728
729 return static_cast<CommandPrivilege>(std::distance(privList.begin(), iter));
730}
731
Richard Marian Thomaiyara45cb342018-12-03 15:08:59 +0530732std::string ChannelConfig::convertToPrivLimitString(const uint8_t value)
AppaRao Puli071f3f22018-05-24 16:45:30 +0530733{
734 if (privList.size() <= value)
735 {
736 log<level::ERR>("Invalid privilege.", entry("PRIV_IDX=%d", value));
737 throw std::invalid_argument("Invalid privilege.");
738 }
739
740 return privList.at(value);
741}
742
743EChannelSessSupported
744 ChannelConfig::convertToSessionSupportIndex(const std::string& value)
745{
746 auto iter =
747 std::find(sessionSupportList.begin(), sessionSupportList.end(), value);
748 if (iter == sessionSupportList.end())
749 {
750 log<level::ERR>("Invalid session supported.",
751 entry("SESS_STR=%s", value.c_str()));
752 throw std::invalid_argument("Invalid session supported.");
753 }
754
755 return static_cast<EChannelSessSupported>(
756 std::distance(sessionSupportList.begin(), iter));
757}
758
759EChannelMediumType
760 ChannelConfig::convertToMediumTypeIndex(const std::string& value)
761{
762 std::unordered_map<std::string, EChannelMediumType>::iterator it =
763 mediumTypeMap.find(value);
764 if (it == mediumTypeMap.end())
765 {
766 log<level::ERR>("Invalid medium type.",
767 entry("MEDIUM_STR=%s", value.c_str()));
768 throw std::invalid_argument("Invalid medium type.");
769 }
770
771 return static_cast<EChannelMediumType>(it->second);
772}
773
774EChannelProtocolType
775 ChannelConfig::convertToProtocolTypeIndex(const std::string& value)
776{
777 std::unordered_map<std::string, EChannelProtocolType>::iterator it =
778 protocolTypeMap.find(value);
779 if (it == protocolTypeMap.end())
780 {
781 log<level::ERR>("Invalid protocol type.",
782 entry("PROTO_STR=%s", value.c_str()));
783 throw std::invalid_argument("Invalid protocol type.");
784 }
785
786 return static_cast<EChannelProtocolType>(it->second);
787}
788
789Json ChannelConfig::readJsonFile(const std::string& configFile)
790{
791 std::ifstream jsonFile(configFile);
792 if (!jsonFile.good())
793 {
Richard Marian Thomaiyarc4196802019-06-03 19:27:48 +0530794 log<level::INFO>("JSON file not found",
795 entry("FILE_NAME=%s", configFile.c_str()));
AppaRao Puli071f3f22018-05-24 16:45:30 +0530796 return nullptr;
797 }
798
799 Json data = nullptr;
800 try
801 {
802 data = Json::parse(jsonFile, nullptr, false);
803 }
804 catch (Json::parse_error& e)
805 {
806 log<level::DEBUG>("Corrupted channel config.",
807 entry("MSG: %s", e.what()));
808 throw std::runtime_error("Corrupted channel config file");
809 }
810
811 return data;
812}
813
814int ChannelConfig::writeJsonFile(const std::string& configFile,
815 const Json& jsonData)
816{
Richard Marian Thomaiyar687df402019-05-09 00:16:53 +0530817 const std::string tmpFile = configFile + "_tmp";
818 int fd = open(tmpFile.c_str(), O_CREAT | O_WRONLY | O_TRUNC | O_SYNC,
819 S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH);
820 if (fd < 0)
AppaRao Puli071f3f22018-05-24 16:45:30 +0530821 {
Richard Marian Thomaiyar687df402019-05-09 00:16:53 +0530822 log<level::ERR>("Error in creating json file",
823 entry("FILE_NAME = %s", tmpFile.c_str()));
824 return -EIO;
825 }
826 const auto& writeData = jsonData.dump();
827 if (write(fd, writeData.c_str(), writeData.size()) !=
828 static_cast<ssize_t>(writeData.size()))
829 {
830 close(fd);
831 log<level::ERR>("Error in writing configuration file",
832 entry("FILE_NAME = %s", tmpFile.c_str()));
833 return -EIO;
834 }
835 close(fd);
836
837 if (std::rename(tmpFile.c_str(), configFile.c_str()) != 0)
838 {
839 log<level::ERR>("Error in renaming temporary data file",
840 entry("FILE_NAME = %s", tmpFile.c_str()));
AppaRao Puli071f3f22018-05-24 16:45:30 +0530841 return -EIO;
842 }
843
AppaRao Puli071f3f22018-05-24 16:45:30 +0530844 return 0;
845}
846
Richard Marian Thomaiyara45cb342018-12-03 15:08:59 +0530847void ChannelConfig::setDefaultChannelConfig(const uint8_t chNum,
AppaRao Puli071f3f22018-05-24 16:45:30 +0530848 const std::string& chName)
849{
850 channelData[chNum].chName = chName;
851 channelData[chNum].chID = chNum;
852 channelData[chNum].isChValid = false;
853 channelData[chNum].activeSessCount = 0;
854
855 channelData[chNum].chInfo.mediumType = defaultMediumType;
856 channelData[chNum].chInfo.protocolType = defaultProtocolType;
857 channelData[chNum].chInfo.sessionSupported = defaultSessionSupported;
858 channelData[chNum].chInfo.isIpmi = defaultIsIpmiState;
859 channelData[chNum].chInfo.authTypeSupported = defaultAuthType;
860}
861
862int ChannelConfig::loadChannelConfig()
863{
864 boost::interprocess::scoped_lock<boost::interprocess::named_recursive_mutex>
865 channelLock{*channelMutex};
866
867 Json data = readJsonFile(channelConfigDefaultFilename);
Johnathan Manteye5c4f1d2018-12-10 16:24:26 -0800868 if (data.empty())
AppaRao Puli071f3f22018-05-24 16:45:30 +0530869 {
870 log<level::DEBUG>("Error in opening IPMI Channel data file");
871 return -EIO;
872 }
873
Johnathan Mantey4c0435a2018-12-11 13:17:55 -0800874 channelData.fill(ChannelProperties{});
875
876 for (int chNum = 0; chNum < maxIpmiChannels; chNum++)
AppaRao Puli071f3f22018-05-24 16:45:30 +0530877 {
Johnathan Mantey4c0435a2018-12-11 13:17:55 -0800878 try
AppaRao Puli071f3f22018-05-24 16:45:30 +0530879 {
AppaRao Puli071f3f22018-05-24 16:45:30 +0530880 std::string chKey = std::to_string(chNum);
881 Json jsonChData = data[chKey].get<Json>();
882 if (jsonChData.is_null())
883 {
884 log<level::WARNING>(
885 "Channel not configured so loading default.",
886 entry("CHANNEL_NUM:%d", chNum));
887 // If user didn't want to configure specific channel (say
888 // reserved channel), then load that index with default values.
Johnathan Mantey4c0435a2018-12-11 13:17:55 -0800889 setDefaultChannelConfig(chNum, defaultChannelName);
890 continue;
AppaRao Puli071f3f22018-05-24 16:45:30 +0530891 }
Johnathan Mantey4c0435a2018-12-11 13:17:55 -0800892 Json jsonChInfo = jsonChData[channelInfoString].get<Json>();
893 if (jsonChInfo.is_null())
AppaRao Puli071f3f22018-05-24 16:45:30 +0530894 {
Johnathan Mantey4c0435a2018-12-11 13:17:55 -0800895 log<level::ERR>("Invalid/corrupted channel config file");
896 return -EBADMSG;
AppaRao Puli071f3f22018-05-24 16:45:30 +0530897 }
Johnathan Mantey4c0435a2018-12-11 13:17:55 -0800898
899 ChannelProperties& chData = channelData[chNum];
900 chData.chName = jsonChData[nameString].get<std::string>();
901 chData.chID = chNum;
902 chData.isChValid = jsonChData[isValidString].get<bool>();
903 chData.activeSessCount = jsonChData.value(activeSessionsString, 0);
904 chData.maxTransferSize =
905 jsonChData.value(maxTransferSizeString, smallChannelSize);
906 std::string medTypeStr =
907 jsonChInfo[mediumTypeString].get<std::string>();
908 chData.chInfo.mediumType =
909 static_cast<uint8_t>(convertToMediumTypeIndex(medTypeStr));
910 std::string protoTypeStr =
911 jsonChInfo[protocolTypeString].get<std::string>();
912 chData.chInfo.protocolType =
913 static_cast<uint8_t>(convertToProtocolTypeIndex(protoTypeStr));
914 std::string sessStr =
915 jsonChInfo[sessionSupportedString].get<std::string>();
916 chData.chInfo.sessionSupported =
917 static_cast<uint8_t>(convertToSessionSupportIndex(sessStr));
918 chData.chInfo.isIpmi = jsonChInfo[isIpmiString].get<bool>();
919 chData.chInfo.authTypeSupported = defaultAuthType;
AppaRao Puli071f3f22018-05-24 16:45:30 +0530920 }
Johnathan Mantey4c0435a2018-12-11 13:17:55 -0800921 catch (const Json::exception& e)
922 {
923 log<level::DEBUG>("Json Exception caught.",
924 entry("MSG:%s", e.what()));
925 return -EBADMSG;
926 }
927 catch (const std::invalid_argument& e)
928 {
929 log<level::ERR>("Corrupted config.", entry("MSG:%s", e.what()));
930 return -EBADMSG;
931 }
AppaRao Puli071f3f22018-05-24 16:45:30 +0530932 }
933
934 return 0;
935}
936
937int ChannelConfig::readChannelVolatileData()
938{
939 boost::interprocess::scoped_lock<boost::interprocess::named_recursive_mutex>
940 channelLock{*channelMutex};
941
942 Json data = readJsonFile(channelVolatileDataFilename);
943 if (data == nullptr)
944 {
945 log<level::DEBUG>("Error in opening IPMI Channel data file");
946 return -EIO;
947 }
AppaRao Puli071f3f22018-05-24 16:45:30 +0530948 try
949 {
950 // Fill in global structure
951 for (auto it = data.begin(); it != data.end(); ++it)
952 {
953 std::string chKey = it.key();
954 uint8_t chNum = std::stoi(chKey, nullptr, 10);
955 if ((chNum < 0) || (chNum > maxIpmiChannels))
956 {
957 log<level::DEBUG>(
958 "Invalid channel access entry in config file");
959 throw std::out_of_range("Out of range - channel number");
960 }
961 Json jsonChData = it.value();
962 if (!jsonChData.is_null())
963 {
964 std::string accModeStr =
965 jsonChData[accessModeString].get<std::string>();
966 channelData[chNum].chAccess.chVolatileData.accessMode =
967 static_cast<uint8_t>(convertToAccessModeIndex(accModeStr));
968 channelData[chNum].chAccess.chVolatileData.userAuthDisabled =
969 jsonChData[userAuthDisabledString].get<bool>();
970 channelData[chNum].chAccess.chVolatileData.perMsgAuthDisabled =
971 jsonChData[perMsgAuthDisabledString].get<bool>();
972 channelData[chNum].chAccess.chVolatileData.alertingDisabled =
973 jsonChData[alertingDisabledString].get<bool>();
974 std::string privStr =
975 jsonChData[privLimitString].get<std::string>();
976 channelData[chNum].chAccess.chVolatileData.privLimit =
977 static_cast<uint8_t>(convertToPrivLimitIndex(privStr));
978 }
979 else
980 {
981 log<level::ERR>(
982 "Invalid/corrupted volatile channel access file",
983 entry("FILE: %s", channelVolatileDataFilename));
984 throw std::runtime_error(
985 "Corrupted volatile channel access file");
986 }
987 }
988 }
989 catch (const Json::exception& e)
990 {
991 log<level::DEBUG>("Json Exception caught.", entry("MSG:%s", e.what()));
992 throw std::runtime_error("Corrupted volatile channel access file");
993 }
994 catch (const std::invalid_argument& e)
995 {
996 log<level::ERR>("Corrupted config.", entry("MSG:%s", e.what()));
997 throw std::runtime_error("Corrupted volatile channel access file");
998 }
999
1000 // Update the timestamp
1001 voltFileLastUpdatedTime = getUpdatedFileTime(channelVolatileDataFilename);
1002 return 0;
1003}
1004
1005int ChannelConfig::readChannelPersistData()
1006{
1007 boost::interprocess::scoped_lock<boost::interprocess::named_recursive_mutex>
1008 channelLock{*channelMutex};
1009
1010 Json data = readJsonFile(channelNvDataFilename);
1011 if (data == nullptr)
1012 {
1013 log<level::DEBUG>("Error in opening IPMI Channel data file");
1014 return -EIO;
1015 }
AppaRao Puli071f3f22018-05-24 16:45:30 +05301016 try
1017 {
1018 // Fill in global structure
1019 for (auto it = data.begin(); it != data.end(); ++it)
1020 {
1021 std::string chKey = it.key();
1022 uint8_t chNum = std::stoi(chKey, nullptr, 10);
1023 if ((chNum < 0) || (chNum > maxIpmiChannels))
1024 {
1025 log<level::DEBUG>(
1026 "Invalid channel access entry in config file");
1027 throw std::out_of_range("Out of range - channel number");
1028 }
1029 Json jsonChData = it.value();
1030 if (!jsonChData.is_null())
1031 {
1032 std::string accModeStr =
1033 jsonChData[accessModeString].get<std::string>();
1034 channelData[chNum].chAccess.chNonVolatileData.accessMode =
1035 static_cast<uint8_t>(convertToAccessModeIndex(accModeStr));
1036 channelData[chNum].chAccess.chNonVolatileData.userAuthDisabled =
1037 jsonChData[userAuthDisabledString].get<bool>();
1038 channelData[chNum]
1039 .chAccess.chNonVolatileData.perMsgAuthDisabled =
1040 jsonChData[perMsgAuthDisabledString].get<bool>();
1041 channelData[chNum].chAccess.chNonVolatileData.alertingDisabled =
1042 jsonChData[alertingDisabledString].get<bool>();
1043 std::string privStr =
1044 jsonChData[privLimitString].get<std::string>();
1045 channelData[chNum].chAccess.chNonVolatileData.privLimit =
1046 static_cast<uint8_t>(convertToPrivLimitIndex(privStr));
1047 }
1048 else
1049 {
1050 log<level::ERR>("Invalid/corrupted nv channel access file",
1051 entry("FILE:%s", channelNvDataFilename));
1052 throw std::runtime_error("Corrupted nv channel access file");
1053 }
1054 }
1055 }
1056 catch (const Json::exception& e)
1057 {
1058 log<level::DEBUG>("Json Exception caught.", entry("MSG:%s", e.what()));
1059 throw std::runtime_error("Corrupted nv channel access file");
1060 }
1061 catch (const std::invalid_argument& e)
1062 {
1063 log<level::ERR>("Corrupted config.", entry("MSG: %s", e.what()));
1064 throw std::runtime_error("Corrupted nv channel access file");
1065 }
1066
1067 // Update the timestamp
1068 nvFileLastUpdatedTime = getUpdatedFileTime(channelNvDataFilename);
1069 return 0;
1070}
1071
1072int ChannelConfig::writeChannelVolatileData()
1073{
1074 boost::interprocess::scoped_lock<boost::interprocess::named_recursive_mutex>
1075 channelLock{*channelMutex};
1076 Json outData;
1077
1078 try
1079 {
1080 for (uint8_t chNum = 0; chNum < maxIpmiChannels; chNum++)
1081 {
1082 if (getChannelSessionSupport(chNum) != EChannelSessSupported::none)
1083 {
1084 Json jsonObj;
1085 std::string chKey = std::to_string(chNum);
1086 std::string accModeStr = convertToAccessModeString(
1087 channelData[chNum].chAccess.chVolatileData.accessMode);
1088 jsonObj[accessModeString] = accModeStr;
1089 jsonObj[userAuthDisabledString] =
1090 channelData[chNum].chAccess.chVolatileData.userAuthDisabled;
1091 jsonObj[perMsgAuthDisabledString] =
1092 channelData[chNum]
1093 .chAccess.chVolatileData.perMsgAuthDisabled;
1094 jsonObj[alertingDisabledString] =
1095 channelData[chNum].chAccess.chVolatileData.alertingDisabled;
1096 std::string privStr = convertToPrivLimitString(
1097 channelData[chNum].chAccess.chVolatileData.privLimit);
1098 jsonObj[privLimitString] = privStr;
1099
1100 outData[chKey] = jsonObj;
1101 }
1102 }
1103 }
1104 catch (const std::invalid_argument& e)
1105 {
1106 log<level::ERR>("Corrupted config.", entry("MSG: %s", e.what()));
1107 return -EINVAL;
1108 }
1109
1110 if (writeJsonFile(channelVolatileDataFilename, outData) != 0)
1111 {
1112 log<level::DEBUG>("Error in write JSON data to file");
1113 return -EIO;
1114 }
1115
1116 // Update the timestamp
1117 voltFileLastUpdatedTime = getUpdatedFileTime(channelVolatileDataFilename);
1118 return 0;
1119}
1120
1121int ChannelConfig::writeChannelPersistData()
1122{
1123 boost::interprocess::scoped_lock<boost::interprocess::named_recursive_mutex>
1124 channelLock{*channelMutex};
1125 Json outData;
1126
1127 try
1128 {
1129 for (uint8_t chNum = 0; chNum < maxIpmiChannels; chNum++)
1130 {
1131 if (getChannelSessionSupport(chNum) != EChannelSessSupported::none)
1132 {
1133 Json jsonObj;
1134 std::string chKey = std::to_string(chNum);
1135 std::string accModeStr = convertToAccessModeString(
1136 channelData[chNum].chAccess.chNonVolatileData.accessMode);
1137 jsonObj[accessModeString] = accModeStr;
1138 jsonObj[userAuthDisabledString] =
1139 channelData[chNum]
1140 .chAccess.chNonVolatileData.userAuthDisabled;
1141 jsonObj[perMsgAuthDisabledString] =
1142 channelData[chNum]
1143 .chAccess.chNonVolatileData.perMsgAuthDisabled;
1144 jsonObj[alertingDisabledString] =
1145 channelData[chNum]
1146 .chAccess.chNonVolatileData.alertingDisabled;
1147 std::string privStr = convertToPrivLimitString(
1148 channelData[chNum].chAccess.chNonVolatileData.privLimit);
1149 jsonObj[privLimitString] = privStr;
1150
1151 outData[chKey] = jsonObj;
1152 }
1153 }
1154 }
1155 catch (const std::invalid_argument& e)
1156 {
1157 log<level::ERR>("Corrupted config.", entry("MSG: %s", e.what()));
1158 return -EINVAL;
1159 }
1160
1161 if (writeJsonFile(channelNvDataFilename, outData) != 0)
1162 {
1163 log<level::DEBUG>("Error in write JSON data to file");
1164 return -EIO;
1165 }
1166
1167 // Update the timestamp
1168 nvFileLastUpdatedTime = getUpdatedFileTime(channelNvDataFilename);
1169 return 0;
1170}
1171
1172int ChannelConfig::checkAndReloadNVData()
1173{
1174 std::time_t updateTime = getUpdatedFileTime(channelNvDataFilename);
1175 int ret = 0;
1176 if (updateTime != nvFileLastUpdatedTime || updateTime == -EIO)
1177 {
1178 try
1179 {
1180 ret = readChannelPersistData();
1181 }
1182 catch (const std::exception& e)
1183 {
1184 log<level::ERR>("Exception caught in readChannelPersistData.",
1185 entry("MSG=%s", e.what()));
1186 ret = -EIO;
1187 }
1188 }
1189 return ret;
1190}
1191
1192int ChannelConfig::checkAndReloadVolatileData()
1193{
1194 std::time_t updateTime = getUpdatedFileTime(channelVolatileDataFilename);
1195 int ret = 0;
1196 if (updateTime != voltFileLastUpdatedTime || updateTime == -EIO)
1197 {
1198 try
1199 {
1200 ret = readChannelVolatileData();
1201 }
1202 catch (const std::exception& e)
1203 {
1204 log<level::ERR>("Exception caught in readChannelVolatileData.",
1205 entry("MSG=%s", e.what()));
1206 ret = -EIO;
1207 }
1208 }
1209 return ret;
1210}
1211
Johnathan Manteyf92261d2018-12-10 15:49:34 -08001212int ChannelConfig::setDbusProperty(const std::string& service,
AppaRao Puli9613ed72018-09-01 23:46:44 +05301213 const std::string& objPath,
1214 const std::string& interface,
1215 const std::string& property,
1216 const DbusVariant& value)
1217{
1218 try
1219 {
1220 auto method =
1221 bus.new_method_call(service.c_str(), objPath.c_str(),
1222 "org.freedesktop.DBus.Properties", "Set");
1223
1224 method.append(interface, property, value);
1225
1226 auto reply = bus.call(method);
1227 }
1228 catch (const sdbusplus::exception::SdBusError& e)
1229 {
1230 log<level::DEBUG>("set-property failed",
1231 entry("SERVICE:%s", service.c_str()),
1232 entry("OBJPATH:%s", objPath.c_str()),
1233 entry("INTERFACE:%s", interface.c_str()),
1234 entry("PROP:%s", property.c_str()));
1235 return -EIO;
1236 }
1237
1238 return 0;
1239}
1240
Johnathan Manteyf92261d2018-12-10 15:49:34 -08001241int ChannelConfig::getDbusProperty(const std::string& service,
AppaRao Puli9613ed72018-09-01 23:46:44 +05301242 const std::string& objPath,
1243 const std::string& interface,
1244 const std::string& property,
1245 DbusVariant& value)
1246{
1247 try
1248 {
1249 auto method =
1250 bus.new_method_call(service.c_str(), objPath.c_str(),
1251 "org.freedesktop.DBus.Properties", "Get");
1252
1253 method.append(interface, property);
1254
1255 auto reply = bus.call(method);
1256 reply.read(value);
1257 }
1258 catch (const sdbusplus::exception::SdBusError& e)
1259 {
1260 log<level::DEBUG>("get-property failed",
1261 entry("SERVICE:%s", service.c_str()),
1262 entry("OBJPATH:%s", objPath.c_str()),
1263 entry("INTERFACE:%s", interface.c_str()),
1264 entry("PROP:%s", property.c_str()));
1265 return -EIO;
1266 }
1267 return 0;
1268}
1269
1270int ChannelConfig::syncNetworkChannelConfig()
1271{
1272 boost::interprocess::scoped_lock<boost::interprocess::named_recursive_mutex>
1273 channelLock{*channelMutex};
1274 bool isUpdated = false;
1275 for (uint8_t chNum = 0; chNum < maxIpmiChannels; chNum++)
1276 {
1277 if (getChannelSessionSupport(chNum) != EChannelSessSupported::none)
1278 {
1279 std::string intfPrivStr;
1280 try
1281 {
AppaRao Puli9613ed72018-09-01 23:46:44 +05301282 std::string networkIntfObj =
Richard Marian Thomaiyar73906b92019-01-04 23:48:02 +05301283 std::string(networkIntfObjectBasePath) + "/" +
1284 channelData[chNum].chName;
AppaRao Puli9613ed72018-09-01 23:46:44 +05301285 DbusVariant variant;
Johnathan Manteyf92261d2018-12-10 15:49:34 -08001286 if (0 != getDbusProperty(networkIntfServiceName, networkIntfObj,
AppaRao Puli9613ed72018-09-01 23:46:44 +05301287 networkChConfigIntfName,
1288 privilegePropertyString, variant))
1289 {
1290 log<level::DEBUG>("Network interface does not exist",
Richard Marian Thomaiyar73906b92019-01-04 23:48:02 +05301291 entry("INTERFACE:%s",
1292 channelData[chNum].chName.c_str()));
AppaRao Puli9613ed72018-09-01 23:46:44 +05301293 continue;
1294 }
Vernon Maueryf442e112019-04-09 11:44:36 -07001295 intfPrivStr = std::get<std::string>(variant);
AppaRao Puli9613ed72018-09-01 23:46:44 +05301296 }
Vernon Maueryf442e112019-04-09 11:44:36 -07001297 catch (const std::bad_variant_access& e)
AppaRao Puli9613ed72018-09-01 23:46:44 +05301298 {
1299 log<level::DEBUG>(
1300 "exception: Network interface does not exist");
1301 continue;
1302 }
1303 catch (const sdbusplus::exception::SdBusError& e)
1304 {
1305 log<level::DEBUG>(
1306 "exception: Network interface does not exist");
1307 continue;
1308 }
1309
1310 uint8_t intfPriv =
1311 static_cast<uint8_t>(convertToPrivLimitIndex(intfPrivStr));
1312 if (channelData[chNum].chAccess.chNonVolatileData.privLimit !=
1313 intfPriv)
1314 {
1315 isUpdated = true;
1316 channelData[chNum].chAccess.chNonVolatileData.privLimit =
1317 intfPriv;
1318 channelData[chNum].chAccess.chVolatileData.privLimit = intfPriv;
1319 }
1320 }
1321 }
1322
1323 if (isUpdated)
1324 {
1325 // Write persistent data to file
1326 if (writeChannelPersistData() != 0)
1327 {
1328 log<level::DEBUG>("Failed to update the persistent data file");
1329 return -EIO;
1330 }
1331 // Write Volatile data to file
1332 if (writeChannelVolatileData() != 0)
1333 {
1334 log<level::DEBUG>("Failed to update the channel volatile data");
1335 return -EIO;
1336 }
1337 }
1338
1339 return 0;
1340}
1341
AppaRao Puli071f3f22018-05-24 16:45:30 +05301342void ChannelConfig::initChannelPersistData()
1343{
Richard Marian Thomaiyare91474c2019-09-01 23:02:47 +05301344 boost::interprocess::scoped_lock<boost::interprocess::named_recursive_mutex>
1345 channelLock{*channelMutex};
1346
AppaRao Puli071f3f22018-05-24 16:45:30 +05301347 /* Always read the channel config */
1348 if (loadChannelConfig() != 0)
1349 {
1350 log<level::ERR>("Failed to read channel config file");
1351 throw std::ios_base::failure("Failed to load channel configuration");
1352 }
1353
1354 /* Populate the channel persist data */
1355 if (readChannelPersistData() != 0)
1356 {
1357 // Copy default NV data to RW location
1358 std::experimental::filesystem::copy_file(channelAccessDefaultFilename,
1359 channelNvDataFilename);
1360
1361 // Load the channel access NV data
1362 if (readChannelPersistData() != 0)
1363 {
1364 log<level::ERR>("Failed to read channel access NV data");
1365 throw std::ios_base::failure(
1366 "Failed to read channel access NV configuration");
1367 }
1368 }
1369
1370 // First check the volatile data file
1371 // If not present, load the default values
1372 if (readChannelVolatileData() != 0)
1373 {
1374 // Copy default volatile data to temporary location
1375 // NV file(channelNvDataFilename) must have created by now.
1376 std::experimental::filesystem::copy_file(channelNvDataFilename,
1377 channelVolatileDataFilename);
1378
1379 // Load the channel access volatile data
1380 if (readChannelVolatileData() != 0)
1381 {
1382 log<level::ERR>("Failed to read channel access volatile data");
1383 throw std::ios_base::failure(
1384 "Failed to read channel access volatile configuration");
1385 }
1386 }
AppaRao Puli9613ed72018-09-01 23:46:44 +05301387
1388 // Synchronize the channel config(priv) with network channel
1389 // configuration(priv) over dbus
1390 if (syncNetworkChannelConfig() != 0)
1391 {
1392 log<level::ERR>(
1393 "Failed to synchronize data with network channel config over dbus");
1394 throw std::ios_base::failure(
1395 "Failed to synchronize data with network channel config over dbus");
1396 }
1397
1398 log<level::DEBUG>("Successfully completed channel data initialization.");
AppaRao Puli071f3f22018-05-24 16:45:30 +05301399 return;
1400}
1401
1402} // namespace ipmi