1 // SPDX-License-Identifier: GPL-2.0-or-later
3 * Handling of a single switch port
5 * Copyright (c) 2017 Savoir-faire Linux Inc.
6 * Vivien Didelot <vivien.didelot@savoirfairelinux.com>
9 #include <linux/if_bridge.h>
10 #include <linux/notifier.h>
11 #include <linux/of_mdio.h>
12 #include <linux/of_net.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
;
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
;
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
;
57 static void dsa_port_set_state_now(struct dsa_port
*dp
, u8 state
)
61 err
= dsa_port_set_state(dp
, state
, NULL
);
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
;
72 if (ds
->ops
->port_enable
) {
73 err
= ds
->ops
->port_enable(ds
, port
, phy
);
79 dsa_port_set_state_now(dp
, BR_STATE_FORWARDING
);
84 void dsa_port_disable(struct dsa_port
*dp
)
86 struct dsa_switch
*ds
= dp
->ds
;
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
,
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
);
110 /* Here the interface is already bridged. Reflect the current
111 * configuration so that drivers can program their chips accordingly.
115 err
= dsa_port_notify(dp
, DSA_NOTIFIER_BRIDGE_JOIN
, &info
);
117 /* The bridging is rolled back on error */
119 dsa_port_bridge_flags(dp
, 0, NULL
);
120 dp
->bridge_dev
= NULL
;
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
,
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
);
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
,
156 struct dsa_switch
*ds
= dp
->ds
;
159 if (!ds
->vlan_filtering_is_global
)
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
;
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
)
178 if (br_vlan_enabled(other_bridge
) != vlan_filtering
) {
179 dev_err(ds
->dev
, "VLAN filtering is a global setting\n");
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
;
192 /* bridge skips -EOPNOTSUPP, so skip the prepare phase */
193 if (switchdev_trans_ph_prepare(trans
))
196 if (!ds
->ops
->port_vlan_filtering
)
199 if (!dsa_port_can_apply_vlan_filtering(dp
, vlan_filtering
))
202 if (dsa_port_is_vlan_filtering(dp
) == vlan_filtering
)
205 err
= ds
->ops
->port_vlan_filtering(ds
, dp
->index
,
210 if (ds
->vlan_filtering_is_global
)
211 ds
->vlan_filtering
= vlan_filtering
;
213 dp
->vlan_filtering
= vlan_filtering
;
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
,
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
)))
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
;
254 if (switchdev_trans_ph_prepare(trans
))
257 if (ds
->ops
->port_egress_floods
)
258 err
= ds
->ops
->port_egress_floods(ds
, port
, flags
& BR_FLOOD
,
259 flags
& BR_MCAST_FLOOD
);
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
,
279 struct dsa_notifier_fdb_info info
= {
280 .sw_index
= dp
->ds
->index
,
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
,
292 struct dsa_notifier_fdb_info info
= {
293 .sw_index
= dp
->ds
->index
,
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
)
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
,
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
,
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
,
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
,
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
,
374 struct switchdev_trans trans
;
377 trans
.ph_prepare
= true;
378 err
= dsa_port_vlan_add(dp
, &vlan
, &trans
);
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
,
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);
408 phydev
= of_phy_find_device(phy_dn
);
411 return ERR_PTR(-EPROBE_DEFER
);
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
)
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
) {
444 if (ds
->ops
->phylink_mac_link_state(ds
, dp
->index
, state
) < 0)
447 EXPORT_SYMBOL_GPL(dsa_port_phylink_mac_pcs_get_state
);
449 void dsa_port_phylink_mac_config(struct phylink_config
*config
,
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
)
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
)
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
,
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
);
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
,
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
);
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
;
530 phydev
= dsa_port_get_phy_device(dp
);
535 return PTR_ERR(phydev
);
538 err
= genphy_resume(phydev
);
542 err
= genphy_read_status(phydev
);
546 err
= genphy_suspend(phydev
);
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
));
557 put_device(&phydev
->mdio
.dev
);
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
;
570 err
= of_phy_register_fixed_link(dn
);
573 "failed to register the fixed PHY of port %d\n",
578 phydev
= of_phy_find_device(dn
);
580 err
= of_get_phy_mode(dn
, &mode
);
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
);
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
;
602 err
= of_get_phy_mode(port_dn
, &mode
);
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
;
623 phylink_start(dp
->pl
);
629 phylink_destroy(dp
->pl
);
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
);
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
);
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
) {
655 phylink_disconnect_phy(dp
->pl
);
657 phylink_destroy(dp
->pl
);
661 if (of_phy_is_fixed_link(dp
->dn
))
662 of_phy_deregister_fixed_link(dp
->dn
);
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
))
675 phydev
= dsa_port_get_phy_device(dp
);
676 if (IS_ERR_OR_NULL(phydev
))
679 ret
= phy_ethtool_get_strings(phydev
, data
);
680 put_device(&phydev
->mdio
.dev
);
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
))
694 phydev
= dsa_port_get_phy_device(dp
);
695 if (IS_ERR_OR_NULL(phydev
))
698 ret
= phy_ethtool_get_stats(phydev
, NULL
, data
);
699 put_device(&phydev
->mdio
.dev
);
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
))
713 phydev
= dsa_port_get_phy_device(dp
);
714 if (IS_ERR_OR_NULL(phydev
))
717 ret
= phy_ethtool_get_sset_count(phydev
);
718 put_device(&phydev
->mdio
.dev
);
722 EXPORT_SYMBOL_GPL(dsa_port_get_phy_sset_count
);