]> git.ipfire.org Git - thirdparty/systemd.git/blame - src/network/networkd-link.c
projects / thirdparty / systemd.git / blame
? search:
summary | shortlog | log | commit | commitdiff | tree
blob | blame (incremental) | history | HEAD
networkd: don't remove route
[thirdparty/systemd.git] / src / network / networkd-link.c
CommitLineData
53e1b683 1/* SPDX-License-Identifier: LGPL-2.1+ */
f579559b
TG		 2
3#include <netinet/ether.h>
4#include <linux/if.h>
06828bb6 5#include <linux/can/netlink.h>
4cc7a82c 6#include <unistd.h>
0d536673 7#include <stdio_ext.h>
f579559b 8
b5efdb8a 9#include "alloc-util.h"
1346b1f0 10#include "bus-util.h"
27dfc982 11#include "dhcp-identifier.h"
bd91b83e 12#include "dhcp-lease-internal.h"
3ffd4af2 13#include "fd-util.h"
cf1d700d
TG		 14#include "fileio.h"
15#include "netlink-util.h"
c6f7c917 16#include "network-internal.h"
a0e5c15d 17#include "networkd-ipv6-proxy-ndp.h"
8e1ad1ea 18#include "networkd-lldp-tx.h"
23f53b99 19#include "networkd-manager.h"
1e7a0e21 20#include "networkd-ndisc.h"
7465dd22 21#include "networkd-radv.h"
bce67bbe 22#include "networkd-routing-policy-rule.h"
cf1d700d
TG		 23#include "set.h"
24#include "socket-util.h"
15a5e950 25#include "stdio-util.h"
8b43440b 26#include "string-table.h"
51517f9e 27#include "strv.h"
cf1d700d
TG		 28#include "util.h"
29#include "virt.h"
fc2f9534 30
f24648a6
YW		 31DUID* link_get_duid(Link *link) {
32 if (link->network->duid.type != _DUID_TYPE_INVALID)
33 return &link->network->duid;
34 else
35 return &link->manager->duid;
36}
37
b9d74c40
LP		 38static bool link_dhcp6_enabled(Link *link) {
39 assert(link);
40
fa709992
LP		 41 if (!socket_ipv6_is_supported())
42 return false;
43
78c958f8
TG		 44 if (link->flags & IFF_LOOPBACK)
45 return false;
46
47 if (!link->network)
48 return false;
49
e0ee46f2 50 return link->network->dhcp & ADDRESS_FAMILY_IPV6;
78c958f8
TG		 51}
52
b9d74c40
LP		 53static bool link_dhcp4_enabled(Link *link) {
54 assert(link);
55
78c958f8
TG		 56 if (link->flags & IFF_LOOPBACK)
57 return false;
58
59 if (!link->network)
60 return false;
61
e0ee46f2 62 return link->network->dhcp & ADDRESS_FAMILY_IPV4;
78c958f8
TG		 63}
64
b9d74c40
LP		 65static bool link_dhcp4_server_enabled(Link *link) {
66 assert(link);
67
78c958f8
TG		 68 if (link->flags & IFF_LOOPBACK)
69 return false;
70
71 if (!link->network)
72 return false;
73
74 return link->network->dhcp_server;
75}
76
b9d74c40
LP		 77static bool link_ipv4ll_enabled(Link *link) {
78 assert(link);
79
78c958f8
TG		 80 if (link->flags & IFF_LOOPBACK)
81 return false;
82
83 if (!link->network)
84 return false;
85
a8f5bba6
JD		 86 if (streq_ptr(link->kind, "wireguard"))
87 return false;
88
e0ee46f2 89 return link->network->link_local & ADDRESS_FAMILY_IPV4;
d0d6a4cd
TG		 90}
91
b9d74c40
LP		 92static bool link_ipv6ll_enabled(Link *link) {
93 assert(link);
94
fa709992
LP		 95 if (!socket_ipv6_is_supported())
96 return false;
97
d0d6a4cd
TG		 98 if (link->flags & IFF_LOOPBACK)
99 return false;
100
101 if (!link->network)
102 return false;
103
a8f5bba6
JD		 104 if (streq_ptr(link->kind, "wireguard"))
105 return false;
106
e0ee46f2 107 return link->network->link_local & ADDRESS_FAMILY_IPV6;
78c958f8
TG		 108}
109
439689c6
SS		 110static bool link_ipv6_enabled(Link *link) {
111 assert(link);
112
113 if (!socket_ipv6_is_supported())
114 return false;
115
2b00a4e0
TY		 116 if (link->network->bridge)
117 return false;
118
4cef7fe3
TY		 119 /* DHCPv6 client will not be started if no IPv6 link-local address is configured. */
120 return link_ipv6ll_enabled(link) || network_has_static_ipv6_addresses(link->network);
439689c6
SS		 121}
122
7465dd22
PF		 123static bool link_radv_enabled(Link *link) {
124 assert(link);
125
126 if (!link_ipv6ll_enabled(link))
127 return false;
128
55a7c78b 129 return link->network->router_prefix_delegation != RADV_PREFIX_DELEGATION_NONE;
7465dd22
PF		 130}
131
8e1ad1ea 132static bool link_lldp_rx_enabled(Link *link) {
b710e6b6
LP		 133 assert(link);
134
ce43e484
SS		 135 if (link->flags & IFF_LOOPBACK)
136 return false;
137
b710e6b6
LP		 138 if (link->iftype != ARPHRD_ETHER)
139 return false;
140
ce43e484
SS		 141 if (!link->network)
142 return false;
143
764febc2
SS		 144 /* LLDP should be handled on bridge slaves as those have a direct
145 * connection to their peers not on the bridge master. Linux doesn't
146 * even (by default) forward lldp packets to the bridge master.*/
147 if (streq_ptr("bridge", link->kind))
ce43e484
SS		 148 return false;
149
34437b4f 150 return link->network->lldp_mode != LLDP_MODE_NO;
ce43e484
SS		 151}
152
7272b25e 153static bool link_lldp_emit_enabled(Link *link) {
8e1ad1ea
LP		 154 assert(link);
155
156 if (link->flags & IFF_LOOPBACK)
157 return false;
158
159 if (link->iftype != ARPHRD_ETHER)
160 return false;
161
162 if (!link->network)
163 return false;
164
7272b25e 165 return link->network->lldp_emit != LLDP_EMIT_NO;
8e1ad1ea
LP		 166}
167
769d324c 168static bool link_ipv4_forward_enabled(Link *link) {
b9d74c40
LP		 169 assert(link);
170
5a8bcb67
LP		 171 if (link->flags & IFF_LOOPBACK)
172 return false;
173
174 if (!link->network)
175 return false;
176
765afd5c
LP		 177 if (link->network->ip_forward == _ADDRESS_FAMILY_BOOLEAN_INVALID)
178 return false;
179
e0ee46f2 180 return link->network->ip_forward & ADDRESS_FAMILY_IPV4;
769d324c
LP		 181}
182
183static bool link_ipv6_forward_enabled(Link *link) {
b9d74c40 184 assert(link);
765afd5c
LP		 185
186 if (!socket_ipv6_is_supported())
187 return false;
188
769d324c
LP		 189 if (link->flags & IFF_LOOPBACK)
190 return false;
191
192 if (!link->network)
193 return false;
194
765afd5c
LP		 195 if (link->network->ip_forward == _ADDRESS_FAMILY_BOOLEAN_INVALID)
196 return false;
197
e0ee46f2 198 return link->network->ip_forward & ADDRESS_FAMILY_IPV6;
5a8bcb67
LP		 199}
200
23d8b221
SS		 201static bool link_proxy_arp_enabled(Link *link) {
202 assert(link);
203
204 if (link->flags & IFF_LOOPBACK)
205 return false;
206
207 if (!link->network)
208 return false;
209
210 if (link->network->proxy_arp < 0)
211 return false;
212
213 return true;
214}
215
b9d74c40
LP		 216static bool link_ipv6_accept_ra_enabled(Link *link) {
217 assert(link);
218
fa709992
LP		 219 if (!socket_ipv6_is_supported())
220 return false;
221
f5a8c43f
TG		 222 if (link->flags & IFF_LOOPBACK)
223 return false;
224
225 if (!link->network)
226 return false;
227
702c979f
SS		 228 if (!link_ipv6ll_enabled(link))
229 return false;
230
f5a8c43f
TG		 231 /* If unset use system default (enabled if local forwarding is disabled.
232 * disabled if local forwarding is enabled).
233 * If set, ignore or enforce RA independent of local forwarding state.
234 */
235 if (link->network->ipv6_accept_ra < 0)
236 /* default to accept RA if ip_forward is disabled and ignore RA if ip_forward is enabled */
237 return !link_ipv6_forward_enabled(link);
238 else if (link->network->ipv6_accept_ra > 0)
239 /* accept RA even if ip_forward is enabled */
240 return true;
241 else
242 /* ignore RA */
243 return false;
244}
245
1f0d9695 246static IPv6PrivacyExtensions link_ipv6_privacy_extensions(Link *link) {
fa709992 247 assert(link);
d68e2e59
LP		 248
249 if (!socket_ipv6_is_supported())
250 return _IPV6_PRIVACY_EXTENSIONS_INVALID;
251
49092e22 252 if (link->flags & IFF_LOOPBACK)
1f0d9695 253 return _IPV6_PRIVACY_EXTENSIONS_INVALID;
49092e22
SS		 254
255 if (!link->network)
1f0d9695 256 return _IPV6_PRIVACY_EXTENSIONS_INVALID;
49092e22
SS		 257
258 return link->network->ipv6_privacy_extensions;
259}
260
439689c6
SS		 261static int link_enable_ipv6(Link *link) {
262 const char *p = NULL;
263 bool disabled;
264 int r;
265
266 if (link->flags & IFF_LOOPBACK)
267 return 0;
268
269 disabled = !link_ipv6_enabled(link);
270
271 p = strjoina("/proc/sys/net/ipv6/conf/", link->ifname, "/disable_ipv6");
272
273 r = write_string_file(p, one_zero(disabled), WRITE_STRING_FILE_VERIFY_ON_FAILURE);
274 if (r < 0)
b106c586
ZJS		 275 log_link_warning_errno(link, r, "Cannot %s IPv6 for interface %s: %m",
276 enable_disable(!disabled), link->ifname);
2d37cd53 277 else
b106c586 278 log_link_info(link, "IPv6 successfully %sd", enable_disable(!disabled));
439689c6
SS		 279
280 return 0;
281}
282
84de38c5
TG		 283void link_update_operstate(Link *link) {
284 LinkOperationalState operstate;
285 assert(link);
286
287 if (link->kernel_operstate == IF_OPER_DORMANT)
288 operstate = LINK_OPERSTATE_DORMANT;
289 else if (link_has_carrier(link)) {
290 Address *address;
291 uint8_t scope = RT_SCOPE_NOWHERE;
292 Iterator i;
293
294 /* if we have carrier, check what addresses we have */
295 SET_FOREACH(address, link->addresses, i) {
296 if (!address_is_ready(address))
297 continue;
298
299 if (address->scope < scope)
300 scope = address->scope;
301 }
302
303 /* for operstate we also take foreign addresses into account */
304 SET_FOREACH(address, link->addresses_foreign, i) {
305 if (!address_is_ready(address))
306 continue;
307
308 if (address->scope < scope)
309 scope = address->scope;
310 }
311
312 if (scope < RT_SCOPE_SITE)
313 /* universally accessible addresses found */
314 operstate = LINK_OPERSTATE_ROUTABLE;
315 else if (scope < RT_SCOPE_HOST)
316 /* only link or site local addresses found */
317 operstate = LINK_OPERSTATE_DEGRADED;
318 else
319 /* no useful addresses found */
320 operstate = LINK_OPERSTATE_CARRIER;
321 } else if (link->flags & IFF_UP)
322 operstate = LINK_OPERSTATE_NO_CARRIER;
323 else
324 operstate = LINK_OPERSTATE_OFF;
325
326 if (link->operstate != operstate) {
327 link->operstate = operstate;
328 link_send_changed(link, "OperationalState", NULL);
329 link_dirty(link);
84de38c5
TG		 330 }
331}
332
51d18171
TG		 333#define FLAG_STRING(string, flag, old, new) \
334 (((old ^ new) & flag) \
335 ? ((old & flag) ? (" -" string) : (" +" string)) \
336 : "")
337
1c4baffc 338static int link_update_flags(Link *link, sd_netlink_message *m) {
51d18171
TG		 339 unsigned flags, unknown_flags_added, unknown_flags_removed, unknown_flags;
340 uint8_t operstate;
341 int r;
342
343 assert(link);
344
345 r = sd_rtnl_message_link_get_flags(m, &flags);
6a7a4e4d
LP		 346 if (r < 0)
347 return log_link_warning_errno(link, r, "Could not get link flags: %m");
51d18171 348
1c4baffc 349 r = sd_netlink_message_read_u8(m, IFLA_OPERSTATE, &operstate);
51d18171
TG		 350 if (r < 0)
351 /* if we got a message without operstate, take it to mean
352 the state was unchanged */
353 operstate = link->kernel_operstate;
354
355 if ((link->flags == flags) && (link->kernel_operstate == operstate))
356 return 0;
357
358 if (link->flags != flags) {
6a7a4e4d 359 log_link_debug(link, "Flags change:%s%s%s%s%s%s%s%s%s%s%s%s%s%s%s%s%s%s%s",
51d18171
TG		 360 FLAG_STRING("LOOPBACK", IFF_LOOPBACK, link->flags, flags),
361 FLAG_STRING("MASTER", IFF_MASTER, link->flags, flags),
362 FLAG_STRING("SLAVE", IFF_SLAVE, link->flags, flags),
363 FLAG_STRING("UP", IFF_UP, link->flags, flags),
364 FLAG_STRING("DORMANT", IFF_DORMANT, link->flags, flags),
365 FLAG_STRING("LOWER_UP", IFF_LOWER_UP, link->flags, flags),
366 FLAG_STRING("RUNNING", IFF_RUNNING, link->flags, flags),
367 FLAG_STRING("MULTICAST", IFF_MULTICAST, link->flags, flags),
368 FLAG_STRING("BROADCAST", IFF_BROADCAST, link->flags, flags),
369 FLAG_STRING("POINTOPOINT", IFF_POINTOPOINT, link->flags, flags),
370 FLAG_STRING("PROMISC", IFF_PROMISC, link->flags, flags),
371 FLAG_STRING("ALLMULTI", IFF_ALLMULTI, link->flags, flags),
372 FLAG_STRING("PORTSEL", IFF_PORTSEL, link->flags, flags),
373 FLAG_STRING("AUTOMEDIA", IFF_AUTOMEDIA, link->flags, flags),
374 FLAG_STRING("DYNAMIC", IFF_DYNAMIC, link->flags, flags),
375 FLAG_STRING("NOARP", IFF_NOARP, link->flags, flags),
376 FLAG_STRING("NOTRAILERS", IFF_NOTRAILERS, link->flags, flags),
377 FLAG_STRING("DEBUG", IFF_DEBUG, link->flags, flags),
378 FLAG_STRING("ECHO", IFF_ECHO, link->flags, flags));
379
380 unknown_flags = ~(IFF_LOOPBACK | IFF_MASTER | IFF_SLAVE | IFF_UP |
381 IFF_DORMANT | IFF_LOWER_UP | IFF_RUNNING |
382 IFF_MULTICAST | IFF_BROADCAST | IFF_POINTOPOINT |
383 IFF_PROMISC | IFF_ALLMULTI | IFF_PORTSEL |
384 IFF_AUTOMEDIA | IFF_DYNAMIC | IFF_NOARP |
385 IFF_NOTRAILERS | IFF_DEBUG | IFF_ECHO);
386 unknown_flags_added = ((link->flags ^ flags) & flags & unknown_flags);
387 unknown_flags_removed = ((link->flags ^ flags) & link->flags & unknown_flags);
388
389 /* link flags are currently at most 18 bits, let's align to
390 * printing 20 */
391 if (unknown_flags_added)
79008bdd 392 log_link_debug(link,
6a7a4e4d 393 "Unknown link flags gained: %#.5x (ignoring)",
51d18171
TG		 394 unknown_flags_added);
395
396 if (unknown_flags_removed)
79008bdd 397 log_link_debug(link,
6a7a4e4d 398 "Unknown link flags lost: %#.5x (ignoring)",
51d18171
TG		 399 unknown_flags_removed);
400 }
401
402 link->flags = flags;
403 link->kernel_operstate = operstate;
404
84de38c5 405 link_update_operstate(link);
51d18171
TG		 406
407 return 0;
408}
409
1046bf9b
YW		 410DEFINE_TRIVIAL_CLEANUP_FUNC(Link*, link_unref);
411
1c4baffc 412static int link_new(Manager *manager, sd_netlink_message *message, Link **ret) {
8e766630 413 _cleanup_(link_unrefp) Link *link = NULL;
505f8da7 414 uint16_t type;
6cad256d 415 const char *ifname, *kind = NULL;
505f8da7 416 int r, ifindex;
b710e6b6 417 unsigned short iftype;
f579559b 418
0c2f9b84 419 assert(manager);
505f8da7 420 assert(message);
f579559b
TG		 421 assert(ret);
422
6cad256d
TJ		 423 /* check for link kind */
424 r = sd_netlink_message_enter_container(message, IFLA_LINKINFO);
425 if (r == 0) {
db2f8a2e 426 (void) sd_netlink_message_read_string(message, IFLA_INFO_KIND, &kind);
6cad256d
TJ		 427 r = sd_netlink_message_exit_container(message);
428 if (r < 0)
429 return r;
430 }
431
1c4baffc 432 r = sd_netlink_message_get_type(message, &type);
505f8da7
TG		 433 if (r < 0)
434 return r;
435 else if (type != RTM_NEWLINK)
436 return -EINVAL;
437
438 r = sd_rtnl_message_link_get_ifindex(message, &ifindex);
439 if (r < 0)
440 return r;
441 else if (ifindex <= 0)
442 return -EINVAL;
443
b710e6b6
LP		 444 r = sd_rtnl_message_link_get_type(message, &iftype);
445 if (r < 0)
446 return r;
447
1c4baffc 448 r = sd_netlink_message_read_string(message, IFLA_IFNAME, &ifname);
505f8da7
TG		 449 if (r < 0)
450 return r;
451
f579559b
TG		 452 link = new0(Link, 1);
453 if (!link)
454 return -ENOMEM;
455
14b746f7 456 link->n_ref = 1;
5a3eb5a7 457 link->manager = manager;
8434fd5c 458 link->state = LINK_STATE_PENDING;
be3a09b7 459 link->rtnl_extended_attrs = true;
505f8da7 460 link->ifindex = ifindex;
b710e6b6 461 link->iftype = iftype;
505f8da7
TG		 462 link->ifname = strdup(ifname);
463 if (!link->ifname)
464 return -ENOMEM;
f579559b 465
6cad256d
TJ		 466 if (kind) {
467 link->kind = strdup(kind);
468 if (!link->kind)
469 return -ENOMEM;
470 }
471
cbff7170
TJ		 472 r = sd_netlink_message_read_u32(message, IFLA_MASTER, (uint32_t *)&link->master_ifindex);
473 if (r < 0)
474 log_link_debug_errno(link, r, "New device has no master, continuing without");
475
1c4baffc 476 r = sd_netlink_message_read_ether_addr(message, IFLA_ADDRESS, &link->mac);
512922f8 477 if (r < 0)
34437b4f 478 log_link_debug_errno(link, r, "MAC address not found for new device, continuing without");
512922f8 479
34437b4f 480 if (asprintf(&link->state_file, "/run/systemd/netif/links/%d", link->ifindex) < 0)
315db1a8 481 return -ENOMEM;
fe8db0c5 482
34437b4f 483 if (asprintf(&link->lease_file, "/run/systemd/netif/leases/%d", link->ifindex) < 0)
68a8723c
TG		 484 return -ENOMEM;
485
34437b4f 486 if (asprintf(&link->lldp_file, "/run/systemd/netif/lldp/%d", link->ifindex) < 0)
49699bac
SS		 487 return -ENOMEM;
488
d5099efc 489 r = hashmap_ensure_allocated(&manager->links, NULL);
ae06ab10
TG		 490 if (r < 0)
491 return r;
492
493 r = hashmap_put(manager->links, INT_TO_PTR(link->ifindex), link);
f579559b
TG		 494 if (r < 0)
495 return r;
496
51d18171
TG		 497 r = link_update_flags(link, message);
498 if (r < 0)
499 return r;
500
1cc6c93a 501 *ret = TAKE_PTR(link);
f579559b
TG		 502
503 return 0;
504}
505
8301aa0b 506static Link *link_free(Link *link) {
428fd0a7 507 Address *address;
0d4ad91d 508 Link *carrier;
ddfc4f6e 509 Route *route;
bce67bbe 510 Iterator i;
428fd0a7 511
8301aa0b 512 assert(link);
f579559b 513
ddfc4f6e
YW		 514 while ((route = set_first(link->routes)))
515 route_free(route);
516
517 while ((route = set_first(link->routes_foreign)))
518 route_free(route);
519
520 link->routes = set_free(link->routes);
521 link->routes_foreign = set_free(link->routes_foreign);
522
0ade014c
YW		 523 while ((address = set_first(link->addresses)))
524 address_free(address);
cf1d700d 525
0ade014c
YW		 526 while ((address = set_first(link->addresses_foreign)))
527 address_free(address);
adda1ed9 528
4701725c 529 link->addresses = set_free(link->addresses);
4701725c 530 link->addresses_foreign = set_free(link->addresses_foreign);
adda1ed9 531
11bf3cce
LP		 532 while ((address = link->pool_addresses)) {
533 LIST_REMOVE(addresses, link->pool_addresses, address);
534 address_free(address);
535 }
536
bfcdba8d 537 sd_dhcp_server_unref(link->dhcp_server);
e5b04c8d 538 sd_dhcp_client_unref(link->dhcp_client);
a6cc569e 539 sd_dhcp_lease_unref(link->dhcp_lease);
f5be5601 540
7272b25e 541 link_lldp_emit_stop(link);
8e1ad1ea 542
68a8723c
TG		 543 free(link->lease_file);
544
4afd3348 545 sd_lldp_unref(link->lldp);
49699bac
SS		 546 free(link->lldp_file);
547
c69305ff
LP		 548 ndisc_flush(link);
549
56cd007a 550 sd_ipv4ll_unref(link->ipv4ll);
4138fb2c 551 sd_dhcp6_client_unref(link->dhcp6_client);
1e7a0e21 552 sd_ndisc_unref(link->ndisc);
7465dd22 553 sd_radv_unref(link->radv);
1e7a0e21 554
27dfc982 555 if (link->manager) {
ae06ab10 556 hashmap_remove(link->manager->links, INT_TO_PTR(link->ifindex));
27dfc982 557 set_remove(link->manager->links_requesting_uuid, link);
1046bf9b 558 link_clean(link);
27dfc982 559 }
f579559b 560
c166a070 561 free(link->ifname);
68a8723c 562
ceac4078 563 free(link->kind);
6cad256d 564
db2f8a2e 565 (void) unlink(link->state_file);
fe8db0c5 566 free(link->state_file);
c166a070 567
51517f9e 568 sd_device_unref(link->sd_device);
b5db00e5 569
0d4ad91d
AR		 570 HASHMAP_FOREACH (carrier, link->bound_to_links, i)
571 hashmap_remove(link->bound_to_links, INT_TO_PTR(carrier->ifindex));
572 hashmap_free(link->bound_to_links);
573
574 HASHMAP_FOREACH (carrier, link->bound_by_links, i)
575 hashmap_remove(link->bound_by_links, INT_TO_PTR(carrier->ifindex));
576 hashmap_free(link->bound_by_links);
577
8301aa0b 578 return mfree(link);
14b746f7
TG		 579}
580
8301aa0b 581DEFINE_TRIVIAL_REF_UNREF_FUNC(Link, link, link_free);
14b746f7 582
1046bf9b
YW		 583void link_netlink_destroy_callback(void *userdata) {
584 Link *link = userdata;
585
586 assert(userdata);
587
588 link_unref(link);
589}
590
11a7f229
TG		 591int link_get(Manager *m, int ifindex, Link **ret) {
592 Link *link;
11a7f229
TG		 593
594 assert(m);
11a7f229
TG		 595 assert(ifindex);
596 assert(ret);
597
ae06ab10 598 link = hashmap_get(m->links, INT_TO_PTR(ifindex));
11a7f229
TG		 599 if (!link)
600 return -ENODEV;
601
602 *ret = link;
603
604 return 0;
605}
606
e331e246
TG		 607static void link_set_state(Link *link, LinkState state) {
608 assert(link);
609
610 if (link->state == state)
611 return;
612
613 link->state = state;
614
615 link_send_changed(link, "AdministrativeState", NULL);
e331e246
TG		 616}
617
57bd6899
TG		 618static void link_enter_unmanaged(Link *link) {
619 assert(link);
620
6a7a4e4d 621 log_link_debug(link, "Unmanaged");
57bd6899 622
e331e246 623 link_set_state(link, LINK_STATE_UNMANAGED);
57bd6899 624
84de38c5 625 link_dirty(link);
57bd6899
TG		 626}
627
111bb8f9
TG		 628static int link_stop_clients(Link *link) {
629 int r = 0, k;
630
631 assert(link);
632 assert(link->manager);
633 assert(link->manager->event);
634
ba179154 635 if (link->dhcp_client) {
111bb8f9 636 k = sd_dhcp_client_stop(link->dhcp_client);
6a7a4e4d 637 if (k < 0)
36c7d709 638 r = log_link_warning_errno(link, k, "Could not stop DHCPv4 client: %m");
111bb8f9
TG		 639 }
640
ba179154 641 if (link->ipv4ll) {
111bb8f9 642 k = sd_ipv4ll_stop(link->ipv4ll);
6a7a4e4d 643 if (k < 0)
36c7d709 644 r = log_link_warning_errno(link, k, "Could not stop IPv4 link-local: %m");
dd43110f
TG		 645 }
646
f5a8c43f
TG		 647 if (link->dhcp6_client) {
648 k = sd_dhcp6_client_stop(link->dhcp6_client);
649 if (k < 0)
36c7d709 650 r = log_link_warning_errno(link, k, "Could not stop DHCPv6 client: %m");
f5a8c43f 651 }
4138fb2c 652
1e7a0e21
LP		 653 if (link->ndisc) {
654 k = sd_ndisc_stop(link->ndisc);
6a7a4e4d 655 if (k < 0)
36c7d709 656 r = log_link_warning_errno(link, k, "Could not stop IPv6 Router Discovery: %m");
4138fb2c
PF		 657 }
658
7465dd22
PF		 659 if (link->radv) {
660 k = sd_radv_stop(link->radv);
661 if (k < 0)
662 r = log_link_warning_errno(link, k, "Could not stop IPv6 Router Advertisement: %m");
663 }
664
7272b25e 665 link_lldp_emit_stop(link);
111bb8f9
TG		 666 return r;
667}
668
b22d8a00 669void link_enter_failed(Link *link) {
ef1ba606 670 assert(link);
f882c247 671
370e9930 672 if (IN_SET(link->state, LINK_STATE_FAILED, LINK_STATE_LINGER))
2139694e
TG		 673 return;
674
6a7a4e4d 675 log_link_warning(link, "Failed");
449f7554 676
e331e246 677 link_set_state(link, LINK_STATE_FAILED);
fe8db0c5 678
111bb8f9
TG		 679 link_stop_clients(link);
680
84de38c5 681 link_dirty(link);
f882c247
TG		 682}
683
4f434938
LP		 684static Address* link_find_dhcp_server_address(Link *link) {
685 Address *address;
686
687 assert(link);
688 assert(link->network);
689
d4cdbea5 690 /* The first statically configured address if there is any */
4f434938
LP		 691 LIST_FOREACH(addresses, address, link->network->static_addresses) {
692
693 if (address->family != AF_INET)
694 continue;
695
af93291c 696 if (in_addr_is_null(address->family, &address->in_addr))
4f434938
LP		 697 continue;
698
699 return address;
700 }
701
702 /* If that didn't work, find a suitable address we got from the pool */
703 LIST_FOREACH(addresses, address, link->pool_addresses) {
704 if (address->family != AF_INET)
705 continue;
706
707 return address;
708 }
709
710 return NULL;
711}
712
e3a7b048 713static void link_enter_configured(Link *link) {
dd43110f
TG		 714 assert(link);
715 assert(link->network);
e3a7b048
SS		 716
717 if (link->state != LINK_STATE_SETTING_ROUTES)
718 return;
dd43110f 719
6a7a4e4d 720 log_link_info(link, "Configured");
dd43110f 721
e331e246 722 link_set_state(link, LINK_STATE_CONFIGURED);
dd43110f 723
84de38c5 724 link_dirty(link);
dd43110f
TG		 725}
726
8012cd39
TG		 727void link_check_ready(Link *link) {
728 Address *a;
729 Iterator i;
730
3c9b8860 731 assert(link);
adda1ed9 732
7209086d
SS		 733 if (IN_SET(link->state, LINK_STATE_FAILED, LINK_STATE_LINGER))
734 return;
735
adda1ed9
TG		 736 if (!link->network)
737 return;
3c9b8860 738
7715629e
ST		 739 if (!link->static_routes_configured)
740 return;
741
742 if (!link->routing_policy_rules_configured)
3c9b8860
TG		 743 return;
744
78c958f8 745 if (link_ipv4ll_enabled(link))
3c9b8860
TG		 746 if (!link->ipv4ll_address ||
747 !link->ipv4ll_route)
748 return;
749
5971cb9d
SS		 750 if (!link->network->bridge) {
751
752 if (link_ipv6ll_enabled(link))
753 if (in_addr_is_null(AF_INET6, (const union in_addr_union*) &link->ipv6ll_address) > 0)
754 return;
755
756 if ((link_dhcp4_enabled(link) && !link_dhcp6_enabled(link) &&
757 !link->dhcp4_configured) ||
758 (link_dhcp6_enabled(link) && !link_dhcp4_enabled(link) &&
759 !link->dhcp6_configured) ||
760 (link_dhcp4_enabled(link) && link_dhcp6_enabled(link) &&
761 !link->dhcp4_configured && !link->dhcp6_configured))
e7ab854c
TG		 762 return;
763
5971cb9d
SS		 764 if (link_ipv6_accept_ra_enabled(link) && !link->ndisc_configured)
765 return;
766 }
fe307276 767
8012cd39
TG		 768 SET_FOREACH(a, link->addresses, i)
769 if (!address_is_ready(a))
770 return;
771
9fdaa992
TG		 772 if (link->state != LINK_STATE_CONFIGURED)
773 link_enter_configured(link);
3c9b8860
TG		 774
775 return;
776}
777
8a9b3a23
SS		 778static int link_set_routing_policy_rule(Link *link) {
779 RoutingPolicyRule *rule, *rrule = NULL;
780 int r;
781
782 assert(link);
783 assert(link->network);
784
785 LIST_FOREACH(rules, rule, link->network->rules) {
786 r = routing_policy_rule_get(link->manager, rule->family, &rule->from, rule->from_prefixlen, &rule->to,
762e2659 787 rule->to_prefixlen, rule->tos, rule->fwmark, rule->table, rule->iif, rule->oif, &rrule);
e6b65ab7 788 if (r == 0) {
8a9b3a23
SS		 789 (void) routing_policy_rule_make_local(link->manager, rrule);
790 continue;
791 }
792
793 r = routing_policy_rule_configure(rule, link, link_routing_policy_rule_handler, false);
794 if (r < 0) {
795 log_link_warning_errno(link, r, "Could not set routing policy rules: %m");
796 link_enter_failed(link);
797 return r;
798 }
799
7715629e 800 link->routing_policy_rule_messages++;
8a9b3a23
SS		 801 }
802
803 routing_policy_rule_purge(link->manager, link);
7715629e
ST		 804 if (link->routing_policy_rule_messages == 0) {
805 link->routing_policy_rules_configured = true;
806 link_check_ready(link);
807 } else
808 log_link_debug(link, "Setting routing policy rules");
8a9b3a23
SS		 809
810 return 0;
811}
812
1c4baffc 813static int route_handler(sd_netlink *rtnl, sd_netlink_message *m, void *userdata) {
1046bf9b 814 Link *link = userdata;
f882c247
TG		 815 int r;
816
1046bf9b 817 assert(link);
7715629e 818 assert(link->route_messages > 0);
370e9930
TG		 819 assert(IN_SET(link->state, LINK_STATE_SETTING_ADDRESSES,
820 LINK_STATE_SETTING_ROUTES, LINK_STATE_FAILED,
821 LINK_STATE_LINGER));
f882c247 822
7715629e 823 link->route_messages--;
f882c247 824
77a008c0 825 if (IN_SET(link->state, LINK_STATE_FAILED, LINK_STATE_LINGER))
f882c247
TG		 826 return 1;
827
1c4baffc 828 r = sd_netlink_message_get_errno(m);
c166a070 829 if (r < 0 && r != -EEXIST)
a2fae7bb 830 log_link_warning_errno(link, r, "Could not set route: %m");
f882c247 831
7715629e 832 if (link->route_messages == 0) {
6a7a4e4d 833 log_link_debug(link, "Routes set");
7715629e 834 link->static_routes_configured = true;
8012cd39 835 link_check_ready(link);
dd3efc09 836 }
f882c247
TG		 837
838 return 1;
839}
840
841static int link_enter_set_routes(Link *link) {
a6cc569e 842 Route *rt;
f882c247
TG		 843 int r;
844
845 assert(link);
846 assert(link->network);
ef1ba606 847 assert(link->state == LINK_STATE_SETTING_ADDRESSES);
f882c247 848
27c34f73
SS		 849 (void) link_set_routing_policy_rule(link);
850
e331e246 851 link_set_state(link, LINK_STATE_SETTING_ROUTES);
f882c247 852
3d3d4255 853 LIST_FOREACH(routes, rt, link->network->static_routes) {
483d099e 854 r = route_configure(rt, link, route_handler);
dd3efc09 855 if (r < 0) {
6a7a4e4d 856 log_link_warning_errno(link, r, "Could not set routes: %m");
3c9b8860 857 link_enter_failed(link);
a6cc569e
TG		 858 return r;
859 }
860
7715629e 861 link->route_messages++;
8ddbeaa2 862 }
f5be5601 863
7715629e
ST		 864 if (link->route_messages == 0) {
865 link->static_routes_configured = true;
8012cd39 866 link_check_ready(link);
431ca2ce 867 } else
6a7a4e4d 868 log_link_debug(link, "Setting routes");
f882c247
TG		 869
870 return 0;
871}
872
91b5f997 873int link_route_remove_handler(sd_netlink *rtnl, sd_netlink_message *m, void *userdata) {
1046bf9b 874 Link *link = userdata;
5c1d3fc9
UTL		 875 int r;
876
877 assert(m);
878 assert(link);
879 assert(link->ifname);
880
5da8149f 881 if (IN_SET(link->state, LINK_STATE_FAILED, LINK_STATE_LINGER))
5c1d3fc9
UTL		 882 return 1;
883
1c4baffc 884 r = sd_netlink_message_get_errno(m);
b90b025a 885 if (r < 0 && r != -ESRCH)
a2fae7bb 886 log_link_warning_errno(link, r, "Could not drop route: %m");
5c1d3fc9 887
5bdd314c 888 return 1;
5c1d3fc9
UTL		 889}
890
1c4baffc 891static int address_handler(sd_netlink *rtnl, sd_netlink_message *m, void *userdata) {
1046bf9b 892 Link *link = userdata;
f882c247
TG		 893 int r;
894
4958aee4 895 assert(rtnl);
f5be5601
TG		 896 assert(m);
897 assert(link);
898 assert(link->ifname);
7715629e 899 assert(link->address_messages > 0);
370e9930
TG		 900 assert(IN_SET(link->state, LINK_STATE_SETTING_ADDRESSES,
901 LINK_STATE_FAILED, LINK_STATE_LINGER));
f882c247 902
7715629e 903 link->address_messages--;
f882c247 904
5da8149f 905 if (IN_SET(link->state, LINK_STATE_FAILED, LINK_STATE_LINGER))
f882c247
TG		 906 return 1;
907
1c4baffc 908 r = sd_netlink_message_get_errno(m);
c166a070 909 if (r < 0 && r != -EEXIST)
a2fae7bb 910 log_link_warning_errno(link, r, "could not set address: %m");
45af44d4 911 else if (r >= 0)
200a0868 912 manager_rtnl_process_address(rtnl, m, link->manager);
f882c247 913
7715629e 914 if (link->address_messages == 0) {
6a7a4e4d 915 log_link_debug(link, "Addresses set");
ef1ba606 916 link_enter_set_routes(link);
dd3efc09 917 }
f882c247
TG		 918
919 return 1;
920}
921
95b74ef6 922static int address_label_handler(sd_netlink *rtnl, sd_netlink_message *m, void *userdata) {
1046bf9b 923 Link *link = userdata;
95b74ef6
SS		 924 int r;
925
926 assert(rtnl);
927 assert(m);
928 assert(link);
929 assert(link->ifname);
7715629e 930 assert(link->address_label_messages > 0);
95b74ef6 931
7715629e 932 link->address_label_messages--;
95b74ef6
SS		 933
934 if (IN_SET(link->state, LINK_STATE_FAILED, LINK_STATE_LINGER))
935 return 1;
936
937 r = sd_netlink_message_get_errno(m);
938 if (r < 0 && r != -EEXIST)
939 log_link_warning_errno(link, r, "could not set address label: %m");
940 else if (r >= 0)
941 manager_rtnl_process_address(rtnl, m, link->manager);
942
7715629e 943 if (link->address_label_messages == 0)
95b74ef6 944 log_link_debug(link, "Addresses label set");
95b74ef6
SS		 945
946 return 1;
947}
948
a380b2d4 949static int link_push_uplink_dns_to_dhcp_server(Link *link, sd_dhcp_server *s) {
4f5f911e
LP		 950 _cleanup_free_ struct in_addr *addresses = NULL;
951 size_t n_addresses = 0, n_allocated = 0;
5512a963 952 unsigned i;
4f5f911e
LP		 953
954 log_debug("Copying DNS server information from %s", link->ifname);
955
956 if (!link->network)
957 return 0;
958
5512a963 959 for (i = 0; i < link->network->n_dns; i++) {
49ad6829 960 struct in_addr ia;
4f5f911e
LP		 961
962 /* Only look for IPv4 addresses */
5512a963 963 if (link->network->dns[i].family != AF_INET)
4f5f911e
LP		 964 continue;
965
49ad6829
LP		 966 ia = link->network->dns[i].address.in;
967
968 /* Never propagate obviously borked data */
969 if (in4_addr_is_null(&ia) || in4_addr_is_localhost(&ia))
970 continue;
971
4f5f911e
LP		 972 if (!GREEDY_REALLOC(addresses, n_allocated, n_addresses + 1))
973 return log_oom();
974
49ad6829 975 addresses[n_addresses++] = ia;
4f5f911e
LP		 976 }
977
5512a963 978 if (link->network->dhcp_use_dns && link->dhcp_lease) {
4f5f911e
LP		 979 const struct in_addr *da = NULL;
980 int n;
981
982 n = sd_dhcp_lease_get_dns(link->dhcp_lease, &da);
983 if (n > 0) {
984
985 if (!GREEDY_REALLOC(addresses, n_allocated, n_addresses + n))
986 return log_oom();
987
988 memcpy(addresses + n_addresses, da, n * sizeof(struct in_addr));
989 n_addresses += n;
990 }
991 }
992
993 if (n_addresses <= 0)
994 return 0;
995
996 return sd_dhcp_server_set_dns(s, addresses, n_addresses);
997}
998
a380b2d4 999static int link_push_uplink_ntp_to_dhcp_server(Link *link, sd_dhcp_server *s) {
4f5f911e
LP		 1000 _cleanup_free_ struct in_addr *addresses = NULL;
1001 size_t n_addresses = 0, n_allocated = 0;
1002 char **a;
1003
1004 if (!link->network)
1005 return 0;
1006
1007 log_debug("Copying NTP server information from %s", link->ifname);
1008
1009 STRV_FOREACH(a, link->network->ntp) {
1010 struct in_addr ia;
1011
1012 /* Only look for IPv4 addresses */
1013 if (inet_pton(AF_INET, *a, &ia) <= 0)
1014 continue;
49ad6829
LP		 1015
1016 /* Never propagate obviously borked data */
1017 if (in4_addr_is_null(&ia) || in4_addr_is_localhost(&ia))
1018 continue;
4f5f911e
LP		 1019
1020 if (!GREEDY_REALLOC(addresses, n_allocated, n_addresses + 1))
1021 return log_oom();
1022
1023 addresses[n_addresses++] = ia;
1024 }
1025
5512a963 1026 if (link->network->dhcp_use_ntp && link->dhcp_lease) {
4f5f911e
LP		 1027 const struct in_addr *da = NULL;
1028 int n;
1029
1030 n = sd_dhcp_lease_get_ntp(link->dhcp_lease, &da);
1031 if (n > 0) {
1032
1033 if (!GREEDY_REALLOC(addresses, n_allocated, n_addresses + n))
1034 return log_oom();
1035
1036 memcpy(addresses + n_addresses, da, n * sizeof(struct in_addr));
1037 n_addresses += n;
1038 }
1039 }
1040
1041 if (n_addresses <= 0)
1042 return 0;
1043
1044 return sd_dhcp_server_set_ntp(s, addresses, n_addresses);
1045}
1046
f6bb7ac5
TJ		 1047static int link_set_bridge_fdb(Link *link) {
1048 FdbEntry *fdb_entry;
197e2809 1049 int r;
f6bb7ac5
TJ		 1050
1051 LIST_FOREACH(static_fdb_entries, fdb_entry, link->network->static_fdb_entries) {
1052 r = fdb_entry_configure(link, fdb_entry);
197e2809 1053 if (r < 0)
f6bb7ac5 1054 return log_link_error_errno(link, r, "Failed to add MAC entry to static MAC table: %m");
f6bb7ac5
TJ		 1055 }
1056
197e2809 1057 return 0;
f6bb7ac5
TJ		 1058}
1059
f882c247 1060static int link_enter_set_addresses(Link *link) {
95b74ef6 1061 AddressLabel *label;
a6cc569e 1062 Address *ad;
f882c247
TG		 1063 int r;
1064
1065 assert(link);
1066 assert(link->network);
f5be5601 1067 assert(link->state != _LINK_STATE_INVALID);
f882c247 1068
f6bb7ac5
TJ		 1069 r = link_set_bridge_fdb(link);
1070 if (r < 0)
1071 return r;
1072
e331e246 1073 link_set_state(link, LINK_STATE_SETTING_ADDRESSES);
f882c247 1074
3d3d4255 1075 LIST_FOREACH(addresses, ad, link->network->static_addresses) {
483d099e 1076 r = address_configure(ad, link, address_handler, false);
dd3efc09 1077 if (r < 0) {
5a8bcb67 1078 log_link_warning_errno(link, r, "Could not set addresses: %m");
f5be5601 1079 link_enter_failed(link);
95b74ef6
SS		 1080 return r;
1081 }
1082
7715629e 1083 link->address_messages++;
95b74ef6
SS		 1084 }
1085
1086 LIST_FOREACH(labels, label, link->network->address_labels) {
1087 r = address_label_configure(label, link, address_label_handler, false);
1088 if (r < 0) {
1089 log_link_warning_errno(link, r, "Could not set address label: %m");
1090 link_enter_failed(link);
f5be5601
TG		 1091 return r;
1092 }
1093
7715629e 1094 link->address_label_messages++;
f882c247
TG		 1095 }
1096
d4cdbea5
TG		 1097 /* now that we can figure out a default address for the dhcp server,
1098 start it */
708c425d 1099 if (link_dhcp4_server_enabled(link) && (link->flags & IFF_UP)) {
d4cdbea5 1100 Address *address;
4f5f911e
LP		 1101 Link *uplink = NULL;
1102 bool acquired_uplink = false;
d4cdbea5
TG		 1103
1104 address = link_find_dhcp_server_address(link);
1105 if (!address) {
6a7a4e4d 1106 log_link_warning(link, "Failed to find suitable address for DHCPv4 server instance.");
d4cdbea5
TG		 1107 link_enter_failed(link);
1108 return 0;
1109 }
1110
61986155 1111 /* use the server address' subnet as the pool */
9b3a67c5
TG		 1112 r = sd_dhcp_server_configure_pool(link->dhcp_server, &address->in_addr.in, address->prefixlen,
1113 link->network->dhcp_server_pool_offset, link->network->dhcp_server_pool_size);
d4cdbea5
TG		 1114 if (r < 0)
1115 return r;
1116
1117 /* TODO:
1118 r = sd_dhcp_server_set_router(link->dhcp_server,
1119 &main_address->in_addr.in);
1120 if (r < 0)
1121 return r;
d4cdbea5
TG		 1122 */
1123
586ac6f7
LP		 1124 if (link->network->dhcp_server_max_lease_time_usec > 0) {
1125 r = sd_dhcp_server_set_max_lease_time(
1126 link->dhcp_server,
1127 DIV_ROUND_UP(link->network->dhcp_server_max_lease_time_usec, USEC_PER_SEC));
1128 if (r < 0)
1129 return r;
1130 }
1131
1132 if (link->network->dhcp_server_default_lease_time_usec > 0) {
1133 r = sd_dhcp_server_set_default_lease_time(
1134 link->dhcp_server,
1135 DIV_ROUND_UP(link->network->dhcp_server_default_lease_time_usec, USEC_PER_SEC));
1136 if (r < 0)
1137 return r;
1138 }
1139
1a04db0f
LP		 1140 if (link->network->dhcp_server_emit_dns) {
1141
4f5f911e 1142 if (link->network->n_dhcp_server_dns > 0)
1a04db0f 1143 r = sd_dhcp_server_set_dns(link->dhcp_server, link->network->dhcp_server_dns, link->network->n_dhcp_server_dns);
4f5f911e
LP		 1144 else {
1145 uplink = manager_find_uplink(link->manager, link);
1146 acquired_uplink = true;
1147
1148 if (!uplink) {
1149 log_link_debug(link, "Not emitting DNS server information on link, couldn't find suitable uplink.");
1150 r = 0;
1151 } else
a380b2d4 1152 r = link_push_uplink_dns_to_dhcp_server(uplink, link->dhcp_server);
4f5f911e
LP		 1153 }
1154 if (r < 0)
1155 log_link_warning_errno(link, r, "Failed to set DNS server for DHCP server, ignoring: %m");
1a04db0f
LP		 1156 }
1157
1a04db0f
LP		 1158 if (link->network->dhcp_server_emit_ntp) {
1159
4f5f911e 1160 if (link->network->n_dhcp_server_ntp > 0)
1a04db0f 1161 r = sd_dhcp_server_set_ntp(link->dhcp_server, link->network->dhcp_server_ntp, link->network->n_dhcp_server_ntp);
4f5f911e
LP		 1162 else {
1163 if (!acquired_uplink)
1164 uplink = manager_find_uplink(link->manager, link);
1165
1166 if (!uplink) {
1167 log_link_debug(link, "Not emitting NTP server information on link, couldn't find suitable uplink.");
1168 r = 0;
1169 } else
a380b2d4 1170 r = link_push_uplink_ntp_to_dhcp_server(uplink, link->dhcp_server);
4f5f911e
LP		 1171
1172 }
1173 if (r < 0)
1174 log_link_warning_errno(link, r, "Failed to set NTP server for DHCP server, ignoring: %m");
1a04db0f
LP		 1175 }
1176
77ff6022 1177 r = sd_dhcp_server_set_emit_router(link->dhcp_server, link->network->dhcp_server_emit_router);
fc95c359
YW		 1178 if (r < 0)
1179 return log_link_warning_errno(link, r, "Failed to set router emission for DHCP server: %m");
77ff6022 1180
8eb9058d
LP		 1181 if (link->network->dhcp_server_emit_timezone) {
1182 _cleanup_free_ char *buffer = NULL;
0ab8a1b6 1183 const char *tz = NULL;
8eb9058d
LP		 1184
1185 if (link->network->dhcp_server_timezone)
1186 tz = link->network->dhcp_server_timezone;
1187 else {
1188 r = get_timezone(&buffer);
1189 if (r < 0)
1190 log_warning_errno(r, "Failed to determine timezone: %m");
1191 else
1192 tz = buffer;
1193 }
1194
1195 if (tz) {
1196 r = sd_dhcp_server_set_timezone(link->dhcp_server, tz);
1197 if (r < 0)
1198 return r;
1199 }
1200 }
1201
d4cdbea5
TG		 1202 r = sd_dhcp_server_start(link->dhcp_server);
1203 if (r < 0) {
6a7a4e4d 1204 log_link_warning_errno(link, r, "Could not start DHCPv4 server instance: %m");
d4cdbea5
TG		 1205
1206 link_enter_failed(link);
1207
1208 return 0;
1209 }
1210
6a7a4e4d 1211 log_link_debug(link, "Offering DHCPv4 leases");
d4cdbea5
TG		 1212 }
1213
7715629e 1214 if (link->address_messages == 0)
431ca2ce 1215 link_enter_set_routes(link);
6a7a4e4d
LP		 1216 else
1217 log_link_debug(link, "Setting addresses");
431ca2ce 1218
f882c247
TG		 1219 return 0;
1220}
1221
91b5f997 1222int link_address_remove_handler(sd_netlink *rtnl, sd_netlink_message *m, void *userdata) {
1046bf9b 1223 Link *link = userdata;
ff254138
TG		 1224 int r;
1225
1226 assert(m);
1227 assert(link);
1228 assert(link->ifname);
1229
5da8149f 1230 if (IN_SET(link->state, LINK_STATE_FAILED, LINK_STATE_LINGER))
ff254138
TG		 1231 return 1;
1232
1c4baffc 1233 r = sd_netlink_message_get_errno(m);
b90b025a 1234 if (r < 0 && r != -EADDRNOTAVAIL)
a2fae7bb 1235 log_link_warning_errno(link, r, "Could not drop address: %m");
ff254138 1236
5bdd314c 1237 return 1;
ff254138
TG		 1238}
1239
13b498f9
TJ		 1240static int link_set_bridge_vlan(Link *link) {
1241 int r = 0;
1242
1243 r = br_vlan_configure(link, link->network->pvid, link->network->br_vid_bitmap, link->network->br_untagged_bitmap);
1244 if (r < 0)
1245 log_link_error_errno(link, r, "Failed to assign VLANs to bridge port: %m");
1246
1247 return r;
1248}
1249
a60a720c 1250static int link_set_proxy_arp(Link *link) {
23d8b221
SS		 1251 const char *p = NULL;
1252 int r;
1253
1254 if (!link_proxy_arp_enabled(link))
1255 return 0;
1256
1257 p = strjoina("/proc/sys/net/ipv4/conf/", link->ifname, "/proxy_arp");
1258
1259 r = write_string_file(p, one_zero(link->network->proxy_arp), WRITE_STRING_FILE_VERIFY_ON_FAILURE);
1260 if (r < 0)
1261 log_link_warning_errno(link, r, "Cannot configure proxy ARP for interface: %m");
1262
1263 return 0;
1264}
1265
1c4baffc 1266static int link_set_handler(sd_netlink *rtnl, sd_netlink_message *m, void *userdata) {
1046bf9b 1267 Link *link = userdata;
e1853b00
SS		 1268 int r;
1269
1046bf9b
YW		 1270 assert(link);
1271
6a7a4e4d 1272 log_link_debug(link, "Set link");
e1853b00 1273
1c4baffc 1274 r = sd_netlink_message_get_errno(m);
e1853b00 1275 if (r < 0 && r != -EEXIST) {
f2341e0a 1276 log_link_error_errno(link, r, "Could not join netdev: %m");
e1853b00 1277 link_enter_failed(link);
e1853b00
SS		 1278 }
1279
0ae286e6 1280 return 1;
e1853b00
SS		 1281}
1282
55dc8c4a
YW		 1283static int link_configure_after_setting_mtu(Link *link);
1284
1c4baffc 1285static int set_mtu_handler(sd_netlink *rtnl, sd_netlink_message *m, void *userdata) {
1046bf9b 1286 Link *link = userdata;
4f882b2a
TG		 1287 int r;
1288
1289 assert(m);
1290 assert(link);
1291 assert(link->ifname);
1292
55dc8c4a
YW		 1293 link->setting_mtu = false;
1294
5da8149f 1295 if (IN_SET(link->state, LINK_STATE_FAILED, LINK_STATE_LINGER))
4f882b2a
TG		 1296 return 1;
1297
1c4baffc 1298 r = sd_netlink_message_get_errno(m);
55dc8c4a 1299 if (r < 0) {
a2fae7bb 1300 log_link_warning_errno(link, r, "Could not set MTU: %m");
55dc8c4a
YW		 1301 return 1;
1302 }
1303
1304 log_link_debug(link, "Setting MTU done.");
1305
1306 if (link->state == LINK_STATE_PENDING)
1307 (void) link_configure_after_setting_mtu(link);
4f882b2a
TG		 1308
1309 return 1;
1310}
1311
3c9b8860 1312int link_set_mtu(Link *link, uint32_t mtu) {
4afd3348 1313 _cleanup_(sd_netlink_message_unrefp) sd_netlink_message *req = NULL;
4f882b2a
TG		 1314 int r;
1315
1316 assert(link);
1317 assert(link->manager);
1318 assert(link->manager->rtnl);
1319
55dc8c4a 1320 if (link->mtu == mtu || link->setting_mtu)
ee493106
YW		 1321 return 0;
1322
6a7a4e4d 1323 log_link_debug(link, "Setting MTU: %" PRIu32, mtu);
4f882b2a 1324
6a7a4e4d
LP		 1325 r = sd_rtnl_message_new_link(link->manager->rtnl, &req, RTM_SETLINK, link->ifindex);
1326 if (r < 0)
1327 return log_link_error_errno(link, r, "Could not allocate RTM_SETLINK message: %m");
4f882b2a 1328
44b598a1 1329 /* If IPv6 not configured (no static IPv6 address and IPv6LL autoconfiguration is disabled)
72c2500b 1330 * for this interface, or if it is a bridge slave, then disable IPv6 else enable it. */
44b598a1
SS		 1331 (void) link_enable_ipv6(link);
1332
1333 /* IPv6 protocol requires a minimum MTU of IPV6_MTU_MIN(1280) bytes
72c2500b
YW		 1334 * on the interface. Bump up MTU bytes to IPV6_MTU_MIN. */
1335 if (link_ipv6_enabled(link) && mtu < IPV6_MIN_MTU) {
44b598a1
SS		 1336
1337 log_link_warning(link, "Bumping MTU to " STRINGIFY(IPV6_MIN_MTU) ", as "
1338 "IPv6 is requested and requires a minimum MTU of " STRINGIFY(IPV6_MIN_MTU) " bytes: %m");
1339
72c2500b 1340 mtu = IPV6_MIN_MTU;
44b598a1
SS		 1341 }
1342
1c4baffc 1343 r = sd_netlink_message_append_u32(req, IFLA_MTU, mtu);
6a7a4e4d
LP		 1344 if (r < 0)
1345 return log_link_error_errno(link, r, "Could not append MTU: %m");
4f882b2a 1346
ee38400b 1347 r = sd_netlink_call_async(link->manager->rtnl, NULL, req, set_mtu_handler,
8190a388 1348 link_netlink_destroy_callback, link, 0, __func__);
6a7a4e4d
LP		 1349 if (r < 0)
1350 return log_link_error_errno(link, r, "Could not send rtnetlink message: %m");
4f882b2a 1351
ae941762 1352 link_ref(link);
1046bf9b 1353 link->setting_mtu = true;
b226d99b 1354
4f882b2a
TG		 1355 return 0;
1356}
1357
99d2baa2 1358static int set_flags_handler(sd_netlink *rtnl, sd_netlink_message *m, void *userdata) {
1046bf9b 1359 Link *link = userdata;
99d2baa2
SS		 1360 int r;
1361
1362 assert(m);
1363 assert(link);
1364 assert(link->ifname);
1365
1366 if (IN_SET(link->state, LINK_STATE_FAILED, LINK_STATE_LINGER))
1367 return 1;
1368
1369 r = sd_netlink_message_get_errno(m);
1370 if (r < 0)
1371 log_link_warning_errno(link, r, "Could not set link flags: %m");
1372
1373 return 1;
1374}
1375
1376static int link_set_flags(Link *link) {
1377 _cleanup_(sd_netlink_message_unrefp) sd_netlink_message *req = NULL;
1378 unsigned ifi_change = 0;
1379 unsigned ifi_flags = 0;
1380 int r;
1381
1382 assert(link);
1383 assert(link->manager);
1384 assert(link->manager->rtnl);
1385
1386 if (link->flags & IFF_LOOPBACK)
1387 return 0;
1388
1389 if (!link->network)
1390 return 0;
1391
866e6b7a 1392 if (link->network->arp < 0 && link->network->multicast < 0 && link->network->allmulticast < 0)
99d2baa2
SS		 1393 return 0;
1394
1395 r = sd_rtnl_message_new_link(link->manager->rtnl, &req, RTM_SETLINK, link->ifindex);
1396 if (r < 0)
1397 return log_link_error_errno(link, r, "Could not allocate RTM_SETLINK message: %m");
1398
1399 if (link->network->arp >= 0) {
1400 ifi_change |= IFF_NOARP;
e6ebebbe
SS		 1401 SET_FLAG(ifi_flags, IFF_NOARP, link->network->arp == 0);
1402 }
1403
1404 if (link->network->multicast >= 0) {
1405 ifi_change |= IFF_MULTICAST;
1406 SET_FLAG(ifi_flags, IFF_MULTICAST, link->network->multicast);
99d2baa2
SS		 1407 }
1408
866e6b7a
SS		 1409 if (link->network->allmulticast >= 0) {
1410 ifi_change |= IFF_ALLMULTI;
1411 SET_FLAG(ifi_flags, IFF_ALLMULTI, link->network->allmulticast);
1412 }
1413
99d2baa2
SS		 1414 r = sd_rtnl_message_link_set_flags(req, ifi_flags, ifi_change);
1415 if (r < 0)
1416 return log_link_error_errno(link, r, "Could not set link flags: %m");
1417
ee38400b 1418 r = sd_netlink_call_async(link->manager->rtnl, NULL, req, set_flags_handler,
8190a388 1419 link_netlink_destroy_callback, link, 0, __func__);
99d2baa2
SS		 1420 if (r < 0)
1421 return log_link_error_errno(link, r, "Could not send rtnetlink message: %m");
1422
1423 link_ref(link);
1424
1425 return 0;
1426}
1427
e1853b00 1428static int link_set_bridge(Link *link) {
4afd3348 1429 _cleanup_(sd_netlink_message_unrefp) sd_netlink_message *req = NULL;
e1853b00
SS		 1430 int r;
1431
1432 assert(link);
1433 assert(link->network);
1434
6a7a4e4d
LP		 1435 r = sd_rtnl_message_new_link(link->manager->rtnl, &req, RTM_SETLINK, link->ifindex);
1436 if (r < 0)
1437 return log_link_error_errno(link, r, "Could not allocate RTM_SETLINK message: %m");
e1853b00
SS		 1438
1439 r = sd_rtnl_message_link_set_family(req, PF_BRIDGE);
6a7a4e4d
LP		 1440 if (r < 0)
1441 return log_link_error_errno(link, r, "Could not set message family: %m");
e1853b00 1442
1c4baffc 1443 r = sd_netlink_message_open_container(req, IFLA_PROTINFO);
6a7a4e4d
LP		 1444 if (r < 0)
1445 return log_link_error_errno(link, r, "Could not append IFLA_PROTINFO attribute: %m");
e1853b00 1446
7f9915f0
SS		 1447 if (link->network->use_bpdu >= 0) {
1448 r = sd_netlink_message_append_u8(req, IFLA_BRPORT_GUARD, link->network->use_bpdu);
1449 if (r < 0)
1450 return log_link_error_errno(link, r, "Could not append IFLA_BRPORT_GUARD attribute: %m");
1451 }
eb7ff4dd 1452
7f9915f0
SS		 1453 if (link->network->hairpin >= 0) {
1454 r = sd_netlink_message_append_u8(req, IFLA_BRPORT_MODE, link->network->hairpin);
1455 if (r < 0)
1456 return log_link_error_errno(link, r, "Could not append IFLA_BRPORT_MODE attribute: %m");
1457 }
eb7ff4dd 1458
7f9915f0
SS		 1459 if (link->network->fast_leave >= 0) {
1460 r = sd_netlink_message_append_u8(req, IFLA_BRPORT_FAST_LEAVE, link->network->fast_leave);
1461 if (r < 0)
1462 return log_link_error_errno(link, r, "Could not append IFLA_BRPORT_FAST_LEAVE attribute: %m");
1463 }
eb7ff4dd 1464
7f9915f0
SS		 1465 if (link->network->allow_port_to_be_root >= 0) {
1466 r = sd_netlink_message_append_u8(req, IFLA_BRPORT_PROTECT, link->network->allow_port_to_be_root);
1467 if (r < 0)
1468 return log_link_error_errno(link, r, "Could not append IFLA_BRPORT_PROTECT attribute: %m");
eb7ff4dd 1469
7f9915f0
SS		 1470 }
1471
1472 if (link->network->unicast_flood >= 0) {
1473 r = sd_netlink_message_append_u8(req, IFLA_BRPORT_UNICAST_FLOOD, link->network->unicast_flood);
1474 if (r < 0)
1475 return log_link_error_errno(link, r, "Could not append IFLA_BRPORT_UNICAST_FLOOD attribute: %m");
1476
1477 }
eb7ff4dd 1478
34437b4f 1479 if (link->network->cost != 0) {
1c4baffc 1480 r = sd_netlink_message_append_u32(req, IFLA_BRPORT_COST, link->network->cost);
6a7a4e4d
LP		 1481 if (r < 0)
1482 return log_link_error_errno(link, r, "Could not append IFLA_BRPORT_COST attribute: %m");
e1853b00 1483 }
b56be296
DJL		 1484 if (link->network->priority != LINK_BRIDGE_PORT_PRIORITY_INVALID) {
1485 r = sd_netlink_message_append_u16(req, IFLA_BRPORT_PRIORITY, link->network->priority);
1486 if (r < 0)
1487 return log_link_error_errno(link, r, "Could not append IFLA_BRPORT_PRIORITY attribute: %m");
1488 }
e1853b00 1489
1c4baffc 1490 r = sd_netlink_message_close_container(req);
6a7a4e4d
LP		 1491 if (r < 0)
1492 return log_link_error_errno(link, r, "Could not append IFLA_LINKINFO attribute: %m");
e1853b00 1493
ee38400b 1494 r = sd_netlink_call_async(link->manager->rtnl, NULL, req, link_set_handler,
8190a388 1495 link_netlink_destroy_callback, link, 0, __func__);
6a7a4e4d
LP		 1496 if (r < 0)
1497 return log_link_error_errno(link, r, "Could not send rtnetlink message: %m");
e1853b00
SS		 1498
1499 link_ref(link);
1500
1501 return r;
1502}
1503
eb64b435
SS		 1504static int link_bond_set(Link *link) {
1505 _cleanup_(sd_netlink_message_unrefp) sd_netlink_message *req = NULL;
1506 int r;
1507
1508 assert(link);
1509 assert(link->network);
1510
1511 r = sd_rtnl_message_new_link(link->manager->rtnl, &req, RTM_NEWLINK, link->network->bond->ifindex);
1512 if (r < 0)
1513 return log_link_error_errno(link, r, "Could not allocate RTM_SETLINK message: %m");
1514
1515 r = sd_netlink_message_set_flags(req, NLM_F_REQUEST | NLM_F_ACK);
1516 if (r < 0)
1517 return log_link_error_errno(link, r, "Could not set netlink flags: %m");
1518
1519 r = sd_netlink_message_open_container(req, IFLA_LINKINFO);
1520 if (r < 0)
1521 return log_link_error_errno(link, r, "Could not append IFLA_PROTINFO attribute: %m");
1522
1523 r = sd_netlink_message_open_container_union(req, IFLA_INFO_DATA, "bond");
1524 if (r < 0)
1525 return log_link_error_errno(link, r, "Could not append IFLA_INFO_DATA attribute: %m");
1526
1527 if (link->network->active_slave) {
1528 r = sd_netlink_message_append_u32(req, IFLA_BOND_ACTIVE_SLAVE, link->ifindex);
1529 if (r < 0)
1530 return log_link_error_errno(link, r, "Could not append IFLA_BOND_ACTIVE_SLAVE attribute: %m");
1531 }
1532
1533 if (link->network->primary_slave) {
1534 r = sd_netlink_message_append_u32(req, IFLA_BOND_PRIMARY, link->ifindex);
1535 if (r < 0)
1536 return log_link_error_errno(link, r, "Could not append IFLA_BOND_PRIMARY attribute: %m");
1537 }
1538
1539 r = sd_netlink_message_close_container(req);
1540 if (r < 0)
1541 return log_link_error_errno(link, r, "Could not append IFLA_LINKINFO attribute: %m");
1542
1543 r = sd_netlink_message_close_container(req);
1544 if (r < 0)
1545 return log_link_error_errno(link, r, "Could not append IFLA_INFO_DATA attribute: %m");
1546
ee38400b 1547 r = sd_netlink_call_async(link->manager->rtnl, NULL, req, set_flags_handler,
8190a388 1548 link_netlink_destroy_callback, link, 0, __func__);
eb64b435
SS		 1549 if (r < 0)
1550 return log_link_error_errno(link, r, "Could not send rtnetlink message: %m");
1551
1552 link_ref(link);
1553
1554 return r;
1555}
1556
34437b4f
LP		 1557static int link_lldp_save(Link *link) {
1558 _cleanup_free_ char *temp_path = NULL;
1559 _cleanup_fclose_ FILE *f = NULL;
1560 sd_lldp_neighbor **l = NULL;
1561 int n = 0, r, i;
49699bac
SS		 1562
1563 assert(link);
34437b4f
LP		 1564 assert(link->lldp_file);
1565
1566 if (!link->lldp) {
1567 (void) unlink(link->lldp_file);
1568 return 0;
1569 }
1570
1571 r = sd_lldp_get_neighbors(link->lldp, &l);
1572 if (r < 0)
1573 goto finish;
1574 if (r == 0) {
1575 (void) unlink(link->lldp_file);
1576 goto finish;
1577 }
1578
1579 n = r;
1580
1581 r = fopen_temporary(link->lldp_file, &f, &temp_path);
1582 if (r < 0)
1583 goto finish;
1584
1585 fchmod(fileno(f), 0644);
49699bac 1586
34437b4f
LP		 1587 for (i = 0; i < n; i++) {
1588 const void *p;
1589 le64_t u;
1590 size_t sz;
1591
1592 r = sd_lldp_neighbor_get_raw(l[i], &p, &sz);
9ef61f2e 1593 if (r < 0)
34437b4f
LP		 1594 goto finish;
1595
1596 u = htole64(sz);
1597 (void) fwrite(&u, 1, sizeof(u), f);
1598 (void) fwrite(p, 1, sz, f);
1599 }
49699bac 1600
34437b4f
LP		 1601 r = fflush_and_check(f);
1602 if (r < 0)
1603 goto finish;
1604
1605 if (rename(temp_path, link->lldp_file) < 0) {
1606 r = -errno;
1607 goto finish;
9ef61f2e 1608 }
34437b4f
LP		 1609
1610finish:
1611 if (r < 0) {
1612 (void) unlink(link->lldp_file);
1613 if (temp_path)
1614 (void) unlink(temp_path);
1615
1616 log_link_error_errno(link, r, "Failed to save LLDP data to %s: %m", link->lldp_file);
1617 }
1618
1619 if (l) {
1620 for (i = 0; i < n; i++)
1621 sd_lldp_neighbor_unref(l[i]);
1622 free(l);
1623 }
1624
1625 return r;
1626}
1627
90dffb22 1628static void lldp_handler(sd_lldp *lldp, sd_lldp_event event, sd_lldp_neighbor *n, void *userdata) {
34437b4f 1629 Link *link = userdata;
90dffb22 1630 int r;
34437b4f
LP		 1631
1632 assert(link);
1633
1634 (void) link_lldp_save(link);
90dffb22 1635
7272b25e 1636 if (link_lldp_emit_enabled(link) && event == SD_LLDP_EVENT_ADDED) {
90dffb22
LP		 1637 /* If we received information about a new neighbor, restart the LLDP "fast" logic */
1638
1639 log_link_debug(link, "Received LLDP datagram from previously unknown neighbor, restarting 'fast' LLDP transmission.");
1640
7272b25e 1641 r = link_lldp_emit_start(link);
90dffb22
LP		 1642 if (r < 0)
1643 log_link_warning_errno(link, r, "Failed to restart LLDP transmission: %m");
1644 }
49699bac
SS		 1645}
1646
e7ab854c
TG		 1647static int link_acquire_ipv6_conf(Link *link) {
1648 int r;
1649
1650 assert(link);
1651
e7ab854c 1652 if (link_ipv6_accept_ra_enabled(link)) {
1e7a0e21 1653 assert(link->ndisc);
e7ab854c
TG		 1654
1655 log_link_debug(link, "Discovering IPv6 routers");
1656
1e7a0e21 1657 r = sd_ndisc_start(link->ndisc);
63348d13 1658 if (r < 0 && r != -EBUSY)
e7ab854c
TG		 1659 return log_link_warning_errno(link, r, "Could not start IPv6 Router Discovery: %m");
1660 }
1661
7465dd22
PF		 1662 if (link_radv_enabled(link)) {
1663 assert(link->radv);
1664 assert(in_addr_is_link_local(AF_INET6, (const union in_addr_union*)&link->ipv6ll_address) > 0);
1665
1666 log_link_debug(link, "Starting IPv6 Router Advertisements");
1667
1668 r = sd_radv_start(link->radv);
1669 if (r < 0 && r != -EBUSY)
1670 return log_link_warning_errno(link, r, "Could not start IPv6 Router Advertisement: %m");
1671 }
1672
10752343
PF		 1673 (void) dhcp6_request_prefix_delegation(link);
1674
e7ab854c
TG		 1675 return 0;
1676}
1677
6fc25497 1678static int link_acquire_ipv4_conf(Link *link) {
ff254138
TG		 1679 int r;
1680
1681 assert(link);
1682 assert(link->network);
ff254138
TG		 1683 assert(link->manager);
1684 assert(link->manager->event);
1685
78c958f8 1686 if (link_ipv4ll_enabled(link)) {
eb34d4af 1687 assert(link->ipv4ll);
ff254138 1688
6a7a4e4d 1689 log_link_debug(link, "Acquiring IPv4 link-local address");
5c1d3fc9
UTL		 1690
1691 r = sd_ipv4ll_start(link->ipv4ll);
6a7a4e4d
LP		 1692 if (r < 0)
1693 return log_link_warning_errno(link, r, "Could not acquire IPv4 link-local address: %m");
5c1d3fc9
UTL		 1694 }
1695
78c958f8 1696 if (link_dhcp4_enabled(link)) {
eb34d4af 1697 assert(link->dhcp_client);
ff254138 1698
6a7a4e4d 1699 log_link_debug(link, "Acquiring DHCPv4 lease");
ab47d620 1700
5c1d3fc9 1701 r = sd_dhcp_client_start(link->dhcp_client);
6a7a4e4d
LP		 1702 if (r < 0)
1703 return log_link_warning_errno(link, r, "Could not acquire DHCPv4 lease: %m");
5c1d3fc9 1704 }
ff254138 1705
6fc25497
SS		 1706 return 0;
1707}
1708
1709static int link_acquire_conf(Link *link) {
1710 int r;
1711
1712 assert(link);
1713
1714 r = link_acquire_ipv4_conf(link);
1715 if (r < 0)
1716 return r;
1717
1718 if (in_addr_is_null(AF_INET6, (const union in_addr_union*) &link->ipv6ll_address) == 0) {
1719 r = link_acquire_ipv6_conf(link);
1720 if (r < 0)
1721 return r;
1722 }
1723
7272b25e
LP		 1724 if (link_lldp_emit_enabled(link)) {
1725 r = link_lldp_emit_start(link);
8e1ad1ea
LP		 1726 if (r < 0)
1727 return log_link_warning_errno(link, r, "Failed to start LLDP transmission: %m");
1728 }
1729
ff254138
TG		 1730 return 0;
1731}
1732
a61bb41c 1733bool link_has_carrier(Link *link) {
deb2e523
TG		 1734 /* see Documentation/networking/operstates.txt in the kernel sources */
1735
a61bb41c 1736 if (link->kernel_operstate == IF_OPER_UP)
deb2e523
TG		 1737 return true;
1738
a61bb41c 1739 if (link->kernel_operstate == IF_OPER_UNKNOWN)
deb2e523 1740 /* operstate may not be implemented, so fall back to flags */
a61bb41c 1741 if ((link->flags & IFF_LOWER_UP) && !(link->flags & IFF_DORMANT))
deb2e523
TG		 1742 return true;
1743
1744 return false;
1745}
1746
1c4baffc 1747static int link_up_handler(sd_netlink *rtnl, sd_netlink_message *m, void *userdata) {
1046bf9b 1748 Link *link = userdata;
dd3efc09
TG		 1749 int r;
1750
1746cf2a
TG		 1751 assert(link);
1752
5da8149f 1753 if (IN_SET(link->state, LINK_STATE_FAILED, LINK_STATE_LINGER))
1746cf2a
TG		 1754 return 1;
1755
1c4baffc 1756 r = sd_netlink_message_get_errno(m);
6a7a4e4d 1757 if (r < 0)
26d6b214 1758 /* we warn but don't fail the link, as it may be brought up later */
a2fae7bb 1759 log_link_warning_errno(link, r, "Could not bring up interface: %m");
45ad2c13 1760
f882c247
TG		 1761 return 1;
1762}
1763
14b6bb77 1764int link_up(Link *link) {
4afd3348 1765 _cleanup_(sd_netlink_message_unrefp) sd_netlink_message *req = NULL;
5c3072ea 1766 uint8_t ipv6ll_mode;
f579559b
TG		 1767 int r;
1768
f882c247 1769 assert(link);
c106cc36 1770 assert(link->network);
f882c247
TG		 1771 assert(link->manager);
1772 assert(link->manager->rtnl);
1773
6a7a4e4d 1774 log_link_debug(link, "Bringing link up");
449f7554 1775
6a7a4e4d
LP		 1776 r = sd_rtnl_message_new_link(link->manager->rtnl, &req, RTM_SETLINK, link->ifindex);
1777 if (r < 0)
1778 return log_link_error_errno(link, r, "Could not allocate RTM_SETLINK message: %m");
f579559b 1779
2b2d8603 1780 /* set it free if not enslaved with networkd */
6cb955c6 1781 if (!link->network->bridge && !link->network->bond && !link->network->vrf) {
2b2d8603
TY		 1782 r = sd_netlink_message_append_u32(req, IFLA_MASTER, 0);
1783 if (r < 0)
1784 return log_link_error_errno(link, r, "Could not append IFLA_MASTER attribute: %m");
1785 }
1786
5d4795f3 1787 r = sd_rtnl_message_link_set_flags(req, IFF_UP, IFF_UP);
6a7a4e4d
LP		 1788 if (r < 0)
1789 return log_link_error_errno(link, r, "Could not set link flags: %m");
fc25d7f8 1790
c106cc36 1791 if (link->network->mac) {
1c4baffc 1792 r = sd_netlink_message_append_ether_addr(req, IFLA_ADDRESS, link->network->mac);
6a7a4e4d
LP		 1793 if (r < 0)
1794 return log_link_error_errno(link, r, "Could not set MAC address: %m");
c106cc36
TG		 1795 }
1796
1c4baffc 1797 r = sd_netlink_message_open_container(req, IFLA_AF_SPEC);
6a7a4e4d
LP		 1798 if (r < 0)
1799 return log_link_error_errno(link, r, "Could not open IFLA_AF_SPEC container: %m");
d0d6a4cd 1800
439689c6 1801 if (link_ipv6_enabled(link)) {
01d28f81 1802 /* if the kernel lacks ipv6 support setting IFF_UP fails if any ipv6 options are passed */
1c4baffc 1803 r = sd_netlink_message_open_container(req, AF_INET6);
01d28f81
TG		 1804 if (r < 0)
1805 return log_link_error_errno(link, r, "Could not open AF_INET6 container: %m");
d0d6a4cd 1806
fbc38f23
TY		 1807 if (!link_ipv6ll_enabled(link))
1808 ipv6ll_mode = IN6_ADDR_GEN_MODE_NONE;
1809 else {
1810 const char *p = NULL;
1811 _cleanup_free_ char *stable_secret = NULL;
1812
1813 p = strjoina("/proc/sys/net/ipv6/conf/", link->ifname, "/stable_secret");
1814 r = read_one_line_file(p, &stable_secret);
1815
1816 if (r < 0)
1817 ipv6ll_mode = IN6_ADDR_GEN_MODE_EUI64;
1818 else
1819 ipv6ll_mode = IN6_ADDR_GEN_MODE_STABLE_PRIVACY;
1820 }
1c4baffc 1821 r = sd_netlink_message_append_u8(req, IFLA_INET6_ADDR_GEN_MODE, ipv6ll_mode);
01d28f81
TG		 1822 if (r < 0)
1823 return log_link_error_errno(link, r, "Could not append IFLA_INET6_ADDR_GEN_MODE: %m");
d0d6a4cd 1824
01d28f81 1825 if (!in_addr_is_null(AF_INET6, &link->network->ipv6_token)) {
1c4baffc 1826 r = sd_netlink_message_append_in6_addr(req, IFLA_INET6_TOKEN, &link->network->ipv6_token.in6);
01d28f81
TG		 1827 if (r < 0)
1828 return log_link_error_errno(link, r, "Could not append IFLA_INET6_TOKEN: %m");
1829 }
1830
1c4baffc 1831 r = sd_netlink_message_close_container(req);
6a7a4e4d 1832 if (r < 0)
01d28f81 1833 return log_link_error_errno(link, r, "Could not close AF_INET6 container: %m");
7f77697a 1834 }
d0d6a4cd 1835
1c4baffc 1836 r = sd_netlink_message_close_container(req);
6a7a4e4d
LP		 1837 if (r < 0)
1838 return log_link_error_errno(link, r, "Could not close IFLA_AF_SPEC container: %m");
d0d6a4cd 1839
ee38400b 1840 r = sd_netlink_call_async(link->manager->rtnl, NULL, req, link_up_handler,
8190a388 1841 link_netlink_destroy_callback, link, 0, __func__);
6a7a4e4d
LP		 1842 if (r < 0)
1843 return log_link_error_errno(link, r, "Could not send rtnetlink message: %m");
f579559b 1844
b226d99b
TG		 1845 link_ref(link);
1846
f882c247
TG		 1847 return 0;
1848}
1849
bd5038f8
MKB		 1850static int link_up_can(Link *link) {
1851 _cleanup_(sd_netlink_message_unrefp) sd_netlink_message *req = NULL;
1852 int r;
1853
1854 assert(link);
1855
1856 log_link_debug(link, "Bringing CAN link up");
1857
1858 r = sd_rtnl_message_new_link(link->manager->rtnl, &req, RTM_SETLINK, link->ifindex);
1859 if (r < 0)
1860 return log_link_error_errno(link, r, "Could not allocate RTM_SETLINK message: %m");
1861
1862 r = sd_rtnl_message_link_set_flags(req, IFF_UP, IFF_UP);
1863 if (r < 0)
1864 return log_link_error_errno(link, r, "Could not set link flags: %m");
1865
ee38400b 1866 r = sd_netlink_call_async(link->manager->rtnl, NULL, req, link_up_handler,
8190a388 1867 link_netlink_destroy_callback, link, 0, __func__);
bd5038f8
MKB		 1868 if (r < 0)
1869 return log_link_error_errno(link, r, "Could not send rtnetlink message: %m");
1870
1871 link_ref(link);
1872
1873 return 0;
1874}
1875
06828bb6
HP		 1876static int link_set_can(Link *link) {
1877 _cleanup_(sd_netlink_message_unrefp) sd_netlink_message *m = NULL;
1878 int r;
1879
1880 assert(link);
1881 assert(link->network);
1882 assert(link->manager);
1883 assert(link->manager->rtnl);
1884
1885 log_link_debug(link, "link_set_can");
1886
1887 r = sd_rtnl_message_new_link(link->manager->rtnl, &m, RTM_NEWLINK, link->ifindex);
1888 if (r < 0)
1889 return log_link_error_errno(link, r, "Failed to allocate netlink message: %m");
1890
1891 r = sd_netlink_message_set_flags(m, NLM_F_REQUEST | NLM_F_ACK);
1892 if (r < 0)
1893 return log_link_error_errno(link, r, "Could not set netlink flags: %m");
1894
1895 r = sd_netlink_message_open_container(m, IFLA_LINKINFO);
1896 if (r < 0)
1897 return log_link_error_errno(link, r, "Failed to open netlink container: %m");
1898
1899 r = sd_netlink_message_open_container_union(m, IFLA_INFO_DATA, link->kind);
1900 if (r < 0)
1901 return log_link_error_errno(link, r, "Could not append IFLA_INFO_DATA attribute: %m");
1902
1903 if (link->network->can_bitrate > 0 || link->network->can_sample_point > 0) {
1904 struct can_bittiming bt = {
1905 .bitrate = link->network->can_bitrate,
1906 .sample_point = link->network->can_sample_point,
1907 };
1908
1909 if (link->network->can_bitrate > UINT32_MAX) {
1910 log_link_error(link, "bitrate (%zu) too big.", link->network->can_bitrate);
1911 return -ERANGE;
1912 }
1913
1914 log_link_debug(link, "Setting bitrate = %d bit/s", bt.bitrate);
1915 if (link->network->can_sample_point > 0)
1916 log_link_debug(link, "Setting sample point = %d.%d%%", bt.sample_point / 10, bt.sample_point % 10);
1917 else
1918 log_link_debug(link, "Using default sample point");
1919
1920 r = sd_netlink_message_append_data(m, IFLA_CAN_BITTIMING, &bt, sizeof(bt));
1921 if (r < 0)
1922 return log_link_error_errno(link, r, "Could not append IFLA_CAN_BITTIMING attribute: %m");
1923 }
1924
1925 if (link->network->can_restart_us > 0) {
1926 char time_string[FORMAT_TIMESPAN_MAX];
1927 uint64_t restart_ms;
1928
1929 if (link->network->can_restart_us == USEC_INFINITY)
1930 restart_ms = 0;
1931 else
1932 restart_ms = DIV_ROUND_UP(link->network->can_restart_us, USEC_PER_MSEC);
1933
1934 format_timespan(time_string, FORMAT_TIMESPAN_MAX, restart_ms * 1000, MSEC_PER_SEC);
1935
1936 if (restart_ms > UINT32_MAX) {
1937 log_link_error(link, "restart timeout (%s) too big.", time_string);
1938 return -ERANGE;
1939 }
1940
1941 log_link_debug(link, "Setting restart = %s", time_string);
1942
1943 r = sd_netlink_message_append_u32(m, IFLA_CAN_RESTART_MS, restart_ms);
1944 if (r < 0)
1945 return log_link_error_errno(link, r, "Could not append IFLA_CAN_RESTART_MS attribute: %m");
1946 }
1947
1948 r = sd_netlink_message_close_container(m);
1949 if (r < 0)
1950 return log_link_error_errno(link, r, "Failed to close netlink container: %m");
1951
1952 r = sd_netlink_message_close_container(m);
1953 if (r < 0)
1954 return log_link_error_errno(link, r, "Failed to close netlink container: %m");
1955
ee38400b 1956 r = sd_netlink_call_async(link->manager->rtnl, NULL, m, link_set_handler,
8190a388 1957 link_netlink_destroy_callback, link, 0, __func__);
06828bb6
HP		 1958 if (r < 0)
1959 return log_link_error_errno(link, r, "Could not send rtnetlink message: %m");
1960
1961 link_ref(link);
1962
1963 if (!(link->flags & IFF_UP)) {
1964 r = link_up_can(link);
1965 if (r < 0) {
1966 link_enter_failed(link);
1967 return r;
1968 }
1969 }
1970
1971 log_link_debug(link, "link_set_can done");
1972
1973 return r;
1974}
1975
1c4baffc 1976static int link_down_handler(sd_netlink *rtnl, sd_netlink_message *m, void *userdata) {
1046bf9b 1977 Link *link = userdata;
0d4ad91d
AR		 1978 int r;
1979
1980 assert(link);
1981
1982 if (IN_SET(link->state, LINK_STATE_FAILED, LINK_STATE_LINGER))
1983 return 1;
1984
1c4baffc 1985 r = sd_netlink_message_get_errno(m);
0d4ad91d 1986 if (r < 0)
a2fae7bb 1987 log_link_warning_errno(link, r, "Could not bring down interface: %m");
0d4ad91d 1988
1046bf9b 1989 if (streq_ptr(link->kind, "can"))
06828bb6 1990 link_set_can(link);
06828bb6 1991
0d4ad91d
AR		 1992 return 1;
1993}
1994
14b6bb77 1995int link_down(Link *link) {
4afd3348 1996 _cleanup_(sd_netlink_message_unrefp) sd_netlink_message *req = NULL;
0d4ad91d
AR		 1997 int r;
1998
1999 assert(link);
2000 assert(link->manager);
2001 assert(link->manager->rtnl);
2002
6a7a4e4d 2003 log_link_debug(link, "Bringing link down");
0d4ad91d
AR		 2004
2005 r = sd_rtnl_message_new_link(link->manager->rtnl, &req,
2006 RTM_SETLINK, link->ifindex);
6a7a4e4d
LP		 2007 if (r < 0)
2008 return log_link_error_errno(link, r, "Could not allocate RTM_SETLINK message: %m");
0d4ad91d
AR		 2009
2010 r = sd_rtnl_message_link_set_flags(req, 0, IFF_UP);
6a7a4e4d
LP		 2011 if (r < 0)
2012 return log_link_error_errno(link, r, "Could not set link flags: %m");
0d4ad91d 2013
ee38400b 2014 r = sd_netlink_call_async(link->manager->rtnl, NULL, req, link_down_handler,
8190a388 2015 link_netlink_destroy_callback, link, 0, __func__);
6a7a4e4d
LP		 2016 if (r < 0)
2017 return log_link_error_errno(link, r, "Could not send rtnetlink message: %m");
0d4ad91d
AR		 2018
2019 link_ref(link);
2020
2021 return 0;
2022}
2023
2024static int link_handle_bound_to_list(Link *link) {
2025 Link *l;
2026 Iterator i;
2027 int r;
2028 bool required_up = false;
2029 bool link_is_up = false;
2030
2031 assert(link);
2032
2033 if (hashmap_isempty(link->bound_to_links))
2034 return 0;
2035
2036 if (link->flags & IFF_UP)
2037 link_is_up = true;
2038
2039 HASHMAP_FOREACH (l, link->bound_to_links, i)
2040 if (link_has_carrier(l)) {
2041 required_up = true;
2042 break;
2043 }
2044
2045 if (!required_up && link_is_up) {
2046 r = link_down(link);
2047 if (r < 0)
2048 return r;
2049 } else if (required_up && !link_is_up) {
2050 r = link_up(link);
2051 if (r < 0)
2052 return r;
2053 }
2054
2055 return 0;
2056}
2057
2058static int link_handle_bound_by_list(Link *link) {
2059 Iterator i;
2060 Link *l;
2061 int r;
2062
2063 assert(link);
2064
2065 if (hashmap_isempty(link->bound_by_links))
2066 return 0;
2067
2068 HASHMAP_FOREACH (l, link->bound_by_links, i) {
2069 r = link_handle_bound_to_list(l);
2070 if (r < 0)
2071 return r;
2072 }
2073
2074 return 0;
2075}
2076
2077static int link_put_carrier(Link *link, Link *carrier, Hashmap **h) {
2078 int r;
2079
2080 assert(link);
2081 assert(carrier);
2082
2083 if (link == carrier)
2084 return 0;
2085
2086 if (hashmap_get(*h, INT_TO_PTR(carrier->ifindex)))
2087 return 0;
2088
2089 r = hashmap_ensure_allocated(h, NULL);
2090 if (r < 0)
2091 return r;
2092
2093 r = hashmap_put(*h, INT_TO_PTR(carrier->ifindex), carrier);
2094 if (r < 0)
2095 return r;
2096
2097 return 0;
2098}
2099
2100static int link_new_bound_by_list(Link *link) {
2101 Manager *m;
2102 Link *carrier;
2103 Iterator i;
2104 int r;
2105 bool list_updated = false;
2106
2107 assert(link);
2108 assert(link->manager);
2109
2110 m = link->manager;
2111
b295beea 2112 HASHMAP_FOREACH(carrier, m->links, i) {
0d4ad91d
AR		 2113 if (!carrier->network)
2114 continue;
2115
2116 if (strv_isempty(carrier->network->bind_carrier))
2117 continue;
2118
2119 if (strv_fnmatch(carrier->network->bind_carrier, link->ifname, 0)) {
2120 r = link_put_carrier(link, carrier, &link->bound_by_links);
2121 if (r < 0)
2122 return r;
2123
2124 list_updated = true;
2125 }
2126 }
2127
2128 if (list_updated)
84de38c5 2129 link_dirty(link);
0d4ad91d 2130
b295beea 2131 HASHMAP_FOREACH(carrier, link->bound_by_links, i) {
0d4ad91d
AR		 2132 r = link_put_carrier(carrier, link, &carrier->bound_to_links);
2133 if (r < 0)
2134 return r;
2135
84de38c5 2136 link_dirty(carrier);
0d4ad91d
AR		 2137 }
2138
2139 return 0;
2140}
2141
2142static int link_new_bound_to_list(Link *link) {
2143 Manager *m;
2144 Link *carrier;
2145 Iterator i;
2146 int r;
2147 bool list_updated = false;
2148
2149 assert(link);
2150 assert(link->manager);
2151
2152 if (!link->network)
2153 return 0;
2154
2155 if (strv_isempty(link->network->bind_carrier))
2156 return 0;
2157
2158 m = link->manager;
2159
2160 HASHMAP_FOREACH (carrier, m->links, i) {
2161 if (strv_fnmatch(link->network->bind_carrier, carrier->ifname, 0)) {
2162 r = link_put_carrier(link, carrier, &link->bound_to_links);
2163 if (r < 0)
2164 return r;
2165
2166 list_updated = true;
2167 }
2168 }
2169
2170 if (list_updated)
84de38c5 2171 link_dirty(link);
0d4ad91d
AR		 2172
2173 HASHMAP_FOREACH (carrier, link->bound_to_links, i) {
2174 r = link_put_carrier(carrier, link, &carrier->bound_by_links);
2175 if (r < 0)
2176 return r;
2177
84de38c5 2178 link_dirty(carrier);
0d4ad91d
AR		 2179 }
2180
2181 return 0;
2182}
2183
2184static int link_new_carrier_maps(Link *link) {
2185 int r;
2186
2187 r = link_new_bound_by_list(link);
2188 if (r < 0)
2189 return r;
2190
2191 r = link_handle_bound_by_list(link);
2192 if (r < 0)
2193 return r;
2194
2195 r = link_new_bound_to_list(link);
2196 if (r < 0)
2197 return r;
2198
2199 r = link_handle_bound_to_list(link);
2200 if (r < 0)
2201 return r;
2202
2203 return 0;
2204}
2205
2206static void link_free_bound_to_list(Link *link) {
2207 Link *bound_to;
2208 Iterator i;
2209
2210 HASHMAP_FOREACH (bound_to, link->bound_to_links, i) {
2211 hashmap_remove(link->bound_to_links, INT_TO_PTR(bound_to->ifindex));
2212
2213 if (hashmap_remove(bound_to->bound_by_links, INT_TO_PTR(link->ifindex)))
84de38c5 2214 link_dirty(bound_to);
0d4ad91d
AR		 2215 }
2216
2217 return;
2218}
2219
2220static void link_free_bound_by_list(Link *link) {
2221 Link *bound_by;
2222 Iterator i;
2223
2224 HASHMAP_FOREACH (bound_by, link->bound_by_links, i) {
2225 hashmap_remove(link->bound_by_links, INT_TO_PTR(bound_by->ifindex));
2226
2227 if (hashmap_remove(bound_by->bound_to_links, INT_TO_PTR(link->ifindex))) {
84de38c5 2228 link_dirty(bound_by);
0d4ad91d
AR		 2229 link_handle_bound_to_list(bound_by);
2230 }
2231 }
2232
2233 return;
2234}
2235
2236static void link_free_carrier_maps(Link *link) {
2237 bool list_updated = false;
2238
2239 assert(link);
2240
2241 if (!hashmap_isempty(link->bound_to_links)) {
2242 link_free_bound_to_list(link);
2243 list_updated = true;
2244 }
2245
2246 if (!hashmap_isempty(link->bound_by_links)) {
2247 link_free_bound_by_list(link);
2248 list_updated = true;
2249 }
2250
2251 if (list_updated)
84de38c5 2252 link_dirty(link);
0d4ad91d
AR		 2253
2254 return;
2255}
2256
2257void link_drop(Link *link) {
2258 if (!link || link->state == LINK_STATE_LINGER)
2259 return;
2260
2261 link_set_state(link, LINK_STATE_LINGER);
2262
2263 link_free_carrier_maps(link);
2264
6a7a4e4d 2265 log_link_debug(link, "Link removed");
0d4ad91d 2266
db2f8a2e 2267 (void) unlink(link->state_file);
0d4ad91d
AR		 2268 link_unref(link);
2269
2270 return;
2271}
2272
3f265037 2273static int link_joined(Link *link) {
f882c247
TG		 2274 int r;
2275
ef1ba606 2276 assert(link);
f5be5601 2277 assert(link->network);
dd3efc09 2278
0d4ad91d
AR		 2279 if (!hashmap_isempty(link->bound_to_links)) {
2280 r = link_handle_bound_to_list(link);
2281 if (r < 0)
2282 return r;
2283 } else if (!(link->flags & IFF_UP)) {
505f8da7
TG		 2284 r = link_up(link);
2285 if (r < 0) {
2286 link_enter_failed(link);
2287 return r;
2288 }
ef1ba606 2289 }
f882c247 2290
9ed794a3 2291 if (link->network->bridge) {
e1853b00 2292 r = link_set_bridge(link);
6a7a4e4d
LP		 2293 if (r < 0)
2294 log_link_error_errno(link, r, "Could not set bridge message: %m");
e1853b00
SS		 2295 }
2296
eb64b435
SS		 2297 if (link->network->bond) {
2298 r = link_bond_set(link);
2299 if (r < 0)
2300 log_link_error_errno(link, r, "Could not set bond message: %m");
2301 }
2302
ffff9abe
TJ		 2303 if (link->network->use_br_vlan &&
2304 (link->network->bridge || streq_ptr("bridge", link->kind))) {
13b498f9
TJ		 2305 r = link_set_bridge_vlan(link);
2306 if (r < 0)
2307 log_link_error_errno(link, r, "Could not set bridge vlan: %m");
2308 }
2309
c1835a42
RM		 2310 /* Skip setting up addresses until it gets carrier,
2311 or it would try to set addresses twice,
2312 which is bad for non-idempotent steps. */
dad2d78e 2313 if (!link_has_carrier(link) && !link->network->configure_without_carrier)
c1835a42
RM		 2314 return 0;
2315
fb6730c4 2316 return link_enter_set_addresses(link);
02b59d57
TG		 2317}
2318
62e2d5bb 2319static int netdev_join_handler(sd_netlink *rtnl, sd_netlink_message *m, void *userdata) {
1046bf9b 2320 Link *link = userdata;
02b59d57
TG		 2321 int r;
2322
1746cf2a 2323 assert(link);
ef1ba606 2324 assert(link->network);
02b59d57 2325
313cefa1 2326 link->enslaving--;
52433f6b 2327
5da8149f 2328 if (IN_SET(link->state, LINK_STATE_FAILED, LINK_STATE_LINGER))
02b59d57
TG		 2329 return 1;
2330
1c4baffc 2331 r = sd_netlink_message_get_errno(m);
856f962c 2332 if (r < 0 && r != -EEXIST) {
a2fae7bb 2333 log_link_error_errno(link, r, "Could not join netdev: %m");
ef1ba606
TG		 2334 link_enter_failed(link);
2335 return 1;
ba179154 2336 } else
6a7a4e4d 2337 log_link_debug(link, "Joined netdev");
02b59d57 2338
856f962c 2339 if (link->enslaving <= 0)
3f265037 2340 link_joined(link);
02b59d57
TG		 2341
2342 return 1;
2343}
2344
3f265037 2345static int link_enter_join_netdev(Link *link) {
6a0a2f86 2346 NetDev *netdev;
672682a6 2347 Iterator i;
02b59d57
TG		 2348 int r;
2349
2350 assert(link);
2351 assert(link->network);
8434fd5c 2352 assert(link->state == LINK_STATE_PENDING);
02b59d57 2353
e331e246 2354 link_set_state(link, LINK_STATE_ENSLAVING);
02b59d57 2355
84de38c5 2356 link_dirty(link);
fe8db0c5 2357
7951dea2
SS		 2358 if (!link->network->bridge &&
2359 !link->network->bond &&
6cb955c6 2360 !link->network->vrf &&
6a0a2f86 2361 hashmap_isempty(link->network->stacked_netdevs))
3f265037 2362 return link_joined(link);
02b59d57 2363
d9c67ea1 2364 if (link->network->bond) {
cbff7170
TJ		 2365 if (link->network->bond->state == NETDEV_STATE_READY &&
2366 link->network->bond->ifindex == link->master_ifindex)
2367 return link_joined(link);
2368
f2341e0a
LP		 2369 log_struct(LOG_DEBUG,
2370 LOG_LINK_INTERFACE(link),
2371 LOG_NETDEV_INTERFACE(link->network->bond),
a1230ff9 2372 LOG_LINK_MESSAGE(link, "Enslaving by '%s'", link->network->bond->ifname));
f2341e0a
LP		 2373
2374 r = netdev_join(link->network->bond, link, netdev_join_handler);
52433f6b 2375 if (r < 0) {
f2341e0a
LP		 2376 log_struct_errno(LOG_WARNING, r,
2377 LOG_LINK_INTERFACE(link),
2378 LOG_NETDEV_INTERFACE(link->network->bond),
a1230ff9 2379 LOG_LINK_MESSAGE(link, "Could not join netdev '%s': %m", link->network->bond->ifname));
52433f6b
TG		 2380 link_enter_failed(link);
2381 return r;
2382 }
2383
313cefa1 2384 link->enslaving++;
0ad6148e
MO		 2385 }
2386
d9c67ea1 2387 if (link->network->bridge) {
f2341e0a
LP		 2388 log_struct(LOG_DEBUG,
2389 LOG_LINK_INTERFACE(link),
2390 LOG_NETDEV_INTERFACE(link->network->bridge),
a1230ff9 2391 LOG_LINK_MESSAGE(link, "Enslaving by '%s'", link->network->bridge->ifname));
f2341e0a
LP		 2392
2393 r = netdev_join(link->network->bridge, link, netdev_join_handler);
0ad6148e 2394 if (r < 0) {
f2341e0a
LP		 2395 log_struct_errno(LOG_WARNING, r,
2396 LOG_LINK_INTERFACE(link),
2397 LOG_NETDEV_INTERFACE(link->network->bridge),
a1230ff9 2398 LOG_LINK_MESSAGE(link, "Could not join netdev '%s': %m", link->network->bridge->ifname));
0ad6148e
MO		 2399 link_enter_failed(link);
2400 return r;
2401 }
2402
313cefa1 2403 link->enslaving++;
52433f6b
TG		 2404 }
2405
6cb955c6
AR		 2406 if (link->network->vrf) {
2407 log_struct(LOG_DEBUG,
2408 LOG_LINK_INTERFACE(link),
2409 LOG_NETDEV_INTERFACE(link->network->vrf),
a1230ff9
ZJS		 2410 LOG_LINK_MESSAGE(link, "Enslaving by '%s'", link->network->vrf->ifname));
2411
6cb955c6
AR		 2412 r = netdev_join(link->network->vrf, link, netdev_join_handler);
2413 if (r < 0) {
2414 log_struct_errno(LOG_WARNING, r,
2415 LOG_LINK_INTERFACE(link),
2416 LOG_NETDEV_INTERFACE(link->network->vrf),
a1230ff9 2417 LOG_LINK_MESSAGE(link, "Could not join netdev '%s': %m", link->network->vrf->ifname));
6cb955c6
AR		 2418 link_enter_failed(link);
2419 return r;
2420 }
2421
2422 link->enslaving++;
2423 }
2424
6a0a2f86 2425 HASHMAP_FOREACH(netdev, link->network->stacked_netdevs, i) {
7951dea2 2426
a63e5daa
SS		 2427 if (netdev->ifindex > 0) {
2428 link_joined(link);
2429 continue;
2430 }
2431
f2341e0a
LP		 2432 log_struct(LOG_DEBUG,
2433 LOG_LINK_INTERFACE(link),
2434 LOG_NETDEV_INTERFACE(netdev),
a1230ff9 2435 LOG_LINK_MESSAGE(link, "Enslaving by '%s'", netdev->ifname));
f2341e0a
LP		 2436
2437 r = netdev_join(netdev, link, netdev_join_handler);
7951dea2 2438 if (r < 0) {
f2341e0a
LP		 2439 log_struct_errno(LOG_WARNING, r,
2440 LOG_LINK_INTERFACE(link),
2441 LOG_NETDEV_INTERFACE(netdev),
a1230ff9 2442 LOG_LINK_MESSAGE(link, "Could not join netdev '%s': %m", netdev->ifname));
326cb406
SS		 2443 link_enter_failed(link);
2444 return r;
2445 }
2446
313cefa1 2447 link->enslaving++;
326cb406
SS		 2448 }
2449
ef1ba606
TG		 2450 return 0;
2451}
2452
769d324c 2453static int link_set_ipv4_forward(Link *link) {
5a8bcb67
LP		 2454 int r;
2455
765afd5c 2456 if (!link_ipv4_forward_enabled(link))
15dee3f0
LP		 2457 return 0;
2458
765afd5c
LP		 2459 /* We propagate the forwarding flag from one interface to the
2460 * global setting one way. This means: as long as at least one
2461 * interface was configured at any time that had IP forwarding
2462 * enabled the setting will stay on for good. We do this
2463 * primarily to keep IPv4 and IPv6 packet forwarding behaviour
2464 * somewhat in sync (see below). */
15dee3f0 2465
765afd5c 2466 r = write_string_file("/proc/sys/net/ipv4/ip_forward", "1", WRITE_STRING_FILE_VERIFY_ON_FAILURE);
eb3da901 2467 if (r < 0)
765afd5c 2468 log_link_warning_errno(link, r, "Cannot turn on IPv4 packet forwarding, ignoring: %m");
43c6d5ab 2469
769d324c
LP		 2470 return 0;
2471}
2472
2473static int link_set_ipv6_forward(Link *link) {
769d324c
LP		 2474 int r;
2475
765afd5c 2476 if (!link_ipv6_forward_enabled(link))
8add5f79
NO		 2477 return 0;
2478
61233823 2479 /* On Linux, the IPv6 stack does not know a per-interface
765afd5c
LP		 2480 * packet forwarding setting: either packet forwarding is on
2481 * for all, or off for all. We hence don't bother with a
2482 * per-interface setting, but simply propagate the interface
2483 * flag, if it is set, to the global flag, one-way. Note that
2484 * while IPv4 would allow a per-interface flag, we expose the
2485 * same behaviour there and also propagate the setting from
2486 * one to all, to keep things simple (see above). */
15dee3f0 2487
765afd5c 2488 r = write_string_file("/proc/sys/net/ipv6/conf/all/forwarding", "1", WRITE_STRING_FILE_VERIFY_ON_FAILURE);
eb3da901 2489 if (r < 0)
765afd5c 2490 log_link_warning_errno(link, r, "Cannot configure IPv6 packet forwarding, ignoring: %m");
5a8bcb67
LP		 2491
2492 return 0;
2493}
2494
49092e22 2495static int link_set_ipv6_privacy_extensions(Link *link) {
1f0d9695
LP		 2496 char buf[DECIMAL_STR_MAX(unsigned) + 1];
2497 IPv6PrivacyExtensions s;
49092e22
SS		 2498 const char *p = NULL;
2499 int r;
2500
1f0d9695 2501 s = link_ipv6_privacy_extensions(link);
66a6bd68 2502 if (s < 0)
49092e22
SS		 2503 return 0;
2504
2505 p = strjoina("/proc/sys/net/ipv6/conf/", link->ifname, "/use_tempaddr");
66a6bd68 2506 xsprintf(buf, "%u", (unsigned) link->network->ipv6_privacy_extensions);
49092e22 2507
eb3da901
LP		 2508 r = write_string_file(p, buf, WRITE_STRING_FILE_VERIFY_ON_FAILURE);
2509 if (r < 0)
49092e22
SS		 2510 log_link_warning_errno(link, r, "Cannot configure IPv6 privacy extension for interface: %m");
2511
2512 return 0;
2513}
2514
4f2e437a 2515static int link_set_ipv6_accept_ra(Link *link) {
3b015d40 2516 const char *p = NULL;
4f2e437a
SS		 2517 int r;
2518
2519 /* Make this a NOP if IPv6 is not available */
2520 if (!socket_ipv6_is_supported())
2521 return 0;
2522
2523 if (link->flags & IFF_LOOPBACK)
2524 return 0;
2525
d68e2e59
LP		 2526 if (!link->network)
2527 return 0;
2528
4f2e437a 2529 p = strjoina("/proc/sys/net/ipv6/conf/", link->ifname, "/accept_ra");
4f2e437a 2530
0053598f 2531 /* We handle router advertisements ourselves, tell the kernel to GTFO */
fe307276 2532 r = write_string_file(p, "0", WRITE_STRING_FILE_VERIFY_ON_FAILURE);
eb3da901 2533 if (r < 0)
fe307276 2534 log_link_warning_errno(link, r, "Cannot disable kernel IPv6 accept_ra for interface: %m");
4f2e437a
SS		 2535
2536 return 0;
2537}
2538
8749cbcd 2539static int link_set_ipv6_dad_transmits(Link *link) {
66a6bd68 2540 char buf[DECIMAL_STR_MAX(int) + 1];
8749cbcd
SS		 2541 const char *p = NULL;
2542 int r;
2543
2544 /* Make this a NOP if IPv6 is not available */
2545 if (!socket_ipv6_is_supported())
2546 return 0;
2547
2548 if (link->flags & IFF_LOOPBACK)
2549 return 0;
2550
d68e2e59
LP		 2551 if (!link->network)
2552 return 0;
2553
8749cbcd
SS		 2554 if (link->network->ipv6_dad_transmits < 0)
2555 return 0;
2556
2557 p = strjoina("/proc/sys/net/ipv6/conf/", link->ifname, "/dad_transmits");
66a6bd68 2558 xsprintf(buf, "%i", link->network->ipv6_dad_transmits);
8749cbcd 2559
eb3da901
LP		 2560 r = write_string_file(p, buf, WRITE_STRING_FILE_VERIFY_ON_FAILURE);
2561 if (r < 0)
8749cbcd 2562 log_link_warning_errno(link, r, "Cannot set IPv6 dad transmits for interface: %m");
8749cbcd
SS		 2563
2564 return 0;
2565}
2566
b69c3180 2567static int link_set_ipv6_hop_limit(Link *link) {
66a6bd68 2568 char buf[DECIMAL_STR_MAX(int) + 1];
b69c3180
SS		 2569 const char *p = NULL;
2570 int r;
2571
2572 /* Make this a NOP if IPv6 is not available */
2573 if (!socket_ipv6_is_supported())
2574 return 0;
2575
2576 if (link->flags & IFF_LOOPBACK)
2577 return 0;
2578
d68e2e59
LP		 2579 if (!link->network)
2580 return 0;
2581
b69c3180
SS		 2582 if (link->network->ipv6_hop_limit < 0)
2583 return 0;
2584
2585 p = strjoina("/proc/sys/net/ipv6/conf/", link->ifname, "/hop_limit");
66a6bd68 2586 xsprintf(buf, "%i", link->network->ipv6_hop_limit);
b69c3180 2587
eb3da901
LP		 2588 r = write_string_file(p, buf, WRITE_STRING_FILE_VERIFY_ON_FAILURE);
2589 if (r < 0)
b69c3180 2590 log_link_warning_errno(link, r, "Cannot set IPv6 hop limit for interface: %m");
b69c3180
SS		 2591
2592 return 0;
2593}
2594
11102cba
SS		 2595static int link_set_ipv6_mtu(Link *link) {
2596 char buf[DECIMAL_STR_MAX(unsigned) + 1];
2597 const char *p = NULL;
2598 int r;
2599
2600 /* Make this a NOP if IPv6 is not available */
2601 if (!socket_ipv6_is_supported())
2602 return 0;
2603
2604 if (link->flags & IFF_LOOPBACK)
2605 return 0;
2606
2607 if (link->network->ipv6_mtu == 0)
2608 return 0;
2609
2610 p = strjoina("/proc/sys/net/ipv6/conf/", link->ifname, "/mtu");
2611
4e964aa0 2612 xsprintf(buf, "%" PRIu32, link->network->ipv6_mtu);
11102cba
SS		 2613
2614 r = write_string_file(p, buf, 0);
2615 if (r < 0)
2616 log_link_warning_errno(link, r, "Cannot set IPv6 MTU for interface: %m");
2617
2618 return 0;
2619}
2620
30226d27
TJ		 2621static bool link_is_static_address_configured(Link *link, Address *address) {
2622 Address *net_address;
2623
2624 assert(link);
2625 assert(address);
2626
2627 if (!link->network)
2628 return false;
2629
2630 LIST_FOREACH(addresses, net_address, link->network->static_addresses)
2631 if (address_equal(net_address, address))
2632 return true;
2633
2634 return false;
2635}
2636
7ecf0c3e
TJ		 2637static bool link_is_static_route_configured(Link *link, Route *route) {
2638 Route *net_route;
2639
2640 assert(link);
2641 assert(route);
2642
2643 if (!link->network)
2644 return false;
2645
2646 LIST_FOREACH(routes, net_route, link->network->static_routes)
2647 if (route_equal(net_route, route))
2648 return true;
2649
2650 return false;
2651}
2652
5e5b137a
TG		 2653static int link_drop_foreign_config(Link *link) {
2654 Address *address;
2655 Route *route;
2656 Iterator i;
2657 int r;
2658
2659 SET_FOREACH(address, link->addresses_foreign, i) {
fe307276 2660 /* we consider IPv6LL addresses to be managed by the kernel */
5e5b137a
TG		 2661 if (address->family == AF_INET6 && in_addr_is_link_local(AF_INET6, &address->in_addr) == 1)
2662 continue;
2663
30226d27
TJ		 2664 if (link_is_static_address_configured(link, address)) {
2665 r = address_add(link, address->family, &address->in_addr, address->prefixlen, NULL);
2666 if (r < 0)
2667 return log_link_error_errno(link, r, "Failed to add address: %m");
2668 } else {
2669 r = address_remove(address, link, link_address_remove_handler);
2670 if (r < 0)
2671 return r;
2672 }
5e5b137a
TG		 2673 }
2674
2675 SET_FOREACH(route, link->routes_foreign, i) {
fe307276 2676 /* do not touch routes managed by the kernel */
5e5b137a
TG		 2677 if (route->protocol == RTPROT_KERNEL)
2678 continue;
2679
7ecf0c3e
TJ		 2680 if (link_is_static_route_configured(link, route)) {
2681 r = route_add(link, route->family, &route->dst, route->dst_prefixlen, route->tos, route->priority, route->table, NULL);
2682 if (r < 0)
2683 return r;
2684 } else {
2685 r = route_remove(route, link, link_route_remove_handler);
2686 if (r < 0)
2687 return r;
2688 }
5e5b137a
TG		 2689 }
2690
2691 return 0;
2692}
2693
3104883d 2694static int link_drop_config(Link *link) {
410a7f15 2695 Address *address, *pool_address;
3104883d
SS		 2696 Route *route;
2697 Iterator i;
2698 int r;
2699
2700 SET_FOREACH(address, link->addresses, i) {
2701 /* we consider IPv6LL addresses to be managed by the kernel */
2702 if (address->family == AF_INET6 && in_addr_is_link_local(AF_INET6, &address->in_addr) == 1)
2703 continue;
2704
2705 r = address_remove(address, link, link_address_remove_handler);
2706 if (r < 0)
2707 return r;
410a7f15
RM		 2708
2709 /* If this address came from an address pool, clean up the pool */
2710 LIST_FOREACH(addresses, pool_address, link->pool_addresses) {
2711 if (address_equal(address, pool_address)) {
2712 LIST_REMOVE(addresses, link->pool_addresses, pool_address);
2713 address_free(pool_address);
2714 break;
2715 }
2716 }
3104883d
SS		 2717 }
2718
2719 SET_FOREACH(route, link->routes, i) {
2720 /* do not touch routes managed by the kernel */
2721 if (route->protocol == RTPROT_KERNEL)
2722 continue;
2723
2724 r = route_remove(route, link, link_route_remove_handler);
2725 if (r < 0)
2726 return r;
2727 }
2728
c69305ff
LP		 2729 ndisc_flush(link);
2730
3104883d
SS		 2731 return 0;
2732}
2733
273eec24
LP		 2734static int link_update_lldp(Link *link) {
2735 int r;
2736
2737 assert(link);
2738
2739 if (!link->lldp)
2740 return 0;
2741
2742 if (link->flags & IFF_UP) {
2743 r = sd_lldp_start(link->lldp);
2744 if (r > 0)
2745 log_link_debug(link, "Started LLDP.");
2746 } else {
2747 r = sd_lldp_stop(link->lldp);
2748 if (r > 0)
2749 log_link_debug(link, "Stopped LLDP.");
2750 }
2751
2752 return r;
2753}
2754
93ea7750
MKB		 2755static int link_configure_can(Link *link) {
2756 int r;
2757
06828bb6
HP		 2758 if (streq_ptr(link->kind, "can")) {
2759 /* The CAN interface must be down to configure bitrate, etc... */
2760 if ((link->flags & IFF_UP)) {
2761 r = link_down(link);
2762 if (r < 0) {
2763 link_enter_failed(link);
2764 return r;
2765 }
2766
2767 return 0;
2768 }
2769
2770 return link_set_can(link);
2771 }
2772
93ea7750
MKB		 2773 if (!(link->flags & IFF_UP)) {
2774 r = link_up_can(link);
2775 if (r < 0) {
2776 link_enter_failed(link);
2777 return r;
2778 }
2779 }
2780
2781 return 0;
2782}
2783
a748b692 2784static int link_configure(Link *link) {
02b59d57
TG		 2785 int r;
2786
ef1ba606 2787 assert(link);
b22d8a00 2788 assert(link->network);
8434fd5c 2789 assert(link->state == LINK_STATE_PENDING);
a748b692 2790
06828bb6 2791 if (STRPTR_IN_SET(link->kind, "can", "vcan"))
93ea7750 2792 return link_configure_can(link);
92c918b0 2793
02e28621
ДГ		 2794 /* Drop foreign config, but ignore loopback or critical devices.
2795 * We do not want to remove loopback address or addresses used for root NFS. */
2796 if (!(link->flags & IFF_LOOPBACK) && !(link->network->dhcp_critical)) {
e5d44b34
CH		 2797 r = link_drop_foreign_config(link);
2798 if (r < 0)
2799 return r;
2800 }
5e5b137a 2801
23d8b221
SS		 2802 r = link_set_proxy_arp(link);
2803 if (r < 0)
2804 return r;
2805
a0e5c15d
FK		 2806 r = ipv6_proxy_ndp_addresses_configure(link);
2807 if (r < 0)
2808 return r;
2809
769d324c
LP		 2810 r = link_set_ipv4_forward(link);
2811 if (r < 0)
2812 return r;
2813
2814 r = link_set_ipv6_forward(link);
5a8bcb67
LP		 2815 if (r < 0)
2816 return r;
2817
49092e22
SS		 2818 r = link_set_ipv6_privacy_extensions(link);
2819 if (r < 0)
2820 return r;
2821
4f2e437a
SS		 2822 r = link_set_ipv6_accept_ra(link);
2823 if (r < 0)
2824 return r;
2825
8749cbcd
SS		 2826 r = link_set_ipv6_dad_transmits(link);
2827 if (r < 0)
2828 return r;
b69c3180
SS		 2829
2830 r = link_set_ipv6_hop_limit(link);
2831 if (r < 0)
2832 return r;
8749cbcd 2833
99d2baa2
SS		 2834 r = link_set_flags(link);
2835 if (r < 0)
2836 return r;
2837
11102cba
SS		 2838 r = link_set_ipv6_mtu(link);
2839 if (r < 0)
2840 return r;
2841
78c958f8 2842 if (link_ipv4ll_enabled(link)) {
b22d8a00 2843 r = ipv4ll_configure(link);
eb34d4af
TG		 2844 if (r < 0)
2845 return r;
2846 }
2847
78c958f8 2848 if (link_dhcp4_enabled(link)) {
64b21ece
MV		 2849 r = dhcp4_set_promote_secondaries(link);
2850 if (r < 0)
2851 return r;
2852
3c9b8860 2853 r = dhcp4_configure(link);
eb34d4af
TG		 2854 if (r < 0)
2855 return r;
eb34d4af
TG		 2856 }
2857
78c958f8 2858 if (link_dhcp4_server_enabled(link)) {
dd43110f
TG		 2859 r = sd_dhcp_server_new(&link->dhcp_server, link->ifindex);
2860 if (r < 0)
2861 return r;
2862
2863 r = sd_dhcp_server_attach_event(link->dhcp_server, NULL, 0);
2864 if (r < 0)
2865 return r;
dd43110f
TG		 2866 }
2867
62379e88
TG		 2868 if (link_dhcp6_enabled(link) ||
2869 link_ipv6_accept_ra_enabled(link)) {
f5a8c43f
TG		 2870 r = dhcp6_configure(link);
2871 if (r < 0)
2872 return r;
2873 }
2874
2875 if (link_ipv6_accept_ra_enabled(link)) {
de1e9928 2876 r = ndisc_configure(link);
4138fb2c
PF		 2877 if (r < 0)
2878 return r;
2879 }
2880
7465dd22
PF		 2881 if (link_radv_enabled(link)) {
2882 r = radv_configure(link);
2883 if (r < 0)
2884 return r;
2885 }
2886
8e1ad1ea 2887 if (link_lldp_rx_enabled(link)) {
fc6a313b
LP		 2888 r = sd_lldp_new(&link->lldp);
2889 if (r < 0)
2890 return r;
2891
2892 r = sd_lldp_set_ifindex(link->lldp, link->ifindex);
34437b4f
LP		 2893 if (r < 0)
2894 return r;
2895
2896 r = sd_lldp_match_capabilities(link->lldp,
2897 link->network->lldp_mode == LLDP_MODE_ROUTERS_ONLY ?
6afa6767
BG		 2898 SD_LLDP_SYSTEM_CAPABILITIES_ALL_ROUTERS :
2899 SD_LLDP_SYSTEM_CAPABILITIES_ALL);
ce43e484
SS		 2900 if (r < 0)
2901 return r;
2902
b553a6b1
LP		 2903 r = sd_lldp_set_filter_address(link->lldp, &link->mac);
2904 if (r < 0)
2905 return r;
2906
ce43e484
SS		 2907 r = sd_lldp_attach_event(link->lldp, NULL, 0);
2908 if (r < 0)
2909 return r;
49699bac 2910
032b27f5 2911 r = sd_lldp_set_callback(link->lldp, lldp_handler, link);
49699bac
SS		 2912 if (r < 0)
2913 return r;
273eec24
LP		 2914
2915 r = link_update_lldp(link);
2916 if (r < 0)
2917 return r;
ce43e484
SS		 2918 }
2919
44b598a1
SS		 2920 if (link->network->mtu > 0) {
2921 r = link_set_mtu(link, link->network->mtu);
2922 if (r < 0)
2923 return r;
2924 }
2925
55dc8c4a
YW		 2926 return link_configure_after_setting_mtu(link);
2927}
2928
2929static int link_configure_after_setting_mtu(Link *link) {
2930 int r;
2931
2932 assert(link);
2933 assert(link->network);
2934 assert(link->state == LINK_STATE_PENDING);
2935
2936 if (link->setting_mtu)
2937 return 0;
2938
dad2d78e 2939 if (link_has_carrier(link) || link->network->configure_without_carrier) {
1e9be60b
TG		 2940 r = link_acquire_conf(link);
2941 if (r < 0)
2942 return r;
cc544d5f 2943 }
1e9be60b 2944
3f265037 2945 return link_enter_join_netdev(link);
505f8da7
TG		 2946}
2947
27dfc982
YW		 2948static int duid_set_uuid(DUID *duid, sd_id128_t uuid) {
2949 assert(duid);
2950
2951 if (duid->raw_data_len > 0)
2952 return 0;
2953
2954 if (duid->type != DUID_TYPE_UUID)
2955 return -EINVAL;
2956
2957 memcpy(&duid->raw_data, &uuid, sizeof(sd_id128_t));
2958 duid->raw_data_len = sizeof(sd_id128_t);
2959
2960 return 1;
2961}
2962
2963int get_product_uuid_handler(sd_bus_message *m, void *userdata, sd_bus_error *ret_error) {
2964 Manager *manager = userdata;
2965 const sd_bus_error *e;
2966 const void *a;
2967 size_t sz;
2968 DUID *duid;
2969 Link *link;
2970 int r;
2971
2972 assert(m);
2973 assert(manager);
2974
2975 e = sd_bus_message_get_error(m);
2976 if (e) {
2977 log_error_errno(sd_bus_error_get_errno(e),
ab4dd984 2978 "Could not get product UUID. Falling back to use machine-app-specific ID as DUID-UUID: %s",
27dfc982
YW		 2979 e->message);
2980 goto configure;
2981 }
2982
2983 r = sd_bus_message_read_array(m, 'y', &a, &sz);
2984 if (r < 0)
2985 goto configure;
2986
2987 if (sz != sizeof(sd_id128_t)) {
ab4dd984 2988 log_error("Invalid product UUID. Falling back to use machine-app-specific ID as DUID-UUID.");
27dfc982
YW		 2989 goto configure;
2990 }
2991
2992 memcpy(&manager->product_uuid, a, sz);
2993 while ((duid = set_steal_first(manager->duids_requesting_uuid)))
2994 (void) duid_set_uuid(duid, manager->product_uuid);
2995
2996 manager->duids_requesting_uuid = set_free(manager->duids_requesting_uuid);
2997
2998configure:
2999 while ((link = set_steal_first(manager->links_requesting_uuid))) {
3000 r = link_configure(link);
3001 if (r < 0)
3002 log_link_error_errno(link, r, "Failed to configure link: %m");
3003 }
3004
3005 manager->links_requesting_uuid = set_free(manager->links_requesting_uuid);
3006
3007 /* To avoid calling GetProductUUID() bus method so frequently, set the flag below
3008 * even if the method fails. */
3009 manager->has_product_uuid = true;
3010
3011 return 1;
3012}
3013
3014static bool link_requires_uuid(Link *link) {
3015 const DUID *duid;
3016
3017 assert(link);
3018 assert(link->manager);
3019 assert(link->network);
3020
3021 duid = link_get_duid(link);
3022 if (duid->type != DUID_TYPE_UUID || duid->raw_data_len != 0)
3023 return false;
3024
3025 if (link_dhcp4_enabled(link) && IN_SET(link->network->dhcp_client_identifier, DHCP_CLIENT_ID_DUID, DHCP_CLIENT_ID_DUID_ONLY))
3026 return true;
3027
3028 if (link_dhcp6_enabled(link) || link_ipv6_accept_ra_enabled(link))
3029 return true;
3030
3031 return false;
3032}
3033
3034static int link_configure_duid(Link *link) {
3035 Manager *m;
3036 DUID *duid;
3037 int r;
3038
3039 assert(link);
3040 assert(link->manager);
3041 assert(link->network);
3042
3043 m = link->manager;
3044 duid = link_get_duid(link);
3045
3046 if (!link_requires_uuid(link))
3047 return 1;
3048
3049 if (m->has_product_uuid) {
3050 (void) duid_set_uuid(duid, m->product_uuid);
3051 return 1;
3052 }
3053
3054 if (!m->links_requesting_uuid) {
3055 r = manager_request_product_uuid(m, link);
3056 if (r < 0) {
3057 if (r == -ENOMEM)
3058 return r;
3059
ab4dd984
ZJS		 3060 log_link_warning_errno(link, r,
3061 "Failed to get product UUID. Falling back to use machine-app-specific ID as DUID-UUID: %m");
27dfc982
YW		 3062 return 1;
3063 }
3064 } else {
3065 r = set_put(m->links_requesting_uuid, link);
3066 if (r < 0)
3067 return log_oom();
3068
3069 r = set_put(m->duids_requesting_uuid, duid);
3070 if (r < 0)
3071 return log_oom();
3072 }
3073
3074 return 0;
3075}
3076
e6bf7774 3077static int link_initialized_and_synced(Link *link) {
505f8da7 3078 Network *network;
505f8da7
TG		 3079 int r;
3080
3081 assert(link);
3082 assert(link->ifname);
3083 assert(link->manager);
3084
8434fd5c 3085 if (link->state != LINK_STATE_PENDING)
5da8149f 3086 return 1;
505f8da7 3087
6a7a4e4d 3088 log_link_debug(link, "Link state is up-to-date");
505f8da7 3089
0d4ad91d
AR		 3090 r = link_new_bound_by_list(link);
3091 if (r < 0)
3092 return r;
3093
3094 r = link_handle_bound_by_list(link);
3095 if (r < 0)
3096 return r;
3097
c4a03a56 3098 if (!link->network) {
51517f9e 3099 r = network_get(link->manager, link->sd_device, link->ifname,
c4a03a56
TG		 3100 &link->mac, &network);
3101 if (r == -ENOENT) {
3102 link_enter_unmanaged(link);
3103 return 1;
a09dc546
DM		 3104 } else if (r == 0 && network->unmanaged) {
3105 link_enter_unmanaged(link);
3106 return 0;
c4a03a56
TG		 3107 } else if (r < 0)
3108 return r;
505f8da7 3109
c4a03a56
TG		 3110 if (link->flags & IFF_LOOPBACK) {
3111 if (network->link_local != ADDRESS_FAMILY_NO)
3112 log_link_debug(link, "Ignoring link-local autoconfiguration for loopback link");
78c958f8 3113
c4a03a56
TG		 3114 if (network->dhcp != ADDRESS_FAMILY_NO)
3115 log_link_debug(link, "Ignoring DHCP clients for loopback link");
78c958f8 3116
c4a03a56
TG		 3117 if (network->dhcp_server)
3118 log_link_debug(link, "Ignoring DHCP server for loopback link");
3119 }
bd2efe92 3120
7d342c03 3121 r = network_apply(network, link);
c4a03a56
TG		 3122 if (r < 0)
3123 return r;
3124 }
505f8da7 3125
0d4ad91d
AR		 3126 r = link_new_bound_to_list(link);
3127 if (r < 0)
3128 return r;
3129
27dfc982
YW		 3130 /* link_configure_duid() returns 0 if it requests product UUID. In that case,
3131 * link_configure() is called later asynchronously. */
3132 r = link_configure_duid(link);
3133 if (r <= 0)
3134 return r;
3135
a748b692
TG		 3136 r = link_configure(link);
3137 if (r < 0)
3138 return r;
3139
5da8149f 3140 return 1;
505f8da7
TG		 3141}
3142
e6bf7774
YW		 3143static int link_initialized_handler(sd_netlink *rtnl, sd_netlink_message *m, void *userdata) {
3144 (void) link_initialized_and_synced(userdata);
3145 return 1;
3146}
3147
51517f9e 3148int link_initialized(Link *link, sd_device *device) {
4afd3348 3149 _cleanup_(sd_netlink_message_unrefp) sd_netlink_message *req = NULL;
4f561e8e
TG		 3150 int r;
3151
3152 assert(link);
3153 assert(link->manager);
3154 assert(link->manager->rtnl);
3155 assert(device);
3156
8434fd5c 3157 if (link->state != LINK_STATE_PENDING)
4f561e8e
TG		 3158 return 0;
3159
51517f9e 3160 if (link->sd_device)
679b3605
TG		 3161 return 0;
3162
79008bdd 3163 log_link_debug(link, "udev initialized link");
4f561e8e 3164
51517f9e 3165 link->sd_device = sd_device_ref(device);
4f561e8e 3166
3c9b8860
TG		 3167 /* udev has initialized the link, but we don't know if we have yet
3168 * processed the NEWLINK messages with the latest state. Do a GETLINK,
3169 * when it returns we know that the pending NEWLINKs have already been
3170 * processed and that we are up-to-date */
4f561e8e 3171
3c9b8860
TG		 3172 r = sd_rtnl_message_new_link(link->manager->rtnl, &req, RTM_GETLINK,
3173 link->ifindex);
4f561e8e
TG		 3174 if (r < 0)
3175 return r;
3176
ee38400b 3177 r = sd_netlink_call_async(link->manager->rtnl, NULL, req, link_initialized_handler,
8190a388 3178 link_netlink_destroy_callback, link, 0, __func__);
4f561e8e
TG		 3179 if (r < 0)
3180 return r;
3181
5da8149f
TG		 3182 link_ref(link);
3183
4f561e8e
TG		 3184 return 0;
3185}
3186
c4a03a56 3187static int link_load(Link *link) {
0bc70f1d
TG		 3188 _cleanup_free_ char *network_file = NULL,
3189 *addresses = NULL,
f703cc2c 3190 *routes = NULL,
0bc70f1d
TG		 3191 *dhcp4_address = NULL,
3192 *ipv4ll_address = NULL;
3193 union in_addr_union address;
f703cc2c 3194 union in_addr_union route_dst;
c598ac76 3195 const char *p;
c4a03a56
TG		 3196 int r;
3197
3198 assert(link);
3199
1a5a177e 3200 r = parse_env_file(NULL, link->state_file, NEWLINE,
c4a03a56
TG		 3201 "NETWORK_FILE", &network_file,
3202 "ADDRESSES", &addresses,
f703cc2c 3203 "ROUTES", &routes,
0bc70f1d
TG		 3204 "DHCP4_ADDRESS", &dhcp4_address,
3205 "IPV4LL_ADDRESS", &ipv4ll_address,
c4a03a56
TG		 3206 NULL);
3207 if (r < 0 && r != -ENOENT)
3208 return log_link_error_errno(link, r, "Failed to read %s: %m", link->state_file);
3209
3210 if (network_file) {
3211 Network *network;
3212 char *suffix;
3213
3214 /* drop suffix */
3215 suffix = strrchr(network_file, '.');
3216 if (!suffix) {
3217 log_link_debug(link, "Failed to get network name from %s", network_file);
3218 goto network_file_fail;
3219 }
3220 *suffix = '\0';
3221
3222 r = network_get_by_name(link->manager, basename(network_file), &network);
3223 if (r < 0) {
3224 log_link_debug_errno(link, r, "Failed to get network %s: %m", basename(network_file));
3225 goto network_file_fail;
3226 }
3227
7d342c03 3228 r = network_apply(network, link);
c4a03a56
TG		 3229 if (r < 0)
3230 return log_link_error_errno(link, r, "Failed to apply network %s: %m", basename(network_file));
3231 }
3232
3233network_file_fail:
3234
3235 if (addresses) {
c598ac76 3236 p = addresses;
c4a03a56 3237
c598ac76
TG		 3238 for (;;) {
3239 _cleanup_free_ char *address_str = NULL;
c4a03a56
TG		 3240 char *prefixlen_str;
3241 int family;
3242 unsigned char prefixlen;
c4a03a56 3243
c598ac76
TG		 3244 r = extract_first_word(&p, &address_str, NULL, 0);
3245 if (r < 0) {
3246 log_link_debug_errno(link, r, "Failed to extract next address string: %m");
3247 continue;
928bc597
TA		 3248 }
3249 if (r == 0)
c598ac76
TG		 3250 break;
3251
3252 prefixlen_str = strchr(address_str, '/');
c4a03a56 3253 if (!prefixlen_str) {
c598ac76 3254 log_link_debug(link, "Failed to parse address and prefix length %s", address_str);
c4a03a56
TG		 3255 continue;
3256 }
3257
313cefa1 3258 *prefixlen_str++ = '\0';
c4a03a56
TG		 3259
3260 r = sscanf(prefixlen_str, "%hhu", &prefixlen);
3261 if (r != 1) {
3262 log_link_error(link, "Failed to parse prefixlen %s", prefixlen_str);
3263 continue;
3264 }
3265
c598ac76 3266 r = in_addr_from_string_auto(address_str, &family, &address);
c4a03a56 3267 if (r < 0) {
c598ac76 3268 log_link_debug_errno(link, r, "Failed to parse address %s: %m", address_str);
c4a03a56
TG		 3269 continue;
3270 }
3271
3272 r = address_add(link, family, &address, prefixlen, NULL);
3273 if (r < 0)
3274 return log_link_error_errno(link, r, "Failed to add address: %m");
3275 }
3276 }
3277
f703cc2c 3278 if (routes) {
74544b4e
TA		 3279 p = routes;
3280
c598ac76 3281 for (;;) {
f833694d 3282 Route *route;
c598ac76 3283 _cleanup_free_ char *route_str = NULL;
4afd3348 3284 _cleanup_(sd_event_source_unrefp) sd_event_source *expire = NULL;
f833694d 3285 usec_t lifetime;
f703cc2c
TG		 3286 char *prefixlen_str;
3287 int family;
3288 unsigned char prefixlen, tos, table;
3289 uint32_t priority;
3290
c598ac76
TG		 3291 r = extract_first_word(&p, &route_str, NULL, 0);
3292 if (r < 0) {
3293 log_link_debug_errno(link, r, "Failed to extract next route string: %m");
3294 continue;
928bc597
TA		 3295 }
3296 if (r == 0)
c598ac76
TG		 3297 break;
3298
3299 prefixlen_str = strchr(route_str, '/');
f703cc2c 3300 if (!prefixlen_str) {
c598ac76 3301 log_link_debug(link, "Failed to parse route %s", route_str);
f703cc2c
TG		 3302 continue;
3303 }
3304
313cefa1 3305 *prefixlen_str++ = '\0';
f703cc2c 3306
f833694d
TG		 3307 r = sscanf(prefixlen_str, "%hhu/%hhu/%"SCNu32"/%hhu/"USEC_FMT, &prefixlen, &tos, &priority, &table, &lifetime);
3308 if (r != 5) {
3309 log_link_debug(link,
3310 "Failed to parse destination prefix length, tos, priority, table or expiration %s",
3311 prefixlen_str);
f703cc2c
TG		 3312 continue;
3313 }
3314
c598ac76 3315 r = in_addr_from_string_auto(route_str, &family, &route_dst);
f703cc2c 3316 if (r < 0) {
c598ac76 3317 log_link_debug_errno(link, r, "Failed to parse route destination %s: %m", route_str);
f703cc2c
TG		 3318 continue;
3319 }
3320
f833694d 3321 r = route_add(link, family, &route_dst, prefixlen, tos, priority, table, &route);
f703cc2c
TG		 3322 if (r < 0)
3323 return log_link_error_errno(link, r, "Failed to add route: %m");
f833694d 3324
f02ba163 3325 if (lifetime != USEC_INFINITY && !kernel_route_expiration_supported()) {
f833694d
TG		 3326 r = sd_event_add_time(link->manager->event, &expire, clock_boottime_or_monotonic(), lifetime,
3327 0, route_expire_handler, route);
3328 if (r < 0)
3329 log_link_warning_errno(link, r, "Could not arm route expiration handler: %m");
3330 }
3331
3332 route->lifetime = lifetime;
3333 sd_event_source_unref(route->expire);
1cc6c93a 3334 route->expire = TAKE_PTR(expire);
f703cc2c
TG		 3335 }
3336 }
3337
0bc70f1d
TG		 3338 if (dhcp4_address) {
3339 r = in_addr_from_string(AF_INET, dhcp4_address, &address);
3340 if (r < 0) {
b68d26b8 3341 log_link_debug_errno(link, r, "Failed to parse DHCPv4 address %s: %m", dhcp4_address);
0bc70f1d
TG		 3342 goto dhcp4_address_fail;
3343 }
3344
b1c626f6 3345 r = sd_dhcp_client_new(&link->dhcp_client, link->network ? link->network->dhcp_anonymize : 0);
0bc70f1d 3346 if (r < 0)
b68d26b8 3347 return log_link_error_errno(link, r, "Failed to create DHCPv4 client: %m");
0bc70f1d
TG		 3348
3349 r = sd_dhcp_client_set_request_address(link->dhcp_client, &address.in);
3350 if (r < 0)
b68d26b8 3351 return log_link_error_errno(link, r, "Failed to set initial DHCPv4 address %s: %m", dhcp4_address);
0bc70f1d
TG		 3352 }
3353
3354dhcp4_address_fail:
3355
3356 if (ipv4ll_address) {
3357 r = in_addr_from_string(AF_INET, ipv4ll_address, &address);
3358 if (r < 0) {
b68d26b8 3359 log_link_debug_errno(link, r, "Failed to parse IPv4LL address %s: %m", ipv4ll_address);
0bc70f1d
TG		 3360 goto ipv4ll_address_fail;
3361 }
3362
3363 r = sd_ipv4ll_new(&link->ipv4ll);
3364 if (r < 0)
b68d26b8 3365 return log_link_error_errno(link, r, "Failed to create IPv4LL client: %m");
0bc70f1d
TG		 3366
3367 r = sd_ipv4ll_set_address(link->ipv4ll, &address.in);
3368 if (r < 0)
b68d26b8 3369 return log_link_error_errno(link, r, "Failed to set initial IPv4LL address %s: %m", ipv4ll_address);
0bc70f1d
TG		 3370 }
3371
3372ipv4ll_address_fail:
3373
c4a03a56
TG		 3374 return 0;
3375}
3376
1c4baffc 3377int link_add(Manager *m, sd_netlink_message *message, Link **ret) {
51517f9e 3378 _cleanup_(sd_device_unrefp) sd_device *device = NULL;
505f8da7 3379 char ifindex_str[2 + DECIMAL_STR_MAX(int)];
51517f9e 3380 Link *link;
5a937ea2 3381 int r;
505f8da7
TG		 3382
3383 assert(m);
fbbeb65a 3384 assert(m->rtnl);
505f8da7
TG		 3385 assert(message);
3386 assert(ret);
3387
3388 r = link_new(m, message, ret);
3389 if (r < 0)
3390 return r;
3391
3392 link = *ret;
3393
6a7a4e4d 3394 log_link_debug(link, "Link %d added", link->ifindex);
505f8da7 3395
c4a03a56
TG		 3396 r = link_load(link);
3397 if (r < 0)
3398 return r;
3399
75f86906 3400 if (detect_container() <= 0) {
505f8da7 3401 /* not in a container, udev will be around */
ae06ab10 3402 sprintf(ifindex_str, "n%d", link->ifindex);
51517f9e
YW		 3403 r = sd_device_new_from_device_id(&device, ifindex_str);
3404 if (r < 0) {
3405 log_link_warning_errno(link, r, "Could not find device: %m");
5c416fc4
TG		 3406 goto failed;
3407 }
505f8da7 3408
5a937ea2 3409 r = sd_device_get_is_initialized(device);
51517f9e
YW		 3410 if (r < 0) {
3411 log_link_warning_errno(link, r, "Could not determine whether the device is initialized or not: %m");
3412 goto failed;
3413 }
5a937ea2 3414 if (r == 0) {
505f8da7 3415 /* not yet ready */
79008bdd 3416 log_link_debug(link, "link pending udev initialization...");
505f8da7 3417 return 0;
3c4cb064 3418 }
505f8da7 3419
4f561e8e
TG		 3420 r = link_initialized(link, device);
3421 if (r < 0)
5c416fc4 3422 goto failed;
4f561e8e 3423 } else {
e6bf7774 3424 r = link_initialized_and_synced(link);
4f561e8e 3425 if (r < 0)
5c416fc4 3426 goto failed;
4f561e8e 3427 }
505f8da7 3428
a748b692 3429 return 0;
5c416fc4
TG		 3430failed:
3431 link_enter_failed(link);
3432 return r;
a748b692
TG		 3433}
3434
c601ebf7 3435int link_ipv6ll_gained(Link *link, const struct in6_addr *address) {
e7ab854c
TG		 3436 int r;
3437
3438 assert(link);
3439
3440 log_link_info(link, "Gained IPv6LL");
3441
c601ebf7 3442 link->ipv6ll_address = *address;
e7ab854c
TG		 3443 link_check_ready(link);
3444
201f0c91 3445 if (!IN_SET(link->state, LINK_STATE_PENDING, LINK_STATE_UNMANAGED, LINK_STATE_FAILED)) {
e7ab854c
TG		 3446 r = link_acquire_ipv6_conf(link);
3447 if (r < 0) {
3448 link_enter_failed(link);
3449 return r;
3450 }
3451 }
3452
3453 return 0;
3454}
3455
9c0a72f9
TG		 3456static int link_carrier_gained(Link *link) {
3457 int r;
3458
3459 assert(link);
3460
201f0c91 3461 if (!IN_SET(link->state, LINK_STATE_PENDING, LINK_STATE_UNMANAGED, LINK_STATE_FAILED)) {
9c0a72f9
TG		 3462 r = link_acquire_conf(link);
3463 if (r < 0) {
3464 link_enter_failed(link);
3465 return r;
3466 }
6fc25497
SS		 3467
3468 r = link_enter_set_addresses(link);
3469 if (r < 0)
3470 return r;
9c0a72f9
TG		 3471 }
3472
0d4ad91d
AR		 3473 r = link_handle_bound_by_list(link);
3474 if (r < 0)
3475 return r;
3476
9c0a72f9
TG		 3477 return 0;
3478}
3479
3480static int link_carrier_lost(Link *link) {
3481 int r;
3482
3483 assert(link);
3484
fbdb6605 3485 /* Some devices reset itself while setting the MTU. This causes the DHCP client fall into a loop.
55dc8c4a
YW		 3486 * setting_mtu keep track whether the device got reset because of setting MTU and does not drop the
3487 * configuration and stop the clients as well. */
97e7fb39
SS		 3488 if (link->setting_mtu)
3489 return 0;
3490
9c0a72f9
TG		 3491 r = link_stop_clients(link);
3492 if (r < 0) {
3493 link_enter_failed(link);
3494 return r;
3495 }
3496
28464ae0
SS		 3497 if (link_dhcp4_server_enabled(link))
3498 (void) sd_dhcp_server_stop(link->dhcp_server);
45a9eac9 3499
3104883d
SS		 3500 r = link_drop_config(link);
3501 if (r < 0)
3502 return r;
3503
f258e948
MP		 3504 if (!IN_SET(link->state, LINK_STATE_UNMANAGED, LINK_STATE_PENDING)) {
3505 log_link_debug(link, "State is %s, dropping config", link_state_to_string(link->state));
c436d553
MM		 3506 r = link_drop_foreign_config(link);
3507 if (r < 0)
3508 return r;
3509 }
3104883d 3510
0d4ad91d
AR		 3511 r = link_handle_bound_by_list(link);
3512 if (r < 0)
3513 return r;
3514
9c0a72f9
TG		 3515 return 0;
3516}
3517
3518int link_carrier_reset(Link *link) {
3519 int r;
3520
3521 assert(link);
3522
3523 if (link_has_carrier(link)) {
3524 r = link_carrier_lost(link);
3525 if (r < 0)
3526 return r;
3527
3528 r = link_carrier_gained(link);
3529 if (r < 0)
3530 return r;
3531
6a7a4e4d 3532 log_link_info(link, "Reset carrier");
9c0a72f9
TG		 3533 }
3534
3535 return 0;
3536}
3537
1c4baffc 3538int link_update(Link *link, sd_netlink_message *m) {
c49b33ac 3539 struct ether_addr mac;
ca4e095a 3540 const char *ifname;
afe7fd56 3541 uint32_t mtu;
a61bb41c 3542 bool had_carrier, carrier_gained, carrier_lost;
22936833
TG		 3543 int r;
3544
dd3efc09 3545 assert(link);
b8941f74 3546 assert(link->ifname);
22936833
TG		 3547 assert(m);
3548
7619683b 3549 if (link->state == LINK_STATE_LINGER) {
6a7a4e4d 3550 log_link_info(link, "Link readded");
e331e246 3551 link_set_state(link, LINK_STATE_ENSLAVING);
0d4ad91d
AR		 3552
3553 r = link_new_carrier_maps(link);
3554 if (r < 0)
3555 return r;
7619683b
TG		 3556 }
3557
1c4baffc 3558 r = sd_netlink_message_read_string(m, IFLA_IFNAME, &ifname);
b8941f74 3559 if (r >= 0 && !streq(ifname, link->ifname)) {
aa2b10da 3560 log_link_info(link, "Interface name change detected, %s has been renamed to %s.", link->ifname, ifname);
b8941f74 3561
587c4586
YW		 3562 if (link->state == LINK_STATE_PENDING) {
3563 r = free_and_strdup(&link->ifname, ifname);
3564 if (r < 0)
3565 return r;
3566 } else {
3567 Manager *manager = link->manager;
0d4ad91d 3568
587c4586
YW		 3569 link_drop(link);
3570 r = link_add(manager, m, &link);
3571 if (r < 0)
3572 return r;
3573 }
b8941f74
TG		 3574 }
3575
1c4baffc 3576 r = sd_netlink_message_read_u32(m, IFLA_MTU, &mtu);
afe7fd56
TG		 3577 if (r >= 0 && mtu > 0) {
3578 link->mtu = mtu;
4e964aa0 3579 if (link->original_mtu == 0) {
afe7fd56 3580 link->original_mtu = mtu;
6a7a4e4d 3581 log_link_debug(link, "Saved original MTU: %" PRIu32, link->original_mtu);
afe7fd56
TG		 3582 }
3583
3584 if (link->dhcp_client) {
3c9b8860
TG		 3585 r = sd_dhcp_client_set_mtu(link->dhcp_client,
3586 link->mtu);
fc95c359
YW		 3587 if (r < 0)
3588 return log_link_warning_errno(link, r, "Could not update MTU in DHCP client: %m");
afe7fd56 3589 }
7465dd22
PF		 3590
3591 if (link->radv) {
3592 r = sd_radv_set_mtu(link->radv, link->mtu);
3593 if (r < 0)
3594 return log_link_warning_errno(link, r, "Could not set MTU for Router Advertisement: %m");
3595 }
9842de0d 3596 }
69629de9 3597
e9189a1f
TG		 3598 /* The kernel may broadcast NEWLINK messages without the MAC address
3599 set, simply ignore them. */
1c4baffc 3600 r = sd_netlink_message_read_ether_addr(m, IFLA_ADDRESS, &mac);
e9189a1f 3601 if (r >= 0) {
3c9b8860
TG		 3602 if (memcmp(link->mac.ether_addr_octet, mac.ether_addr_octet,
3603 ETH_ALEN)) {
c49b33ac 3604
3c9b8860
TG		 3605 memcpy(link->mac.ether_addr_octet, mac.ether_addr_octet,
3606 ETH_ALEN);
c49b33ac 3607
79008bdd 3608 log_link_debug(link, "MAC address: "
20861203
TG		 3609 "%02hhx:%02hhx:%02hhx:%02hhx:%02hhx:%02hhx",
3610 mac.ether_addr_octet[0],
3611 mac.ether_addr_octet[1],
3612 mac.ether_addr_octet[2],
3613 mac.ether_addr_octet[3],
3614 mac.ether_addr_octet[4],
3615 mac.ether_addr_octet[5]);
c49b33ac 3616
20861203
TG		 3617 if (link->ipv4ll) {
3618 r = sd_ipv4ll_set_mac(link->ipv4ll, &link->mac);
6a7a4e4d
LP		 3619 if (r < 0)
3620 return log_link_warning_errno(link, r, "Could not update MAC address in IPv4LL client: %m");
c49b33ac 3621 }
c49b33ac 3622
20861203 3623 if (link->dhcp_client) {
3c9b8860 3624 r = sd_dhcp_client_set_mac(link->dhcp_client,
76253e73
DW		 3625 (const uint8_t *) &link->mac,
3626 sizeof (link->mac),
3627 ARPHRD_ETHER);
6a7a4e4d
LP		 3628 if (r < 0)
3629 return log_link_warning_errno(link, r, "Could not update MAC address in DHCP client: %m");
413708d1 3630
fff1f40c
YW		 3631 r = dhcp4_set_client_identifier(link);
3632 if (r < 0)
3633 return r;
c49b33ac 3634 }
4138fb2c
PF		 3635
3636 if (link->dhcp6_client) {
f24648a6 3637 const DUID* duid = link_get_duid(link);
8341a5c3 3638
4138fb2c 3639 r = sd_dhcp6_client_set_mac(link->dhcp6_client,
76253e73
DW		 3640 (const uint8_t *) &link->mac,
3641 sizeof (link->mac),
3642 ARPHRD_ETHER);
6a7a4e4d
LP		 3643 if (r < 0)
3644 return log_link_warning_errno(link, r, "Could not update MAC address in DHCPv6 client: %m");
413708d1
VK		 3645
3646 r = sd_dhcp6_client_set_iaid(link->dhcp6_client,
3647 link->network->iaid);
3648 if (r < 0)
3649 return log_link_warning_errno(link, r, "Could not update DHCPv6 IAID: %m");
3650
8341a5c3
ZJS		 3651 r = sd_dhcp6_client_set_duid(link->dhcp6_client,
3652 duid->type,
3653 duid->raw_data_len > 0 ? duid->raw_data : NULL,
3654 duid->raw_data_len);
413708d1
VK		 3655 if (r < 0)
3656 return log_link_warning_errno(link, r, "Could not update DHCPv6 DUID: %m");
4138fb2c 3657 }
7465dd22
PF		 3658
3659 if (link->radv) {
3660 r = sd_radv_set_mac(link->radv, &link->mac);
3661 if (r < 0)
3662 return log_link_warning_errno(link, r, "Could not update MAC for Router Advertisement: %m");
3663 }
420d2058
SS		 3664
3665 if (link->ndisc) {
3666 r = sd_ndisc_set_mac(link->ndisc, &link->mac);
3667 if (r < 0)
3668 return log_link_warning_errno(link, r, "Could not update MAC for ndisc: %m");
3669 }
c49b33ac 3670 }
4f882b2a
TG		 3671 }
3672
a61bb41c
TG		 3673 had_carrier = link_has_carrier(link);
3674
3675 r = link_update_flags(link, m);
3676 if (r < 0)
3677 return r;
3678
273eec24
LP		 3679 r = link_update_lldp(link);
3680 if (r < 0)
3681 return r;
3682
a61bb41c
TG		 3683 carrier_gained = !had_carrier && link_has_carrier(link);
3684 carrier_lost = had_carrier && !link_has_carrier(link);
3685
3686 if (carrier_gained) {
6a7a4e4d 3687 log_link_info(link, "Gained carrier");
a61bb41c 3688
9c0a72f9
TG		 3689 r = link_carrier_gained(link);
3690 if (r < 0)
3691 return r;
a61bb41c 3692 } else if (carrier_lost) {
6a7a4e4d 3693 log_link_info(link, "Lost carrier");
a61bb41c 3694
9c0a72f9
TG		 3695 r = link_carrier_lost(link);
3696 if (r < 0)
a61bb41c 3697 return r;
a61bb41c
TG		 3698 }
3699
3700 return 0;
dd3efc09 3701}
fe8db0c5 3702
b295beea
LP		 3703static void print_link_hashmap(FILE *f, const char *prefix, Hashmap* h) {
3704 bool space = false;
3705 Iterator i;
3706 Link *link;
3707
3708 assert(f);
3709 assert(prefix);
3710
3711 if (hashmap_isempty(h))
3712 return;
3713
0d536673 3714 fputs(prefix, f);
b295beea
LP		 3715 HASHMAP_FOREACH(link, h, i) {
3716 if (space)
0d536673 3717 fputc(' ', f);
b295beea
LP		 3718
3719 fprintf(f, "%i", link->ifindex);
3720 space = true;
3721 }
3722
0d536673 3723 fputc('\n', f);
b295beea
LP		 3724}
3725
fe8db0c5 3726int link_save(Link *link) {
68a8723c 3727 _cleanup_free_ char *temp_path = NULL;
fe8db0c5 3728 _cleanup_fclose_ FILE *f = NULL;
e375dcde 3729 const char *admin_state, *oper_state;
e7780c8d 3730 Address *a;
c1eb9872 3731 Route *route;
e7780c8d 3732 Iterator i;
fe8db0c5
TG		 3733 int r;
3734
3735 assert(link);
3736 assert(link->state_file);
68a8723c 3737 assert(link->lease_file);
bbf7c048
TG		 3738 assert(link->manager);
3739
370e9930
TG		 3740 if (link->state == LINK_STATE_LINGER) {
3741 unlink(link->state_file);
3742 return 0;
3743 }
3744
34437b4f
LP		 3745 link_lldp_save(link);
3746
deb2e523
TG		 3747 admin_state = link_state_to_string(link->state);
3748 assert(admin_state);
3749
e375dcde
TG		 3750 oper_state = link_operstate_to_string(link->operstate);
3751 assert(oper_state);
deb2e523 3752
fe8db0c5
TG		 3753 r = fopen_temporary(link->state_file, &f, &temp_path);
3754 if (r < 0)
6a7a4e4d 3755 goto fail;
fe8db0c5 3756
0d536673 3757 (void) __fsetlocking(f, FSETLOCKING_BYCALLER);
5512a963 3758 (void) fchmod(fileno(f), 0644);
fe8db0c5
TG		 3759
3760 fprintf(f,
3761 "# This is private data. Do not parse.\n"
deb2e523 3762 "ADMIN_STATE=%s\n"
6dcaa6f5
TG		 3763 "OPER_STATE=%s\n",
3764 admin_state, oper_state);
fe8db0c5 3765
bcb7a07e 3766 if (link->network) {
ea352b40 3767 bool space;
07bdc70d 3768 sd_dhcp6_lease *dhcp6_lease = NULL;
b2a81c0b
LP		 3769 const char *dhcp_domainname = NULL;
3770 char **dhcp6_domains = NULL;
b85bc551 3771 char **dhcp_domains = NULL;
5512a963 3772 unsigned j;
07bdc70d 3773
c1a38904
MTL		 3774 fprintf(f, "REQUIRED_FOR_ONLINE=%s\n",
3775 yes_no(link->network->required_for_online));
3776
07bdc70d 3777 if (link->dhcp6_client) {
4058d339
TG		 3778 r = sd_dhcp6_client_get_lease(link->dhcp6_client, &dhcp6_lease);
3779 if (r < 0 && r != -ENOMSG)
07bdc70d
PF		 3780 log_link_debug(link, "No DHCPv6 lease");
3781 }
b0e39c82 3782
adc5b2e2
TG		 3783 fprintf(f, "NETWORK_FILE=%s\n", link->network->filename);
3784
0d536673 3785 fputs("DNS=", f);
ea352b40 3786 space = false;
5512a963
LP		 3787
3788 for (j = 0; j < link->network->n_dns; j++) {
3789 _cleanup_free_ char *b = NULL;
3790
3791 r = in_addr_to_string(link->network->dns[j].family,
3792 &link->network->dns[j].address, &b);
3793 if (r < 0) {
3794 log_debug_errno(r, "Failed to format address, ignoring: %m");
3795 continue;
3796 }
3797
3798 if (space)
0d536673
LP		 3799 fputc(' ', f);
3800 fputs(b, f);
5512a963
LP		 3801 space = true;
3802 }
d5314fff 3803
27cb34f5 3804 if (link->network->dhcp_use_dns &&
b0e39c82
TG		 3805 link->dhcp_lease) {
3806 const struct in_addr *addresses;
3807
3808 r = sd_dhcp_lease_get_dns(link->dhcp_lease, &addresses);
3809 if (r > 0) {
ea352b40 3810 if (space)
0d536673 3811 fputc(' ', f);
b0e39c82 3812 serialize_in_addrs(f, addresses, r);
07bdc70d
PF		 3813 space = true;
3814 }
3815 }
3816
27cb34f5 3817 if (link->network->dhcp_use_dns && dhcp6_lease) {
07bdc70d
PF		 3818 struct in6_addr *in6_addrs;
3819
3820 r = sd_dhcp6_lease_get_dns(dhcp6_lease, &in6_addrs);
3821 if (r > 0) {
3822 if (space)
0d536673 3823 fputc(' ', f);
07bdc70d 3824 serialize_in6_addrs(f, in6_addrs, r);
1e7a0e21
LP		 3825 space = true;
3826 }
3827 }
3828
3829 /* Make sure to flush out old entries before we use the NDISC data */
3830 ndisc_vacuum(link);
3831
b296797f 3832 if (link->network->ipv6_accept_ra_use_dns && link->ndisc_rdnss) {
1e7a0e21
LP		 3833 NDiscRDNSS *dd;
3834
3835 SET_FOREACH(dd, link->ndisc_rdnss, i) {
3836 if (space)
0d536673 3837 fputc(' ', f);
1e7a0e21
LP		 3838
3839 serialize_in6_addrs(f, &dd->address, 1);
3840 space = true;
b0e39c82
TG		 3841 }
3842 }
3843
0d536673 3844 fputc('\n', f);
b0e39c82 3845
0d536673 3846 fputs("NTP=", f);
ea352b40 3847 space = false;
3df9bec5 3848 fputstrv(f, link->network->ntp, NULL, &space);
d5314fff 3849
27cb34f5 3850 if (link->network->dhcp_use_ntp &&
b0e39c82
TG		 3851 link->dhcp_lease) {
3852 const struct in_addr *addresses;
3853
3854 r = sd_dhcp_lease_get_ntp(link->dhcp_lease, &addresses);
3855 if (r > 0) {
ea352b40 3856 if (space)
0d536673 3857 fputc(' ', f);
b0e39c82 3858 serialize_in_addrs(f, addresses, r);
07bdc70d
PF		 3859 space = true;
3860 }
3861 }
3862
27cb34f5 3863 if (link->network->dhcp_use_ntp && dhcp6_lease) {
07bdc70d
PF		 3864 struct in6_addr *in6_addrs;
3865 char **hosts;
07bdc70d
PF		 3866
3867 r = sd_dhcp6_lease_get_ntp_addrs(dhcp6_lease,
3868 &in6_addrs);
3869 if (r > 0) {
3870 if (space)
0d536673 3871 fputc(' ', f);
07bdc70d
PF		 3872 serialize_in6_addrs(f, in6_addrs, r);
3873 space = true;
3874 }
3875
3876 r = sd_dhcp6_lease_get_ntp_fqdn(dhcp6_lease, &hosts);
3df9bec5
LP		 3877 if (r > 0)
3878 fputstrv(f, hosts, NULL, &space);
b0e39c82
TG		 3879 }
3880
0d536673 3881 fputc('\n', f);
bd8f6538 3882
b2a81c0b 3883 if (link->network->dhcp_use_domains != DHCP_USE_DOMAINS_NO) {
b85bc551 3884 if (link->dhcp_lease) {
b2a81c0b 3885 (void) sd_dhcp_lease_get_domainname(link->dhcp_lease, &dhcp_domainname);
b85bc551
DW		 3886 (void) sd_dhcp_lease_get_search_domains(link->dhcp_lease, &dhcp_domains);
3887 }
b2a81c0b
LP		 3888 if (dhcp6_lease)
3889 (void) sd_dhcp6_lease_get_domains(dhcp6_lease, &dhcp6_domains);
07bdc70d
PF		 3890 }
3891
0d536673 3892 fputs("DOMAINS=", f);
b85bc551 3893 space = false;
b2a81c0b 3894 fputstrv(f, link->network->search_domains, NULL, &space);
07bdc70d 3895
1e7a0e21
LP		 3896 if (link->network->dhcp_use_domains == DHCP_USE_DOMAINS_YES) {
3897 NDiscDNSSL *dd;
9b4d1882 3898
1e7a0e21
LP		 3899 if (dhcp_domainname)
3900 fputs_with_space(f, dhcp_domainname, NULL, &space);
b85bc551
DW		 3901 if (dhcp_domains)
3902 fputstrv(f, dhcp_domains, NULL, &space);
1e7a0e21
LP		 3903 if (dhcp6_domains)
3904 fputstrv(f, dhcp6_domains, NULL, &space);
3905
3906 SET_FOREACH(dd, link->ndisc_dnssl, i)
3907 fputs_with_space(f, NDISC_DNSSL_DOMAIN(dd), NULL, &space);
3908 }
b2a81c0b 3909
0d536673 3910 fputc('\n', f);
6192b846 3911
0d536673 3912 fputs("ROUTE_DOMAINS=", f);
b85bc551
DW		 3913 space = false;
3914 fputstrv(f, link->network->route_domains, NULL, &space);
b2a81c0b 3915
1e7a0e21
LP		 3916 if (link->network->dhcp_use_domains == DHCP_USE_DOMAINS_ROUTE) {
3917 NDiscDNSSL *dd;
b2a81c0b 3918
1e7a0e21
LP		 3919 if (dhcp_domainname)
3920 fputs_with_space(f, dhcp_domainname, NULL, &space);
b85bc551
DW		 3921 if (dhcp_domains)
3922 fputstrv(f, dhcp_domains, NULL, &space);
1e7a0e21
LP		 3923 if (dhcp6_domains)
3924 fputstrv(f, dhcp6_domains, NULL, &space);
3925
3926 SET_FOREACH(dd, link->ndisc_dnssl, i)
3927 fputs_with_space(f, NDISC_DNSSL_DOMAIN(dd), NULL, &space);
3928 }
b2a81c0b 3929
0d536673 3930 fputc('\n', f);
67272d15 3931
3c9b8860 3932 fprintf(f, "LLMNR=%s\n",
a7e5da6e 3933 resolve_support_to_string(link->network->llmnr));
aaa297d4
LP		 3934 fprintf(f, "MDNS=%s\n",
3935 resolve_support_to_string(link->network->mdns));
e7780c8d 3936
c9299be2
IT		 3937 if (link->network->dns_over_tls_mode != _DNS_OVER_TLS_MODE_INVALID)
3938 fprintf(f, "DNS_OVER_TLS=%s\n",
3939 dns_over_tls_mode_to_string(link->network->dns_over_tls_mode));
d050561a 3940
ad6c0475
LP		 3941 if (link->network->dnssec_mode != _DNSSEC_MODE_INVALID)
3942 fprintf(f, "DNSSEC=%s\n",
3943 dnssec_mode_to_string(link->network->dnssec_mode));
3944
8a516214
LP		 3945 if (!set_isempty(link->network->dnssec_negative_trust_anchors)) {
3946 const char *n;
3947
0d536673 3948 fputs("DNSSEC_NTA=", f);
8a516214 3949 space = false;
d390f8ef
LP		 3950 SET_FOREACH(n, link->network->dnssec_negative_trust_anchors, i)
3951 fputs_with_space(f, n, NULL, &space);
0d536673 3952 fputc('\n', f);
8a516214
LP		 3953 }
3954
0d536673 3955 fputs("ADDRESSES=", f);
e7780c8d
TG		 3956 space = false;
3957 SET_FOREACH(a, link->addresses, i) {
3958 _cleanup_free_ char *address_str = NULL;
3959
3960 r = in_addr_to_string(a->family, &a->in_addr, &address_str);
3961 if (r < 0)
3962 goto fail;
3963
e7780c8d
TG		 3964 fprintf(f, "%s%s/%u", space ? " " : "", address_str, a->prefixlen);
3965 space = true;
3966 }
0d536673 3967 fputc('\n', f);
c1eb9872 3968
0d536673 3969 fputs("ROUTES=", f);
c1eb9872
TG		 3970 space = false;
3971 SET_FOREACH(route, link->routes, i) {
3972 _cleanup_free_ char *route_str = NULL;
3973
3974 r = in_addr_to_string(route->family, &route->dst, &route_str);
3975 if (r < 0)
3976 goto fail;
3977
ecc3f340
ZJS		 3978 fprintf(f, "%s%s/%hhu/%hhu/%"PRIu32"/%"PRIu32"/"USEC_FMT,
3979 space ? " " : "", route_str,
f833694d 3980 route->dst_prefixlen, route->tos, route->priority, route->table, route->lifetime);
c1eb9872
TG		 3981 space = true;
3982 }
3983
0d536673 3984 fputc('\n', f);
bcb7a07e 3985 }
7374f9d8 3986
b295beea
LP		 3987 print_link_hashmap(f, "CARRIER_BOUND_TO=", link->bound_to_links);
3988 print_link_hashmap(f, "CARRIER_BOUND_BY=", link->bound_by_links);
0d4ad91d 3989
8eb9058d 3990 if (link->dhcp_lease) {
0bc70f1d 3991 struct in_addr address;
8eb9058d
LP		 3992 const char *tz = NULL;
3993
0bc70f1d
TG		 3994 assert(link->network);
3995
8eb9058d
LP		 3996 r = sd_dhcp_lease_get_timezone(link->dhcp_lease, &tz);
3997 if (r >= 0)
3998 fprintf(f, "TIMEZONE=%s\n", tz);
8eb9058d 3999
0bc70f1d
TG		 4000 r = sd_dhcp_lease_get_address(link->dhcp_lease, &address);
4001 if (r >= 0) {
0d536673 4002 fputs("DHCP4_ADDRESS=", f);
0bc70f1d 4003 serialize_in_addrs(f, &address, 1);
0d536673 4004 fputc('\n', f);
0bc70f1d 4005 }
d9876a52 4006
bd91b83e 4007 r = dhcp_lease_save(link->dhcp_lease, link->lease_file);
fe8db0c5 4008 if (r < 0)
c2d6bd61 4009 goto fail;
fe8db0c5 4010
7374f9d8 4011 fprintf(f,
b0e39c82
TG		 4012 "DHCP_LEASE=%s\n",
4013 link->lease_file);
deb2e523 4014 } else
68a8723c 4015 unlink(link->lease_file);
fe8db0c5 4016
0bc70f1d
TG		 4017 if (link->ipv4ll) {
4018 struct in_addr address;
4019
4020 r = sd_ipv4ll_get_address(link->ipv4ll, &address);
4021 if (r >= 0) {
0d536673 4022 fputs("IPV4LL_ADDRESS=", f);
0bc70f1d 4023 serialize_in_addrs(f, &address, 1);
0d536673 4024 fputc('\n', f);
0bc70f1d
TG		 4025 }
4026 }
4027
c2d6bd61
LP		 4028 r = fflush_and_check(f);
4029 if (r < 0)
4030 goto fail;
fe8db0c5 4031
c2d6bd61 4032 if (rename(temp_path, link->state_file) < 0) {
fe8db0c5 4033 r = -errno;
c2d6bd61 4034 goto fail;
fe8db0c5
TG		 4035 }
4036
c2d6bd61 4037 return 0;
dacd6cee 4038
c2d6bd61 4039fail:
6a7a4e4d 4040 (void) unlink(link->state_file);
6a7a4e4d
LP		 4041 if (temp_path)
4042 (void) unlink(temp_path);
4043
dacd6cee 4044 return log_link_error_errno(link, r, "Failed to save link data to %s: %m", link->state_file);
fe8db0c5
TG		 4045}
4046
84de38c5
TG		 4047/* The serialized state in /run is no longer up-to-date. */
4048void link_dirty(Link *link) {
4049 int r;
4050
4051 assert(link);
4052
0c241a37
SS		 4053 /* mark manager dirty as link is dirty */
4054 manager_dirty(link->manager);
4055
84de38c5
TG		 4056 r = set_ensure_allocated(&link->manager->dirty_links, NULL);
4057 if (r < 0)
4058 /* allocation errors are ignored */
4059 return;
4060
4061 r = set_put(link->manager->dirty_links, link);
0c241a37
SS		 4062 if (r <= 0)
4063 /* don't take another ref if the link was already dirty */
84de38c5
TG		 4064 return;
4065
4066 link_ref(link);
4067}
4068
4069/* The serialized state in /run is up-to-date */
4070void link_clean(Link *link) {
4071 assert(link);
4072 assert(link->manager);
4073
1046bf9b 4074 link_unref(set_remove(link->manager->dirty_links, link));
84de38c5
TG		 4075}
4076
fe8db0c5 4077static const char* const link_state_table[_LINK_STATE_MAX] = {
8434fd5c 4078 [LINK_STATE_PENDING] = "pending",
fe8db0c5
TG		 4079 [LINK_STATE_ENSLAVING] = "configuring",
4080 [LINK_STATE_SETTING_ADDRESSES] = "configuring",
4081 [LINK_STATE_SETTING_ROUTES] = "configuring",
4082 [LINK_STATE_CONFIGURED] = "configured",
57bd6899 4083 [LINK_STATE_UNMANAGED] = "unmanaged",
fe8db0c5 4084 [LINK_STATE_FAILED] = "failed",
370e9930 4085 [LINK_STATE_LINGER] = "linger",
fe8db0c5
TG		 4086};
4087
4088DEFINE_STRING_TABLE_LOOKUP(link_state, LinkState);
e375dcde
TG		 4089
4090static const char* const link_operstate_table[_LINK_OPERSTATE_MAX] = {
d3df0e39
TG		 4091 [LINK_OPERSTATE_OFF] = "off",
4092 [LINK_OPERSTATE_NO_CARRIER] = "no-carrier",
e375dcde
TG		 4093 [LINK_OPERSTATE_DORMANT] = "dormant",
4094 [LINK_OPERSTATE_CARRIER] = "carrier",
4095 [LINK_OPERSTATE_DEGRADED] = "degraded",
4096 [LINK_OPERSTATE_ROUTABLE] = "routable",
4097};
4098
4099DEFINE_STRING_TABLE_LOOKUP(link_operstate, LinkOperationalState);
Unnamed repository; edit this file 'description' to name the repository.