Branch data Line data Source code
1 : : /* SPDX-License-Identifier: LGPL-2.1+ */
2 : :
3 : : #include "sd-netlink.h"
4 : :
5 : : #include "alloc-util.h"
6 : : #include "bond.h"
7 : : #include "conf-parser.h"
8 : : #include "ether-addr-util.h"
9 : : #include "extract-word.h"
10 : : #include "netlink-util.h"
11 : : #include "networkd-manager.h"
12 : : #include "string-table.h"
13 : : #include "string-util.h"
14 : :
15 : : /*
16 : : * Number of seconds between instances where the bonding
17 : : * driver sends learning packets to each slaves peer switch
18 : : */
19 : : #define LEARNING_PACKETS_INTERVAL_MIN_SEC (1 * USEC_PER_SEC)
20 : : #define LEARNING_PACKETS_INTERVAL_MAX_SEC (0x7fffffff * USEC_PER_SEC)
21 : :
22 : : /* Number of IGMP membership reports to be issued after
23 : : * a failover event.
24 : : */
25 : : #define RESEND_IGMP_MIN 0
26 : : #define RESEND_IGMP_MAX 255
27 : : #define RESEND_IGMP_DEFAULT 1
28 : :
29 : : /*
30 : : * Number of packets to transmit through a slave before
31 : : * moving to the next one.
32 : : */
33 : : #define PACKETS_PER_SLAVE_MIN 0
34 : : #define PACKETS_PER_SLAVE_MAX 65535
35 : : #define PACKETS_PER_SLAVE_DEFAULT 1
36 : :
37 : : /*
38 : : * Number of peer notifications (gratuitous ARPs and
39 : : * unsolicited IPv6 Neighbor Advertisements) to be issued after a
40 : : * failover event.
41 : : */
42 : : #define GRATUITOUS_ARP_MIN 0
43 : : #define GRATUITOUS_ARP_MAX 255
44 : : #define GRATUITOUS_ARP_DEFAULT 1
45 : :
46 : : static const char* const bond_mode_table[_NETDEV_BOND_MODE_MAX] = {
47 : : [NETDEV_BOND_MODE_BALANCE_RR] = "balance-rr",
48 : : [NETDEV_BOND_MODE_ACTIVE_BACKUP] = "active-backup",
49 : : [NETDEV_BOND_MODE_BALANCE_XOR] = "balance-xor",
50 : : [NETDEV_BOND_MODE_BROADCAST] = "broadcast",
51 : : [NETDEV_BOND_MODE_802_3AD] = "802.3ad",
52 : : [NETDEV_BOND_MODE_BALANCE_TLB] = "balance-tlb",
53 : : [NETDEV_BOND_MODE_BALANCE_ALB] = "balance-alb",
54 : : };
55 : :
56 [ + + + + ]: 72 : DEFINE_STRING_TABLE_LOOKUP(bond_mode, BondMode);
57 [ # # # # : 0 : DEFINE_CONFIG_PARSE_ENUM(config_parse_bond_mode, bond_mode, BondMode, "Failed to parse bond mode");
# # # # #
# # # ]
58 : :
59 : : static const char* const bond_xmit_hash_policy_table[_NETDEV_BOND_XMIT_HASH_POLICY_MAX] = {
60 : : [NETDEV_BOND_XMIT_HASH_POLICY_LAYER2] = "layer2",
61 : : [NETDEV_BOND_XMIT_HASH_POLICY_LAYER34] = "layer3+4",
62 : : [NETDEV_BOND_XMIT_HASH_POLICY_LAYER23] = "layer2+3",
63 : : [NETDEV_BOND_XMIT_HASH_POLICY_ENCAP23] = "encap2+3",
64 : : [NETDEV_BOND_XMIT_HASH_POLICY_ENCAP34] = "encap3+4",
65 : : };
66 : :
67 [ + + + + ]: 56 : DEFINE_STRING_TABLE_LOOKUP(bond_xmit_hash_policy, BondXmitHashPolicy);
68 [ # # # # : 0 : DEFINE_CONFIG_PARSE_ENUM(config_parse_bond_xmit_hash_policy,
# # # # #
# # # ]
69 : : bond_xmit_hash_policy,
70 : : BondXmitHashPolicy,
71 : : "Failed to parse bond transmit hash policy")
72 : :
73 : : static const char* const bond_lacp_rate_table[_NETDEV_BOND_LACP_RATE_MAX] = {
74 : : [NETDEV_BOND_LACP_RATE_SLOW] = "slow",
75 : : [NETDEV_BOND_LACP_RATE_FAST] = "fast",
76 : : };
77 : :
78 [ + + + + ]: 32 : DEFINE_STRING_TABLE_LOOKUP(bond_lacp_rate, BondLacpRate);
79 [ # # # # : 0 : DEFINE_CONFIG_PARSE_ENUM(config_parse_bond_lacp_rate, bond_lacp_rate, BondLacpRate, "Failed to parse bond lacp rate")
# # # # #
# # # ]
80 : :
81 : : static const char* const bond_ad_select_table[_NETDEV_BOND_AD_SELECT_MAX] = {
82 : : [NETDEV_BOND_AD_SELECT_STABLE] = "stable",
83 : : [NETDEV_BOND_AD_SELECT_BANDWIDTH] = "bandwidth",
84 : : [NETDEV_BOND_AD_SELECT_COUNT] = "count",
85 : : };
86 : :
87 [ + + + + ]: 40 : DEFINE_STRING_TABLE_LOOKUP(bond_ad_select, BondAdSelect);
88 [ # # # # : 0 : DEFINE_CONFIG_PARSE_ENUM(config_parse_bond_ad_select, bond_ad_select, BondAdSelect, "Failed to parse bond AD select");
# # # # #
# # # ]
89 : :
90 : : static const char* const bond_fail_over_mac_table[_NETDEV_BOND_FAIL_OVER_MAC_MAX] = {
91 : : [NETDEV_BOND_FAIL_OVER_MAC_NONE] = "none",
92 : : [NETDEV_BOND_FAIL_OVER_MAC_ACTIVE] = "active",
93 : : [NETDEV_BOND_FAIL_OVER_MAC_FOLLOW] = "follow",
94 : : };
95 : :
96 [ + + + + ]: 40 : DEFINE_STRING_TABLE_LOOKUP(bond_fail_over_mac, BondFailOverMac);
97 [ # # # # : 0 : DEFINE_CONFIG_PARSE_ENUM(config_parse_bond_fail_over_mac, bond_fail_over_mac, BondFailOverMac, "Failed to parse bond fail over MAC");
# # # # #
# # # ]
98 : :
99 : : static const char *const bond_arp_validate_table[_NETDEV_BOND_ARP_VALIDATE_MAX] = {
100 : : [NETDEV_BOND_ARP_VALIDATE_NONE] = "none",
101 : : [NETDEV_BOND_ARP_VALIDATE_ACTIVE]= "active",
102 : : [NETDEV_BOND_ARP_VALIDATE_BACKUP]= "backup",
103 : : [NETDEV_BOND_ARP_VALIDATE_ALL]= "all",
104 : : };
105 : :
106 [ + + + + ]: 48 : DEFINE_STRING_TABLE_LOOKUP(bond_arp_validate, BondArpValidate);
107 [ # # # # : 0 : DEFINE_CONFIG_PARSE_ENUM(config_parse_bond_arp_validate, bond_arp_validate, BondArpValidate, "Failed to parse bond arp validate");
# # # # #
# # # ]
108 : :
109 : : static const char *const bond_arp_all_targets_table[_NETDEV_BOND_ARP_ALL_TARGETS_MAX] = {
110 : : [NETDEV_BOND_ARP_ALL_TARGETS_ANY] = "any",
111 : : [NETDEV_BOND_ARP_ALL_TARGETS_ALL] = "all",
112 : : };
113 : :
114 [ + + + + ]: 32 : DEFINE_STRING_TABLE_LOOKUP(bond_arp_all_targets, BondArpAllTargets);
115 [ # # # # : 0 : DEFINE_CONFIG_PARSE_ENUM(config_parse_bond_arp_all_targets, bond_arp_all_targets, BondArpAllTargets, "Failed to parse bond Arp all targets");
# # # # #
# # # ]
116 : :
117 : : static const char *const bond_primary_reselect_table[_NETDEV_BOND_PRIMARY_RESELECT_MAX] = {
118 : : [NETDEV_BOND_PRIMARY_RESELECT_ALWAYS] = "always",
119 : : [NETDEV_BOND_PRIMARY_RESELECT_BETTER]= "better",
120 : : [NETDEV_BOND_PRIMARY_RESELECT_FAILURE]= "failure",
121 : : };
122 : :
123 [ + + + + ]: 40 : DEFINE_STRING_TABLE_LOOKUP(bond_primary_reselect, BondPrimaryReselect);
124 [ # # # # : 0 : DEFINE_CONFIG_PARSE_ENUM(config_parse_bond_primary_reselect, bond_primary_reselect, BondPrimaryReselect, "Failed to parse bond primary reselect");
# # # # #
# # # ]
125 : :
126 : 0 : static int netdev_bond_fill_message_create(NetDev *netdev, Link *link, sd_netlink_message *m) {
127 : : Bond *b;
128 : : int r;
129 : :
130 [ # # ]: 0 : assert(netdev);
131 [ # # ]: 0 : assert(!link);
132 [ # # ]: 0 : assert(m);
133 : :
134 : 0 : b = BOND(netdev);
135 : :
136 [ # # ]: 0 : assert(b);
137 : :
138 [ # # ]: 0 : if (b->mode != _NETDEV_BOND_MODE_INVALID) {
139 : 0 : r = sd_netlink_message_append_u8(m, IFLA_BOND_MODE, b->mode);
140 [ # # ]: 0 : if (r < 0)
141 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_MODE attribute: %m");
142 : : }
143 : :
144 [ # # ]: 0 : if (b->xmit_hash_policy != _NETDEV_BOND_XMIT_HASH_POLICY_INVALID) {
145 : 0 : r = sd_netlink_message_append_u8(m, IFLA_BOND_XMIT_HASH_POLICY, b->xmit_hash_policy);
146 [ # # ]: 0 : if (r < 0)
147 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_XMIT_HASH_POLICY attribute: %m");
148 : : }
149 : :
150 [ # # ]: 0 : if (b->lacp_rate != _NETDEV_BOND_LACP_RATE_INVALID &&
151 [ # # ]: 0 : b->mode == NETDEV_BOND_MODE_802_3AD) {
152 : 0 : r = sd_netlink_message_append_u8(m, IFLA_BOND_AD_LACP_RATE, b->lacp_rate);
153 [ # # ]: 0 : if (r < 0)
154 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_AD_LACP_RATE attribute: %m");
155 : : }
156 : :
157 [ # # ]: 0 : if (b->miimon != 0) {
158 : 0 : r = sd_netlink_message_append_u32(m, IFLA_BOND_MIIMON, b->miimon / USEC_PER_MSEC);
159 [ # # ]: 0 : if (r < 0)
160 [ # # ]: 0 : log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_BOND_MIIMON attribute: %m");
161 : : }
162 : :
163 [ # # ]: 0 : if (b->downdelay != 0) {
164 : 0 : r = sd_netlink_message_append_u32(m, IFLA_BOND_DOWNDELAY, b->downdelay / USEC_PER_MSEC);
165 [ # # ]: 0 : if (r < 0)
166 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_DOWNDELAY attribute: %m");
167 : : }
168 : :
169 [ # # ]: 0 : if (b->updelay != 0) {
170 : 0 : r = sd_netlink_message_append_u32(m, IFLA_BOND_UPDELAY, b->updelay / USEC_PER_MSEC);
171 [ # # ]: 0 : if (r < 0)
172 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_UPDELAY attribute: %m");
173 : : }
174 : :
175 [ # # ]: 0 : if (b->arp_interval != 0) {
176 : 0 : r = sd_netlink_message_append_u32(m, IFLA_BOND_ARP_INTERVAL, b->arp_interval / USEC_PER_MSEC);
177 [ # # ]: 0 : if (r < 0)
178 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_ARP_INTERVAL attribute: %m");
179 : :
180 [ # # ]: 0 : if (b->lp_interval >= LEARNING_PACKETS_INTERVAL_MIN_SEC &&
181 [ # # ]: 0 : b->lp_interval <= LEARNING_PACKETS_INTERVAL_MAX_SEC) {
182 : 0 : r = sd_netlink_message_append_u32(m, IFLA_BOND_LP_INTERVAL, b->lp_interval / USEC_PER_SEC);
183 [ # # ]: 0 : if (r < 0)
184 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_LP_INTERVAL attribute: %m");
185 : : }
186 : : }
187 : :
188 [ # # ]: 0 : if (b->ad_select != _NETDEV_BOND_AD_SELECT_INVALID &&
189 [ # # ]: 0 : b->mode == NETDEV_BOND_MODE_802_3AD) {
190 : 0 : r = sd_netlink_message_append_u8(m, IFLA_BOND_AD_SELECT, b->ad_select);
191 [ # # ]: 0 : if (r < 0)
192 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_AD_SELECT attribute: %m");
193 : : }
194 : :
195 [ # # ]: 0 : if (b->fail_over_mac != _NETDEV_BOND_FAIL_OVER_MAC_INVALID &&
196 [ # # ]: 0 : b->mode == NETDEV_BOND_MODE_ACTIVE_BACKUP) {
197 : 0 : r = sd_netlink_message_append_u8(m, IFLA_BOND_FAIL_OVER_MAC, b->fail_over_mac);
198 [ # # ]: 0 : if (r < 0)
199 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_FAIL_OVER_MAC attribute: %m");
200 : : }
201 : :
202 [ # # ]: 0 : if (b->arp_validate != _NETDEV_BOND_ARP_VALIDATE_INVALID) {
203 : 0 : r = sd_netlink_message_append_u32(m, IFLA_BOND_ARP_VALIDATE, b->arp_validate);
204 [ # # ]: 0 : if (r < 0)
205 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_ARP_VALIDATE attribute: %m");
206 : : }
207 : :
208 [ # # ]: 0 : if (b->arp_all_targets != _NETDEV_BOND_ARP_ALL_TARGETS_INVALID) {
209 : 0 : r = sd_netlink_message_append_u32(m, IFLA_BOND_ARP_ALL_TARGETS, b->arp_all_targets);
210 [ # # ]: 0 : if (r < 0)
211 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_ARP_ALL_TARGETS attribute: %m");
212 : : }
213 : :
214 [ # # ]: 0 : if (b->primary_reselect != _NETDEV_BOND_PRIMARY_RESELECT_INVALID) {
215 : 0 : r = sd_netlink_message_append_u8(m, IFLA_BOND_PRIMARY_RESELECT, b->primary_reselect);
216 [ # # ]: 0 : if (r < 0)
217 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_PRIMARY_RESELECT attribute: %m");
218 : : }
219 : :
220 [ # # ]: 0 : if (b->resend_igmp <= RESEND_IGMP_MAX) {
221 : 0 : r = sd_netlink_message_append_u32(m, IFLA_BOND_RESEND_IGMP, b->resend_igmp);
222 [ # # ]: 0 : if (r < 0)
223 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_RESEND_IGMP attribute: %m");
224 : : }
225 : :
226 [ # # ]: 0 : if (b->packets_per_slave <= PACKETS_PER_SLAVE_MAX &&
227 [ # # ]: 0 : b->mode == NETDEV_BOND_MODE_BALANCE_RR) {
228 : 0 : r = sd_netlink_message_append_u32(m, IFLA_BOND_PACKETS_PER_SLAVE, b->packets_per_slave);
229 [ # # ]: 0 : if (r < 0)
230 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_PACKETS_PER_SLAVE attribute: %m");
231 : : }
232 : :
233 [ # # ]: 0 : if (b->num_grat_arp <= GRATUITOUS_ARP_MAX) {
234 : 0 : r = sd_netlink_message_append_u8(m, IFLA_BOND_NUM_PEER_NOTIF, b->num_grat_arp);
235 [ # # ]: 0 : if (r < 0)
236 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_NUM_PEER_NOTIF attribute: %m");
237 : : }
238 : :
239 [ # # ]: 0 : if (b->min_links != 0) {
240 : 0 : r = sd_netlink_message_append_u32(m, IFLA_BOND_MIN_LINKS, b->min_links);
241 [ # # ]: 0 : if (r < 0)
242 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_MIN_LINKS attribute: %m");
243 : : }
244 : :
245 [ # # ]: 0 : if (b->ad_actor_sys_prio != 0) {
246 : 0 : r = sd_netlink_message_append_u16(m, IFLA_BOND_AD_ACTOR_SYS_PRIO, b->ad_actor_sys_prio);
247 [ # # ]: 0 : if (r < 0)
248 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_AD_ACTOR_SYS_PRIO attribute: %m");
249 : : }
250 : :
251 [ # # ]: 0 : if (b->ad_user_port_key != 0) {
252 : 0 : r = sd_netlink_message_append_u16(m, IFLA_BOND_AD_USER_PORT_KEY, b->ad_user_port_key);
253 [ # # ]: 0 : if (r < 0)
254 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_AD_USER_PORT_KEY attribute: %m");
255 : : }
256 : :
257 [ # # ]: 0 : if (!ether_addr_is_null(&b->ad_actor_system)) {
258 : 0 : r = sd_netlink_message_append_ether_addr(m, IFLA_BOND_AD_ACTOR_SYSTEM, &b->ad_actor_system);
259 [ # # ]: 0 : if (r < 0)
260 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_AD_ACTOR_SYSTEM attribute: %m");
261 : : }
262 : :
263 : 0 : r = sd_netlink_message_append_u8(m, IFLA_BOND_ALL_SLAVES_ACTIVE, b->all_slaves_active);
264 [ # # ]: 0 : if (r < 0)
265 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_ALL_SLAVES_ACTIVE attribute: %m");
266 : :
267 [ # # ]: 0 : if (b->tlb_dynamic_lb >= 0) {
268 : 0 : r = sd_netlink_message_append_u8(m, IFLA_BOND_TLB_DYNAMIC_LB, b->tlb_dynamic_lb);
269 [ # # ]: 0 : if (r < 0)
270 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_TLB_DYNAMIC_LB attribute: %m");
271 : : }
272 : :
273 [ # # # # ]: 0 : if (b->arp_interval > 0 && !ordered_set_isempty(b->arp_ip_targets)) {
274 : : Iterator i;
275 : : void *val;
276 : 0 : int n = 0;
277 : :
278 : 0 : r = sd_netlink_message_open_container(m, IFLA_BOND_ARP_IP_TARGET);
279 [ # # ]: 0 : if (r < 0)
280 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not open contaniner IFLA_BOND_ARP_IP_TARGET : %m");
281 : :
282 [ # # ]: 0 : ORDERED_SET_FOREACH(val, b->arp_ip_targets, i) {
283 : 0 : r = sd_netlink_message_append_u32(m, n++, PTR_TO_UINT32(val));
284 [ # # ]: 0 : if (r < 0)
285 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not append IFLA_BOND_ARP_ALL_TARGETS attribute: %m");
286 : : }
287 : :
288 : 0 : r = sd_netlink_message_close_container(m);
289 [ # # ]: 0 : if (r < 0)
290 [ # # ]: 0 : return log_netdev_error_errno(netdev, r, "Could not close contaniner IFLA_BOND_ARP_IP_TARGET : %m");
291 : : }
292 : :
293 : 0 : return 0;
294 : : }
295 : :
296 : 0 : static int link_set_bond_handler(sd_netlink *rtnl, sd_netlink_message *m, Link *link) {
297 : : int r;
298 : :
299 [ # # ]: 0 : assert(m);
300 [ # # ]: 0 : assert(link);
301 [ # # ]: 0 : assert(link->ifname);
302 : :
303 [ # # # # ]: 0 : if (IN_SET(link->state, LINK_STATE_FAILED, LINK_STATE_LINGER))
304 : 0 : return 1;
305 : :
306 : 0 : r = sd_netlink_message_get_errno(m);
307 [ # # ]: 0 : if (r < 0) {
308 [ # # # # ]: 0 : log_link_warning_errno(link, r, "Could not set bonding interface: %m");
309 : 0 : return 1;
310 : : }
311 : :
312 : 0 : return 1;
313 : : }
314 : :
315 : 0 : int link_set_bond(Link *link) {
316 : 0 : _cleanup_(sd_netlink_message_unrefp) sd_netlink_message *req = NULL;
317 : : int r;
318 : :
319 [ # # ]: 0 : assert(link);
320 [ # # ]: 0 : assert(link->network);
321 : :
322 : 0 : r = sd_rtnl_message_new_link(link->manager->rtnl, &req, RTM_NEWLINK, link->network->bond->ifindex);
323 [ # # ]: 0 : if (r < 0)
324 [ # # # # ]: 0 : return log_link_error_errno(link, r, "Could not allocate RTM_SETLINK message: %m");
325 : :
326 : 0 : r = sd_netlink_message_set_flags(req, NLM_F_REQUEST | NLM_F_ACK);
327 [ # # ]: 0 : if (r < 0)
328 [ # # # # ]: 0 : return log_link_error_errno(link, r, "Could not set netlink flags: %m");
329 : :
330 : 0 : r = sd_netlink_message_open_container(req, IFLA_LINKINFO);
331 [ # # ]: 0 : if (r < 0)
332 [ # # # # ]: 0 : return log_link_error_errno(link, r, "Could not append IFLA_PROTINFO attribute: %m");
333 : :
334 : 0 : r = sd_netlink_message_open_container_union(req, IFLA_INFO_DATA, "bond");
335 [ # # ]: 0 : if (r < 0)
336 [ # # # # ]: 0 : return log_link_error_errno(link, r, "Could not append IFLA_INFO_DATA attribute: %m");
337 : :
338 [ # # ]: 0 : if (link->network->active_slave) {
339 : 0 : r = sd_netlink_message_append_u32(req, IFLA_BOND_ACTIVE_SLAVE, link->ifindex);
340 [ # # ]: 0 : if (r < 0)
341 [ # # # # ]: 0 : return log_link_error_errno(link, r, "Could not append IFLA_BOND_ACTIVE_SLAVE attribute: %m");
342 : : }
343 : :
344 [ # # ]: 0 : if (link->network->primary_slave) {
345 : 0 : r = sd_netlink_message_append_u32(req, IFLA_BOND_PRIMARY, link->ifindex);
346 [ # # ]: 0 : if (r < 0)
347 [ # # # # ]: 0 : return log_link_error_errno(link, r, "Could not append IFLA_BOND_PRIMARY attribute: %m");
348 : : }
349 : :
350 : 0 : r = sd_netlink_message_close_container(req);
351 [ # # ]: 0 : if (r < 0)
352 [ # # # # ]: 0 : return log_link_error_errno(link, r, "Could not append IFLA_LINKINFO attribute: %m");
353 : :
354 : 0 : r = sd_netlink_message_close_container(req);
355 [ # # ]: 0 : if (r < 0)
356 [ # # # # ]: 0 : return log_link_error_errno(link, r, "Could not append IFLA_INFO_DATA attribute: %m");
357 : :
358 : 0 : r = netlink_call_async(link->manager->rtnl, NULL, req, link_set_bond_handler,
359 : : link_netlink_destroy_callback, link);
360 [ # # ]: 0 : if (r < 0)
361 [ # # # # ]: 0 : return log_link_error_errno(link, r, "Could not send rtnetlink message: %m");
362 : :
363 : 0 : link_ref(link);
364 : :
365 : 0 : return r;
366 : : }
367 : :
368 : 0 : int config_parse_arp_ip_target_address(
369 : : const char *unit,
370 : : const char *filename,
371 : : unsigned line,
372 : : const char *section,
373 : : unsigned section_line,
374 : : const char *lvalue,
375 : : int ltype,
376 : : const char *rvalue,
377 : : void *data,
378 : : void *userdata) {
379 : :
380 : 0 : Bond *b = userdata;
381 : : int r;
382 : :
383 [ # # ]: 0 : assert(filename);
384 [ # # ]: 0 : assert(lvalue);
385 [ # # ]: 0 : assert(rvalue);
386 [ # # ]: 0 : assert(data);
387 : :
388 [ # # ]: 0 : if (isempty(rvalue)) {
389 : 0 : b->arp_ip_targets = ordered_set_free(b->arp_ip_targets);
390 : 0 : return 0;
391 : : }
392 : :
393 : 0 : for (;;) {
394 [ # # # ]: 0 : _cleanup_free_ char *n = NULL;
395 : : union in_addr_union ip;
396 : :
397 : 0 : r = extract_first_word(&rvalue, &n, NULL, 0);
398 [ # # ]: 0 : if (r < 0) {
399 [ # # ]: 0 : log_syntax(unit, LOG_ERR, filename, line, r,
400 : : "Failed to parse Bond ARP ip target address, ignoring assignment: %s",
401 : : rvalue);
402 : 0 : return 0;
403 : : }
404 [ # # ]: 0 : if (r == 0)
405 : 0 : return 0;
406 : :
407 : 0 : r = in_addr_from_string(AF_INET, n, &ip);
408 [ # # ]: 0 : if (r < 0) {
409 [ # # ]: 0 : log_syntax(unit, LOG_ERR, filename, line, r,
410 : : "Bond ARP ip target address is invalid, ignoring assignment: %s", n);
411 : 0 : continue;
412 : : }
413 : :
414 : 0 : r = ordered_set_ensure_allocated(&b->arp_ip_targets, NULL);
415 [ # # ]: 0 : if (r < 0)
416 : 0 : return log_oom();
417 : :
418 [ # # ]: 0 : if (ordered_set_size(b->arp_ip_targets) >= NETDEV_BOND_ARP_TARGETS_MAX) {
419 [ # # ]: 0 : log_syntax(unit, LOG_WARNING, filename, line, 0,
420 : : "Too many ARP ip targets are specified. The maximum number is %d. Ignoring assignment: %s",
421 : : NETDEV_BOND_ARP_TARGETS_MAX, n);
422 : 0 : continue;
423 : : }
424 : :
425 : 0 : r = ordered_set_put(b->arp_ip_targets, UINT32_TO_PTR(ip.in.s_addr));
426 [ # # ]: 0 : if (r == -EEXIST)
427 [ # # ]: 0 : log_syntax(unit, LOG_WARNING, filename, line, r,
428 : : "Bond ARP ip target address is duplicated, ignoring assignment: %s", n);
429 [ # # ]: 0 : if (r < 0)
430 [ # # ]: 0 : log_syntax(unit, LOG_ERR, filename, line, r,
431 : : "Failed to store bond ARP ip target address '%s', ignoring assignment: %m", n);
432 : : }
433 : : }
434 : :
435 : 0 : int config_parse_ad_actor_sys_prio(
436 : : const char *unit,
437 : : const char *filename,
438 : : unsigned line,
439 : : const char *section,
440 : : unsigned section_line,
441 : : const char *lvalue,
442 : : int ltype,
443 : : const char *rvalue,
444 : : void *data,
445 : : void *userdata) {
446 : 0 : Bond *b = userdata;
447 : : uint16_t v;
448 : : int r;
449 : :
450 [ # # ]: 0 : assert(filename);
451 [ # # ]: 0 : assert(lvalue);
452 [ # # ]: 0 : assert(rvalue);
453 [ # # ]: 0 : assert(data);
454 : :
455 : 0 : r = safe_atou16(rvalue, &v);
456 [ # # ]: 0 : if (r < 0) {
457 [ # # ]: 0 : log_syntax(unit, LOG_ERR, filename, line, r,
458 : : "Failed to parse actor system priority '%s', ignoring: %m", rvalue);
459 : 0 : return 0;
460 : : }
461 : :
462 [ # # ]: 0 : if (v == 0) {
463 [ # # ]: 0 : log_syntax(unit, LOG_ERR, filename, line, 0,
464 : : "Failed to parse actor system priority '%s'. Range is [1,65535], ignoring.",
465 : : rvalue);
466 : 0 : return 0;
467 : : }
468 : :
469 : 0 : b->ad_actor_sys_prio = v;
470 : :
471 : 0 : return 0;
472 : : }
473 : :
474 : 0 : int config_parse_ad_user_port_key(
475 : : const char *unit,
476 : : const char *filename,
477 : : unsigned line,
478 : : const char *section,
479 : : unsigned section_line,
480 : : const char *lvalue,
481 : : int ltype,
482 : : const char *rvalue,
483 : : void *data,
484 : : void *userdata) {
485 : 0 : Bond *b = userdata;
486 : : uint16_t v;
487 : : int r;
488 : :
489 [ # # ]: 0 : assert(filename);
490 [ # # ]: 0 : assert(lvalue);
491 [ # # ]: 0 : assert(rvalue);
492 [ # # ]: 0 : assert(data);
493 : :
494 : 0 : r = safe_atou16(rvalue, &v);
495 [ # # ]: 0 : if (r < 0) {
496 [ # # ]: 0 : log_syntax(unit, LOG_ERR, filename, line, r,
497 : : "Failed to parse user port key '%s', ignoring: %m", rvalue);
498 : 0 : return 0;
499 : : }
500 : :
501 [ # # ]: 0 : if (v > 1023) {
502 [ # # ]: 0 : log_syntax(unit, LOG_ERR, filename, line, 0,
503 : : "Failed to parse user port key '%s'. Range is [0…1023], ignoring.", rvalue);
504 : 0 : return 0;
505 : : }
506 : :
507 : 0 : b->ad_user_port_key = v;
508 : :
509 : 0 : return 0;
510 : : }
511 : :
512 : 0 : int config_parse_ad_actor_system(
513 : : const char *unit,
514 : : const char *filename,
515 : : unsigned line,
516 : : const char *section,
517 : : unsigned section_line,
518 : : const char *lvalue,
519 : : int ltype,
520 : : const char *rvalue,
521 : : void *data,
522 : : void *userdata) {
523 : 0 : Bond *b = userdata;
524 : : struct ether_addr n;
525 : : int r;
526 : :
527 [ # # ]: 0 : assert(filename);
528 [ # # ]: 0 : assert(lvalue);
529 [ # # ]: 0 : assert(rvalue);
530 [ # # ]: 0 : assert(data);
531 : :
532 : 0 : r = ether_addr_from_string(rvalue, &n);
533 [ # # ]: 0 : if (r < 0) {
534 [ # # ]: 0 : log_syntax(unit, LOG_ERR, filename, line, r,
535 : : "Not a valid MAC address %s. Ignoring assignment: %m",
536 : : rvalue);
537 : 0 : return 0;
538 : : }
539 [ # # # # ]: 0 : if (ether_addr_is_null(&n) || (n.ether_addr_octet[0] & 0x01)) {
540 [ # # ]: 0 : log_syntax(unit, LOG_ERR, filename, line, 0,
541 : : "Not a valid MAC address %s, can not be null or multicast. Ignoring assignment.",
542 : : rvalue);
543 : 0 : return 0;
544 : : }
545 : :
546 : 0 : b->ad_actor_system = n;
547 : :
548 : 0 : return 0;
549 : : }
550 : :
551 : 0 : static void bond_done(NetDev *netdev) {
552 : : Bond *b;
553 : :
554 [ # # ]: 0 : assert(netdev);
555 : 0 : b = BOND(netdev);
556 [ # # ]: 0 : assert(b);
557 : :
558 : 0 : ordered_set_free(b->arp_ip_targets);
559 : 0 : }
560 : :
561 : 0 : static void bond_init(NetDev *netdev) {
562 : : Bond *b;
563 : :
564 [ # # ]: 0 : assert(netdev);
565 : :
566 : 0 : b = BOND(netdev);
567 : :
568 [ # # ]: 0 : assert(b);
569 : :
570 : 0 : b->mode = _NETDEV_BOND_MODE_INVALID;
571 : 0 : b->xmit_hash_policy = _NETDEV_BOND_XMIT_HASH_POLICY_INVALID;
572 : 0 : b->lacp_rate = _NETDEV_BOND_LACP_RATE_INVALID;
573 : 0 : b->ad_select = _NETDEV_BOND_AD_SELECT_INVALID;
574 : 0 : b->fail_over_mac = _NETDEV_BOND_FAIL_OVER_MAC_INVALID;
575 : 0 : b->arp_validate = _NETDEV_BOND_ARP_VALIDATE_INVALID;
576 : 0 : b->arp_all_targets = _NETDEV_BOND_ARP_ALL_TARGETS_INVALID;
577 : 0 : b->primary_reselect = _NETDEV_BOND_PRIMARY_RESELECT_INVALID;
578 : :
579 : 0 : b->all_slaves_active = false;
580 : 0 : b->tlb_dynamic_lb = -1;
581 : :
582 : 0 : b->resend_igmp = RESEND_IGMP_DEFAULT;
583 : 0 : b->packets_per_slave = PACKETS_PER_SLAVE_DEFAULT;
584 : 0 : b->num_grat_arp = GRATUITOUS_ARP_DEFAULT;
585 : 0 : b->lp_interval = LEARNING_PACKETS_INTERVAL_MIN_SEC;
586 : 0 : }
587 : :
588 : : const NetDevVTable bond_vtable = {
589 : : .object_size = sizeof(Bond),
590 : : .init = bond_init,
591 : : .done = bond_done,
592 : : .sections = "Match\0NetDev\0Bond\0",
593 : : .fill_message_create = netdev_bond_fill_message_create,
594 : : .create_type = NETDEV_CREATE_MASTER,
595 : : .generate_mac = true,
596 : : };
|
