Ratan Gupta | a54d8f8 | 2017-09-08 17:05:46 +0530 | [diff] [blame] | 1 | #include "config.h" |
Gunnar Mills | 57d9c50 | 2018-09-14 14:42:34 -0500 | [diff] [blame] | 2 | |
Patrick Venture | 189d44e | 2018-07-09 12:30:59 -0700 | [diff] [blame] | 3 | #include "dns_updater.hpp" |
Ratan Gupta | 0f9dc1b | 2017-09-03 17:57:50 +0530 | [diff] [blame] | 4 | #include "network_manager.hpp" |
| 5 | #include "rtnetlink_server.hpp" |
William A. Kennington III | 3a70fa2 | 2018-09-20 18:48:20 -0700 | [diff] [blame^] | 6 | #include "types.hpp" |
Vishwanatha Subbanna | 18891c6 | 2017-10-17 15:22:46 +0530 | [diff] [blame] | 7 | #include "watch.hpp" |
Ratan Gupta | 0f9dc1b | 2017-09-03 17:57:50 +0530 | [diff] [blame] | 8 | |
Ratan Gupta | f665738 | 2017-11-10 17:58:17 +0530 | [diff] [blame] | 9 | #include <linux/netlink.h> |
Ratan Gupta | 0f9dc1b | 2017-09-03 17:57:50 +0530 | [diff] [blame] | 10 | |
William A. Kennington III | 3a70fa2 | 2018-09-20 18:48:20 -0700 | [diff] [blame^] | 11 | #include <functional> |
Ratan Gupta | f665738 | 2017-11-10 17:58:17 +0530 | [diff] [blame] | 12 | #include <memory> |
| 13 | #include <phosphor-logging/elog-errors.hpp> |
Ratan Gupta | 0f9dc1b | 2017-09-03 17:57:50 +0530 | [diff] [blame] | 14 | #include <phosphor-logging/log.hpp> |
Ratan Gupta | cb7098d | 2017-04-14 17:46:05 +0530 | [diff] [blame] | 15 | #include <sdbusplus/bus.hpp> |
| 16 | #include <sdbusplus/server/manager.hpp> |
William A. Kennington III | 3a70fa2 | 2018-09-20 18:48:20 -0700 | [diff] [blame^] | 17 | #include <sdeventplus/event.hpp> |
Ratan Gupta | f665738 | 2017-11-10 17:58:17 +0530 | [diff] [blame] | 18 | #include <xyz/openbmc_project/Common/error.hpp> |
Ratan Gupta | 0f9dc1b | 2017-09-03 17:57:50 +0530 | [diff] [blame] | 19 | |
| 20 | namespace phosphor |
| 21 | { |
| 22 | namespace network |
| 23 | { |
| 24 | |
| 25 | std::unique_ptr<phosphor::network::Manager> manager = nullptr; |
William A. Kennington III | 3a70fa2 | 2018-09-20 18:48:20 -0700 | [diff] [blame^] | 26 | std::unique_ptr<Timer> refreshObjectTimer = nullptr; |
| 27 | std::unique_ptr<Timer> restartTimer = nullptr; |
Ratan Gupta | a54d8f8 | 2017-09-08 17:05:46 +0530 | [diff] [blame] | 28 | |
Ratan Gupta | 16f1288 | 2017-09-22 18:26:11 +0530 | [diff] [blame] | 29 | /** @brief refresh the network objects. */ |
Ratan Gupta | a54d8f8 | 2017-09-08 17:05:46 +0530 | [diff] [blame] | 30 | void refreshObjects() |
| 31 | { |
Ratan Gupta | 310a0b1 | 2017-11-15 17:40:24 +0530 | [diff] [blame] | 32 | using namespace phosphor::logging; |
Ratan Gupta | 16f1288 | 2017-09-22 18:26:11 +0530 | [diff] [blame] | 33 | if (manager) |
| 34 | { |
Ratan Gupta | 310a0b1 | 2017-11-15 17:40:24 +0530 | [diff] [blame] | 35 | log<level::INFO>("Refreshing the objects."); |
Ratan Gupta | 16f1288 | 2017-09-22 18:26:11 +0530 | [diff] [blame] | 36 | manager->createChildObjects(); |
Ratan Gupta | 310a0b1 | 2017-11-15 17:40:24 +0530 | [diff] [blame] | 37 | log<level::INFO>("Refreshing complete."); |
Ratan Gupta | 16f1288 | 2017-09-22 18:26:11 +0530 | [diff] [blame] | 38 | } |
| 39 | } |
| 40 | |
| 41 | /** @brief restart the systemd networkd. */ |
| 42 | void restartNetwork() |
| 43 | { |
| 44 | restartSystemdUnit("systemd-networkd.service"); |
Ratan Gupta | a54d8f8 | 2017-09-08 17:05:46 +0530 | [diff] [blame] | 45 | } |
Ratan Gupta | 0f9dc1b | 2017-09-03 17:57:50 +0530 | [diff] [blame] | 46 | |
Ratan Gupta | 16f1288 | 2017-09-22 18:26:11 +0530 | [diff] [blame] | 47 | void initializeTimers() |
| 48 | { |
William A. Kennington III | 3a70fa2 | 2018-09-20 18:48:20 -0700 | [diff] [blame^] | 49 | auto event = sdeventplus::Event::get_default(); |
| 50 | refreshObjectTimer = |
| 51 | std::make_unique<Timer>(event, std::bind(refreshObjects)); |
| 52 | restartTimer = std::make_unique<Timer>(event, std::bind(restartNetwork)); |
Ratan Gupta | 16f1288 | 2017-09-22 18:26:11 +0530 | [diff] [blame] | 53 | } |
| 54 | |
William A. Kennington III | 3a70fa2 | 2018-09-20 18:48:20 -0700 | [diff] [blame^] | 55 | } // namespace network |
| 56 | } // namespace phosphor |
| 57 | |
Ratan Gupta | f665738 | 2017-11-10 17:58:17 +0530 | [diff] [blame] | 58 | void createNetLinkSocket(phosphor::Descriptor& smartSock) |
| 59 | { |
| 60 | using namespace phosphor::logging; |
Gunnar Mills | 57d9c50 | 2018-09-14 14:42:34 -0500 | [diff] [blame] | 61 | using InternalFailure = |
| 62 | sdbusplus::xyz::openbmc_project::Common::Error::InternalFailure; |
| 63 | // RtnetLink socket |
Ratan Gupta | f665738 | 2017-11-10 17:58:17 +0530 | [diff] [blame] | 64 | auto fd = socket(PF_NETLINK, SOCK_RAW | SOCK_NONBLOCK, NETLINK_ROUTE); |
| 65 | if (fd < 0) |
| 66 | { |
| 67 | auto r = -errno; |
| 68 | log<level::ERR>("Unable to create the net link socket", |
| 69 | entry("ERRNO=%d", r)); |
| 70 | elog<InternalFailure>(); |
| 71 | } |
| 72 | smartSock.set(fd); |
| 73 | } |
| 74 | |
Gunnar Mills | 57d9c50 | 2018-09-14 14:42:34 -0500 | [diff] [blame] | 75 | int main(int argc, char* argv[]) |
Ratan Gupta | 8c83493 | 2017-04-14 16:30:24 +0530 | [diff] [blame] | 76 | { |
Ratan Gupta | 0f9dc1b | 2017-09-03 17:57:50 +0530 | [diff] [blame] | 77 | using namespace phosphor::logging; |
| 78 | |
William A. Kennington III | 3a70fa2 | 2018-09-20 18:48:20 -0700 | [diff] [blame^] | 79 | phosphor::network::initializeTimers(); |
Ratan Gupta | a54d8f8 | 2017-09-08 17:05:46 +0530 | [diff] [blame] | 80 | |
Ratan Gupta | cb7098d | 2017-04-14 17:46:05 +0530 | [diff] [blame] | 81 | auto bus = sdbusplus::bus::new_default(); |
| 82 | |
Ratan Gupta | 0f9dc1b | 2017-09-03 17:57:50 +0530 | [diff] [blame] | 83 | // Need sd_event to watch for OCC device errors |
| 84 | sd_event* event = nullptr; |
| 85 | auto r = sd_event_default(&event); |
| 86 | if (r < 0) |
| 87 | { |
| 88 | log<level::ERR>("Error creating a default sd_event handler"); |
| 89 | return r; |
| 90 | } |
| 91 | |
| 92 | phosphor::network::EventPtr eventPtr{event}; |
| 93 | event = nullptr; |
| 94 | |
| 95 | // Attach the bus to sd_event to service user requests |
| 96 | bus.attach_event(eventPtr.get(), SD_EVENT_PRIORITY_NORMAL); |
| 97 | |
Ratan Gupta | cb7098d | 2017-04-14 17:46:05 +0530 | [diff] [blame] | 98 | // Add sdbusplus Object Manager for the 'root' path of the network manager. |
| 99 | sdbusplus::server::manager::manager objManager(bus, OBJ_NETWORK); |
Ratan Gupta | 26e87a0 | 2017-08-18 01:08:40 +0530 | [diff] [blame] | 100 | bus.request_name(BUSNAME_NETWORK); |
Ratan Gupta | cb7098d | 2017-04-14 17:46:05 +0530 | [diff] [blame] | 101 | |
Gunnar Mills | 57d9c50 | 2018-09-14 14:42:34 -0500 | [diff] [blame] | 102 | phosphor::network::manager = std::make_unique<phosphor::network::Manager>( |
| 103 | bus, OBJ_NETWORK, NETWORK_CONF_DIR); |
Ratan Gupta | cb7098d | 2017-04-14 17:46:05 +0530 | [diff] [blame] | 104 | |
Ratan Gupta | b610caf | 2017-09-19 09:33:51 +0530 | [diff] [blame] | 105 | // create the default network files if the network file |
| 106 | // is not there for any interface. |
| 107 | // Parameter false means don't create the network |
| 108 | // files forcefully. |
| 109 | if (phosphor::network::manager->createDefaultNetworkFiles(false)) |
| 110 | { |
| 111 | // if files created restart the network. |
| 112 | // don't need to call the create child objects as eventhandler |
| 113 | // will create it. |
Ratan Gupta | 16f1288 | 2017-09-22 18:26:11 +0530 | [diff] [blame] | 114 | phosphor::network::restartNetwork(); |
Ratan Gupta | b610caf | 2017-09-19 09:33:51 +0530 | [diff] [blame] | 115 | } |
Ratan Gupta | e962941 | 2017-12-21 08:20:25 +0530 | [diff] [blame] | 116 | else |
| 117 | { |
| 118 | // this will add the additional fixes which is needed |
| 119 | // in the existing network file. |
| 120 | phosphor::network::manager->writeToConfigurationFile(); |
Ratan Gupta | 2939f18 | 2018-02-14 23:14:54 +0530 | [diff] [blame] | 121 | // whenever the configuration file gets written it restart |
| 122 | // the network which creates the network objects |
Ratan Gupta | e962941 | 2017-12-21 08:20:25 +0530 | [diff] [blame] | 123 | } |
Vishwanatha Subbanna | 18891c6 | 2017-10-17 15:22:46 +0530 | [diff] [blame] | 124 | |
Gunnar Mills | 57d9c50 | 2018-09-14 14:42:34 -0500 | [diff] [blame] | 125 | // RtnetLink socket |
Ratan Gupta | f665738 | 2017-11-10 17:58:17 +0530 | [diff] [blame] | 126 | phosphor::Descriptor smartSock; |
| 127 | createNetLinkSocket(smartSock); |
| 128 | |
Vishwanatha Subbanna | 18891c6 | 2017-10-17 15:22:46 +0530 | [diff] [blame] | 129 | // RTNETLINK event handler |
Ratan Gupta | f665738 | 2017-11-10 17:58:17 +0530 | [diff] [blame] | 130 | phosphor::network::rtnetlink::Server svr(eventPtr, smartSock); |
Vishwanatha Subbanna | 18891c6 | 2017-10-17 15:22:46 +0530 | [diff] [blame] | 131 | |
| 132 | // DNS entry handler |
Gunnar Mills | 57d9c50 | 2018-09-14 14:42:34 -0500 | [diff] [blame] | 133 | phosphor::network::inotify::Watch watch( |
| 134 | eventPtr, DNS_ENTRY_FILE, |
| 135 | std::bind(&phosphor::network::dns::updater::processDNSEntries, |
| 136 | std::placeholders::_1)); |
Vishwanatha Subbanna | 18891c6 | 2017-10-17 15:22:46 +0530 | [diff] [blame] | 137 | |
| 138 | // At this point, we have registered for the notifications for future |
| 139 | // events. However, if the file is already populated before this, then |
| 140 | // they won't ever get notified and thus we need to read once before |
| 141 | // waiting on change events |
| 142 | phosphor::network::dns::updater::processDNSEntries(DNS_ENTRY_FILE); |
| 143 | |
Vishwanatha Subbanna | 18891c6 | 2017-10-17 15:22:46 +0530 | [diff] [blame] | 144 | sd_event_loop(eventPtr.get()); |
Ratan Gupta | 8c83493 | 2017-04-14 16:30:24 +0530 | [diff] [blame] | 145 | } |