xref: /openbmc/linux/net/dsa/switch.c (revision 711aab1d)
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_cpu_port(ds, port) || 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 
138 	for_each_set_bit(port, group, ds->num_ports)
139 		ds->ops->port_mdb_add(ds, port, mdb, trans);
140 
141 	return 0;
142 }
143 
144 static int dsa_switch_mdb_del(struct dsa_switch *ds,
145 			      struct dsa_notifier_mdb_info *info)
146 {
147 	const struct switchdev_obj_port_mdb *mdb = info->mdb;
148 
149 	if (!ds->ops->port_mdb_del)
150 		return -EOPNOTSUPP;
151 
152 	if (ds->index == info->sw_index)
153 		return ds->ops->port_mdb_del(ds, info->port, mdb);
154 
155 	return 0;
156 }
157 
158 static int dsa_switch_vlan_add(struct dsa_switch *ds,
159 			       struct dsa_notifier_vlan_info *info)
160 {
161 	const struct switchdev_obj_port_vlan *vlan = info->vlan;
162 	struct switchdev_trans *trans = info->trans;
163 	DECLARE_BITMAP(members, ds->num_ports);
164 	int port, err;
165 
166 	/* Build a mask of VLAN members */
167 	bitmap_zero(members, ds->num_ports);
168 	if (ds->index == info->sw_index)
169 		set_bit(info->port, members);
170 	for (port = 0; port < ds->num_ports; port++)
171 		if (dsa_is_cpu_port(ds, port) || dsa_is_dsa_port(ds, port))
172 			set_bit(port, members);
173 
174 	if (switchdev_trans_ph_prepare(trans)) {
175 		if (!ds->ops->port_vlan_prepare || !ds->ops->port_vlan_add)
176 			return -EOPNOTSUPP;
177 
178 		for_each_set_bit(port, members, ds->num_ports) {
179 			err = ds->ops->port_vlan_prepare(ds, port, vlan, trans);
180 			if (err)
181 				return err;
182 		}
183 	}
184 
185 	for_each_set_bit(port, members, ds->num_ports)
186 		ds->ops->port_vlan_add(ds, port, vlan, trans);
187 
188 	return 0;
189 }
190 
191 static int dsa_switch_vlan_del(struct dsa_switch *ds,
192 			       struct dsa_notifier_vlan_info *info)
193 {
194 	const struct switchdev_obj_port_vlan *vlan = info->vlan;
195 
196 	if (!ds->ops->port_vlan_del)
197 		return -EOPNOTSUPP;
198 
199 	if (ds->index == info->sw_index)
200 		return ds->ops->port_vlan_del(ds, info->port, vlan);
201 
202 	return 0;
203 }
204 
205 static int dsa_switch_event(struct notifier_block *nb,
206 			    unsigned long event, void *info)
207 {
208 	struct dsa_switch *ds = container_of(nb, struct dsa_switch, nb);
209 	int err;
210 
211 	switch (event) {
212 	case DSA_NOTIFIER_AGEING_TIME:
213 		err = dsa_switch_ageing_time(ds, info);
214 		break;
215 	case DSA_NOTIFIER_BRIDGE_JOIN:
216 		err = dsa_switch_bridge_join(ds, info);
217 		break;
218 	case DSA_NOTIFIER_BRIDGE_LEAVE:
219 		err = dsa_switch_bridge_leave(ds, info);
220 		break;
221 	case DSA_NOTIFIER_FDB_ADD:
222 		err = dsa_switch_fdb_add(ds, info);
223 		break;
224 	case DSA_NOTIFIER_FDB_DEL:
225 		err = dsa_switch_fdb_del(ds, info);
226 		break;
227 	case DSA_NOTIFIER_MDB_ADD:
228 		err = dsa_switch_mdb_add(ds, info);
229 		break;
230 	case DSA_NOTIFIER_MDB_DEL:
231 		err = dsa_switch_mdb_del(ds, info);
232 		break;
233 	case DSA_NOTIFIER_VLAN_ADD:
234 		err = dsa_switch_vlan_add(ds, info);
235 		break;
236 	case DSA_NOTIFIER_VLAN_DEL:
237 		err = dsa_switch_vlan_del(ds, info);
238 		break;
239 	default:
240 		err = -EOPNOTSUPP;
241 		break;
242 	}
243 
244 	/* Non-switchdev operations cannot be rolled back. If a DSA driver
245 	 * returns an error during the chained call, switch chips may be in an
246 	 * inconsistent state.
247 	 */
248 	if (err)
249 		dev_dbg(ds->dev, "breaking chain for DSA event %lu (%d)\n",
250 			event, err);
251 
252 	return notifier_from_errno(err);
253 }
254 
255 int dsa_switch_register_notifier(struct dsa_switch *ds)
256 {
257 	ds->nb.notifier_call = dsa_switch_event;
258 
259 	return raw_notifier_chain_register(&ds->dst->nh, &ds->nb);
260 }
261 
262 void dsa_switch_unregister_notifier(struct dsa_switch *ds)
263 {
264 	int err;
265 
266 	err = raw_notifier_chain_unregister(&ds->dst->nh, &ds->nb);
267 	if (err)
268 		dev_err(ds->dev, "failed to unregister notifier (%d)\n", err);
269 }
270