Ratan Gupta | 6811f82 | 2017-04-14 16:34:56 +0530 | [diff] [blame] | 1 | #include "network_manager.hpp" |
Patrick Venture | 189d44e | 2018-07-09 12:30:59 -0700 | [diff] [blame] | 2 | |
William A. Kennington III | 09f3a4a | 2022-10-25 02:59:16 -0700 | [diff] [blame] | 3 | #include "config_parser.hpp" |
Ratan Gupta | 5978dd1 | 2017-07-25 13:47:13 +0530 | [diff] [blame] | 4 | #include "ipaddress.hpp" |
William A. Kennington III | 2e09d27 | 2022-10-14 17:15:00 -0700 | [diff] [blame] | 5 | #include "system_queries.hpp" |
William A. Kennington III | 3a70fa2 | 2018-09-20 18:48:20 -0700 | [diff] [blame] | 6 | #include "types.hpp" |
William A. Kennington III | b800612 | 2022-11-13 18:15:15 -0800 | [diff] [blame] | 7 | #include "util.hpp" |
| 8 | |
William A. Kennington III | 57ca961 | 2022-11-14 15:26:47 -0800 | [diff] [blame] | 9 | #include <linux/if_addr.h> |
William A. Kennington III | 7310ac7 | 2022-11-14 15:44:00 -0800 | [diff] [blame] | 10 | #include <linux/neighbour.h> |
William A. Kennington III | b800612 | 2022-11-13 18:15:15 -0800 | [diff] [blame] | 11 | #include <net/if.h> |
William A. Kennington III | 9c441fd | 2023-02-24 13:40:01 -0800 | [diff] [blame] | 12 | #include <net/if_arp.h> |
Ratan Gupta | 738a67f | 2017-04-21 10:38:05 +0530 | [diff] [blame] | 13 | |
Patrick Venture | 189d44e | 2018-07-09 12:30:59 -0700 | [diff] [blame] | 14 | #include <phosphor-logging/elog-errors.hpp> |
Jagpal Singh Gill | f78a415 | 2023-04-17 21:17:56 -0700 | [diff] [blame] | 15 | #include <phosphor-logging/lg2.hpp> |
William A. Kennington III | 80d2901 | 2022-11-12 02:31:40 -0800 | [diff] [blame] | 16 | #include <sdbusplus/message.hpp> |
William A. Kennington III | 9b2a20d | 2023-06-17 14:05:48 -0700 | [diff] [blame] | 17 | #include <stdplus/numeric/str.hpp> |
William A. Kennington III | 9ede1b7 | 2022-11-21 01:59:28 -0800 | [diff] [blame] | 18 | #include <stdplus/pinned.hpp> |
William A. Kennington III | b740196 | 2023-07-21 16:36:11 -0700 | [diff] [blame^] | 19 | #include <stdplus/print.hpp> |
Patrick Venture | 189d44e | 2018-07-09 12:30:59 -0700 | [diff] [blame] | 20 | #include <xyz/openbmc_project/Common/error.hpp> |
Ratan Gupta | 6811f82 | 2017-04-14 16:34:56 +0530 | [diff] [blame] | 21 | |
Patrick Williams | 89d734b | 2023-05-10 07:50:25 -0500 | [diff] [blame] | 22 | #include <filesystem> |
| 23 | |
Ratan Gupta | 6811f82 | 2017-04-14 16:34:56 +0530 | [diff] [blame] | 24 | namespace phosphor |
| 25 | { |
| 26 | namespace network |
| 27 | { |
Ratan Gupta | 82549cc | 2017-04-21 08:45:23 +0530 | [diff] [blame] | 28 | |
Ratan Gupta | 6811f82 | 2017-04-14 16:34:56 +0530 | [diff] [blame] | 29 | using namespace phosphor::logging; |
Ratan Gupta | ef85eb9 | 2017-06-15 08:57:54 +0530 | [diff] [blame] | 30 | using namespace sdbusplus::xyz::openbmc_project::Common::Error; |
Jiaqing Zhao | b685cb6 | 2022-04-12 22:57:34 +0800 | [diff] [blame] | 31 | using Argument = xyz::openbmc_project::Common::InvalidArgument; |
Ratan Gupta | 6811f82 | 2017-04-14 16:34:56 +0530 | [diff] [blame] | 32 | |
William A. Kennington III | 80d2901 | 2022-11-12 02:31:40 -0800 | [diff] [blame] | 33 | static constexpr const char enabledMatch[] = |
| 34 | "type='signal',sender='org.freedesktop.network1',path_namespace='/org/" |
| 35 | "freedesktop/network1/" |
| 36 | "link',interface='org.freedesktop.DBus.Properties',member='" |
| 37 | "PropertiesChanged',arg0='org.freedesktop.network1.Link',"; |
| 38 | |
William A. Kennington III | 9ede1b7 | 2022-11-21 01:59:28 -0800 | [diff] [blame] | 39 | Manager::Manager(stdplus::PinnedRef<sdbusplus::bus_t> bus, |
William A. Kennington III | d40046b | 2023-06-30 20:36:11 -0700 | [diff] [blame] | 40 | stdplus::PinnedRef<DelayedExecutor> reload, |
| 41 | stdplus::zstring_view objPath, |
William A. Kennington III | 5b17938 | 2022-11-15 15:23:26 -0800 | [diff] [blame] | 42 | const std::filesystem::path& confDir) : |
William A. Kennington III | de70ccf | 2022-11-20 17:18:01 -0800 | [diff] [blame] | 43 | ManagerIface(bus, objPath.c_str(), ManagerIface::action::defer_emit), |
| 44 | reload(reload), bus(bus), objPath(std::string(objPath)), confDir(confDir), |
William A. Kennington III | 80d2901 | 2022-11-12 02:31:40 -0800 | [diff] [blame] | 45 | systemdNetworkdEnabledMatch( |
William A. Kennington III | 9ede1b7 | 2022-11-21 01:59:28 -0800 | [diff] [blame] | 46 | bus, enabledMatch, |
| 47 | [man = stdplus::PinnedRef(*this)](sdbusplus::message_t& m) { |
Patrick Williams | 89d734b | 2023-05-10 07:50:25 -0500 | [diff] [blame] | 48 | std::string intf; |
| 49 | std::unordered_map<std::string, std::variant<std::string>> values; |
| 50 | try |
| 51 | { |
| 52 | m.read(intf, values); |
| 53 | auto it = values.find("AdministrativeState"); |
| 54 | if (it == values.end()) |
| 55 | { |
| 56 | return; |
| 57 | } |
| 58 | const std::string_view obj = m.get_path(); |
| 59 | auto sep = obj.rfind('/'); |
| 60 | if (sep == obj.npos || sep + 3 > obj.size()) |
| 61 | { |
| 62 | throw std::invalid_argument("Invalid obj path"); |
| 63 | } |
William A. Kennington III | 9b2a20d | 2023-06-17 14:05:48 -0700 | [diff] [blame] | 64 | auto ifidx = stdplus::StrToInt<10, uint16_t>{}(obj.substr(sep + 3)); |
Patrick Williams | 89d734b | 2023-05-10 07:50:25 -0500 | [diff] [blame] | 65 | const auto& state = std::get<std::string>(it->second); |
| 66 | man.get().handleAdminState(state, ifidx); |
| 67 | } |
| 68 | catch (const std::exception& e) |
| 69 | { |
| 70 | lg2::error("AdministrativeState match parsing failed: {ERROR}", "ERROR", |
| 71 | e); |
| 72 | } |
William A. Kennington III | 80d2901 | 2022-11-12 02:31:40 -0800 | [diff] [blame] | 73 | }) |
Ratan Gupta | 6811f82 | 2017-04-14 16:34:56 +0530 | [diff] [blame] | 74 | { |
William A. Kennington III | d40046b | 2023-06-30 20:36:11 -0700 | [diff] [blame] | 75 | reload.get().setCallback([&]() { |
William A. Kennington III | de70ccf | 2022-11-20 17:18:01 -0800 | [diff] [blame] | 76 | for (auto& hook : reloadPreHooks) |
| 77 | { |
| 78 | try |
| 79 | { |
| 80 | hook(); |
| 81 | } |
| 82 | catch (const std::exception& ex) |
| 83 | { |
Jagpal Singh Gill | f78a415 | 2023-04-17 21:17:56 -0700 | [diff] [blame] | 84 | lg2::error("Failed executing reload hook, ignoring: {ERROR}", |
| 85 | "ERROR", ex); |
William A. Kennington III | de70ccf | 2022-11-20 17:18:01 -0800 | [diff] [blame] | 86 | } |
| 87 | } |
| 88 | reloadPreHooks.clear(); |
| 89 | try |
| 90 | { |
William A. Kennington III | 9ede1b7 | 2022-11-21 01:59:28 -0800 | [diff] [blame] | 91 | bus.get() |
William A. Kennington III | af77f82 | 2023-06-23 02:17:20 -0700 | [diff] [blame] | 92 | .new_method_call("org.freedesktop.network1", |
| 93 | "/org/freedesktop/network1", |
| 94 | "org.freedesktop.network1.Manager", "Reload") |
William A. Kennington III | 9ede1b7 | 2022-11-21 01:59:28 -0800 | [diff] [blame] | 95 | .call(); |
Jagpal Singh Gill | f78a415 | 2023-04-17 21:17:56 -0700 | [diff] [blame] | 96 | lg2::info("Reloaded systemd-networkd"); |
William A. Kennington III | de70ccf | 2022-11-20 17:18:01 -0800 | [diff] [blame] | 97 | } |
| 98 | catch (const sdbusplus::exception_t& ex) |
| 99 | { |
Jagpal Singh Gill | f78a415 | 2023-04-17 21:17:56 -0700 | [diff] [blame] | 100 | lg2::error("Failed to reload configuration: {ERROR}", "ERROR", ex); |
William A. Kennington III | de70ccf | 2022-11-20 17:18:01 -0800 | [diff] [blame] | 101 | reloadPostHooks.clear(); |
| 102 | } |
| 103 | for (auto& hook : reloadPostHooks) |
| 104 | { |
| 105 | try |
| 106 | { |
| 107 | hook(); |
| 108 | } |
| 109 | catch (const std::exception& ex) |
| 110 | { |
Jagpal Singh Gill | f78a415 | 2023-04-17 21:17:56 -0700 | [diff] [blame] | 111 | lg2::error("Failed executing reload hook, ignoring: {ERROR}", |
| 112 | "ERROR", ex); |
William A. Kennington III | de70ccf | 2022-11-20 17:18:01 -0800 | [diff] [blame] | 113 | } |
| 114 | } |
| 115 | reloadPostHooks.clear(); |
| 116 | }); |
William A. Kennington III | 80d2901 | 2022-11-12 02:31:40 -0800 | [diff] [blame] | 117 | std::vector< |
| 118 | std::tuple<int32_t, std::string, sdbusplus::message::object_path>> |
| 119 | links; |
| 120 | try |
| 121 | { |
William A. Kennington III | 9ede1b7 | 2022-11-21 01:59:28 -0800 | [diff] [blame] | 122 | auto rsp = bus.get() |
| 123 | .new_method_call("org.freedesktop.network1", |
| 124 | "/org/freedesktop/network1", |
| 125 | "org.freedesktop.network1.Manager", |
| 126 | "ListLinks") |
| 127 | .call(); |
William A. Kennington III | 80d2901 | 2022-11-12 02:31:40 -0800 | [diff] [blame] | 128 | rsp.read(links); |
| 129 | } |
| 130 | catch (const sdbusplus::exception::SdBusError& e) |
| 131 | { |
| 132 | // Any failures are systemd-network not being ready |
| 133 | } |
| 134 | for (const auto& link : links) |
| 135 | { |
| 136 | unsigned ifidx = std::get<0>(link); |
| 137 | auto obj = fmt::format("/org/freedesktop/network1/link/_3{}", ifidx); |
| 138 | auto req = |
William A. Kennington III | 9ede1b7 | 2022-11-21 01:59:28 -0800 | [diff] [blame] | 139 | bus.get().new_method_call("org.freedesktop.network1", obj.c_str(), |
| 140 | "org.freedesktop.DBus.Properties", "Get"); |
William A. Kennington III | 80d2901 | 2022-11-12 02:31:40 -0800 | [diff] [blame] | 141 | req.append("org.freedesktop.network1.Link", "AdministrativeState"); |
| 142 | auto rsp = req.call(); |
| 143 | std::variant<std::string> val; |
| 144 | rsp.read(val); |
| 145 | handleAdminState(std::get<std::string>(val), ifidx); |
| 146 | } |
Ratan Gupta | ef85eb9 | 2017-06-15 08:57:54 +0530 | [diff] [blame] | 147 | |
William A. Kennington III | 5b17938 | 2022-11-15 15:23:26 -0800 | [diff] [blame] | 148 | std::filesystem::create_directories(confDir); |
| 149 | systemConf = std::make_unique<phosphor::network::SystemConfiguration>( |
| 150 | bus, (this->objPath / "config").str); |
| 151 | dhcpConf = std::make_unique<phosphor::network::dhcp::Configuration>( |
| 152 | bus, (this->objPath / "dhcp").str, *this); |
Ratan Gupta | 29b0e43 | 2017-05-25 12:51:40 +0530 | [diff] [blame] | 153 | } |
| 154 | |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 155 | void Manager::createInterface(const AllIntfInfo& info, bool enabled) |
William A. Kennington III | 80d2901 | 2022-11-12 02:31:40 -0800 | [diff] [blame] | 156 | { |
William A. Kennington III | 93f5c6d | 2022-11-17 16:23:44 -0800 | [diff] [blame] | 157 | if (ignoredIntf.find(info.intf.idx) != ignoredIntf.end()) |
| 158 | { |
| 159 | return; |
| 160 | } |
William A. Kennington III | 5b17938 | 2022-11-15 15:23:26 -0800 | [diff] [blame] | 161 | if (auto it = interfacesByIdx.find(info.intf.idx); |
| 162 | it != interfacesByIdx.end()) |
| 163 | { |
William A. Kennington III | 5b17938 | 2022-11-15 15:23:26 -0800 | [diff] [blame] | 164 | if (info.intf.name && *info.intf.name != it->second->interfaceName()) |
| 165 | { |
William A. Kennington III | bf29046 | 2022-11-15 19:44:25 -0800 | [diff] [blame] | 166 | interfaces.erase(it->second->interfaceName()); |
| 167 | interfacesByIdx.erase(it); |
William A. Kennington III | 5b17938 | 2022-11-15 15:23:26 -0800 | [diff] [blame] | 168 | } |
William A. Kennington III | bf29046 | 2022-11-15 19:44:25 -0800 | [diff] [blame] | 169 | else |
| 170 | { |
| 171 | it->second->updateInfo(info.intf); |
| 172 | return; |
| 173 | } |
William A. Kennington III | 5b17938 | 2022-11-15 15:23:26 -0800 | [diff] [blame] | 174 | } |
William A. Kennington III | 876927c | 2022-11-17 16:20:15 -0800 | [diff] [blame] | 175 | else if (info.intf.name) |
| 176 | { |
| 177 | auto it = interfaces.find(*info.intf.name); |
| 178 | if (it != interfaces.end()) |
| 179 | { |
| 180 | it->second->updateInfo(info.intf); |
| 181 | return; |
| 182 | } |
| 183 | } |
William A. Kennington III | 3ee5b7e | 2022-11-15 15:04:37 -0800 | [diff] [blame] | 184 | if (!info.intf.name) |
| 185 | { |
William A. Kennington III | 1d25ca4 | 2023-05-30 16:55:28 -0700 | [diff] [blame] | 186 | lg2::error("Can't create interface without name: {NET_IDX}", "NET_IDX", |
Jagpal Singh Gill | f78a415 | 2023-04-17 21:17:56 -0700 | [diff] [blame] | 187 | info.intf.idx); |
William A. Kennington III | 3ee5b7e | 2022-11-15 15:04:37 -0800 | [diff] [blame] | 188 | return; |
| 189 | } |
William A. Kennington III | f30d560 | 2022-11-13 17:09:55 -0800 | [diff] [blame] | 190 | config::Parser config(config::pathForIntfConf(confDir, *info.intf.name)); |
William A. Kennington III | 80d2901 | 2022-11-12 02:31:40 -0800 | [diff] [blame] | 191 | auto intf = std::make_unique<EthernetInterface>( |
William A. Kennington III | 13d665c | 2022-11-15 20:34:40 -0800 | [diff] [blame] | 192 | bus, *this, info, objPath.str, config, enabled); |
William A. Kennington III | 80d2901 | 2022-11-12 02:31:40 -0800 | [diff] [blame] | 193 | intf->loadNameServers(config); |
| 194 | intf->loadNTPServers(config); |
| 195 | auto ptr = intf.get(); |
William A. Kennington III | f30d560 | 2022-11-13 17:09:55 -0800 | [diff] [blame] | 196 | interfaces.insert_or_assign(*info.intf.name, std::move(intf)); |
| 197 | interfacesByIdx.insert_or_assign(info.intf.idx, ptr); |
William A. Kennington III | 80d2901 | 2022-11-12 02:31:40 -0800 | [diff] [blame] | 198 | } |
| 199 | |
William A. Kennington III | 0813a24 | 2022-11-12 18:07:11 -0800 | [diff] [blame] | 200 | void Manager::addInterface(const InterfaceInfo& info) |
| 201 | { |
William A. Kennington III | 9c441fd | 2023-02-24 13:40:01 -0800 | [diff] [blame] | 202 | if (info.type != ARPHRD_ETHER) |
William A. Kennington III | b800612 | 2022-11-13 18:15:15 -0800 | [diff] [blame] | 203 | { |
William A. Kennington III | 3ee5b7e | 2022-11-15 15:04:37 -0800 | [diff] [blame] | 204 | ignoredIntf.emplace(info.idx); |
William A. Kennington III | b800612 | 2022-11-13 18:15:15 -0800 | [diff] [blame] | 205 | return; |
| 206 | } |
William A. Kennington III | 3ee5b7e | 2022-11-15 15:04:37 -0800 | [diff] [blame] | 207 | if (info.name) |
William A. Kennington III | b800612 | 2022-11-13 18:15:15 -0800 | [diff] [blame] | 208 | { |
William A. Kennington III | 3ee5b7e | 2022-11-15 15:04:37 -0800 | [diff] [blame] | 209 | const auto& ignored = internal::getIgnoredInterfaces(); |
| 210 | if (ignored.find(*info.name) != ignored.end()) |
| 211 | { |
| 212 | static std::unordered_set<std::string> ignored; |
| 213 | if (!ignored.contains(*info.name)) |
| 214 | { |
| 215 | ignored.emplace(*info.name); |
William A. Kennington III | 1d25ca4 | 2023-05-30 16:55:28 -0700 | [diff] [blame] | 216 | lg2::info("Ignoring interface {NET_INTF}", "NET_INTF", |
| 217 | *info.name); |
William A. Kennington III | 3ee5b7e | 2022-11-15 15:04:37 -0800 | [diff] [blame] | 218 | } |
| 219 | ignoredIntf.emplace(info.idx); |
| 220 | return; |
| 221 | } |
William A. Kennington III | b800612 | 2022-11-13 18:15:15 -0800 | [diff] [blame] | 222 | } |
| 223 | |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 224 | auto infoIt = intfInfo.find(info.idx); |
| 225 | if (infoIt != intfInfo.end()) |
William A. Kennington III | 0813a24 | 2022-11-12 18:07:11 -0800 | [diff] [blame] | 226 | { |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 227 | infoIt->second.intf = info; |
William A. Kennington III | 0813a24 | 2022-11-12 18:07:11 -0800 | [diff] [blame] | 228 | } |
| 229 | else |
| 230 | { |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 231 | infoIt = std::get<0>(intfInfo.emplace(info.idx, AllIntfInfo{info})); |
| 232 | } |
| 233 | |
| 234 | if (auto it = systemdNetworkdEnabled.find(info.idx); |
| 235 | it != systemdNetworkdEnabled.end()) |
| 236 | { |
| 237 | createInterface(infoIt->second, it->second); |
William A. Kennington III | 0813a24 | 2022-11-12 18:07:11 -0800 | [diff] [blame] | 238 | } |
| 239 | } |
| 240 | |
| 241 | void Manager::removeInterface(const InterfaceInfo& info) |
| 242 | { |
| 243 | auto iit = interfacesByIdx.find(info.idx); |
| 244 | auto nit = interfaces.end(); |
| 245 | if (info.name) |
| 246 | { |
| 247 | nit = interfaces.find(*info.name); |
| 248 | if (nit != interfaces.end() && iit != interfacesByIdx.end() && |
| 249 | nit->second.get() != iit->second) |
| 250 | { |
William A. Kennington III | b740196 | 2023-07-21 16:36:11 -0700 | [diff] [blame^] | 251 | stdplus::print(stderr, "Removed interface desync detected\n"); |
William A. Kennington III | 0813a24 | 2022-11-12 18:07:11 -0800 | [diff] [blame] | 252 | fflush(stderr); |
| 253 | std::abort(); |
| 254 | } |
| 255 | } |
| 256 | else if (iit != interfacesByIdx.end()) |
| 257 | { |
| 258 | for (nit = interfaces.begin(); nit != interfaces.end(); ++nit) |
| 259 | { |
| 260 | if (nit->second.get() == iit->second) |
| 261 | { |
| 262 | break; |
| 263 | } |
| 264 | } |
| 265 | } |
| 266 | |
| 267 | if (iit != interfacesByIdx.end()) |
| 268 | { |
| 269 | interfacesByIdx.erase(iit); |
| 270 | } |
| 271 | else |
| 272 | { |
William A. Kennington III | 3ee5b7e | 2022-11-15 15:04:37 -0800 | [diff] [blame] | 273 | ignoredIntf.erase(info.idx); |
William A. Kennington III | 0813a24 | 2022-11-12 18:07:11 -0800 | [diff] [blame] | 274 | } |
| 275 | if (nit != interfaces.end()) |
| 276 | { |
| 277 | interfaces.erase(nit); |
| 278 | } |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 279 | intfInfo.erase(info.idx); |
William A. Kennington III | 0813a24 | 2022-11-12 18:07:11 -0800 | [diff] [blame] | 280 | } |
| 281 | |
William A. Kennington III | ed5ff47 | 2022-11-12 16:24:02 -0800 | [diff] [blame] | 282 | void Manager::addAddress(const AddressInfo& info) |
| 283 | { |
William A. Kennington III | 57ca961 | 2022-11-14 15:26:47 -0800 | [diff] [blame] | 284 | if (info.flags & IFA_F_DEPRECATED) |
| 285 | { |
| 286 | return; |
| 287 | } |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 288 | if (auto it = intfInfo.find(info.ifidx); it != intfInfo.end()) |
William A. Kennington III | 57ca961 | 2022-11-14 15:26:47 -0800 | [diff] [blame] | 289 | { |
| 290 | it->second.addrs.insert_or_assign(info.ifaddr, info); |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 291 | if (auto it = interfacesByIdx.find(info.ifidx); |
| 292 | it != interfacesByIdx.end()) |
| 293 | { |
| 294 | it->second->addAddr(info); |
| 295 | } |
William A. Kennington III | 57ca961 | 2022-11-14 15:26:47 -0800 | [diff] [blame] | 296 | } |
William A. Kennington III | 3ee5b7e | 2022-11-15 15:04:37 -0800 | [diff] [blame] | 297 | else if (!ignoredIntf.contains(info.ifidx)) |
William A. Kennington III | 57ca961 | 2022-11-14 15:26:47 -0800 | [diff] [blame] | 298 | { |
| 299 | throw std::runtime_error( |
| 300 | fmt::format("Interface `{}` not found for addr", info.ifidx)); |
| 301 | } |
William A. Kennington III | ed5ff47 | 2022-11-12 16:24:02 -0800 | [diff] [blame] | 302 | } |
| 303 | |
| 304 | void Manager::removeAddress(const AddressInfo& info) |
| 305 | { |
William A. Kennington III | 57ca961 | 2022-11-14 15:26:47 -0800 | [diff] [blame] | 306 | if (auto it = interfacesByIdx.find(info.ifidx); it != interfacesByIdx.end()) |
| 307 | { |
| 308 | it->second->addrs.erase(info.ifaddr); |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 309 | if (auto it = intfInfo.find(info.ifidx); it != intfInfo.end()) |
| 310 | { |
| 311 | it->second.addrs.erase(info.ifaddr); |
| 312 | } |
William A. Kennington III | 57ca961 | 2022-11-14 15:26:47 -0800 | [diff] [blame] | 313 | } |
William A. Kennington III | ed5ff47 | 2022-11-12 16:24:02 -0800 | [diff] [blame] | 314 | } |
| 315 | |
| 316 | void Manager::addNeighbor(const NeighborInfo& info) |
| 317 | { |
William A. Kennington III | 7310ac7 | 2022-11-14 15:44:00 -0800 | [diff] [blame] | 318 | if (!(info.state & NUD_PERMANENT) || !info.addr) |
| 319 | { |
| 320 | return; |
| 321 | } |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 322 | if (auto it = intfInfo.find(info.ifidx); it != intfInfo.end()) |
William A. Kennington III | 7310ac7 | 2022-11-14 15:44:00 -0800 | [diff] [blame] | 323 | { |
| 324 | it->second.staticNeighs.insert_or_assign(*info.addr, info); |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 325 | if (auto it = interfacesByIdx.find(info.ifidx); |
| 326 | it != interfacesByIdx.end()) |
| 327 | { |
| 328 | it->second->addStaticNeigh(info); |
| 329 | } |
William A. Kennington III | 7310ac7 | 2022-11-14 15:44:00 -0800 | [diff] [blame] | 330 | } |
William A. Kennington III | 3ee5b7e | 2022-11-15 15:04:37 -0800 | [diff] [blame] | 331 | else if (!ignoredIntf.contains(info.ifidx)) |
William A. Kennington III | 7310ac7 | 2022-11-14 15:44:00 -0800 | [diff] [blame] | 332 | { |
| 333 | throw std::runtime_error( |
| 334 | fmt::format("Interface `{}` not found for neigh", info.ifidx)); |
| 335 | } |
William A. Kennington III | ed5ff47 | 2022-11-12 16:24:02 -0800 | [diff] [blame] | 336 | } |
| 337 | |
| 338 | void Manager::removeNeighbor(const NeighborInfo& info) |
| 339 | { |
William A. Kennington III | 7310ac7 | 2022-11-14 15:44:00 -0800 | [diff] [blame] | 340 | if (!info.addr) |
William A. Kennington III | ed5ff47 | 2022-11-12 16:24:02 -0800 | [diff] [blame] | 341 | { |
William A. Kennington III | 7310ac7 | 2022-11-14 15:44:00 -0800 | [diff] [blame] | 342 | return; |
| 343 | } |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 344 | if (auto it = intfInfo.find(info.ifidx); it != intfInfo.end()) |
William A. Kennington III | 7310ac7 | 2022-11-14 15:44:00 -0800 | [diff] [blame] | 345 | { |
| 346 | it->second.staticNeighs.erase(*info.addr); |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 347 | if (auto it = interfacesByIdx.find(info.ifidx); |
| 348 | it != interfacesByIdx.end()) |
| 349 | { |
| 350 | it->second->staticNeighbors.erase(*info.addr); |
| 351 | } |
William A. Kennington III | ed5ff47 | 2022-11-12 16:24:02 -0800 | [diff] [blame] | 352 | } |
| 353 | } |
| 354 | |
William A. Kennington III | 9b2a20d | 2023-06-17 14:05:48 -0700 | [diff] [blame] | 355 | void Manager::addDefGw(unsigned ifidx, stdplus::InAnyAddr addr) |
William A. Kennington III | ed5ff47 | 2022-11-12 16:24:02 -0800 | [diff] [blame] | 356 | { |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 357 | if (auto it = intfInfo.find(ifidx); it != intfInfo.end()) |
William A. Kennington III | bb9e909 | 2022-11-14 15:58:02 -0800 | [diff] [blame] | 358 | { |
| 359 | std::visit( |
| 360 | [&](auto addr) { |
William A. Kennington III | 9b2a20d | 2023-06-17 14:05:48 -0700 | [diff] [blame] | 361 | if constexpr (std::is_same_v<stdplus::In4Addr, decltype(addr)>) |
Patrick Williams | 89d734b | 2023-05-10 07:50:25 -0500 | [diff] [blame] | 362 | { |
| 363 | it->second.defgw4.emplace(addr); |
| 364 | } |
Patrick Williams | 89d734b | 2023-05-10 07:50:25 -0500 | [diff] [blame] | 365 | else |
| 366 | { |
William A. Kennington III | 9b2a20d | 2023-06-17 14:05:48 -0700 | [diff] [blame] | 367 | static_assert(std::is_same_v<stdplus::In6Addr, decltype(addr)>); |
| 368 | it->second.defgw6.emplace(addr); |
Patrick Williams | 89d734b | 2023-05-10 07:50:25 -0500 | [diff] [blame] | 369 | } |
William A. Kennington III | bb9e909 | 2022-11-14 15:58:02 -0800 | [diff] [blame] | 370 | }, |
| 371 | addr); |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 372 | if (auto it = interfacesByIdx.find(ifidx); it != interfacesByIdx.end()) |
| 373 | { |
| 374 | std::visit( |
| 375 | [&](auto addr) { |
William A. Kennington III | 9b2a20d | 2023-06-17 14:05:48 -0700 | [diff] [blame] | 376 | if constexpr (std::is_same_v<stdplus::In4Addr, decltype(addr)>) |
Patrick Williams | 89d734b | 2023-05-10 07:50:25 -0500 | [diff] [blame] | 377 | { |
| 378 | it->second->EthernetInterfaceIntf::defaultGateway( |
William A. Kennington III | 9b2a20d | 2023-06-17 14:05:48 -0700 | [diff] [blame] | 379 | stdplus::toStr(addr)); |
Patrick Williams | 89d734b | 2023-05-10 07:50:25 -0500 | [diff] [blame] | 380 | } |
| 381 | else |
| 382 | { |
William A. Kennington III | 9b2a20d | 2023-06-17 14:05:48 -0700 | [diff] [blame] | 383 | static_assert( |
| 384 | std::is_same_v<stdplus::In6Addr, decltype(addr)>); |
| 385 | it->second->EthernetInterfaceIntf::defaultGateway6( |
| 386 | stdplus::toStr(addr)); |
Patrick Williams | 89d734b | 2023-05-10 07:50:25 -0500 | [diff] [blame] | 387 | } |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 388 | }, |
| 389 | addr); |
| 390 | } |
William A. Kennington III | bb9e909 | 2022-11-14 15:58:02 -0800 | [diff] [blame] | 391 | } |
William A. Kennington III | 3ee5b7e | 2022-11-15 15:04:37 -0800 | [diff] [blame] | 392 | else if (!ignoredIntf.contains(ifidx)) |
William A. Kennington III | bb9e909 | 2022-11-14 15:58:02 -0800 | [diff] [blame] | 393 | { |
William A. Kennington III | 1d25ca4 | 2023-05-30 16:55:28 -0700 | [diff] [blame] | 394 | lg2::error("Interface {NET_IDX} not found for gw", "NET_IDX", ifidx); |
William A. Kennington III | bb9e909 | 2022-11-14 15:58:02 -0800 | [diff] [blame] | 395 | } |
William A. Kennington III | ed5ff47 | 2022-11-12 16:24:02 -0800 | [diff] [blame] | 396 | } |
| 397 | |
William A. Kennington III | 9b2a20d | 2023-06-17 14:05:48 -0700 | [diff] [blame] | 398 | void Manager::removeDefGw(unsigned ifidx, stdplus::InAnyAddr addr) |
William A. Kennington III | ed5ff47 | 2022-11-12 16:24:02 -0800 | [diff] [blame] | 399 | { |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 400 | if (auto it = intfInfo.find(ifidx); it != intfInfo.end()) |
William A. Kennington III | bb9e909 | 2022-11-14 15:58:02 -0800 | [diff] [blame] | 401 | { |
| 402 | std::visit( |
| 403 | [&](auto addr) { |
William A. Kennington III | 9b2a20d | 2023-06-17 14:05:48 -0700 | [diff] [blame] | 404 | if constexpr (std::is_same_v<stdplus::In4Addr, decltype(addr)>) |
Patrick Williams | 89d734b | 2023-05-10 07:50:25 -0500 | [diff] [blame] | 405 | { |
| 406 | if (it->second.defgw4 == addr) |
William A. Kennington III | bb9e909 | 2022-11-14 15:58:02 -0800 | [diff] [blame] | 407 | { |
Patrick Williams | 89d734b | 2023-05-10 07:50:25 -0500 | [diff] [blame] | 408 | it->second.defgw4.reset(); |
William A. Kennington III | bb9e909 | 2022-11-14 15:58:02 -0800 | [diff] [blame] | 409 | } |
Patrick Williams | 89d734b | 2023-05-10 07:50:25 -0500 | [diff] [blame] | 410 | } |
William A. Kennington III | 9b2a20d | 2023-06-17 14:05:48 -0700 | [diff] [blame] | 411 | else |
Patrick Williams | 89d734b | 2023-05-10 07:50:25 -0500 | [diff] [blame] | 412 | { |
William A. Kennington III | 9b2a20d | 2023-06-17 14:05:48 -0700 | [diff] [blame] | 413 | static_assert(std::is_same_v<stdplus::In6Addr, decltype(addr)>); |
Patrick Williams | 89d734b | 2023-05-10 07:50:25 -0500 | [diff] [blame] | 414 | if (it->second.defgw6 == addr) |
William A. Kennington III | bb9e909 | 2022-11-14 15:58:02 -0800 | [diff] [blame] | 415 | { |
Patrick Williams | 89d734b | 2023-05-10 07:50:25 -0500 | [diff] [blame] | 416 | it->second.defgw6.reset(); |
William A. Kennington III | bb9e909 | 2022-11-14 15:58:02 -0800 | [diff] [blame] | 417 | } |
Patrick Williams | 89d734b | 2023-05-10 07:50:25 -0500 | [diff] [blame] | 418 | } |
William A. Kennington III | bb9e909 | 2022-11-14 15:58:02 -0800 | [diff] [blame] | 419 | }, |
| 420 | addr); |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 421 | if (auto it = interfacesByIdx.find(ifidx); it != interfacesByIdx.end()) |
| 422 | { |
| 423 | std::visit( |
| 424 | [&](auto addr) { |
William A. Kennington III | 9b2a20d | 2023-06-17 14:05:48 -0700 | [diff] [blame] | 425 | if constexpr (std::is_same_v<stdplus::In4Addr, decltype(addr)>) |
Patrick Williams | 89d734b | 2023-05-10 07:50:25 -0500 | [diff] [blame] | 426 | { |
William A. Kennington III | 9b2a20d | 2023-06-17 14:05:48 -0700 | [diff] [blame] | 427 | stdplus::ToStrHandle<stdplus::ToStr<stdplus::In4Addr>> tsh; |
| 428 | if (it->second->defaultGateway() == tsh(addr)) |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 429 | { |
Patrick Williams | 89d734b | 2023-05-10 07:50:25 -0500 | [diff] [blame] | 430 | it->second->EthernetInterfaceIntf::defaultGateway(""); |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 431 | } |
Patrick Williams | 89d734b | 2023-05-10 07:50:25 -0500 | [diff] [blame] | 432 | } |
William A. Kennington III | 9b2a20d | 2023-06-17 14:05:48 -0700 | [diff] [blame] | 433 | else |
Patrick Williams | 89d734b | 2023-05-10 07:50:25 -0500 | [diff] [blame] | 434 | { |
William A. Kennington III | 9b2a20d | 2023-06-17 14:05:48 -0700 | [diff] [blame] | 435 | static_assert( |
| 436 | std::is_same_v<stdplus::In6Addr, decltype(addr)>); |
| 437 | stdplus::ToStrHandle<stdplus::ToStr<stdplus::In6Addr>> tsh; |
| 438 | if (it->second->defaultGateway6() == tsh(addr)) |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 439 | { |
Patrick Williams | 89d734b | 2023-05-10 07:50:25 -0500 | [diff] [blame] | 440 | it->second->EthernetInterfaceIntf::defaultGateway6(""); |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 441 | } |
Patrick Williams | 89d734b | 2023-05-10 07:50:25 -0500 | [diff] [blame] | 442 | } |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 443 | }, |
| 444 | addr); |
| 445 | } |
William A. Kennington III | bb9e909 | 2022-11-14 15:58:02 -0800 | [diff] [blame] | 446 | } |
William A. Kennington III | ed5ff47 | 2022-11-12 16:24:02 -0800 | [diff] [blame] | 447 | } |
| 448 | |
William A. Kennington III | 085bbdc | 2022-10-05 02:45:37 -0700 | [diff] [blame] | 449 | ObjectPath Manager::vlan(std::string interfaceName, uint32_t id) |
Ratan Gupta | 6811f82 | 2017-04-14 16:34:56 +0530 | [diff] [blame] | 450 | { |
Jiaqing Zhao | b685cb6 | 2022-04-12 22:57:34 +0800 | [diff] [blame] | 451 | if (id == 0 || id >= 4095) |
| 452 | { |
William A. Kennington III | 1d25ca4 | 2023-05-30 16:55:28 -0700 | [diff] [blame] | 453 | lg2::error("VLAN ID {NET_VLAN} is not valid", "NET_VLAN", id); |
Jiaqing Zhao | b685cb6 | 2022-04-12 22:57:34 +0800 | [diff] [blame] | 454 | elog<InvalidArgument>( |
| 455 | Argument::ARGUMENT_NAME("VLANId"), |
| 456 | Argument::ARGUMENT_VALUE(std::to_string(id).c_str())); |
| 457 | } |
| 458 | |
William A. Kennington III | 9644479 | 2022-10-05 15:16:22 -0700 | [diff] [blame] | 459 | auto it = interfaces.find(interfaceName); |
| 460 | if (it == interfaces.end()) |
| 461 | { |
| 462 | using ResourceErr = |
| 463 | phosphor::logging::xyz::openbmc_project::Common::ResourceNotFound; |
| 464 | elog<ResourceNotFound>(ResourceErr::RESOURCE(interfaceName.c_str())); |
| 465 | } |
| 466 | return it->second->createVLAN(id); |
Ratan Gupta | 6811f82 | 2017-04-14 16:34:56 +0530 | [diff] [blame] | 467 | } |
| 468 | |
Michael Tritz | 29f2fd6 | 2017-05-22 15:27:26 -0500 | [diff] [blame] | 469 | void Manager::reset() |
| 470 | { |
William A. Kennington III | 5b17938 | 2022-11-15 15:23:26 -0800 | [diff] [blame] | 471 | for (const auto& dirent : std::filesystem::directory_iterator(confDir)) |
Michael Tritz | 29f2fd6 | 2017-05-22 15:27:26 -0500 | [diff] [blame] | 472 | { |
William A. Kennington III | 5b17938 | 2022-11-15 15:23:26 -0800 | [diff] [blame] | 473 | std::error_code ec; |
| 474 | std::filesystem::remove(dirent.path(), ec); |
Michael Tritz | 29f2fd6 | 2017-05-22 15:27:26 -0500 | [diff] [blame] | 475 | } |
Jagpal Singh Gill | f78a415 | 2023-04-17 21:17:56 -0700 | [diff] [blame] | 476 | lg2::info("Network data purged."); |
Michael Tritz | 29f2fd6 | 2017-05-22 15:27:26 -0500 | [diff] [blame] | 477 | } |
| 478 | |
Ratan Gupta | 4f1c18b | 2017-05-25 12:59:35 +0530 | [diff] [blame] | 479 | // Need to merge the below function with the code which writes the |
| 480 | // config file during factory reset. |
Gunnar Mills | 57d9c50 | 2018-09-14 14:42:34 -0500 | [diff] [blame] | 481 | // TODO openbmc/openbmc#1751 |
Ratan Gupta | 4f1c18b | 2017-05-25 12:59:35 +0530 | [diff] [blame] | 482 | void Manager::writeToConfigurationFile() |
| 483 | { |
| 484 | // write all the static ip address in the systemd-network conf file |
Ratan Gupta | 4f1c18b | 2017-05-25 12:59:35 +0530 | [diff] [blame] | 485 | for (const auto& intf : interfaces) |
| 486 | { |
Ratan Gupta | 2b10653 | 2017-07-25 16:05:02 +0530 | [diff] [blame] | 487 | intf.second->writeConfigurationFile(); |
Ratan Gupta | 4f1c18b | 2017-05-25 12:59:35 +0530 | [diff] [blame] | 488 | } |
Ratan Gupta | e05083a | 2017-09-16 07:12:11 +0530 | [diff] [blame] | 489 | } |
| 490 | |
William A. Kennington III | 80d2901 | 2022-11-12 02:31:40 -0800 | [diff] [blame] | 491 | void Manager::handleAdminState(std::string_view state, unsigned ifidx) |
| 492 | { |
| 493 | if (state == "initialized" || state == "linger") |
| 494 | { |
| 495 | systemdNetworkdEnabled.erase(ifidx); |
| 496 | } |
| 497 | else |
| 498 | { |
| 499 | bool managed = state != "unmanaged"; |
| 500 | systemdNetworkdEnabled.insert_or_assign(ifidx, managed); |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 501 | if (auto it = interfacesByIdx.find(ifidx); it != interfacesByIdx.end()) |
William A. Kennington III | 80d2901 | 2022-11-12 02:31:40 -0800 | [diff] [blame] | 502 | { |
| 503 | it->second->EthernetInterfaceIntf::nicEnabled(managed); |
| 504 | } |
William A. Kennington III | 2fb0c87 | 2022-11-15 19:35:39 -0800 | [diff] [blame] | 505 | else if (auto it = intfInfo.find(ifidx); it != intfInfo.end()) |
| 506 | { |
| 507 | createInterface(it->second, managed); |
| 508 | } |
William A. Kennington III | 80d2901 | 2022-11-12 02:31:40 -0800 | [diff] [blame] | 509 | } |
| 510 | } |
| 511 | |
Gunnar Mills | 57d9c50 | 2018-09-14 14:42:34 -0500 | [diff] [blame] | 512 | } // namespace network |
| 513 | } // namespace phosphor |