1 /* SPDX-License-Identifier: LGPL-2.1-or-later */
3 #include <netinet/in.h>
4 #include <sys/socket.h>
7 #include <linux/fib_rules.h>
8 #include <linux/nexthop.h>
9 #include <linux/nl80211.h>
11 #include "sd-netlink.h"
13 #include "alloc-util.h"
14 #include "bus-error.h"
15 #include "bus-locator.h"
16 #include "bus-log-control-api.h"
17 #include "bus-polkit.h"
19 #include "common-signal.h"
20 #include "conf-parser.h"
21 #include "constants.h"
22 #include "daemon-util.h"
23 #include "device-private.h"
24 #include "device-util.h"
25 #include "dns-domain.h"
29 #include "firewall-util.h"
31 #include "initrd-util.h"
32 #include "local-addresses.h"
33 #include "netlink-util.h"
34 #include "network-internal.h"
35 #include "networkd-address-pool.h"
36 #include "networkd-address.h"
37 #include "networkd-dhcp-server-bus.h"
38 #include "networkd-dhcp6.h"
39 #include "networkd-link-bus.h"
40 #include "networkd-manager.h"
41 #include "networkd-manager-bus.h"
42 #include "networkd-manager-varlink.h"
43 #include "networkd-neighbor.h"
44 #include "networkd-network-bus.h"
45 #include "networkd-nexthop.h"
46 #include "networkd-queue.h"
47 #include "networkd-route.h"
48 #include "networkd-routing-policy-rule.h"
49 #include "networkd-speed-meter.h"
50 #include "networkd-state-file.h"
51 #include "networkd-wifi.h"
52 #include "networkd-wiphy.h"
53 #include "ordered-set.h"
54 #include "path-lookup.h"
55 #include "path-util.h"
57 #include "selinux-util.h"
59 #include "signal-util.h"
60 #include "stat-util.h"
62 #include "sysctl-util.h"
64 #include "tmpfile-util.h"
66 #include "udev-util.h"
68 /* use 128 MB for receive socket kernel queue. */
69 #define RCVBUF_SIZE (128*1024*1024)
71 static int match_prepare_for_sleep(sd_bus_message
*message
, void *userdata
, sd_bus_error
*ret_error
) {
72 Manager
*m
= ASSERT_PTR(userdata
);
78 r
= sd_bus_message_read(message
, "b", &b
);
80 bus_log_parse_error(r
);
87 log_debug("Coming back from suspend, reconfiguring all connections...");
89 HASHMAP_FOREACH(link
, m
->links_by_index
) {
90 r
= link_reconfigure(link
, /* force = */ true);
92 log_link_warning_errno(link
, r
, "Failed to reconfigure interface: %m");
93 link_enter_failed(link
);
100 static int on_connected(sd_bus_message
*message
, void *userdata
, sd_bus_error
*ret_error
) {
101 Manager
*m
= ASSERT_PTR(userdata
);
105 /* Did we get a timezone or transient hostname from DHCP while D-Bus wasn't up yet? */
106 if (m
->dynamic_hostname
)
107 (void) manager_set_hostname(m
, m
->dynamic_hostname
);
108 if (m
->dynamic_timezone
)
109 (void) manager_set_timezone(m
, m
->dynamic_timezone
);
110 if (m
->product_uuid_requested
)
111 (void) manager_request_product_uuid(m
);
116 static int manager_connect_bus(Manager
*m
) {
122 r
= bus_open_system_watch_bind_with_description(&m
->bus
, "bus-api-network");
124 return log_error_errno(r
, "Failed to connect to bus: %m");
126 r
= bus_add_implementation(m
->bus
, &manager_object
, m
);
130 r
= bus_log_control_api_register(m
->bus
);
134 r
= sd_bus_request_name_async(m
->bus
, NULL
, "org.freedesktop.network1", 0, NULL
, NULL
);
136 return log_error_errno(r
, "Failed to request name: %m");
138 r
= sd_bus_attach_event(m
->bus
, m
->event
, 0);
140 return log_error_errno(r
, "Failed to attach bus to event loop: %m");
142 r
= sd_bus_match_signal_async(
145 "org.freedesktop.DBus.Local",
147 "org.freedesktop.DBus.Local",
149 on_connected
, NULL
, m
);
151 return log_error_errno(r
, "Failed to request match on Connected signal: %m");
153 r
= bus_match_signal_async(
158 match_prepare_for_sleep
, NULL
, m
);
160 log_warning_errno(r
, "Failed to request match for PrepareForSleep, ignoring: %m");
165 static int manager_process_uevent(sd_device_monitor
*monitor
, sd_device
*device
, void *userdata
) {
166 Manager
*m
= ASSERT_PTR(userdata
);
167 sd_device_action_t action
;
172 r
= sd_device_get_action(device
, &action
);
174 return log_device_warning_errno(device
, r
, "Failed to get udev action, ignoring: %m");
176 if (device_in_subsystem(device
, "net"))
177 r
= manager_udev_process_link(m
, device
, action
);
178 else if (device_in_subsystem(device
, "ieee80211"))
179 r
= manager_udev_process_wiphy(m
, device
, action
);
180 else if (device_in_subsystem(device
, "rfkill"))
181 r
= manager_udev_process_rfkill(m
, device
, action
);
183 log_device_warning_errno(device
, r
, "Failed to process \"%s\" uevent, ignoring: %m",
184 device_action_to_string(action
));
189 static int manager_connect_udev(Manager
*m
) {
192 /* udev does not initialize devices inside containers, so we rely on them being already
193 * initialized before entering the container. */
194 if (!udev_available())
197 r
= sd_device_monitor_new(&m
->device_monitor
);
199 return log_error_errno(r
, "Failed to initialize device monitor: %m");
201 r
= sd_device_monitor_filter_add_match_subsystem_devtype(m
->device_monitor
, "net", NULL
);
203 return log_error_errno(r
, "Could not add device monitor filter for net subsystem: %m");
205 r
= sd_device_monitor_filter_add_match_subsystem_devtype(m
->device_monitor
, "ieee80211", NULL
);
207 return log_error_errno(r
, "Could not add device monitor filter for ieee80211 subsystem: %m");
209 r
= sd_device_monitor_filter_add_match_subsystem_devtype(m
->device_monitor
, "rfkill", NULL
);
211 return log_error_errno(r
, "Could not add device monitor filter for rfkill subsystem: %m");
213 r
= sd_device_monitor_attach_event(m
->device_monitor
, m
->event
);
215 return log_error_errno(r
, "Failed to attach event to device monitor: %m");
217 r
= sd_device_monitor_start(m
->device_monitor
, manager_process_uevent
, m
);
219 return log_error_errno(r
, "Failed to start device monitor: %m");
224 static int manager_listen_fds(Manager
*m
, int *ret_rtnl_fd
) {
225 _cleanup_strv_free_
char **names
= NULL
;
226 int n
, rtnl_fd
= -EBADF
;
231 n
= sd_listen_fds_with_names(/* unset_environment = */ true, &names
);
235 if (strv_length(names
) != (size_t) n
)
238 for (int i
= 0; i
< n
; i
++) {
239 int fd
= i
+ SD_LISTEN_FDS_START
;
241 if (sd_is_socket(fd
, AF_NETLINK
, SOCK_RAW
, -1) > 0) {
243 log_debug("Received multiple netlink socket, ignoring.");
252 if (manager_add_tuntap_fd(m
, fd
, names
[i
]) >= 0)
258 close_and_notify_warn(fd
, names
[i
]);
261 *ret_rtnl_fd
= rtnl_fd
;
265 static int manager_connect_genl(Manager
*m
) {
270 r
= sd_genl_socket_open(&m
->genl
);
274 r
= sd_netlink_increase_rxbuf(m
->genl
, RCVBUF_SIZE
);
276 log_warning_errno(r
, "Failed to increase receive buffer size for general netlink socket, ignoring: %m");
278 r
= sd_netlink_attach_event(m
->genl
, m
->event
, 0);
282 r
= genl_add_match(m
->genl
, NULL
, NL80211_GENL_NAME
, NL80211_MULTICAST_GROUP_CONFIG
, 0,
283 &manager_genl_process_nl80211_config
, NULL
, m
, "network-genl_process_nl80211_config");
284 if (r
< 0 && r
!= -EOPNOTSUPP
)
287 r
= genl_add_match(m
->genl
, NULL
, NL80211_GENL_NAME
, NL80211_MULTICAST_GROUP_MLME
, 0,
288 &manager_genl_process_nl80211_mlme
, NULL
, m
, "network-genl_process_nl80211_mlme");
289 if (r
< 0 && r
!= -EOPNOTSUPP
)
295 static int manager_setup_rtnl_filter(Manager
*manager
) {
296 struct sock_filter filter
[] = {
297 /* Check the packet length. */
298 BPF_STMT(BPF_LD
+ BPF_W
+ BPF_LEN
, 0), /* A <- packet length */
299 BPF_JUMP(BPF_JMP
+ BPF_JGE
+ BPF_K
, sizeof(struct nlmsghdr
), 1, 0), /* A (packet length) >= sizeof(struct nlmsghdr) ? */
300 BPF_STMT(BPF_RET
+ BPF_K
, 0), /* reject */
301 /* Always accept multipart message. */
302 BPF_STMT(BPF_LD
+ BPF_H
+ BPF_ABS
, offsetof(struct nlmsghdr
, nlmsg_flags
)), /* A <- message flags */
303 BPF_JUMP(BPF_JMP
+ BPF_JSET
+ BPF_K
, htobe16(NLM_F_MULTI
), 0, 1), /* message flags has NLM_F_MULTI ? */
304 BPF_STMT(BPF_RET
+ BPF_K
, UINT32_MAX
), /* accept */
305 /* Accept all message types except for RTM_NEWNEIGH or RTM_DELNEIGH. */
306 BPF_STMT(BPF_LD
+ BPF_H
+ BPF_ABS
, offsetof(struct nlmsghdr
, nlmsg_type
)), /* A <- message type */
307 BPF_JUMP(BPF_JMP
+ BPF_JEQ
+ BPF_K
, htobe16(RTM_NEWNEIGH
), 2, 0), /* message type == RTM_NEWNEIGH ? */
308 BPF_JUMP(BPF_JMP
+ BPF_JEQ
+ BPF_K
, htobe16(RTM_DELNEIGH
), 1, 0), /* message type == RTM_DELNEIGH ? */
309 BPF_STMT(BPF_RET
+ BPF_K
, UINT32_MAX
), /* accept */
310 /* Check the packet length. */
311 BPF_STMT(BPF_LD
+ BPF_W
+ BPF_LEN
, 0), /* A <- packet length */
312 BPF_JUMP(BPF_JMP
+ BPF_JGE
+ BPF_K
, sizeof(struct nlmsghdr
) + sizeof(struct ndmsg
), 1, 0),
313 /* packet length >= sizeof(struct nlmsghdr) + sizeof(struct ndmsg) ? */
314 BPF_STMT(BPF_RET
+ BPF_K
, 0), /* reject */
315 /* Reject the message when the neighbor state does not have NUD_PERMANENT flag. */
316 BPF_STMT(BPF_LD
+ BPF_H
+ BPF_ABS
, sizeof(struct nlmsghdr
) + offsetof(struct ndmsg
, ndm_state
)),
317 /* A <- neighbor state */
318 BPF_JUMP(BPF_JMP
+ BPF_JSET
+ BPF_K
, htobe16(NUD_PERMANENT
), 1, 0), /* neighbor state has NUD_PERMANENT ? */
319 BPF_STMT(BPF_RET
+ BPF_K
, 0), /* reject */
320 BPF_STMT(BPF_RET
+ BPF_K
, UINT32_MAX
), /* accept */
324 assert(manager
->rtnl
);
326 return sd_netlink_attach_filter(manager
->rtnl
, ELEMENTSOF(filter
), filter
);
329 static int manager_connect_rtnl(Manager
*m
, int fd
) {
330 _unused_ _cleanup_close_
int fd_close
= fd
;
335 /* This takes input fd. */
338 r
= sd_netlink_open(&m
->rtnl
);
340 r
= sd_netlink_open_fd(&m
->rtnl
, fd
);
345 /* Bump receiver buffer, but only if we are not called via socket activation, as in that
346 * case systemd sets the receive buffer size for us, and the value in the .socket unit
347 * should take full effect. */
349 r
= sd_netlink_increase_rxbuf(m
->rtnl
, RCVBUF_SIZE
);
351 log_warning_errno(r
, "Failed to increase receive buffer size for rtnl socket, ignoring: %m");
354 r
= sd_netlink_attach_event(m
->rtnl
, m
->event
, 0);
358 r
= netlink_add_match(m
->rtnl
, NULL
, RTM_NEWLINK
, &manager_rtnl_process_link
, NULL
, m
, "network-rtnl_process_link");
362 r
= netlink_add_match(m
->rtnl
, NULL
, RTM_DELLINK
, &manager_rtnl_process_link
, NULL
, m
, "network-rtnl_process_link");
366 r
= netlink_add_match(m
->rtnl
, NULL
, RTM_NEWQDISC
, &manager_rtnl_process_qdisc
, NULL
, m
, "network-rtnl_process_qdisc");
370 r
= netlink_add_match(m
->rtnl
, NULL
, RTM_DELQDISC
, &manager_rtnl_process_qdisc
, NULL
, m
, "network-rtnl_process_qdisc");
374 r
= netlink_add_match(m
->rtnl
, NULL
, RTM_NEWTCLASS
, &manager_rtnl_process_tclass
, NULL
, m
, "network-rtnl_process_tclass");
378 r
= netlink_add_match(m
->rtnl
, NULL
, RTM_DELTCLASS
, &manager_rtnl_process_tclass
, NULL
, m
, "network-rtnl_process_tclass");
382 r
= netlink_add_match(m
->rtnl
, NULL
, RTM_NEWADDR
, &manager_rtnl_process_address
, NULL
, m
, "network-rtnl_process_address");
386 r
= netlink_add_match(m
->rtnl
, NULL
, RTM_DELADDR
, &manager_rtnl_process_address
, NULL
, m
, "network-rtnl_process_address");
390 r
= netlink_add_match(m
->rtnl
, NULL
, RTM_NEWNEIGH
, &manager_rtnl_process_neighbor
, NULL
, m
, "network-rtnl_process_neighbor");
394 r
= netlink_add_match(m
->rtnl
, NULL
, RTM_DELNEIGH
, &manager_rtnl_process_neighbor
, NULL
, m
, "network-rtnl_process_neighbor");
398 r
= netlink_add_match(m
->rtnl
, NULL
, RTM_NEWROUTE
, &manager_rtnl_process_route
, NULL
, m
, "network-rtnl_process_route");
402 r
= netlink_add_match(m
->rtnl
, NULL
, RTM_DELROUTE
, &manager_rtnl_process_route
, NULL
, m
, "network-rtnl_process_route");
406 r
= netlink_add_match(m
->rtnl
, NULL
, RTM_NEWRULE
, &manager_rtnl_process_rule
, NULL
, m
, "network-rtnl_process_rule");
410 r
= netlink_add_match(m
->rtnl
, NULL
, RTM_DELRULE
, &manager_rtnl_process_rule
, NULL
, m
, "network-rtnl_process_rule");
414 r
= netlink_add_match(m
->rtnl
, NULL
, RTM_NEWNEXTHOP
, &manager_rtnl_process_nexthop
, NULL
, m
, "network-rtnl_process_nexthop");
418 r
= netlink_add_match(m
->rtnl
, NULL
, RTM_DELNEXTHOP
, &manager_rtnl_process_nexthop
, NULL
, m
, "network-rtnl_process_nexthop");
422 return manager_setup_rtnl_filter(m
);
425 static int manager_post_handler(sd_event_source
*s
, void *userdata
) {
426 Manager
*manager
= ASSERT_PTR(userdata
);
428 (void) manager_process_remove_requests(manager
);
429 (void) manager_process_requests(manager
);
430 (void) manager_clean_all(manager
);
434 static int signal_terminate_callback(sd_event_source
*s
, const struct signalfd_siginfo
*si
, void *userdata
) {
435 Manager
*m
= ASSERT_PTR(userdata
);
437 m
->restarting
= false;
439 log_debug("Terminate operation initiated.");
441 return sd_event_exit(sd_event_source_get_event(s
), 0);
444 static int signal_restart_callback(sd_event_source
*s
, const struct signalfd_siginfo
*si
, void *userdata
) {
445 Manager
*m
= ASSERT_PTR(userdata
);
447 m
->restarting
= true;
449 log_debug("Restart operation initiated.");
451 return sd_event_exit(sd_event_source_get_event(s
), 0);
454 static int signal_reload_callback(sd_event_source
*s
, const struct signalfd_siginfo
*si
, void *userdata
) {
455 Manager
*m
= ASSERT_PTR(userdata
);
457 (void) manager_reload(m
, /* message = */ NULL
);
462 static int manager_set_keep_configuration(Manager
*m
) {
468 log_debug("Running in initrd, keep DHCPv4 addresses on stopping networkd by default.");
469 m
->keep_configuration
= KEEP_CONFIGURATION_DHCP_ON_STOP
;
473 r
= path_is_network_fs("/");
475 return log_error_errno(r
, "Failed to detect if root is network filesystem: %m");
477 m
->keep_configuration
= _KEEP_CONFIGURATION_INVALID
;
481 log_debug("Running on network filesystem, enabling KeepConfiguration= by default.");
482 m
->keep_configuration
= KEEP_CONFIGURATION_YES
;
486 int manager_setup(Manager
*m
) {
487 _cleanup_close_
int rtnl_fd
= -EBADF
;
492 r
= sd_event_default(&m
->event
);
496 (void) sd_event_set_watchdog(m
->event
, true);
497 (void) sd_event_add_signal(m
->event
, NULL
, SIGTERM
| SD_EVENT_SIGNAL_PROCMASK
, signal_terminate_callback
, m
);
498 (void) sd_event_add_signal(m
->event
, NULL
, SIGINT
| SD_EVENT_SIGNAL_PROCMASK
, signal_terminate_callback
, m
);
499 (void) sd_event_add_signal(m
->event
, NULL
, SIGUSR2
| SD_EVENT_SIGNAL_PROCMASK
, signal_restart_callback
, m
);
500 (void) sd_event_add_signal(m
->event
, NULL
, SIGHUP
| SD_EVENT_SIGNAL_PROCMASK
, signal_reload_callback
, m
);
501 (void) sd_event_add_signal(m
->event
, NULL
, (SIGRTMIN
+18) | SD_EVENT_SIGNAL_PROCMASK
, sigrtmin18_handler
, NULL
);
503 r
= sd_event_add_memory_pressure(m
->event
, NULL
, NULL
, NULL
);
505 log_debug_errno(r
, "Failed allocate memory pressure event source, ignoring: %m");
507 r
= sd_event_add_post(m
->event
, NULL
, manager_post_handler
, m
);
511 r
= manager_listen_fds(m
, &rtnl_fd
);
515 r
= manager_connect_rtnl(m
, TAKE_FD(rtnl_fd
));
519 r
= manager_connect_genl(m
);
526 r
= manager_connect_varlink(m
);
530 r
= manager_connect_bus(m
);
534 r
= manager_connect_udev(m
);
538 r
= sd_resolve_default(&m
->resolve
);
542 r
= sd_resolve_attach_event(m
->resolve
, m
->event
, 0);
546 r
= address_pool_setup_default(m
);
550 r
= manager_set_keep_configuration(m
);
554 m
->state_file
= strdup("/run/systemd/netif/state");
561 static int persistent_storage_open(void) {
562 _cleanup_close_
int fd
= -EBADF
;
565 r
= getenv_bool("SYSTEMD_NETWORK_PERSISTENT_STORAGE_READY");
566 if (r
< 0 && r
!= -ENXIO
)
567 return log_debug_errno(r
, "Failed to parse $SYSTEMD_NETWORK_PERSISTENT_STORAGE_READY environment variable, ignoring: %m");
571 fd
= open("/var/lib/systemd/network/", O_CLOEXEC
| O_DIRECTORY
);
573 return log_debug_errno(errno
, "Failed to open /var/lib/systemd/network/, ignoring: %m");
575 r
= fd_is_read_only_fs(fd
);
577 return log_debug_errno(r
, "Failed to check if /var/lib/systemd/network/ is writable: %m");
579 return log_debug_errno(SYNTHETIC_ERRNO(EROFS
), "The directory /var/lib/systemd/network/ is on read-only filesystem.");
584 int manager_new(Manager
**ret
, bool test_mode
) {
585 _cleanup_(manager_freep
) Manager
*m
= NULL
;
592 .keep_configuration
= _KEEP_CONFIGURATION_INVALID
,
593 .ipv6_privacy_extensions
= IPV6_PRIVACY_EXTENSIONS_NO
,
594 .test_mode
= test_mode
,
595 .speed_meter_interval_usec
= SPEED_METER_DEFAULT_TIME_INTERVAL
,
596 .online_state
= _LINK_ONLINE_STATE_INVALID
,
597 .manage_foreign_routes
= true,
598 .manage_foreign_rules
= true,
599 .manage_foreign_nexthops
= true,
600 .ethtool_fd
= -EBADF
,
601 .persistent_storage_fd
= persistent_storage_open(),
602 .dhcp_use_domains
= _USE_DOMAINS_INVALID
,
603 .dhcp6_use_domains
= _USE_DOMAINS_INVALID
,
604 .ndisc_use_domains
= _USE_DOMAINS_INVALID
,
605 .dhcp_duid
.type
= DUID_TYPE_EN
,
606 .dhcp6_duid
.type
= DUID_TYPE_EN
,
607 .duid_product_uuid
.type
= DUID_TYPE_UUID
,
608 .dhcp_server_persist_leases
= true,
609 .ip_forwarding
= { -1, -1, },
616 Manager
* manager_free(Manager
*m
) {
624 HASHMAP_FOREACH(link
, m
->links_by_index
)
625 (void) link_stop_engines(link
, true);
627 m
->request_queue
= ordered_set_free(m
->request_queue
);
628 m
->remove_request_queue
= ordered_set_free(m
->remove_request_queue
);
630 m
->dirty_links
= set_free_with_destructor(m
->dirty_links
, link_unref
);
631 m
->new_wlan_ifindices
= set_free(m
->new_wlan_ifindices
);
632 m
->links_by_name
= hashmap_free(m
->links_by_name
);
633 m
->links_by_hw_addr
= hashmap_free(m
->links_by_hw_addr
);
634 m
->links_by_dhcp_pd_subnet_prefix
= hashmap_free(m
->links_by_dhcp_pd_subnet_prefix
);
635 m
->links_by_index
= hashmap_free_with_destructor(m
->links_by_index
, link_unref
);
637 m
->dhcp_pd_subnet_ids
= set_free(m
->dhcp_pd_subnet_ids
);
638 m
->networks
= ordered_hashmap_free_with_destructor(m
->networks
, network_unref
);
640 m
->netdevs
= hashmap_free_with_destructor(m
->netdevs
, netdev_unref
);
642 m
->tuntap_fds_by_name
= hashmap_free(m
->tuntap_fds_by_name
);
644 m
->wiphy_by_name
= hashmap_free(m
->wiphy_by_name
);
645 m
->wiphy_by_index
= hashmap_free_with_destructor(m
->wiphy_by_index
, wiphy_free
);
647 ordered_set_free_free(m
->address_pools
);
649 hashmap_free(m
->route_table_names_by_number
);
650 hashmap_free(m
->route_table_numbers_by_name
);
654 sd_netlink_unref(m
->rtnl
);
655 sd_netlink_unref(m
->genl
);
656 sd_resolve_unref(m
->resolve
);
658 /* reject (e.g. unreachable) type routes are managed by Manager, but may be referenced by a
659 * link. E.g., DHCP6 with prefix delegation creates unreachable routes, and they are referenced
660 * by the upstream link. And the links may be referenced by netlink slots. Hence, two
661 * set_free() must be called after the above sd_netlink_unref(). */
662 m
->routes
= set_free(m
->routes
);
664 m
->nexthops_by_id
= hashmap_free(m
->nexthops_by_id
);
665 m
->nexthop_ids
= set_free(m
->nexthop_ids
);
667 sd_event_source_unref(m
->speed_meter_event_source
);
668 sd_event_unref(m
->event
);
670 sd_device_monitor_unref(m
->device_monitor
);
672 manager_varlink_done(m
);
673 hashmap_free(m
->polkit_registry
);
674 sd_bus_flush_close_unref(m
->bus
);
676 free(m
->dynamic_timezone
);
677 free(m
->dynamic_hostname
);
679 safe_close(m
->ethtool_fd
);
680 safe_close(m
->persistent_storage_fd
);
682 m
->fw_ctx
= fw_ctx_free(m
->fw_ctx
);
687 int manager_start(Manager
*m
) {
693 manager_set_sysctl(m
);
695 r
= manager_start_speed_meter(m
);
697 return log_error_errno(r
, "Failed to initialize speed meter: %m");
699 /* The dirty handler will deal with future serialization, but the first one
700 must be done explicitly. */
704 log_warning_errno(r
, "Failed to update state file %s, ignoring: %m", m
->state_file
);
706 HASHMAP_FOREACH(link
, m
->links_by_index
) {
707 r
= link_save_and_clean(link
);
709 log_link_warning_errno(link
, r
, "Failed to update link state file %s, ignoring: %m", link
->state_file
);
715 int manager_load_config(Manager
*m
) {
718 r
= netdev_load(m
, false);
722 manager_clear_unmanaged_tuntap_fds(m
);
724 r
= network_load(m
, &m
->networks
);
728 r
= manager_build_dhcp_pd_subnet_ids(m
);
732 r
= manager_build_nexthop_ids(m
);
739 int manager_enumerate_internal(
742 sd_netlink_message
*req
,
743 int (*process
)(sd_netlink
*, sd_netlink_message
*, Manager
*)) {
745 _cleanup_(sd_netlink_message_unrefp
) sd_netlink_message
*reply
= NULL
;
753 r
= sd_netlink_message_set_request_dump(req
, true);
757 r
= sd_netlink_call(nl
, req
, 0, &reply
);
761 m
->enumerating
= true;
762 for (sd_netlink_message
*reply_one
= reply
; reply_one
; reply_one
= sd_netlink_message_next(reply_one
))
763 RET_GATHER(r
, process(nl
, reply_one
, m
));
764 m
->enumerating
= false;
769 static int manager_enumerate_links(Manager
*m
) {
770 _cleanup_(sd_netlink_message_unrefp
) sd_netlink_message
*req
= NULL
;
776 r
= sd_rtnl_message_new_link(m
->rtnl
, &req
, RTM_GETLINK
, 0);
780 r
= manager_enumerate_internal(m
, m
->rtnl
, req
, manager_rtnl_process_link
);
784 req
= sd_netlink_message_unref(req
);
786 r
= sd_rtnl_message_new_link(m
->rtnl
, &req
, RTM_GETLINK
, 0);
790 r
= sd_rtnl_message_link_set_family(req
, AF_BRIDGE
);
794 return manager_enumerate_internal(m
, m
->rtnl
, req
, manager_rtnl_process_link
);
797 static int manager_enumerate_qdisc(Manager
*m
) {
798 _cleanup_(sd_netlink_message_unrefp
) sd_netlink_message
*req
= NULL
;
804 r
= sd_rtnl_message_new_traffic_control(m
->rtnl
, &req
, RTM_GETQDISC
, 0, 0, 0);
808 return manager_enumerate_internal(m
, m
->rtnl
, req
, manager_rtnl_process_qdisc
);
811 static int manager_enumerate_tclass(Manager
*m
) {
818 /* TC class can be enumerated only per link. See tc_dump_tclass() in net/sched/sched_api.c. */
820 HASHMAP_FOREACH(link
, m
->links_by_index
)
821 RET_GATHER(r
, link_enumerate_tclass(link
, 0));
826 static int manager_enumerate_addresses(Manager
*m
) {
827 _cleanup_(sd_netlink_message_unrefp
) sd_netlink_message
*req
= NULL
;
833 r
= sd_rtnl_message_new_addr(m
->rtnl
, &req
, RTM_GETADDR
, 0, 0);
837 return manager_enumerate_internal(m
, m
->rtnl
, req
, manager_rtnl_process_address
);
840 static int manager_enumerate_neighbors(Manager
*m
) {
841 _cleanup_(sd_netlink_message_unrefp
) sd_netlink_message
*req
= NULL
;
847 r
= sd_rtnl_message_new_neigh(m
->rtnl
, &req
, RTM_GETNEIGH
, 0, AF_UNSPEC
);
851 return manager_enumerate_internal(m
, m
->rtnl
, req
, manager_rtnl_process_neighbor
);
854 static int manager_enumerate_routes(Manager
*m
) {
855 _cleanup_(sd_netlink_message_unrefp
) sd_netlink_message
*req
= NULL
;
861 if (!m
->manage_foreign_routes
)
864 r
= sd_rtnl_message_new_route(m
->rtnl
, &req
, RTM_GETROUTE
, 0, 0);
868 return manager_enumerate_internal(m
, m
->rtnl
, req
, manager_rtnl_process_route
);
871 static int manager_enumerate_rules(Manager
*m
) {
872 _cleanup_(sd_netlink_message_unrefp
) sd_netlink_message
*req
= NULL
;
878 if (!m
->manage_foreign_rules
)
881 r
= sd_rtnl_message_new_routing_policy_rule(m
->rtnl
, &req
, RTM_GETRULE
, 0);
885 return manager_enumerate_internal(m
, m
->rtnl
, req
, manager_rtnl_process_rule
);
888 static int manager_enumerate_nexthop(Manager
*m
) {
889 _cleanup_(sd_netlink_message_unrefp
) sd_netlink_message
*req
= NULL
;
895 if (!m
->manage_foreign_nexthops
)
898 r
= sd_rtnl_message_new_nexthop(m
->rtnl
, &req
, RTM_GETNEXTHOP
, 0, 0);
902 return manager_enumerate_internal(m
, m
->rtnl
, req
, manager_rtnl_process_nexthop
);
905 static int manager_enumerate_nl80211_wiphy(Manager
*m
) {
906 _cleanup_(sd_netlink_message_unrefp
) sd_netlink_message
*req
= NULL
;
912 r
= sd_genl_message_new(m
->genl
, NL80211_GENL_NAME
, NL80211_CMD_GET_WIPHY
, &req
);
916 return manager_enumerate_internal(m
, m
->genl
, req
, manager_genl_process_nl80211_wiphy
);
919 static int manager_enumerate_nl80211_config(Manager
*m
) {
920 _cleanup_(sd_netlink_message_unrefp
) sd_netlink_message
*req
= NULL
;
926 r
= sd_genl_message_new(m
->genl
, NL80211_GENL_NAME
, NL80211_CMD_GET_INTERFACE
, &req
);
930 return manager_enumerate_internal(m
, m
->genl
, req
, manager_genl_process_nl80211_config
);
933 static int manager_enumerate_nl80211_mlme(Manager
*m
) {
940 HASHMAP_FOREACH(link
, m
->links_by_index
) {
941 _cleanup_(sd_netlink_message_unrefp
) sd_netlink_message
*req
= NULL
;
943 if (link
->wlan_iftype
!= NL80211_IFTYPE_STATION
)
946 r
= sd_genl_message_new(m
->genl
, NL80211_GENL_NAME
, NL80211_CMD_GET_STATION
, &req
);
950 r
= sd_netlink_message_append_u32(req
, NL80211_ATTR_IFINDEX
, link
->ifindex
);
954 r
= manager_enumerate_internal(m
, m
->genl
, req
, manager_genl_process_nl80211_mlme
);
962 int manager_enumerate(Manager
*m
) {
965 r
= manager_enumerate_links(m
);
967 return log_error_errno(r
, "Could not enumerate links: %m");
969 r
= manager_enumerate_qdisc(m
);
970 if (r
== -EOPNOTSUPP
)
971 log_debug_errno(r
, "Could not enumerate QDiscs, ignoring: %m");
973 return log_error_errno(r
, "Could not enumerate QDisc: %m");
975 r
= manager_enumerate_tclass(m
);
976 if (r
== -EOPNOTSUPP
)
977 log_debug_errno(r
, "Could not enumerate TClasses, ignoring: %m");
979 return log_error_errno(r
, "Could not enumerate TClass: %m");
981 r
= manager_enumerate_addresses(m
);
983 return log_error_errno(r
, "Could not enumerate addresses: %m");
985 r
= manager_enumerate_neighbors(m
);
987 return log_error_errno(r
, "Could not enumerate neighbors: %m");
989 /* NextHop support is added in kernel v5.3 (65ee00a9409f751188a8cdc0988167858eb4a536),
990 * and older kernels return -EOPNOTSUPP, or -EINVAL if SELinux is enabled. */
991 r
= manager_enumerate_nexthop(m
);
992 if (r
== -EOPNOTSUPP
|| (r
== -EINVAL
&& mac_selinux_enforcing()))
993 log_debug_errno(r
, "Could not enumerate nexthops, ignoring: %m");
995 return log_error_errno(r
, "Could not enumerate nexthops: %m");
997 r
= manager_enumerate_routes(m
);
999 return log_error_errno(r
, "Could not enumerate routes: %m");
1001 /* If kernel is built with CONFIG_FIB_RULES=n, it returns -EOPNOTSUPP. */
1002 r
= manager_enumerate_rules(m
);
1003 if (r
== -EOPNOTSUPP
)
1004 log_debug_errno(r
, "Could not enumerate routing policy rules, ignoring: %m");
1006 return log_error_errno(r
, "Could not enumerate routing policy rules: %m");
1008 r
= manager_enumerate_nl80211_wiphy(m
);
1009 if (r
== -EOPNOTSUPP
)
1010 log_debug_errno(r
, "Could not enumerate wireless LAN phy, ignoring: %m");
1012 return log_error_errno(r
, "Could not enumerate wireless LAN phy: %m");
1014 r
= manager_enumerate_nl80211_config(m
);
1015 if (r
== -EOPNOTSUPP
)
1016 log_debug_errno(r
, "Could not enumerate wireless LAN interfaces, ignoring: %m");
1018 return log_error_errno(r
, "Could not enumerate wireless LAN interfaces: %m");
1020 r
= manager_enumerate_nl80211_mlme(m
);
1021 if (r
== -EOPNOTSUPP
)
1022 log_debug_errno(r
, "Could not enumerate wireless LAN stations, ignoring: %m");
1024 return log_error_errno(r
, "Could not enumerate wireless LAN stations: %m");
1029 static int set_hostname_handler(sd_bus_message
*m
, void *userdata
, sd_bus_error
*ret_error
) {
1030 const sd_bus_error
*e
;
1035 e
= sd_bus_message_get_error(m
);
1037 r
= sd_bus_error_get_errno(e
);
1038 log_warning_errno(r
, "Could not set hostname: %s", bus_error_message(e
, r
));
1044 int manager_set_hostname(Manager
*m
, const char *hostname
) {
1047 log_debug("Setting transient hostname: '%s'", strna(hostname
));
1049 r
= free_and_strdup_warn(&m
->dynamic_hostname
, hostname
);
1053 if (sd_bus_is_ready(m
->bus
) <= 0) {
1054 log_debug("Not connected to system bus, setting system hostname later.");
1058 r
= bus_call_method_async(
1063 set_hostname_handler
,
1069 return log_error_errno(r
, "Could not set transient hostname: %m");
1074 static int set_timezone_handler(sd_bus_message
*m
, void *userdata
, sd_bus_error
*ret_error
) {
1075 const sd_bus_error
*e
;
1080 e
= sd_bus_message_get_error(m
);
1082 r
= sd_bus_error_get_errno(e
);
1083 log_warning_errno(r
, "Could not set timezone: %s", bus_error_message(e
, r
));
1089 int manager_set_timezone(Manager
*m
, const char *tz
) {
1095 log_debug("Setting system timezone: '%s'", tz
);
1096 r
= free_and_strdup_warn(&m
->dynamic_timezone
, tz
);
1100 if (sd_bus_is_ready(m
->bus
) <= 0) {
1101 log_debug("Not connected to system bus, setting system timezone later.");
1105 r
= bus_call_method_async(
1110 set_timezone_handler
,
1116 return log_error_errno(r
, "Could not set timezone: %m");
1121 int manager_reload(Manager
*m
, sd_bus_message
*message
) {
1127 (void) notify_reloading();
1129 r
= netdev_load(m
, /* reload= */ true);
1133 r
= network_reload(m
);
1137 HASHMAP_FOREACH(link
, m
->links_by_index
) {
1139 r
= link_reconfigure_on_bus_method_reload(link
, message
);
1141 r
= link_reconfigure(link
, /* force = */ false);
1143 log_link_warning_errno(link
, r
, "Failed to reconfigure the interface: %m");
1144 link_enter_failed(link
);
1150 (void) sd_notify(/* unset= */ false, NOTIFY_READY
);