Commit 981f084b authored by Ido Schimmel's avatar Ido Schimmel Committed by David S. Miller
Browse files

mlxsw: spectrum_switchdev: Process learned VxLAN FDB entries 



Start processing two new entry types in addition to current ones:
* Learned unicast tunnel entry
* Aged-out unicast tunnel entry

In both cases the device reports on a new {MAC, FID, IP address} tuple
that was learned / aged-out. Based on this notification, the driver
instructs the device to add / delete the entry to / from its database.

The driver also makes sure to notify the bridge and VxLAN drivers about
the new entry.

Signed-off-by: default avatarIdo Schimmel <idosch@mellanox.com>
Reviewed-by: default avatarPetr Machata <petrm@mellanox.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent 3c55bdac

drivers/net/ethernet/mellanox/mlxsw/spectrum_switchdev.c

+189 −14
Original line number Diff line number Diff line
@@ -2311,6 +2311,71 @@ void mlxsw_sp_bridge_vxlan_leave(struct mlxsw_sp *mlxsw_sp, 
	bridge_device->ops->vxlan_leave(bridge_device, vxlan_dev);

}



static void

mlxsw_sp_switchdev_vxlan_addr_convert(const union vxlan_addr *vxlan_addr,

				      enum mlxsw_sp_l3proto *proto,

				      union mlxsw_sp_l3addr *addr)

{

	if (vxlan_addr->sa.sa_family == AF_INET) {

		addr->addr4 = vxlan_addr->sin.sin_addr.s_addr;

		*proto = MLXSW_SP_L3_PROTO_IPV4;

	} else {

		addr->addr6 = vxlan_addr->sin6.sin6_addr;

		*proto = MLXSW_SP_L3_PROTO_IPV6;

	}

}



static void

mlxsw_sp_switchdev_addr_vxlan_convert(enum mlxsw_sp_l3proto proto,

				      const union mlxsw_sp_l3addr *addr,

				      union vxlan_addr *vxlan_addr)

{

	switch (proto) {

	case MLXSW_SP_L3_PROTO_IPV4:

		vxlan_addr->sa.sa_family = AF_INET;

		vxlan_addr->sin.sin_addr.s_addr = addr->addr4;

		break;

	case MLXSW_SP_L3_PROTO_IPV6:

		vxlan_addr->sa.sa_family = AF_INET6;

		vxlan_addr->sin6.sin6_addr = addr->addr6;

		break;

	}

}



static void mlxsw_sp_fdb_vxlan_call_notifiers(struct net_device *dev,

					      const char *mac,

					      enum mlxsw_sp_l3proto proto,

					      union mlxsw_sp_l3addr *addr,

					      __be32 vni, bool adding)

{

	struct switchdev_notifier_vxlan_fdb_info info;

	struct vxlan_dev *vxlan = netdev_priv(dev);

	enum switchdev_notifier_type type;



	type = adding ? SWITCHDEV_VXLAN_FDB_ADD_TO_BRIDGE :

			SWITCHDEV_VXLAN_FDB_DEL_TO_BRIDGE;

	mlxsw_sp_switchdev_addr_vxlan_convert(proto, addr, &info.remote_ip);

	info.remote_port = vxlan->cfg.dst_port;

	info.remote_vni = vni;

	info.remote_ifindex = 0;

	ether_addr_copy(info.eth_addr, mac);

	info.vni = vni;

	info.offloaded = adding;

	call_switchdev_notifiers(type, dev, &info.info);

}



static void mlxsw_sp_fdb_nve_call_notifiers(struct net_device *dev,

					    const char *mac,

					    enum mlxsw_sp_l3proto proto,

					    union mlxsw_sp_l3addr *addr,

					    __be32 vni,

					    bool adding)

{

	if (netif_is_vxlan(dev))

		mlxsw_sp_fdb_vxlan_call_notifiers(dev, mac, proto, addr, vni,

						  adding);

}



static void

mlxsw_sp_fdb_call_notifiers(enum switchdev_notifier_type type,

			    const char *mac, u16 vid,
@@ -2442,6 +2507,122 @@ just_remove: 
	goto do_fdb_op;

}



static int

__mlxsw_sp_fdb_notify_mac_uc_tunnel_process(struct mlxsw_sp *mlxsw_sp,

					    const struct mlxsw_sp_fid *fid,

					    bool adding,

					    struct net_device **nve_dev,

					    u16 *p_vid, __be32 *p_vni)

{

	struct mlxsw_sp_bridge_device *bridge_device;

	struct net_device *br_dev, *dev;

	int nve_ifindex;

	int err;



	err = mlxsw_sp_fid_nve_ifindex(fid, &nve_ifindex);

	if (err)

		return err;



	err = mlxsw_sp_fid_vni(fid, p_vni);

	if (err)

		return err;



	dev = __dev_get_by_index(&init_net, nve_ifindex);

	if (!dev)

		return -EINVAL;

	*nve_dev = dev;



	if (!netif_running(dev))

		return -EINVAL;



	if (adding && !br_port_flag_is_set(dev, BR_LEARNING))

		return -EINVAL;



	if (adding && netif_is_vxlan(dev)) {

		struct vxlan_dev *vxlan = netdev_priv(dev);



		if (!(vxlan->cfg.flags & VXLAN_F_LEARN))

			return -EINVAL;

	}



	br_dev = netdev_master_upper_dev_get(dev);

	if (!br_dev)

		return -EINVAL;



	bridge_device = mlxsw_sp_bridge_device_find(mlxsw_sp->bridge, br_dev);

	if (!bridge_device)

		return -EINVAL;



	*p_vid = bridge_device->ops->fid_vid(bridge_device, fid);



	return 0;

}



static void mlxsw_sp_fdb_notify_mac_uc_tunnel_process(struct mlxsw_sp *mlxsw_sp,

						      char *sfn_pl,

						      int rec_index,

						      bool adding)

{

	enum mlxsw_reg_sfn_uc_tunnel_protocol sfn_proto;

	enum switchdev_notifier_type type;

	struct net_device *nve_dev;

	union mlxsw_sp_l3addr addr;

	struct mlxsw_sp_fid *fid;

	char mac[ETH_ALEN];

	u16 fid_index, vid;

	__be32 vni;

	u32 uip;

	int err;



	mlxsw_reg_sfn_uc_tunnel_unpack(sfn_pl, rec_index, mac, &fid_index,

				       &uip, &sfn_proto);



	fid = mlxsw_sp_fid_lookup_by_index(mlxsw_sp, fid_index);

	if (!fid)

		goto err_fid_lookup;



	err = mlxsw_sp_nve_learned_ip_resolve(mlxsw_sp, uip,

					      (enum mlxsw_sp_l3proto) sfn_proto,

					      &addr);

	if (err)

		goto err_ip_resolve;



	err = __mlxsw_sp_fdb_notify_mac_uc_tunnel_process(mlxsw_sp, fid, adding,

							  &nve_dev, &vid, &vni);

	if (err)

		goto err_fdb_process;



	err = mlxsw_sp_port_fdb_tunnel_uc_op(mlxsw_sp, mac, fid_index,

					     (enum mlxsw_sp_l3proto) sfn_proto,

					     &addr, adding, true);

	if (err)

		goto err_fdb_op;



	mlxsw_sp_fdb_nve_call_notifiers(nve_dev, mac,

					(enum mlxsw_sp_l3proto) sfn_proto,

					&addr, vni, adding);



	type = adding ? SWITCHDEV_FDB_ADD_TO_BRIDGE :

			SWITCHDEV_FDB_DEL_TO_BRIDGE;

	mlxsw_sp_fdb_call_notifiers(type, mac, vid, nve_dev, adding);



	mlxsw_sp_fid_put(fid);



	return;



err_fdb_op:

err_fdb_process:

err_ip_resolve:

	mlxsw_sp_fid_put(fid);

err_fid_lookup:

	/* Remove an FDB entry in case we cannot process it. Otherwise the

	 * device will keep sending the same notification over and over again.

	 */

	mlxsw_sp_port_fdb_tunnel_uc_op(mlxsw_sp, mac, fid_index,

				       (enum mlxsw_sp_l3proto) sfn_proto, &addr,

				       false, true);

}



static void mlxsw_sp_fdb_notify_rec_process(struct mlxsw_sp *mlxsw_sp,

					    char *sfn_pl, int rec_index)

{
@@ -2462,6 +2643,14 @@ static void mlxsw_sp_fdb_notify_rec_process(struct mlxsw_sp *mlxsw_sp, 
		mlxsw_sp_fdb_notify_mac_lag_process(mlxsw_sp, sfn_pl,

						    rec_index, false);

		break;

	case MLXSW_REG_SFN_REC_TYPE_LEARNED_UNICAST_TUNNEL:

		mlxsw_sp_fdb_notify_mac_uc_tunnel_process(mlxsw_sp, sfn_pl,

							  rec_index, true);

		break;

	case MLXSW_REG_SFN_REC_TYPE_AGED_OUT_UNICAST_TUNNEL:

		mlxsw_sp_fdb_notify_mac_uc_tunnel_process(mlxsw_sp, sfn_pl,

							  rec_index, false);

		break;

	}

}
@@ -2516,20 +2705,6 @@ struct mlxsw_sp_switchdev_event_work { 
	unsigned long event;

};



static void

mlxsw_sp_switchdev_vxlan_addr_convert(const union vxlan_addr *vxlan_addr,

				      enum mlxsw_sp_l3proto *proto,

				      union mlxsw_sp_l3addr *addr)

{

	if (vxlan_addr->sa.sa_family == AF_INET) {

		addr->addr4 = vxlan_addr->sin.sin_addr.s_addr;

		*proto = MLXSW_SP_L3_PROTO_IPV4;

	} else {

		addr->addr6 = vxlan_addr->sin6.sin6_addr;

		*proto = MLXSW_SP_L3_PROTO_IPV6;

	}

}



static void

mlxsw_sp_switchdev_bridge_vxlan_fdb_event(struct mlxsw_sp *mlxsw_sp,

					  struct mlxsw_sp_switchdev_event_work *

CRA Git | Maintained and supported by SUSTech CRA and CCSE