xref: /linux/net/switchdev/switchdev.c (revision 8ca07176)
1 // SPDX-License-Identifier: GPL-2.0-or-later
2 /*
3  * net/switchdev/switchdev.c - Switch device API
4  * Copyright (c) 2014-2015 Jiri Pirko <jiri@resnulli.us>
5  * Copyright (c) 2014-2015 Scott Feldman <sfeldma@gmail.com>
6  */
7 
8 #include <linux/kernel.h>
9 #include <linux/types.h>
10 #include <linux/init.h>
11 #include <linux/mutex.h>
12 #include <linux/notifier.h>
13 #include <linux/netdevice.h>
14 #include <linux/etherdevice.h>
15 #include <linux/if_bridge.h>
16 #include <linux/list.h>
17 #include <linux/workqueue.h>
18 #include <linux/if_vlan.h>
19 #include <linux/rtnetlink.h>
20 #include <net/switchdev.h>
21 
22 static LIST_HEAD(deferred);
23 static DEFINE_SPINLOCK(deferred_lock);
24 
25 typedef void switchdev_deferred_func_t(struct net_device *dev,
26 				       const void *data);
27 
28 struct switchdev_deferred_item {
29 	struct list_head list;
30 	struct net_device *dev;
31 	switchdev_deferred_func_t *func;
32 	unsigned long data[];
33 };
34 
35 static struct switchdev_deferred_item *switchdev_deferred_dequeue(void)
36 {
37 	struct switchdev_deferred_item *dfitem;
38 
39 	spin_lock_bh(&deferred_lock);
40 	if (list_empty(&deferred)) {
41 		dfitem = NULL;
42 		goto unlock;
43 	}
44 	dfitem = list_first_entry(&deferred,
45 				  struct switchdev_deferred_item, list);
46 	list_del(&dfitem->list);
47 unlock:
48 	spin_unlock_bh(&deferred_lock);
49 	return dfitem;
50 }
51 
52 /**
53  *	switchdev_deferred_process - Process ops in deferred queue
54  *
55  *	Called to flush the ops currently queued in deferred ops queue.
56  *	rtnl_lock must be held.
57  */
58 void switchdev_deferred_process(void)
59 {
60 	struct switchdev_deferred_item *dfitem;
61 
62 	ASSERT_RTNL();
63 
64 	while ((dfitem = switchdev_deferred_dequeue())) {
65 		dfitem->func(dfitem->dev, dfitem->data);
66 		dev_put(dfitem->dev);
67 		kfree(dfitem);
68 	}
69 }
70 EXPORT_SYMBOL_GPL(switchdev_deferred_process);
71 
72 static void switchdev_deferred_process_work(struct work_struct *work)
73 {
74 	rtnl_lock();
75 	switchdev_deferred_process();
76 	rtnl_unlock();
77 }
78 
79 static DECLARE_WORK(deferred_process_work, switchdev_deferred_process_work);
80 
81 static int switchdev_deferred_enqueue(struct net_device *dev,
82 				      const void *data, size_t data_len,
83 				      switchdev_deferred_func_t *func)
84 {
85 	struct switchdev_deferred_item *dfitem;
86 
87 	dfitem = kmalloc(sizeof(*dfitem) + data_len, GFP_ATOMIC);
88 	if (!dfitem)
89 		return -ENOMEM;
90 	dfitem->dev = dev;
91 	dfitem->func = func;
92 	memcpy(dfitem->data, data, data_len);
93 	dev_hold(dev);
94 	spin_lock_bh(&deferred_lock);
95 	list_add_tail(&dfitem->list, &deferred);
96 	spin_unlock_bh(&deferred_lock);
97 	schedule_work(&deferred_process_work);
98 	return 0;
99 }
100 
101 static int switchdev_port_attr_notify(enum switchdev_notifier_type nt,
102 				      struct net_device *dev,
103 				      const struct switchdev_attr *attr,
104 				      struct netlink_ext_ack *extack)
105 {
106 	int err;
107 	int rc;
108 
109 	struct switchdev_notifier_port_attr_info attr_info = {
110 		.attr = attr,
111 		.handled = false,
112 	};
113 
114 	rc = call_switchdev_blocking_notifiers(nt, dev,
115 					       &attr_info.info, extack);
116 	err = notifier_to_errno(rc);
117 	if (err) {
118 		WARN_ON(!attr_info.handled);
119 		return err;
120 	}
121 
122 	if (!attr_info.handled)
123 		return -EOPNOTSUPP;
124 
125 	return 0;
126 }
127 
128 static int switchdev_port_attr_set_now(struct net_device *dev,
129 				       const struct switchdev_attr *attr,
130 				       struct netlink_ext_ack *extack)
131 {
132 	return switchdev_port_attr_notify(SWITCHDEV_PORT_ATTR_SET, dev, attr,
133 					  extack);
134 }
135 
136 static void switchdev_port_attr_set_deferred(struct net_device *dev,
137 					     const void *data)
138 {
139 	const struct switchdev_attr *attr = data;
140 	int err;
141 
142 	err = switchdev_port_attr_set_now(dev, attr, NULL);
143 	if (err && err != -EOPNOTSUPP)
144 		netdev_err(dev, "failed (err=%d) to set attribute (id=%d)\n",
145 			   err, attr->id);
146 	if (attr->complete)
147 		attr->complete(dev, err, attr->complete_priv);
148 }
149 
150 static int switchdev_port_attr_set_defer(struct net_device *dev,
151 					 const struct switchdev_attr *attr)
152 {
153 	return switchdev_deferred_enqueue(dev, attr, sizeof(*attr),
154 					  switchdev_port_attr_set_deferred);
155 }
156 
157 /**
158  *	switchdev_port_attr_set - Set port attribute
159  *
160  *	@dev: port device
161  *	@attr: attribute to set
162  *	@extack: netlink extended ack, for error message propagation
163  *
164  *	rtnl_lock must be held and must not be in atomic section,
165  *	in case SWITCHDEV_F_DEFER flag is not set.
166  */
167 int switchdev_port_attr_set(struct net_device *dev,
168 			    const struct switchdev_attr *attr,
169 			    struct netlink_ext_ack *extack)
170 {
171 	if (attr->flags & SWITCHDEV_F_DEFER)
172 		return switchdev_port_attr_set_defer(dev, attr);
173 	ASSERT_RTNL();
174 	return switchdev_port_attr_set_now(dev, attr, extack);
175 }
176 EXPORT_SYMBOL_GPL(switchdev_port_attr_set);
177 
178 static size_t switchdev_obj_size(const struct switchdev_obj *obj)
179 {
180 	switch (obj->id) {
181 	case SWITCHDEV_OBJ_ID_PORT_VLAN:
182 		return sizeof(struct switchdev_obj_port_vlan);
183 	case SWITCHDEV_OBJ_ID_PORT_MDB:
184 		return sizeof(struct switchdev_obj_port_mdb);
185 	case SWITCHDEV_OBJ_ID_HOST_MDB:
186 		return sizeof(struct switchdev_obj_port_mdb);
187 	default:
188 		BUG();
189 	}
190 	return 0;
191 }
192 
193 static int switchdev_port_obj_notify(enum switchdev_notifier_type nt,
194 				     struct net_device *dev,
195 				     const struct switchdev_obj *obj,
196 				     struct netlink_ext_ack *extack)
197 {
198 	int rc;
199 	int err;
200 
201 	struct switchdev_notifier_port_obj_info obj_info = {
202 		.obj = obj,
203 		.handled = false,
204 	};
205 
206 	rc = call_switchdev_blocking_notifiers(nt, dev, &obj_info.info, extack);
207 	err = notifier_to_errno(rc);
208 	if (err) {
209 		WARN_ON(!obj_info.handled);
210 		return err;
211 	}
212 	if (!obj_info.handled)
213 		return -EOPNOTSUPP;
214 	return 0;
215 }
216 
217 static void switchdev_port_obj_add_deferred(struct net_device *dev,
218 					    const void *data)
219 {
220 	const struct switchdev_obj *obj = data;
221 	int err;
222 
223 	ASSERT_RTNL();
224 	err = switchdev_port_obj_notify(SWITCHDEV_PORT_OBJ_ADD,
225 					dev, obj, NULL);
226 	if (err && err != -EOPNOTSUPP)
227 		netdev_err(dev, "failed (err=%d) to add object (id=%d)\n",
228 			   err, obj->id);
229 	if (obj->complete)
230 		obj->complete(dev, err, obj->complete_priv);
231 }
232 
233 static int switchdev_port_obj_add_defer(struct net_device *dev,
234 					const struct switchdev_obj *obj)
235 {
236 	return switchdev_deferred_enqueue(dev, obj, switchdev_obj_size(obj),
237 					  switchdev_port_obj_add_deferred);
238 }
239 
240 /**
241  *	switchdev_port_obj_add - Add port object
242  *
243  *	@dev: port device
244  *	@obj: object to add
245  *	@extack: netlink extended ack
246  *
247  *	rtnl_lock must be held and must not be in atomic section,
248  *	in case SWITCHDEV_F_DEFER flag is not set.
249  */
250 int switchdev_port_obj_add(struct net_device *dev,
251 			   const struct switchdev_obj *obj,
252 			   struct netlink_ext_ack *extack)
253 {
254 	if (obj->flags & SWITCHDEV_F_DEFER)
255 		return switchdev_port_obj_add_defer(dev, obj);
256 	ASSERT_RTNL();
257 	return switchdev_port_obj_notify(SWITCHDEV_PORT_OBJ_ADD,
258 					 dev, obj, extack);
259 }
260 EXPORT_SYMBOL_GPL(switchdev_port_obj_add);
261 
262 static int switchdev_port_obj_del_now(struct net_device *dev,
263 				      const struct switchdev_obj *obj)
264 {
265 	return switchdev_port_obj_notify(SWITCHDEV_PORT_OBJ_DEL,
266 					 dev, obj, NULL);
267 }
268 
269 static void switchdev_port_obj_del_deferred(struct net_device *dev,
270 					    const void *data)
271 {
272 	const struct switchdev_obj *obj = data;
273 	int err;
274 
275 	err = switchdev_port_obj_del_now(dev, obj);
276 	if (err && err != -EOPNOTSUPP)
277 		netdev_err(dev, "failed (err=%d) to del object (id=%d)\n",
278 			   err, obj->id);
279 	if (obj->complete)
280 		obj->complete(dev, err, obj->complete_priv);
281 }
282 
283 static int switchdev_port_obj_del_defer(struct net_device *dev,
284 					const struct switchdev_obj *obj)
285 {
286 	return switchdev_deferred_enqueue(dev, obj, switchdev_obj_size(obj),
287 					  switchdev_port_obj_del_deferred);
288 }
289 
290 /**
291  *	switchdev_port_obj_del - Delete port object
292  *
293  *	@dev: port device
294  *	@obj: object to delete
295  *
296  *	rtnl_lock must be held and must not be in atomic section,
297  *	in case SWITCHDEV_F_DEFER flag is not set.
298  */
299 int switchdev_port_obj_del(struct net_device *dev,
300 			   const struct switchdev_obj *obj)
301 {
302 	if (obj->flags & SWITCHDEV_F_DEFER)
303 		return switchdev_port_obj_del_defer(dev, obj);
304 	ASSERT_RTNL();
305 	return switchdev_port_obj_del_now(dev, obj);
306 }
307 EXPORT_SYMBOL_GPL(switchdev_port_obj_del);
308 
309 static ATOMIC_NOTIFIER_HEAD(switchdev_notif_chain);
310 static BLOCKING_NOTIFIER_HEAD(switchdev_blocking_notif_chain);
311 
312 /**
313  *	register_switchdev_notifier - Register notifier
314  *	@nb: notifier_block
315  *
316  *	Register switch device notifier.
317  */
318 int register_switchdev_notifier(struct notifier_block *nb)
319 {
320 	return atomic_notifier_chain_register(&switchdev_notif_chain, nb);
321 }
322 EXPORT_SYMBOL_GPL(register_switchdev_notifier);
323 
324 /**
325  *	unregister_switchdev_notifier - Unregister notifier
326  *	@nb: notifier_block
327  *
328  *	Unregister switch device notifier.
329  */
330 int unregister_switchdev_notifier(struct notifier_block *nb)
331 {
332 	return atomic_notifier_chain_unregister(&switchdev_notif_chain, nb);
333 }
334 EXPORT_SYMBOL_GPL(unregister_switchdev_notifier);
335 
336 /**
337  *	call_switchdev_notifiers - Call notifiers
338  *	@val: value passed unmodified to notifier function
339  *	@dev: port device
340  *	@info: notifier information data
341  *	@extack: netlink extended ack
342  *	Call all network notifier blocks.
343  */
344 int call_switchdev_notifiers(unsigned long val, struct net_device *dev,
345 			     struct switchdev_notifier_info *info,
346 			     struct netlink_ext_ack *extack)
347 {
348 	info->dev = dev;
349 	info->extack = extack;
350 	return atomic_notifier_call_chain(&switchdev_notif_chain, val, info);
351 }
352 EXPORT_SYMBOL_GPL(call_switchdev_notifiers);
353 
354 int register_switchdev_blocking_notifier(struct notifier_block *nb)
355 {
356 	struct blocking_notifier_head *chain = &switchdev_blocking_notif_chain;
357 
358 	return blocking_notifier_chain_register(chain, nb);
359 }
360 EXPORT_SYMBOL_GPL(register_switchdev_blocking_notifier);
361 
362 int unregister_switchdev_blocking_notifier(struct notifier_block *nb)
363 {
364 	struct blocking_notifier_head *chain = &switchdev_blocking_notif_chain;
365 
366 	return blocking_notifier_chain_unregister(chain, nb);
367 }
368 EXPORT_SYMBOL_GPL(unregister_switchdev_blocking_notifier);
369 
370 int call_switchdev_blocking_notifiers(unsigned long val, struct net_device *dev,
371 				      struct switchdev_notifier_info *info,
372 				      struct netlink_ext_ack *extack)
373 {
374 	info->dev = dev;
375 	info->extack = extack;
376 	return blocking_notifier_call_chain(&switchdev_blocking_notif_chain,
377 					    val, info);
378 }
379 EXPORT_SYMBOL_GPL(call_switchdev_blocking_notifiers);
380 
381 static int __switchdev_handle_fdb_add_to_device(struct net_device *dev,
382 		const struct net_device *orig_dev,
383 		const struct switchdev_notifier_fdb_info *fdb_info,
384 		bool (*check_cb)(const struct net_device *dev),
385 		bool (*foreign_dev_check_cb)(const struct net_device *dev,
386 					     const struct net_device *foreign_dev),
387 		int (*add_cb)(struct net_device *dev,
388 			      const struct net_device *orig_dev, const void *ctx,
389 			      const struct switchdev_notifier_fdb_info *fdb_info),
390 		int (*lag_add_cb)(struct net_device *dev,
391 				  const struct net_device *orig_dev, const void *ctx,
392 				  const struct switchdev_notifier_fdb_info *fdb_info))
393 {
394 	const struct switchdev_notifier_info *info = &fdb_info->info;
395 	struct net_device *lower_dev;
396 	struct list_head *iter;
397 	int err = -EOPNOTSUPP;
398 
399 	if (check_cb(dev)) {
400 		/* Handle FDB entries on foreign interfaces as FDB entries
401 		 * towards the software bridge.
402 		 */
403 		if (foreign_dev_check_cb && foreign_dev_check_cb(dev, orig_dev)) {
404 			struct net_device *br = netdev_master_upper_dev_get_rcu(dev);
405 
406 			if (!br || !netif_is_bridge_master(br))
407 				return 0;
408 
409 			/* No point in handling FDB entries on a foreign bridge */
410 			if (foreign_dev_check_cb(dev, br))
411 				return 0;
412 
413 			return __switchdev_handle_fdb_add_to_device(br, orig_dev,
414 								    fdb_info, check_cb,
415 								    foreign_dev_check_cb,
416 								    add_cb, lag_add_cb);
417 		}
418 
419 		return add_cb(dev, orig_dev, info->ctx, fdb_info);
420 	}
421 
422 	/* If we passed over the foreign check, it means that the LAG interface
423 	 * is offloaded.
424 	 */
425 	if (netif_is_lag_master(dev)) {
426 		if (!lag_add_cb)
427 			return -EOPNOTSUPP;
428 
429 		return lag_add_cb(dev, orig_dev, info->ctx, fdb_info);
430 	}
431 
432 	/* Recurse through lower interfaces in case the FDB entry is pointing
433 	 * towards a bridge device.
434 	 */
435 	netdev_for_each_lower_dev(dev, lower_dev, iter) {
436 		/* Do not propagate FDB entries across bridges */
437 		if (netif_is_bridge_master(lower_dev))
438 			continue;
439 
440 		err = __switchdev_handle_fdb_add_to_device(lower_dev, orig_dev,
441 							   fdb_info, check_cb,
442 							   foreign_dev_check_cb,
443 							   add_cb, lag_add_cb);
444 		if (err && err != -EOPNOTSUPP)
445 			return err;
446 	}
447 
448 	return err;
449 }
450 
451 int switchdev_handle_fdb_add_to_device(struct net_device *dev,
452 		const struct switchdev_notifier_fdb_info *fdb_info,
453 		bool (*check_cb)(const struct net_device *dev),
454 		bool (*foreign_dev_check_cb)(const struct net_device *dev,
455 					     const struct net_device *foreign_dev),
456 		int (*add_cb)(struct net_device *dev,
457 			      const struct net_device *orig_dev, const void *ctx,
458 			      const struct switchdev_notifier_fdb_info *fdb_info),
459 		int (*lag_add_cb)(struct net_device *dev,
460 				  const struct net_device *orig_dev, const void *ctx,
461 				  const struct switchdev_notifier_fdb_info *fdb_info))
462 {
463 	int err;
464 
465 	err = __switchdev_handle_fdb_add_to_device(dev, dev, fdb_info,
466 						   check_cb,
467 						   foreign_dev_check_cb,
468 						   add_cb, lag_add_cb);
469 	if (err == -EOPNOTSUPP)
470 		err = 0;
471 
472 	return err;
473 }
474 EXPORT_SYMBOL_GPL(switchdev_handle_fdb_add_to_device);
475 
476 static int __switchdev_handle_fdb_del_to_device(struct net_device *dev,
477 		const struct net_device *orig_dev,
478 		const struct switchdev_notifier_fdb_info *fdb_info,
479 		bool (*check_cb)(const struct net_device *dev),
480 		bool (*foreign_dev_check_cb)(const struct net_device *dev,
481 					     const struct net_device *foreign_dev),
482 		int (*del_cb)(struct net_device *dev,
483 			      const struct net_device *orig_dev, const void *ctx,
484 			      const struct switchdev_notifier_fdb_info *fdb_info),
485 		int (*lag_del_cb)(struct net_device *dev,
486 				  const struct net_device *orig_dev, const void *ctx,
487 				  const struct switchdev_notifier_fdb_info *fdb_info))
488 {
489 	const struct switchdev_notifier_info *info = &fdb_info->info;
490 	struct net_device *lower_dev;
491 	struct list_head *iter;
492 	int err = -EOPNOTSUPP;
493 
494 	if (check_cb(dev)) {
495 		/* Handle FDB entries on foreign interfaces as FDB entries
496 		 * towards the software bridge.
497 		 */
498 		if (foreign_dev_check_cb && foreign_dev_check_cb(dev, orig_dev)) {
499 			struct net_device *br = netdev_master_upper_dev_get_rcu(dev);
500 
501 			if (!br || !netif_is_bridge_master(br))
502 				return 0;
503 
504 			/* No point in handling FDB entries on a foreign bridge */
505 			if (foreign_dev_check_cb(dev, br))
506 				return 0;
507 
508 			return __switchdev_handle_fdb_del_to_device(br, orig_dev,
509 								    fdb_info, check_cb,
510 								    foreign_dev_check_cb,
511 								    del_cb, lag_del_cb);
512 		}
513 
514 		return del_cb(dev, orig_dev, info->ctx, fdb_info);
515 	}
516 
517 	/* If we passed over the foreign check, it means that the LAG interface
518 	 * is offloaded.
519 	 */
520 	if (netif_is_lag_master(dev)) {
521 		if (!lag_del_cb)
522 			return -EOPNOTSUPP;
523 
524 		return lag_del_cb(dev, orig_dev, info->ctx, fdb_info);
525 	}
526 
527 	/* Recurse through lower interfaces in case the FDB entry is pointing
528 	 * towards a bridge device.
529 	 */
530 	netdev_for_each_lower_dev(dev, lower_dev, iter) {
531 		/* Do not propagate FDB entries across bridges */
532 		if (netif_is_bridge_master(lower_dev))
533 			continue;
534 
535 		err = switchdev_handle_fdb_del_to_device(lower_dev, fdb_info,
536 							 check_cb,
537 							 foreign_dev_check_cb,
538 							 del_cb, lag_del_cb);
539 		if (err && err != -EOPNOTSUPP)
540 			return err;
541 	}
542 
543 	return err;
544 }
545 
546 int switchdev_handle_fdb_del_to_device(struct net_device *dev,
547 		const struct switchdev_notifier_fdb_info *fdb_info,
548 		bool (*check_cb)(const struct net_device *dev),
549 		bool (*foreign_dev_check_cb)(const struct net_device *dev,
550 					     const struct net_device *foreign_dev),
551 		int (*del_cb)(struct net_device *dev,
552 			      const struct net_device *orig_dev, const void *ctx,
553 			      const struct switchdev_notifier_fdb_info *fdb_info),
554 		int (*lag_del_cb)(struct net_device *dev,
555 				  const struct net_device *orig_dev, const void *ctx,
556 				  const struct switchdev_notifier_fdb_info *fdb_info))
557 {
558 	int err;
559 
560 	err = __switchdev_handle_fdb_del_to_device(dev, dev, fdb_info,
561 						   check_cb,
562 						   foreign_dev_check_cb,
563 						   del_cb, lag_del_cb);
564 	if (err == -EOPNOTSUPP)
565 		err = 0;
566 
567 	return err;
568 }
569 EXPORT_SYMBOL_GPL(switchdev_handle_fdb_del_to_device);
570 
571 static int __switchdev_handle_port_obj_add(struct net_device *dev,
572 			struct switchdev_notifier_port_obj_info *port_obj_info,
573 			bool (*check_cb)(const struct net_device *dev),
574 			int (*add_cb)(struct net_device *dev, const void *ctx,
575 				      const struct switchdev_obj *obj,
576 				      struct netlink_ext_ack *extack))
577 {
578 	struct switchdev_notifier_info *info = &port_obj_info->info;
579 	struct netlink_ext_ack *extack;
580 	struct net_device *lower_dev;
581 	struct list_head *iter;
582 	int err = -EOPNOTSUPP;
583 
584 	extack = switchdev_notifier_info_to_extack(info);
585 
586 	if (check_cb(dev)) {
587 		err = add_cb(dev, info->ctx, port_obj_info->obj, extack);
588 		if (err != -EOPNOTSUPP)
589 			port_obj_info->handled = true;
590 		return err;
591 	}
592 
593 	/* Switch ports might be stacked under e.g. a LAG. Ignore the
594 	 * unsupported devices, another driver might be able to handle them. But
595 	 * propagate to the callers any hard errors.
596 	 *
597 	 * If the driver does its own bookkeeping of stacked ports, it's not
598 	 * necessary to go through this helper.
599 	 */
600 	netdev_for_each_lower_dev(dev, lower_dev, iter) {
601 		if (netif_is_bridge_master(lower_dev))
602 			continue;
603 
604 		err = __switchdev_handle_port_obj_add(lower_dev, port_obj_info,
605 						      check_cb, add_cb);
606 		if (err && err != -EOPNOTSUPP)
607 			return err;
608 	}
609 
610 	return err;
611 }
612 
613 int switchdev_handle_port_obj_add(struct net_device *dev,
614 			struct switchdev_notifier_port_obj_info *port_obj_info,
615 			bool (*check_cb)(const struct net_device *dev),
616 			int (*add_cb)(struct net_device *dev, const void *ctx,
617 				      const struct switchdev_obj *obj,
618 				      struct netlink_ext_ack *extack))
619 {
620 	int err;
621 
622 	err = __switchdev_handle_port_obj_add(dev, port_obj_info, check_cb,
623 					      add_cb);
624 	if (err == -EOPNOTSUPP)
625 		err = 0;
626 	return err;
627 }
628 EXPORT_SYMBOL_GPL(switchdev_handle_port_obj_add);
629 
630 static int __switchdev_handle_port_obj_del(struct net_device *dev,
631 			struct switchdev_notifier_port_obj_info *port_obj_info,
632 			bool (*check_cb)(const struct net_device *dev),
633 			int (*del_cb)(struct net_device *dev, const void *ctx,
634 				      const struct switchdev_obj *obj))
635 {
636 	struct switchdev_notifier_info *info = &port_obj_info->info;
637 	struct net_device *lower_dev;
638 	struct list_head *iter;
639 	int err = -EOPNOTSUPP;
640 
641 	if (check_cb(dev)) {
642 		err = del_cb(dev, info->ctx, port_obj_info->obj);
643 		if (err != -EOPNOTSUPP)
644 			port_obj_info->handled = true;
645 		return err;
646 	}
647 
648 	/* Switch ports might be stacked under e.g. a LAG. Ignore the
649 	 * unsupported devices, another driver might be able to handle them. But
650 	 * propagate to the callers any hard errors.
651 	 *
652 	 * If the driver does its own bookkeeping of stacked ports, it's not
653 	 * necessary to go through this helper.
654 	 */
655 	netdev_for_each_lower_dev(dev, lower_dev, iter) {
656 		if (netif_is_bridge_master(lower_dev))
657 			continue;
658 
659 		err = __switchdev_handle_port_obj_del(lower_dev, port_obj_info,
660 						      check_cb, del_cb);
661 		if (err && err != -EOPNOTSUPP)
662 			return err;
663 	}
664 
665 	return err;
666 }
667 
668 int switchdev_handle_port_obj_del(struct net_device *dev,
669 			struct switchdev_notifier_port_obj_info *port_obj_info,
670 			bool (*check_cb)(const struct net_device *dev),
671 			int (*del_cb)(struct net_device *dev, const void *ctx,
672 				      const struct switchdev_obj *obj))
673 {
674 	int err;
675 
676 	err = __switchdev_handle_port_obj_del(dev, port_obj_info, check_cb,
677 					      del_cb);
678 	if (err == -EOPNOTSUPP)
679 		err = 0;
680 	return err;
681 }
682 EXPORT_SYMBOL_GPL(switchdev_handle_port_obj_del);
683 
684 static int __switchdev_handle_port_attr_set(struct net_device *dev,
685 			struct switchdev_notifier_port_attr_info *port_attr_info,
686 			bool (*check_cb)(const struct net_device *dev),
687 			int (*set_cb)(struct net_device *dev, const void *ctx,
688 				      const struct switchdev_attr *attr,
689 				      struct netlink_ext_ack *extack))
690 {
691 	struct switchdev_notifier_info *info = &port_attr_info->info;
692 	struct netlink_ext_ack *extack;
693 	struct net_device *lower_dev;
694 	struct list_head *iter;
695 	int err = -EOPNOTSUPP;
696 
697 	extack = switchdev_notifier_info_to_extack(info);
698 
699 	if (check_cb(dev)) {
700 		err = set_cb(dev, info->ctx, port_attr_info->attr, extack);
701 		if (err != -EOPNOTSUPP)
702 			port_attr_info->handled = true;
703 		return err;
704 	}
705 
706 	/* Switch ports might be stacked under e.g. a LAG. Ignore the
707 	 * unsupported devices, another driver might be able to handle them. But
708 	 * propagate to the callers any hard errors.
709 	 *
710 	 * If the driver does its own bookkeeping of stacked ports, it's not
711 	 * necessary to go through this helper.
712 	 */
713 	netdev_for_each_lower_dev(dev, lower_dev, iter) {
714 		if (netif_is_bridge_master(lower_dev))
715 			continue;
716 
717 		err = __switchdev_handle_port_attr_set(lower_dev, port_attr_info,
718 						       check_cb, set_cb);
719 		if (err && err != -EOPNOTSUPP)
720 			return err;
721 	}
722 
723 	return err;
724 }
725 
726 int switchdev_handle_port_attr_set(struct net_device *dev,
727 			struct switchdev_notifier_port_attr_info *port_attr_info,
728 			bool (*check_cb)(const struct net_device *dev),
729 			int (*set_cb)(struct net_device *dev, const void *ctx,
730 				      const struct switchdev_attr *attr,
731 				      struct netlink_ext_ack *extack))
732 {
733 	int err;
734 
735 	err = __switchdev_handle_port_attr_set(dev, port_attr_info, check_cb,
736 					       set_cb);
737 	if (err == -EOPNOTSUPP)
738 		err = 0;
739 	return err;
740 }
741 EXPORT_SYMBOL_GPL(switchdev_handle_port_attr_set);
742