Commit c64b9c05 authored by Vladimir Oltean's avatar Vladimir Oltean Committed by David S. Miller

net: dsa: tag_8021q: add proper cross-chip notifier support

The big problem which mandates cross-chip notifiers for tag_8021q is
this:

                                             |
    sw0p0     sw0p1     sw0p2     sw0p3     sw0p4
 [  user ] [  user ] [  user ] [  dsa  ] [  cpu  ]
                                   |
                                   +---------+
                                             |
    sw1p0     sw1p1     sw1p2     sw1p3     sw1p4
 [  user ] [  user ] [  user ] [  dsa  ] [  dsa  ]
                                   |
                                   +---------+
                                             |
    sw2p0     sw2p1     sw2p2     sw2p3     sw2p4
 [  user ] [  user ] [  user ] [  dsa  ] [  dsa  ]

When the user runs:

ip link add br0 type bridge
ip link set sw0p0 master br0
ip link set sw2p0 master br0

It doesn't work.

This is because dsa_8021q_crosschip_bridge_join() assumes that "ds" and
"other_ds" are at most 1 hop away from each other, so it is sufficient
to add the RX VLAN of {ds, port} into {other_ds, other_port} and vice
versa and presto, the cross-chip link works. When there is another
switch in the middle, such as in this case switch 1 with its DSA links
sw1p3 and sw1p4, somebody needs to tell it about these VLANs too.

Which is exactly why the problem is quadratic: when a port joins a
bridge, for each port in the tree that's already in that same bridge we
notify a tag_8021q VLAN addition of that port's RX VLAN to the entire
tree. It is a very complicated web of VLANs.

It must be mentioned that currently we install tag_8021q VLANs on too
many ports (DSA links - to be precise, on all of them). For example,
when sw2p0 joins br0, and assuming sw1p0 was part of br0 too, we add the
RX VLAN of sw2p0 on the DSA links of switch 0 too, even though there
isn't any port of switch 0 that is a member of br0 (at least yet).
In theory we could notify only the switches which sit in between the
port joining the bridge and the port reacting to that bridge_join event.
But in practice that is impossible, because of the way 'link' properties
are described in the device tree. The DSA bindings require DT writers to
list out not only the real/physical DSA links, but in fact the entire
routing table, like for example switch 0 above will have:

	sw0p3: port@3 {
		link = <&sw1p4 &sw2p4>;
	};

This was done because:

/* TODO: ideally DSA ports would have a single dp->link_dp member,
 * and no dst->rtable nor this struct dsa_link would be needed,
 * but this would require some more complex tree walking,
 * so keep it stupid at the moment and list them all.
 */

but it is a perfect example of a situation where too much information is
actively detrimential, because we are now in the position where we
cannot distinguish a real DSA link from one that is put there to avoid
the 'complex tree walking'. And because DT is ABI, there is not much we
can change.

And because we do not know which DSA links are real and which ones
aren't, we can't really know if DSA switch A is in the data path between
switches B and C, in the general case.

So this is why tag_8021q RX VLANs are added on all DSA links, and
probably why it will never change.

On the other hand, at least the number of additions/deletions is well
balanced, and this means that once we implement reference counting at
the cross-chip notifier level a la fdb/mdb, there is absolutely zero
need for a struct dsa_8021q_crosschip_link, it's all self-managing.

In fact, with the tag_8021q notifiers emitted from the bridge join
notifiers, it becomes so generic that sja1105 does not need to do
anything anymore, we can just delete its implementation of the
.crosschip_bridge_{join,leave} methods.

Among other things we can simply delete is the home-grown implementation
of sja1105_notify_crosschip_switches(). The reason why that is wrong is
because it is not quadratic - it only covers remote switches to which we
have a cross-chip bridging link and that does not cover in-between
switches. This deletion is part of the same patch because sja1105 used
to poke deep inside the guts of the tag_8021q context in order to do
that. Because the cross-chip links went away, so needs the sja1105 code.

Last but not least, dsa_8021q_setup_port() is simplified (and also
renamed). Because our TAG_8021Q_VLAN_ADD notifier is designed to react
on the CPU port too, the four dsa_8021q_vid_apply() calls:
- 1 for RX VLAN on user port
- 1 for the user port's RX VLAN on the CPU port
- 1 for TX VLAN on user port
- 1 for the user port's TX VLAN on the CPU port

now get squashed into only 2 notifier calls via
dsa_port_tag_8021q_vlan_add.

And because the notifiers to add and to delete a tag_8021q VLAN are
distinct, now we finally break up the port setup and teardown into
separate functions instead of relying on a "bool enabled" flag which
tells us what to do. Arguably it should have been this way from the
get go.
Signed-off-by: default avatarVladimir Oltean <vladimir.oltean@nxp.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent e19cc13c
...@@ -1990,61 +1990,6 @@ static int sja1105_pvid_apply(struct sja1105_private *priv, int port, u16 pvid) ...@@ -1990,61 +1990,6 @@ static int sja1105_pvid_apply(struct sja1105_private *priv, int port, u16 pvid)
&mac[port], true); &mac[port], true);
} }
static int sja1105_crosschip_bridge_join(struct dsa_switch *ds,
int tree_index, int sw_index,
int other_port, struct net_device *br)
{
struct dsa_switch *other_ds = dsa_switch_find(tree_index, sw_index);
int port, rc;
if (other_ds->ops != &sja1105_switch_ops)
return 0;
for (port = 0; port < ds->num_ports; port++) {
if (!dsa_is_user_port(ds, port))
continue;
if (dsa_to_port(ds, port)->bridge_dev != br)
continue;
rc = dsa_8021q_crosschip_bridge_join(ds, port, other_ds,
other_port);
if (rc)
return rc;
rc = dsa_8021q_crosschip_bridge_join(other_ds, other_port,
ds, port);
if (rc)
return rc;
}
return 0;
}
static void sja1105_crosschip_bridge_leave(struct dsa_switch *ds,
int tree_index, int sw_index,
int other_port,
struct net_device *br)
{
struct dsa_switch *other_ds = dsa_switch_find(tree_index, sw_index);
int port;
if (other_ds->ops != &sja1105_switch_ops)
return;
for (port = 0; port < ds->num_ports; port++) {
if (!dsa_is_user_port(ds, port))
continue;
if (dsa_to_port(ds, port)->bridge_dev != br)
continue;
dsa_8021q_crosschip_bridge_leave(ds, port, other_ds,
other_port);
dsa_8021q_crosschip_bridge_leave(other_ds, other_port,
ds, port);
}
}
static enum dsa_tag_protocol static enum dsa_tag_protocol
sja1105_get_tag_protocol(struct dsa_switch *ds, int port, sja1105_get_tag_protocol(struct dsa_switch *ds, int port,
enum dsa_tag_protocol mp) enum dsa_tag_protocol mp)
...@@ -2135,11 +2080,6 @@ static int sja1105_commit_vlans(struct sja1105_private *priv, ...@@ -2135,11 +2080,6 @@ static int sja1105_commit_vlans(struct sja1105_private *priv,
return 0; return 0;
} }
struct sja1105_crosschip_switch {
struct list_head list;
struct dsa_8021q_context *other_ctx;
};
static int sja1105_commit_pvid(struct sja1105_private *priv) static int sja1105_commit_pvid(struct sja1105_private *priv)
{ {
struct sja1105_bridge_vlan *v; struct sja1105_bridge_vlan *v;
...@@ -2205,59 +2145,7 @@ sja1105_build_dsa_8021q_vlans(struct sja1105_private *priv, ...@@ -2205,59 +2145,7 @@ sja1105_build_dsa_8021q_vlans(struct sja1105_private *priv,
return 0; return 0;
} }
static int sja1105_build_vlan_table(struct sja1105_private *priv, bool notify); static int sja1105_build_vlan_table(struct sja1105_private *priv)
static int sja1105_notify_crosschip_switches(struct sja1105_private *priv)
{
struct dsa_8021q_context *ctx = priv->ds->tag_8021q_ctx;
struct sja1105_crosschip_switch *s, *pos;
struct list_head crosschip_switches;
struct dsa_8021q_crosschip_link *c;
int rc = 0;
INIT_LIST_HEAD(&crosschip_switches);
list_for_each_entry(c, &ctx->crosschip_links, list) {
bool already_added = false;
list_for_each_entry(s, &crosschip_switches, list) {
if (s->other_ctx == c->other_ctx) {
already_added = true;
break;
}
}
if (already_added)
continue;
s = kzalloc(sizeof(*s), GFP_KERNEL);
if (!s) {
dev_err(priv->ds->dev, "Failed to allocate memory\n");
rc = -ENOMEM;
goto out;
}
s->other_ctx = c->other_ctx;
list_add(&s->list, &crosschip_switches);
}
list_for_each_entry(s, &crosschip_switches, list) {
struct sja1105_private *other_priv = s->other_ctx->ds->priv;
rc = sja1105_build_vlan_table(other_priv, false);
if (rc)
goto out;
}
out:
list_for_each_entry_safe(s, pos, &crosschip_switches, list) {
list_del(&s->list);
kfree(s);
}
return rc;
}
static int sja1105_build_vlan_table(struct sja1105_private *priv, bool notify)
{ {
struct sja1105_vlan_lookup_entry *new_vlan; struct sja1105_vlan_lookup_entry *new_vlan;
struct sja1105_table *table; struct sja1105_table *table;
...@@ -2296,12 +2184,6 @@ static int sja1105_build_vlan_table(struct sja1105_private *priv, bool notify) ...@@ -2296,12 +2184,6 @@ static int sja1105_build_vlan_table(struct sja1105_private *priv, bool notify)
if (rc) if (rc)
goto out; goto out;
if (notify) {
rc = sja1105_notify_crosschip_switches(priv);
if (rc)
goto out;
}
out: out:
kfree(new_vlan); kfree(new_vlan);
...@@ -2389,7 +2271,7 @@ int sja1105_vlan_filtering(struct dsa_switch *ds, int port, bool enabled, ...@@ -2389,7 +2271,7 @@ int sja1105_vlan_filtering(struct dsa_switch *ds, int port, bool enabled,
l2_lookup_params = table->entries; l2_lookup_params = table->entries;
l2_lookup_params->shared_learn = !priv->vlan_aware; l2_lookup_params->shared_learn = !priv->vlan_aware;
rc = sja1105_build_vlan_table(priv, false); rc = sja1105_build_vlan_table(priv);
if (rc) if (rc)
return rc; return rc;
...@@ -2485,7 +2367,7 @@ static int sja1105_vlan_add(struct dsa_switch *ds, int port, ...@@ -2485,7 +2367,7 @@ static int sja1105_vlan_add(struct dsa_switch *ds, int port,
if (!vlan_table_changed) if (!vlan_table_changed)
return 0; return 0;
return sja1105_build_vlan_table(priv, true); return sja1105_build_vlan_table(priv);
} }
static int sja1105_vlan_del(struct dsa_switch *ds, int port, static int sja1105_vlan_del(struct dsa_switch *ds, int port,
...@@ -2502,7 +2384,7 @@ static int sja1105_vlan_del(struct dsa_switch *ds, int port, ...@@ -2502,7 +2384,7 @@ static int sja1105_vlan_del(struct dsa_switch *ds, int port,
if (!vlan_table_changed) if (!vlan_table_changed)
return 0; return 0;
return sja1105_build_vlan_table(priv, true); return sja1105_build_vlan_table(priv);
} }
static int sja1105_dsa_8021q_vlan_add(struct dsa_switch *ds, int port, u16 vid, static int sja1105_dsa_8021q_vlan_add(struct dsa_switch *ds, int port, u16 vid,
...@@ -2515,7 +2397,7 @@ static int sja1105_dsa_8021q_vlan_add(struct dsa_switch *ds, int port, u16 vid, ...@@ -2515,7 +2397,7 @@ static int sja1105_dsa_8021q_vlan_add(struct dsa_switch *ds, int port, u16 vid,
if (rc <= 0) if (rc <= 0)
return rc; return rc;
return sja1105_build_vlan_table(priv, true); return sja1105_build_vlan_table(priv);
} }
static int sja1105_dsa_8021q_vlan_del(struct dsa_switch *ds, int port, u16 vid) static int sja1105_dsa_8021q_vlan_del(struct dsa_switch *ds, int port, u16 vid)
...@@ -2527,7 +2409,7 @@ static int sja1105_dsa_8021q_vlan_del(struct dsa_switch *ds, int port, u16 vid) ...@@ -2527,7 +2409,7 @@ static int sja1105_dsa_8021q_vlan_del(struct dsa_switch *ds, int port, u16 vid)
if (!rc) if (!rc)
return 0; return 0;
return sja1105_build_vlan_table(priv, true); return sja1105_build_vlan_table(priv);
} }
/* The programming model for the SJA1105 switch is "all-at-once" via static /* The programming model for the SJA1105 switch is "all-at-once" via static
...@@ -3132,8 +3014,6 @@ static const struct dsa_switch_ops sja1105_switch_ops = { ...@@ -3132,8 +3014,6 @@ static const struct dsa_switch_ops sja1105_switch_ops = {
.cls_flower_add = sja1105_cls_flower_add, .cls_flower_add = sja1105_cls_flower_add,
.cls_flower_del = sja1105_cls_flower_del, .cls_flower_del = sja1105_cls_flower_del,
.cls_flower_stats = sja1105_cls_flower_stats, .cls_flower_stats = sja1105_cls_flower_stats,
.crosschip_bridge_join = sja1105_crosschip_bridge_join,
.crosschip_bridge_leave = sja1105_crosschip_bridge_leave,
.devlink_info_get = sja1105_devlink_info_get, .devlink_info_get = sja1105_devlink_info_get,
.tag_8021q_vlan_add = sja1105_dsa_8021q_vlan_add, .tag_8021q_vlan_add = sja1105_dsa_8021q_vlan_add,
.tag_8021q_vlan_del = sja1105_dsa_8021q_vlan_del, .tag_8021q_vlan_del = sja1105_dsa_8021q_vlan_del,
......
...@@ -11,19 +11,17 @@ ...@@ -11,19 +11,17 @@
struct dsa_switch; struct dsa_switch;
struct sk_buff; struct sk_buff;
struct net_device; struct net_device;
struct dsa_8021q_context;
struct dsa_8021q_crosschip_link { struct dsa_tag_8021q_vlan {
struct list_head list; struct list_head list;
int port; int port;
struct dsa_8021q_context *other_ctx; u16 vid;
int other_port;
refcount_t refcount; refcount_t refcount;
}; };
struct dsa_8021q_context { struct dsa_8021q_context {
struct dsa_switch *ds; struct dsa_switch *ds;
struct list_head crosschip_links; struct list_head vlans;
/* EtherType of RX VID, used for filtering on master interface */ /* EtherType of RX VID, used for filtering on master interface */
__be16 proto; __be16 proto;
}; };
...@@ -32,14 +30,6 @@ int dsa_tag_8021q_register(struct dsa_switch *ds, __be16 proto); ...@@ -32,14 +30,6 @@ int dsa_tag_8021q_register(struct dsa_switch *ds, __be16 proto);
void dsa_tag_8021q_unregister(struct dsa_switch *ds); void dsa_tag_8021q_unregister(struct dsa_switch *ds);
int dsa_8021q_crosschip_bridge_join(struct dsa_switch *ds, int port,
struct dsa_switch *other_ds,
int other_port);
int dsa_8021q_crosschip_bridge_leave(struct dsa_switch *ds, int port,
struct dsa_switch *other_ds,
int other_port);
struct sk_buff *dsa_8021q_xmit(struct sk_buff *skb, struct net_device *netdev, struct sk_buff *dsa_8021q_xmit(struct sk_buff *skb, struct net_device *netdev,
u16 tpid, u16 tci); u16 tpid, u16 tci);
......
...@@ -39,6 +39,8 @@ enum { ...@@ -39,6 +39,8 @@ enum {
DSA_NOTIFIER_MRP_DEL, DSA_NOTIFIER_MRP_DEL,
DSA_NOTIFIER_MRP_ADD_RING_ROLE, DSA_NOTIFIER_MRP_ADD_RING_ROLE,
DSA_NOTIFIER_MRP_DEL_RING_ROLE, DSA_NOTIFIER_MRP_DEL_RING_ROLE,
DSA_NOTIFIER_TAG_8021Q_VLAN_ADD,
DSA_NOTIFIER_TAG_8021Q_VLAN_DEL,
}; };
/* DSA_NOTIFIER_AGEING_TIME */ /* DSA_NOTIFIER_AGEING_TIME */
...@@ -113,6 +115,14 @@ struct dsa_notifier_mrp_ring_role_info { ...@@ -113,6 +115,14 @@ struct dsa_notifier_mrp_ring_role_info {
int port; int port;
}; };
/* DSA_NOTIFIER_TAG_8021Q_VLAN_* */
struct dsa_notifier_tag_8021q_vlan_info {
int tree_index;
int sw_index;
int port;
u16 vid;
};
struct dsa_switchdev_event_work { struct dsa_switchdev_event_work {
struct dsa_switch *ds; struct dsa_switch *ds;
int port; int port;
...@@ -253,6 +263,8 @@ int dsa_port_link_register_of(struct dsa_port *dp); ...@@ -253,6 +263,8 @@ int dsa_port_link_register_of(struct dsa_port *dp);
void dsa_port_link_unregister_of(struct dsa_port *dp); void dsa_port_link_unregister_of(struct dsa_port *dp);
int dsa_port_hsr_join(struct dsa_port *dp, struct net_device *hsr); int dsa_port_hsr_join(struct dsa_port *dp, struct net_device *hsr);
void dsa_port_hsr_leave(struct dsa_port *dp, struct net_device *hsr); void dsa_port_hsr_leave(struct dsa_port *dp, struct net_device *hsr);
int dsa_port_tag_8021q_vlan_add(struct dsa_port *dp, u16 vid);
void dsa_port_tag_8021q_vlan_del(struct dsa_port *dp, u16 vid);
extern const struct phylink_mac_ops dsa_port_phylink_mac_ops; extern const struct phylink_mac_ops dsa_port_phylink_mac_ops;
static inline bool dsa_port_offloads_bridge_port(struct dsa_port *dp, static inline bool dsa_port_offloads_bridge_port(struct dsa_port *dp,
...@@ -391,6 +403,10 @@ int dsa_tag_8021q_bridge_join(struct dsa_switch *ds, ...@@ -391,6 +403,10 @@ int dsa_tag_8021q_bridge_join(struct dsa_switch *ds,
struct dsa_notifier_bridge_info *info); struct dsa_notifier_bridge_info *info);
int dsa_tag_8021q_bridge_leave(struct dsa_switch *ds, int dsa_tag_8021q_bridge_leave(struct dsa_switch *ds,
struct dsa_notifier_bridge_info *info); struct dsa_notifier_bridge_info *info);
int dsa_switch_tag_8021q_vlan_add(struct dsa_switch *ds,
struct dsa_notifier_tag_8021q_vlan_info *info);
int dsa_switch_tag_8021q_vlan_del(struct dsa_switch *ds,
struct dsa_notifier_tag_8021q_vlan_info *info);
extern struct list_head dsa_tree_list; extern struct list_head dsa_tree_list;
......
...@@ -1217,3 +1217,31 @@ void dsa_port_hsr_leave(struct dsa_port *dp, struct net_device *hsr) ...@@ -1217,3 +1217,31 @@ void dsa_port_hsr_leave(struct dsa_port *dp, struct net_device *hsr)
if (err) if (err)
pr_err("DSA: failed to notify DSA_NOTIFIER_HSR_LEAVE\n"); pr_err("DSA: failed to notify DSA_NOTIFIER_HSR_LEAVE\n");
} }
int dsa_port_tag_8021q_vlan_add(struct dsa_port *dp, u16 vid)
{
struct dsa_notifier_tag_8021q_vlan_info info = {
.tree_index = dp->ds->dst->index,
.sw_index = dp->ds->index,
.port = dp->index,
.vid = vid,
};
return dsa_broadcast(DSA_NOTIFIER_TAG_8021Q_VLAN_ADD, &info);
}
void dsa_port_tag_8021q_vlan_del(struct dsa_port *dp, u16 vid)
{
struct dsa_notifier_tag_8021q_vlan_info info = {
.tree_index = dp->ds->dst->index,
.sw_index = dp->ds->index,
.port = dp->index,
.vid = vid,
};
int err;
err = dsa_broadcast(DSA_NOTIFIER_TAG_8021Q_VLAN_DEL, &info);
if (err)
pr_err("DSA: failed to notify tag_8021q VLAN deletion: %pe\n",
ERR_PTR(err));
}
...@@ -734,6 +734,12 @@ static int dsa_switch_event(struct notifier_block *nb, ...@@ -734,6 +734,12 @@ static int dsa_switch_event(struct notifier_block *nb,
case DSA_NOTIFIER_MRP_DEL_RING_ROLE: case DSA_NOTIFIER_MRP_DEL_RING_ROLE:
err = dsa_switch_mrp_del_ring_role(ds, info); err = dsa_switch_mrp_del_ring_role(ds, info);
break; break;
case DSA_NOTIFIER_TAG_8021Q_VLAN_ADD:
err = dsa_switch_tag_8021q_vlan_add(ds, info);
break;
case DSA_NOTIFIER_TAG_8021Q_VLAN_DEL:
err = dsa_switch_tag_8021q_vlan_del(ds, info);
break;
default: default:
err = -EOPNOTSUPP; err = -EOPNOTSUPP;
break; break;
......
...@@ -107,21 +107,152 @@ bool vid_is_dsa_8021q(u16 vid) ...@@ -107,21 +107,152 @@ bool vid_is_dsa_8021q(u16 vid)
} }
EXPORT_SYMBOL_GPL(vid_is_dsa_8021q); EXPORT_SYMBOL_GPL(vid_is_dsa_8021q);
/* If @enabled is true, installs @vid with @flags into the switch port's HW static struct dsa_tag_8021q_vlan *
* filter. dsa_tag_8021q_vlan_find(struct dsa_8021q_context *ctx, int port, u16 vid)
* If @enabled is false, deletes @vid (ignores @flags) from the port. Had the {
* user explicitly configured this @vid through the bridge core, then the @vid struct dsa_tag_8021q_vlan *v;
* is installed again, but this time with the flags from the bridge layer.
*/ list_for_each_entry(v, &ctx->vlans, list)
static int dsa_8021q_vid_apply(struct dsa_switch *ds, int port, u16 vid, if (v->vid == vid && v->port == port)
u16 flags, bool enabled) return v;
return NULL;
}
static int dsa_switch_do_tag_8021q_vlan_add(struct dsa_switch *ds, int port,
u16 vid, u16 flags)
{
struct dsa_8021q_context *ctx = ds->tag_8021q_ctx;
struct dsa_port *dp = dsa_to_port(ds, port);
struct dsa_tag_8021q_vlan *v;
int err;
/* No need to bother with refcounting for user ports */
if (!(dsa_port_is_cpu(dp) || dsa_port_is_dsa(dp)))
return ds->ops->tag_8021q_vlan_add(ds, port, vid, flags);
v = dsa_tag_8021q_vlan_find(ctx, port, vid);
if (v) {
refcount_inc(&v->refcount);
return 0;
}
v = kzalloc(sizeof(*v), GFP_KERNEL);
if (!v)
return -ENOMEM;
err = ds->ops->tag_8021q_vlan_add(ds, port, vid, flags);
if (err) {
kfree(v);
return err;
}
v->vid = vid;
v->port = port;
refcount_set(&v->refcount, 1);
list_add_tail(&v->list, &ctx->vlans);
return 0;
}
static int dsa_switch_do_tag_8021q_vlan_del(struct dsa_switch *ds, int port,
u16 vid)
{ {
struct dsa_8021q_context *ctx = ds->tag_8021q_ctx;
struct dsa_port *dp = dsa_to_port(ds, port); struct dsa_port *dp = dsa_to_port(ds, port);
struct dsa_tag_8021q_vlan *v;
int err;
/* No need to bother with refcounting for user ports */
if (!(dsa_port_is_cpu(dp) || dsa_port_is_dsa(dp)))
return ds->ops->tag_8021q_vlan_del(ds, port, vid);
v = dsa_tag_8021q_vlan_find(ctx, port, vid);
if (!v)
return -ENOENT;
if (!refcount_dec_and_test(&v->refcount))
return 0;
err = ds->ops->tag_8021q_vlan_del(ds, port, vid);
if (err) {
refcount_inc(&v->refcount);
return err;
}
list_del(&v->list);
kfree(v);
return 0;
}
static bool
dsa_switch_tag_8021q_vlan_match(struct dsa_switch *ds, int port,
struct dsa_notifier_tag_8021q_vlan_info *info)
{
if (dsa_is_dsa_port(ds, port) || dsa_is_cpu_port(ds, port))
return true;
if (ds->dst->index == info->tree_index && ds->index == info->sw_index)
return port == info->port;
if (enabled) return false;
return ds->ops->tag_8021q_vlan_add(ds, dp->index, vid, flags); }
int dsa_switch_tag_8021q_vlan_add(struct dsa_switch *ds,
struct dsa_notifier_tag_8021q_vlan_info *info)
{
int port, err;
/* Since we use dsa_broadcast(), there might be other switches in other
* trees which don't support tag_8021q, so don't return an error.
* Or they might even support tag_8021q but have not registered yet to
* use it (maybe they use another tagger currently).
*/
if (!ds->ops->tag_8021q_vlan_add || !ds->tag_8021q_ctx)
return 0;
for (port = 0; port < ds->num_ports; port++) {
if (dsa_switch_tag_8021q_vlan_match(ds, port, info)) {
u16 flags = 0;
if (dsa_is_user_port(ds, port))
flags |= BRIDGE_VLAN_INFO_UNTAGGED;
if (vid_is_dsa_8021q_rxvlan(info->vid) &&
dsa_8021q_rx_switch_id(info->vid) == ds->index &&
dsa_8021q_rx_source_port(info->vid) == port)
flags |= BRIDGE_VLAN_INFO_PVID;
err = dsa_switch_do_tag_8021q_vlan_add(ds, port,
info->vid,
flags);
if (err)
return err;
}
}
return 0;
}
int dsa_switch_tag_8021q_vlan_del(struct dsa_switch *ds,
struct dsa_notifier_tag_8021q_vlan_info *info)
{
int port, err;
return ds->ops->tag_8021q_vlan_del(ds, dp->index, vid); if (!ds->ops->tag_8021q_vlan_del || !ds->tag_8021q_ctx)
return 0;
for (port = 0; port < ds->num_ports; port++) {
if (dsa_switch_tag_8021q_vlan_match(ds, port, info)) {
err = dsa_switch_do_tag_8021q_vlan_del(ds, port,
info->vid);
if (err)
return err;
}
}
return 0;
} }
/* RX VLAN tagging (left) and TX VLAN tagging (right) setup shown for a single /* RX VLAN tagging (left) and TX VLAN tagging (right) setup shown for a single
...@@ -192,6 +323,7 @@ int dsa_tag_8021q_bridge_join(struct dsa_switch *ds, ...@@ -192,6 +323,7 @@ int dsa_tag_8021q_bridge_join(struct dsa_switch *ds,
struct dsa_notifier_bridge_info *info) struct dsa_notifier_bridge_info *info)
{ {
struct dsa_switch *targeted_ds; struct dsa_switch *targeted_ds;
struct dsa_port *targeted_dp;
u16 targeted_rx_vid; u16 targeted_rx_vid;
int err, port; int err, port;
...@@ -199,23 +331,23 @@ int dsa_tag_8021q_bridge_join(struct dsa_switch *ds, ...@@ -199,23 +331,23 @@ int dsa_tag_8021q_bridge_join(struct dsa_switch *ds,
return 0; return 0;
targeted_ds = dsa_switch_find(info->tree_index, info->sw_index); targeted_ds = dsa_switch_find(info->tree_index, info->sw_index);
targeted_dp = dsa_to_port(targeted_ds, info->port);
targeted_rx_vid = dsa_8021q_rx_vid(targeted_ds, info->port); targeted_rx_vid = dsa_8021q_rx_vid(targeted_ds, info->port);
for (port = 0; port < ds->num_ports; port++) { for (port = 0; port < ds->num_ports; port++) {
struct dsa_port *dp = dsa_to_port(ds, port);
u16 rx_vid = dsa_8021q_rx_vid(ds, port); u16 rx_vid = dsa_8021q_rx_vid(ds, port);
if (!dsa_tag_8021q_bridge_match(ds, port, info)) if (!dsa_tag_8021q_bridge_match(ds, port, info))
continue; continue;
/* Install the RX VID of the targeted port in our VLAN table */ /* Install the RX VID of the targeted port in our VLAN table */
err = dsa_8021q_vid_apply(ds, port, targeted_rx_vid, err = dsa_port_tag_8021q_vlan_add(dp, targeted_rx_vid);
BRIDGE_VLAN_INFO_UNTAGGED, true);
if (err) if (err)
return err; return err;
/* Install our RX VID into the targeted port's VLAN table */ /* Install our RX VID into the targeted port's VLAN table */
err = dsa_8021q_vid_apply(targeted_ds, info->port, rx_vid, err = dsa_port_tag_8021q_vlan_add(targeted_dp, rx_vid);
BRIDGE_VLAN_INFO_UNTAGGED, true);
if (err) if (err)
return err; return err;
} }
...@@ -227,46 +359,39 @@ int dsa_tag_8021q_bridge_leave(struct dsa_switch *ds, ...@@ -227,46 +359,39 @@ int dsa_tag_8021q_bridge_leave(struct dsa_switch *ds,
struct dsa_notifier_bridge_info *info) struct dsa_notifier_bridge_info *info)
{ {
struct dsa_switch *targeted_ds; struct dsa_switch *targeted_ds;
struct dsa_port *targeted_dp;
u16 targeted_rx_vid; u16 targeted_rx_vid;
int err, port; int port;
if (!ds->tag_8021q_ctx) if (!ds->tag_8021q_ctx)
return 0; return 0;
targeted_ds = dsa_switch_find(info->tree_index, info->sw_index); targeted_ds = dsa_switch_find(info->tree_index, info->sw_index);
targeted_dp = dsa_to_port(targeted_ds, info->port);
targeted_rx_vid = dsa_8021q_rx_vid(targeted_ds, info->port); targeted_rx_vid = dsa_8021q_rx_vid(targeted_ds, info->port);
for (port = 0; port < ds->num_ports; port++) { for (port = 0; port < ds->num_ports; port++) {
struct dsa_port *dp = dsa_to_port(ds, port);
u16 rx_vid = dsa_8021q_rx_vid(ds, port); u16 rx_vid = dsa_8021q_rx_vid(ds, port);
if (!dsa_tag_8021q_bridge_match(ds, port, info)) if (!dsa_tag_8021q_bridge_match(ds, port, info))
continue; continue;
/* Remove the RX VID of the targeted port from our VLAN table */ /* Remove the RX VID of the targeted port from our VLAN table */
err = dsa_8021q_vid_apply(ds, port, targeted_rx_vid, dsa_port_tag_8021q_vlan_del(dp, targeted_rx_vid);
BRIDGE_VLAN_INFO_UNTAGGED, false);
if (err)
dev_err(ds->dev,
"port %d failed to delete tag_8021q VLAN: %pe\n",
port, ERR_PTR(err));
/* Remove our RX VID from the targeted port's VLAN table */ /* Remove our RX VID from the targeted port's VLAN table */
err = dsa_8021q_vid_apply(targeted_ds, info->port, rx_vid, dsa_port_tag_8021q_vlan_del(targeted_dp, rx_vid);
BRIDGE_VLAN_INFO_UNTAGGED, false);
if (err)
dev_err(targeted_ds->dev,
"port %d failed to delete tag_8021q VLAN: %pe\n",
info->port, ERR_PTR(err));
} }
return 0; return 0;
} }
/* Set up a port's tag_8021q RX and TX VLAN for standalone mode operation */ /* Set up a port's tag_8021q RX and TX VLAN for standalone mode operation */
static int dsa_8021q_setup_port(struct dsa_switch *ds, int port, bool enabled) static int dsa_tag_8021q_port_setup(struct dsa_switch *ds, int port)
{ {
struct dsa_8021q_context *ctx = ds->tag_8021q_ctx; struct dsa_8021q_context *ctx = ds->tag_8021q_ctx;
int upstream = dsa_upstream_port(ds, port); struct dsa_port *dp = dsa_to_port(ds, port);
u16 rx_vid = dsa_8021q_rx_vid(ds, port); u16 rx_vid = dsa_8021q_rx_vid(ds, port);
u16 tx_vid = dsa_8021q_tx_vid(ds, port); u16 tx_vid = dsa_8021q_tx_vid(ds, port);
struct net_device *master; struct net_device *master;
...@@ -275,29 +400,17 @@ static int dsa_8021q_setup_port(struct dsa_switch *ds, int port, bool enabled) ...@@ -275,29 +400,17 @@ static int dsa_8021q_setup_port(struct dsa_switch *ds, int port, bool enabled)
/* The CPU port is implicitly configured by /* The CPU port is implicitly configured by
* configuring the front-panel ports * configuring the front-panel ports
*/ */
if (!dsa_is_user_port(ds, port)) if (!dsa_port_is_user(dp))
return 0; return 0;
master = dsa_to_port(ds, port)->cpu_dp->master; master = dp->cpu_dp->master;
/* Add this user port's RX VID to the membership list of all others /* Add this user port's RX VID to the membership list of all others
* (including itself). This is so that bridging will not be hindered. * (including itself). This is so that bridging will not be hindered.
* L2 forwarding rules still take precedence when there are no VLAN * L2 forwarding rules still take precedence when there are no VLAN
* restrictions, so there are no concerns about leaking traffic. * restrictions, so there are no concerns about leaking traffic.
*/ */
err = dsa_8021q_vid_apply(ds, port, rx_vid, BRIDGE_VLAN_INFO_UNTAGGED | err = dsa_port_tag_8021q_vlan_add(dp, rx_vid);
BRIDGE_VLAN_INFO_PVID, enabled);
if (err) {
dev_err(ds->dev,
"Failed to apply RX VID %d to port %d: %pe\n",
rx_vid, port, ERR_PTR(err));
return err;
}
/* CPU port needs to see this port's RX VID
* as tagged egress.
*/
err = dsa_8021q_vid_apply(ds, upstream, rx_vid, 0, enabled);
if (err) { if (err) {
dev_err(ds->dev, dev_err(ds->dev,
"Failed to apply RX VID %d to port %d: %pe\n", "Failed to apply RX VID %d to port %d: %pe\n",
...@@ -306,184 +419,71 @@ static int dsa_8021q_setup_port(struct dsa_switch *ds, int port, bool enabled) ...@@ -306,184 +419,71 @@ static int dsa_8021q_setup_port(struct dsa_switch *ds, int port, bool enabled)
} }
/* Add @rx_vid to the master's RX filter. */ /* Add @rx_vid to the master's RX filter. */
if (enabled)
vlan_vid_add(master, ctx->proto, rx_vid); vlan_vid_add(master, ctx->proto, rx_vid);
else
vlan_vid_del(master, ctx->proto, rx_vid);
/* Finally apply the TX VID on this port and on the CPU port */ /* Finally apply the TX VID on this port and on the CPU port */
err = dsa_8021q_vid_apply(ds, port, tx_vid, BRIDGE_VLAN_INFO_UNTAGGED, err = dsa_port_tag_8021q_vlan_add(dp, tx_vid);
enabled);
if (err) { if (err) {
dev_err(ds->dev, dev_err(ds->dev,
"Failed to apply TX VID %d on port %d: %pe\n", "Failed to apply TX VID %d on port %d: %pe\n",
tx_vid, port, ERR_PTR(err)); tx_vid, port, ERR_PTR(err));
return err; return err;
} }
err = dsa_8021q_vid_apply(ds, upstream, tx_vid, 0, enabled);
if (err) {
dev_err(ds->dev,
"Failed to apply TX VID %d on port %d: %pe\n",
tx_vid, upstream, ERR_PTR(err));
return err;
}
return err; return err;
} }
static int dsa_8021q_setup(struct dsa_switch *ds, bool enabled) static void dsa_tag_8021q_port_teardown(struct dsa_switch *ds, int port)
{
int err, port;
ASSERT_RTNL();
for (port = 0; port < ds->num_ports; port++) {
err = dsa_8021q_setup_port(ds, port, enabled);
if (err < 0) {
dev_err(ds->dev,
"Failed to setup VLAN tagging for port %d: %pe\n",
port, ERR_PTR(err));
return err;
}
}
return 0;
}
static int dsa_8021q_crosschip_link_apply(struct dsa_switch *ds, int port,
struct dsa_switch *other_ds,
int other_port, bool enabled)
{ {
struct dsa_8021q_context *ctx = ds->tag_8021q_ctx;
struct dsa_port *dp = dsa_to_port(ds, port);
u16 rx_vid = dsa_8021q_rx_vid(ds, port); u16 rx_vid = dsa_8021q_rx_vid(ds, port);
u16 tx_vid = dsa_8021q_tx_vid(ds, port);
struct net_device *master;
/* @rx_vid of local @ds port @port goes to @other_port of /* The CPU port is implicitly configured by
* @other_ds * configuring the front-panel ports
*/ */
return dsa_8021q_vid_apply(other_ds, other_port, rx_vid, if (!dsa_port_is_user(dp))
BRIDGE_VLAN_INFO_UNTAGGED, enabled); return;
}
static int dsa_8021q_crosschip_link_add(struct dsa_switch *ds, int port,
struct dsa_switch *other_ds,
int other_port)
{
struct dsa_8021q_context *other_ctx = other_ds->tag_8021q_ctx;
struct dsa_8021q_context *ctx = ds->tag_8021q_ctx;
struct dsa_8021q_crosschip_link *c;
list_for_each_entry(c, &ctx->crosschip_links, list) {
if (c->port == port && c->other_ctx == other_ctx &&
c->other_port == other_port) {
refcount_inc(&c->refcount);
return 0;
}
}
dev_dbg(ds->dev,
"adding crosschip link from port %d to %s port %d\n",
port, dev_name(other_ds->dev), other_port);
c = kzalloc(sizeof(*c), GFP_KERNEL); master = dp->cpu_dp->master;
if (!c)
return -ENOMEM;
c->port = port; dsa_port_tag_8021q_vlan_del(dp, rx_vid);
c->other_ctx = other_ctx;
c->other_port = other_port;
refcount_set(&c->refcount, 1);
list_add(&c->list, &ctx->crosschip_links); vlan_vid_del(master, ctx->proto, rx_vid);
return 0; dsa_port_tag_8021q_vlan_del(dp, tx_vid);
} }
static void dsa_8021q_crosschip_link_del(struct dsa_switch *ds, static int dsa_tag_8021q_setup(struct dsa_switch *ds)
struct dsa_8021q_crosschip_link *c,
bool *keep)
{ {
*keep = !refcount_dec_and_test(&c->refcount); int err, port;
if (*keep)
return;
dev_dbg(ds->dev,
"deleting crosschip link from port %d to %s port %d\n",
c->port, dev_name(c->other_ctx->ds->dev), c->other_port);
list_del(&c->list);
kfree(c);
}
/* Make traffic from local port @port be received by remote port @other_port.
* This means that our @rx_vid needs to be installed on @other_ds's upstream
* and user ports. The user ports should be egress-untagged so that they can
* pop the dsa_8021q VLAN. But the @other_upstream can be either egress-tagged
* or untagged: it doesn't matter, since it should never egress a frame having
* our @rx_vid.
*/
int dsa_8021q_crosschip_bridge_join(struct dsa_switch *ds, int port,
struct dsa_switch *other_ds,
int other_port)
{
/* @other_upstream is how @other_ds reaches us. If we are part
* of disjoint trees, then we are probably connected through
* our CPU ports. If we're part of the same tree though, we should
* probably use dsa_towards_port.
*/
int other_upstream = dsa_upstream_port(other_ds, other_port);
int err;
err = dsa_8021q_crosschip_link_add(ds, port, other_ds, other_port);
if (err)
return err;
err = dsa_8021q_crosschip_link_apply(ds, port, other_ds, ASSERT_RTNL();
other_port, true);
if (err)
return err;
err = dsa_8021q_crosschip_link_add(ds, port, other_ds, other_upstream); for (port = 0; port < ds->num_ports; port++) {
if (err) err = dsa_tag_8021q_port_setup(ds, port);
if (err < 0) {
dev_err(ds->dev,
"Failed to setup VLAN tagging for port %d: %pe\n",
port, ERR_PTR(err));
return err; return err;
}
}
return dsa_8021q_crosschip_link_apply(ds, port, other_ds, return 0;
other_upstream, true);
} }
EXPORT_SYMBOL_GPL(dsa_8021q_crosschip_bridge_join);
int dsa_8021q_crosschip_bridge_leave(struct dsa_switch *ds, int port, static void dsa_tag_8021q_teardown(struct dsa_switch *ds)
struct dsa_switch *other_ds,
int other_port)
{ {
struct dsa_8021q_context *other_ctx = other_ds->tag_8021q_ctx; int port;
int other_upstream = dsa_upstream_port(other_ds, other_port);
struct dsa_8021q_context *ctx = ds->tag_8021q_ctx;
struct dsa_8021q_crosschip_link *c, *n;
list_for_each_entry_safe(c, n, &ctx->crosschip_links, list) {
if (c->port == port && c->other_ctx == other_ctx &&
(c->other_port == other_port ||
c->other_port == other_upstream)) {
int other_port = c->other_port;
bool keep;
int err;
dsa_8021q_crosschip_link_del(ds, c, &keep); ASSERT_RTNL();
if (keep)
continue;
err = dsa_8021q_crosschip_link_apply(ds, port,
other_ds,
other_port,
false);
if (err)
return err;
}
}
return 0; for (port = 0; port < ds->num_ports; port++)
dsa_tag_8021q_port_teardown(ds, port);
} }
EXPORT_SYMBOL_GPL(dsa_8021q_crosschip_bridge_leave);
int dsa_tag_8021q_register(struct dsa_switch *ds, __be16 proto) int dsa_tag_8021q_register(struct dsa_switch *ds, __be16 proto)
{ {
...@@ -496,28 +496,24 @@ int dsa_tag_8021q_register(struct dsa_switch *ds, __be16 proto) ...@@ -496,28 +496,24 @@ int dsa_tag_8021q_register(struct dsa_switch *ds, __be16 proto)
ctx->proto = proto; ctx->proto = proto;
ctx->ds = ds; ctx->ds = ds;
INIT_LIST_HEAD(&ctx->crosschip_links); INIT_LIST_HEAD(&ctx->vlans);
ds->tag_8021q_ctx = ctx; ds->tag_8021q_ctx = ctx;
return dsa_8021q_setup(ds, true); return dsa_tag_8021q_setup(ds);
} }
EXPORT_SYMBOL_GPL(dsa_tag_8021q_register); EXPORT_SYMBOL_GPL(dsa_tag_8021q_register);
void dsa_tag_8021q_unregister(struct dsa_switch *ds) void dsa_tag_8021q_unregister(struct dsa_switch *ds)
{ {
struct dsa_8021q_context *ctx = ds->tag_8021q_ctx; struct dsa_8021q_context *ctx = ds->tag_8021q_ctx;
struct dsa_8021q_crosschip_link *c, *n; struct dsa_tag_8021q_vlan *v, *n;
int err;
err = dsa_8021q_setup(ds, false); dsa_tag_8021q_teardown(ds);
if (err)
dev_err(ds->dev, "failed to tear down tag_8021q VLANs: %pe\n",
ERR_PTR(err));
list_for_each_entry_safe(c, n, &ctx->crosschip_links, list) { list_for_each_entry_safe(v, n, &ctx->vlans, list) {
list_del(&c->list); list_del(&v->list);
kfree(c); kfree(v);
} }
ds->tag_8021q_ctx = NULL; ds->tag_8021q_ctx = NULL;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment