#include "missing_network.h"
#include "netlink-util.h"
#include "network-internal.h"
+#include "networkd-address-label.h"
+#include "networkd-address.h"
#include "networkd-can.h"
#include "networkd-dhcp-server.h"
#include "networkd-dhcp4.h"
#include "networkd-dhcp6.h"
+#include "networkd-fdb.h"
#include "networkd-ipv4ll.h"
#include "networkd-ipv6-proxy-ndp.h"
#include "networkd-link-bus.h"
#include "networkd-link.h"
#include "networkd-lldp-tx.h"
#include "networkd-manager.h"
+#include "networkd-mdb.h"
#include "networkd-ndisc.h"
#include "networkd-neighbor.h"
+#include "networkd-nexthop.h"
#include "networkd-sriov.h"
+#include "networkd-sysctl.h"
#include "networkd-radv.h"
#include "networkd-routing-policy-rule.h"
#include "networkd-wifi.h"
#include "util.h"
#include "vrf.h"
-uint32_t link_get_vrf_table(Link *link) {
- return link->network->vrf ? VRF(link->network->vrf)->table : RT_TABLE_MAIN;
-}
-
-uint32_t link_get_dhcp_route_table(Link *link) {
- /* When the interface is part of an VRF use the VRFs routing table, unless
- * another table is explicitly specified. */
- if (link->network->dhcp_route_table_set)
- return link->network->dhcp_route_table;
- return link_get_vrf_table(link);
-}
-
-uint32_t link_get_ipv6_accept_ra_route_table(Link *link) {
- if (link->network->ipv6_accept_ra_route_table_set)
- return link->network->ipv6_accept_ra_route_table;
- return link_get_vrf_table(link);
-}
-
-DUID* link_get_duid(Link *link) {
- if (link->network->duid.type != _DUID_TYPE_INVALID)
- return &link->network->duid;
- else
- return &link->manager->duid;
-}
-
-static bool link_dhcp6_enabled(Link *link) {
- assert(link);
-
- if (!socket_ipv6_is_supported())
- return false;
-
- if (link->flags & IFF_LOOPBACK)
- return false;
-
- if (!link->network)
- return false;
-
- if (link->network->bond)
- return false;
-
- if (link->iftype == ARPHRD_CAN)
- return false;
-
- return link->network->dhcp & ADDRESS_FAMILY_IPV6;
-}
-
-static bool link_dhcp4_enabled(Link *link) {
- assert(link);
-
- if (link->flags & IFF_LOOPBACK)
- return false;
-
- if (!link->network)
- return false;
-
- if (link->network->bond)
- return false;
-
- if (link->iftype == ARPHRD_CAN)
- return false;
-
- return link->network->dhcp & ADDRESS_FAMILY_IPV4;
-}
-
-static bool link_dhcp4_server_enabled(Link *link) {
- assert(link);
-
- if (link->flags & IFF_LOOPBACK)
- return false;
-
- if (!link->network)
- return false;
-
- if (link->network->bond)
- return false;
-
- if (link->iftype == ARPHRD_CAN)
- return false;
-
- return link->network->dhcp_server;
-}
-
bool link_ipv4ll_enabled(Link *link, AddressFamily mask) {
assert(link);
assert((mask & ~(ADDRESS_FAMILY_IPV4 | ADDRESS_FAMILY_FALLBACK_IPV4)) == 0);
if (STRPTR_IN_SET(link->kind,
"vrf", "wireguard", "ipip", "gre", "ip6gre","ip6tnl", "sit", "vti",
- "vti6", "nlmon", "xfrm"))
+ "vti6", "nlmon", "xfrm", "bareudp"))
return false;
/* L3 or L3S mode do not support ARP. */
return link->network->link_local & mask;
}
-static bool link_ipv6ll_enabled(Link *link) {
+bool link_ipv6ll_enabled(Link *link) {
assert(link);
if (!socket_ipv6_is_supported())
return link->network->link_local & ADDRESS_FAMILY_IPV6;
}
-static bool link_ipv6_enabled(Link *link) {
+bool link_ipv6_enabled(Link *link) {
assert(link);
if (!socket_ipv6_is_supported())
return false;
}
-static bool link_radv_enabled(Link *link) {
- assert(link);
-
- if (!link_ipv6ll_enabled(link))
- return false;
-
- return link->network->router_prefix_delegation != RADV_PREFIX_DELEGATION_NONE;
-}
-
-static bool link_ipv4_forward_enabled(Link *link) {
- assert(link);
-
- if (link->flags & IFF_LOOPBACK)
- return false;
-
- if (!link->network)
- return false;
-
- if (link->network->ip_forward == _ADDRESS_FAMILY_INVALID)
- return false;
-
- return link->network->ip_forward & ADDRESS_FAMILY_IPV4;
-}
-
-static bool link_ipv6_forward_enabled(Link *link) {
- assert(link);
-
- if (!socket_ipv6_is_supported())
- return false;
-
- if (link->flags & IFF_LOOPBACK)
- return false;
-
- if (!link->network)
- return false;
-
- if (link->network->ip_forward == _ADDRESS_FAMILY_INVALID)
- return false;
-
- return link->network->ip_forward & ADDRESS_FAMILY_IPV6;
-}
-
-static bool link_proxy_arp_enabled(Link *link) {
- assert(link);
-
- if (link->flags & IFF_LOOPBACK)
- return false;
-
- if (!link->network)
- return false;
-
- if (link->network->proxy_arp < 0)
- return false;
-
- return true;
-}
-
-static bool link_ipv6_accept_ra_enabled(Link *link) {
- assert(link);
-
- if (!socket_ipv6_is_supported())
- return false;
-
- if (link->flags & IFF_LOOPBACK)
- return false;
-
- if (!link->network)
- return false;
-
- if (!link_ipv6ll_enabled(link))
- return false;
-
- /* If unset use system default (enabled if local forwarding is disabled.
- * disabled if local forwarding is enabled).
- * If set, ignore or enforce RA independent of local forwarding state.
- */
- if (link->network->ipv6_accept_ra < 0)
- /* default to accept RA if ip_forward is disabled and ignore RA if ip_forward is enabled */
- return !link_ipv6_forward_enabled(link);
- else if (link->network->ipv6_accept_ra > 0)
- /* accept RA even if ip_forward is enabled */
- return true;
- else
- /* ignore RA */
- return false;
-}
-
-static IPv6PrivacyExtensions link_ipv6_privacy_extensions(Link *link) {
- assert(link);
-
- if (!socket_ipv6_is_supported())
- return _IPV6_PRIVACY_EXTENSIONS_INVALID;
-
- if (link->flags & IFF_LOOPBACK)
- return _IPV6_PRIVACY_EXTENSIONS_INVALID;
-
- if (!link->network)
- return _IPV6_PRIVACY_EXTENSIONS_INVALID;
-
- return link->network->ipv6_privacy_extensions;
-}
-
-static int link_update_ipv6_sysctl(Link *link) {
- bool enabled;
- int r;
-
- if (link->flags & IFF_LOOPBACK)
- return 0;
-
- enabled = link_ipv6_enabled(link);
- if (enabled) {
- r = sysctl_write_ip_property_boolean(AF_INET6, link->ifname, "disable_ipv6", false);
- if (r < 0)
- return log_link_warning_errno(link, r, "Cannot enable IPv6: %m");
-
- log_link_info(link, "IPv6 successfully enabled");
- }
-
- return 0;
-}
-
static bool link_is_enslaved(Link *link) {
if (link->flags & IFF_SLAVE)
/* Even if the link is not managed by networkd, honor IFF_SLAVE flag. */
link->dhcp6_lease = sd_dhcp6_lease_unref(link->dhcp6_lease);
link->ndisc = sd_ndisc_unref(link->ndisc);
link->radv = sd_radv_unref(link->radv);
+ link->dhcp_acd = sd_ipv4acd_unref(link->dhcp_acd);
}
static Link *link_free(Link *link) {
- Address *address;
-
assert(link);
link_ntp_settings_clear(link);
link->addresses = set_free(link->addresses);
link->addresses_foreign = set_free(link->addresses_foreign);
+ link->pool_addresses = set_free(link->pool_addresses);
link->static_addresses = set_free(link->static_addresses);
link->dhcp6_addresses = set_free(link->dhcp6_addresses);
link->dhcp6_addresses_old = set_free(link->dhcp6_addresses_old);
link->dhcp6_pd_addresses_old = set_free(link->dhcp6_pd_addresses_old);
link->ndisc_addresses = set_free(link->ndisc_addresses);
- while ((address = link->pool_addresses)) {
- LIST_REMOVE(addresses, link->pool_addresses, address);
- address_free(address);
- }
-
link_lldp_emit_stop(link);
link_free_engines(link);
free(link->lease_file);
link_dirty(link);
}
-int link_stop_clients(Link *link, bool may_keep_dhcp) {
+int link_stop_engines(Link *link, bool may_keep_dhcp) {
int r = 0, k;
- Address *ad;
assert(link);
assert(link->manager);
(link->manager->restarting ||
FLAGS_SET(link->network->keep_configuration, KEEP_CONFIGURATION_DHCP_ON_STOP));
- if (link->dhcp_client && !keep_dhcp) {
+ if (!keep_dhcp) {
k = sd_dhcp_client_stop(link->dhcp_client);
if (k < 0)
r = log_link_warning_errno(link, k, "Could not stop DHCPv4 client: %m");
}
- if (link->ipv4ll) {
- k = sd_ipv4ll_stop(link->ipv4ll);
- if (k < 0)
- r = log_link_warning_errno(link, k, "Could not stop IPv4 link-local: %m");
- }
+ k = sd_ipv4acd_stop(link->dhcp_acd);
+ if (k < 0)
+ r = log_link_warning_errno(link, k, "Could not stop IPv4 ACD client for DHCPv4: %m");
- if (link->network)
- LIST_FOREACH(addresses, ad, link->network->static_addresses)
- if (ad->acd && sd_ipv4acd_is_running(ad->acd) == 0) {
- k = sd_ipv4acd_stop(ad->acd);
- if (k < 0)
- r = log_link_warning_errno(link, k, "Could not stop IPv4 ACD client: %m");
- }
+ k = sd_dhcp_server_stop(link->dhcp_server);
+ if (k < 0)
+ r = log_link_warning_errno(link, k, "Could not stop DHCPv4 server: %m");
- if (link->dhcp6_client) {
- k = sd_dhcp6_client_stop(link->dhcp6_client);
- if (k < 0)
- r = log_link_warning_errno(link, k, "Could not stop DHCPv6 client: %m");
- }
+ k = sd_ipv4ll_stop(link->ipv4ll);
+ if (k < 0)
+ r = log_link_warning_errno(link, k, "Could not stop IPv4 link-local: %m");
- if (link_dhcp6_pd_is_enabled(link)) {
- k = dhcp6_pd_remove(link);
- if (k < 0)
- r = log_link_warning_errno(link, k, "Could not remove DHCPv6 PD addresses and routes: %m");
- }
+ k = ipv4_dad_stop(link);
+ if (k < 0)
+ r = log_link_warning_errno(link, k, "Could not stop IPv4 ACD client: %m");
- if (link->ndisc) {
- k = sd_ndisc_stop(link->ndisc);
- if (k < 0)
- r = log_link_warning_errno(link, k, "Could not stop IPv6 Router Discovery: %m");
- }
+ k = sd_dhcp6_client_stop(link->dhcp6_client);
+ if (k < 0)
+ r = log_link_warning_errno(link, k, "Could not stop DHCPv6 client: %m");
- if (link->radv) {
- k = sd_radv_stop(link->radv);
- if (k < 0)
- r = log_link_warning_errno(link, k, "Could not stop IPv6 Router Advertisement: %m");
- }
+ k = dhcp6_pd_remove(link);
+ if (k < 0)
+ r = log_link_warning_errno(link, k, "Could not remove DHCPv6 PD addresses and routes: %m");
+
+ k = sd_ndisc_stop(link->ndisc);
+ if (k < 0)
+ r = log_link_warning_errno(link, k, "Could not stop IPv6 Router Discovery: %m");
+
+ k = sd_radv_stop(link->radv);
+ if (k < 0)
+ r = log_link_warning_errno(link, k, "Could not stop IPv6 Router Advertisement: %m");
link_lldp_emit_stop(link);
return r;
link_set_state(link, LINK_STATE_FAILED);
- link_stop_clients(link, false);
+ (void) link_stop_engines(link, false);
link_dirty(link);
}
link_dirty(link);
}
-static int link_request_set_routing_policy_rule(Link *link) {
- RoutingPolicyRule *rule, *rrule = NULL;
- int r;
+void link_check_ready(Link *link) {
+ Address *a;
assert(link);
- assert(link->network);
-
- link->routing_policy_rules_configured = false;
-
- LIST_FOREACH(rules, rule, link->network->rules) {
- r = routing_policy_rule_get(link->manager, rule, &rrule);
- if (r >= 0) {
- if (r == 0)
- (void) routing_policy_rule_make_local(link->manager, rrule);
- continue;
- }
- r = routing_policy_rule_configure(rule, link, NULL);
- if (r < 0)
- return log_link_warning_errno(link, r, "Could not set routing policy rules: %m");
- if (r > 0)
- link->routing_policy_rule_messages++;
- }
+ if (link->state == LINK_STATE_CONFIGURED)
+ return;
- routing_policy_rule_purge(link->manager, link);
- if (link->routing_policy_rule_messages == 0)
- link->routing_policy_rules_configured = true;
- else {
- log_link_debug(link, "Setting routing policy rules");
- link_set_state(link, LINK_STATE_CONFIGURING);
+ if (link->state != LINK_STATE_CONFIGURING) {
+ log_link_debug(link, "%s(): link is in %s state.", __func__, link_state_to_string(link->state));
+ return;
}
- return 0;
-}
+ if (!link->network)
+ return;
-static int nexthop_handler(sd_netlink *rtnl, sd_netlink_message *m, Link *link) {
- int r;
+ if (!link->addresses_configured) {
+ log_link_debug(link, "%s(): static addresses are not configured.", __func__);
+ return;
+ }
- assert(link);
- assert(link->nexthop_messages > 0);
- assert(IN_SET(link->state, LINK_STATE_CONFIGURING,
- LINK_STATE_FAILED, LINK_STATE_LINGER));
+ if (!link->neighbors_configured) {
+ log_link_debug(link, "%s(): static neighbors are not configured.", __func__);
+ return;
+ }
- link->nexthop_messages--;
+ SET_FOREACH(a, link->addresses)
+ if (!address_is_ready(a)) {
+ _cleanup_free_ char *str = NULL;
- if (IN_SET(link->state, LINK_STATE_FAILED, LINK_STATE_LINGER))
- return 1;
+ (void) in_addr_to_string(a->family, &a->in_addr, &str);
+ log_link_debug(link, "%s(): an address %s/%d is not ready.", __func__, strnull(str), a->prefixlen);
+ return;
+ }
- r = sd_netlink_message_get_errno(m);
- if (r < 0 && r != -EEXIST) {
- log_link_message_warning_errno(link, m, r, "Could not set nexthop");
- link_enter_failed(link);
- return 1;
+ if (!link->static_routes_configured) {
+ log_link_debug(link, "%s(): static routes are not configured.", __func__);
+ return;
}
- if (link->nexthop_messages == 0) {
- log_link_debug(link, "Nexthop set");
- link->static_nexthops_configured = true;
- link_check_ready(link);
+ if (!link->static_nexthops_configured) {
+ log_link_debug(link, "%s(): static nexthops are not configured.", __func__);
+ return;
}
- return 1;
-}
-
-static int link_request_set_nexthop(Link *link) {
- NextHop *nh;
- int r;
-
- link->static_nexthops_configured = false;
+ if (!link->routing_policy_rules_configured) {
+ log_link_debug(link, "%s(): static routing policy rules are not configured.", __func__);
+ return;
+ }
- LIST_FOREACH(nexthops, nh, link->network->static_nexthops) {
- r = nexthop_configure(nh, link, nexthop_handler);
- if (r < 0)
- return log_link_warning_errno(link, r, "Could not set nexthop: %m");
- if (r > 0)
- link->nexthop_messages++;
+ if (!link->tc_configured) {
+ log_link_debug(link, "%s(): traffic controls are not configured.", __func__);
+ return;
}
- if (link->nexthop_messages == 0) {
- link->static_nexthops_configured = true;
- link_check_ready(link);
- } else {
- log_link_debug(link, "Setting nexthop");
- link_set_state(link, LINK_STATE_CONFIGURING);
+ if (!link->sr_iov_configured) {
+ log_link_debug(link, "%s(): SR-IOV is not configured.", __func__);
+ return;
}
- return 1;
-}
+ if (!link->bridge_mdb_configured) {
+ log_link_debug(link, "%s(): Bridge MDB is not configured.", __func__);
+ return;
+ }
-static int route_handler(sd_netlink *rtnl, sd_netlink_message *m, Link *link) {
- int r;
+ if (link_has_carrier(link) || !link->network->configure_without_carrier) {
+ bool has_ndisc_address = false;
+ NDiscAddress *n;
- assert(link);
- assert(link->route_messages > 0);
- assert(IN_SET(link->state, LINK_STATE_CONFIGURING,
- LINK_STATE_FAILED, LINK_STATE_LINGER));
+ if (link_ipv4ll_enabled(link, ADDRESS_FAMILY_IPV4) && !link->ipv4ll_address_configured) {
+ log_link_debug(link, "%s(): IPv4LL is not configured.", __func__);
+ return;
+ }
- link->route_messages--;
-
- if (IN_SET(link->state, LINK_STATE_FAILED, LINK_STATE_LINGER))
- return 1;
-
- r = sd_netlink_message_get_errno(m);
- if (r < 0 && r != -EEXIST) {
- log_link_message_warning_errno(link, m, r, "Could not set route");
- link_enter_failed(link);
- return 1;
- }
-
- if (link->route_messages == 0) {
- log_link_debug(link, "Routes set");
- link->static_routes_configured = true;
- link_request_set_nexthop(link);
- }
-
- return 1;
-}
-
-int link_request_set_routes(Link *link) {
- enum {
- PHASE_NON_GATEWAY, /* First phase: Routes without a gateway */
- PHASE_GATEWAY, /* Second phase: Routes with a gateway */
- _PHASE_MAX
- } phase;
- Route *rt;
- int r;
-
- assert(link);
- assert(link->network);
- assert(link->state != _LINK_STATE_INVALID);
-
- link->static_routes_configured = false;
-
- if (!link->addresses_ready)
- return 0;
-
- if (!link_has_carrier(link) && !link->network->configure_without_carrier)
- /* During configuring addresses, the link lost its carrier. As networkd is dropping
- * the addresses now, let's not configure the routes either. */
- return 0;
-
- r = link_request_set_routing_policy_rule(link);
- if (r < 0)
- return r;
-
- /* First add the routes that enable us to talk to gateways, then add in the others that need a gateway. */
- for (phase = 0; phase < _PHASE_MAX; phase++)
- LIST_FOREACH(routes, rt, link->network->static_routes) {
- if (rt->gateway_from_dhcp)
- continue;
-
- if ((in_addr_is_null(rt->family, &rt->gw) && ordered_set_isempty(rt->multipath_routes)) != (phase == PHASE_NON_GATEWAY))
- continue;
-
- r = route_configure(rt, link, route_handler, NULL);
- if (r < 0)
- return log_link_warning_errno(link, r, "Could not set routes: %m");
- if (r > 0)
- link->route_messages++;
- }
-
- if (link->route_messages == 0) {
- link->static_routes_configured = true;
- link_request_set_nexthop(link);
- } else {
- log_link_debug(link, "Setting routes");
- link_set_state(link, LINK_STATE_CONFIGURING);
- }
-
- return 0;
-}
-
-void link_check_ready(Link *link) {
- Address *a;
-
- assert(link);
-
- if (link->state == LINK_STATE_CONFIGURED)
- return;
-
- if (link->state != LINK_STATE_CONFIGURING) {
- log_link_debug(link, "%s(): link is in %s state.", __func__, link_state_to_string(link->state));
- return;
- }
-
- if (!link->network)
- return;
-
- if (!link->addresses_configured) {
- log_link_debug(link, "%s(): static addresses are not configured.", __func__);
- return;
- }
-
- if (!link->neighbors_configured) {
- log_link_debug(link, "%s(): static neighbors are not configured.", __func__);
- return;
- }
-
- SET_FOREACH(a, link->addresses)
- if (!address_is_ready(a)) {
- _cleanup_free_ char *str = NULL;
-
- (void) in_addr_to_string(a->family, &a->in_addr, &str);
- log_link_debug(link, "%s(): an address %s/%d is not ready.", __func__, strnull(str), a->prefixlen);
- return;
- }
-
- if (!link->static_routes_configured) {
- log_link_debug(link, "%s(): static routes are not configured.", __func__);
- return;
- }
-
- if (!link->static_nexthops_configured) {
- log_link_debug(link, "%s(): static nexthops are not configured.", __func__);
- return;
- }
-
- if (!link->routing_policy_rules_configured) {
- log_link_debug(link, "%s(): static routing policy rules are not configured.", __func__);
- return;
- }
-
- if (!link->tc_configured) {
- log_link_debug(link, "%s(): traffic controls are not configured.", __func__);
- return;
- }
-
- if (!link->sr_iov_configured) {
- log_link_debug(link, "%s(): SR-IOV is not configured.", __func__);
- return;
- }
-
- if (link_has_carrier(link) || !link->network->configure_without_carrier) {
- bool has_ndisc_address = false;
- NDiscAddress *n;
-
- if (link_ipv4ll_enabled(link, ADDRESS_FAMILY_IPV4) && !link->ipv4ll_address_configured) {
- log_link_debug(link, "%s(): IPv4LL is not configured.", __func__);
- return;
- }
-
- if (link_ipv6ll_enabled(link) &&
- in_addr_is_null(AF_INET6, (const union in_addr_union*) &link->ipv6ll_address)) {
- log_link_debug(link, "%s(): IPv6LL is not configured.", __func__);
- return;
- }
+ if (link_ipv6ll_enabled(link) &&
+ in_addr_is_null(AF_INET6, (const union in_addr_union*) &link->ipv6ll_address)) {
+ log_link_debug(link, "%s(): IPv6LL is not configured.", __func__);
+ return;
+ }
SET_FOREACH(n, link->ndisc_addresses)
if (!n->marked) {
return;
}
-static int link_request_set_neighbors(Link *link) {
- Neighbor *neighbor;
+static int link_set_static_configs(Link *link) {
int r;
assert(link);
assert(link->network);
assert(link->state != _LINK_STATE_INVALID);
+ /* Reset all *_configured flags we are configuring. */
+ link->request_static_addresses = false;
+ link->addresses_configured = false;
+ link->addresses_ready = false;
link->neighbors_configured = false;
+ link->static_routes_configured = false;
+ link->static_nexthops_configured = false;
+ link->routing_policy_rules_configured = false;
- LIST_FOREACH(neighbors, neighbor, link->network->neighbors) {
- r = neighbor_configure(neighbor, link, NULL);
- if (r < 0)
- return log_link_warning_errno(link, r, "Could not set neighbor: %m");
- }
-
- if (link->neighbor_messages == 0) {
- link->neighbors_configured = true;
- link_check_ready(link);
- } else {
- log_link_debug(link, "Setting neighbors");
- link_set_state(link, LINK_STATE_CONFIGURING);
- }
-
- return 0;
-}
-
-static int link_set_bridge_fdb(Link *link) {
- FdbEntry *fdb_entry;
- int r;
-
- LIST_FOREACH(static_fdb_entries, fdb_entry, link->network->static_fdb_entries) {
- r = fdb_entry_configure(link, fdb_entry);
- if (r < 0)
- return log_link_error_errno(link, r, "Failed to add MAC entry to static MAC table: %m");
- }
-
- return 0;
-}
+ r = link_set_bridge_fdb(link);
+ if (r < 0)
+ return r;
-static int link_set_bridge_mdb(Link *link) {
- MdbEntry *mdb_entry;
- int r;
+ r = link_set_bridge_mdb(link);
+ if (r < 0)
+ return r;
- if (!link->network)
- return 0;
+ r = link_set_neighbors(link);
+ if (r < 0)
+ return r;
- if (LIST_IS_EMPTY(link->network->static_mdb_entries))
- return 0;
+ r = link_set_addresses(link);
+ if (r < 0)
+ return r;
- if (!link->network->bridge) {
- log_link_error(link, "Cannot configure MDB entries on non-bridge port");
- return 0;
- }
+ r = link_set_address_labels(link);
+ if (r < 0)
+ return r;
- LIST_FOREACH(static_mdb_entries, mdb_entry, link->network->static_mdb_entries) {
- r = mdb_entry_configure(link, mdb_entry);
- if (r < 0)
- return log_link_error_errno(link, r, "Failed to add entry to multicast group database: %m");
- }
+ /* now that we can figure out a default address for the dhcp server, start it */
+ r = dhcp4_server_configure(link);
+ if (r < 0)
+ return r;
return 0;
}
-static int static_address_ready_callback(Address *address) {
- Address *a;
- Link *link;
-
- assert(address);
- assert(address->link);
-
- link = address->link;
-
- if (!link->addresses_configured)
- return 0;
-
- SET_FOREACH(a, link->static_addresses)
- if (!address_is_ready(a)) {
- _cleanup_free_ char *str = NULL;
-
- (void) in_addr_to_string(a->family, &a->in_addr, &str);
- log_link_debug(link, "an address %s/%u is not ready", strnull(str), a->prefixlen);
- return 0;
- }
-
- /* This should not be called again */
- SET_FOREACH(a, link->static_addresses)
- a->callback = NULL;
-
- link->addresses_ready = true;
-
- return link_request_set_routes(link);
-}
+static int link_configure_continue(Link *link);
-static int address_handler(sd_netlink *rtnl, sd_netlink_message *m, Link *link) {
+static int set_mtu_handler(sd_netlink *rtnl, sd_netlink_message *m, Link *link) {
int r;
- assert(rtnl);
assert(m);
assert(link);
assert(link->ifname);
- assert(link->address_messages > 0);
- assert(IN_SET(link->state, LINK_STATE_CONFIGURING,
- LINK_STATE_FAILED, LINK_STATE_LINGER));
- link->address_messages--;
+ link->setting_mtu = false;
if (IN_SET(link->state, LINK_STATE_FAILED, LINK_STATE_LINGER))
return 1;
r = sd_netlink_message_get_errno(m);
- if (r < 0 && r != -EEXIST) {
- log_link_message_warning_errno(link, m, r, "Could not set address");
- link_enter_failed(link);
- return 1;
- } else if (r >= 0)
- (void) manager_rtnl_process_address(rtnl, m, link->manager);
-
- if (link->address_messages == 0) {
- Address *a;
-
- log_link_debug(link, "Addresses set");
- link->addresses_configured = true;
+ if (r < 0)
+ log_link_message_warning_errno(link, m, r, "Could not set MTU, ignoring");
+ else
+ log_link_debug(link, "Setting MTU done.");
- /* When all static addresses are already ready, then static_address_ready_callback()
- * will not be called automatically. So, call it here. */
- a = set_first(link->static_addresses);
- if (!a) {
- log_link_warning(link, "No static address is stored.");
- link_enter_failed(link);
- return 1;
- }
- if (!a->callback) {
- log_link_warning(link, "Address ready callback is not set.");
- link_enter_failed(link);
- return 1;
- }
- r = a->callback(a);
+ if (link->state == LINK_STATE_INITIALIZED) {
+ r = link_configure_continue(link);
if (r < 0)
link_enter_failed(link);
}
return 1;
}
-static int static_address_configure(Address *address, Link *link, bool update) {
- Address *ret;
+int link_set_mtu(Link *link, uint32_t mtu) {
+ _cleanup_(sd_netlink_message_unrefp) sd_netlink_message *req = NULL;
int r;
- assert(address);
assert(link);
+ assert(link->manager);
+ assert(link->manager->rtnl);
- r = address_configure(address, link, address_handler, update, &ret);
- if (r < 0)
- return log_link_warning_errno(link, r, "Could not configure static address: %m");
-
- link->address_messages++;
+ if (mtu == 0 || link->setting_mtu)
+ return 0;
- r = set_ensure_put(&link->static_addresses, &address_hash_ops, ret);
- if (r < 0)
- return log_link_warning_errno(link, r, "Failed to store static address: %m");
+ if (link->mtu == mtu)
+ return 0;
- ret->callback = static_address_ready_callback;
+ log_link_debug(link, "Setting MTU: %" PRIu32, mtu);
- return 0;
-}
+ r = sd_rtnl_message_new_link(link->manager->rtnl, &req, RTM_SETLINK, link->ifindex);
+ if (r < 0)
+ return log_link_error_errno(link, r, "Could not allocate RTM_SETLINK message: %m");
-static int link_request_set_addresses(Link *link) {
- AddressLabel *label;
- Address *ad;
- Prefix *p;
- int r;
+ /* IPv6 protocol requires a minimum MTU of IPV6_MTU_MIN(1280) bytes
+ * on the interface. Bump up MTU bytes to IPV6_MTU_MIN. */
+ if (link_ipv6_enabled(link) && mtu < IPV6_MIN_MTU) {
- assert(link);
- assert(link->network);
- assert(link->state != _LINK_STATE_INVALID);
+ log_link_warning(link, "Bumping MTU to " STRINGIFY(IPV6_MIN_MTU) ", as "
+ "IPv6 is requested and requires a minimum MTU of " STRINGIFY(IPV6_MIN_MTU) " bytes");
- if (link->address_remove_messages != 0) {
- log_link_debug(link, "Removing old addresses, new addresses will be configured later.");
- link->request_static_addresses = true;
- return 0;
+ mtu = IPV6_MIN_MTU;
}
- /* Reset all *_configured flags we are configuring. */
- link->request_static_addresses = false;
- link->addresses_configured = false;
- link->addresses_ready = false;
- link->neighbors_configured = false;
- link->static_routes_configured = false;
- link->static_nexthops_configured = false;
- link->routing_policy_rules_configured = false;
-
- r = link_set_bridge_fdb(link);
+ r = sd_netlink_message_append_u32(req, IFLA_MTU, mtu);
if (r < 0)
- return r;
+ return log_link_error_errno(link, r, "Could not append MTU: %m");
- r = link_request_set_neighbors(link);
+ r = netlink_call_async(link->manager->rtnl, NULL, req, set_mtu_handler,
+ link_netlink_destroy_callback, link);
if (r < 0)
- return r;
-
- LIST_FOREACH(addresses, ad, link->network->static_addresses) {
- bool update;
-
- if (ad->family == AF_INET6 && !in_addr_is_null(ad->family, &ad->in_addr_peer))
- update = address_get(link, ad->family, &ad->in_addr_peer, ad->prefixlen, NULL) > 0;
- else
- update = address_get(link, ad->family, &ad->in_addr, ad->prefixlen, NULL) > 0;
+ return log_link_error_errno(link, r, "Could not send rtnetlink message: %m");
- r = static_address_configure(ad, link, update);
- if (r < 0)
- return r;
- }
+ link_ref(link);
+ link->setting_mtu = true;
- if (link->network->router_prefix_delegation & RADV_PREFIX_DELEGATION_STATIC)
- LIST_FOREACH(prefixes, p, link->network->static_prefixes) {
- _cleanup_(address_freep) Address *address = NULL;
-
- if (!p->assign)
- continue;
-
- r = address_new(&address);
- if (r < 0)
- return log_oom();
-
- r = sd_radv_prefix_get_prefix(p->radv_prefix, &address->in_addr.in6, &address->prefixlen);
- if (r < 0)
- return log_link_warning_errno(link, r, "Could not get RA prefix: %m");
-
- r = generate_ipv6_eui_64_address(link, &address->in_addr.in6);
- if (r < 0)
- return log_link_warning_errno(link, r, "Could not generate EUI64 address: %m");
-
- address->family = AF_INET6;
- r = static_address_configure(address, link, true);
- if (r < 0)
- return r;
- }
-
- LIST_FOREACH(labels, label, link->network->address_labels) {
- r = address_label_configure(label, link, NULL, false);
- if (r < 0)
- return log_link_warning_errno(link, r, "Could not set address label: %m");
-
- link->address_label_messages++;
- }
-
- /* now that we can figure out a default address for the dhcp server, start it */
- if (link_dhcp4_server_enabled(link) && (link->flags & IFF_UP)) {
- r = dhcp4_server_configure(link);
- if (r < 0)
- return r;
- log_link_debug(link, "Offering DHCPv4 leases");
- }
-
- if (link->address_messages == 0) {
- link->addresses_configured = true;
- link->addresses_ready = true;
- r = link_request_set_routes(link);
- if (r < 0)
- return r;
- } else {
- log_link_debug(link, "Setting addresses");
- link_set_state(link, LINK_STATE_CONFIGURING);
- }
-
- return 0;
-}
-
-static int link_set_bridge_vlan(Link *link) {
- int r;
-
- r = br_vlan_configure(link, link->network->pvid, link->network->br_vid_bitmap, link->network->br_untagged_bitmap);
- if (r < 0)
- log_link_error_errno(link, r, "Failed to assign VLANs to bridge port: %m");
-
- return r;
-}
-
-static int link_set_proxy_arp(Link *link) {
- int r;
-
- if (!link_proxy_arp_enabled(link))
- return 0;
-
- r = sysctl_write_ip_property_boolean(AF_INET, link->ifname, "proxy_arp", link->network->proxy_arp > 0);
- if (r < 0)
- log_link_warning_errno(link, r, "Cannot configure proxy ARP for interface: %m");
-
- return 0;
-}
-
-static int link_configure_continue(Link *link);
-
-static int set_mtu_handler(sd_netlink *rtnl, sd_netlink_message *m, Link *link) {
- int r;
-
- assert(m);
- assert(link);
- assert(link->ifname);
-
- link->setting_mtu = false;
-
- if (IN_SET(link->state, LINK_STATE_FAILED, LINK_STATE_LINGER))
- return 1;
-
- r = sd_netlink_message_get_errno(m);
- if (r < 0)
- log_link_message_warning_errno(link, m, r, "Could not set MTU, ignoring");
- else
- log_link_debug(link, "Setting MTU done.");
-
- if (link->state == LINK_STATE_INITIALIZED) {
- r = link_configure_continue(link);
- if (r < 0)
- link_enter_failed(link);
- }
-
- return 1;
-}
-
-int link_set_mtu(Link *link, uint32_t mtu) {
- _cleanup_(sd_netlink_message_unrefp) sd_netlink_message *req = NULL;
- int r;
-
- assert(link);
- assert(link->manager);
- assert(link->manager->rtnl);
-
- if (mtu == 0 || link->setting_mtu)
- return 0;
-
- if (link->mtu == mtu)
- return 0;
-
- log_link_debug(link, "Setting MTU: %" PRIu32, mtu);
-
- r = sd_rtnl_message_new_link(link->manager->rtnl, &req, RTM_SETLINK, link->ifindex);
- if (r < 0)
- return log_link_error_errno(link, r, "Could not allocate RTM_SETLINK message: %m");
-
- /* IPv6 protocol requires a minimum MTU of IPV6_MTU_MIN(1280) bytes
- * on the interface. Bump up MTU bytes to IPV6_MTU_MIN. */
- if (link_ipv6_enabled(link) && mtu < IPV6_MIN_MTU) {
-
- log_link_warning(link, "Bumping MTU to " STRINGIFY(IPV6_MIN_MTU) ", as "
- "IPv6 is requested and requires a minimum MTU of " STRINGIFY(IPV6_MIN_MTU) " bytes");
-
- mtu = IPV6_MIN_MTU;
- }
-
- r = sd_netlink_message_append_u32(req, IFLA_MTU, mtu);
- if (r < 0)
- return log_link_error_errno(link, r, "Could not append MTU: %m");
-
- r = netlink_call_async(link->manager->rtnl, NULL, req, set_mtu_handler,
- link_netlink_destroy_callback, link);
- if (r < 0)
- return log_link_error_errno(link, r, "Could not send rtnetlink message: %m");
-
- link_ref(link);
- link->setting_mtu = true;
-
- return 0;
-}
+ return 0;
+}
static bool link_reduces_vlan_mtu(Link *link) {
/* See netif_reduces_vlan_mtu() in kernel. */
assert(link);
- if (link_ipv6_accept_ra_enabled(link)) {
- assert(link->ndisc);
-
+ if (link->ndisc) {
log_link_debug(link, "Discovering IPv6 routers");
r = sd_ndisc_start(link->ndisc);
return log_link_warning_errno(link, r, "Could not start IPv6 Router Discovery: %m");
}
- if (link_radv_enabled(link)) {
+ if (link->radv) {
assert(link->radv);
assert(in_addr_is_link_local(AF_INET6, (const union in_addr_union*)&link->ipv6ll_address) > 0);
return log_link_warning_errno(link, r, "Could not acquire IPv4 link-local address: %m");
}
- if (link_dhcp4_enabled(link)) {
- assert(link->dhcp_client);
-
+ if (link->dhcp_client) {
log_link_debug(link, "Acquiring DHCPv4 lease");
r = sd_dhcp_client_start(link->dhcp_client);
return r;
}
- if (link_lldp_emit_enabled(link)) {
- r = link_lldp_emit_start(link);
- if (r < 0)
- return log_link_warning_errno(link, r, "Failed to start LLDP transmission: %m");
- }
+ r = link_lldp_emit_start(link);
+ if (r < 0)
+ return log_link_warning_errno(link, r, "Failed to start LLDP transmission: %m");
return 0;
}
log_link_debug(link, "Setting group");
- r = sd_rtnl_message_new_link(link->manager->rtnl, &req, RTM_SETLINK, link->ifindex);
- if (r < 0)
- return log_link_error_errno(link, r, "Could not allocate RTM_SETLINK message: %m");
-
- r = sd_netlink_message_append_u32(req, IFLA_GROUP, link->network->group);
- if (r < 0)
- return log_link_error_errno(link, r, "Could not set link group: %m");
-
- r = netlink_call_async(link->manager->rtnl, NULL, req, link_group_handler,
- link_netlink_destroy_callback, link);
- if (r < 0)
- return log_link_error_errno(link, r, "Could not send rtnetlink message: %m");
-
- link_ref(link);
-
- return 0;
-}
-
-static int link_handle_bound_to_list(Link *link) {
- Link *l;
- int r;
- bool required_up = false;
- bool link_is_up = false;
-
- assert(link);
-
- if (hashmap_isempty(link->bound_to_links))
- return 0;
-
- if (link->flags & IFF_UP)
- link_is_up = true;
-
- HASHMAP_FOREACH (l, link->bound_to_links)
- if (link_has_carrier(l)) {
- required_up = true;
- break;
- }
-
- if (!required_up && link_is_up) {
- r = link_down(link, NULL);
- if (r < 0)
- return r;
- } else if (required_up && !link_is_up) {
- r = link_up(link);
- if (r < 0)
- return r;
- }
-
- return 0;
-}
-
-static int link_handle_bound_by_list(Link *link) {
- Link *l;
- int r;
-
- assert(link);
-
- if (hashmap_isempty(link->bound_by_links))
- return 0;
-
- HASHMAP_FOREACH (l, link->bound_by_links) {
- r = link_handle_bound_to_list(l);
- if (r < 0)
- return r;
- }
-
- return 0;
-}
-
-static int link_put_carrier(Link *link, Link *carrier, Hashmap **h) {
- int r;
-
- assert(link);
- assert(carrier);
-
- if (link == carrier)
- return 0;
-
- if (hashmap_get(*h, INT_TO_PTR(carrier->ifindex)))
- return 0;
-
- r = hashmap_ensure_allocated(h, NULL);
- if (r < 0)
- return r;
-
- r = hashmap_put(*h, INT_TO_PTR(carrier->ifindex), carrier);
- if (r < 0)
- return r;
-
- return 0;
-}
-
-static int link_new_bound_by_list(Link *link) {
- Manager *m;
- Link *carrier;
- int r;
- bool list_updated = false;
-
- assert(link);
- assert(link->manager);
-
- m = link->manager;
-
- HASHMAP_FOREACH(carrier, m->links) {
- if (!carrier->network)
- continue;
-
- if (strv_isempty(carrier->network->bind_carrier))
- continue;
-
- if (strv_fnmatch(carrier->network->bind_carrier, link->ifname)) {
- r = link_put_carrier(link, carrier, &link->bound_by_links);
- if (r < 0)
- return r;
-
- list_updated = true;
- }
- }
-
- if (list_updated)
- link_dirty(link);
-
- HASHMAP_FOREACH(carrier, link->bound_by_links) {
- r = link_put_carrier(carrier, link, &carrier->bound_to_links);
- if (r < 0)
- return r;
-
- link_dirty(carrier);
- }
-
- return 0;
-}
-
-static int link_new_bound_to_list(Link *link) {
- Manager *m;
- Link *carrier;
- int r;
- bool list_updated = false;
-
- assert(link);
- assert(link->manager);
-
- if (!link->network)
- return 0;
-
- if (strv_isempty(link->network->bind_carrier))
- return 0;
-
- m = link->manager;
-
- HASHMAP_FOREACH (carrier, m->links) {
- if (strv_fnmatch(link->network->bind_carrier, carrier->ifname)) {
- r = link_put_carrier(link, carrier, &link->bound_to_links);
- if (r < 0)
- return r;
-
- list_updated = true;
- }
- }
-
- if (list_updated)
- link_dirty(link);
-
- HASHMAP_FOREACH (carrier, link->bound_to_links) {
- r = link_put_carrier(carrier, link, &carrier->bound_by_links);
- if (r < 0)
- return r;
-
- link_dirty(carrier);
- }
-
- return 0;
-}
-
-static int link_new_carrier_maps(Link *link) {
- int r;
-
- r = link_new_bound_by_list(link);
- if (r < 0)
- return r;
-
- r = link_handle_bound_by_list(link);
- if (r < 0)
- return r;
-
- r = link_new_bound_to_list(link);
- if (r < 0)
- return r;
-
- r = link_handle_bound_to_list(link);
- if (r < 0)
- return r;
-
- return 0;
-}
-
-static void link_free_bound_to_list(Link *link) {
- Link *bound_to;
-
- HASHMAP_FOREACH (bound_to, link->bound_to_links) {
- hashmap_remove(link->bound_to_links, INT_TO_PTR(bound_to->ifindex));
-
- if (hashmap_remove(bound_to->bound_by_links, INT_TO_PTR(link->ifindex)))
- link_dirty(bound_to);
- }
-
- return;
-}
-
-static void link_free_bound_by_list(Link *link) {
- Link *bound_by;
-
- HASHMAP_FOREACH (bound_by, link->bound_by_links) {
- hashmap_remove(link->bound_by_links, INT_TO_PTR(bound_by->ifindex));
-
- if (hashmap_remove(bound_by->bound_to_links, INT_TO_PTR(link->ifindex))) {
- link_dirty(bound_by);
- link_handle_bound_to_list(bound_by);
- }
- }
-
- return;
-}
-
-static void link_free_carrier_maps(Link *link) {
- bool list_updated = false;
-
- assert(link);
-
- if (!hashmap_isempty(link->bound_to_links)) {
- link_free_bound_to_list(link);
- list_updated = true;
- }
-
- if (!hashmap_isempty(link->bound_by_links)) {
- link_free_bound_by_list(link);
- list_updated = true;
- }
-
- if (list_updated)
- link_dirty(link);
-
- return;
-}
-
-static int link_append_to_master(Link *link, NetDev *netdev) {
- Link *master;
- int r;
-
- assert(link);
- assert(netdev);
-
- r = link_get(link->manager, netdev->ifindex, &master);
- if (r < 0)
- return r;
-
- r = set_ensure_put(&master->slaves, NULL, link);
- if (r <= 0)
- return r;
-
- link_ref(link);
- return 0;
-}
-
-static void link_drop_from_master(Link *link, NetDev *netdev) {
- Link *master;
-
- assert(link);
-
- if (!link->manager || !netdev)
- return;
-
- if (link_get(link->manager, netdev->ifindex, &master) < 0)
- return;
-
- link_unref(set_remove(master->slaves, link));
-}
-
-static void link_detach_from_manager(Link *link) {
- if (!link || !link->manager)
- return;
-
- link_unref(set_remove(link->manager->links_requesting_uuid, link));
- link_clean(link);
-
- /* The following must be called at last. */
- assert_se(hashmap_remove(link->manager->links, INT_TO_PTR(link->ifindex)) == link);
- link_unref(link);
-}
-
-void link_drop(Link *link) {
- if (!link || link->state == LINK_STATE_LINGER)
- return;
-
- link_set_state(link, LINK_STATE_LINGER);
-
- link_free_carrier_maps(link);
-
- if (link->network) {
- link_drop_from_master(link, link->network->bridge);
- link_drop_from_master(link, link->network->bond);
- }
-
- log_link_debug(link, "Link removed");
-
- (void) unlink(link->state_file);
- link_detach_from_manager(link);
-}
-
-static int link_joined(Link *link) {
- int r;
-
- assert(link);
- assert(link->network);
-
- if (!hashmap_isempty(link->bound_to_links)) {
- r = link_handle_bound_to_list(link);
- if (r < 0)
- return r;
- } else if (!(link->flags & IFF_UP)) {
- r = link_up(link);
- if (r < 0) {
- link_enter_failed(link);
- return r;
- }
- }
-
- if (link->network->bridge) {
- r = link_set_bridge(link);
- if (r < 0)
- log_link_error_errno(link, r, "Could not set bridge message: %m");
-
- r = link_append_to_master(link, link->network->bridge);
- if (r < 0)
- log_link_error_errno(link, r, "Failed to add to bridge master's slave list: %m");
- }
-
- if (link->network->bond) {
- r = link_set_bond(link);
- if (r < 0)
- log_link_error_errno(link, r, "Could not set bond message: %m");
-
- r = link_append_to_master(link, link->network->bond);
- if (r < 0)
- log_link_error_errno(link, r, "Failed to add to bond master's slave list: %m");
- }
-
- if (link->network->use_br_vlan &&
- (link->network->bridge || streq_ptr("bridge", link->kind))) {
- r = link_set_bridge_vlan(link);
- if (r < 0)
- log_link_error_errno(link, r, "Could not set bridge vlan: %m");
- }
-
- /* Skip setting up addresses until it gets carrier,
- or it would try to set addresses twice,
- which is bad for non-idempotent steps. */
- if (!link_has_carrier(link) && !link->network->configure_without_carrier)
- return 0;
-
- link_set_state(link, LINK_STATE_CONFIGURING);
- return link_request_set_addresses(link);
-}
-
-static int netdev_join_handler(sd_netlink *rtnl, sd_netlink_message *m, Link *link) {
- int r;
-
- assert(link);
- assert(link->network);
- assert(link->enslaving > 0);
-
- link->enslaving--;
-
- if (IN_SET(link->state, LINK_STATE_FAILED, LINK_STATE_LINGER))
- return 1;
-
- r = sd_netlink_message_get_errno(m);
- if (r < 0 && r != -EEXIST) {
- log_link_message_warning_errno(link, m, r, "Could not join netdev");
- link_enter_failed(link);
- return 1;
- }
-
- log_link_debug(link, "Joined netdev");
-
- if (link->enslaving == 0) {
- r = link_joined(link);
- if (r < 0)
- link_enter_failed(link);
- }
-
- return 1;
-}
-
-static int link_enter_join_netdev(Link *link) {
- NetDev *netdev;
- int r;
-
- assert(link);
- assert(link->network);
- assert(link->state == LINK_STATE_INITIALIZED);
-
- link_set_state(link, LINK_STATE_CONFIGURING);
-
- link_dirty(link);
- link->enslaving = 0;
-
- if (link->network->bond) {
- if (link->network->bond->state == NETDEV_STATE_READY &&
- link->network->bond->ifindex == link->master_ifindex)
- return link_joined(link);
-
- log_struct(LOG_DEBUG,
- LOG_LINK_INTERFACE(link),
- LOG_NETDEV_INTERFACE(link->network->bond),
- LOG_LINK_MESSAGE(link, "Enslaving by '%s'", link->network->bond->ifname));
-
- link->enslaving++;
-
- r = netdev_join(link->network->bond, link, netdev_join_handler);
- if (r < 0) {
- log_struct_errno(LOG_WARNING, r,
- LOG_LINK_INTERFACE(link),
- LOG_NETDEV_INTERFACE(link->network->bond),
- LOG_LINK_MESSAGE(link, "Could not join netdev '%s': %m", link->network->bond->ifname));
- link_enter_failed(link);
- return r;
- }
- }
-
- if (link->network->bridge) {
- log_struct(LOG_DEBUG,
- LOG_LINK_INTERFACE(link),
- LOG_NETDEV_INTERFACE(link->network->bridge),
- LOG_LINK_MESSAGE(link, "Enslaving by '%s'", link->network->bridge->ifname));
-
- link->enslaving++;
-
- r = netdev_join(link->network->bridge, link, netdev_join_handler);
- if (r < 0) {
- log_struct_errno(LOG_WARNING, r,
- LOG_LINK_INTERFACE(link),
- LOG_NETDEV_INTERFACE(link->network->bridge),
- LOG_LINK_MESSAGE(link, "Could not join netdev '%s': %m", link->network->bridge->ifname));
- link_enter_failed(link);
- return r;
- }
- }
-
- if (link->network->vrf) {
- log_struct(LOG_DEBUG,
- LOG_LINK_INTERFACE(link),
- LOG_NETDEV_INTERFACE(link->network->vrf),
- LOG_LINK_MESSAGE(link, "Enslaving by '%s'", link->network->vrf->ifname));
-
- link->enslaving++;
-
- r = netdev_join(link->network->vrf, link, netdev_join_handler);
- if (r < 0) {
- log_struct_errno(LOG_WARNING, r,
- LOG_LINK_INTERFACE(link),
- LOG_NETDEV_INTERFACE(link->network->vrf),
- LOG_LINK_MESSAGE(link, "Could not join netdev '%s': %m", link->network->vrf->ifname));
- link_enter_failed(link);
- return r;
- }
- }
-
- HASHMAP_FOREACH(netdev, link->network->stacked_netdevs) {
-
- if (netdev->ifindex > 0)
- /* Assume already enslaved. */
- continue;
-
- if (netdev_get_create_type(netdev) != NETDEV_CREATE_STACKED)
- continue;
-
- log_struct(LOG_DEBUG,
- LOG_LINK_INTERFACE(link),
- LOG_NETDEV_INTERFACE(netdev),
- LOG_LINK_MESSAGE(link, "Enslaving by '%s'", netdev->ifname));
-
- link->enslaving++;
-
- r = netdev_join(netdev, link, netdev_join_handler);
- if (r < 0) {
- log_struct_errno(LOG_WARNING, r,
- LOG_LINK_INTERFACE(link),
- LOG_NETDEV_INTERFACE(netdev),
- LOG_LINK_MESSAGE(link, "Could not join netdev '%s': %m", netdev->ifname));
- link_enter_failed(link);
- return r;
- }
- }
-
- if (link->enslaving == 0)
- return link_joined(link);
-
- return 0;
-}
-
-static int link_set_ipv4_forward(Link *link) {
- int r;
-
- if (!link_ipv4_forward_enabled(link))
- return 0;
+ r = sd_rtnl_message_new_link(link->manager->rtnl, &req, RTM_SETLINK, link->ifindex);
+ if (r < 0)
+ return log_link_error_errno(link, r, "Could not allocate RTM_SETLINK message: %m");
- /* We propagate the forwarding flag from one interface to the
- * global setting one way. This means: as long as at least one
- * interface was configured at any time that had IP forwarding
- * enabled the setting will stay on for good. We do this
- * primarily to keep IPv4 and IPv6 packet forwarding behaviour
- * somewhat in sync (see below). */
+ r = sd_netlink_message_append_u32(req, IFLA_GROUP, link->network->group);
+ if (r < 0)
+ return log_link_error_errno(link, r, "Could not set link group: %m");
- r = sysctl_write_ip_property(AF_INET, NULL, "ip_forward", "1");
+ r = netlink_call_async(link->manager->rtnl, NULL, req, link_group_handler,
+ link_netlink_destroy_callback, link);
if (r < 0)
- log_link_warning_errno(link, r, "Cannot turn on IPv4 packet forwarding, ignoring: %m");
+ return log_link_error_errno(link, r, "Could not send rtnetlink message: %m");
+
+ link_ref(link);
return 0;
}
-static int link_set_ipv6_forward(Link *link) {
+static int link_handle_bound_to_list(Link *link) {
+ Link *l;
int r;
+ bool required_up = false;
+ bool link_is_up = false;
- if (!link_ipv6_forward_enabled(link))
+ assert(link);
+
+ if (hashmap_isempty(link->bound_to_links))
return 0;
- /* On Linux, the IPv6 stack does not know a per-interface
- * packet forwarding setting: either packet forwarding is on
- * for all, or off for all. We hence don't bother with a
- * per-interface setting, but simply propagate the interface
- * flag, if it is set, to the global flag, one-way. Note that
- * while IPv4 would allow a per-interface flag, we expose the
- * same behaviour there and also propagate the setting from
- * one to all, to keep things simple (see above). */
+ if (link->flags & IFF_UP)
+ link_is_up = true;
- r = sysctl_write_ip_property(AF_INET6, "all", "forwarding", "1");
- if (r < 0)
- log_link_warning_errno(link, r, "Cannot configure IPv6 packet forwarding, ignoring: %m");
+ HASHMAP_FOREACH (l, link->bound_to_links)
+ if (link_has_carrier(l)) {
+ required_up = true;
+ break;
+ }
+
+ if (!required_up && link_is_up) {
+ r = link_down(link, NULL);
+ if (r < 0)
+ return r;
+ } else if (required_up && !link_is_up) {
+ r = link_up(link);
+ if (r < 0)
+ return r;
+ }
return 0;
}
-static int link_set_ipv6_privacy_extensions(Link *link) {
- IPv6PrivacyExtensions s;
+static int link_handle_bound_by_list(Link *link) {
+ Link *l;
int r;
- s = link_ipv6_privacy_extensions(link);
- if (s < 0)
+ assert(link);
+
+ if (hashmap_isempty(link->bound_by_links))
return 0;
- r = sysctl_write_ip_property_int(AF_INET6, link->ifname, "use_tempaddr", (int) link->network->ipv6_privacy_extensions);
- if (r < 0)
- log_link_warning_errno(link, r, "Cannot configure IPv6 privacy extension for interface: %m");
+ HASHMAP_FOREACH (l, link->bound_by_links) {
+ r = link_handle_bound_to_list(l);
+ if (r < 0)
+ return r;
+ }
return 0;
}
-static int link_set_ipv6_accept_ra(Link *link) {
+static int link_put_carrier(Link *link, Link *carrier, Hashmap **h) {
int r;
- /* Make this a NOP if IPv6 is not available */
- if (!socket_ipv6_is_supported())
- return 0;
+ assert(link);
+ assert(carrier);
- if (link->flags & IFF_LOOPBACK)
+ if (link == carrier)
return 0;
- if (!link->network)
+ if (hashmap_get(*h, INT_TO_PTR(carrier->ifindex)))
return 0;
- r = sysctl_write_ip_property(AF_INET6, link->ifname, "accept_ra", "0");
+ r = hashmap_ensure_allocated(h, NULL);
+ if (r < 0)
+ return r;
+
+ r = hashmap_put(*h, INT_TO_PTR(carrier->ifindex), carrier);
if (r < 0)
- log_link_warning_errno(link, r, "Cannot disable kernel IPv6 accept_ra for interface: %m");
+ return r;
return 0;
}
-static int link_set_ipv6_dad_transmits(Link *link) {
+static int link_new_bound_by_list(Link *link) {
+ Manager *m;
+ Link *carrier;
int r;
+ bool list_updated = false;
- /* Make this a NOP if IPv6 is not available */
- if (!socket_ipv6_is_supported())
- return 0;
-
- if (link->flags & IFF_LOOPBACK)
- return 0;
-
- if (!link->network)
- return 0;
-
- if (link->network->ipv6_dad_transmits < 0)
- return 0;
+ assert(link);
+ assert(link->manager);
- r = sysctl_write_ip_property_int(AF_INET6, link->ifname, "dad_transmits", link->network->ipv6_dad_transmits);
- if (r < 0)
- log_link_warning_errno(link, r, "Cannot set IPv6 dad transmits for interface: %m");
+ m = link->manager;
- return 0;
-}
+ HASHMAP_FOREACH(carrier, m->links) {
+ if (!carrier->network)
+ continue;
-static int link_set_ipv6_hop_limit(Link *link) {
- int r;
+ if (strv_isempty(carrier->network->bind_carrier))
+ continue;
- /* Make this a NOP if IPv6 is not available */
- if (!socket_ipv6_is_supported())
- return 0;
+ if (strv_fnmatch(carrier->network->bind_carrier, link->ifname)) {
+ r = link_put_carrier(link, carrier, &link->bound_by_links);
+ if (r < 0)
+ return r;
- if (link->flags & IFF_LOOPBACK)
- return 0;
+ list_updated = true;
+ }
+ }
- if (!link->network)
- return 0;
+ if (list_updated)
+ link_dirty(link);
- if (link->network->ipv6_hop_limit < 0)
- return 0;
+ HASHMAP_FOREACH(carrier, link->bound_by_links) {
+ r = link_put_carrier(carrier, link, &carrier->bound_to_links);
+ if (r < 0)
+ return r;
- r = sysctl_write_ip_property_int(AF_INET6, link->ifname, "hop_limit", link->network->ipv6_hop_limit);
- if (r < 0)
- log_link_warning_errno(link, r, "Cannot set IPv6 hop limit for interface: %m");
+ link_dirty(carrier);
+ }
return 0;
}
-static int link_set_ipv6_mtu(Link *link) {
+static int link_new_bound_to_list(Link *link) {
+ Manager *m;
+ Link *carrier;
int r;
+ bool list_updated = false;
- /* Make this a NOP if IPv6 is not available */
- if (!socket_ipv6_is_supported())
- return 0;
+ assert(link);
+ assert(link->manager);
- if (link->flags & IFF_LOOPBACK)
+ if (!link->network)
return 0;
- if (link->network->ipv6_mtu == 0)
+ if (strv_isempty(link->network->bind_carrier))
return 0;
- /* IPv6 protocol requires a minimum MTU of IPV6_MTU_MIN(1280) bytes
- * on the interface. Bump up IPv6 MTU bytes to IPV6_MTU_MIN. */
- if (link->network->ipv6_mtu < IPV6_MIN_MTU) {
- log_link_notice(link, "Bumping IPv6 MTU to "STRINGIFY(IPV6_MIN_MTU)" byte minimum required");
- link->network->ipv6_mtu = IPV6_MIN_MTU;
- }
+ m = link->manager;
- r = sysctl_write_ip_property_uint32(AF_INET6, link->ifname, "mtu", link->network->ipv6_mtu);
- if (r < 0) {
- if (link->mtu < link->network->ipv6_mtu)
- log_link_warning(link, "Cannot set IPv6 MTU %"PRIu32" higher than device MTU %"PRIu32,
- link->network->ipv6_mtu, link->mtu);
- else
- log_link_warning_errno(link, r, "Cannot set IPv6 MTU for interface: %m");
+ HASHMAP_FOREACH (carrier, m->links) {
+ if (strv_fnmatch(link->network->bind_carrier, carrier->ifname)) {
+ r = link_put_carrier(link, carrier, &link->bound_to_links);
+ if (r < 0)
+ return r;
+
+ list_updated = true;
+ }
}
- link->ipv6_mtu_set = true;
+ if (list_updated)
+ link_dirty(link);
+
+ HASHMAP_FOREACH (carrier, link->bound_to_links) {
+ r = link_put_carrier(carrier, link, &carrier->bound_by_links);
+ if (r < 0)
+ return r;
+
+ link_dirty(carrier);
+ }
return 0;
}
-static int link_set_ipv4_accept_local(Link *link) {
+static int link_new_carrier_maps(Link *link) {
int r;
- if (link->flags & IFF_LOOPBACK)
- return 0;
+ r = link_new_bound_by_list(link);
+ if (r < 0)
+ return r;
- if (link->network->ipv4_accept_local < 0)
- return 0;
+ r = link_handle_bound_by_list(link);
+ if (r < 0)
+ return r;
+
+ r = link_new_bound_to_list(link);
+ if (r < 0)
+ return r;
- r = sysctl_write_ip_property_boolean(AF_INET, link->ifname, "accept_local", link->network->ipv4_accept_local);
+ r = link_handle_bound_to_list(link);
if (r < 0)
- log_link_warning_errno(link, r, "Cannot set IPv4 accept_local flag for interface: %m");
+ return r;
return 0;
}
-static bool link_is_static_address_configured(Link *link, Address *address) {
- Address *net_address;
+static void link_free_bound_to_list(Link *link) {
+ Link *bound_to;
- assert(link);
- assert(address);
+ HASHMAP_FOREACH (bound_to, link->bound_to_links) {
+ hashmap_remove(link->bound_to_links, INT_TO_PTR(bound_to->ifindex));
- if (!link->network)
- return false;
+ if (hashmap_remove(bound_to->bound_by_links, INT_TO_PTR(link->ifindex)))
+ link_dirty(bound_to);
+ }
- LIST_FOREACH(addresses, net_address, link->network->static_addresses)
- if (address_equal(net_address, address))
- return true;
- else if (address->family == AF_INET6 && net_address->family == AF_INET6 &&
- in_addr_equal(AF_INET6, &address->in_addr, &net_address->in_addr_peer) > 0)
- return true;
+ return;
+}
- return false;
+static void link_free_bound_by_list(Link *link) {
+ Link *bound_by;
+
+ HASHMAP_FOREACH (bound_by, link->bound_by_links) {
+ hashmap_remove(link->bound_by_links, INT_TO_PTR(bound_by->ifindex));
+
+ if (hashmap_remove(bound_by->bound_to_links, INT_TO_PTR(link->ifindex))) {
+ link_dirty(bound_by);
+ link_handle_bound_to_list(bound_by);
+ }
+ }
+
+ return;
}
-static bool link_is_neighbor_configured(Link *link, Neighbor *neighbor) {
- Neighbor *net_neighbor;
+static void link_free_carrier_maps(Link *link) {
+ bool list_updated = false;
assert(link);
- assert(neighbor);
- if (!link->network)
- return false;
+ if (!hashmap_isempty(link->bound_to_links)) {
+ link_free_bound_to_list(link);
+ list_updated = true;
+ }
- LIST_FOREACH(neighbors, net_neighbor, link->network->neighbors)
- if (neighbor_equal(net_neighbor, neighbor))
- return true;
+ if (!hashmap_isempty(link->bound_by_links)) {
+ link_free_bound_by_list(link);
+ list_updated = true;
+ }
- return false;
+ if (list_updated)
+ link_dirty(link);
+
+ return;
}
-static bool link_is_static_route_configured(Link *link, Route *route) {
- Route *net_route;
+static int link_append_to_master(Link *link, NetDev *netdev) {
+ Link *master;
+ int r;
assert(link);
- assert(route);
+ assert(netdev);
- if (!link->network)
- return false;
+ r = link_get(link->manager, netdev->ifindex, &master);
+ if (r < 0)
+ return r;
- LIST_FOREACH(routes, net_route, link->network->static_routes)
- if (route_equal(net_route, route))
- return true;
+ r = set_ensure_put(&master->slaves, NULL, link);
+ if (r <= 0)
+ return r;
- return false;
+ link_ref(link);
+ return 0;
}
-static bool link_address_is_dynamic(Link *link, Address *address) {
- Route *route;
+static void link_drop_from_master(Link *link, NetDev *netdev) {
+ Link *master;
assert(link);
- assert(address);
-
- if (address->cinfo.ifa_prefered != CACHE_INFO_INFINITY_LIFE_TIME)
- return true;
- /* Even when the address is leased from a DHCP server, networkd assign the address
- * without lifetime when KeepConfiguration=dhcp. So, let's check that we have
- * corresponding routes with RTPROT_DHCP. */
- SET_FOREACH(route, link->routes_foreign) {
- if (route->protocol != RTPROT_DHCP)
- continue;
-
- if (address->family != route->family)
- continue;
+ if (!link->manager || !netdev)
+ return;
- if (in_addr_equal(address->family, &address->in_addr, &route->prefsrc))
- return true;
- }
+ if (link_get(link->manager, netdev->ifindex, &master) < 0)
+ return;
- return false;
+ link_unref(set_remove(master->slaves, link));
}
-static int link_enumerate_ipv6_tentative_addresses(Link *link) {
- _cleanup_(sd_netlink_message_unrefp) sd_netlink_message *req = NULL, *reply = NULL;
- sd_netlink_message *addr;
- int r;
-
- assert(link);
- assert(link->manager);
- assert(link->manager->rtnl);
+static void link_detach_from_manager(Link *link) {
+ if (!link || !link->manager)
+ return;
- r = sd_rtnl_message_new_addr(link->manager->rtnl, &req, RTM_GETADDR, 0, AF_INET6);
- if (r < 0)
- return r;
+ link_unref(set_remove(link->manager->links_requesting_uuid, link));
+ link_clean(link);
- r = sd_netlink_call(link->manager->rtnl, req, 0, &reply);
- if (r < 0)
- return r;
+ /* The following must be called at last. */
+ assert_se(hashmap_remove(link->manager->links, INT_TO_PTR(link->ifindex)) == link);
+ link_unref(link);
+}
- for (addr = reply; addr; addr = sd_netlink_message_next(addr)) {
- unsigned char flags;
- int ifindex;
+void link_drop(Link *link) {
+ if (!link || link->state == LINK_STATE_LINGER)
+ return;
- r = sd_rtnl_message_addr_get_ifindex(addr, &ifindex);
- if (r < 0) {
- log_link_warning_errno(link, r, "rtnl: invalid ifindex, ignoring: %m");
- continue;
- } else if (link->ifindex != ifindex)
- continue;
+ link_set_state(link, LINK_STATE_LINGER);
- r = sd_rtnl_message_addr_get_flags(addr, &flags);
- if (r < 0) {
- log_link_warning_errno(link, r, "rtnl: received address message with invalid flags, ignoring: %m");
- continue;
- } else if (!(flags & IFA_F_TENTATIVE))
- continue;
+ link_free_carrier_maps(link);
- log_link_debug(link, "Found tentative ipv6 link-local address");
- (void) manager_rtnl_process_address(link->manager->rtnl, addr, link->manager);
+ if (link->network) {
+ link_drop_from_master(link, link->network->bridge);
+ link_drop_from_master(link, link->network->bond);
}
- return 0;
+ log_link_debug(link, "Link removed");
+
+ (void) unlink(link->state_file);
+ link_detach_from_manager(link);
}
-static int link_drop_foreign_config(Link *link) {
- Address *address;
- Neighbor *neighbor;
- Route *route;
+static int link_joined(Link *link) {
int r;
- /* The kernel doesn't notify us about tentative addresses;
- * so if ipv6ll is disabled, we need to enumerate them now so we can drop them below */
- if (!link_ipv6ll_enabled(link)) {
- r = link_enumerate_ipv6_tentative_addresses(link);
+ assert(link);
+ assert(link->network);
+
+ if (!hashmap_isempty(link->bound_to_links)) {
+ r = link_handle_bound_to_list(link);
if (r < 0)
return r;
+ } else if (!(link->flags & IFF_UP)) {
+ r = link_up(link);
+ if (r < 0) {
+ link_enter_failed(link);
+ return r;
+ }
}
- SET_FOREACH(address, link->addresses_foreign) {
- /* we consider IPv6LL addresses to be managed by the kernel */
- if (address->family == AF_INET6 && in_addr_is_link_local(AF_INET6, &address->in_addr) == 1 && link_ipv6ll_enabled(link))
- continue;
-
- if (link_address_is_dynamic(link, address)) {
- if (link->network && FLAGS_SET(link->network->keep_configuration, KEEP_CONFIGURATION_DHCP))
- continue;
- } else if (link->network && FLAGS_SET(link->network->keep_configuration, KEEP_CONFIGURATION_STATIC))
- continue;
+ if (link->network->bridge) {
+ r = link_set_bridge(link);
+ if (r < 0)
+ log_link_error_errno(link, r, "Could not set bridge message: %m");
- if (link_is_static_address_configured(link, address)) {
- r = address_add(link, address->family, &address->in_addr, address->prefixlen, NULL);
- if (r < 0)
- return log_link_error_errno(link, r, "Failed to add address: %m");
- } else {
- r = address_remove(address, link, NULL);
- if (r < 0)
- return r;
- }
+ r = link_append_to_master(link, link->network->bridge);
+ if (r < 0)
+ log_link_error_errno(link, r, "Failed to add to bridge master's slave list: %m");
}
- SET_FOREACH(neighbor, link->neighbors_foreign) {
- if (link_is_neighbor_configured(link, neighbor)) {
- r = neighbor_add(link, neighbor->family, &neighbor->in_addr, &neighbor->lladdr, neighbor->lladdr_size, NULL);
- if (r < 0)
- return r;
- } else {
- r = neighbor_remove(neighbor, link, NULL);
- if (r < 0)
- return r;
- }
- }
+ if (link->network->bond) {
+ r = link_set_bond(link);
+ if (r < 0)
+ log_link_error_errno(link, r, "Could not set bond message: %m");
- SET_FOREACH(route, link->routes_foreign) {
- /* do not touch routes managed by the kernel */
- if (route->protocol == RTPROT_KERNEL)
- continue;
+ r = link_append_to_master(link, link->network->bond);
+ if (r < 0)
+ log_link_error_errno(link, r, "Failed to add to bond master's slave list: %m");
+ }
- /* do not touch multicast route added by kernel */
- /* FIXME: Why the kernel adds this route with protocol RTPROT_BOOT??? We need to investigate that.
- * https://tools.ietf.org/html/rfc4862#section-5.4 may explain why. */
- if (route->protocol == RTPROT_BOOT &&
- route->family == AF_INET6 &&
- route->dst_prefixlen == 8 &&
- in_addr_equal(AF_INET6, &route->dst, &(union in_addr_union) { .in6 = {{{ 0xff,0,0,0, 0,0,0,0, 0,0,0,0, 0,0,0,0 }}} }))
- continue;
+ r = link_set_bridge_vlan(link);
+ if (r < 0)
+ log_link_error_errno(link, r, "Could not set bridge vlan: %m");
- if (route->protocol == RTPROT_STATIC && link->network &&
- FLAGS_SET(link->network->keep_configuration, KEEP_CONFIGURATION_STATIC))
- continue;
+ /* Skip setting up addresses until it gets carrier,
+ or it would try to set addresses twice,
+ which is bad for non-idempotent steps. */
+ if (!link_has_carrier(link) && !link->network->configure_without_carrier)
+ return 0;
- if (route->protocol == RTPROT_DHCP && link->network &&
- FLAGS_SET(link->network->keep_configuration, KEEP_CONFIGURATION_DHCP))
- continue;
+ link_set_state(link, LINK_STATE_CONFIGURING);
- if (link_is_static_route_configured(link, route)) {
- r = route_add(link, route, NULL);
- if (r < 0)
- return r;
- } else {
- r = route_remove(route, link, NULL);
- if (r < 0)
- return r;
- }
- }
+ r = link_acquire_conf(link);
+ if (r < 0)
+ return r;
- return 0;
+ return link_set_static_configs(link);
}
-static int remove_static_address_handler(sd_netlink *rtnl, sd_netlink_message *m, Link *link) {
+static int netdev_join_handler(sd_netlink *rtnl, sd_netlink_message *m, Link *link) {
int r;
- assert(m);
assert(link);
- assert(link->ifname);
- assert(link->address_remove_messages > 0);
+ assert(link->network);
+ assert(link->enslaving > 0);
- link->address_remove_messages--;
+ link->enslaving--;
if (IN_SET(link->state, LINK_STATE_FAILED, LINK_STATE_LINGER))
return 1;
r = sd_netlink_message_get_errno(m);
- if (r < 0 && r != -EADDRNOTAVAIL)
- log_link_message_warning_errno(link, m, r, "Could not drop address");
- else if (r >= 0)
- (void) manager_rtnl_process_address(rtnl, m, link->manager);
+ if (r < 0 && r != -EEXIST) {
+ log_link_message_warning_errno(link, m, r, "Could not join netdev");
+ link_enter_failed(link);
+ return 1;
+ }
- if (link->address_remove_messages == 0 && link->request_static_addresses) {
- link_set_state(link, LINK_STATE_CONFIGURING);
- r = link_request_set_addresses(link);
+ log_link_debug(link, "Joined netdev");
+
+ if (link->enslaving == 0) {
+ r = link_joined(link);
if (r < 0)
link_enter_failed(link);
}
return 1;
}
-static int link_drop_config(Link *link) {
- Address *address, *pool_address;
- Neighbor *neighbor;
- Route *route;
+static int link_enter_join_netdev(Link *link) {
+ NetDev *netdev;
int r;
- SET_FOREACH(address, link->addresses) {
- /* we consider IPv6LL addresses to be managed by the kernel */
- if (address->family == AF_INET6 && in_addr_is_link_local(AF_INET6, &address->in_addr) == 1 && link_ipv6ll_enabled(link))
- continue;
+ assert(link);
+ assert(link->network);
+ assert(link->state == LINK_STATE_INITIALIZED);
- r = address_remove(address, link, remove_static_address_handler);
- if (r < 0)
- return r;
+ link_set_state(link, LINK_STATE_CONFIGURING);
- link->address_remove_messages++;
+ link_dirty(link);
+ link->enslaving = 0;
- /* If this address came from an address pool, clean up the pool */
- LIST_FOREACH(addresses, pool_address, link->pool_addresses)
- if (address_equal(address, pool_address)) {
- LIST_REMOVE(addresses, link->pool_addresses, pool_address);
- address_free(pool_address);
- break;
- }
- }
+ if (link->network->bond) {
+ if (link->network->bond->state == NETDEV_STATE_READY &&
+ link->network->bond->ifindex == link->master_ifindex)
+ return link_joined(link);
- SET_FOREACH(neighbor, link->neighbors) {
- r = neighbor_remove(neighbor, link, NULL);
- if (r < 0)
- return r;
- }
+ log_struct(LOG_DEBUG,
+ LOG_LINK_INTERFACE(link),
+ LOG_NETDEV_INTERFACE(link->network->bond),
+ LOG_LINK_MESSAGE(link, "Enslaving by '%s'", link->network->bond->ifname));
- SET_FOREACH(route, link->routes) {
- /* do not touch routes managed by the kernel */
- if (route->protocol == RTPROT_KERNEL)
- continue;
+ link->enslaving++;
- r = route_remove(route, link, NULL);
- if (r < 0)
+ r = netdev_join(link->network->bond, link, netdev_join_handler);
+ if (r < 0) {
+ log_struct_errno(LOG_WARNING, r,
+ LOG_LINK_INTERFACE(link),
+ LOG_NETDEV_INTERFACE(link->network->bond),
+ LOG_LINK_MESSAGE(link, "Could not join netdev '%s': %m", link->network->bond->ifname));
+ link_enter_failed(link);
return r;
+ }
}
- ndisc_flush(link);
-
- return 0;
-}
-
-static int link_configure_ipv4_dad(Link *link) {
- Address *address;
- int r;
+ if (link->network->bridge) {
+ log_struct(LOG_DEBUG,
+ LOG_LINK_INTERFACE(link),
+ LOG_NETDEV_INTERFACE(link->network->bridge),
+ LOG_LINK_MESSAGE(link, "Enslaving by '%s'", link->network->bridge->ifname));
- assert(link);
- assert(link->network);
+ link->enslaving++;
- LIST_FOREACH(addresses, address, link->network->static_addresses)
- if (address->family == AF_INET &&
- FLAGS_SET(address->duplicate_address_detection, ADDRESS_FAMILY_IPV4)) {
- r = configure_ipv4_duplicate_address_detection(link, address);
- if (r < 0)
- return log_link_error_errno(link, r, "Failed to configure IPv4ACD: %m");
+ r = netdev_join(link->network->bridge, link, netdev_join_handler);
+ if (r < 0) {
+ log_struct_errno(LOG_WARNING, r,
+ LOG_LINK_INTERFACE(link),
+ LOG_NETDEV_INTERFACE(link->network->bridge),
+ LOG_LINK_MESSAGE(link, "Could not join netdev '%s': %m", link->network->bridge->ifname));
+ link_enter_failed(link);
+ return r;
}
+ }
- return 0;
-}
-
-static int link_configure_traffic_control(Link *link) {
- TrafficControl *tc;
- int r;
+ if (link->network->vrf) {
+ log_struct(LOG_DEBUG,
+ LOG_LINK_INTERFACE(link),
+ LOG_NETDEV_INTERFACE(link->network->vrf),
+ LOG_LINK_MESSAGE(link, "Enslaving by '%s'", link->network->vrf->ifname));
- link->tc_configured = false;
- link->tc_messages = 0;
+ link->enslaving++;
- ORDERED_HASHMAP_FOREACH(tc, link->network->tc_by_section) {
- r = traffic_control_configure(link, tc);
- if (r < 0)
+ r = netdev_join(link->network->vrf, link, netdev_join_handler);
+ if (r < 0) {
+ log_struct_errno(LOG_WARNING, r,
+ LOG_LINK_INTERFACE(link),
+ LOG_NETDEV_INTERFACE(link->network->vrf),
+ LOG_LINK_MESSAGE(link, "Could not join netdev '%s': %m", link->network->vrf->ifname));
+ link_enter_failed(link);
return r;
+ }
}
- if (link->tc_messages == 0)
- link->tc_configured = true;
- else
- log_link_debug(link, "Configuring traffic control");
+ HASHMAP_FOREACH(netdev, link->network->stacked_netdevs) {
- return 0;
-}
+ if (netdev->ifindex > 0)
+ /* Assume already enslaved. */
+ continue;
-static int link_configure_sr_iov(Link *link) {
- SRIOV *sr_iov;
- int r;
+ if (netdev_get_create_type(netdev) != NETDEV_CREATE_STACKED)
+ continue;
- link->sr_iov_configured = false;
- link->sr_iov_messages = 0;
+ log_struct(LOG_DEBUG,
+ LOG_LINK_INTERFACE(link),
+ LOG_NETDEV_INTERFACE(netdev),
+ LOG_LINK_MESSAGE(link, "Enslaving by '%s'", netdev->ifname));
- ORDERED_HASHMAP_FOREACH(sr_iov, link->network->sr_iov_by_section) {
- r = sr_iov_configure(link, sr_iov);
- if (r < 0)
+ link->enslaving++;
+
+ r = netdev_join(netdev, link, netdev_join_handler);
+ if (r < 0) {
+ log_struct_errno(LOG_WARNING, r,
+ LOG_LINK_INTERFACE(link),
+ LOG_NETDEV_INTERFACE(netdev),
+ LOG_LINK_MESSAGE(link, "Could not join netdev '%s': %m", netdev->ifname));
+ link_enter_failed(link);
return r;
+ }
}
- if (link->sr_iov_messages == 0)
- link->sr_iov_configured = true;
- else
- log_link_debug(link, "Configuring SR-IOV");
+ if (link->enslaving == 0)
+ return link_joined(link);
return 0;
}
-static int link_configure(Link *link) {
+static int link_drop_foreign_config(Link *link) {
int r;
- assert(link);
- assert(link->network);
- assert(link->state == LINK_STATE_INITIALIZED);
-
- r = link_configure_traffic_control(link);
+ r = link_drop_foreign_addresses(link);
if (r < 0)
return r;
- r = link_configure_sr_iov(link);
+ r = link_drop_foreign_neighbors(link);
if (r < 0)
return r;
- if (link->iftype == ARPHRD_CAN)
- return link_configure_can(link);
-
- /* If IPv6 configured that is static IPv6 address and IPv6LL autoconfiguration is enabled
- * for this interface, then enable IPv6 */
- (void) link_update_ipv6_sysctl(link);
+ return link_drop_foreign_routes(link);
+}
- r = link_set_proxy_arp(link);
- if (r < 0)
- return r;
+static int link_drop_config(Link *link) {
+ int r;
- r = ipv6_proxy_ndp_addresses_configure(link);
+ r = link_drop_addresses(link);
if (r < 0)
return r;
- r = link_set_ipv4_forward(link);
+ r = link_drop_neighbors(link);
if (r < 0)
return r;
- r = link_set_ipv6_forward(link);
+ r = link_drop_routes(link);
if (r < 0)
return r;
- r = link_set_ipv6_privacy_extensions(link);
- if (r < 0)
- return r;
+ ndisc_flush(link);
+
+ return 0;
+}
+
+int link_configure(Link *link) {
+ int r;
- r = link_set_ipv6_accept_ra(link);
+ assert(link);
+ assert(link->network);
+ assert(link->state == LINK_STATE_INITIALIZED);
+
+ r = link_configure_traffic_control(link);
if (r < 0)
return r;
- r = link_set_ipv6_dad_transmits(link);
+ r = link_configure_sr_iov(link);
if (r < 0)
return r;
- r = link_set_ipv6_hop_limit(link);
+ if (link->iftype == ARPHRD_CAN)
+ return link_configure_can(link);
+
+ r = link_set_sysctl(link);
if (r < 0)
return r;
- r = link_set_ipv4_accept_local(link);
+ r = link_set_ipv6_proxy_ndp_addresses(link);
if (r < 0)
return r;
r = link_set_group(link);
if (r < 0)
- return r;
-
- if (link_ipv4ll_enabled(link, ADDRESS_FAMILY_IPV4 | ADDRESS_FAMILY_FALLBACK_IPV4)) {
- r = ipv4ll_configure(link);
- if (r < 0)
- return r;
- }
-
- if (link_dhcp4_enabled(link)) {
- r = dhcp4_set_promote_secondaries(link);
- if (r < 0)
- return r;
-
- r = dhcp4_configure(link);
- if (r < 0)
- return r;
- }
-
- if (link_dhcp4_server_enabled(link)) {
- r = sd_dhcp_server_new(&link->dhcp_server, link->ifindex);
- if (r < 0)
- return r;
+ return r;
- r = sd_dhcp_server_attach_event(link->dhcp_server, NULL, 0);
- if (r < 0)
- return r;
- }
+ r = ipv4ll_configure(link);
+ if (r < 0)
+ return r;
- if (link_dhcp6_enabled(link) ||
- link_ipv6_accept_ra_enabled(link)) {
- r = dhcp6_configure(link);
- if (r < 0)
- return r;
- }
+ r = dhcp4_configure(link);
+ if (r < 0)
+ return r;
- if (link_ipv6_accept_ra_enabled(link)) {
- r = ndisc_configure(link);
- if (r < 0)
- return r;
- }
+ r = dhcp6_configure(link);
+ if (r < 0)
+ return r;
- if (link_radv_enabled(link)) {
- r = radv_configure(link);
- if (r < 0)
- return r;
- }
+ r = ndisc_configure(link);
+ if (r < 0)
+ return r;
- if (link_lldp_rx_enabled(link)) {
- r = link_lldp_rx_configure(link);
- if (r < 0)
- return r;
- }
+ r = radv_configure(link);
+ if (r < 0)
+ return r;
- r = link_configure_mtu(link);
+ r = link_lldp_rx_configure(link);
if (r < 0)
return r;
- r = link_configure_addrgen_mode(link);
+ r = link_configure_mtu(link);
if (r < 0)
return r;
- r = link_configure_ipv4_dad(link);
+ r = link_configure_addrgen_mode(link);
if (r < 0)
return r;
* we must set this here, after we've set device mtu */
r = link_set_ipv6_mtu(link);
if (r < 0)
- return r;
-
- if (link_has_carrier(link) || link->network->configure_without_carrier) {
- r = link_acquire_conf(link);
- if (r < 0)
- return r;
- }
+ log_link_warning_errno(link, r, "Cannot set IPv6 MTU for interface, ignoring: %m");
return link_enter_join_netdev(link);
}
-static int duid_set_uuid(DUID *duid, sd_id128_t uuid) {
- assert(duid);
-
- if (duid->raw_data_len > 0)
- return 0;
-
- if (duid->type != DUID_TYPE_UUID)
- return -EINVAL;
-
- memcpy(&duid->raw_data, &uuid, sizeof(sd_id128_t));
- duid->raw_data_len = sizeof(sd_id128_t);
-
- return 1;
-}
-
-int get_product_uuid_handler(sd_bus_message *m, void *userdata, sd_bus_error *ret_error) {
- Manager *manager = userdata;
- const sd_bus_error *e;
- const void *a;
- size_t sz;
- DUID *duid;
- Link *link;
- int r;
-
- assert(m);
- assert(manager);
-
- e = sd_bus_message_get_error(m);
- if (e) {
- log_error_errno(sd_bus_error_get_errno(e),
- "Could not get product UUID. Falling back to use machine-app-specific ID as DUID-UUID: %s",
- e->message);
- goto configure;
- }
-
- r = sd_bus_message_read_array(m, 'y', &a, &sz);
- if (r < 0)
- goto configure;
-
- if (sz != sizeof(sd_id128_t)) {
- log_error("Invalid product UUID. Falling back to use machine-app-specific ID as DUID-UUID.");
- goto configure;
- }
-
- memcpy(&manager->product_uuid, a, sz);
- while ((duid = set_steal_first(manager->duids_requesting_uuid)))
- (void) duid_set_uuid(duid, manager->product_uuid);
-
- manager->duids_requesting_uuid = set_free(manager->duids_requesting_uuid);
-
-configure:
- while ((link = set_steal_first(manager->links_requesting_uuid))) {
- link_unref(link);
-
- r = link_configure(link);
- if (r < 0)
- link_enter_failed(link);
- }
-
- manager->links_requesting_uuid = set_free(manager->links_requesting_uuid);
-
- /* To avoid calling GetProductUUID() bus method so frequently, set the flag below
- * even if the method fails. */
- manager->has_product_uuid = true;
-
- return 1;
-}
-
-static bool link_requires_uuid(Link *link) {
- const DUID *duid;
-
- assert(link);
- assert(link->manager);
- assert(link->network);
-
- duid = link_get_duid(link);
- if (duid->type != DUID_TYPE_UUID || duid->raw_data_len != 0)
- return false;
-
- if (link_dhcp4_enabled(link) && IN_SET(link->network->dhcp_client_identifier, DHCP_CLIENT_ID_DUID, DHCP_CLIENT_ID_DUID_ONLY))
- return true;
-
- if (link_dhcp6_enabled(link) || link_ipv6_accept_ra_enabled(link))
- return true;
-
- return false;
-}
-
-static int link_configure_duid(Link *link) {
- Manager *m;
- DUID *duid;
- int r;
-
- assert(link);
- assert(link->manager);
- assert(link->network);
-
- m = link->manager;
- duid = link_get_duid(link);
-
- if (!link_requires_uuid(link))
- return 1;
-
- if (m->has_product_uuid) {
- (void) duid_set_uuid(duid, m->product_uuid);
- return 1;
- }
-
- if (!m->links_requesting_uuid) {
- r = manager_request_product_uuid(m, link);
- if (r < 0) {
- if (r == -ENOMEM)
- return r;
-
- log_link_warning_errno(link, r,
- "Failed to get product UUID. Falling back to use machine-app-specific ID as DUID-UUID: %m");
- return 1;
- }
- } else {
- r = set_put(m->links_requesting_uuid, link);
- if (r < 0)
- return log_oom();
- if (r > 0)
- link_ref(link);
-
- r = set_put(m->duids_requesting_uuid, duid);
- if (r < 0)
- return log_oom();
- }
-
- return 0;
-}
-
static int link_reconfigure_internal(Link *link, sd_netlink_message *m, bool force) {
Network *network;
int r;
log_link_info(link, "Re-configuring with %s", network->filename);
/* Dropping old .network file */
- r = link_stop_clients(link, false);
+ r = link_stop_engines(link, false);
if (r < 0)
return r;
- if (link_dhcp4_server_enabled(link))
- (void) sd_dhcp_server_stop(link->dhcp_server);
-
r = link_drop_config(link);
if (r < 0)
return r;
*routes = NULL,
*dhcp4_address = NULL,
*ipv4ll_address = NULL;
- union in_addr_union address;
int r;
assert(link);
network_file_fail:
- for (const char *p = addresses; p; ) {
- _cleanup_free_ char *address_str = NULL;
- char *prefixlen_str;
- int family;
- unsigned char prefixlen;
-
- r = extract_first_word(&p, &address_str, NULL, 0);
- if (r < 0)
- log_link_warning_errno(link, r, "failed to parse ADDRESSES: %m");
- if (r <= 0)
- break;
-
- prefixlen_str = strchr(address_str, '/');
- if (!prefixlen_str) {
- log_link_debug(link, "Failed to parse address and prefix length %s", address_str);
- continue;
- }
- *prefixlen_str++ = '\0';
-
- r = sscanf(prefixlen_str, "%hhu", &prefixlen);
- if (r != 1) {
- log_link_error(link, "Failed to parse prefixlen %s", prefixlen_str);
- continue;
- }
-
- r = in_addr_from_string_auto(address_str, &family, &address);
- if (r < 0) {
- log_link_debug_errno(link, r, "Failed to parse address %s: %m", address_str);
- continue;
- }
-
- r = address_add(link, family, &address, prefixlen, NULL);
- if (r < 0)
- return log_link_error_errno(link, r, "Failed to add address: %m");
- }
-
- for (const char *p = routes; p; ) {
- _cleanup_(sd_event_source_unrefp) sd_event_source *expire = NULL;
- _cleanup_(route_freep) Route *tmp = NULL;
- _cleanup_free_ char *route_str = NULL;
- char *prefixlen_str;
- Route *route;
-
- r = extract_first_word(&p, &route_str, NULL, 0);
- if (r < 0)
- log_link_debug_errno(link, r, "failed to parse ROUTES: %m");
- if (r <= 0)
- break;
-
- prefixlen_str = strchr(route_str, '/');
- if (!prefixlen_str) {
- log_link_debug(link, "Failed to parse route %s", route_str);
- continue;
- }
- *prefixlen_str++ = '\0';
-
- r = route_new(&tmp);
- if (r < 0)
- return log_oom();
-
- r = sscanf(prefixlen_str,
- "%hhu/%hhu/%"SCNu32"/%"PRIu32"/"USEC_FMT,
- &tmp->dst_prefixlen,
- &tmp->tos,
- &tmp->priority,
- &tmp->table,
- &tmp->lifetime);
- if (r != 5) {
- log_link_debug(link,
- "Failed to parse destination prefix length, tos, priority, table or expiration %s",
- prefixlen_str);
- continue;
- }
-
- r = in_addr_from_string_auto(route_str, &tmp->family, &tmp->dst);
- if (r < 0) {
- log_link_debug_errno(link, r, "Failed to parse route destination %s: %m", route_str);
- continue;
- }
-
- r = route_add(link, tmp, &route);
- if (r < 0)
- return log_link_error_errno(link, r, "Failed to add route: %m");
-
- if (route->lifetime != USEC_INFINITY && !kernel_route_expiration_supported()) {
- r = sd_event_add_time(link->manager->event, &expire,
- clock_boottime_or_monotonic(),
- route->lifetime, 0, route_expire_handler, route);
- if (r < 0)
- log_link_warning_errno(link, r, "Could not arm route expiration handler: %m");
- }
-
- sd_event_source_unref(route->expire);
- route->expire = TAKE_PTR(expire);
- }
-
- if (dhcp4_address) {
- r = in_addr_from_string(AF_INET, dhcp4_address, &address);
- if (r < 0) {
- log_link_debug_errno(link, r, "Failed to parse DHCPv4 address %s: %m", dhcp4_address);
- goto dhcp4_address_fail;
- }
-
- r = sd_dhcp_client_new(&link->dhcp_client, link->network ? link->network->dhcp_anonymize : 0);
- if (r < 0)
- return log_link_error_errno(link, r, "Failed to create DHCPv4 client: %m");
-
- r = sd_dhcp_client_attach_event(link->dhcp_client, NULL, 0);
- if (r < 0)
- return log_link_error_errno(link, r, "Failed to attach DHCPv4 event: %m");
-
- r = sd_dhcp_client_set_request_address(link->dhcp_client, &address.in);
- if (r < 0)
- return log_link_error_errno(link, r, "Failed to set initial DHCPv4 address %s: %m", dhcp4_address);
- }
-
-dhcp4_address_fail:
-
- if (ipv4ll_address) {
- r = in_addr_from_string(AF_INET, ipv4ll_address, &address);
- if (r < 0) {
- log_link_debug_errno(link, r, "Failed to parse IPv4LL address %s: %m", ipv4ll_address);
- goto ipv4ll_address_fail;
- }
-
- r = sd_ipv4ll_new(&link->ipv4ll);
- if (r < 0)
- return log_link_error_errno(link, r, "Failed to create IPv4LL client: %m");
+ r = link_deserialize_addresses(link, addresses);
+ if (r < 0)
+ log_link_warning_errno(link, r, "Failed to load addresses from %s, ignoring: %m", link->state_file);
- r = sd_ipv4ll_attach_event(link->ipv4ll, NULL, 0);
- if (r < 0)
- return log_link_error_errno(link, r, "Failed to attach IPv4LL event: %m");
+ r = link_deserialize_routes(link, routes);
+ if (r < 0)
+ log_link_warning_errno(link, r, "Failed to load routes from %s, ignoring: %m", link->state_file);
- r = sd_ipv4ll_set_address(link->ipv4ll, &address.in);
- if (r < 0)
- return log_link_error_errno(link, r, "Failed to set initial IPv4LL address %s: %m", ipv4ll_address);
- }
+ r = link_deserialize_dhcp4(link, dhcp4_address);
+ if (r < 0)
+ log_link_warning_errno(link, r, "Failed to load DHCPv4 address from %s, ignoring: %m", link->state_file);
-ipv4ll_address_fail:
+ r = link_deserialize_ipv4ll(link, ipv4ll_address);
+ if (r < 0)
+ log_link_warning_errno(link, r, "Failed to load IPv4LL address from %s, ignoring: %m", link->state_file);
return 0;
}
}
link_set_state(link, LINK_STATE_CONFIGURING);
- r = link_request_set_addresses(link);
+ r = link_set_static_configs(link);
if (r < 0)
return r;
}
if (r < 0)
return r;
- r = link_set_bridge_mdb(link);
- if (r < 0)
- return r;
+ if (!link->bridge_mdb_configured) {
+ r = link_set_bridge_mdb(link);
+ if (r < 0)
+ return r;
+ }
+
+ if (streq_ptr(link->kind, "bridge")) {
+ Link *slave;
+
+ SET_FOREACH(slave, link->slaves) {
+ if (slave->bridge_mdb_configured)
+ continue;
+
+ r = link_set_bridge_mdb(slave);
+ if (r < 0)
+ link_enter_failed(slave);
+ }
+ }
return 0;
}
if (link->setting_mtu)
return 0;
- r = link_stop_clients(link, false);
+ r = link_stop_engines(link, false);
if (r < 0) {
link_enter_failed(link);
return r;
}
- if (link_dhcp4_server_enabled(link))
- (void) sd_dhcp_server_stop(link->dhcp_server);
-
r = link_drop_config(link);
if (r < 0)
return r;
mac.ether_addr_octet[4],
mac.ether_addr_octet[5]);
- if (link->ipv4ll) {
- bool restart = sd_ipv4ll_is_running(link->ipv4ll) > 0;
-
- if (restart) {
- r = sd_ipv4ll_stop(link->ipv4ll);
- if (r < 0)
- return log_link_warning_errno(link, r, "Could not stop IPv4LL client: %m");
- }
-
- r = sd_ipv4ll_set_mac(link->ipv4ll, &link->mac);
- if (r < 0)
- return log_link_warning_errno(link, r, "Could not update MAC address in IPv4LL client: %m");
-
- if (restart) {
- r = sd_ipv4ll_start(link->ipv4ll);
- if (r < 0)
- return log_link_warning_errno(link, r, "Could not restart IPv4LL client: %m");
- }
- }
-
- if (link->dhcp_client) {
- r = sd_dhcp_client_set_mac(link->dhcp_client,
- (const uint8_t *) &link->mac,
- sizeof (link->mac),
- ARPHRD_ETHER);
- if (r < 0)
- return log_link_warning_errno(link, r, "Could not update MAC address in DHCP client: %m");
-
- r = dhcp4_set_client_identifier(link);
- if (r < 0)
- return log_link_warning_errno(link, r, "Could not set DHCP client identifier: %m");
- }
-
- if (link->dhcp6_client) {
- const DUID* duid = link_get_duid(link);
- bool restart = sd_dhcp6_client_is_running(link->dhcp6_client) > 0;
-
- if (restart) {
- r = sd_dhcp6_client_stop(link->dhcp6_client);
- if (r < 0)
- return log_link_warning_errno(link, r, "Could not stop DHCPv6 client: %m");
- }
-
- r = sd_dhcp6_client_set_mac(link->dhcp6_client,
- (const uint8_t *) &link->mac,
- sizeof (link->mac),
- ARPHRD_ETHER);
- if (r < 0)
- return log_link_warning_errno(link, r, "Could not update MAC address in DHCPv6 client: %m");
-
- if (link->network->iaid_set) {
- r = sd_dhcp6_client_set_iaid(link->dhcp6_client, link->network->iaid);
- if (r < 0)
- return log_link_warning_errno(link, r, "Could not update DHCPv6 IAID: %m");
- }
-
- r = sd_dhcp6_client_set_duid(link->dhcp6_client,
- duid->type,
- duid->raw_data_len > 0 ? duid->raw_data : NULL,
- duid->raw_data_len);
- if (r < 0)
- return log_link_warning_errno(link, r, "Could not update DHCPv6 DUID: %m");
-
- if (restart) {
- r = sd_dhcp6_client_start(link->dhcp6_client);
- if (r < 0)
- return log_link_warning_errno(link, r, "Could not restart DHCPv6 client: %m");
- }
- }
-
- if (link->radv) {
- bool restart = sd_radv_is_running(link->radv);
+ r = ipv4ll_update_mac(link);
+ if (r < 0)
+ return log_link_warning_errno(link, r, "Could not update MAC address in IPv4LL client: %m");
- if (restart) {
- r = sd_radv_stop(link->radv);
- if (r < 0)
- return log_link_warning_errno(link, r, "Could not stop Router Advertisement: %m");
- }
+ r = dhcp4_update_mac(link);
+ if (r < 0)
+ return log_link_warning_errno(link, r, "Could not update MAC address in DHCP client: %m");
- r = sd_radv_set_mac(link->radv, &link->mac);
- if (r < 0)
- return log_link_warning_errno(link, r, "Could not update MAC for Router Advertisement: %m");
+ r = dhcp6_update_mac(link);
+ if (r < 0)
+ return log_link_warning_errno(link, r, "Could not update MAC address in DHCPv6 client: %m");
- if (restart) {
- r = sd_radv_start(link->radv);
- if (r < 0)
- return log_link_warning_errno(link, r, "Could not restart Router Advertisement: %m");
- }
- }
+ r = dhcp6_update_mac(link);
+ if (r < 0)
+ return log_link_warning_errno(link, r, "Could not update MAC address for Router Advertisement: %m");
if (link->ndisc) {
r = sd_ndisc_set_mac(link->ndisc, &link->mac);
if (r < 0)
return log_link_warning_errno(link, r, "Could not update MAC for NDisc: %m");
}
+
+ r = ipv4_dad_update_mac(link);
+ if (r < 0)
+ return log_link_warning_errno(link, r, "Could not update MAC address in IPv4 ACD client: %m");
}
old_master = link->master_ifindex;
const char *admin_state, *oper_state, *carrier_state, *address_state;
_cleanup_free_ char *temp_path = NULL;
_cleanup_fclose_ FILE *f = NULL;
- Route *route;
- Address *a;
int r;
assert(link);
/************************************************************/
- fputs("ADDRESSES=", f);
- space = false;
- SET_FOREACH(a, link->addresses) {
- _cleanup_free_ char *address_str = NULL;
-
- r = in_addr_to_string(a->family, &a->in_addr, &address_str);
- if (r < 0)
- goto fail;
-
- fprintf(f, "%s%s/%u", space ? " " : "", address_str, a->prefixlen);
- space = true;
- }
- fputc('\n', f);
+ r = link_serialize_addresses(link, f);
+ if (r < 0)
+ goto fail;
/************************************************************/
- fputs("ROUTES=", f);
- space = false;
- SET_FOREACH(route, link->routes) {
- _cleanup_free_ char *route_str = NULL;
-
- r = in_addr_to_string(route->family, &route->dst, &route_str);
- if (r < 0)
- goto fail;
-
- fprintf(f, "%s%s/%hhu/%hhu/%"PRIu32"/%"PRIu32"/"USEC_FMT,
- space ? " " : "", route_str,
- route->dst_prefixlen, route->tos, route->priority, route->table, route->lifetime);
- space = true;
- }
-
- fputc('\n', f);
+ r = link_serialize_routes(link, f);
+ if (r < 0)
+ goto fail;
}
print_link_hashmap(f, "CARRIER_BOUND_TO=", link->bound_to_links);
} else
(void) unlink(link->lease_file);
- if (link->ipv4ll) {
- struct in_addr address;
-
- r = sd_ipv4ll_get_address(link->ipv4ll, &address);
- if (r >= 0) {
- fputs("IPV4LL_ADDRESS=", f);
- serialize_in_addrs(f, &address, 1, false, NULL);
- fputc('\n', f);
- }
- }
-
- if (link->dhcp6_client) {
- _cleanup_free_ char *duid = NULL;
- uint32_t iaid;
-
- r = sd_dhcp6_client_get_iaid(link->dhcp6_client, &iaid);
- if (r >= 0)
- fprintf(f, "DHCP6_CLIENT_IAID=0x%x\n", iaid);
+ r = link_serialize_ipv4ll(link, f);
+ if (r < 0)
+ goto fail;
- r = sd_dhcp6_client_duid_as_string(link->dhcp6_client, &duid);
- if (r >= 0)
- fprintf(f, "DHCP6_CLIENT_DUID=%s\n", duid);
- }
+ r = link_serialize_dhcp6_client(link, f);
+ if (r < 0)
+ goto fail;
r = fflush_and_check(f);
if (r < 0)
projects / thirdparty / systemd.git / blobdiff