xref: /linux/net/dsa/switch.c (revision fd639726bf15fca8ee1a00dce8e0096d0ad9bd18)
1 /*
2  * Handling of a single switch chip, part of a switch fabric
3  *
4  * Copyright (c) 2017 Savoir-faire Linux Inc.
5  *	Vivien Didelot <vivien.didelot@savoirfairelinux.com>
6  *
7  * This program is free software; you can redistribute it and/or modify
8  * it under the terms of the GNU General Public License as published by
9  * the Free Software Foundation; either version 2 of the License, or
10  * (at your option) any later version.
11  */
12 
13 #include <linux/netdevice.h>
14 #include <linux/notifier.h>
15 #include <net/switchdev.h>
16 
17 #include "dsa_priv.h"
18 
19 static unsigned int dsa_switch_fastest_ageing_time(struct dsa_switch *ds,
20 						   unsigned int ageing_time)
21 {
22 	int i;
23 
24 	for (i = 0; i < ds->num_ports; ++i) {
25 		struct dsa_port *dp = &ds->ports[i];
26 
27 		if (dp->ageing_time && dp->ageing_time < ageing_time)
28 			ageing_time = dp->ageing_time;
29 	}
30 
31 	return ageing_time;
32 }
33 
34 static int dsa_switch_ageing_time(struct dsa_switch *ds,
35 				  struct dsa_notifier_ageing_time_info *info)
36 {
37 	unsigned int ageing_time = info->ageing_time;
38 	struct switchdev_trans *trans = info->trans;
39 
40 	if (switchdev_trans_ph_prepare(trans)) {
41 		if (ds->ageing_time_min && ageing_time < ds->ageing_time_min)
42 			return -ERANGE;
43 		if (ds->ageing_time_max && ageing_time > ds->ageing_time_max)
44 			return -ERANGE;
45 		return 0;
46 	}
47 
48 	/* Program the fastest ageing time in case of multiple bridges */
49 	ageing_time = dsa_switch_fastest_ageing_time(ds, ageing_time);
50 
51 	if (ds->ops->set_ageing_time)
52 		return ds->ops->set_ageing_time(ds, ageing_time);
53 
54 	return 0;
55 }
56 
57 static int dsa_switch_bridge_join(struct dsa_switch *ds,
58 				  struct dsa_notifier_bridge_info *info)
59 {
60 	if (ds->index == info->sw_index && ds->ops->port_bridge_join)
61 		return ds->ops->port_bridge_join(ds, info->port, info->br);
62 
63 	if (ds->index != info->sw_index && ds->ops->crosschip_bridge_join)
64 		return ds->ops->crosschip_bridge_join(ds, info->sw_index,
65 						      info->port, info->br);
66 
67 	return 0;
68 }
69 
70 static int dsa_switch_bridge_leave(struct dsa_switch *ds,
71 				   struct dsa_notifier_bridge_info *info)
72 {
73 	if (ds->index == info->sw_index && ds->ops->port_bridge_leave)
74 		ds->ops->port_bridge_leave(ds, info->port, info->br);
75 
76 	if (ds->index != info->sw_index && ds->ops->crosschip_bridge_leave)
77 		ds->ops->crosschip_bridge_leave(ds, info->sw_index, info->port,
78 						info->br);
79 
80 	return 0;
81 }
82 
83 static int dsa_switch_fdb_add(struct dsa_switch *ds,
84 			      struct dsa_notifier_fdb_info *info)
85 {
86 	/* Do not care yet about other switch chips of the fabric */
87 	if (ds->index != info->sw_index)
88 		return 0;
89 
90 	if (!ds->ops->port_fdb_add)
91 		return -EOPNOTSUPP;
92 
93 	return ds->ops->port_fdb_add(ds, info->port, info->addr,
94 				     info->vid);
95 }
96 
97 static int dsa_switch_fdb_del(struct dsa_switch *ds,
98 			      struct dsa_notifier_fdb_info *info)
99 {
100 	/* Do not care yet about other switch chips of the fabric */
101 	if (ds->index != info->sw_index)
102 		return 0;
103 
104 	if (!ds->ops->port_fdb_del)
105 		return -EOPNOTSUPP;
106 
107 	return ds->ops->port_fdb_del(ds, info->port, info->addr,
108 				     info->vid);
109 }
110 
111 static int dsa_switch_mdb_add(struct dsa_switch *ds,
112 			      struct dsa_notifier_mdb_info *info)
113 {
114 	const struct switchdev_obj_port_mdb *mdb = info->mdb;
115 	struct switchdev_trans *trans = info->trans;
116 	DECLARE_BITMAP(group, ds->num_ports);
117 	int port, err;
118 
119 	/* Build a mask of Multicast group members */
120 	bitmap_zero(group, ds->num_ports);
121 	if (ds->index == info->sw_index)
122 		set_bit(info->port, group);
123 	for (port = 0; port < ds->num_ports; port++)
124 		if (dsa_is_dsa_port(ds, port))
125 			set_bit(port, group);
126 
127 	if (switchdev_trans_ph_prepare(trans)) {
128 		if (!ds->ops->port_mdb_prepare || !ds->ops->port_mdb_add)
129 			return -EOPNOTSUPP;
130 
131 		for_each_set_bit(port, group, ds->num_ports) {
132 			err = ds->ops->port_mdb_prepare(ds, port, mdb, trans);
133 			if (err)
134 				return err;
135 		}
136 
137 		return 0;
138 	}
139 
140 	for_each_set_bit(port, group, ds->num_ports)
141 		ds->ops->port_mdb_add(ds, port, mdb, trans);
142 
143 	return 0;
144 }
145 
146 static int dsa_switch_mdb_del(struct dsa_switch *ds,
147 			      struct dsa_notifier_mdb_info *info)
148 {
149 	const struct switchdev_obj_port_mdb *mdb = info->mdb;
150 
151 	if (!ds->ops->port_mdb_del)
152 		return -EOPNOTSUPP;
153 
154 	if (ds->index == info->sw_index)
155 		return ds->ops->port_mdb_del(ds, info->port, mdb);
156 
157 	return 0;
158 }
159 
160 static int dsa_switch_vlan_add(struct dsa_switch *ds,
161 			       struct dsa_notifier_vlan_info *info)
162 {
163 	const struct switchdev_obj_port_vlan *vlan = info->vlan;
164 	struct switchdev_trans *trans = info->trans;
165 	DECLARE_BITMAP(members, ds->num_ports);
166 	int port, err;
167 
168 	/* Build a mask of VLAN members */
169 	bitmap_zero(members, ds->num_ports);
170 	if (ds->index == info->sw_index)
171 		set_bit(info->port, members);
172 	for (port = 0; port < ds->num_ports; port++)
173 		if (dsa_is_cpu_port(ds, port) || dsa_is_dsa_port(ds, port))
174 			set_bit(port, members);
175 
176 	if (switchdev_trans_ph_prepare(trans)) {
177 		if (!ds->ops->port_vlan_prepare || !ds->ops->port_vlan_add)
178 			return -EOPNOTSUPP;
179 
180 		for_each_set_bit(port, members, ds->num_ports) {
181 			err = ds->ops->port_vlan_prepare(ds, port, vlan, trans);
182 			if (err)
183 				return err;
184 		}
185 
186 		return 0;
187 	}
188 
189 	for_each_set_bit(port, members, ds->num_ports)
190 		ds->ops->port_vlan_add(ds, port, vlan, trans);
191 
192 	return 0;
193 }
194 
195 static int dsa_switch_vlan_del(struct dsa_switch *ds,
196 			       struct dsa_notifier_vlan_info *info)
197 {
198 	const struct switchdev_obj_port_vlan *vlan = info->vlan;
199 
200 	if (!ds->ops->port_vlan_del)
201 		return -EOPNOTSUPP;
202 
203 	if (ds->index == info->sw_index)
204 		return ds->ops->port_vlan_del(ds, info->port, vlan);
205 
206 	return 0;
207 }
208 
209 static int dsa_switch_event(struct notifier_block *nb,
210 			    unsigned long event, void *info)
211 {
212 	struct dsa_switch *ds = container_of(nb, struct dsa_switch, nb);
213 	int err;
214 
215 	switch (event) {
216 	case DSA_NOTIFIER_AGEING_TIME:
217 		err = dsa_switch_ageing_time(ds, info);
218 		break;
219 	case DSA_NOTIFIER_BRIDGE_JOIN:
220 		err = dsa_switch_bridge_join(ds, info);
221 		break;
222 	case DSA_NOTIFIER_BRIDGE_LEAVE:
223 		err = dsa_switch_bridge_leave(ds, info);
224 		break;
225 	case DSA_NOTIFIER_FDB_ADD:
226 		err = dsa_switch_fdb_add(ds, info);
227 		break;
228 	case DSA_NOTIFIER_FDB_DEL:
229 		err = dsa_switch_fdb_del(ds, info);
230 		break;
231 	case DSA_NOTIFIER_MDB_ADD:
232 		err = dsa_switch_mdb_add(ds, info);
233 		break;
234 	case DSA_NOTIFIER_MDB_DEL:
235 		err = dsa_switch_mdb_del(ds, info);
236 		break;
237 	case DSA_NOTIFIER_VLAN_ADD:
238 		err = dsa_switch_vlan_add(ds, info);
239 		break;
240 	case DSA_NOTIFIER_VLAN_DEL:
241 		err = dsa_switch_vlan_del(ds, info);
242 		break;
243 	default:
244 		err = -EOPNOTSUPP;
245 		break;
246 	}
247 
248 	/* Non-switchdev operations cannot be rolled back. If a DSA driver
249 	 * returns an error during the chained call, switch chips may be in an
250 	 * inconsistent state.
251 	 */
252 	if (err)
253 		dev_dbg(ds->dev, "breaking chain for DSA event %lu (%d)\n",
254 			event, err);
255 
256 	return notifier_from_errno(err);
257 }
258 
259 int dsa_switch_register_notifier(struct dsa_switch *ds)
260 {
261 	ds->nb.notifier_call = dsa_switch_event;
262 
263 	return raw_notifier_chain_register(&ds->dst->nh, &ds->nb);
264 }
265 
266 void dsa_switch_unregister_notifier(struct dsa_switch *ds)
267 {
268 	int err;
269 
270 	err = raw_notifier_chain_unregister(&ds->dst->nh, &ds->nb);
271 	if (err)
272 		dev_err(ds->dev, "failed to unregister notifier (%d)\n", err);
273 }
274