]> git.karo-electronics.de Git - karo-tx-linux.git/blob - drivers/net/ethernet/mellanox/mlxsw/spectrum_switchdev.c
mlxsw: spectrum: Add an option to flood mc by mc_router_port
[karo-tx-linux.git] / drivers / net / ethernet / mellanox / mlxsw / spectrum_switchdev.c
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 <net/switchdev.h>
50
51 #include "spectrum.h"
52 #include "core.h"
53 #include "reg.h"
54
55 static u16 mlxsw_sp_port_vid_to_fid_get(struct mlxsw_sp_port *mlxsw_sp_port,
56                                         u16 vid)
57 {
58         struct mlxsw_sp_fid *f = mlxsw_sp_vport_fid_get(mlxsw_sp_port);
59         u16 fid = vid;
60
61         fid = f ? f->fid : fid;
62
63         if (!fid)
64                 fid = mlxsw_sp_port->pvid;
65
66         return fid;
67 }
68
69 static struct mlxsw_sp_port *
70 mlxsw_sp_port_orig_get(struct net_device *dev,
71                        struct mlxsw_sp_port *mlxsw_sp_port)
72 {
73         struct mlxsw_sp_port *mlxsw_sp_vport;
74         u16 vid;
75
76         if (!is_vlan_dev(dev))
77                 return mlxsw_sp_port;
78
79         vid = vlan_dev_vlan_id(dev);
80         mlxsw_sp_vport = mlxsw_sp_port_vport_find(mlxsw_sp_port, vid);
81         WARN_ON(!mlxsw_sp_vport);
82
83         return mlxsw_sp_vport;
84 }
85
86 static int mlxsw_sp_port_attr_get(struct net_device *dev,
87                                   struct switchdev_attr *attr)
88 {
89         struct mlxsw_sp_port *mlxsw_sp_port = netdev_priv(dev);
90         struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
91
92         mlxsw_sp_port = mlxsw_sp_port_orig_get(attr->orig_dev, mlxsw_sp_port);
93         if (!mlxsw_sp_port)
94                 return -EINVAL;
95
96         switch (attr->id) {
97         case SWITCHDEV_ATTR_ID_PORT_PARENT_ID:
98                 attr->u.ppid.id_len = sizeof(mlxsw_sp->base_mac);
99                 memcpy(&attr->u.ppid.id, &mlxsw_sp->base_mac,
100                        attr->u.ppid.id_len);
101                 break;
102         case SWITCHDEV_ATTR_ID_PORT_BRIDGE_FLAGS:
103                 attr->u.brport_flags =
104                         (mlxsw_sp_port->learning ? BR_LEARNING : 0) |
105                         (mlxsw_sp_port->learning_sync ? BR_LEARNING_SYNC : 0) |
106                         (mlxsw_sp_port->uc_flood ? BR_FLOOD : 0);
107                 break;
108         default:
109                 return -EOPNOTSUPP;
110         }
111
112         return 0;
113 }
114
115 static int mlxsw_sp_port_stp_state_set(struct mlxsw_sp_port *mlxsw_sp_port,
116                                        u8 state)
117 {
118         struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
119         enum mlxsw_reg_spms_state spms_state;
120         char *spms_pl;
121         u16 vid;
122         int err;
123
124         switch (state) {
125         case BR_STATE_FORWARDING:
126                 spms_state = MLXSW_REG_SPMS_STATE_FORWARDING;
127                 break;
128         case BR_STATE_LEARNING:
129                 spms_state = MLXSW_REG_SPMS_STATE_LEARNING;
130                 break;
131         case BR_STATE_LISTENING: /* fall-through */
132         case BR_STATE_DISABLED: /* fall-through */
133         case BR_STATE_BLOCKING:
134                 spms_state = MLXSW_REG_SPMS_STATE_DISCARDING;
135                 break;
136         default:
137                 BUG();
138         }
139
140         spms_pl = kmalloc(MLXSW_REG_SPMS_LEN, GFP_KERNEL);
141         if (!spms_pl)
142                 return -ENOMEM;
143         mlxsw_reg_spms_pack(spms_pl, mlxsw_sp_port->local_port);
144
145         if (mlxsw_sp_port_is_vport(mlxsw_sp_port)) {
146                 vid = mlxsw_sp_vport_vid_get(mlxsw_sp_port);
147                 mlxsw_reg_spms_vid_pack(spms_pl, vid, spms_state);
148         } else {
149                 for_each_set_bit(vid, mlxsw_sp_port->active_vlans, VLAN_N_VID)
150                         mlxsw_reg_spms_vid_pack(spms_pl, vid, spms_state);
151         }
152
153         err = mlxsw_reg_write(mlxsw_sp->core, MLXSW_REG(spms), spms_pl);
154         kfree(spms_pl);
155         return err;
156 }
157
158 static int mlxsw_sp_port_attr_stp_state_set(struct mlxsw_sp_port *mlxsw_sp_port,
159                                             struct switchdev_trans *trans,
160                                             u8 state)
161 {
162         if (switchdev_trans_ph_prepare(trans))
163                 return 0;
164
165         mlxsw_sp_port->stp_state = state;
166         return mlxsw_sp_port_stp_state_set(mlxsw_sp_port, state);
167 }
168
169 static int __mlxsw_sp_port_flood_table_set(struct mlxsw_sp_port *mlxsw_sp_port,
170                                            u16 idx_begin, u16 idx_end,
171                                            enum mlxsw_sp_flood_table table,
172                                            bool set)
173 {
174         struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
175         u16 local_port = mlxsw_sp_port->local_port;
176         enum mlxsw_flood_table_type table_type;
177         u16 range = idx_end - idx_begin + 1;
178         char *sftr_pl;
179         int err;
180
181         if (mlxsw_sp_port_is_vport(mlxsw_sp_port))
182                 table_type = MLXSW_REG_SFGC_TABLE_TYPE_FID;
183         else
184                 table_type = MLXSW_REG_SFGC_TABLE_TYPE_FID_OFFEST;
185
186         sftr_pl = kmalloc(MLXSW_REG_SFTR_LEN, GFP_KERNEL);
187         if (!sftr_pl)
188                 return -ENOMEM;
189
190         mlxsw_reg_sftr_pack(sftr_pl, table, idx_begin,
191                             table_type, range, local_port, set);
192         err = mlxsw_reg_write(mlxsw_sp->core, MLXSW_REG(sftr), sftr_pl);
193
194         kfree(sftr_pl);
195         return err;
196 }
197
198 static int __mlxsw_sp_port_flood_set(struct mlxsw_sp_port *mlxsw_sp_port,
199                                      u16 idx_begin, u16 idx_end, bool uc_set,
200                                      bool bc_set, bool mc_set)
201 {
202         int err;
203
204         err = __mlxsw_sp_port_flood_table_set(mlxsw_sp_port, idx_begin, idx_end,
205                                               MLXSW_SP_FLOOD_TABLE_UC, uc_set);
206         if (err)
207                 return err;
208
209         err = __mlxsw_sp_port_flood_table_set(mlxsw_sp_port, idx_begin, idx_end,
210                                               MLXSW_SP_FLOOD_TABLE_BC, bc_set);
211         if (err)
212                 goto err_flood_bm_set;
213
214         err = __mlxsw_sp_port_flood_table_set(mlxsw_sp_port, idx_begin, idx_end,
215                                               MLXSW_SP_FLOOD_TABLE_MC, mc_set);
216         if (err)
217                 goto err_flood_mc_set;
218         return 0;
219
220 err_flood_mc_set:
221         __mlxsw_sp_port_flood_table_set(mlxsw_sp_port, idx_begin, idx_end,
222                                         MLXSW_SP_FLOOD_TABLE_BC, !bc_set);
223 err_flood_bm_set:
224         __mlxsw_sp_port_flood_table_set(mlxsw_sp_port, idx_begin, idx_end,
225                                         MLXSW_SP_FLOOD_TABLE_UC, !uc_set);
226         return err;
227 }
228
229 static int mlxsw_sp_port_flood_table_set(struct mlxsw_sp_port *mlxsw_sp_port,
230                                          enum mlxsw_sp_flood_table table,
231                                          bool set)
232 {
233         struct net_device *dev = mlxsw_sp_port->dev;
234         u16 vid, last_visited_vid;
235         int err;
236
237         if (mlxsw_sp_port_is_vport(mlxsw_sp_port)) {
238                 u16 fid = mlxsw_sp_vport_fid_get(mlxsw_sp_port)->fid;
239                 u16 vfid = mlxsw_sp_fid_to_vfid(fid);
240
241                 return __mlxsw_sp_port_flood_table_set(mlxsw_sp_port, vfid,
242                                                        vfid, table, set);
243         }
244
245         for_each_set_bit(vid, mlxsw_sp_port->active_vlans, VLAN_N_VID) {
246                 err = __mlxsw_sp_port_flood_table_set(mlxsw_sp_port, vid, vid,
247                                                       table, set);
248                 if (err) {
249                         last_visited_vid = vid;
250                         goto err_port_flood_set;
251                 }
252         }
253
254         return 0;
255
256 err_port_flood_set:
257         for_each_set_bit(vid, mlxsw_sp_port->active_vlans, last_visited_vid)
258                 __mlxsw_sp_port_flood_table_set(mlxsw_sp_port, vid, vid, table,
259                                                 !set);
260         netdev_err(dev, "Failed to configure unicast flooding\n");
261         return err;
262 }
263
264 int mlxsw_sp_vport_flood_set(struct mlxsw_sp_port *mlxsw_sp_vport, u16 fid,
265                              bool set)
266 {
267         bool mc_set = set;
268         u16 vfid;
269
270         /* In case of vFIDs, index into the flooding table is relative to
271          * the start of the vFIDs range.
272          */
273         vfid = mlxsw_sp_fid_to_vfid(fid);
274
275         if (set)
276                 mc_set = mlxsw_sp_vport->mc_disabled ?
277                          mlxsw_sp_vport->mc_flood : mlxsw_sp_vport->mc_router;
278
279         return __mlxsw_sp_port_flood_set(mlxsw_sp_vport, vfid, vfid, set, set,
280                                          mc_set);
281 }
282
283 static int mlxsw_sp_port_learning_set(struct mlxsw_sp_port *mlxsw_sp_port,
284                                       bool set)
285 {
286         u16 vid;
287         int err;
288
289         if (mlxsw_sp_port_is_vport(mlxsw_sp_port)) {
290                 vid = mlxsw_sp_vport_vid_get(mlxsw_sp_port);
291
292                 return __mlxsw_sp_port_vid_learning_set(mlxsw_sp_port, vid, vid,
293                                                         set);
294         }
295
296         for_each_set_bit(vid, mlxsw_sp_port->active_vlans, VLAN_N_VID) {
297                 err = __mlxsw_sp_port_vid_learning_set(mlxsw_sp_port, vid, vid,
298                                                        set);
299                 if (err)
300                         goto err_port_vid_learning_set;
301         }
302
303         return 0;
304
305 err_port_vid_learning_set:
306         for_each_set_bit(vid, mlxsw_sp_port->active_vlans, VLAN_N_VID)
307                 __mlxsw_sp_port_vid_learning_set(mlxsw_sp_port, vid, vid, !set);
308         return err;
309 }
310
311 static int mlxsw_sp_port_attr_br_flags_set(struct mlxsw_sp_port *mlxsw_sp_port,
312                                            struct switchdev_trans *trans,
313                                            unsigned long brport_flags)
314 {
315         unsigned long learning = mlxsw_sp_port->learning ? BR_LEARNING : 0;
316         unsigned long uc_flood = mlxsw_sp_port->uc_flood ? BR_FLOOD : 0;
317         int err;
318
319         if (!mlxsw_sp_port->bridged)
320                 return -EINVAL;
321
322         if (switchdev_trans_ph_prepare(trans))
323                 return 0;
324
325         if ((uc_flood ^ brport_flags) & BR_FLOOD) {
326                 err = mlxsw_sp_port_flood_table_set(mlxsw_sp_port,
327                                                     MLXSW_SP_FLOOD_TABLE_UC,
328                                                     !mlxsw_sp_port->uc_flood);
329                 if (err)
330                         return err;
331         }
332
333         if ((learning ^ brport_flags) & BR_LEARNING) {
334                 err = mlxsw_sp_port_learning_set(mlxsw_sp_port,
335                                                  !mlxsw_sp_port->learning);
336                 if (err)
337                         goto err_port_learning_set;
338         }
339
340         mlxsw_sp_port->uc_flood = brport_flags & BR_FLOOD ? 1 : 0;
341         mlxsw_sp_port->learning = brport_flags & BR_LEARNING ? 1 : 0;
342         mlxsw_sp_port->learning_sync = brport_flags & BR_LEARNING_SYNC ? 1 : 0;
343
344         return 0;
345
346 err_port_learning_set:
347         if ((uc_flood ^ brport_flags) & BR_FLOOD)
348                 mlxsw_sp_port_flood_table_set(mlxsw_sp_port,
349                                               MLXSW_SP_FLOOD_TABLE_UC,
350                                               mlxsw_sp_port->uc_flood);
351         return err;
352 }
353
354 static int mlxsw_sp_ageing_set(struct mlxsw_sp *mlxsw_sp, u32 ageing_time)
355 {
356         char sfdat_pl[MLXSW_REG_SFDAT_LEN];
357         int err;
358
359         mlxsw_reg_sfdat_pack(sfdat_pl, ageing_time);
360         err = mlxsw_reg_write(mlxsw_sp->core, MLXSW_REG(sfdat), sfdat_pl);
361         if (err)
362                 return err;
363         mlxsw_sp->ageing_time = ageing_time;
364         return 0;
365 }
366
367 static int mlxsw_sp_port_attr_br_ageing_set(struct mlxsw_sp_port *mlxsw_sp_port,
368                                             struct switchdev_trans *trans,
369                                             unsigned long ageing_clock_t)
370 {
371         struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
372         unsigned long ageing_jiffies = clock_t_to_jiffies(ageing_clock_t);
373         u32 ageing_time = jiffies_to_msecs(ageing_jiffies) / 1000;
374
375         if (switchdev_trans_ph_prepare(trans)) {
376                 if (ageing_time < MLXSW_SP_MIN_AGEING_TIME ||
377                     ageing_time > MLXSW_SP_MAX_AGEING_TIME)
378                         return -ERANGE;
379                 else
380                         return 0;
381         }
382
383         return mlxsw_sp_ageing_set(mlxsw_sp, ageing_time);
384 }
385
386 static int mlxsw_sp_port_attr_br_vlan_set(struct mlxsw_sp_port *mlxsw_sp_port,
387                                           struct switchdev_trans *trans,
388                                           struct net_device *orig_dev,
389                                           bool vlan_enabled)
390 {
391         struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
392
393         /* SWITCHDEV_TRANS_PREPARE phase */
394         if ((!vlan_enabled) && (mlxsw_sp->master_bridge.dev == orig_dev)) {
395                 netdev_err(mlxsw_sp_port->dev, "Bridge must be vlan-aware\n");
396                 return -EINVAL;
397         }
398
399         return 0;
400 }
401
402 static int mlxsw_sp_port_attr_mc_router_set(struct mlxsw_sp_port *mlxsw_sp_port,
403                                             struct switchdev_trans *trans,
404                                             bool is_port_mc_router)
405 {
406         if (switchdev_trans_ph_prepare(trans))
407                 return 0;
408
409         mlxsw_sp_port->mc_router = is_port_mc_router;
410         if (!mlxsw_sp_port->mc_disabled)
411                 return mlxsw_sp_port_flood_table_set(mlxsw_sp_port,
412                                                      MLXSW_SP_FLOOD_TABLE_MC,
413                                                      is_port_mc_router);
414
415         return 0;
416 }
417
418 static int mlxsw_sp_port_attr_set(struct net_device *dev,
419                                   const struct switchdev_attr *attr,
420                                   struct switchdev_trans *trans)
421 {
422         struct mlxsw_sp_port *mlxsw_sp_port = netdev_priv(dev);
423         int err = 0;
424
425         mlxsw_sp_port = mlxsw_sp_port_orig_get(attr->orig_dev, mlxsw_sp_port);
426         if (!mlxsw_sp_port)
427                 return -EINVAL;
428
429         switch (attr->id) {
430         case SWITCHDEV_ATTR_ID_PORT_STP_STATE:
431                 err = mlxsw_sp_port_attr_stp_state_set(mlxsw_sp_port, trans,
432                                                        attr->u.stp_state);
433                 break;
434         case SWITCHDEV_ATTR_ID_PORT_BRIDGE_FLAGS:
435                 err = mlxsw_sp_port_attr_br_flags_set(mlxsw_sp_port, trans,
436                                                       attr->u.brport_flags);
437                 break;
438         case SWITCHDEV_ATTR_ID_BRIDGE_AGEING_TIME:
439                 err = mlxsw_sp_port_attr_br_ageing_set(mlxsw_sp_port, trans,
440                                                        attr->u.ageing_time);
441                 break;
442         case SWITCHDEV_ATTR_ID_BRIDGE_VLAN_FILTERING:
443                 err = mlxsw_sp_port_attr_br_vlan_set(mlxsw_sp_port, trans,
444                                                      attr->orig_dev,
445                                                      attr->u.vlan_filtering);
446                 break;
447         case SWITCHDEV_ATTR_ID_PORT_MROUTER:
448                 err = mlxsw_sp_port_attr_mc_router_set(mlxsw_sp_port, trans,
449                                                        attr->u.mrouter);
450                 break;
451         default:
452                 err = -EOPNOTSUPP;
453                 break;
454         }
455
456         return err;
457 }
458
459 static int mlxsw_sp_fid_op(struct mlxsw_sp *mlxsw_sp, u16 fid, bool create)
460 {
461         char sfmr_pl[MLXSW_REG_SFMR_LEN];
462
463         mlxsw_reg_sfmr_pack(sfmr_pl, !create, fid, fid);
464         return mlxsw_reg_write(mlxsw_sp->core, MLXSW_REG(sfmr), sfmr_pl);
465 }
466
467 static int mlxsw_sp_fid_map(struct mlxsw_sp *mlxsw_sp, u16 fid, bool valid)
468 {
469         enum mlxsw_reg_svfa_mt mt = MLXSW_REG_SVFA_MT_VID_TO_FID;
470         char svfa_pl[MLXSW_REG_SVFA_LEN];
471
472         mlxsw_reg_svfa_pack(svfa_pl, 0, mt, valid, fid, fid);
473         return mlxsw_reg_write(mlxsw_sp->core, MLXSW_REG(svfa), svfa_pl);
474 }
475
476 static struct mlxsw_sp_fid *mlxsw_sp_fid_alloc(u16 fid)
477 {
478         struct mlxsw_sp_fid *f;
479
480         f = kzalloc(sizeof(*f), GFP_KERNEL);
481         if (!f)
482                 return NULL;
483
484         f->fid = fid;
485
486         return f;
487 }
488
489 struct mlxsw_sp_fid *mlxsw_sp_fid_create(struct mlxsw_sp *mlxsw_sp, u16 fid)
490 {
491         struct mlxsw_sp_fid *f;
492         int err;
493
494         err = mlxsw_sp_fid_op(mlxsw_sp, fid, true);
495         if (err)
496                 return ERR_PTR(err);
497
498         /* Although all the ports member in the FID might be using a
499          * {Port, VID} to FID mapping, we create a global VID-to-FID
500          * mapping. This allows a port to transition to VLAN mode,
501          * knowing the global mapping exists.
502          */
503         err = mlxsw_sp_fid_map(mlxsw_sp, fid, true);
504         if (err)
505                 goto err_fid_map;
506
507         f = mlxsw_sp_fid_alloc(fid);
508         if (!f) {
509                 err = -ENOMEM;
510                 goto err_allocate_fid;
511         }
512
513         list_add(&f->list, &mlxsw_sp->fids);
514
515         return f;
516
517 err_allocate_fid:
518         mlxsw_sp_fid_map(mlxsw_sp, fid, false);
519 err_fid_map:
520         mlxsw_sp_fid_op(mlxsw_sp, fid, false);
521         return ERR_PTR(err);
522 }
523
524 void mlxsw_sp_fid_destroy(struct mlxsw_sp *mlxsw_sp, struct mlxsw_sp_fid *f)
525 {
526         u16 fid = f->fid;
527
528         list_del(&f->list);
529
530         if (f->r)
531                 mlxsw_sp_rif_bridge_destroy(mlxsw_sp, f->r);
532
533         kfree(f);
534
535         mlxsw_sp_fid_map(mlxsw_sp, fid, false);
536
537         mlxsw_sp_fid_op(mlxsw_sp, fid, false);
538 }
539
540 static int __mlxsw_sp_port_fid_join(struct mlxsw_sp_port *mlxsw_sp_port,
541                                     u16 fid)
542 {
543         struct mlxsw_sp_fid *f;
544
545         if (test_bit(fid, mlxsw_sp_port->active_vlans))
546                 return 0;
547
548         f = mlxsw_sp_fid_find(mlxsw_sp_port->mlxsw_sp, fid);
549         if (!f) {
550                 f = mlxsw_sp_fid_create(mlxsw_sp_port->mlxsw_sp, fid);
551                 if (IS_ERR(f))
552                         return PTR_ERR(f);
553         }
554
555         f->ref_count++;
556
557         netdev_dbg(mlxsw_sp_port->dev, "Joined FID=%d\n", fid);
558
559         return 0;
560 }
561
562 static void __mlxsw_sp_port_fid_leave(struct mlxsw_sp_port *mlxsw_sp_port,
563                                       u16 fid)
564 {
565         struct mlxsw_sp_fid *f;
566
567         f = mlxsw_sp_fid_find(mlxsw_sp_port->mlxsw_sp, fid);
568         if (WARN_ON(!f))
569                 return;
570
571         netdev_dbg(mlxsw_sp_port->dev, "Left FID=%d\n", fid);
572
573         mlxsw_sp_port_fdb_flush(mlxsw_sp_port, fid);
574
575         if (--f->ref_count == 0)
576                 mlxsw_sp_fid_destroy(mlxsw_sp_port->mlxsw_sp, f);
577 }
578
579 static int mlxsw_sp_port_fid_map(struct mlxsw_sp_port *mlxsw_sp_port, u16 fid,
580                                  bool valid)
581 {
582         enum mlxsw_reg_svfa_mt mt = MLXSW_REG_SVFA_MT_PORT_VID_TO_FID;
583
584         /* If port doesn't have vPorts, then it can use the global
585          * VID-to-FID mapping.
586          */
587         if (list_empty(&mlxsw_sp_port->vports_list))
588                 return 0;
589
590         return mlxsw_sp_port_vid_to_fid_set(mlxsw_sp_port, mt, valid, fid, fid);
591 }
592
593 static int mlxsw_sp_port_fid_join(struct mlxsw_sp_port *mlxsw_sp_port,
594                                   u16 fid_begin, u16 fid_end)
595 {
596         bool mc_flood;
597         int fid, err;
598
599         for (fid = fid_begin; fid <= fid_end; fid++) {
600                 err = __mlxsw_sp_port_fid_join(mlxsw_sp_port, fid);
601                 if (err)
602                         goto err_port_fid_join;
603         }
604
605         mc_flood = mlxsw_sp_port->mc_disabled ?
606                         mlxsw_sp_port->mc_flood : mlxsw_sp_port->mc_router;
607
608         err = __mlxsw_sp_port_flood_set(mlxsw_sp_port, fid_begin, fid_end,
609                                         mlxsw_sp_port->uc_flood, true,
610                                         mc_flood);
611         if (err)
612                 goto err_port_flood_set;
613
614         for (fid = fid_begin; fid <= fid_end; fid++) {
615                 err = mlxsw_sp_port_fid_map(mlxsw_sp_port, fid, true);
616                 if (err)
617                         goto err_port_fid_map;
618         }
619
620         return 0;
621
622 err_port_fid_map:
623         for (fid--; fid >= fid_begin; fid--)
624                 mlxsw_sp_port_fid_map(mlxsw_sp_port, fid, false);
625         __mlxsw_sp_port_flood_set(mlxsw_sp_port, fid_begin, fid_end, false,
626                                   false, false);
627 err_port_flood_set:
628         fid = fid_end;
629 err_port_fid_join:
630         for (fid--; fid >= fid_begin; fid--)
631                 __mlxsw_sp_port_fid_leave(mlxsw_sp_port, fid);
632         return err;
633 }
634
635 static void mlxsw_sp_port_fid_leave(struct mlxsw_sp_port *mlxsw_sp_port,
636                                     u16 fid_begin, u16 fid_end)
637 {
638         int fid;
639
640         for (fid = fid_begin; fid <= fid_end; fid++)
641                 mlxsw_sp_port_fid_map(mlxsw_sp_port, fid, false);
642
643         __mlxsw_sp_port_flood_set(mlxsw_sp_port, fid_begin, fid_end, false,
644                                   false, false);
645
646         for (fid = fid_begin; fid <= fid_end; fid++)
647                 __mlxsw_sp_port_fid_leave(mlxsw_sp_port, fid);
648 }
649
650 static int __mlxsw_sp_port_pvid_set(struct mlxsw_sp_port *mlxsw_sp_port,
651                                     u16 vid)
652 {
653         struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
654         char spvid_pl[MLXSW_REG_SPVID_LEN];
655
656         mlxsw_reg_spvid_pack(spvid_pl, mlxsw_sp_port->local_port, vid);
657         return mlxsw_reg_write(mlxsw_sp->core, MLXSW_REG(spvid), spvid_pl);
658 }
659
660 static int mlxsw_sp_port_allow_untagged_set(struct mlxsw_sp_port *mlxsw_sp_port,
661                                             bool allow)
662 {
663         struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
664         char spaft_pl[MLXSW_REG_SPAFT_LEN];
665
666         mlxsw_reg_spaft_pack(spaft_pl, mlxsw_sp_port->local_port, allow);
667         return mlxsw_reg_write(mlxsw_sp->core, MLXSW_REG(spaft), spaft_pl);
668 }
669
670 int mlxsw_sp_port_pvid_set(struct mlxsw_sp_port *mlxsw_sp_port, u16 vid)
671 {
672         struct net_device *dev = mlxsw_sp_port->dev;
673         int err;
674
675         if (!vid) {
676                 err = mlxsw_sp_port_allow_untagged_set(mlxsw_sp_port, false);
677                 if (err) {
678                         netdev_err(dev, "Failed to disallow untagged traffic\n");
679                         return err;
680                 }
681         } else {
682                 err = __mlxsw_sp_port_pvid_set(mlxsw_sp_port, vid);
683                 if (err) {
684                         netdev_err(dev, "Failed to set PVID\n");
685                         return err;
686                 }
687
688                 /* Only allow if not already allowed. */
689                 if (!mlxsw_sp_port->pvid) {
690                         err = mlxsw_sp_port_allow_untagged_set(mlxsw_sp_port,
691                                                                true);
692                         if (err) {
693                                 netdev_err(dev, "Failed to allow untagged traffic\n");
694                                 goto err_port_allow_untagged_set;
695                         }
696                 }
697         }
698
699         mlxsw_sp_port->pvid = vid;
700         return 0;
701
702 err_port_allow_untagged_set:
703         __mlxsw_sp_port_pvid_set(mlxsw_sp_port, mlxsw_sp_port->pvid);
704         return err;
705 }
706
707 static int __mlxsw_sp_port_vlans_set(struct mlxsw_sp_port *mlxsw_sp_port,
708                                      u16 vid_begin, u16 vid_end, bool is_member,
709                                      bool untagged)
710 {
711         u16 vid, vid_e;
712         int err;
713
714         for (vid = vid_begin; vid <= vid_end;
715              vid += MLXSW_REG_SPVM_REC_MAX_COUNT) {
716                 vid_e = min((u16) (vid + MLXSW_REG_SPVM_REC_MAX_COUNT - 1),
717                             vid_end);
718
719                 err = mlxsw_sp_port_vlan_set(mlxsw_sp_port, vid, vid_e,
720                                              is_member, untagged);
721                 if (err)
722                         return err;
723         }
724
725         return 0;
726 }
727
728 static int mlxsw_sp_port_vid_learning_set(struct mlxsw_sp_port *mlxsw_sp_port,
729                                           u16 vid_begin, u16 vid_end,
730                                           bool learn_enable)
731 {
732         u16 vid, vid_e;
733         int err;
734
735         for (vid = vid_begin; vid <= vid_end;
736              vid += MLXSW_REG_SPVMLR_REC_MAX_COUNT) {
737                 vid_e = min((u16) (vid + MLXSW_REG_SPVMLR_REC_MAX_COUNT - 1),
738                             vid_end);
739
740                 err = __mlxsw_sp_port_vid_learning_set(mlxsw_sp_port, vid,
741                                                        vid_e, learn_enable);
742                 if (err)
743                         return err;
744         }
745
746         return 0;
747 }
748
749 static int __mlxsw_sp_port_vlans_add(struct mlxsw_sp_port *mlxsw_sp_port,
750                                      u16 vid_begin, u16 vid_end,
751                                      bool flag_untagged, bool flag_pvid)
752 {
753         struct net_device *dev = mlxsw_sp_port->dev;
754         u16 vid, old_pvid;
755         int err;
756
757         if (!mlxsw_sp_port->bridged)
758                 return -EINVAL;
759
760         err = mlxsw_sp_port_fid_join(mlxsw_sp_port, vid_begin, vid_end);
761         if (err) {
762                 netdev_err(dev, "Failed to join FIDs\n");
763                 return err;
764         }
765
766         err = __mlxsw_sp_port_vlans_set(mlxsw_sp_port, vid_begin, vid_end,
767                                         true, flag_untagged);
768         if (err) {
769                 netdev_err(dev, "Unable to add VIDs %d-%d\n", vid_begin,
770                            vid_end);
771                 goto err_port_vlans_set;
772         }
773
774         old_pvid = mlxsw_sp_port->pvid;
775         if (flag_pvid && old_pvid != vid_begin) {
776                 err = mlxsw_sp_port_pvid_set(mlxsw_sp_port, vid_begin);
777                 if (err) {
778                         netdev_err(dev, "Unable to add PVID %d\n", vid_begin);
779                         goto err_port_pvid_set;
780                 }
781         } else if (!flag_pvid && old_pvid >= vid_begin && old_pvid <= vid_end) {
782                 err = mlxsw_sp_port_pvid_set(mlxsw_sp_port, 0);
783                 if (err) {
784                         netdev_err(dev, "Unable to del PVID\n");
785                         goto err_port_pvid_set;
786                 }
787         }
788
789         err = mlxsw_sp_port_vid_learning_set(mlxsw_sp_port, vid_begin, vid_end,
790                                              mlxsw_sp_port->learning);
791         if (err) {
792                 netdev_err(dev, "Failed to set learning for VIDs %d-%d\n",
793                            vid_begin, vid_end);
794                 goto err_port_vid_learning_set;
795         }
796
797         /* Changing activity bits only if HW operation succeded */
798         for (vid = vid_begin; vid <= vid_end; vid++) {
799                 set_bit(vid, mlxsw_sp_port->active_vlans);
800                 if (flag_untagged)
801                         set_bit(vid, mlxsw_sp_port->untagged_vlans);
802                 else
803                         clear_bit(vid, mlxsw_sp_port->untagged_vlans);
804         }
805
806         /* STP state change must be done after we set active VLANs */
807         err = mlxsw_sp_port_stp_state_set(mlxsw_sp_port,
808                                           mlxsw_sp_port->stp_state);
809         if (err) {
810                 netdev_err(dev, "Failed to set STP state\n");
811                 goto err_port_stp_state_set;
812         }
813
814         return 0;
815
816 err_port_stp_state_set:
817         for (vid = vid_begin; vid <= vid_end; vid++)
818                 clear_bit(vid, mlxsw_sp_port->active_vlans);
819         mlxsw_sp_port_vid_learning_set(mlxsw_sp_port, vid_begin, vid_end,
820                                        false);
821 err_port_vid_learning_set:
822         if (old_pvid != mlxsw_sp_port->pvid)
823                 mlxsw_sp_port_pvid_set(mlxsw_sp_port, old_pvid);
824 err_port_pvid_set:
825         __mlxsw_sp_port_vlans_set(mlxsw_sp_port, vid_begin, vid_end, false,
826                                   false);
827 err_port_vlans_set:
828         mlxsw_sp_port_fid_leave(mlxsw_sp_port, vid_begin, vid_end);
829         return err;
830 }
831
832 static int mlxsw_sp_port_vlans_add(struct mlxsw_sp_port *mlxsw_sp_port,
833                                    const struct switchdev_obj_port_vlan *vlan,
834                                    struct switchdev_trans *trans)
835 {
836         bool flag_untagged = vlan->flags & BRIDGE_VLAN_INFO_UNTAGGED;
837         bool flag_pvid = vlan->flags & BRIDGE_VLAN_INFO_PVID;
838
839         if (switchdev_trans_ph_prepare(trans))
840                 return 0;
841
842         return __mlxsw_sp_port_vlans_add(mlxsw_sp_port,
843                                          vlan->vid_begin, vlan->vid_end,
844                                          flag_untagged, flag_pvid);
845 }
846
847 static enum mlxsw_reg_sfd_rec_policy mlxsw_sp_sfd_rec_policy(bool dynamic)
848 {
849         return dynamic ? MLXSW_REG_SFD_REC_POLICY_DYNAMIC_ENTRY_INGRESS :
850                          MLXSW_REG_SFD_REC_POLICY_STATIC_ENTRY;
851 }
852
853 static enum mlxsw_reg_sfd_op mlxsw_sp_sfd_op(bool adding)
854 {
855         return adding ? MLXSW_REG_SFD_OP_WRITE_EDIT :
856                         MLXSW_REG_SFD_OP_WRITE_REMOVE;
857 }
858
859 static int __mlxsw_sp_port_fdb_uc_op(struct mlxsw_sp *mlxsw_sp, u8 local_port,
860                                      const char *mac, u16 fid, bool adding,
861                                      enum mlxsw_reg_sfd_rec_action action,
862                                      bool dynamic)
863 {
864         char *sfd_pl;
865         int err;
866
867         sfd_pl = kmalloc(MLXSW_REG_SFD_LEN, GFP_KERNEL);
868         if (!sfd_pl)
869                 return -ENOMEM;
870
871         mlxsw_reg_sfd_pack(sfd_pl, mlxsw_sp_sfd_op(adding), 0);
872         mlxsw_reg_sfd_uc_pack(sfd_pl, 0, mlxsw_sp_sfd_rec_policy(dynamic),
873                               mac, fid, action, local_port);
874         err = mlxsw_reg_write(mlxsw_sp->core, MLXSW_REG(sfd), sfd_pl);
875         kfree(sfd_pl);
876
877         return err;
878 }
879
880 static int mlxsw_sp_port_fdb_uc_op(struct mlxsw_sp *mlxsw_sp, u8 local_port,
881                                    const char *mac, u16 fid, bool adding,
882                                    bool dynamic)
883 {
884         return __mlxsw_sp_port_fdb_uc_op(mlxsw_sp, local_port, mac, fid, adding,
885                                          MLXSW_REG_SFD_REC_ACTION_NOP, dynamic);
886 }
887
888 int mlxsw_sp_rif_fdb_op(struct mlxsw_sp *mlxsw_sp, const char *mac, u16 fid,
889                         bool adding)
890 {
891         return __mlxsw_sp_port_fdb_uc_op(mlxsw_sp, 0, mac, fid, adding,
892                                          MLXSW_REG_SFD_REC_ACTION_FORWARD_IP_ROUTER,
893                                          false);
894 }
895
896 static int mlxsw_sp_port_fdb_uc_lag_op(struct mlxsw_sp *mlxsw_sp, u16 lag_id,
897                                        const char *mac, u16 fid, u16 lag_vid,
898                                        bool adding, bool dynamic)
899 {
900         char *sfd_pl;
901         int err;
902
903         sfd_pl = kmalloc(MLXSW_REG_SFD_LEN, GFP_KERNEL);
904         if (!sfd_pl)
905                 return -ENOMEM;
906
907         mlxsw_reg_sfd_pack(sfd_pl, mlxsw_sp_sfd_op(adding), 0);
908         mlxsw_reg_sfd_uc_lag_pack(sfd_pl, 0, mlxsw_sp_sfd_rec_policy(dynamic),
909                                   mac, fid, MLXSW_REG_SFD_REC_ACTION_NOP,
910                                   lag_vid, lag_id);
911         err = mlxsw_reg_write(mlxsw_sp->core, MLXSW_REG(sfd), sfd_pl);
912         kfree(sfd_pl);
913
914         return err;
915 }
916
917 static int
918 mlxsw_sp_port_fdb_static_add(struct mlxsw_sp_port *mlxsw_sp_port,
919                              const struct switchdev_obj_port_fdb *fdb,
920                              struct switchdev_trans *trans)
921 {
922         u16 fid = mlxsw_sp_port_vid_to_fid_get(mlxsw_sp_port, fdb->vid);
923         u16 lag_vid = 0;
924
925         if (switchdev_trans_ph_prepare(trans))
926                 return 0;
927
928         if (mlxsw_sp_port_is_vport(mlxsw_sp_port)) {
929                 lag_vid = mlxsw_sp_vport_vid_get(mlxsw_sp_port);
930         }
931
932         if (!mlxsw_sp_port->lagged)
933                 return mlxsw_sp_port_fdb_uc_op(mlxsw_sp_port->mlxsw_sp,
934                                                mlxsw_sp_port->local_port,
935                                                fdb->addr, fid, true, false);
936         else
937                 return mlxsw_sp_port_fdb_uc_lag_op(mlxsw_sp_port->mlxsw_sp,
938                                                    mlxsw_sp_port->lag_id,
939                                                    fdb->addr, fid, lag_vid,
940                                                    true, false);
941 }
942
943 static int mlxsw_sp_port_mdb_op(struct mlxsw_sp *mlxsw_sp, const char *addr,
944                                 u16 fid, u16 mid, bool adding)
945 {
946         char *sfd_pl;
947         int err;
948
949         sfd_pl = kmalloc(MLXSW_REG_SFD_LEN, GFP_KERNEL);
950         if (!sfd_pl)
951                 return -ENOMEM;
952
953         mlxsw_reg_sfd_pack(sfd_pl, mlxsw_sp_sfd_op(adding), 0);
954         mlxsw_reg_sfd_mc_pack(sfd_pl, 0, addr, fid,
955                               MLXSW_REG_SFD_REC_ACTION_NOP, mid);
956         err = mlxsw_reg_write(mlxsw_sp->core, MLXSW_REG(sfd), sfd_pl);
957         kfree(sfd_pl);
958         return err;
959 }
960
961 static int mlxsw_sp_port_smid_set(struct mlxsw_sp_port *mlxsw_sp_port, u16 mid,
962                                   bool add, bool clear_all_ports)
963 {
964         struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
965         char *smid_pl;
966         int err, i;
967
968         smid_pl = kmalloc(MLXSW_REG_SMID_LEN, GFP_KERNEL);
969         if (!smid_pl)
970                 return -ENOMEM;
971
972         mlxsw_reg_smid_pack(smid_pl, mid, mlxsw_sp_port->local_port, add);
973         if (clear_all_ports) {
974                 for (i = 1; i < MLXSW_PORT_MAX_PORTS; i++)
975                         if (mlxsw_sp->ports[i])
976                                 mlxsw_reg_smid_port_mask_set(smid_pl, i, 1);
977         }
978         err = mlxsw_reg_write(mlxsw_sp->core, MLXSW_REG(smid), smid_pl);
979         kfree(smid_pl);
980         return err;
981 }
982
983 static struct mlxsw_sp_mid *__mlxsw_sp_mc_get(struct mlxsw_sp *mlxsw_sp,
984                                               const unsigned char *addr,
985                                               u16 fid)
986 {
987         struct mlxsw_sp_mid *mid;
988
989         list_for_each_entry(mid, &mlxsw_sp->br_mids.list, list) {
990                 if (ether_addr_equal(mid->addr, addr) && mid->fid == fid)
991                         return mid;
992         }
993         return NULL;
994 }
995
996 static struct mlxsw_sp_mid *__mlxsw_sp_mc_alloc(struct mlxsw_sp *mlxsw_sp,
997                                                 const unsigned char *addr,
998                                                 u16 fid)
999 {
1000         struct mlxsw_sp_mid *mid;
1001         u16 mid_idx;
1002
1003         mid_idx = find_first_zero_bit(mlxsw_sp->br_mids.mapped,
1004                                       MLXSW_SP_MID_MAX);
1005         if (mid_idx == MLXSW_SP_MID_MAX)
1006                 return NULL;
1007
1008         mid = kzalloc(sizeof(*mid), GFP_KERNEL);
1009         if (!mid)
1010                 return NULL;
1011
1012         set_bit(mid_idx, mlxsw_sp->br_mids.mapped);
1013         ether_addr_copy(mid->addr, addr);
1014         mid->fid = fid;
1015         mid->mid = mid_idx;
1016         mid->ref_count = 0;
1017         list_add_tail(&mid->list, &mlxsw_sp->br_mids.list);
1018
1019         return mid;
1020 }
1021
1022 static int __mlxsw_sp_mc_dec_ref(struct mlxsw_sp *mlxsw_sp,
1023                                  struct mlxsw_sp_mid *mid)
1024 {
1025         if (--mid->ref_count == 0) {
1026                 list_del(&mid->list);
1027                 clear_bit(mid->mid, mlxsw_sp->br_mids.mapped);
1028                 kfree(mid);
1029                 return 1;
1030         }
1031         return 0;
1032 }
1033
1034 static int mlxsw_sp_port_mdb_add(struct mlxsw_sp_port *mlxsw_sp_port,
1035                                  const struct switchdev_obj_port_mdb *mdb,
1036                                  struct switchdev_trans *trans)
1037 {
1038         struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
1039         struct net_device *dev = mlxsw_sp_port->dev;
1040         struct mlxsw_sp_mid *mid;
1041         u16 fid = mlxsw_sp_port_vid_to_fid_get(mlxsw_sp_port, mdb->vid);
1042         int err = 0;
1043
1044         if (switchdev_trans_ph_prepare(trans))
1045                 return 0;
1046
1047         mid = __mlxsw_sp_mc_get(mlxsw_sp, mdb->addr, fid);
1048         if (!mid) {
1049                 mid = __mlxsw_sp_mc_alloc(mlxsw_sp, mdb->addr, fid);
1050                 if (!mid) {
1051                         netdev_err(dev, "Unable to allocate MC group\n");
1052                         return -ENOMEM;
1053                 }
1054         }
1055         mid->ref_count++;
1056
1057         err = mlxsw_sp_port_smid_set(mlxsw_sp_port, mid->mid, true,
1058                                      mid->ref_count == 1);
1059         if (err) {
1060                 netdev_err(dev, "Unable to set SMID\n");
1061                 goto err_out;
1062         }
1063
1064         if (mid->ref_count == 1) {
1065                 err = mlxsw_sp_port_mdb_op(mlxsw_sp, mdb->addr, fid, mid->mid,
1066                                            true);
1067                 if (err) {
1068                         netdev_err(dev, "Unable to set MC SFD\n");
1069                         goto err_out;
1070                 }
1071         }
1072
1073         return 0;
1074
1075 err_out:
1076         __mlxsw_sp_mc_dec_ref(mlxsw_sp, mid);
1077         return err;
1078 }
1079
1080 static int mlxsw_sp_port_obj_add(struct net_device *dev,
1081                                  const struct switchdev_obj *obj,
1082                                  struct switchdev_trans *trans)
1083 {
1084         struct mlxsw_sp_port *mlxsw_sp_port = netdev_priv(dev);
1085         int err = 0;
1086
1087         mlxsw_sp_port = mlxsw_sp_port_orig_get(obj->orig_dev, mlxsw_sp_port);
1088         if (!mlxsw_sp_port)
1089                 return -EINVAL;
1090
1091         switch (obj->id) {
1092         case SWITCHDEV_OBJ_ID_PORT_VLAN:
1093                 if (mlxsw_sp_port_is_vport(mlxsw_sp_port))
1094                         return 0;
1095
1096                 err = mlxsw_sp_port_vlans_add(mlxsw_sp_port,
1097                                               SWITCHDEV_OBJ_PORT_VLAN(obj),
1098                                               trans);
1099                 break;
1100         case SWITCHDEV_OBJ_ID_PORT_FDB:
1101                 err = mlxsw_sp_port_fdb_static_add(mlxsw_sp_port,
1102                                                    SWITCHDEV_OBJ_PORT_FDB(obj),
1103                                                    trans);
1104                 break;
1105         case SWITCHDEV_OBJ_ID_PORT_MDB:
1106                 err = mlxsw_sp_port_mdb_add(mlxsw_sp_port,
1107                                             SWITCHDEV_OBJ_PORT_MDB(obj),
1108                                             trans);
1109                 break;
1110         default:
1111                 err = -EOPNOTSUPP;
1112                 break;
1113         }
1114
1115         return err;
1116 }
1117
1118 static int __mlxsw_sp_port_vlans_del(struct mlxsw_sp_port *mlxsw_sp_port,
1119                                      u16 vid_begin, u16 vid_end)
1120 {
1121         u16 vid, pvid;
1122
1123         if (!mlxsw_sp_port->bridged)
1124                 return -EINVAL;
1125
1126         mlxsw_sp_port_vid_learning_set(mlxsw_sp_port, vid_begin, vid_end,
1127                                        false);
1128
1129         pvid = mlxsw_sp_port->pvid;
1130         if (pvid >= vid_begin && pvid <= vid_end)
1131                 mlxsw_sp_port_pvid_set(mlxsw_sp_port, 0);
1132
1133         __mlxsw_sp_port_vlans_set(mlxsw_sp_port, vid_begin, vid_end, false,
1134                                   false);
1135
1136         mlxsw_sp_port_fid_leave(mlxsw_sp_port, vid_begin, vid_end);
1137
1138         /* Changing activity bits only if HW operation succeded */
1139         for (vid = vid_begin; vid <= vid_end; vid++)
1140                 clear_bit(vid, mlxsw_sp_port->active_vlans);
1141
1142         return 0;
1143 }
1144
1145 static int mlxsw_sp_port_vlans_del(struct mlxsw_sp_port *mlxsw_sp_port,
1146                                    const struct switchdev_obj_port_vlan *vlan)
1147 {
1148         return __mlxsw_sp_port_vlans_del(mlxsw_sp_port, vlan->vid_begin,
1149                                          vlan->vid_end);
1150 }
1151
1152 void mlxsw_sp_port_active_vlans_del(struct mlxsw_sp_port *mlxsw_sp_port)
1153 {
1154         u16 vid;
1155
1156         for_each_set_bit(vid, mlxsw_sp_port->active_vlans, VLAN_N_VID)
1157                 __mlxsw_sp_port_vlans_del(mlxsw_sp_port, vid, vid);
1158 }
1159
1160 static int
1161 mlxsw_sp_port_fdb_static_del(struct mlxsw_sp_port *mlxsw_sp_port,
1162                              const struct switchdev_obj_port_fdb *fdb)
1163 {
1164         u16 fid = mlxsw_sp_port_vid_to_fid_get(mlxsw_sp_port, fdb->vid);
1165         u16 lag_vid = 0;
1166
1167         if (mlxsw_sp_port_is_vport(mlxsw_sp_port)) {
1168                 lag_vid = mlxsw_sp_vport_vid_get(mlxsw_sp_port);
1169         }
1170
1171         if (!mlxsw_sp_port->lagged)
1172                 return mlxsw_sp_port_fdb_uc_op(mlxsw_sp_port->mlxsw_sp,
1173                                                mlxsw_sp_port->local_port,
1174                                                fdb->addr, fid,
1175                                                false, false);
1176         else
1177                 return mlxsw_sp_port_fdb_uc_lag_op(mlxsw_sp_port->mlxsw_sp,
1178                                                    mlxsw_sp_port->lag_id,
1179                                                    fdb->addr, fid, lag_vid,
1180                                                    false, false);
1181 }
1182
1183 static int mlxsw_sp_port_mdb_del(struct mlxsw_sp_port *mlxsw_sp_port,
1184                                  const struct switchdev_obj_port_mdb *mdb)
1185 {
1186         struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
1187         struct net_device *dev = mlxsw_sp_port->dev;
1188         struct mlxsw_sp_mid *mid;
1189         u16 fid = mlxsw_sp_port_vid_to_fid_get(mlxsw_sp_port, mdb->vid);
1190         u16 mid_idx;
1191         int err = 0;
1192
1193         mid = __mlxsw_sp_mc_get(mlxsw_sp, mdb->addr, fid);
1194         if (!mid) {
1195                 netdev_err(dev, "Unable to remove port from MC DB\n");
1196                 return -EINVAL;
1197         }
1198
1199         err = mlxsw_sp_port_smid_set(mlxsw_sp_port, mid->mid, false, false);
1200         if (err)
1201                 netdev_err(dev, "Unable to remove port from SMID\n");
1202
1203         mid_idx = mid->mid;
1204         if (__mlxsw_sp_mc_dec_ref(mlxsw_sp, mid)) {
1205                 err = mlxsw_sp_port_mdb_op(mlxsw_sp, mdb->addr, fid, mid_idx,
1206                                            false);
1207                 if (err)
1208                         netdev_err(dev, "Unable to remove MC SFD\n");
1209         }
1210
1211         return err;
1212 }
1213
1214 static int mlxsw_sp_port_obj_del(struct net_device *dev,
1215                                  const struct switchdev_obj *obj)
1216 {
1217         struct mlxsw_sp_port *mlxsw_sp_port = netdev_priv(dev);
1218         int err = 0;
1219
1220         mlxsw_sp_port = mlxsw_sp_port_orig_get(obj->orig_dev, mlxsw_sp_port);
1221         if (!mlxsw_sp_port)
1222                 return -EINVAL;
1223
1224         switch (obj->id) {
1225         case SWITCHDEV_OBJ_ID_PORT_VLAN:
1226                 if (mlxsw_sp_port_is_vport(mlxsw_sp_port))
1227                         return 0;
1228
1229                 err = mlxsw_sp_port_vlans_del(mlxsw_sp_port,
1230                                               SWITCHDEV_OBJ_PORT_VLAN(obj));
1231                 break;
1232         case SWITCHDEV_OBJ_ID_PORT_FDB:
1233                 err = mlxsw_sp_port_fdb_static_del(mlxsw_sp_port,
1234                                                    SWITCHDEV_OBJ_PORT_FDB(obj));
1235                 break;
1236         case SWITCHDEV_OBJ_ID_PORT_MDB:
1237                 err = mlxsw_sp_port_mdb_del(mlxsw_sp_port,
1238                                             SWITCHDEV_OBJ_PORT_MDB(obj));
1239                 break;
1240         default:
1241                 err = -EOPNOTSUPP;
1242                 break;
1243         }
1244
1245         return err;
1246 }
1247
1248 static struct mlxsw_sp_port *mlxsw_sp_lag_rep_port(struct mlxsw_sp *mlxsw_sp,
1249                                                    u16 lag_id)
1250 {
1251         struct mlxsw_sp_port *mlxsw_sp_port;
1252         u64 max_lag_members;
1253         int i;
1254
1255         max_lag_members = MLXSW_CORE_RES_GET(mlxsw_sp->core,
1256                                              MAX_LAG_MEMBERS);
1257         for (i = 0; i < max_lag_members; i++) {
1258                 mlxsw_sp_port = mlxsw_sp_port_lagged_get(mlxsw_sp, lag_id, i);
1259                 if (mlxsw_sp_port)
1260                         return mlxsw_sp_port;
1261         }
1262         return NULL;
1263 }
1264
1265 static int mlxsw_sp_port_fdb_dump(struct mlxsw_sp_port *mlxsw_sp_port,
1266                                   struct switchdev_obj_port_fdb *fdb,
1267                                   switchdev_obj_dump_cb_t *cb,
1268                                   struct net_device *orig_dev)
1269 {
1270         struct mlxsw_sp *mlxsw_sp = mlxsw_sp_port->mlxsw_sp;
1271         struct mlxsw_sp_port *tmp;
1272         struct mlxsw_sp_fid *f;
1273         u16 vport_fid;
1274         char *sfd_pl;
1275         char mac[ETH_ALEN];
1276         u16 fid;
1277         u8 local_port;
1278         u16 lag_id;
1279         u8 num_rec;
1280         int stored_err = 0;
1281         int i;
1282         int err;
1283
1284         sfd_pl = kmalloc(MLXSW_REG_SFD_LEN, GFP_KERNEL);
1285         if (!sfd_pl)
1286                 return -ENOMEM;
1287
1288         f = mlxsw_sp_vport_fid_get(mlxsw_sp_port);
1289         vport_fid = f ? f->fid : 0;
1290
1291         mlxsw_reg_sfd_pack(sfd_pl, MLXSW_REG_SFD_OP_QUERY_DUMP, 0);
1292         do {
1293                 mlxsw_reg_sfd_num_rec_set(sfd_pl, MLXSW_REG_SFD_REC_MAX_COUNT);
1294                 err = mlxsw_reg_query(mlxsw_sp->core, MLXSW_REG(sfd), sfd_pl);
1295                 if (err)
1296                         goto out;
1297
1298                 num_rec = mlxsw_reg_sfd_num_rec_get(sfd_pl);
1299
1300                 /* Even in case of error, we have to run the dump to the end
1301                  * so the session in firmware is finished.
1302                  */
1303                 if (stored_err)
1304                         continue;
1305
1306                 for (i = 0; i < num_rec; i++) {
1307                         switch (mlxsw_reg_sfd_rec_type_get(sfd_pl, i)) {
1308                         case MLXSW_REG_SFD_REC_TYPE_UNICAST:
1309                                 mlxsw_reg_sfd_uc_unpack(sfd_pl, i, mac, &fid,
1310                                                         &local_port);
1311                                 if (local_port == mlxsw_sp_port->local_port) {
1312                                         if (vport_fid && vport_fid == fid)
1313                                                 fdb->vid = 0;
1314                                         else if (!vport_fid &&
1315                                                  !mlxsw_sp_fid_is_vfid(fid))
1316                                                 fdb->vid = fid;
1317                                         else
1318                                                 continue;
1319                                         ether_addr_copy(fdb->addr, mac);
1320                                         fdb->ndm_state = NUD_REACHABLE;
1321                                         err = cb(&fdb->obj);
1322                                         if (err)
1323                                                 stored_err = err;
1324                                 }
1325                                 break;
1326                         case MLXSW_REG_SFD_REC_TYPE_UNICAST_LAG:
1327                                 mlxsw_reg_sfd_uc_lag_unpack(sfd_pl, i,
1328                                                             mac, &fid, &lag_id);
1329                                 tmp = mlxsw_sp_lag_rep_port(mlxsw_sp, lag_id);
1330                                 if (tmp && tmp->local_port ==
1331                                     mlxsw_sp_port->local_port) {
1332                                         /* LAG records can only point to LAG
1333                                          * devices or VLAN devices on top.
1334                                          */
1335                                         if (!netif_is_lag_master(orig_dev) &&
1336                                             !is_vlan_dev(orig_dev))
1337                                                 continue;
1338                                         if (vport_fid && vport_fid == fid)
1339                                                 fdb->vid = 0;
1340                                         else if (!vport_fid &&
1341                                                  !mlxsw_sp_fid_is_vfid(fid))
1342                                                 fdb->vid = fid;
1343                                         else
1344                                                 continue;
1345                                         ether_addr_copy(fdb->addr, mac);
1346                                         fdb->ndm_state = NUD_REACHABLE;
1347                                         err = cb(&fdb->obj);
1348                                         if (err)
1349                                                 stored_err = err;
1350                                 }
1351                                 break;
1352                         }
1353                 }
1354         } while (num_rec == MLXSW_REG_SFD_REC_MAX_COUNT);
1355
1356 out:
1357         kfree(sfd_pl);
1358         return stored_err ? stored_err : err;
1359 }
1360
1361 static int mlxsw_sp_port_vlan_dump(struct mlxsw_sp_port *mlxsw_sp_port,
1362                                    struct switchdev_obj_port_vlan *vlan,
1363                                    switchdev_obj_dump_cb_t *cb)
1364 {
1365         u16 vid;
1366         int err = 0;
1367
1368         if (mlxsw_sp_port_is_vport(mlxsw_sp_port)) {
1369                 vlan->flags = 0;
1370                 vlan->vid_begin = mlxsw_sp_vport_vid_get(mlxsw_sp_port);
1371                 vlan->vid_end = mlxsw_sp_vport_vid_get(mlxsw_sp_port);
1372                 return cb(&vlan->obj);
1373         }
1374
1375         for_each_set_bit(vid, mlxsw_sp_port->active_vlans, VLAN_N_VID) {
1376                 vlan->flags = 0;
1377                 if (vid == mlxsw_sp_port->pvid)
1378                         vlan->flags |= BRIDGE_VLAN_INFO_PVID;
1379                 if (test_bit(vid, mlxsw_sp_port->untagged_vlans))
1380                         vlan->flags |= BRIDGE_VLAN_INFO_UNTAGGED;
1381                 vlan->vid_begin = vid;
1382                 vlan->vid_end = vid;
1383                 err = cb(&vlan->obj);
1384                 if (err)
1385                         break;
1386         }
1387         return err;
1388 }
1389
1390 static int mlxsw_sp_port_obj_dump(struct net_device *dev,
1391                                   struct switchdev_obj *obj,
1392                                   switchdev_obj_dump_cb_t *cb)
1393 {
1394         struct mlxsw_sp_port *mlxsw_sp_port = netdev_priv(dev);
1395         int err = 0;
1396
1397         mlxsw_sp_port = mlxsw_sp_port_orig_get(obj->orig_dev, mlxsw_sp_port);
1398         if (!mlxsw_sp_port)
1399                 return -EINVAL;
1400
1401         switch (obj->id) {
1402         case SWITCHDEV_OBJ_ID_PORT_VLAN:
1403                 err = mlxsw_sp_port_vlan_dump(mlxsw_sp_port,
1404                                               SWITCHDEV_OBJ_PORT_VLAN(obj), cb);
1405                 break;
1406         case SWITCHDEV_OBJ_ID_PORT_FDB:
1407                 err = mlxsw_sp_port_fdb_dump(mlxsw_sp_port,
1408                                              SWITCHDEV_OBJ_PORT_FDB(obj), cb,
1409                                              obj->orig_dev);
1410                 break;
1411         default:
1412                 err = -EOPNOTSUPP;
1413                 break;
1414         }
1415
1416         return err;
1417 }
1418
1419 static const struct switchdev_ops mlxsw_sp_port_switchdev_ops = {
1420         .switchdev_port_attr_get        = mlxsw_sp_port_attr_get,
1421         .switchdev_port_attr_set        = mlxsw_sp_port_attr_set,
1422         .switchdev_port_obj_add         = mlxsw_sp_port_obj_add,
1423         .switchdev_port_obj_del         = mlxsw_sp_port_obj_del,
1424         .switchdev_port_obj_dump        = mlxsw_sp_port_obj_dump,
1425 };
1426
1427 static void mlxsw_sp_fdb_call_notifiers(bool learning_sync, bool adding,
1428                                         char *mac, u16 vid,
1429                                         struct net_device *dev)
1430 {
1431         struct switchdev_notifier_fdb_info info;
1432         unsigned long notifier_type;
1433
1434         if (learning_sync) {
1435                 info.addr = mac;
1436                 info.vid = vid;
1437                 notifier_type = adding ? SWITCHDEV_FDB_ADD : SWITCHDEV_FDB_DEL;
1438                 call_switchdev_notifiers(notifier_type, dev, &info.info);
1439         }
1440 }
1441
1442 static void mlxsw_sp_fdb_notify_mac_process(struct mlxsw_sp *mlxsw_sp,
1443                                             char *sfn_pl, int rec_index,
1444                                             bool adding)
1445 {
1446         struct mlxsw_sp_port *mlxsw_sp_port;
1447         char mac[ETH_ALEN];
1448         u8 local_port;
1449         u16 vid, fid;
1450         bool do_notification = true;
1451         int err;
1452
1453         mlxsw_reg_sfn_mac_unpack(sfn_pl, rec_index, mac, &fid, &local_port);
1454         mlxsw_sp_port = mlxsw_sp->ports[local_port];
1455         if (!mlxsw_sp_port) {
1456                 dev_err_ratelimited(mlxsw_sp->bus_info->dev, "Incorrect local port in FDB notification\n");
1457                 goto just_remove;
1458         }
1459
1460         if (mlxsw_sp_fid_is_vfid(fid)) {
1461                 struct mlxsw_sp_port *mlxsw_sp_vport;
1462
1463                 mlxsw_sp_vport = mlxsw_sp_port_vport_find_by_fid(mlxsw_sp_port,
1464                                                                  fid);
1465                 if (!mlxsw_sp_vport) {
1466                         netdev_err(mlxsw_sp_port->dev, "Failed to find a matching vPort following FDB notification\n");
1467                         goto just_remove;
1468                 }
1469                 vid = 0;
1470                 /* Override the physical port with the vPort. */
1471                 mlxsw_sp_port = mlxsw_sp_vport;
1472         } else {
1473                 vid = fid;
1474         }
1475
1476 do_fdb_op:
1477         err = mlxsw_sp_port_fdb_uc_op(mlxsw_sp, local_port, mac, fid,
1478                                       adding, true);
1479         if (err) {
1480                 if (net_ratelimit())
1481                         netdev_err(mlxsw_sp_port->dev, "Failed to set FDB entry\n");
1482                 return;
1483         }
1484
1485         if (!do_notification)
1486                 return;
1487         mlxsw_sp_fdb_call_notifiers(mlxsw_sp_port->learning_sync,
1488                                     adding, mac, vid, mlxsw_sp_port->dev);
1489         return;
1490
1491 just_remove:
1492         adding = false;
1493         do_notification = false;
1494         goto do_fdb_op;
1495 }
1496
1497 static void mlxsw_sp_fdb_notify_mac_lag_process(struct mlxsw_sp *mlxsw_sp,
1498                                                 char *sfn_pl, int rec_index,
1499                                                 bool adding)
1500 {
1501         struct mlxsw_sp_port *mlxsw_sp_port;
1502         struct net_device *dev;
1503         char mac[ETH_ALEN];
1504         u16 lag_vid = 0;
1505         u16 lag_id;
1506         u16 vid, fid;
1507         bool do_notification = true;
1508         int err;
1509
1510         mlxsw_reg_sfn_mac_lag_unpack(sfn_pl, rec_index, mac, &fid, &lag_id);
1511         mlxsw_sp_port = mlxsw_sp_lag_rep_port(mlxsw_sp, lag_id);
1512         if (!mlxsw_sp_port) {
1513                 dev_err_ratelimited(mlxsw_sp->bus_info->dev, "Cannot find port representor for LAG\n");
1514                 goto just_remove;
1515         }
1516
1517         if (mlxsw_sp_fid_is_vfid(fid)) {
1518                 struct mlxsw_sp_port *mlxsw_sp_vport;
1519
1520                 mlxsw_sp_vport = mlxsw_sp_port_vport_find_by_fid(mlxsw_sp_port,
1521                                                                  fid);
1522                 if (!mlxsw_sp_vport) {
1523                         netdev_err(mlxsw_sp_port->dev, "Failed to find a matching vPort following FDB notification\n");
1524                         goto just_remove;
1525                 }
1526
1527                 lag_vid = mlxsw_sp_vport_vid_get(mlxsw_sp_vport);
1528                 dev = mlxsw_sp_vport->dev;
1529                 vid = 0;
1530                 /* Override the physical port with the vPort. */
1531                 mlxsw_sp_port = mlxsw_sp_vport;
1532         } else {
1533                 dev = mlxsw_sp_lag_get(mlxsw_sp, lag_id)->dev;
1534                 vid = fid;
1535         }
1536
1537 do_fdb_op:
1538         err = mlxsw_sp_port_fdb_uc_lag_op(mlxsw_sp, lag_id, mac, fid, lag_vid,
1539                                           adding, true);
1540         if (err) {
1541                 if (net_ratelimit())
1542                         netdev_err(mlxsw_sp_port->dev, "Failed to set FDB entry\n");
1543                 return;
1544         }
1545
1546         if (!do_notification)
1547                 return;
1548         mlxsw_sp_fdb_call_notifiers(mlxsw_sp_port->learning_sync, adding, mac,
1549                                     vid, dev);
1550         return;
1551
1552 just_remove:
1553         adding = false;
1554         do_notification = false;
1555         goto do_fdb_op;
1556 }
1557
1558 static void mlxsw_sp_fdb_notify_rec_process(struct mlxsw_sp *mlxsw_sp,
1559                                             char *sfn_pl, int rec_index)
1560 {
1561         switch (mlxsw_reg_sfn_rec_type_get(sfn_pl, rec_index)) {
1562         case MLXSW_REG_SFN_REC_TYPE_LEARNED_MAC:
1563                 mlxsw_sp_fdb_notify_mac_process(mlxsw_sp, sfn_pl,
1564                                                 rec_index, true);
1565                 break;
1566         case MLXSW_REG_SFN_REC_TYPE_AGED_OUT_MAC:
1567                 mlxsw_sp_fdb_notify_mac_process(mlxsw_sp, sfn_pl,
1568                                                 rec_index, false);
1569                 break;
1570         case MLXSW_REG_SFN_REC_TYPE_LEARNED_MAC_LAG:
1571                 mlxsw_sp_fdb_notify_mac_lag_process(mlxsw_sp, sfn_pl,
1572                                                     rec_index, true);
1573                 break;
1574         case MLXSW_REG_SFN_REC_TYPE_AGED_OUT_MAC_LAG:
1575                 mlxsw_sp_fdb_notify_mac_lag_process(mlxsw_sp, sfn_pl,
1576                                                     rec_index, false);
1577                 break;
1578         }
1579 }
1580
1581 static void mlxsw_sp_fdb_notify_work_schedule(struct mlxsw_sp *mlxsw_sp)
1582 {
1583         mlxsw_core_schedule_dw(&mlxsw_sp->fdb_notify.dw,
1584                                msecs_to_jiffies(mlxsw_sp->fdb_notify.interval));
1585 }
1586
1587 static void mlxsw_sp_fdb_notify_work(struct work_struct *work)
1588 {
1589         struct mlxsw_sp *mlxsw_sp;
1590         char *sfn_pl;
1591         u8 num_rec;
1592         int i;
1593         int err;
1594
1595         sfn_pl = kmalloc(MLXSW_REG_SFN_LEN, GFP_KERNEL);
1596         if (!sfn_pl)
1597                 return;
1598
1599         mlxsw_sp = container_of(work, struct mlxsw_sp, fdb_notify.dw.work);
1600
1601         rtnl_lock();
1602         mlxsw_reg_sfn_pack(sfn_pl);
1603         err = mlxsw_reg_query(mlxsw_sp->core, MLXSW_REG(sfn), sfn_pl);
1604         if (err) {
1605                 dev_err_ratelimited(mlxsw_sp->bus_info->dev, "Failed to get FDB notifications\n");
1606                 goto out;
1607         }
1608         num_rec = mlxsw_reg_sfn_num_rec_get(sfn_pl);
1609         for (i = 0; i < num_rec; i++)
1610                 mlxsw_sp_fdb_notify_rec_process(mlxsw_sp, sfn_pl, i);
1611
1612 out:
1613         rtnl_unlock();
1614         kfree(sfn_pl);
1615         mlxsw_sp_fdb_notify_work_schedule(mlxsw_sp);
1616 }
1617
1618 static int mlxsw_sp_fdb_init(struct mlxsw_sp *mlxsw_sp)
1619 {
1620         int err;
1621
1622         err = mlxsw_sp_ageing_set(mlxsw_sp, MLXSW_SP_DEFAULT_AGEING_TIME);
1623         if (err) {
1624                 dev_err(mlxsw_sp->bus_info->dev, "Failed to set default ageing time\n");
1625                 return err;
1626         }
1627         INIT_DELAYED_WORK(&mlxsw_sp->fdb_notify.dw, mlxsw_sp_fdb_notify_work);
1628         mlxsw_sp->fdb_notify.interval = MLXSW_SP_DEFAULT_LEARNING_INTERVAL;
1629         mlxsw_sp_fdb_notify_work_schedule(mlxsw_sp);
1630         return 0;
1631 }
1632
1633 static void mlxsw_sp_fdb_fini(struct mlxsw_sp *mlxsw_sp)
1634 {
1635         cancel_delayed_work_sync(&mlxsw_sp->fdb_notify.dw);
1636 }
1637
1638 int mlxsw_sp_switchdev_init(struct mlxsw_sp *mlxsw_sp)
1639 {
1640         return mlxsw_sp_fdb_init(mlxsw_sp);
1641 }
1642
1643 void mlxsw_sp_switchdev_fini(struct mlxsw_sp *mlxsw_sp)
1644 {
1645         mlxsw_sp_fdb_fini(mlxsw_sp);
1646 }
1647
1648 void mlxsw_sp_port_switchdev_init(struct mlxsw_sp_port *mlxsw_sp_port)
1649 {
1650         mlxsw_sp_port->dev->switchdev_ops = &mlxsw_sp_port_switchdev_ops;
1651 }
1652
1653 void mlxsw_sp_port_switchdev_fini(struct mlxsw_sp_port *mlxsw_sp_port)
1654 {
1655 }