1 /*
2  * drivers/net/ethernet/mellanox/mlxsw/spectrum_switchdev.c
3  * Copyright (c) 2015 Mellanox Technologies. All rights reserved.
4  * Copyright (c) 2015 Jiri Pirko <jiri@mellanox.com>
5  * Copyright (c) 2015 Ido Schimmel <idosch@mellanox.com>
6  * Copyright (c) 2015 Elad Raz <eladr@mellanox.com>
7  *
8  * Redistribution and use in source and binary forms, with or without
9  * modification, are permitted provided that the following conditions are met:
10  *
11  * 1. Redistributions of source code must retain the above copyright
12  *    notice, this list of conditions and the following disclaimer.
13  * 2. Redistributions in binary form must reproduce the above copyright
14  *    notice, this list of conditions and the following disclaimer in the
15  *    documentation and/or other materials provided with the distribution.
16  * 3. Neither the names of the copyright holders nor the names of its
17  *    contributors may be used to endorse or promote products derived from
18  *    this software without specific prior written permission.
19  *
20  * Alternatively, this software may be distributed under the terms of the
21  * GNU General Public License ("GPL") version 2 as published by the Free
22  * Software Foundation.
23  *
24  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
25  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
26  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
27  * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
28  * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
29  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
30  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
31  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
32  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
33  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
34  * POSSIBILITY OF SUCH DAMAGE.
35  */
36 
37 #include <linux/kernel.h>
38 #include <linux/types.h>
39 #include <linux/netdevice.h>
40 #include <linux/etherdevice.h>
41 #include <linux/slab.h>
42 #include <linux/device.h>
43 #include <linux/skbuff.h>
44 #include <linux/if_vlan.h>
45 #include <linux/if_bridge.h>
46 #include <linux/workqueue.h>
47 #include <linux/jiffies.h>
48 #include <linux/rtnetlink.h>
49 #include <linux/netlink.h>
50 #include <net/switchdev.h>
51 
52 #include "spectrum_span.h"
53 #include "spectrum_router.h"
54 #include "spectrum_switchdev.h"
55 #include "spectrum.h"
56 #include "core.h"
57 #include "reg.h"
58 
59 struct mlxsw_sp_bridge_ops;
60 
61 struct mlxsw_sp_bridge {
62 	struct mlxsw_sp *mlxsw_sp;
63 	struct {
64 		struct delayed_work dw;
65 #define MLXSW_SP_DEFAULT_LEARNING_INTERVAL 100
66 		unsigned int interval; /* ms */
67 	} fdb_notify;
68 #define MLXSW_SP_MIN_AGEING_TIME 10
69 #define MLXSW_SP_MAX_AGEING_TIME 1000000
70 #define MLXSW_SP_DEFAULT_AGEING_TIME 300
71 	u32 ageing_time;
72 	bool vlan_enabled_exists;
73 	struct list_head bridges_list;
74 	DECLARE_BITMAP(mids_bitmap, MLXSW_SP_MID_MAX);
75 	const struct mlxsw_sp_bridge_ops *bridge_8021q_ops;
76 	const struct mlxsw_sp_bridge_ops *bridge_8021d_ops;
77 };
78 
79 struct mlxsw_sp_bridge_device {
80 	struct net_device *dev;
81 	struct list_head list;
82 	struct list_head ports_list;
83 	struct list_head mids_list;
84 	u8 vlan_enabled:1,
85 	   multicast_enabled:1,
86 	   mrouter:1;
87 	const struct mlxsw_sp_bridge_ops *ops;
88 };
89 
90 struct mlxsw_sp_bridge_port {
91 	struct net_device *dev;
92 	struct mlxsw_sp_bridge_device *bridge_device;
93 	struct list_head list;
94 	struct list_head vlans_list;
95 	unsigned int ref_count;
96 	u8 stp_state;
97 	unsigned long flags;
98 	bool mrouter;
99 	bool lagged;
100 	union {
101 		u16 lag_id;
102 		u16 system_port;
103 	};
104 };
105 
106 struct mlxsw_sp_bridge_vlan {
107 	struct list_head list;
108 	struct list_head port_vlan_list;
109 	u16 vid;
110 };
111 
112 struct mlxsw_sp_bridge_ops {
113 	int (*port_join)(struct mlxsw_sp_bridge_device *bridge_device,
114 			 struct mlxsw_sp_bridge_port *bridge_port,
115 			 struct mlxsw_sp_port *mlxsw_sp_port,
116 			 struct netlink_ext_ack *extack);
117 	void (*port_leave)(struct mlxsw_sp_bridge_device *bridge_device,
118 			   struct mlxsw_sp_bridge_port *bridge_port,
119 			   struct mlxsw_sp_port *mlxsw_sp_port);
120 	struct mlxsw_sp_fid *
121 		(*fid_get)(struct mlxsw_sp_bridge_device *bridge_device,
122 			   u16 vid);
123 };
124 
125 static int
126 mlxsw_sp_bridge_port_fdb_flush(struct mlxsw_sp *mlxsw_sp,
127 			       struct mlxsw_sp_bridge_port *bridge_port,
128 			       u16 fid_index);
129 
130 static void
131 mlxsw_sp_bridge_port_mdb_flush(struct mlxsw_sp_port *mlxsw_sp_port,
132 			       struct mlxsw_sp_bridge_port *bridge_port);
133 
134 static void
135 mlxsw_sp_bridge_mdb_mc_enable_sync(struct mlxsw_sp_port *mlxsw_sp_port,
136 				   struct mlxsw_sp_bridge_device
137 				   *bridge_device);
138 
139 static void
140 mlxsw_sp_port_mrouter_update_mdb(struct mlxsw_sp_port *mlxsw_sp_port,
141 				 struct mlxsw_sp_bridge_port *bridge_port,
142 				 bool add);
143 
144 static struct mlxsw_sp_bridge_device *
145 mlxsw_sp_bridge_device_find(const struct mlxsw_sp_bridge *bridge,
146 			    const struct net_device *br_dev)
147 {
148 	struct mlxsw_sp_bridge_device *bridge_device;
149 
150 	list_for_each_entry(bridge_device, &bridge->bridges_list, list)
151 		if (bridge_device->dev == br_dev)
152 			return bridge_device;
153 
154 	return NULL;
155 }
156 
157 bool mlxsw_sp_bridge_device_is_offloaded(const struct mlxsw_sp *mlxsw_sp,
158 					 const struct net_device *br_dev)
159 {
160 	return !!mlxsw_sp_bridge_device_find(mlxsw_sp->bridge, br_dev);
161 }
162 
163 static struct mlxsw_sp_bridge_device *
164 mlxsw_sp_bridge_device_create(struct mlxsw_sp_bridge *bridge,
165 			      struct net_device *br_dev)
166 {
167 	struct device *dev = bridge->mlxsw_sp->bus_info->dev;
168 	struct mlxsw_sp_bridge_device *bridge_device;
169 	bool vlan_enabled = br_vlan_enabled(br_dev);
170 
171 	if (vlan_enabled && bridge->vlan_enabled_exists) {
172 		dev_err(dev, "Only one VLAN-aware bridge is supported\n");
173 		return ERR_PTR(-EINVAL);
174 	}
175 
176 	bridge_device = kzalloc(sizeof(*bridge_device), GFP_KERNEL);
177 	if (!bridge_device)
178 		return ERR_PTR(-ENOMEM);
179 
180 	bridge_device->dev = br_dev;
181 	bridge_device->vlan_enabled = vlan_enabled;
182 	bridge_device->multicast_enabled = br_multicast_enabled(br_dev);
183 	bridge_device->mrouter = br_multicast_router(br_dev);
184 	INIT_LIST_HEAD(&bridge_device->ports_list);
185 	if (vlan_enabled) {
186 		bridge->vlan_enabled_exists = true;
187 		bridge_device->ops = bridge->bridge_8021q_ops;
188 	} else {
189 		bridge_device->ops = bridge->bridge_8021d_ops;
190 	}
191 	INIT_LIST_HEAD(&bridge_device->mids_list);
192 	list_add(&bridge_device->list, &bridge->bridges_list);
193 
194 	return bridge_device;
195 }
196 
197 static void
198 mlxsw_sp_bridge_device_destroy(struct mlxsw_sp_bridge *bridge,
199 			       struct mlxsw_sp_bridge_device *bridge_device)
200 {
201 	list_del(&bridge_device->list);
202 	if (bridge_device->vlan_enabled)
203 		bridge->vlan_enabled_exists = false;
204 	WARN_ON(!list_empty(&bridge_device->ports_list));
205 	WARN_ON(!list_empty(&bridge_device->mids_list));
206 	kfree(bridge_device);
207 }
208 
209 static struct mlxsw_sp_bridge_device *
210 mlxsw_sp_bridge_device_get(struct mlxsw_sp_bridge *bridge,
211 			   struct net_device *br_dev)
212 {
213 	struct mlxsw_sp_bridge_device *bridge_device;
214 
215 	bridge_device = mlxsw_sp_bridge_device_find(bridge, br_dev);
216 	if (bridge_device)
217 		return bridge_device;
218 
219 	return mlxsw_sp_bridge_device_create(bridge, br_dev);
220 }
221 
222 static void
223 mlxsw_sp_bridge_device_put(struct mlxsw_sp_bridge *bridge,
224 			   struct mlxsw_sp_bridge_device *bridge_device)
225 {
226 	if (list_empty(&bridge_device->ports_list))
227 		mlxsw_sp_bridge_device_destroy(bridge, bridge_device);
228 }
229 
230 static struct mlxsw_sp_bridge_port *
231 __mlxsw_sp_bridge_port_find(const struct mlxsw_sp_bridge_device *bridge_device,
232 			    const struct net_device *brport_dev)
233 {
234 	struct mlxsw_sp_bridge_port *bridge_port;
235 
236 	list_for_each_entry(bridge_port, &bridge_device->ports_list, list) {
237 		if (bridge_port->dev == brport_dev)
238 			return bridge_port;
239 	}
240 
241 	return NULL;
242 }
243 
244 struct mlxsw_sp_bridge_port *
245 mlxsw_sp_bridge_port_find(struct mlxsw_sp_bridge *bridge,
246 			  struct net_device *brport_dev)
247 {
248 	struct net_device *br_dev = netdev_master_upper_dev_get(brport_dev);
249 	struct mlxsw_sp_bridge_device *bridge_device;
250 
251 	if (!br_dev)
252 		return NULL;
253 
254 	bridge_device = mlxsw_sp_bridge_device_find(bridge, br_dev);
255 	if (!bridge_device)
256 		return NULL;
257 
258 	return __mlxsw_sp_bridge_port_find(bridge_device, brport_dev);
259 }
260 
261 static struct mlxsw_sp_bridge_port *
262 mlxsw_sp_bridge_port_create(struct mlxsw_sp_bridge_device *bridge_device,
263 			    struct net_device *brport_dev)
264 {
265 	struct mlxsw_sp_bridge_port *bridge_port;
266 	struct mlxsw_sp_port *mlxsw_sp_port;
267 
268 	bridge_port = kzalloc(sizeof(*bridge_port), GFP_KERNEL);
269 	if (!bridge_port)
270 		return NULL;
271 
272 	mlxsw_sp_port = mlxsw_sp_port_dev_lower_find(brport_dev);
273 	bridge_port->lagged = mlxsw_sp_port->lagged;
274 	if (bridge_port->lagged)
275 		bridge_port->lag_id = mlxsw_sp_port->lag_id;
276 	else
277 		bridge_port->system_port = mlxsw_sp_port->local_port;
278 	bridge_port->dev = brport_dev;
279 	bridge_port->bridge_device = bridge_device;
280 	bridge_port->stp_state = BR_STATE_DISABLED;
281 	bridge_port->flags = BR_LEARNING | BR_FLOOD | BR_LEARNING_SYNC |
282 			     BR_MCAST_FLOOD;
283 	INIT_LIST_HEAD(&bridge_port->vlans_list);
284 	list_add(&bridge_port->list, &bridge_device->ports_list);
285 	bridge_port->ref_count = 1;
286 
287 	return bridge_port;
288 }
289 
290 static void
291 mlxsw_sp_bridge_port_destroy(struct mlxsw_sp_bridge_port *bridge_port)
292 {
293 	list_del(&bridge_port->list);
294 	WARN_ON(!list_empty(&bridge_port->vlans_list));
295 	kfree(bridge_port);
296 }
297 
298 static bool
299 mlxsw_sp_bridge_port_should_destroy(const struct mlxsw_sp_bridge_port *
300 				    bridge_port)
301 {
302 	struct mlxsw_sp *mlxsw_sp = mlxsw_sp_lower_get(bridge_port->dev);
303 
304 	/* In case ports were pulled from out of a bridged LAG, then
305 	 * it's possible the reference count isn't zero, yet the bridge
306 	 * port should be destroyed, as it's no longer an upper of ours.
307 	 */
308 	if (!mlxsw_sp && list_empty(&bridge_port->vlans_list))
309 		return true;
310 	else if (bridge_port->ref_count == 0)
311 		return true;
312 	else
313 		return false;
314 }
315 
316 static struct mlxsw_sp_bridge_port *
317 mlxsw_sp_bridge_port_get(struct mlxsw_sp_bridge *bridge,
318 			 struct net_device *brport_dev)
319 {
320 	struct net_device *br_dev = netdev_master_upper_dev_get(brport_dev);
321 	struct mlxsw_sp_bridge_device *bridge_device;
322 	struct mlxsw_sp_bridge_port *bridge_port;
323 	int err;
324 
325 	bridge_port = mlxsw_sp_bridge_port_find(bridge, brport_dev);
326 	if (bridge_port) {
327 		bridge_port->ref_count++;
328 		return bridge_port;
329 	}
330 
331 	bridge_device = mlxsw_sp_bridge_device_get(bridge, br_dev);
332 	if (IS_ERR(bridge_device))
333 		return ERR_CAST(bridge_device);
334 
335 	bridge_port = mlxsw_sp_bridge_port_create(bridge_device, brport_dev);
336 	if (!bridge_port) {
337 		err = -ENOMEM;
338 		goto err_bridge_port_create;
339 	}
340 
341 	return bridge_port;
342 
343 err_bridge_port_create:
344 	mlxsw_sp_bridge_device_put(bridge, bridge_device);
345 	return ERR_PTR(err);
346 }
347 
348 static void mlxsw_sp_bridge_port_put(struct mlxsw_sp_bridge *bridge,
349 				     struct mlxsw_sp_bridge_port *bridge_port)
350 {
351 	struct mlxsw_sp_bridge_device *bridge_device;
352 
353 	bridge_port->ref_count--;
354 	if (!mlxsw_sp_bridge_port_should_destroy(bridge_port))
355 		return;
356 	bridge_device = bridge_port->bridge_device;
357 	mlxsw_sp_bridge_port_destroy(bridge_port);
358 	mlxsw_sp_bridge_device_put(bridge, bridge_device);
359 }
360 
361 static struct mlxsw_sp_port_vlan *
362 mlxsw_sp_port_vlan_find_by_bridge(struct mlxsw_sp_port *mlxsw_sp_port,
363 				  const struct mlxsw_sp_bridge_device *
364 				  bridge_device,
365 				  u16 vid)
366 {
367 	struct mlxsw_sp_port_vlan *mlxsw_sp_port_vlan;
368 
369 	list_for_each_entry(mlxsw_sp_port_vlan, &mlxsw_sp_port->vlans_list,
370 			    list) {
371 		if (!mlxsw_sp_port_vlan->bridge_port)
372 			continue;
373 		if (mlxsw_sp_port_vlan->bridge_port->bridge_device !=
374 		    bridge_device)
375 			continue;
376 		if (bridge_device->vlan_enabled &&
377 		    mlxsw_sp_port_vlan->vid != vid)
378 			continue;
379 		return mlxsw_sp_port_vlan;
380 	}
381 
382 	return NULL;
383 }
384 
385 static struct mlxsw_sp_port_vlan*
386 mlxsw_sp_port_vlan_find_by_fid(struct mlxsw_sp_port *mlxsw_sp_port,
387 			       u16 fid_index)
388 {
389 	struct mlxsw_sp_port_vlan *mlxsw_sp_port_vlan;
390 
391 	list_for_each_entry(mlxsw_sp_port_vlan, &mlxsw_sp_port->vlans_list,
392 			    list) {
393 		struct mlxsw_sp_fid *fid = mlxsw_sp_port_vlan->fid;
394 
395 		if (fid && mlxsw_sp_fid_index(fid) == fid_index)
396 			return mlxsw_sp_port_vlan;
397 	}
398 
399 	return NULL;
400 }
401 
402 static struct mlxsw_sp_bridge_vlan *
403 mlxsw_sp_bridge_vlan_find(const struct mlxsw_sp_bridge_port *bridge_port,
404 			  u16 vid)
405 {
406 	struct mlxsw_sp_bridge_vlan *bridge_vlan;
407 
408 	list_for_each_entry(bridge_vlan, &bridge_port->vlans_list, list) {
409 		if (bridge_vlan->vid == vid)
410 			return bridge_vlan;
411 	}
412 
413 	return NULL;
414 }
415 
416 static struct mlxsw_sp_bridge_vlan *
417 mlxsw_sp_bridge_vlan_create(struct mlxsw_sp_bridge_port *bridge_port, u16 vid)
418 {
419 	struct mlxsw_sp_bridge_vlan *bridge_vlan;
420 
421 	bridge_vlan = kzalloc(sizeof(*bridge_vlan), GFP_KERNEL);
422 	if (!bridge_vlan)
423 		return NULL;
424 
425 	INIT_LIST_HEAD(&bridge_vlan->port_vlan_list);
426 	bridge_vlan->vid = vid;
427 	list_add(&bridge_vlan->list, &bridge_port->vlans_list);
428 
429 	return bridge_vlan;
430 }
431 
432 static void
433 mlxsw_sp_bridge_vlan_destroy(struct mlxsw_sp_bridge_vlan *bridge_vlan)
434 {
435 	list_del(&bridge_vlan->list);
436 	WARN_ON(!list_empty(&bridge_vlan->port_vlan_list));
437 	kfree(bridge_vlan);
438 }
439 
440 static struct mlxsw_sp_bridge_vlan *
441 mlxsw_sp_bridge_vlan_get(struct mlxsw_sp_bridge_port *bridge_port, u16 vid)
442 {
443 	struct mlxsw_sp_bridge_vlan *bridge_vlan;
444 
445 	bridge_vlan = mlxsw_sp_bridge_vlan_find(bridge_port, vid);
446 	if (bridge_vlan)
447 		return bridge_vlan;
448 
449 	return mlxsw_sp_bridge_vlan_create(bridge_port, vid);
450 }
451 
452 static void mlxsw_sp_bridge_vlan_put(struct mlxsw_sp_bridge_vlan *bridge_vlan)
453 {
454 	if (list_empty(&bridge_vlan->port_vlan_list))
455 		mlxsw_sp_bridge_vlan_destroy(bridge_vlan);
456 }
457 
458 static void mlxsw_sp_port_bridge_flags_get(struct mlxsw_sp_bridge *bridge,
459 					   struct net_device *dev,
460 					   unsigned long *brport_flags)
461 {
462 	struct mlxsw_sp_bridge_port *bridge_port;
463 
464 	bridge_port = mlxsw_sp_bridge_port_find(bridge, dev);
465 	if (WARN_ON(!bridge_port))
466 		return;
467 
468 	memcpy(brport_flags, &bridge_port->flags, sizeof(*brport_flags));
469 }
470 
471 static int mlxsw_sp_port_attr_get(struct net_device *dev,
472 				  struct switchdev_attr *attr)
473 {
474 	struct mlxsw_sp_port *mlxsw_sp_port = netdev_priv(dev);
475 	struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
476 
477 	switch (attr->id) {
478 	case SWITCHDEV_ATTR_ID_PORT_PARENT_ID:
479 		attr->u.ppid.id_len = sizeof(mlxsw_sp->base_mac);
480 		memcpy(&attr->u.ppid.id, &mlxsw_sp->base_mac,
481 		       attr->u.ppid.id_len);
482 		break;
483 	case SWITCHDEV_ATTR_ID_PORT_BRIDGE_FLAGS:
484 		mlxsw_sp_port_bridge_flags_get(mlxsw_sp->bridge, attr->orig_dev,
485 					       &attr->u.brport_flags);
486 		break;
487 	case SWITCHDEV_ATTR_ID_PORT_BRIDGE_FLAGS_SUPPORT:
488 		attr->u.brport_flags_support = BR_LEARNING | BR_FLOOD |
489 					       BR_MCAST_FLOOD;
490 		break;
491 	default:
492 		return -EOPNOTSUPP;
493 	}
494 
495 	return 0;
496 }
497 
498 static int
499 mlxsw_sp_port_bridge_vlan_stp_set(struct mlxsw_sp_port *mlxsw_sp_port,
500 				  struct mlxsw_sp_bridge_vlan *bridge_vlan,
501 				  u8 state)
502 {
503 	struct mlxsw_sp_port_vlan *mlxsw_sp_port_vlan;
504 
505 	list_for_each_entry(mlxsw_sp_port_vlan, &bridge_vlan->port_vlan_list,
506 			    bridge_vlan_node) {
507 		if (mlxsw_sp_port_vlan->mlxsw_sp_port != mlxsw_sp_port)
508 			continue;
509 		return mlxsw_sp_port_vid_stp_set(mlxsw_sp_port,
510 						 bridge_vlan->vid, state);
511 	}
512 
513 	return 0;
514 }
515 
516 static int mlxsw_sp_port_attr_stp_state_set(struct mlxsw_sp_port *mlxsw_sp_port,
517 					    struct switchdev_trans *trans,
518 					    struct net_device *orig_dev,
519 					    u8 state)
520 {
521 	struct mlxsw_sp_bridge_port *bridge_port;
522 	struct mlxsw_sp_bridge_vlan *bridge_vlan;
523 	int err;
524 
525 	if (switchdev_trans_ph_prepare(trans))
526 		return 0;
527 
528 	/* It's possible we failed to enslave the port, yet this
529 	 * operation is executed due to it being deferred.
530 	 */
531 	bridge_port = mlxsw_sp_bridge_port_find(mlxsw_sp_port->mlxsw_sp->bridge,
532 						orig_dev);
533 	if (!bridge_port)
534 		return 0;
535 
536 	list_for_each_entry(bridge_vlan, &bridge_port->vlans_list, list) {
537 		err = mlxsw_sp_port_bridge_vlan_stp_set(mlxsw_sp_port,
538 							bridge_vlan, state);
539 		if (err)
540 			goto err_port_bridge_vlan_stp_set;
541 	}
542 
543 	bridge_port->stp_state = state;
544 
545 	return 0;
546 
547 err_port_bridge_vlan_stp_set:
548 	list_for_each_entry_continue_reverse(bridge_vlan,
549 					     &bridge_port->vlans_list, list)
550 		mlxsw_sp_port_bridge_vlan_stp_set(mlxsw_sp_port, bridge_vlan,
551 						  bridge_port->stp_state);
552 	return err;
553 }
554 
555 static int
556 mlxsw_sp_port_bridge_vlan_flood_set(struct mlxsw_sp_port *mlxsw_sp_port,
557 				    struct mlxsw_sp_bridge_vlan *bridge_vlan,
558 				    enum mlxsw_sp_flood_type packet_type,
559 				    bool member)
560 {
561 	struct mlxsw_sp_port_vlan *mlxsw_sp_port_vlan;
562 
563 	list_for_each_entry(mlxsw_sp_port_vlan, &bridge_vlan->port_vlan_list,
564 			    bridge_vlan_node) {
565 		if (mlxsw_sp_port_vlan->mlxsw_sp_port != mlxsw_sp_port)
566 			continue;
567 		return mlxsw_sp_fid_flood_set(mlxsw_sp_port_vlan->fid,
568 					      packet_type,
569 					      mlxsw_sp_port->local_port,
570 					      member);
571 	}
572 
573 	return 0;
574 }
575 
576 static int
577 mlxsw_sp_bridge_port_flood_table_set(struct mlxsw_sp_port *mlxsw_sp_port,
578 				     struct mlxsw_sp_bridge_port *bridge_port,
579 				     enum mlxsw_sp_flood_type packet_type,
580 				     bool member)
581 {
582 	struct mlxsw_sp_bridge_vlan *bridge_vlan;
583 	int err;
584 
585 	list_for_each_entry(bridge_vlan, &bridge_port->vlans_list, list) {
586 		err = mlxsw_sp_port_bridge_vlan_flood_set(mlxsw_sp_port,
587 							  bridge_vlan,
588 							  packet_type,
589 							  member);
590 		if (err)
591 			goto err_port_bridge_vlan_flood_set;
592 	}
593 
594 	return 0;
595 
596 err_port_bridge_vlan_flood_set:
597 	list_for_each_entry_continue_reverse(bridge_vlan,
598 					     &bridge_port->vlans_list, list)
599 		mlxsw_sp_port_bridge_vlan_flood_set(mlxsw_sp_port, bridge_vlan,
600 						    packet_type, !member);
601 	return err;
602 }
603 
604 static int
605 mlxsw_sp_port_bridge_vlan_learning_set(struct mlxsw_sp_port *mlxsw_sp_port,
606 				       struct mlxsw_sp_bridge_vlan *bridge_vlan,
607 				       bool set)
608 {
609 	struct mlxsw_sp_port_vlan *mlxsw_sp_port_vlan;
610 	u16 vid = bridge_vlan->vid;
611 
612 	list_for_each_entry(mlxsw_sp_port_vlan, &bridge_vlan->port_vlan_list,
613 			    bridge_vlan_node) {
614 		if (mlxsw_sp_port_vlan->mlxsw_sp_port != mlxsw_sp_port)
615 			continue;
616 		return mlxsw_sp_port_vid_learning_set(mlxsw_sp_port, vid, set);
617 	}
618 
619 	return 0;
620 }
621 
622 static int
623 mlxsw_sp_bridge_port_learning_set(struct mlxsw_sp_port *mlxsw_sp_port,
624 				  struct mlxsw_sp_bridge_port *bridge_port,
625 				  bool set)
626 {
627 	struct mlxsw_sp_bridge_vlan *bridge_vlan;
628 	int err;
629 
630 	list_for_each_entry(bridge_vlan, &bridge_port->vlans_list, list) {
631 		err = mlxsw_sp_port_bridge_vlan_learning_set(mlxsw_sp_port,
632 							     bridge_vlan, set);
633 		if (err)
634 			goto err_port_bridge_vlan_learning_set;
635 	}
636 
637 	return 0;
638 
639 err_port_bridge_vlan_learning_set:
640 	list_for_each_entry_continue_reverse(bridge_vlan,
641 					     &bridge_port->vlans_list, list)
642 		mlxsw_sp_port_bridge_vlan_learning_set(mlxsw_sp_port,
643 						       bridge_vlan, !set);
644 	return err;
645 }
646 
647 static int mlxsw_sp_port_attr_br_flags_set(struct mlxsw_sp_port *mlxsw_sp_port,
648 					   struct switchdev_trans *trans,
649 					   struct net_device *orig_dev,
650 					   unsigned long brport_flags)
651 {
652 	struct mlxsw_sp_bridge_port *bridge_port;
653 	int err;
654 
655 	if (switchdev_trans_ph_prepare(trans))
656 		return 0;
657 
658 	bridge_port = mlxsw_sp_bridge_port_find(mlxsw_sp_port->mlxsw_sp->bridge,
659 						orig_dev);
660 	if (!bridge_port)
661 		return 0;
662 
663 	err = mlxsw_sp_bridge_port_flood_table_set(mlxsw_sp_port, bridge_port,
664 						   MLXSW_SP_FLOOD_TYPE_UC,
665 						   brport_flags & BR_FLOOD);
666 	if (err)
667 		return err;
668 
669 	err = mlxsw_sp_bridge_port_learning_set(mlxsw_sp_port, bridge_port,
670 						brport_flags & BR_LEARNING);
671 	if (err)
672 		return err;
673 
674 	if (bridge_port->bridge_device->multicast_enabled)
675 		goto out;
676 
677 	err = mlxsw_sp_bridge_port_flood_table_set(mlxsw_sp_port, bridge_port,
678 						   MLXSW_SP_FLOOD_TYPE_MC,
679 						   brport_flags &
680 						   BR_MCAST_FLOOD);
681 	if (err)
682 		return err;
683 
684 out:
685 	memcpy(&bridge_port->flags, &brport_flags, sizeof(brport_flags));
686 	return 0;
687 }
688 
689 static int mlxsw_sp_ageing_set(struct mlxsw_sp *mlxsw_sp, u32 ageing_time)
690 {
691 	char sfdat_pl[MLXSW_REG_SFDAT_LEN];
692 	int err;
693 
694 	mlxsw_reg_sfdat_pack(sfdat_pl, ageing_time);
695 	err = mlxsw_reg_write(mlxsw_sp->core, MLXSW_REG(sfdat), sfdat_pl);
696 	if (err)
697 		return err;
698 	mlxsw_sp->bridge->ageing_time = ageing_time;
699 	return 0;
700 }
701 
702 static int mlxsw_sp_port_attr_br_ageing_set(struct mlxsw_sp_port *mlxsw_sp_port,
703 					    struct switchdev_trans *trans,
704 					    unsigned long ageing_clock_t)
705 {
706 	struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
707 	unsigned long ageing_jiffies = clock_t_to_jiffies(ageing_clock_t);
708 	u32 ageing_time = jiffies_to_msecs(ageing_jiffies) / 1000;
709 
710 	if (switchdev_trans_ph_prepare(trans)) {
711 		if (ageing_time < MLXSW_SP_MIN_AGEING_TIME ||
712 		    ageing_time > MLXSW_SP_MAX_AGEING_TIME)
713 			return -ERANGE;
714 		else
715 			return 0;
716 	}
717 
718 	return mlxsw_sp_ageing_set(mlxsw_sp, ageing_time);
719 }
720 
721 static int mlxsw_sp_port_attr_br_vlan_set(struct mlxsw_sp_port *mlxsw_sp_port,
722 					  struct switchdev_trans *trans,
723 					  struct net_device *orig_dev,
724 					  bool vlan_enabled)
725 {
726 	struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
727 	struct mlxsw_sp_bridge_device *bridge_device;
728 
729 	if (!switchdev_trans_ph_prepare(trans))
730 		return 0;
731 
732 	bridge_device = mlxsw_sp_bridge_device_find(mlxsw_sp->bridge, orig_dev);
733 	if (WARN_ON(!bridge_device))
734 		return -EINVAL;
735 
736 	if (bridge_device->vlan_enabled == vlan_enabled)
737 		return 0;
738 
739 	netdev_err(bridge_device->dev, "VLAN filtering can't be changed for existing bridge\n");
740 	return -EINVAL;
741 }
742 
743 static int mlxsw_sp_port_attr_mrouter_set(struct mlxsw_sp_port *mlxsw_sp_port,
744 					  struct switchdev_trans *trans,
745 					  struct net_device *orig_dev,
746 					  bool is_port_mrouter)
747 {
748 	struct mlxsw_sp_bridge_port *bridge_port;
749 	int err;
750 
751 	if (switchdev_trans_ph_prepare(trans))
752 		return 0;
753 
754 	bridge_port = mlxsw_sp_bridge_port_find(mlxsw_sp_port->mlxsw_sp->bridge,
755 						orig_dev);
756 	if (!bridge_port)
757 		return 0;
758 
759 	if (!bridge_port->bridge_device->multicast_enabled)
760 		goto out;
761 
762 	err = mlxsw_sp_bridge_port_flood_table_set(mlxsw_sp_port, bridge_port,
763 						   MLXSW_SP_FLOOD_TYPE_MC,
764 						   is_port_mrouter);
765 	if (err)
766 		return err;
767 
768 	mlxsw_sp_port_mrouter_update_mdb(mlxsw_sp_port, bridge_port,
769 					 is_port_mrouter);
770 out:
771 	bridge_port->mrouter = is_port_mrouter;
772 	return 0;
773 }
774 
775 static bool mlxsw_sp_mc_flood(const struct mlxsw_sp_bridge_port *bridge_port)
776 {
777 	const struct mlxsw_sp_bridge_device *bridge_device;
778 
779 	bridge_device = bridge_port->bridge_device;
780 	return bridge_device->multicast_enabled ? bridge_port->mrouter :
781 					bridge_port->flags & BR_MCAST_FLOOD;
782 }
783 
784 static int mlxsw_sp_port_mc_disabled_set(struct mlxsw_sp_port *mlxsw_sp_port,
785 					 struct switchdev_trans *trans,
786 					 struct net_device *orig_dev,
787 					 bool mc_disabled)
788 {
789 	struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
790 	struct mlxsw_sp_bridge_device *bridge_device;
791 	struct mlxsw_sp_bridge_port *bridge_port;
792 	int err;
793 
794 	if (switchdev_trans_ph_prepare(trans))
795 		return 0;
796 
797 	/* It's possible we failed to enslave the port, yet this
798 	 * operation is executed due to it being deferred.
799 	 */
800 	bridge_device = mlxsw_sp_bridge_device_find(mlxsw_sp->bridge, orig_dev);
801 	if (!bridge_device)
802 		return 0;
803 
804 	if (bridge_device->multicast_enabled != !mc_disabled) {
805 		bridge_device->multicast_enabled = !mc_disabled;
806 		mlxsw_sp_bridge_mdb_mc_enable_sync(mlxsw_sp_port,
807 						   bridge_device);
808 	}
809 
810 	list_for_each_entry(bridge_port, &bridge_device->ports_list, list) {
811 		enum mlxsw_sp_flood_type packet_type = MLXSW_SP_FLOOD_TYPE_MC;
812 		bool member = mlxsw_sp_mc_flood(bridge_port);
813 
814 		err = mlxsw_sp_bridge_port_flood_table_set(mlxsw_sp_port,
815 							   bridge_port,
816 							   packet_type, member);
817 		if (err)
818 			return err;
819 	}
820 
821 	bridge_device->multicast_enabled = !mc_disabled;
822 
823 	return 0;
824 }
825 
826 static int mlxsw_sp_smid_router_port_set(struct mlxsw_sp *mlxsw_sp,
827 					 u16 mid_idx, bool add)
828 {
829 	char *smid_pl;
830 	int err;
831 
832 	smid_pl = kmalloc(MLXSW_REG_SMID_LEN, GFP_KERNEL);
833 	if (!smid_pl)
834 		return -ENOMEM;
835 
836 	mlxsw_reg_smid_pack(smid_pl, mid_idx,
837 			    mlxsw_sp_router_port(mlxsw_sp), add);
838 	err = mlxsw_reg_write(mlxsw_sp->core, MLXSW_REG(smid), smid_pl);
839 	kfree(smid_pl);
840 	return err;
841 }
842 
843 static void
844 mlxsw_sp_bridge_mrouter_update_mdb(struct mlxsw_sp *mlxsw_sp,
845 				   struct mlxsw_sp_bridge_device *bridge_device,
846 				   bool add)
847 {
848 	struct mlxsw_sp_mid *mid;
849 
850 	list_for_each_entry(mid, &bridge_device->mids_list, list)
851 		mlxsw_sp_smid_router_port_set(mlxsw_sp, mid->mid, add);
852 }
853 
854 static int
855 mlxsw_sp_port_attr_br_mrouter_set(struct mlxsw_sp_port *mlxsw_sp_port,
856 				  struct switchdev_trans *trans,
857 				  struct net_device *orig_dev,
858 				  bool is_mrouter)
859 {
860 	struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
861 	struct mlxsw_sp_bridge_device *bridge_device;
862 
863 	if (switchdev_trans_ph_prepare(trans))
864 		return 0;
865 
866 	/* It's possible we failed to enslave the port, yet this
867 	 * operation is executed due to it being deferred.
868 	 */
869 	bridge_device = mlxsw_sp_bridge_device_find(mlxsw_sp->bridge, orig_dev);
870 	if (!bridge_device)
871 		return 0;
872 
873 	if (bridge_device->mrouter != is_mrouter)
874 		mlxsw_sp_bridge_mrouter_update_mdb(mlxsw_sp, bridge_device,
875 						   is_mrouter);
876 	bridge_device->mrouter = is_mrouter;
877 	return 0;
878 }
879 
880 static int mlxsw_sp_port_attr_set(struct net_device *dev,
881 				  const struct switchdev_attr *attr,
882 				  struct switchdev_trans *trans)
883 {
884 	struct mlxsw_sp_port *mlxsw_sp_port = netdev_priv(dev);
885 	int err;
886 
887 	switch (attr->id) {
888 	case SWITCHDEV_ATTR_ID_PORT_STP_STATE:
889 		err = mlxsw_sp_port_attr_stp_state_set(mlxsw_sp_port, trans,
890 						       attr->orig_dev,
891 						       attr->u.stp_state);
892 		break;
893 	case SWITCHDEV_ATTR_ID_PORT_BRIDGE_FLAGS:
894 		err = mlxsw_sp_port_attr_br_flags_set(mlxsw_sp_port, trans,
895 						      attr->orig_dev,
896 						      attr->u.brport_flags);
897 		break;
898 	case SWITCHDEV_ATTR_ID_BRIDGE_AGEING_TIME:
899 		err = mlxsw_sp_port_attr_br_ageing_set(mlxsw_sp_port, trans,
900 						       attr->u.ageing_time);
901 		break;
902 	case SWITCHDEV_ATTR_ID_BRIDGE_VLAN_FILTERING:
903 		err = mlxsw_sp_port_attr_br_vlan_set(mlxsw_sp_port, trans,
904 						     attr->orig_dev,
905 						     attr->u.vlan_filtering);
906 		break;
907 	case SWITCHDEV_ATTR_ID_PORT_MROUTER:
908 		err = mlxsw_sp_port_attr_mrouter_set(mlxsw_sp_port, trans,
909 						     attr->orig_dev,
910 						     attr->u.mrouter);
911 		break;
912 	case SWITCHDEV_ATTR_ID_BRIDGE_MC_DISABLED:
913 		err = mlxsw_sp_port_mc_disabled_set(mlxsw_sp_port, trans,
914 						    attr->orig_dev,
915 						    attr->u.mc_disabled);
916 		break;
917 	case SWITCHDEV_ATTR_ID_BRIDGE_MROUTER:
918 		err = mlxsw_sp_port_attr_br_mrouter_set(mlxsw_sp_port, trans,
919 							attr->orig_dev,
920 							attr->u.mrouter);
921 		break;
922 	default:
923 		err = -EOPNOTSUPP;
924 		break;
925 	}
926 
927 	if (switchdev_trans_ph_commit(trans))
928 		mlxsw_sp_span_respin(mlxsw_sp_port->mlxsw_sp);
929 
930 	return err;
931 }
932 
933 static int
934 mlxsw_sp_port_vlan_fid_join(struct mlxsw_sp_port_vlan *mlxsw_sp_port_vlan,
935 			    struct mlxsw_sp_bridge_port *bridge_port)
936 {
937 	struct mlxsw_sp_port *mlxsw_sp_port = mlxsw_sp_port_vlan->mlxsw_sp_port;
938 	struct mlxsw_sp_bridge_device *bridge_device;
939 	u8 local_port = mlxsw_sp_port->local_port;
940 	u16 vid = mlxsw_sp_port_vlan->vid;
941 	struct mlxsw_sp_fid *fid;
942 	int err;
943 
944 	bridge_device = bridge_port->bridge_device;
945 	fid = bridge_device->ops->fid_get(bridge_device, vid);
946 	if (IS_ERR(fid))
947 		return PTR_ERR(fid);
948 
949 	err = mlxsw_sp_fid_flood_set(fid, MLXSW_SP_FLOOD_TYPE_UC, local_port,
950 				     bridge_port->flags & BR_FLOOD);
951 	if (err)
952 		goto err_fid_uc_flood_set;
953 
954 	err = mlxsw_sp_fid_flood_set(fid, MLXSW_SP_FLOOD_TYPE_MC, local_port,
955 				     mlxsw_sp_mc_flood(bridge_port));
956 	if (err)
957 		goto err_fid_mc_flood_set;
958 
959 	err = mlxsw_sp_fid_flood_set(fid, MLXSW_SP_FLOOD_TYPE_BC, local_port,
960 				     true);
961 	if (err)
962 		goto err_fid_bc_flood_set;
963 
964 	err = mlxsw_sp_fid_port_vid_map(fid, mlxsw_sp_port, vid);
965 	if (err)
966 		goto err_fid_port_vid_map;
967 
968 	mlxsw_sp_port_vlan->fid = fid;
969 
970 	return 0;
971 
972 err_fid_port_vid_map:
973 	mlxsw_sp_fid_flood_set(fid, MLXSW_SP_FLOOD_TYPE_BC, local_port, false);
974 err_fid_bc_flood_set:
975 	mlxsw_sp_fid_flood_set(fid, MLXSW_SP_FLOOD_TYPE_MC, local_port, false);
976 err_fid_mc_flood_set:
977 	mlxsw_sp_fid_flood_set(fid, MLXSW_SP_FLOOD_TYPE_UC, local_port, false);
978 err_fid_uc_flood_set:
979 	mlxsw_sp_fid_put(fid);
980 	return err;
981 }
982 
983 static void
984 mlxsw_sp_port_vlan_fid_leave(struct mlxsw_sp_port_vlan *mlxsw_sp_port_vlan)
985 {
986 	struct mlxsw_sp_port *mlxsw_sp_port = mlxsw_sp_port_vlan->mlxsw_sp_port;
987 	struct mlxsw_sp_fid *fid = mlxsw_sp_port_vlan->fid;
988 	u8 local_port = mlxsw_sp_port->local_port;
989 	u16 vid = mlxsw_sp_port_vlan->vid;
990 
991 	mlxsw_sp_port_vlan->fid = NULL;
992 	mlxsw_sp_fid_port_vid_unmap(fid, mlxsw_sp_port, vid);
993 	mlxsw_sp_fid_flood_set(fid, MLXSW_SP_FLOOD_TYPE_BC, local_port, false);
994 	mlxsw_sp_fid_flood_set(fid, MLXSW_SP_FLOOD_TYPE_MC, local_port, false);
995 	mlxsw_sp_fid_flood_set(fid, MLXSW_SP_FLOOD_TYPE_UC, local_port, false);
996 	mlxsw_sp_fid_put(fid);
997 }
998 
999 static u16
1000 mlxsw_sp_port_pvid_determine(const struct mlxsw_sp_port *mlxsw_sp_port,
1001 			     u16 vid, bool is_pvid)
1002 {
1003 	if (is_pvid)
1004 		return vid;
1005 	else if (mlxsw_sp_port->pvid == vid)
1006 		return 0;	/* Dis-allow untagged packets */
1007 	else
1008 		return mlxsw_sp_port->pvid;
1009 }
1010 
1011 static int
1012 mlxsw_sp_port_vlan_bridge_join(struct mlxsw_sp_port_vlan *mlxsw_sp_port_vlan,
1013 			       struct mlxsw_sp_bridge_port *bridge_port)
1014 {
1015 	struct mlxsw_sp_port *mlxsw_sp_port = mlxsw_sp_port_vlan->mlxsw_sp_port;
1016 	struct mlxsw_sp_bridge_vlan *bridge_vlan;
1017 	u16 vid = mlxsw_sp_port_vlan->vid;
1018 	int err;
1019 
1020 	/* No need to continue if only VLAN flags were changed */
1021 	if (mlxsw_sp_port_vlan->bridge_port) {
1022 		mlxsw_sp_port_vlan_put(mlxsw_sp_port_vlan);
1023 		return 0;
1024 	}
1025 
1026 	err = mlxsw_sp_port_vlan_fid_join(mlxsw_sp_port_vlan, bridge_port);
1027 	if (err)
1028 		return err;
1029 
1030 	err = mlxsw_sp_port_vid_learning_set(mlxsw_sp_port, vid,
1031 					     bridge_port->flags & BR_LEARNING);
1032 	if (err)
1033 		goto err_port_vid_learning_set;
1034 
1035 	err = mlxsw_sp_port_vid_stp_set(mlxsw_sp_port, vid,
1036 					bridge_port->stp_state);
1037 	if (err)
1038 		goto err_port_vid_stp_set;
1039 
1040 	bridge_vlan = mlxsw_sp_bridge_vlan_get(bridge_port, vid);
1041 	if (!bridge_vlan) {
1042 		err = -ENOMEM;
1043 		goto err_bridge_vlan_get;
1044 	}
1045 
1046 	list_add(&mlxsw_sp_port_vlan->bridge_vlan_node,
1047 		 &bridge_vlan->port_vlan_list);
1048 
1049 	mlxsw_sp_bridge_port_get(mlxsw_sp_port->mlxsw_sp->bridge,
1050 				 bridge_port->dev);
1051 	mlxsw_sp_port_vlan->bridge_port = bridge_port;
1052 
1053 	return 0;
1054 
1055 err_bridge_vlan_get:
1056 	mlxsw_sp_port_vid_stp_set(mlxsw_sp_port, vid, BR_STATE_DISABLED);
1057 err_port_vid_stp_set:
1058 	mlxsw_sp_port_vid_learning_set(mlxsw_sp_port, vid, false);
1059 err_port_vid_learning_set:
1060 	mlxsw_sp_port_vlan_fid_leave(mlxsw_sp_port_vlan);
1061 	return err;
1062 }
1063 
1064 void
1065 mlxsw_sp_port_vlan_bridge_leave(struct mlxsw_sp_port_vlan *mlxsw_sp_port_vlan)
1066 {
1067 	struct mlxsw_sp_port *mlxsw_sp_port = mlxsw_sp_port_vlan->mlxsw_sp_port;
1068 	struct mlxsw_sp_fid *fid = mlxsw_sp_port_vlan->fid;
1069 	struct mlxsw_sp_bridge_vlan *bridge_vlan;
1070 	struct mlxsw_sp_bridge_port *bridge_port;
1071 	u16 vid = mlxsw_sp_port_vlan->vid;
1072 	bool last_port, last_vlan;
1073 
1074 	if (WARN_ON(mlxsw_sp_fid_type(fid) != MLXSW_SP_FID_TYPE_8021Q &&
1075 		    mlxsw_sp_fid_type(fid) != MLXSW_SP_FID_TYPE_8021D))
1076 		return;
1077 
1078 	bridge_port = mlxsw_sp_port_vlan->bridge_port;
1079 	last_vlan = list_is_singular(&bridge_port->vlans_list);
1080 	bridge_vlan = mlxsw_sp_bridge_vlan_find(bridge_port, vid);
1081 	last_port = list_is_singular(&bridge_vlan->port_vlan_list);
1082 
1083 	list_del(&mlxsw_sp_port_vlan->bridge_vlan_node);
1084 	mlxsw_sp_bridge_vlan_put(bridge_vlan);
1085 	mlxsw_sp_port_vid_stp_set(mlxsw_sp_port, vid, BR_STATE_DISABLED);
1086 	mlxsw_sp_port_vid_learning_set(mlxsw_sp_port, vid, false);
1087 	if (last_port)
1088 		mlxsw_sp_bridge_port_fdb_flush(mlxsw_sp_port->mlxsw_sp,
1089 					       bridge_port,
1090 					       mlxsw_sp_fid_index(fid));
1091 	if (last_vlan)
1092 		mlxsw_sp_bridge_port_mdb_flush(mlxsw_sp_port, bridge_port);
1093 
1094 	mlxsw_sp_port_vlan_fid_leave(mlxsw_sp_port_vlan);
1095 
1096 	mlxsw_sp_bridge_port_put(mlxsw_sp_port->mlxsw_sp->bridge, bridge_port);
1097 	mlxsw_sp_port_vlan->bridge_port = NULL;
1098 }
1099 
1100 static int
1101 mlxsw_sp_bridge_port_vlan_add(struct mlxsw_sp_port *mlxsw_sp_port,
1102 			      struct mlxsw_sp_bridge_port *bridge_port,
1103 			      u16 vid, bool is_untagged, bool is_pvid)
1104 {
1105 	u16 pvid = mlxsw_sp_port_pvid_determine(mlxsw_sp_port, vid, is_pvid);
1106 	struct mlxsw_sp_port_vlan *mlxsw_sp_port_vlan;
1107 	u16 old_pvid = mlxsw_sp_port->pvid;
1108 	int err;
1109 
1110 	mlxsw_sp_port_vlan = mlxsw_sp_port_vlan_get(mlxsw_sp_port, vid);
1111 	if (IS_ERR(mlxsw_sp_port_vlan))
1112 		return PTR_ERR(mlxsw_sp_port_vlan);
1113 
1114 	err = mlxsw_sp_port_vlan_set(mlxsw_sp_port, vid, vid, true,
1115 				     is_untagged);
1116 	if (err)
1117 		goto err_port_vlan_set;
1118 
1119 	err = mlxsw_sp_port_pvid_set(mlxsw_sp_port, pvid);
1120 	if (err)
1121 		goto err_port_pvid_set;
1122 
1123 	err = mlxsw_sp_port_vlan_bridge_join(mlxsw_sp_port_vlan, bridge_port);
1124 	if (err)
1125 		goto err_port_vlan_bridge_join;
1126 
1127 	return 0;
1128 
1129 err_port_vlan_bridge_join:
1130 	mlxsw_sp_port_pvid_set(mlxsw_sp_port, old_pvid);
1131 err_port_pvid_set:
1132 	mlxsw_sp_port_vlan_set(mlxsw_sp_port, vid, vid, false, false);
1133 err_port_vlan_set:
1134 	mlxsw_sp_port_vlan_put(mlxsw_sp_port_vlan);
1135 	return err;
1136 }
1137 
1138 static int
1139 mlxsw_sp_br_ban_rif_pvid_change(struct mlxsw_sp *mlxsw_sp,
1140 				const struct net_device *br_dev,
1141 				const struct switchdev_obj_port_vlan *vlan)
1142 {
1143 	struct mlxsw_sp_rif *rif;
1144 	struct mlxsw_sp_fid *fid;
1145 	u16 pvid;
1146 	u16 vid;
1147 
1148 	rif = mlxsw_sp_rif_find_by_dev(mlxsw_sp, br_dev);
1149 	if (!rif)
1150 		return 0;
1151 	fid = mlxsw_sp_rif_fid(rif);
1152 	pvid = mlxsw_sp_fid_8021q_vid(fid);
1153 
1154 	for (vid = vlan->vid_begin; vid <= vlan->vid_end; ++vid) {
1155 		if (vlan->flags & BRIDGE_VLAN_INFO_PVID) {
1156 			if (vid != pvid) {
1157 				netdev_err(br_dev, "Can't change PVID, it's used by router interface\n");
1158 				return -EBUSY;
1159 			}
1160 		} else {
1161 			if (vid == pvid) {
1162 				netdev_err(br_dev, "Can't remove PVID, it's used by router interface\n");
1163 				return -EBUSY;
1164 			}
1165 		}
1166 	}
1167 
1168 	return 0;
1169 }
1170 
1171 static int mlxsw_sp_port_vlans_add(struct mlxsw_sp_port *mlxsw_sp_port,
1172 				   const struct switchdev_obj_port_vlan *vlan,
1173 				   struct switchdev_trans *trans)
1174 {
1175 	bool flag_untagged = vlan->flags & BRIDGE_VLAN_INFO_UNTAGGED;
1176 	bool flag_pvid = vlan->flags & BRIDGE_VLAN_INFO_PVID;
1177 	struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
1178 	struct net_device *orig_dev = vlan->obj.orig_dev;
1179 	struct mlxsw_sp_bridge_port *bridge_port;
1180 	u16 vid;
1181 
1182 	if (netif_is_bridge_master(orig_dev)) {
1183 		int err = 0;
1184 
1185 		if ((vlan->flags & BRIDGE_VLAN_INFO_BRENTRY) &&
1186 		    br_vlan_enabled(orig_dev) &&
1187 		    switchdev_trans_ph_prepare(trans))
1188 			err = mlxsw_sp_br_ban_rif_pvid_change(mlxsw_sp,
1189 							      orig_dev, vlan);
1190 		if (!err)
1191 			err = -EOPNOTSUPP;
1192 		return err;
1193 	}
1194 
1195 	if (switchdev_trans_ph_prepare(trans))
1196 		return 0;
1197 
1198 	bridge_port = mlxsw_sp_bridge_port_find(mlxsw_sp->bridge, orig_dev);
1199 	if (WARN_ON(!bridge_port))
1200 		return -EINVAL;
1201 
1202 	if (!bridge_port->bridge_device->vlan_enabled)
1203 		return 0;
1204 
1205 	for (vid = vlan->vid_begin; vid <= vlan->vid_end; vid++) {
1206 		int err;
1207 
1208 		err = mlxsw_sp_bridge_port_vlan_add(mlxsw_sp_port, bridge_port,
1209 						    vid, flag_untagged,
1210 						    flag_pvid);
1211 		if (err)
1212 			return err;
1213 	}
1214 
1215 	return 0;
1216 }
1217 
1218 static enum mlxsw_reg_sfdf_flush_type mlxsw_sp_fdb_flush_type(bool lagged)
1219 {
1220 	return lagged ? MLXSW_REG_SFDF_FLUSH_PER_LAG_AND_FID :
1221 			MLXSW_REG_SFDF_FLUSH_PER_PORT_AND_FID;
1222 }
1223 
1224 static int
1225 mlxsw_sp_bridge_port_fdb_flush(struct mlxsw_sp *mlxsw_sp,
1226 			       struct mlxsw_sp_bridge_port *bridge_port,
1227 			       u16 fid_index)
1228 {
1229 	bool lagged = bridge_port->lagged;
1230 	char sfdf_pl[MLXSW_REG_SFDF_LEN];
1231 	u16 system_port;
1232 
1233 	system_port = lagged ? bridge_port->lag_id : bridge_port->system_port;
1234 	mlxsw_reg_sfdf_pack(sfdf_pl, mlxsw_sp_fdb_flush_type(lagged));
1235 	mlxsw_reg_sfdf_fid_set(sfdf_pl, fid_index);
1236 	mlxsw_reg_sfdf_port_fid_system_port_set(sfdf_pl, system_port);
1237 
1238 	return mlxsw_reg_write(mlxsw_sp->core, MLXSW_REG(sfdf), sfdf_pl);
1239 }
1240 
1241 static enum mlxsw_reg_sfd_rec_policy mlxsw_sp_sfd_rec_policy(bool dynamic)
1242 {
1243 	return dynamic ? MLXSW_REG_SFD_REC_POLICY_DYNAMIC_ENTRY_INGRESS :
1244 			 MLXSW_REG_SFD_REC_POLICY_STATIC_ENTRY;
1245 }
1246 
1247 static enum mlxsw_reg_sfd_op mlxsw_sp_sfd_op(bool adding)
1248 {
1249 	return adding ? MLXSW_REG_SFD_OP_WRITE_EDIT :
1250 			MLXSW_REG_SFD_OP_WRITE_REMOVE;
1251 }
1252 
1253 static int __mlxsw_sp_port_fdb_uc_op(struct mlxsw_sp *mlxsw_sp, u8 local_port,
1254 				     const char *mac, u16 fid, bool adding,
1255 				     enum mlxsw_reg_sfd_rec_action action,
1256 				     bool dynamic)
1257 {
1258 	char *sfd_pl;
1259 	u8 num_rec;
1260 	int err;
1261 
1262 	sfd_pl = kmalloc(MLXSW_REG_SFD_LEN, GFP_KERNEL);
1263 	if (!sfd_pl)
1264 		return -ENOMEM;
1265 
1266 	mlxsw_reg_sfd_pack(sfd_pl, mlxsw_sp_sfd_op(adding), 0);
1267 	mlxsw_reg_sfd_uc_pack(sfd_pl, 0, mlxsw_sp_sfd_rec_policy(dynamic),
1268 			      mac, fid, action, local_port);
1269 	num_rec = mlxsw_reg_sfd_num_rec_get(sfd_pl);
1270 	err = mlxsw_reg_write(mlxsw_sp->core, MLXSW_REG(sfd), sfd_pl);
1271 	if (err)
1272 		goto out;
1273 
1274 	if (num_rec != mlxsw_reg_sfd_num_rec_get(sfd_pl))
1275 		err = -EBUSY;
1276 
1277 out:
1278 	kfree(sfd_pl);
1279 	return err;
1280 }
1281 
1282 static int mlxsw_sp_port_fdb_uc_op(struct mlxsw_sp *mlxsw_sp, u8 local_port,
1283 				   const char *mac, u16 fid, bool adding,
1284 				   bool dynamic)
1285 {
1286 	return __mlxsw_sp_port_fdb_uc_op(mlxsw_sp, local_port, mac, fid, adding,
1287 					 MLXSW_REG_SFD_REC_ACTION_NOP, dynamic);
1288 }
1289 
1290 int mlxsw_sp_rif_fdb_op(struct mlxsw_sp *mlxsw_sp, const char *mac, u16 fid,
1291 			bool adding)
1292 {
1293 	return __mlxsw_sp_port_fdb_uc_op(mlxsw_sp, 0, mac, fid, adding,
1294 					 MLXSW_REG_SFD_REC_ACTION_FORWARD_IP_ROUTER,
1295 					 false);
1296 }
1297 
1298 static int mlxsw_sp_port_fdb_uc_lag_op(struct mlxsw_sp *mlxsw_sp, u16 lag_id,
1299 				       const char *mac, u16 fid, u16 lag_vid,
1300 				       bool adding, bool dynamic)
1301 {
1302 	char *sfd_pl;
1303 	u8 num_rec;
1304 	int err;
1305 
1306 	sfd_pl = kmalloc(MLXSW_REG_SFD_LEN, GFP_KERNEL);
1307 	if (!sfd_pl)
1308 		return -ENOMEM;
1309 
1310 	mlxsw_reg_sfd_pack(sfd_pl, mlxsw_sp_sfd_op(adding), 0);
1311 	mlxsw_reg_sfd_uc_lag_pack(sfd_pl, 0, mlxsw_sp_sfd_rec_policy(dynamic),
1312 				  mac, fid, MLXSW_REG_SFD_REC_ACTION_NOP,
1313 				  lag_vid, lag_id);
1314 	num_rec = mlxsw_reg_sfd_num_rec_get(sfd_pl);
1315 	err = mlxsw_reg_write(mlxsw_sp->core, MLXSW_REG(sfd), sfd_pl);
1316 	if (err)
1317 		goto out;
1318 
1319 	if (num_rec != mlxsw_reg_sfd_num_rec_get(sfd_pl))
1320 		err = -EBUSY;
1321 
1322 out:
1323 	kfree(sfd_pl);
1324 	return err;
1325 }
1326 
1327 static int
1328 mlxsw_sp_port_fdb_set(struct mlxsw_sp_port *mlxsw_sp_port,
1329 		      struct switchdev_notifier_fdb_info *fdb_info, bool adding)
1330 {
1331 	struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
1332 	struct net_device *orig_dev = fdb_info->info.dev;
1333 	struct mlxsw_sp_port_vlan *mlxsw_sp_port_vlan;
1334 	struct mlxsw_sp_bridge_device *bridge_device;
1335 	struct mlxsw_sp_bridge_port *bridge_port;
1336 	u16 fid_index, vid;
1337 
1338 	bridge_port = mlxsw_sp_bridge_port_find(mlxsw_sp->bridge, orig_dev);
1339 	if (!bridge_port)
1340 		return -EINVAL;
1341 
1342 	bridge_device = bridge_port->bridge_device;
1343 	mlxsw_sp_port_vlan = mlxsw_sp_port_vlan_find_by_bridge(mlxsw_sp_port,
1344 							       bridge_device,
1345 							       fdb_info->vid);
1346 	if (!mlxsw_sp_port_vlan)
1347 		return 0;
1348 
1349 	fid_index = mlxsw_sp_fid_index(mlxsw_sp_port_vlan->fid);
1350 	vid = mlxsw_sp_port_vlan->vid;
1351 
1352 	if (!bridge_port->lagged)
1353 		return mlxsw_sp_port_fdb_uc_op(mlxsw_sp,
1354 					       bridge_port->system_port,
1355 					       fdb_info->addr, fid_index,
1356 					       adding, false);
1357 	else
1358 		return mlxsw_sp_port_fdb_uc_lag_op(mlxsw_sp,
1359 						   bridge_port->lag_id,
1360 						   fdb_info->addr, fid_index,
1361 						   vid, adding, false);
1362 }
1363 
1364 static int mlxsw_sp_port_mdb_op(struct mlxsw_sp *mlxsw_sp, const char *addr,
1365 				u16 fid, u16 mid_idx, bool adding)
1366 {
1367 	char *sfd_pl;
1368 	u8 num_rec;
1369 	int err;
1370 
1371 	sfd_pl = kmalloc(MLXSW_REG_SFD_LEN, GFP_KERNEL);
1372 	if (!sfd_pl)
1373 		return -ENOMEM;
1374 
1375 	mlxsw_reg_sfd_pack(sfd_pl, mlxsw_sp_sfd_op(adding), 0);
1376 	mlxsw_reg_sfd_mc_pack(sfd_pl, 0, addr, fid,
1377 			      MLXSW_REG_SFD_REC_ACTION_NOP, mid_idx);
1378 	num_rec = mlxsw_reg_sfd_num_rec_get(sfd_pl);
1379 	err = mlxsw_reg_write(mlxsw_sp->core, MLXSW_REG(sfd), sfd_pl);
1380 	if (err)
1381 		goto out;
1382 
1383 	if (num_rec != mlxsw_reg_sfd_num_rec_get(sfd_pl))
1384 		err = -EBUSY;
1385 
1386 out:
1387 	kfree(sfd_pl);
1388 	return err;
1389 }
1390 
1391 static int mlxsw_sp_port_smid_full_entry(struct mlxsw_sp *mlxsw_sp, u16 mid_idx,
1392 					 long *ports_bitmap,
1393 					 bool set_router_port)
1394 {
1395 	char *smid_pl;
1396 	int err, i;
1397 
1398 	smid_pl = kmalloc(MLXSW_REG_SMID_LEN, GFP_KERNEL);
1399 	if (!smid_pl)
1400 		return -ENOMEM;
1401 
1402 	mlxsw_reg_smid_pack(smid_pl, mid_idx, 0, false);
1403 	for (i = 1; i < mlxsw_core_max_ports(mlxsw_sp->core); i++) {
1404 		if (mlxsw_sp->ports[i])
1405 			mlxsw_reg_smid_port_mask_set(smid_pl, i, 1);
1406 	}
1407 
1408 	mlxsw_reg_smid_port_mask_set(smid_pl,
1409 				     mlxsw_sp_router_port(mlxsw_sp), 1);
1410 
1411 	for_each_set_bit(i, ports_bitmap, mlxsw_core_max_ports(mlxsw_sp->core))
1412 		mlxsw_reg_smid_port_set(smid_pl, i, 1);
1413 
1414 	mlxsw_reg_smid_port_set(smid_pl, mlxsw_sp_router_port(mlxsw_sp),
1415 				set_router_port);
1416 
1417 	err = mlxsw_reg_write(mlxsw_sp->core, MLXSW_REG(smid), smid_pl);
1418 	kfree(smid_pl);
1419 	return err;
1420 }
1421 
1422 static int mlxsw_sp_port_smid_set(struct mlxsw_sp_port *mlxsw_sp_port,
1423 				  u16 mid_idx, bool add)
1424 {
1425 	struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
1426 	char *smid_pl;
1427 	int err;
1428 
1429 	smid_pl = kmalloc(MLXSW_REG_SMID_LEN, GFP_KERNEL);
1430 	if (!smid_pl)
1431 		return -ENOMEM;
1432 
1433 	mlxsw_reg_smid_pack(smid_pl, mid_idx, mlxsw_sp_port->local_port, add);
1434 	err = mlxsw_reg_write(mlxsw_sp->core, MLXSW_REG(smid), smid_pl);
1435 	kfree(smid_pl);
1436 	return err;
1437 }
1438 
1439 static struct
1440 mlxsw_sp_mid *__mlxsw_sp_mc_get(struct mlxsw_sp_bridge_device *bridge_device,
1441 				const unsigned char *addr,
1442 				u16 fid)
1443 {
1444 	struct mlxsw_sp_mid *mid;
1445 
1446 	list_for_each_entry(mid, &bridge_device->mids_list, list) {
1447 		if (ether_addr_equal(mid->addr, addr) && mid->fid == fid)
1448 			return mid;
1449 	}
1450 	return NULL;
1451 }
1452 
1453 static void
1454 mlxsw_sp_bridge_port_get_ports_bitmap(struct mlxsw_sp *mlxsw_sp,
1455 				      struct mlxsw_sp_bridge_port *bridge_port,
1456 				      unsigned long *ports_bitmap)
1457 {
1458 	struct mlxsw_sp_port *mlxsw_sp_port;
1459 	u64 max_lag_members, i;
1460 	int lag_id;
1461 
1462 	if (!bridge_port->lagged) {
1463 		set_bit(bridge_port->system_port, ports_bitmap);
1464 	} else {
1465 		max_lag_members = MLXSW_CORE_RES_GET(mlxsw_sp->core,
1466 						     MAX_LAG_MEMBERS);
1467 		lag_id = bridge_port->lag_id;
1468 		for (i = 0; i < max_lag_members; i++) {
1469 			mlxsw_sp_port = mlxsw_sp_port_lagged_get(mlxsw_sp,
1470 								 lag_id, i);
1471 			if (mlxsw_sp_port)
1472 				set_bit(mlxsw_sp_port->local_port,
1473 					ports_bitmap);
1474 		}
1475 	}
1476 }
1477 
1478 static void
1479 mlxsw_sp_mc_get_mrouters_bitmap(unsigned long *flood_bitmap,
1480 				struct mlxsw_sp_bridge_device *bridge_device,
1481 				struct mlxsw_sp *mlxsw_sp)
1482 {
1483 	struct mlxsw_sp_bridge_port *bridge_port;
1484 
1485 	list_for_each_entry(bridge_port, &bridge_device->ports_list, list) {
1486 		if (bridge_port->mrouter) {
1487 			mlxsw_sp_bridge_port_get_ports_bitmap(mlxsw_sp,
1488 							      bridge_port,
1489 							      flood_bitmap);
1490 		}
1491 	}
1492 }
1493 
1494 static bool
1495 mlxsw_sp_mc_write_mdb_entry(struct mlxsw_sp *mlxsw_sp,
1496 			    struct mlxsw_sp_mid *mid,
1497 			    struct mlxsw_sp_bridge_device *bridge_device)
1498 {
1499 	long *flood_bitmap;
1500 	int num_of_ports;
1501 	int alloc_size;
1502 	u16 mid_idx;
1503 	int err;
1504 
1505 	mid_idx = find_first_zero_bit(mlxsw_sp->bridge->mids_bitmap,
1506 				      MLXSW_SP_MID_MAX);
1507 	if (mid_idx == MLXSW_SP_MID_MAX)
1508 		return false;
1509 
1510 	num_of_ports = mlxsw_core_max_ports(mlxsw_sp->core);
1511 	alloc_size = sizeof(long) * BITS_TO_LONGS(num_of_ports);
1512 	flood_bitmap = kzalloc(alloc_size, GFP_KERNEL);
1513 	if (!flood_bitmap)
1514 		return false;
1515 
1516 	bitmap_copy(flood_bitmap,  mid->ports_in_mid, num_of_ports);
1517 	mlxsw_sp_mc_get_mrouters_bitmap(flood_bitmap, bridge_device, mlxsw_sp);
1518 
1519 	mid->mid = mid_idx;
1520 	err = mlxsw_sp_port_smid_full_entry(mlxsw_sp, mid_idx, flood_bitmap,
1521 					    bridge_device->mrouter);
1522 	kfree(flood_bitmap);
1523 	if (err)
1524 		return false;
1525 
1526 	err = mlxsw_sp_port_mdb_op(mlxsw_sp, mid->addr, mid->fid, mid_idx,
1527 				   true);
1528 	if (err)
1529 		return false;
1530 
1531 	set_bit(mid_idx, mlxsw_sp->bridge->mids_bitmap);
1532 	mid->in_hw = true;
1533 	return true;
1534 }
1535 
1536 static int mlxsw_sp_mc_remove_mdb_entry(struct mlxsw_sp *mlxsw_sp,
1537 					struct mlxsw_sp_mid *mid)
1538 {
1539 	if (!mid->in_hw)
1540 		return 0;
1541 
1542 	clear_bit(mid->mid, mlxsw_sp->bridge->mids_bitmap);
1543 	mid->in_hw = false;
1544 	return mlxsw_sp_port_mdb_op(mlxsw_sp, mid->addr, mid->fid, mid->mid,
1545 				    false);
1546 }
1547 
1548 static struct
1549 mlxsw_sp_mid *__mlxsw_sp_mc_alloc(struct mlxsw_sp *mlxsw_sp,
1550 				  struct mlxsw_sp_bridge_device *bridge_device,
1551 				  const unsigned char *addr,
1552 				  u16 fid)
1553 {
1554 	struct mlxsw_sp_mid *mid;
1555 	size_t alloc_size;
1556 
1557 	mid = kzalloc(sizeof(*mid), GFP_KERNEL);
1558 	if (!mid)
1559 		return NULL;
1560 
1561 	alloc_size = sizeof(unsigned long) *
1562 		     BITS_TO_LONGS(mlxsw_core_max_ports(mlxsw_sp->core));
1563 
1564 	mid->ports_in_mid = kzalloc(alloc_size, GFP_KERNEL);
1565 	if (!mid->ports_in_mid)
1566 		goto err_ports_in_mid_alloc;
1567 
1568 	ether_addr_copy(mid->addr, addr);
1569 	mid->fid = fid;
1570 	mid->in_hw = false;
1571 
1572 	if (!bridge_device->multicast_enabled)
1573 		goto out;
1574 
1575 	if (!mlxsw_sp_mc_write_mdb_entry(mlxsw_sp, mid, bridge_device))
1576 		goto err_write_mdb_entry;
1577 
1578 out:
1579 	list_add_tail(&mid->list, &bridge_device->mids_list);
1580 	return mid;
1581 
1582 err_write_mdb_entry:
1583 	kfree(mid->ports_in_mid);
1584 err_ports_in_mid_alloc:
1585 	kfree(mid);
1586 	return NULL;
1587 }
1588 
1589 static int mlxsw_sp_port_remove_from_mid(struct mlxsw_sp_port *mlxsw_sp_port,
1590 					 struct mlxsw_sp_mid *mid)
1591 {
1592 	struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
1593 	int err = 0;
1594 
1595 	clear_bit(mlxsw_sp_port->local_port, mid->ports_in_mid);
1596 	if (bitmap_empty(mid->ports_in_mid,
1597 			 mlxsw_core_max_ports(mlxsw_sp->core))) {
1598 		err = mlxsw_sp_mc_remove_mdb_entry(mlxsw_sp, mid);
1599 		list_del(&mid->list);
1600 		kfree(mid->ports_in_mid);
1601 		kfree(mid);
1602 	}
1603 	return err;
1604 }
1605 
1606 static int mlxsw_sp_port_mdb_add(struct mlxsw_sp_port *mlxsw_sp_port,
1607 				 const struct switchdev_obj_port_mdb *mdb,
1608 				 struct switchdev_trans *trans)
1609 {
1610 	struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
1611 	struct net_device *orig_dev = mdb->obj.orig_dev;
1612 	struct mlxsw_sp_port_vlan *mlxsw_sp_port_vlan;
1613 	struct net_device *dev = mlxsw_sp_port->dev;
1614 	struct mlxsw_sp_bridge_device *bridge_device;
1615 	struct mlxsw_sp_bridge_port *bridge_port;
1616 	struct mlxsw_sp_mid *mid;
1617 	u16 fid_index;
1618 	int err = 0;
1619 
1620 	if (switchdev_trans_ph_prepare(trans))
1621 		return 0;
1622 
1623 	bridge_port = mlxsw_sp_bridge_port_find(mlxsw_sp->bridge, orig_dev);
1624 	if (!bridge_port)
1625 		return 0;
1626 
1627 	bridge_device = bridge_port->bridge_device;
1628 	mlxsw_sp_port_vlan = mlxsw_sp_port_vlan_find_by_bridge(mlxsw_sp_port,
1629 							       bridge_device,
1630 							       mdb->vid);
1631 	if (!mlxsw_sp_port_vlan)
1632 		return 0;
1633 
1634 	fid_index = mlxsw_sp_fid_index(mlxsw_sp_port_vlan->fid);
1635 
1636 	mid = __mlxsw_sp_mc_get(bridge_device, mdb->addr, fid_index);
1637 	if (!mid) {
1638 		mid = __mlxsw_sp_mc_alloc(mlxsw_sp, bridge_device, mdb->addr,
1639 					  fid_index);
1640 		if (!mid) {
1641 			netdev_err(dev, "Unable to allocate MC group\n");
1642 			return -ENOMEM;
1643 		}
1644 	}
1645 	set_bit(mlxsw_sp_port->local_port, mid->ports_in_mid);
1646 
1647 	if (!bridge_device->multicast_enabled)
1648 		return 0;
1649 
1650 	if (bridge_port->mrouter)
1651 		return 0;
1652 
1653 	err = mlxsw_sp_port_smid_set(mlxsw_sp_port, mid->mid, true);
1654 	if (err) {
1655 		netdev_err(dev, "Unable to set SMID\n");
1656 		goto err_out;
1657 	}
1658 
1659 	return 0;
1660 
1661 err_out:
1662 	mlxsw_sp_port_remove_from_mid(mlxsw_sp_port, mid);
1663 	return err;
1664 }
1665 
1666 static void
1667 mlxsw_sp_bridge_mdb_mc_enable_sync(struct mlxsw_sp_port *mlxsw_sp_port,
1668 				   struct mlxsw_sp_bridge_device
1669 				   *bridge_device)
1670 {
1671 	struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
1672 	struct mlxsw_sp_mid *mid;
1673 	bool mc_enabled;
1674 
1675 	mc_enabled = bridge_device->multicast_enabled;
1676 
1677 	list_for_each_entry(mid, &bridge_device->mids_list, list) {
1678 		if (mc_enabled)
1679 			mlxsw_sp_mc_write_mdb_entry(mlxsw_sp, mid,
1680 						    bridge_device);
1681 		else
1682 			mlxsw_sp_mc_remove_mdb_entry(mlxsw_sp, mid);
1683 	}
1684 }
1685 
1686 static void
1687 mlxsw_sp_port_mrouter_update_mdb(struct mlxsw_sp_port *mlxsw_sp_port,
1688 				 struct mlxsw_sp_bridge_port *bridge_port,
1689 				 bool add)
1690 {
1691 	struct mlxsw_sp_bridge_device *bridge_device;
1692 	struct mlxsw_sp_mid *mid;
1693 
1694 	bridge_device = bridge_port->bridge_device;
1695 
1696 	list_for_each_entry(mid, &bridge_device->mids_list, list) {
1697 		if (!test_bit(mlxsw_sp_port->local_port, mid->ports_in_mid))
1698 			mlxsw_sp_port_smid_set(mlxsw_sp_port, mid->mid, add);
1699 	}
1700 }
1701 
1702 struct mlxsw_sp_span_respin_work {
1703 	struct work_struct work;
1704 	struct mlxsw_sp *mlxsw_sp;
1705 };
1706 
1707 static void mlxsw_sp_span_respin_work(struct work_struct *work)
1708 {
1709 	struct mlxsw_sp_span_respin_work *respin_work =
1710 		container_of(work, struct mlxsw_sp_span_respin_work, work);
1711 
1712 	rtnl_lock();
1713 	mlxsw_sp_span_respin(respin_work->mlxsw_sp);
1714 	rtnl_unlock();
1715 	kfree(respin_work);
1716 }
1717 
1718 static void mlxsw_sp_span_respin_schedule(struct mlxsw_sp *mlxsw_sp)
1719 {
1720 	struct mlxsw_sp_span_respin_work *respin_work;
1721 
1722 	respin_work = kzalloc(sizeof(*respin_work), GFP_ATOMIC);
1723 	if (!respin_work)
1724 		return;
1725 
1726 	INIT_WORK(&respin_work->work, mlxsw_sp_span_respin_work);
1727 	respin_work->mlxsw_sp = mlxsw_sp;
1728 
1729 	mlxsw_core_schedule_work(&respin_work->work);
1730 }
1731 
1732 static int mlxsw_sp_port_obj_add(struct net_device *dev,
1733 				 const struct switchdev_obj *obj,
1734 				 struct switchdev_trans *trans)
1735 {
1736 	struct mlxsw_sp_port *mlxsw_sp_port = netdev_priv(dev);
1737 	const struct switchdev_obj_port_vlan *vlan;
1738 	int err = 0;
1739 
1740 	switch (obj->id) {
1741 	case SWITCHDEV_OBJ_ID_PORT_VLAN:
1742 		vlan = SWITCHDEV_OBJ_PORT_VLAN(obj);
1743 		err = mlxsw_sp_port_vlans_add(mlxsw_sp_port, vlan, trans);
1744 
1745 		if (switchdev_trans_ph_prepare(trans)) {
1746 			/* The event is emitted before the changes are actually
1747 			 * applied to the bridge. Therefore schedule the respin
1748 			 * call for later, so that the respin logic sees the
1749 			 * updated bridge state.
1750 			 */
1751 			mlxsw_sp_span_respin_schedule(mlxsw_sp_port->mlxsw_sp);
1752 		}
1753 		break;
1754 	case SWITCHDEV_OBJ_ID_PORT_MDB:
1755 		err = mlxsw_sp_port_mdb_add(mlxsw_sp_port,
1756 					    SWITCHDEV_OBJ_PORT_MDB(obj),
1757 					    trans);
1758 		break;
1759 	default:
1760 		err = -EOPNOTSUPP;
1761 		break;
1762 	}
1763 
1764 	return err;
1765 }
1766 
1767 static void
1768 mlxsw_sp_bridge_port_vlan_del(struct mlxsw_sp_port *mlxsw_sp_port,
1769 			      struct mlxsw_sp_bridge_port *bridge_port, u16 vid)
1770 {
1771 	u16 pvid = mlxsw_sp_port->pvid == vid ? 0 : vid;
1772 	struct mlxsw_sp_port_vlan *mlxsw_sp_port_vlan;
1773 
1774 	mlxsw_sp_port_vlan = mlxsw_sp_port_vlan_find_by_vid(mlxsw_sp_port, vid);
1775 	if (WARN_ON(!mlxsw_sp_port_vlan))
1776 		return;
1777 
1778 	mlxsw_sp_port_vlan_bridge_leave(mlxsw_sp_port_vlan);
1779 	mlxsw_sp_port_pvid_set(mlxsw_sp_port, pvid);
1780 	mlxsw_sp_port_vlan_set(mlxsw_sp_port, vid, vid, false, false);
1781 	mlxsw_sp_port_vlan_put(mlxsw_sp_port_vlan);
1782 }
1783 
1784 static int mlxsw_sp_port_vlans_del(struct mlxsw_sp_port *mlxsw_sp_port,
1785 				   const struct switchdev_obj_port_vlan *vlan)
1786 {
1787 	struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
1788 	struct net_device *orig_dev = vlan->obj.orig_dev;
1789 	struct mlxsw_sp_bridge_port *bridge_port;
1790 	u16 vid;
1791 
1792 	if (netif_is_bridge_master(orig_dev))
1793 		return -EOPNOTSUPP;
1794 
1795 	bridge_port = mlxsw_sp_bridge_port_find(mlxsw_sp->bridge, orig_dev);
1796 	if (WARN_ON(!bridge_port))
1797 		return -EINVAL;
1798 
1799 	if (!bridge_port->bridge_device->vlan_enabled)
1800 		return 0;
1801 
1802 	for (vid = vlan->vid_begin; vid <= vlan->vid_end; vid++)
1803 		mlxsw_sp_bridge_port_vlan_del(mlxsw_sp_port, bridge_port, vid);
1804 
1805 	return 0;
1806 }
1807 
1808 static int
1809 __mlxsw_sp_port_mdb_del(struct mlxsw_sp_port *mlxsw_sp_port,
1810 			struct mlxsw_sp_bridge_port *bridge_port,
1811 			struct mlxsw_sp_mid *mid)
1812 {
1813 	struct net_device *dev = mlxsw_sp_port->dev;
1814 	int err;
1815 
1816 	if (bridge_port->bridge_device->multicast_enabled &&
1817 	    !bridge_port->mrouter) {
1818 		err = mlxsw_sp_port_smid_set(mlxsw_sp_port, mid->mid, false);
1819 		if (err)
1820 			netdev_err(dev, "Unable to remove port from SMID\n");
1821 	}
1822 
1823 	err = mlxsw_sp_port_remove_from_mid(mlxsw_sp_port, mid);
1824 	if (err)
1825 		netdev_err(dev, "Unable to remove MC SFD\n");
1826 
1827 	return err;
1828 }
1829 
1830 static int mlxsw_sp_port_mdb_del(struct mlxsw_sp_port *mlxsw_sp_port,
1831 				 const struct switchdev_obj_port_mdb *mdb)
1832 {
1833 	struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
1834 	struct net_device *orig_dev = mdb->obj.orig_dev;
1835 	struct mlxsw_sp_port_vlan *mlxsw_sp_port_vlan;
1836 	struct mlxsw_sp_bridge_device *bridge_device;
1837 	struct net_device *dev = mlxsw_sp_port->dev;
1838 	struct mlxsw_sp_bridge_port *bridge_port;
1839 	struct mlxsw_sp_mid *mid;
1840 	u16 fid_index;
1841 
1842 	bridge_port = mlxsw_sp_bridge_port_find(mlxsw_sp->bridge, orig_dev);
1843 	if (!bridge_port)
1844 		return 0;
1845 
1846 	bridge_device = bridge_port->bridge_device;
1847 	mlxsw_sp_port_vlan = mlxsw_sp_port_vlan_find_by_bridge(mlxsw_sp_port,
1848 							       bridge_device,
1849 							       mdb->vid);
1850 	if (!mlxsw_sp_port_vlan)
1851 		return 0;
1852 
1853 	fid_index = mlxsw_sp_fid_index(mlxsw_sp_port_vlan->fid);
1854 
1855 	mid = __mlxsw_sp_mc_get(bridge_device, mdb->addr, fid_index);
1856 	if (!mid) {
1857 		netdev_err(dev, "Unable to remove port from MC DB\n");
1858 		return -EINVAL;
1859 	}
1860 
1861 	return __mlxsw_sp_port_mdb_del(mlxsw_sp_port, bridge_port, mid);
1862 }
1863 
1864 static void
1865 mlxsw_sp_bridge_port_mdb_flush(struct mlxsw_sp_port *mlxsw_sp_port,
1866 			       struct mlxsw_sp_bridge_port *bridge_port)
1867 {
1868 	struct mlxsw_sp_bridge_device *bridge_device;
1869 	struct mlxsw_sp_mid *mid, *tmp;
1870 
1871 	bridge_device = bridge_port->bridge_device;
1872 
1873 	list_for_each_entry_safe(mid, tmp, &bridge_device->mids_list, list) {
1874 		if (test_bit(mlxsw_sp_port->local_port, mid->ports_in_mid)) {
1875 			__mlxsw_sp_port_mdb_del(mlxsw_sp_port, bridge_port,
1876 						mid);
1877 		} else if (bridge_device->multicast_enabled &&
1878 			   bridge_port->mrouter) {
1879 			mlxsw_sp_port_smid_set(mlxsw_sp_port, mid->mid, false);
1880 		}
1881 	}
1882 }
1883 
1884 static int mlxsw_sp_port_obj_del(struct net_device *dev,
1885 				 const struct switchdev_obj *obj)
1886 {
1887 	struct mlxsw_sp_port *mlxsw_sp_port = netdev_priv(dev);
1888 	int err = 0;
1889 
1890 	switch (obj->id) {
1891 	case SWITCHDEV_OBJ_ID_PORT_VLAN:
1892 		err = mlxsw_sp_port_vlans_del(mlxsw_sp_port,
1893 					      SWITCHDEV_OBJ_PORT_VLAN(obj));
1894 		break;
1895 	case SWITCHDEV_OBJ_ID_PORT_MDB:
1896 		err = mlxsw_sp_port_mdb_del(mlxsw_sp_port,
1897 					    SWITCHDEV_OBJ_PORT_MDB(obj));
1898 		break;
1899 	default:
1900 		err = -EOPNOTSUPP;
1901 		break;
1902 	}
1903 
1904 	mlxsw_sp_span_respin_schedule(mlxsw_sp_port->mlxsw_sp);
1905 
1906 	return err;
1907 }
1908 
1909 static struct mlxsw_sp_port *mlxsw_sp_lag_rep_port(struct mlxsw_sp *mlxsw_sp,
1910 						   u16 lag_id)
1911 {
1912 	struct mlxsw_sp_port *mlxsw_sp_port;
1913 	u64 max_lag_members;
1914 	int i;
1915 
1916 	max_lag_members = MLXSW_CORE_RES_GET(mlxsw_sp->core,
1917 					     MAX_LAG_MEMBERS);
1918 	for (i = 0; i < max_lag_members; i++) {
1919 		mlxsw_sp_port = mlxsw_sp_port_lagged_get(mlxsw_sp, lag_id, i);
1920 		if (mlxsw_sp_port)
1921 			return mlxsw_sp_port;
1922 	}
1923 	return NULL;
1924 }
1925 
1926 static const struct switchdev_ops mlxsw_sp_port_switchdev_ops = {
1927 	.switchdev_port_attr_get	= mlxsw_sp_port_attr_get,
1928 	.switchdev_port_attr_set	= mlxsw_sp_port_attr_set,
1929 	.switchdev_port_obj_add		= mlxsw_sp_port_obj_add,
1930 	.switchdev_port_obj_del		= mlxsw_sp_port_obj_del,
1931 };
1932 
1933 static int
1934 mlxsw_sp_bridge_8021q_port_join(struct mlxsw_sp_bridge_device *bridge_device,
1935 				struct mlxsw_sp_bridge_port *bridge_port,
1936 				struct mlxsw_sp_port *mlxsw_sp_port,
1937 				struct netlink_ext_ack *extack)
1938 {
1939 	struct mlxsw_sp_port_vlan *mlxsw_sp_port_vlan;
1940 
1941 	if (is_vlan_dev(bridge_port->dev)) {
1942 		NL_SET_ERR_MSG_MOD(extack, "Can not enslave a VLAN device to a VLAN-aware bridge");
1943 		return -EINVAL;
1944 	}
1945 
1946 	mlxsw_sp_port_vlan = mlxsw_sp_port_vlan_find_by_vid(mlxsw_sp_port, 1);
1947 	if (WARN_ON(!mlxsw_sp_port_vlan))
1948 		return -EINVAL;
1949 
1950 	/* Let VLAN-aware bridge take care of its own VLANs */
1951 	mlxsw_sp_port_vlan_put(mlxsw_sp_port_vlan);
1952 
1953 	return 0;
1954 }
1955 
1956 static void
1957 mlxsw_sp_bridge_8021q_port_leave(struct mlxsw_sp_bridge_device *bridge_device,
1958 				 struct mlxsw_sp_bridge_port *bridge_port,
1959 				 struct mlxsw_sp_port *mlxsw_sp_port)
1960 {
1961 	mlxsw_sp_port_vlan_get(mlxsw_sp_port, 1);
1962 	/* Make sure untagged frames are allowed to ingress */
1963 	mlxsw_sp_port_pvid_set(mlxsw_sp_port, 1);
1964 }
1965 
1966 static struct mlxsw_sp_fid *
1967 mlxsw_sp_bridge_8021q_fid_get(struct mlxsw_sp_bridge_device *bridge_device,
1968 			      u16 vid)
1969 {
1970 	struct mlxsw_sp *mlxsw_sp = mlxsw_sp_lower_get(bridge_device->dev);
1971 
1972 	return mlxsw_sp_fid_8021q_get(mlxsw_sp, vid);
1973 }
1974 
1975 static const struct mlxsw_sp_bridge_ops mlxsw_sp_bridge_8021q_ops = {
1976 	.port_join	= mlxsw_sp_bridge_8021q_port_join,
1977 	.port_leave	= mlxsw_sp_bridge_8021q_port_leave,
1978 	.fid_get	= mlxsw_sp_bridge_8021q_fid_get,
1979 };
1980 
1981 static bool
1982 mlxsw_sp_port_is_br_member(const struct mlxsw_sp_port *mlxsw_sp_port,
1983 			   const struct net_device *br_dev)
1984 {
1985 	struct mlxsw_sp_port_vlan *mlxsw_sp_port_vlan;
1986 
1987 	list_for_each_entry(mlxsw_sp_port_vlan, &mlxsw_sp_port->vlans_list,
1988 			    list) {
1989 		if (mlxsw_sp_port_vlan->bridge_port &&
1990 		    mlxsw_sp_port_vlan->bridge_port->bridge_device->dev ==
1991 		    br_dev)
1992 			return true;
1993 	}
1994 
1995 	return false;
1996 }
1997 
1998 static int
1999 mlxsw_sp_bridge_8021d_port_join(struct mlxsw_sp_bridge_device *bridge_device,
2000 				struct mlxsw_sp_bridge_port *bridge_port,
2001 				struct mlxsw_sp_port *mlxsw_sp_port,
2002 				struct netlink_ext_ack *extack)
2003 {
2004 	struct mlxsw_sp_port_vlan *mlxsw_sp_port_vlan;
2005 	struct net_device *dev = bridge_port->dev;
2006 	u16 vid;
2007 
2008 	vid = is_vlan_dev(dev) ? vlan_dev_vlan_id(dev) : 1;
2009 	mlxsw_sp_port_vlan = mlxsw_sp_port_vlan_find_by_vid(mlxsw_sp_port, vid);
2010 	if (WARN_ON(!mlxsw_sp_port_vlan))
2011 		return -EINVAL;
2012 
2013 	if (mlxsw_sp_port_is_br_member(mlxsw_sp_port, bridge_device->dev)) {
2014 		NL_SET_ERR_MSG_MOD(extack, "Can not bridge VLAN uppers of the same port");
2015 		return -EINVAL;
2016 	}
2017 
2018 	/* Port is no longer usable as a router interface */
2019 	if (mlxsw_sp_port_vlan->fid)
2020 		mlxsw_sp_port_vlan_router_leave(mlxsw_sp_port_vlan);
2021 
2022 	return mlxsw_sp_port_vlan_bridge_join(mlxsw_sp_port_vlan, bridge_port);
2023 }
2024 
2025 static void
2026 mlxsw_sp_bridge_8021d_port_leave(struct mlxsw_sp_bridge_device *bridge_device,
2027 				 struct mlxsw_sp_bridge_port *bridge_port,
2028 				 struct mlxsw_sp_port *mlxsw_sp_port)
2029 {
2030 	struct mlxsw_sp_port_vlan *mlxsw_sp_port_vlan;
2031 	struct net_device *dev = bridge_port->dev;
2032 	u16 vid;
2033 
2034 	vid = is_vlan_dev(dev) ? vlan_dev_vlan_id(dev) : 1;
2035 	mlxsw_sp_port_vlan = mlxsw_sp_port_vlan_find_by_vid(mlxsw_sp_port, vid);
2036 	if (WARN_ON(!mlxsw_sp_port_vlan))
2037 		return;
2038 
2039 	mlxsw_sp_port_vlan_bridge_leave(mlxsw_sp_port_vlan);
2040 }
2041 
2042 static struct mlxsw_sp_fid *
2043 mlxsw_sp_bridge_8021d_fid_get(struct mlxsw_sp_bridge_device *bridge_device,
2044 			      u16 vid)
2045 {
2046 	struct mlxsw_sp *mlxsw_sp = mlxsw_sp_lower_get(bridge_device->dev);
2047 
2048 	return mlxsw_sp_fid_8021d_get(mlxsw_sp, bridge_device->dev->ifindex);
2049 }
2050 
2051 static const struct mlxsw_sp_bridge_ops mlxsw_sp_bridge_8021d_ops = {
2052 	.port_join	= mlxsw_sp_bridge_8021d_port_join,
2053 	.port_leave	= mlxsw_sp_bridge_8021d_port_leave,
2054 	.fid_get	= mlxsw_sp_bridge_8021d_fid_get,
2055 };
2056 
2057 int mlxsw_sp_port_bridge_join(struct mlxsw_sp_port *mlxsw_sp_port,
2058 			      struct net_device *brport_dev,
2059 			      struct net_device *br_dev,
2060 			      struct netlink_ext_ack *extack)
2061 {
2062 	struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
2063 	struct mlxsw_sp_bridge_device *bridge_device;
2064 	struct mlxsw_sp_bridge_port *bridge_port;
2065 	int err;
2066 
2067 	bridge_port = mlxsw_sp_bridge_port_get(mlxsw_sp->bridge, brport_dev);
2068 	if (IS_ERR(bridge_port))
2069 		return PTR_ERR(bridge_port);
2070 	bridge_device = bridge_port->bridge_device;
2071 
2072 	err = bridge_device->ops->port_join(bridge_device, bridge_port,
2073 					    mlxsw_sp_port, extack);
2074 	if (err)
2075 		goto err_port_join;
2076 
2077 	return 0;
2078 
2079 err_port_join:
2080 	mlxsw_sp_bridge_port_put(mlxsw_sp->bridge, bridge_port);
2081 	return err;
2082 }
2083 
2084 void mlxsw_sp_port_bridge_leave(struct mlxsw_sp_port *mlxsw_sp_port,
2085 				struct net_device *brport_dev,
2086 				struct net_device *br_dev)
2087 {
2088 	struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
2089 	struct mlxsw_sp_bridge_device *bridge_device;
2090 	struct mlxsw_sp_bridge_port *bridge_port;
2091 
2092 	bridge_device = mlxsw_sp_bridge_device_find(mlxsw_sp->bridge, br_dev);
2093 	if (!bridge_device)
2094 		return;
2095 	bridge_port = __mlxsw_sp_bridge_port_find(bridge_device, brport_dev);
2096 	if (!bridge_port)
2097 		return;
2098 
2099 	bridge_device->ops->port_leave(bridge_device, bridge_port,
2100 				       mlxsw_sp_port);
2101 	mlxsw_sp_bridge_port_put(mlxsw_sp->bridge, bridge_port);
2102 }
2103 
2104 static void
2105 mlxsw_sp_fdb_call_notifiers(enum switchdev_notifier_type type,
2106 			    const char *mac, u16 vid,
2107 			    struct net_device *dev)
2108 {
2109 	struct switchdev_notifier_fdb_info info;
2110 
2111 	info.addr = mac;
2112 	info.vid = vid;
2113 	call_switchdev_notifiers(type, dev, &info.info);
2114 }
2115 
2116 static void mlxsw_sp_fdb_notify_mac_process(struct mlxsw_sp *mlxsw_sp,
2117 					    char *sfn_pl, int rec_index,
2118 					    bool adding)
2119 {
2120 	struct mlxsw_sp_port_vlan *mlxsw_sp_port_vlan;
2121 	struct mlxsw_sp_bridge_device *bridge_device;
2122 	struct mlxsw_sp_bridge_port *bridge_port;
2123 	struct mlxsw_sp_port *mlxsw_sp_port;
2124 	enum switchdev_notifier_type type;
2125 	char mac[ETH_ALEN];
2126 	u8 local_port;
2127 	u16 vid, fid;
2128 	bool do_notification = true;
2129 	int err;
2130 
2131 	mlxsw_reg_sfn_mac_unpack(sfn_pl, rec_index, mac, &fid, &local_port);
2132 	mlxsw_sp_port = mlxsw_sp->ports[local_port];
2133 	if (!mlxsw_sp_port) {
2134 		dev_err_ratelimited(mlxsw_sp->bus_info->dev, "Incorrect local port in FDB notification\n");
2135 		goto just_remove;
2136 	}
2137 
2138 	mlxsw_sp_port_vlan = mlxsw_sp_port_vlan_find_by_fid(mlxsw_sp_port, fid);
2139 	if (!mlxsw_sp_port_vlan) {
2140 		netdev_err(mlxsw_sp_port->dev, "Failed to find a matching {Port, VID} following FDB notification\n");
2141 		goto just_remove;
2142 	}
2143 
2144 	bridge_port = mlxsw_sp_port_vlan->bridge_port;
2145 	if (!bridge_port) {
2146 		netdev_err(mlxsw_sp_port->dev, "{Port, VID} not associated with a bridge\n");
2147 		goto just_remove;
2148 	}
2149 
2150 	bridge_device = bridge_port->bridge_device;
2151 	vid = bridge_device->vlan_enabled ? mlxsw_sp_port_vlan->vid : 0;
2152 
2153 do_fdb_op:
2154 	err = mlxsw_sp_port_fdb_uc_op(mlxsw_sp, local_port, mac, fid,
2155 				      adding, true);
2156 	if (err) {
2157 		dev_err_ratelimited(mlxsw_sp->bus_info->dev, "Failed to set FDB entry\n");
2158 		return;
2159 	}
2160 
2161 	if (!do_notification)
2162 		return;
2163 	type = adding ? SWITCHDEV_FDB_ADD_TO_BRIDGE : SWITCHDEV_FDB_DEL_TO_BRIDGE;
2164 	mlxsw_sp_fdb_call_notifiers(type, mac, vid, bridge_port->dev);
2165 
2166 	return;
2167 
2168 just_remove:
2169 	adding = false;
2170 	do_notification = false;
2171 	goto do_fdb_op;
2172 }
2173 
2174 static void mlxsw_sp_fdb_notify_mac_lag_process(struct mlxsw_sp *mlxsw_sp,
2175 						char *sfn_pl, int rec_index,
2176 						bool adding)
2177 {
2178 	struct mlxsw_sp_port_vlan *mlxsw_sp_port_vlan;
2179 	struct mlxsw_sp_bridge_device *bridge_device;
2180 	struct mlxsw_sp_bridge_port *bridge_port;
2181 	struct mlxsw_sp_port *mlxsw_sp_port;
2182 	enum switchdev_notifier_type type;
2183 	char mac[ETH_ALEN];
2184 	u16 lag_vid = 0;
2185 	u16 lag_id;
2186 	u16 vid, fid;
2187 	bool do_notification = true;
2188 	int err;
2189 
2190 	mlxsw_reg_sfn_mac_lag_unpack(sfn_pl, rec_index, mac, &fid, &lag_id);
2191 	mlxsw_sp_port = mlxsw_sp_lag_rep_port(mlxsw_sp, lag_id);
2192 	if (!mlxsw_sp_port) {
2193 		dev_err_ratelimited(mlxsw_sp->bus_info->dev, "Cannot find port representor for LAG\n");
2194 		goto just_remove;
2195 	}
2196 
2197 	mlxsw_sp_port_vlan = mlxsw_sp_port_vlan_find_by_fid(mlxsw_sp_port, fid);
2198 	if (!mlxsw_sp_port_vlan) {
2199 		netdev_err(mlxsw_sp_port->dev, "Failed to find a matching {Port, VID} following FDB notification\n");
2200 		goto just_remove;
2201 	}
2202 
2203 	bridge_port = mlxsw_sp_port_vlan->bridge_port;
2204 	if (!bridge_port) {
2205 		netdev_err(mlxsw_sp_port->dev, "{Port, VID} not associated with a bridge\n");
2206 		goto just_remove;
2207 	}
2208 
2209 	bridge_device = bridge_port->bridge_device;
2210 	vid = bridge_device->vlan_enabled ? mlxsw_sp_port_vlan->vid : 0;
2211 	lag_vid = mlxsw_sp_port_vlan->vid;
2212 
2213 do_fdb_op:
2214 	err = mlxsw_sp_port_fdb_uc_lag_op(mlxsw_sp, lag_id, mac, fid, lag_vid,
2215 					  adding, true);
2216 	if (err) {
2217 		dev_err_ratelimited(mlxsw_sp->bus_info->dev, "Failed to set FDB entry\n");
2218 		return;
2219 	}
2220 
2221 	if (!do_notification)
2222 		return;
2223 	type = adding ? SWITCHDEV_FDB_ADD_TO_BRIDGE : SWITCHDEV_FDB_DEL_TO_BRIDGE;
2224 	mlxsw_sp_fdb_call_notifiers(type, mac, vid, bridge_port->dev);
2225 
2226 	return;
2227 
2228 just_remove:
2229 	adding = false;
2230 	do_notification = false;
2231 	goto do_fdb_op;
2232 }
2233 
2234 static void mlxsw_sp_fdb_notify_rec_process(struct mlxsw_sp *mlxsw_sp,
2235 					    char *sfn_pl, int rec_index)
2236 {
2237 	switch (mlxsw_reg_sfn_rec_type_get(sfn_pl, rec_index)) {
2238 	case MLXSW_REG_SFN_REC_TYPE_LEARNED_MAC:
2239 		mlxsw_sp_fdb_notify_mac_process(mlxsw_sp, sfn_pl,
2240 						rec_index, true);
2241 		break;
2242 	case MLXSW_REG_SFN_REC_TYPE_AGED_OUT_MAC:
2243 		mlxsw_sp_fdb_notify_mac_process(mlxsw_sp, sfn_pl,
2244 						rec_index, false);
2245 		break;
2246 	case MLXSW_REG_SFN_REC_TYPE_LEARNED_MAC_LAG:
2247 		mlxsw_sp_fdb_notify_mac_lag_process(mlxsw_sp, sfn_pl,
2248 						    rec_index, true);
2249 		break;
2250 	case MLXSW_REG_SFN_REC_TYPE_AGED_OUT_MAC_LAG:
2251 		mlxsw_sp_fdb_notify_mac_lag_process(mlxsw_sp, sfn_pl,
2252 						    rec_index, false);
2253 		break;
2254 	}
2255 }
2256 
2257 static void mlxsw_sp_fdb_notify_work_schedule(struct mlxsw_sp *mlxsw_sp)
2258 {
2259 	struct mlxsw_sp_bridge *bridge = mlxsw_sp->bridge;
2260 
2261 	mlxsw_core_schedule_dw(&bridge->fdb_notify.dw,
2262 			       msecs_to_jiffies(bridge->fdb_notify.interval));
2263 }
2264 
2265 static void mlxsw_sp_fdb_notify_work(struct work_struct *work)
2266 {
2267 	struct mlxsw_sp_bridge *bridge;
2268 	struct mlxsw_sp *mlxsw_sp;
2269 	char *sfn_pl;
2270 	u8 num_rec;
2271 	int i;
2272 	int err;
2273 
2274 	sfn_pl = kmalloc(MLXSW_REG_SFN_LEN, GFP_KERNEL);
2275 	if (!sfn_pl)
2276 		return;
2277 
2278 	bridge = container_of(work, struct mlxsw_sp_bridge, fdb_notify.dw.work);
2279 	mlxsw_sp = bridge->mlxsw_sp;
2280 
2281 	rtnl_lock();
2282 	mlxsw_reg_sfn_pack(sfn_pl);
2283 	err = mlxsw_reg_query(mlxsw_sp->core, MLXSW_REG(sfn), sfn_pl);
2284 	if (err) {
2285 		dev_err_ratelimited(mlxsw_sp->bus_info->dev, "Failed to get FDB notifications\n");
2286 		goto out;
2287 	}
2288 	num_rec = mlxsw_reg_sfn_num_rec_get(sfn_pl);
2289 	for (i = 0; i < num_rec; i++)
2290 		mlxsw_sp_fdb_notify_rec_process(mlxsw_sp, sfn_pl, i);
2291 
2292 out:
2293 	rtnl_unlock();
2294 	kfree(sfn_pl);
2295 	mlxsw_sp_fdb_notify_work_schedule(mlxsw_sp);
2296 }
2297 
2298 struct mlxsw_sp_switchdev_event_work {
2299 	struct work_struct work;
2300 	struct switchdev_notifier_fdb_info fdb_info;
2301 	struct net_device *dev;
2302 	unsigned long event;
2303 };
2304 
2305 static void mlxsw_sp_switchdev_event_work(struct work_struct *work)
2306 {
2307 	struct mlxsw_sp_switchdev_event_work *switchdev_work =
2308 		container_of(work, struct mlxsw_sp_switchdev_event_work, work);
2309 	struct net_device *dev = switchdev_work->dev;
2310 	struct switchdev_notifier_fdb_info *fdb_info;
2311 	struct mlxsw_sp_port *mlxsw_sp_port;
2312 	int err;
2313 
2314 	rtnl_lock();
2315 	mlxsw_sp_port = mlxsw_sp_port_dev_lower_find(dev);
2316 	if (!mlxsw_sp_port)
2317 		goto out;
2318 
2319 	switch (switchdev_work->event) {
2320 	case SWITCHDEV_FDB_ADD_TO_DEVICE:
2321 		fdb_info = &switchdev_work->fdb_info;
2322 		if (!fdb_info->added_by_user)
2323 			break;
2324 		err = mlxsw_sp_port_fdb_set(mlxsw_sp_port, fdb_info, true);
2325 		if (err)
2326 			break;
2327 		mlxsw_sp_fdb_call_notifiers(SWITCHDEV_FDB_OFFLOADED,
2328 					    fdb_info->addr,
2329 					    fdb_info->vid, dev);
2330 		break;
2331 	case SWITCHDEV_FDB_DEL_TO_DEVICE:
2332 		fdb_info = &switchdev_work->fdb_info;
2333 		if (!fdb_info->added_by_user)
2334 			break;
2335 		mlxsw_sp_port_fdb_set(mlxsw_sp_port, fdb_info, false);
2336 		break;
2337 	case SWITCHDEV_FDB_ADD_TO_BRIDGE: /* fall through */
2338 	case SWITCHDEV_FDB_DEL_TO_BRIDGE:
2339 		/* These events are only used to potentially update an existing
2340 		 * SPAN mirror.
2341 		 */
2342 		break;
2343 	}
2344 
2345 	mlxsw_sp_span_respin(mlxsw_sp_port->mlxsw_sp);
2346 
2347 out:
2348 	rtnl_unlock();
2349 	kfree(switchdev_work->fdb_info.addr);
2350 	kfree(switchdev_work);
2351 	dev_put(dev);
2352 }
2353 
2354 /* Called under rcu_read_lock() */
2355 static int mlxsw_sp_switchdev_event(struct notifier_block *unused,
2356 				    unsigned long event, void *ptr)
2357 {
2358 	struct net_device *dev = switchdev_notifier_info_to_dev(ptr);
2359 	struct mlxsw_sp_switchdev_event_work *switchdev_work;
2360 	struct switchdev_notifier_fdb_info *fdb_info = ptr;
2361 
2362 	if (!mlxsw_sp_port_dev_lower_find_rcu(dev))
2363 		return NOTIFY_DONE;
2364 
2365 	switchdev_work = kzalloc(sizeof(*switchdev_work), GFP_ATOMIC);
2366 	if (!switchdev_work)
2367 		return NOTIFY_BAD;
2368 
2369 	INIT_WORK(&switchdev_work->work, mlxsw_sp_switchdev_event_work);
2370 	switchdev_work->dev = dev;
2371 	switchdev_work->event = event;
2372 
2373 	switch (event) {
2374 	case SWITCHDEV_FDB_ADD_TO_DEVICE: /* fall through */
2375 	case SWITCHDEV_FDB_DEL_TO_DEVICE: /* fall through */
2376 	case SWITCHDEV_FDB_ADD_TO_BRIDGE: /* fall through */
2377 	case SWITCHDEV_FDB_DEL_TO_BRIDGE:
2378 		memcpy(&switchdev_work->fdb_info, ptr,
2379 		       sizeof(switchdev_work->fdb_info));
2380 		switchdev_work->fdb_info.addr = kzalloc(ETH_ALEN, GFP_ATOMIC);
2381 		if (!switchdev_work->fdb_info.addr)
2382 			goto err_addr_alloc;
2383 		ether_addr_copy((u8 *)switchdev_work->fdb_info.addr,
2384 				fdb_info->addr);
2385 		/* Take a reference on the device. This can be either
2386 		 * upper device containig mlxsw_sp_port or just a
2387 		 * mlxsw_sp_port
2388 		 */
2389 		dev_hold(dev);
2390 		break;
2391 	default:
2392 		kfree(switchdev_work);
2393 		return NOTIFY_DONE;
2394 	}
2395 
2396 	mlxsw_core_schedule_work(&switchdev_work->work);
2397 
2398 	return NOTIFY_DONE;
2399 
2400 err_addr_alloc:
2401 	kfree(switchdev_work);
2402 	return NOTIFY_BAD;
2403 }
2404 
2405 static struct notifier_block mlxsw_sp_switchdev_notifier = {
2406 	.notifier_call = mlxsw_sp_switchdev_event,
2407 };
2408 
2409 u8
2410 mlxsw_sp_bridge_port_stp_state(struct mlxsw_sp_bridge_port *bridge_port)
2411 {
2412 	return bridge_port->stp_state;
2413 }
2414 
2415 static int mlxsw_sp_fdb_init(struct mlxsw_sp *mlxsw_sp)
2416 {
2417 	struct mlxsw_sp_bridge *bridge = mlxsw_sp->bridge;
2418 	int err;
2419 
2420 	err = mlxsw_sp_ageing_set(mlxsw_sp, MLXSW_SP_DEFAULT_AGEING_TIME);
2421 	if (err) {
2422 		dev_err(mlxsw_sp->bus_info->dev, "Failed to set default ageing time\n");
2423 		return err;
2424 	}
2425 
2426 	err = register_switchdev_notifier(&mlxsw_sp_switchdev_notifier);
2427 	if (err) {
2428 		dev_err(mlxsw_sp->bus_info->dev, "Failed to register switchdev notifier\n");
2429 		return err;
2430 	}
2431 
2432 	INIT_DELAYED_WORK(&bridge->fdb_notify.dw, mlxsw_sp_fdb_notify_work);
2433 	bridge->fdb_notify.interval = MLXSW_SP_DEFAULT_LEARNING_INTERVAL;
2434 	mlxsw_sp_fdb_notify_work_schedule(mlxsw_sp);
2435 	return 0;
2436 }
2437 
2438 static void mlxsw_sp_fdb_fini(struct mlxsw_sp *mlxsw_sp)
2439 {
2440 	cancel_delayed_work_sync(&mlxsw_sp->bridge->fdb_notify.dw);
2441 	unregister_switchdev_notifier(&mlxsw_sp_switchdev_notifier);
2442 
2443 }
2444 
2445 int mlxsw_sp_switchdev_init(struct mlxsw_sp *mlxsw_sp)
2446 {
2447 	struct mlxsw_sp_bridge *bridge;
2448 
2449 	bridge = kzalloc(sizeof(*mlxsw_sp->bridge), GFP_KERNEL);
2450 	if (!bridge)
2451 		return -ENOMEM;
2452 	mlxsw_sp->bridge = bridge;
2453 	bridge->mlxsw_sp = mlxsw_sp;
2454 
2455 	INIT_LIST_HEAD(&mlxsw_sp->bridge->bridges_list);
2456 
2457 	bridge->bridge_8021q_ops = &mlxsw_sp_bridge_8021q_ops;
2458 	bridge->bridge_8021d_ops = &mlxsw_sp_bridge_8021d_ops;
2459 
2460 	return mlxsw_sp_fdb_init(mlxsw_sp);
2461 }
2462 
2463 void mlxsw_sp_switchdev_fini(struct mlxsw_sp *mlxsw_sp)
2464 {
2465 	mlxsw_sp_fdb_fini(mlxsw_sp);
2466 	WARN_ON(!list_empty(&mlxsw_sp->bridge->bridges_list));
2467 	kfree(mlxsw_sp->bridge);
2468 }
2469 
2470 void mlxsw_sp_port_switchdev_init(struct mlxsw_sp_port *mlxsw_sp_port)
2471 {
2472 	mlxsw_sp_port->dev->switchdev_ops = &mlxsw_sp_port_switchdev_ops;
2473 }
2474 
2475 void mlxsw_sp_port_switchdev_fini(struct mlxsw_sp_port *mlxsw_sp_port)
2476 {
2477 }
2478