1 /*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/
4 This file is part of systemd.
6 Copyright 2013 Tom Gundersen <teg@jklm.no>
8 systemd is free software; you can redistribute it and/or modify it
9 under the terms of the GNU Lesser General Public License as published by
10 the Free Software Foundation; either version 2.1 of the License, or
11 (at your option) any later version.
13 systemd is distributed in the hope that it will be useful, but
14 WITHOUT ANY WARRANTY; without even the implied warranty of
15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
16 Lesser General Public License for more details.
18 You should have received a copy of the GNU Lesser General Public License
19 along with systemd; If not, see <http://www.gnu.org/licenses/>.
24 #include "path-util.h"
26 #include "libudev-private.h"
27 #include "udev-util.h"
30 const char* const network_dirs[] = {
31 "/etc/systemd/network",
32 "/run/systemd/network",
33 "/usr/lib/systemd/network",
34 #ifdef HAVE_SPLIT_USER
35 "/lib/systemd/network",
39 int manager_new(Manager **ret) {
40 _cleanup_manager_free_ Manager *m = NULL;
47 r = sd_event_default(&m->event);
51 sd_event_set_watchdog(m->event, true);
53 r = sd_rtnl_open(RTMGRP_LINK | RTMGRP_IPV4_IFADDR, &m->rtnl);
57 r = sd_bus_default_system(&m->bus);
58 if (r < 0 && r != -ENOENT) /* TODO: drop when we can rely on kdbus */
65 m->udev_monitor = udev_monitor_new_from_netlink(m->udev, "udev");
69 m->links = hashmap_new(uint64_hash_func, uint64_compare_func);
73 m->netdevs = hashmap_new(string_hash_func, string_compare_func);
77 LIST_HEAD_INIT(m->networks);
85 void manager_free(Manager *m) {
90 udev_monitor_unref(m->udev_monitor);
93 sd_event_source_unref(m->udev_event_source);
94 sd_event_unref(m->event);
96 while ((network = m->networks))
97 network_free(network);
99 while ((link = hashmap_first(m->links)))
101 hashmap_free(m->links);
103 while ((netdev = hashmap_first(m->netdevs)))
105 hashmap_free(m->netdevs);
107 sd_rtnl_unref(m->rtnl);
112 int manager_load_config(Manager *m) {
115 /* update timestamp */
116 paths_check_timestamp(network_dirs, &m->network_dirs_ts_usec, true);
129 bool manager_should_reload(Manager *m) {
130 return paths_check_timestamp(network_dirs, &m->network_dirs_ts_usec, false);
133 static int manager_process_link(Manager *m, struct udev_device *device) {
137 if (streq_ptr(udev_device_get_action(device), "remove")) {
140 log_debug("%s: link removed", udev_device_get_sysname(device));
142 ifindex = udev_device_get_ifindex(device);
143 link = hashmap_get(m->links, &ifindex);
149 r = link_add(m, device, &link);
152 log_debug("%s: link already exists, ignoring",
155 log_error("%s: could not handle link: %s",
156 udev_device_get_sysname(device),
159 log_debug("%s: link (with ifindex %" PRIu64") added",
160 link->ifname, link->ifindex);
166 int manager_udev_enumerate_links(Manager *m) {
167 _cleanup_udev_enumerate_unref_ struct udev_enumerate *e = NULL;
168 struct udev_list_entry *item = NULL, *first = NULL;
173 e = udev_enumerate_new(m->udev);
177 r = udev_enumerate_add_match_subsystem(e, "net");
181 r = udev_enumerate_add_match_is_initialized(e);
185 r = udev_enumerate_scan_devices(e);
189 first = udev_enumerate_get_list_entry(e);
190 udev_list_entry_foreach(item, first) {
191 _cleanup_udev_device_unref_ struct udev_device *d = NULL;
194 d = udev_device_new_from_syspath(m->udev, udev_list_entry_get_name(item));
198 k = manager_process_link(m, d);
206 static int manager_dispatch_link_udev(sd_event_source *source, int fd, uint32_t revents, void *userdata) {
207 Manager *m = userdata;
208 struct udev_monitor *monitor = m->udev_monitor;
209 _cleanup_udev_device_unref_ struct udev_device *device = NULL;
211 device = udev_monitor_receive_device(monitor);
215 manager_process_link(m, device);
219 int manager_udev_listen(Manager *m) {
222 r = udev_monitor_filter_add_match_subsystem_devtype(m->udev_monitor, "net", NULL);
224 log_error("Could not add udev monitor filter: %s", strerror(-r));
228 r = udev_monitor_enable_receiving(m->udev_monitor);
230 log_error("Could not enable udev monitor");
234 r = sd_event_add_io(m->event,
235 udev_monitor_get_fd(m->udev_monitor),
236 EPOLLIN, manager_dispatch_link_udev,
237 m, &m->udev_event_source);
244 static int manager_rtnl_process_link(sd_rtnl *rtnl, sd_rtnl_message *message, void *userdata) {
245 Manager *m = userdata;
250 r = sd_rtnl_message_link_get_ifindex(message, &ifindex);
252 log_debug("received RTM_NEWLINK message without valid ifindex");
256 ifindex_64 = ifindex;
257 link = hashmap_get(m->links, &ifindex_64);
259 log_debug("received RTM_NEWLINK message for untracked ifindex %d", ifindex);
263 /* only track the status of links we want to manage */
265 r = link_update(link, message);
269 log_debug("%s: received RTM_NEWLINK message for unmanaged link", link->ifname);
274 int manager_rtnl_listen(Manager *m) {
277 r = sd_rtnl_attach_event(m->rtnl, m->event, 0);
281 r = sd_rtnl_add_match(m->rtnl, RTM_NEWLINK, &manager_rtnl_process_link, m);
288 int manager_bus_listen(Manager *m) {
293 if (!m->bus) /* TODO: drop when we can rely on kdbus */
296 r = sd_bus_attach_event(m->bus, m->event, 0);
303 static void append_dns(FILE *f, struct in_addr *dns, unsigned char family, unsigned *count) {
304 char buf[INET6_ADDRSTRLEN];
307 address = inet_ntop(family, dns, buf, INET6_ADDRSTRLEN);
309 log_warning("Invalid DNS address. Ignoring.");
314 fputs("# Too many DNS servers configured, the following entries "
315 "will be ignored\n", f);
317 fprintf(f, "nameserver %s\n", address);
322 int manager_update_resolv_conf(Manager *m) {
323 _cleanup_free_ char *temp_path = NULL;
324 _cleanup_fclose_ FILE *f = NULL;
328 const char *domainname = NULL;
333 r = mkdir_safe_label("/run/systemd/network", 0755, 0, 0);
337 r = fopen_temporary("/run/systemd/network/resolv.conf", &f, &temp_path);
341 fchmod(fileno(f), 0644);
343 fputs("# This file is managed by systemd-networkd(8). Do not edit.\n#\n"
344 "# Third party programs must not access this file directly, but\n"
345 "# only through the symlink at /etc/resolv.conf. To manage\n"
346 "# resolv.conf(5) in a different way, replace the symlink by a\n"
347 "# static file or a different symlink.\n\n", f);
349 HASHMAP_FOREACH(link, m->links, i) {
351 struct in_addr *nameservers;
352 size_t nameservers_size;
354 if (link->network->dhcp_dns) {
355 r = sd_dhcp_client_get_dns(link->dhcp, &nameservers, &nameservers_size);
359 for (j = 0; j < nameservers_size; j++)
360 append_dns(f, &nameservers[j], AF_INET, &count);
364 if (link->network->dhcp_domainname && !domainname) {
365 r = sd_dhcp_client_get_domainname(link->dhcp, &domainname);
367 fprintf(f, "domain %s\n", domainname);
372 HASHMAP_FOREACH(link, m->links, i)
373 if (link->network && link->network->dns)
374 append_dns(f, &link->network->dns->in_addr.in,
375 link->network->dns->family, &count);
379 if (ferror(f) || rename(temp_path, "/run/systemd/network/resolv.conf") < 0) {
381 unlink("/run/systemd/network/resolv.conf");