blob: 71442816411d465bcdd187fa64233e6634360698 [file] [log] [blame]
Jayanth Othayothcb65ffc2018-10-16 08:29:32 -05001#include "config.h"
2
3#include "elog_watch.hpp"
4
5#include "dump_internal.hpp"
6#include "dump_serialize.hpp"
Marri Devender Rao0deb2872018-11-12 07:45:54 -06007#include "errors_map.hpp"
Jayanth Othayothcb65ffc2018-10-16 08:29:32 -05008#include "xyz/openbmc_project/Dump/Create/error.hpp"
9
Vishwanatha Subbanna31085972017-10-05 17:06:37 +053010#include <cereal/cereal.hpp>
Marri Devender Rao0deb2872018-11-12 07:45:54 -060011#include <fstream>
Jayanth Othayothd0f00642017-09-04 06:26:30 -050012#include <phosphor-logging/elog.hpp>
William A. Kennington III15cd3ce2018-05-15 11:34:44 -070013#include <sdbusplus/exception.hpp>
Jayanth Othayothd0f00642017-09-04 06:26:30 -050014
Vishwanatha Subbanna31085972017-10-05 17:06:37 +053015// Register class version with Cereal
16CEREAL_CLASS_VERSION(phosphor::dump::elog::Watch, CLASS_VERSION);
Jayanth Othayothd0f00642017-09-04 06:26:30 -050017
18namespace phosphor
19{
20namespace dump
21{
22namespace elog
23{
24
25using namespace phosphor::logging;
26constexpr auto LOG_PATH = "/xyz/openbmc_project/logging";
Jayanth Othayothd0f00642017-09-04 06:26:30 -050027using Message = std::string;
Patrick Williams984a98f2020-05-13 17:53:32 -050028using Attributes = std::variant<Message>;
Jayanth Othayothd0f00642017-09-04 06:26:30 -050029using AttributeName = std::string;
30using AttributeMap = std::map<AttributeName, Attributes>;
31using PropertyName = std::string;
32using PropertyMap = std::map<PropertyName, AttributeMap>;
Jayanth Othayothd0f00642017-09-04 06:26:30 -050033
Jayanth Othayothcb65ffc2018-10-16 08:29:32 -050034Watch::Watch(sdbusplus::bus::bus& bus, IMgr& iMgr) :
Jayanth Othayoth24964822017-09-04 22:07:06 -050035 iMgr(iMgr),
Jayanth Othayothcb65ffc2018-10-16 08:29:32 -050036 addMatch(bus,
37 sdbusplus::bus::match::rules::interfacesAdded() +
38 sdbusplus::bus::match::rules::path_namespace(OBJ_LOGGING),
39 std::bind(std::mem_fn(&Watch::addCallback), this,
40 std::placeholders::_1)),
41 delMatch(bus,
42 sdbusplus::bus::match::rules::interfacesRemoved() +
43 sdbusplus::bus::match::rules::path_namespace(OBJ_LOGGING),
44 std::bind(std::mem_fn(&Watch::delCallback), this,
45 std::placeholders::_1))
Jayanth Othayoth24964822017-09-04 22:07:06 -050046{
47
48 fs::path file(ELOG_ID_PERSIST_PATH);
49 if (fs::exists(file))
50 {
51 if (!deserialize(ELOG_ID_PERSIST_PATH, elogList))
52 {
53 log<level::ERR>("Error occurred during error id deserialize");
54 }
55 }
56}
57
58void Watch::addCallback(sdbusplus::message::message& msg)
Jayanth Othayothd0f00642017-09-04 06:26:30 -050059{
Jayanth Othayothd0f00642017-09-04 06:26:30 -050060 using QuotaExceeded =
61 sdbusplus::xyz::openbmc_project::Dump::Create::Error::QuotaExceeded;
62
William A. Kennington III90d147a2018-06-12 16:42:33 -070063 sdbusplus::message::object_path objectPath;
64 PropertyMap propertyMap;
William A. Kennington III15cd3ce2018-05-15 11:34:44 -070065 try
66 {
William A. Kennington III90d147a2018-06-12 16:42:33 -070067 msg.read(objectPath, propertyMap);
William A. Kennington III15cd3ce2018-05-15 11:34:44 -070068 }
69 catch (const sdbusplus::exception::SdBusError& e)
70 {
71 log<level::ERR>("Failed to parse elog add signal",
72 entry("ERROR=%s", e.what()),
73 entry("REPLY_SIG=%s", msg.get_signature()));
74 return;
75 }
Jayanth Othayothd0f00642017-09-04 06:26:30 -050076
William A. Kennington III90d147a2018-06-12 16:42:33 -070077 std::size_t found = objectPath.str.find("entry");
Jayanth Othayothd0f00642017-09-04 06:26:30 -050078 if (found == std::string::npos)
79 {
Jayanth Othayothcb65ffc2018-10-16 08:29:32 -050080 // Not a new error entry skip
Jayanth Othayothd0f00642017-09-04 06:26:30 -050081 return;
82 }
83
Jayanth Othayoth24964822017-09-04 22:07:06 -050084 auto eId = getEid(objectPath);
85
86 auto search = elogList.find(eId);
87 if (search != elogList.end())
88 {
Jayanth Othayothcb65ffc2018-10-16 08:29:32 -050089 // elog exists in the list, Skip the dump
Jayanth Othayoth24964822017-09-04 22:07:06 -050090 return;
91 }
92
William A. Kennington III90d147a2018-06-12 16:42:33 -070093 auto iter = propertyMap.find("xyz.openbmc_project.Logging.Entry");
94 if (iter == propertyMap.end())
Jayanth Othayothd0f00642017-09-04 06:26:30 -050095 {
96 return;
97 }
98
99 auto attr = iter->second.find("Message");
100 if (attr == iter->second.end())
101 {
102 return;
103 }
104
Patrick Williams07f0f462020-05-13 11:58:11 -0500105 auto& data = std::get<PropertyName>(attr->second);
Jayanth Othayothd0f00642017-09-04 06:26:30 -0500106 if (data.empty())
107 {
Jayanth Othayothcb65ffc2018-10-16 08:29:32 -0500108 // No Message skip
Jayanth Othayothd0f00642017-09-04 06:26:30 -0500109 return;
110 }
111
Marri Devender Rao0deb2872018-11-12 07:45:54 -0600112 EType errorType;
113 for (const auto& [type, errorList] : errorMap)
Jayanth Othayothd0f00642017-09-04 06:26:30 -0500114 {
Marri Devender Rao0deb2872018-11-12 07:45:54 -0600115 auto error = std::find(errorList.begin(), errorList.end(), data);
116 if (error != errorList.end())
117 {
118 errorType = type;
119 break;
120 }
121 }
122
123 // error not supported in the configuration
124 if (errorType.empty())
125 {
Jayanth Othayothd0f00642017-09-04 06:26:30 -0500126 return;
127 }
128
129 std::vector<std::string> fullPaths;
130 fullPaths.push_back(objectPath);
131
132 try
133 {
Jayanth Othayothcb65ffc2018-10-16 08:29:32 -0500134 // Save the elog information. This is to avoid dump requests
135 // in elog restore path.
Jayanth Othayoth24964822017-09-04 22:07:06 -0500136 elogList.insert(eId);
137
138 phosphor::dump::elog::serialize(elogList);
139
Marri Devender Rao0deb2872018-11-12 07:45:54 -0600140 auto item = std::find_if(
141 TypeMap.begin(), TypeMap.end(),
142 [errorType](const auto& err) { return (err.second == errorType); });
143 if (item != TypeMap.end())
144 {
145 iMgr.IMgr::create((*item).first, fullPaths);
146 }
Jayanth Othayothd0f00642017-09-04 06:26:30 -0500147 }
148 catch (QuotaExceeded& e)
149 {
Jayanth Othayothcb65ffc2018-10-16 08:29:32 -0500150 // No action now
Jayanth Othayothd0f00642017-09-04 06:26:30 -0500151 }
152 return;
153}
154
Jayanth Othayoth24964822017-09-04 22:07:06 -0500155void Watch::delCallback(sdbusplus::message::message& msg)
156{
William A. Kennington III90d147a2018-06-12 16:42:33 -0700157 sdbusplus::message::object_path objectPath;
William A. Kennington III15cd3ce2018-05-15 11:34:44 -0700158 try
159 {
William A. Kennington III90d147a2018-06-12 16:42:33 -0700160 msg.read(objectPath);
William A. Kennington III15cd3ce2018-05-15 11:34:44 -0700161 }
162 catch (const sdbusplus::exception::SdBusError& e)
163 {
164 log<level::ERR>("Failed to parse elog del signal",
165 entry("ERROR=%s", e.what()),
166 entry("REPLY_SIG=%s", msg.get_signature()));
167 return;
168 }
Jayanth Othayoth24964822017-09-04 22:07:06 -0500169
Andrew Geissler638b43f2020-04-16 13:33:33 -0500170 std::size_t found = objectPath.str.find("entry");
171 if (found == std::string::npos)
172 {
173 // Not a error entry so skip
174 return;
175 }
176
Jayanth Othayothcb65ffc2018-10-16 08:29:32 -0500177 // Get elog id
Jayanth Othayoth24964822017-09-04 22:07:06 -0500178 auto eId = getEid(objectPath);
179
Jayanth Othayothcb65ffc2018-10-16 08:29:32 -0500180 // Delete the elog entry from the list and serialize
Jayanth Othayoth24964822017-09-04 22:07:06 -0500181 auto search = elogList.find(eId);
182 if (search != elogList.end())
183 {
184 elogList.erase(search);
185 phosphor::dump::elog::serialize(elogList);
186 }
187}
188
Jayanth Othayothcb65ffc2018-10-16 08:29:32 -0500189} // namespace elog
190} // namespace dump
191} // namespace phosphor