kpacket_gen: use constants for cmdlength
[cor.git] / net / dsa / port.c
blob46ac9ba219871c4c86b360b2e83fd550f77e11d0
1 // SPDX-License-Identifier: GPL-2.0-or-later
2 /*
3 * Handling of a single switch port
5 * Copyright (c) 2017 Savoir-faire Linux Inc.
6 * Vivien Didelot <vivien.didelot@savoirfairelinux.com>
7 */
9 #include <linux/if_bridge.h>
10 #include <linux/notifier.h>
11 #include <linux/of_mdio.h>
12 #include <linux/of_net.h>
14 #include "dsa_priv.h"
16 static int dsa_port_notify(const struct dsa_port *dp, unsigned long e, void *v)
18 struct raw_notifier_head *nh = &dp->ds->dst->nh;
19 int err;
21 err = raw_notifier_call_chain(nh, e, v);
23 return notifier_to_errno(err);
26 int dsa_port_set_state(struct dsa_port *dp, u8 state,
27 struct switchdev_trans *trans)
29 struct dsa_switch *ds = dp->ds;
30 int port = dp->index;
32 if (switchdev_trans_ph_prepare(trans))
33 return ds->ops->port_stp_state_set ? 0 : -EOPNOTSUPP;
35 if (ds->ops->port_stp_state_set)
36 ds->ops->port_stp_state_set(ds, port, state);
38 if (ds->ops->port_fast_age) {
39 /* Fast age FDB entries or flush appropriate forwarding database
40 * for the given port, if we are moving it from Learning or
41 * Forwarding state, to Disabled or Blocking or Listening state.
44 if ((dp->stp_state == BR_STATE_LEARNING ||
45 dp->stp_state == BR_STATE_FORWARDING) &&
46 (state == BR_STATE_DISABLED ||
47 state == BR_STATE_BLOCKING ||
48 state == BR_STATE_LISTENING))
49 ds->ops->port_fast_age(ds, port);
52 dp->stp_state = state;
54 return 0;
57 static void dsa_port_set_state_now(struct dsa_port *dp, u8 state)
59 int err;
61 err = dsa_port_set_state(dp, state, NULL);
62 if (err)
63 pr_err("DSA: failed to set STP state %u (%d)\n", state, err);
66 int dsa_port_enable(struct dsa_port *dp, struct phy_device *phy)
68 struct dsa_switch *ds = dp->ds;
69 int port = dp->index;
70 int err;
72 if (ds->ops->port_enable) {
73 err = ds->ops->port_enable(ds, port, phy);
74 if (err)
75 return err;
78 if (!dp->bridge_dev)
79 dsa_port_set_state_now(dp, BR_STATE_FORWARDING);
81 return 0;
84 void dsa_port_disable(struct dsa_port *dp)
86 struct dsa_switch *ds = dp->ds;
87 int port = dp->index;
89 if (!dp->bridge_dev)
90 dsa_port_set_state_now(dp, BR_STATE_DISABLED);
92 if (ds->ops->port_disable)
93 ds->ops->port_disable(ds, port);
96 int dsa_port_bridge_join(struct dsa_port *dp, struct net_device *br)
98 struct dsa_notifier_bridge_info info = {
99 .sw_index = dp->ds->index,
100 .port = dp->index,
101 .br = br,
103 int err;
105 /* Set the flooding mode before joining the port in the switch */
106 err = dsa_port_bridge_flags(dp, BR_FLOOD | BR_MCAST_FLOOD, NULL);
107 if (err)
108 return err;
110 /* Here the interface is already bridged. Reflect the current
111 * configuration so that drivers can program their chips accordingly.
113 dp->bridge_dev = br;
115 err = dsa_port_notify(dp, DSA_NOTIFIER_BRIDGE_JOIN, &info);
117 /* The bridging is rolled back on error */
118 if (err) {
119 dsa_port_bridge_flags(dp, 0, NULL);
120 dp->bridge_dev = NULL;
123 return err;
126 void dsa_port_bridge_leave(struct dsa_port *dp, struct net_device *br)
128 struct dsa_notifier_bridge_info info = {
129 .sw_index = dp->ds->index,
130 .port = dp->index,
131 .br = br,
133 int err;
135 /* Here the port is already unbridged. Reflect the current configuration
136 * so that drivers can program their chips accordingly.
138 dp->bridge_dev = NULL;
140 err = dsa_port_notify(dp, DSA_NOTIFIER_BRIDGE_LEAVE, &info);
141 if (err)
142 pr_err("DSA: failed to notify DSA_NOTIFIER_BRIDGE_LEAVE\n");
144 /* Port is leaving the bridge, disable flooding */
145 dsa_port_bridge_flags(dp, 0, NULL);
147 /* Port left the bridge, put in BR_STATE_DISABLED by the bridge layer,
148 * so allow it to be in BR_STATE_FORWARDING to be kept functional
150 dsa_port_set_state_now(dp, BR_STATE_FORWARDING);
153 static bool dsa_port_can_apply_vlan_filtering(struct dsa_port *dp,
154 bool vlan_filtering)
156 struct dsa_switch *ds = dp->ds;
157 int i;
159 if (!ds->vlan_filtering_is_global)
160 return true;
162 /* For cases where enabling/disabling VLAN awareness is global to the
163 * switch, we need to handle the case where multiple bridges span
164 * different ports of the same switch device and one of them has a
165 * different setting than what is being requested.
167 for (i = 0; i < ds->num_ports; i++) {
168 struct net_device *other_bridge;
170 other_bridge = dsa_to_port(ds, i)->bridge_dev;
171 if (!other_bridge)
172 continue;
173 /* If it's the same bridge, it also has same
174 * vlan_filtering setting => no need to check
176 if (other_bridge == dp->bridge_dev)
177 continue;
178 if (br_vlan_enabled(other_bridge) != vlan_filtering) {
179 dev_err(ds->dev, "VLAN filtering is a global setting\n");
180 return false;
183 return true;
186 int dsa_port_vlan_filtering(struct dsa_port *dp, bool vlan_filtering,
187 struct switchdev_trans *trans)
189 struct dsa_switch *ds = dp->ds;
190 int err;
192 /* bridge skips -EOPNOTSUPP, so skip the prepare phase */
193 if (switchdev_trans_ph_prepare(trans))
194 return 0;
196 if (!ds->ops->port_vlan_filtering)
197 return 0;
199 if (!dsa_port_can_apply_vlan_filtering(dp, vlan_filtering))
200 return -EINVAL;
202 if (dsa_port_is_vlan_filtering(dp) == vlan_filtering)
203 return 0;
205 err = ds->ops->port_vlan_filtering(ds, dp->index,
206 vlan_filtering);
207 if (err)
208 return err;
210 if (ds->vlan_filtering_is_global)
211 ds->vlan_filtering = vlan_filtering;
212 else
213 dp->vlan_filtering = vlan_filtering;
214 return 0;
217 int dsa_port_ageing_time(struct dsa_port *dp, clock_t ageing_clock,
218 struct switchdev_trans *trans)
220 unsigned long ageing_jiffies = clock_t_to_jiffies(ageing_clock);
221 unsigned int ageing_time = jiffies_to_msecs(ageing_jiffies);
222 struct dsa_notifier_ageing_time_info info = {
223 .ageing_time = ageing_time,
224 .trans = trans,
227 if (switchdev_trans_ph_prepare(trans))
228 return dsa_port_notify(dp, DSA_NOTIFIER_AGEING_TIME, &info);
230 dp->ageing_time = ageing_time;
232 return dsa_port_notify(dp, DSA_NOTIFIER_AGEING_TIME, &info);
235 int dsa_port_pre_bridge_flags(const struct dsa_port *dp, unsigned long flags,
236 struct switchdev_trans *trans)
238 struct dsa_switch *ds = dp->ds;
240 if (!ds->ops->port_egress_floods ||
241 (flags & ~(BR_FLOOD | BR_MCAST_FLOOD)))
242 return -EINVAL;
244 return 0;
247 int dsa_port_bridge_flags(const struct dsa_port *dp, unsigned long flags,
248 struct switchdev_trans *trans)
250 struct dsa_switch *ds = dp->ds;
251 int port = dp->index;
252 int err = 0;
254 if (switchdev_trans_ph_prepare(trans))
255 return 0;
257 if (ds->ops->port_egress_floods)
258 err = ds->ops->port_egress_floods(ds, port, flags & BR_FLOOD,
259 flags & BR_MCAST_FLOOD);
261 return err;
264 int dsa_port_mrouter(struct dsa_port *dp, bool mrouter,
265 struct switchdev_trans *trans)
267 struct dsa_switch *ds = dp->ds;
268 int port = dp->index;
270 if (switchdev_trans_ph_prepare(trans))
271 return ds->ops->port_egress_floods ? 0 : -EOPNOTSUPP;
273 return ds->ops->port_egress_floods(ds, port, true, mrouter);
276 int dsa_port_fdb_add(struct dsa_port *dp, const unsigned char *addr,
277 u16 vid)
279 struct dsa_notifier_fdb_info info = {
280 .sw_index = dp->ds->index,
281 .port = dp->index,
282 .addr = addr,
283 .vid = vid,
286 return dsa_port_notify(dp, DSA_NOTIFIER_FDB_ADD, &info);
289 int dsa_port_fdb_del(struct dsa_port *dp, const unsigned char *addr,
290 u16 vid)
292 struct dsa_notifier_fdb_info info = {
293 .sw_index = dp->ds->index,
294 .port = dp->index,
295 .addr = addr,
296 .vid = vid,
300 return dsa_port_notify(dp, DSA_NOTIFIER_FDB_DEL, &info);
303 int dsa_port_fdb_dump(struct dsa_port *dp, dsa_fdb_dump_cb_t *cb, void *data)
305 struct dsa_switch *ds = dp->ds;
306 int port = dp->index;
308 if (!ds->ops->port_fdb_dump)
309 return -EOPNOTSUPP;
311 return ds->ops->port_fdb_dump(ds, port, cb, data);
314 int dsa_port_mdb_add(const struct dsa_port *dp,
315 const struct switchdev_obj_port_mdb *mdb,
316 struct switchdev_trans *trans)
318 struct dsa_notifier_mdb_info info = {
319 .sw_index = dp->ds->index,
320 .port = dp->index,
321 .trans = trans,
322 .mdb = mdb,
325 return dsa_port_notify(dp, DSA_NOTIFIER_MDB_ADD, &info);
328 int dsa_port_mdb_del(const struct dsa_port *dp,
329 const struct switchdev_obj_port_mdb *mdb)
331 struct dsa_notifier_mdb_info info = {
332 .sw_index = dp->ds->index,
333 .port = dp->index,
334 .mdb = mdb,
337 return dsa_port_notify(dp, DSA_NOTIFIER_MDB_DEL, &info);
340 int dsa_port_vlan_add(struct dsa_port *dp,
341 const struct switchdev_obj_port_vlan *vlan,
342 struct switchdev_trans *trans)
344 struct dsa_notifier_vlan_info info = {
345 .sw_index = dp->ds->index,
346 .port = dp->index,
347 .trans = trans,
348 .vlan = vlan,
351 return dsa_port_notify(dp, DSA_NOTIFIER_VLAN_ADD, &info);
354 int dsa_port_vlan_del(struct dsa_port *dp,
355 const struct switchdev_obj_port_vlan *vlan)
357 struct dsa_notifier_vlan_info info = {
358 .sw_index = dp->ds->index,
359 .port = dp->index,
360 .vlan = vlan,
363 return dsa_port_notify(dp, DSA_NOTIFIER_VLAN_DEL, &info);
366 int dsa_port_vid_add(struct dsa_port *dp, u16 vid, u16 flags)
368 struct switchdev_obj_port_vlan vlan = {
369 .obj.id = SWITCHDEV_OBJ_ID_PORT_VLAN,
370 .flags = flags,
371 .vid_begin = vid,
372 .vid_end = vid,
374 struct switchdev_trans trans;
375 int err;
377 trans.ph_prepare = true;
378 err = dsa_port_vlan_add(dp, &vlan, &trans);
379 if (err)
380 return err;
382 trans.ph_prepare = false;
383 return dsa_port_vlan_add(dp, &vlan, &trans);
385 EXPORT_SYMBOL(dsa_port_vid_add);
387 int dsa_port_vid_del(struct dsa_port *dp, u16 vid)
389 struct switchdev_obj_port_vlan vlan = {
390 .obj.id = SWITCHDEV_OBJ_ID_PORT_VLAN,
391 .vid_begin = vid,
392 .vid_end = vid,
395 return dsa_port_vlan_del(dp, &vlan);
397 EXPORT_SYMBOL(dsa_port_vid_del);
399 static struct phy_device *dsa_port_get_phy_device(struct dsa_port *dp)
401 struct device_node *phy_dn;
402 struct phy_device *phydev;
404 phy_dn = of_parse_phandle(dp->dn, "phy-handle", 0);
405 if (!phy_dn)
406 return NULL;
408 phydev = of_phy_find_device(phy_dn);
409 if (!phydev) {
410 of_node_put(phy_dn);
411 return ERR_PTR(-EPROBE_DEFER);
414 of_node_put(phy_dn);
415 return phydev;
418 void dsa_port_phylink_validate(struct phylink_config *config,
419 unsigned long *supported,
420 struct phylink_link_state *state)
422 struct dsa_port *dp = container_of(config, struct dsa_port, pl_config);
423 struct dsa_switch *ds = dp->ds;
425 if (!ds->ops->phylink_validate)
426 return;
428 ds->ops->phylink_validate(ds, dp->index, supported, state);
430 EXPORT_SYMBOL_GPL(dsa_port_phylink_validate);
432 void dsa_port_phylink_mac_pcs_get_state(struct phylink_config *config,
433 struct phylink_link_state *state)
435 struct dsa_port *dp = container_of(config, struct dsa_port, pl_config);
436 struct dsa_switch *ds = dp->ds;
438 /* Only called for inband modes */
439 if (!ds->ops->phylink_mac_link_state) {
440 state->link = 0;
441 return;
444 if (ds->ops->phylink_mac_link_state(ds, dp->index, state) < 0)
445 state->link = 0;
447 EXPORT_SYMBOL_GPL(dsa_port_phylink_mac_pcs_get_state);
449 void dsa_port_phylink_mac_config(struct phylink_config *config,
450 unsigned int mode,
451 const struct phylink_link_state *state)
453 struct dsa_port *dp = container_of(config, struct dsa_port, pl_config);
454 struct dsa_switch *ds = dp->ds;
456 if (!ds->ops->phylink_mac_config)
457 return;
459 ds->ops->phylink_mac_config(ds, dp->index, mode, state);
461 EXPORT_SYMBOL_GPL(dsa_port_phylink_mac_config);
463 void dsa_port_phylink_mac_an_restart(struct phylink_config *config)
465 struct dsa_port *dp = container_of(config, struct dsa_port, pl_config);
466 struct dsa_switch *ds = dp->ds;
468 if (!ds->ops->phylink_mac_an_restart)
469 return;
471 ds->ops->phylink_mac_an_restart(ds, dp->index);
473 EXPORT_SYMBOL_GPL(dsa_port_phylink_mac_an_restart);
475 void dsa_port_phylink_mac_link_down(struct phylink_config *config,
476 unsigned int mode,
477 phy_interface_t interface)
479 struct dsa_port *dp = container_of(config, struct dsa_port, pl_config);
480 struct phy_device *phydev = NULL;
481 struct dsa_switch *ds = dp->ds;
483 if (dsa_is_user_port(ds, dp->index))
484 phydev = dp->slave->phydev;
486 if (!ds->ops->phylink_mac_link_down) {
487 if (ds->ops->adjust_link && phydev)
488 ds->ops->adjust_link(ds, dp->index, phydev);
489 return;
492 ds->ops->phylink_mac_link_down(ds, dp->index, mode, interface);
494 EXPORT_SYMBOL_GPL(dsa_port_phylink_mac_link_down);
496 void dsa_port_phylink_mac_link_up(struct phylink_config *config,
497 unsigned int mode,
498 phy_interface_t interface,
499 struct phy_device *phydev)
501 struct dsa_port *dp = container_of(config, struct dsa_port, pl_config);
502 struct dsa_switch *ds = dp->ds;
504 if (!ds->ops->phylink_mac_link_up) {
505 if (ds->ops->adjust_link && phydev)
506 ds->ops->adjust_link(ds, dp->index, phydev);
507 return;
510 ds->ops->phylink_mac_link_up(ds, dp->index, mode, interface, phydev);
512 EXPORT_SYMBOL_GPL(dsa_port_phylink_mac_link_up);
514 const struct phylink_mac_ops dsa_port_phylink_mac_ops = {
515 .validate = dsa_port_phylink_validate,
516 .mac_pcs_get_state = dsa_port_phylink_mac_pcs_get_state,
517 .mac_config = dsa_port_phylink_mac_config,
518 .mac_an_restart = dsa_port_phylink_mac_an_restart,
519 .mac_link_down = dsa_port_phylink_mac_link_down,
520 .mac_link_up = dsa_port_phylink_mac_link_up,
523 static int dsa_port_setup_phy_of(struct dsa_port *dp, bool enable)
525 struct dsa_switch *ds = dp->ds;
526 struct phy_device *phydev;
527 int port = dp->index;
528 int err = 0;
530 phydev = dsa_port_get_phy_device(dp);
531 if (!phydev)
532 return 0;
534 if (IS_ERR(phydev))
535 return PTR_ERR(phydev);
537 if (enable) {
538 err = genphy_resume(phydev);
539 if (err < 0)
540 goto err_put_dev;
542 err = genphy_read_status(phydev);
543 if (err < 0)
544 goto err_put_dev;
545 } else {
546 err = genphy_suspend(phydev);
547 if (err < 0)
548 goto err_put_dev;
551 if (ds->ops->adjust_link)
552 ds->ops->adjust_link(ds, port, phydev);
554 dev_dbg(ds->dev, "enabled port's phy: %s", phydev_name(phydev));
556 err_put_dev:
557 put_device(&phydev->mdio.dev);
558 return err;
561 static int dsa_port_fixed_link_register_of(struct dsa_port *dp)
563 struct device_node *dn = dp->dn;
564 struct dsa_switch *ds = dp->ds;
565 struct phy_device *phydev;
566 int port = dp->index;
567 phy_interface_t mode;
568 int err;
570 err = of_phy_register_fixed_link(dn);
571 if (err) {
572 dev_err(ds->dev,
573 "failed to register the fixed PHY of port %d\n",
574 port);
575 return err;
578 phydev = of_phy_find_device(dn);
580 err = of_get_phy_mode(dn, &mode);
581 if (err)
582 mode = PHY_INTERFACE_MODE_NA;
583 phydev->interface = mode;
585 genphy_read_status(phydev);
587 if (ds->ops->adjust_link)
588 ds->ops->adjust_link(ds, port, phydev);
590 put_device(&phydev->mdio.dev);
592 return 0;
595 static int dsa_port_phylink_register(struct dsa_port *dp)
597 struct dsa_switch *ds = dp->ds;
598 struct device_node *port_dn = dp->dn;
599 phy_interface_t mode;
600 int err;
602 err = of_get_phy_mode(port_dn, &mode);
603 if (err)
604 mode = PHY_INTERFACE_MODE_NA;
606 dp->pl_config.dev = ds->dev;
607 dp->pl_config.type = PHYLINK_DEV;
609 dp->pl = phylink_create(&dp->pl_config, of_fwnode_handle(port_dn),
610 mode, &dsa_port_phylink_mac_ops);
611 if (IS_ERR(dp->pl)) {
612 pr_err("error creating PHYLINK: %ld\n", PTR_ERR(dp->pl));
613 return PTR_ERR(dp->pl);
616 err = phylink_of_phy_connect(dp->pl, port_dn, 0);
617 if (err && err != -ENODEV) {
618 pr_err("could not attach to PHY: %d\n", err);
619 goto err_phy_connect;
622 rtnl_lock();
623 phylink_start(dp->pl);
624 rtnl_unlock();
626 return 0;
628 err_phy_connect:
629 phylink_destroy(dp->pl);
630 return err;
633 int dsa_port_link_register_of(struct dsa_port *dp)
635 struct dsa_switch *ds = dp->ds;
637 if (!ds->ops->adjust_link)
638 return dsa_port_phylink_register(dp);
640 dev_warn(ds->dev,
641 "Using legacy PHYLIB callbacks. Please migrate to PHYLINK!\n");
643 if (of_phy_is_fixed_link(dp->dn))
644 return dsa_port_fixed_link_register_of(dp);
645 else
646 return dsa_port_setup_phy_of(dp, true);
649 void dsa_port_link_unregister_of(struct dsa_port *dp)
651 struct dsa_switch *ds = dp->ds;
653 if (!ds->ops->adjust_link) {
654 rtnl_lock();
655 phylink_disconnect_phy(dp->pl);
656 rtnl_unlock();
657 phylink_destroy(dp->pl);
658 return;
661 if (of_phy_is_fixed_link(dp->dn))
662 of_phy_deregister_fixed_link(dp->dn);
663 else
664 dsa_port_setup_phy_of(dp, false);
667 int dsa_port_get_phy_strings(struct dsa_port *dp, uint8_t *data)
669 struct phy_device *phydev;
670 int ret = -EOPNOTSUPP;
672 if (of_phy_is_fixed_link(dp->dn))
673 return ret;
675 phydev = dsa_port_get_phy_device(dp);
676 if (IS_ERR_OR_NULL(phydev))
677 return ret;
679 ret = phy_ethtool_get_strings(phydev, data);
680 put_device(&phydev->mdio.dev);
682 return ret;
684 EXPORT_SYMBOL_GPL(dsa_port_get_phy_strings);
686 int dsa_port_get_ethtool_phy_stats(struct dsa_port *dp, uint64_t *data)
688 struct phy_device *phydev;
689 int ret = -EOPNOTSUPP;
691 if (of_phy_is_fixed_link(dp->dn))
692 return ret;
694 phydev = dsa_port_get_phy_device(dp);
695 if (IS_ERR_OR_NULL(phydev))
696 return ret;
698 ret = phy_ethtool_get_stats(phydev, NULL, data);
699 put_device(&phydev->mdio.dev);
701 return ret;
703 EXPORT_SYMBOL_GPL(dsa_port_get_ethtool_phy_stats);
705 int dsa_port_get_phy_sset_count(struct dsa_port *dp)
707 struct phy_device *phydev;
708 int ret = -EOPNOTSUPP;
710 if (of_phy_is_fixed_link(dp->dn))
711 return ret;
713 phydev = dsa_port_get_phy_device(dp);
714 if (IS_ERR_OR_NULL(phydev))
715 return ret;
717 ret = phy_ethtool_get_sset_count(phydev);
718 put_device(&phydev->mdio.dev);
720 return ret;
722 EXPORT_SYMBOL_GPL(dsa_port_get_phy_sset_count);