Commit eca4205f authored by Pablo Neira Ayuso's avatar Pablo Neira Ayuso Committed by David S. Miller
Browse files

ethtool: add ethtool_rx_flow_spec to flow_rule structure translator 



This patch adds a function to translate the ethtool_rx_flow_spec
structure to the flow_rule representation.

This allows us to reuse code from the driver side given that both flower
and ethtool_rx_flow interfaces use the same representation.

This patch also includes support for the flow type flags FLOW_EXT,
FLOW_MAC_EXT and FLOW_RSS.

The ethtool_rx_flow_spec_input wrapper structure is used to convey the
rss_context field, that is away from the ethtool_rx_flow_spec structure,
and the ethtool_rx_flow_spec structure.

Signed-off-by: default avatarPablo Neira Ayuso <pablo@netfilter.org>
Acked-by: default avatarJiri Pirko <jiri@mellanox.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent 8bec2833

include/linux/ethtool.h

+15 −0
Original line number Diff line number Diff line
@@ -400,4 +400,19 @@ struct ethtool_ops { 
	void	(*get_ethtool_phy_stats)(struct net_device *,

					 struct ethtool_stats *, u64 *);

};



struct ethtool_rx_flow_rule {

	struct flow_rule	*rule;

	unsigned long		priv[0];

};



struct ethtool_rx_flow_spec_input {

	const struct ethtool_rx_flow_spec	*fs;

	u32					rss_ctx;

};



struct ethtool_rx_flow_rule *

ethtool_rx_flow_rule_create(const struct ethtool_rx_flow_spec_input *input);

void ethtool_rx_flow_rule_destroy(struct ethtool_rx_flow_rule *rule);



#endif /* _LINUX_ETHTOOL_H */

net/core/ethtool.c

+241 −0
Original line number Diff line number Diff line
@@ -29,6 +29,7 @@ 
#include <linux/net.h>

#include <net/devlink.h>

#include <net/xdp_sock.h>

#include <net/flow_offload.h>



/*

 * Some useful ethtool_ops methods that're device independent.
@@ -2820,3 +2821,243 @@ int dev_ethtool(struct net *net, struct ifreq *ifr) 


	return rc;

}



struct ethtool_rx_flow_key {

	struct flow_dissector_key_basic			basic;

	union {

		struct flow_dissector_key_ipv4_addrs	ipv4;

		struct flow_dissector_key_ipv6_addrs	ipv6;

	};

	struct flow_dissector_key_ports			tp;

	struct flow_dissector_key_ip			ip;

	struct flow_dissector_key_vlan			vlan;

	struct flow_dissector_key_eth_addrs		eth_addrs;

} __aligned(BITS_PER_LONG / 8); /* Ensure that we can do comparisons as longs. */



struct ethtool_rx_flow_match {

	struct flow_dissector		dissector;

	struct ethtool_rx_flow_key	key;

	struct ethtool_rx_flow_key	mask;

};



struct ethtool_rx_flow_rule *

ethtool_rx_flow_rule_create(const struct ethtool_rx_flow_spec_input *input)

{

	const struct ethtool_rx_flow_spec *fs = input->fs;

	static struct in6_addr zero_addr = {};

	struct ethtool_rx_flow_match *match;

	struct ethtool_rx_flow_rule *flow;

	struct flow_action_entry *act;



	flow = kzalloc(sizeof(struct ethtool_rx_flow_rule) +

		       sizeof(struct ethtool_rx_flow_match), GFP_KERNEL);

	if (!flow)

		return ERR_PTR(-ENOMEM);



	/* ethtool_rx supports only one single action per rule. */

	flow->rule = flow_rule_alloc(1);

	if (!flow->rule) {

		kfree(flow);

		return ERR_PTR(-ENOMEM);

	}



	match = (struct ethtool_rx_flow_match *)flow->priv;

	flow->rule->match.dissector	= &match->dissector;

	flow->rule->match.mask		= &match->mask;

	flow->rule->match.key		= &match->key;



	match->mask.basic.n_proto = htons(0xffff);



	switch (fs->flow_type & ~(FLOW_EXT | FLOW_MAC_EXT | FLOW_RSS)) {

	case TCP_V4_FLOW:

	case UDP_V4_FLOW: {

		const struct ethtool_tcpip4_spec *v4_spec, *v4_m_spec;



		match->key.basic.n_proto = htons(ETH_P_IP);



		v4_spec = &fs->h_u.tcp_ip4_spec;

		v4_m_spec = &fs->m_u.tcp_ip4_spec;



		if (v4_m_spec->ip4src) {

			match->key.ipv4.src = v4_spec->ip4src;

			match->mask.ipv4.src = v4_m_spec->ip4src;

		}

		if (v4_m_spec->ip4dst) {

			match->key.ipv4.dst = v4_spec->ip4dst;

			match->mask.ipv4.dst = v4_m_spec->ip4dst;

		}

		if (v4_m_spec->ip4src ||

		    v4_m_spec->ip4dst) {

			match->dissector.used_keys |=

				BIT(FLOW_DISSECTOR_KEY_IPV4_ADDRS);

			match->dissector.offset[FLOW_DISSECTOR_KEY_IPV4_ADDRS] =

				offsetof(struct ethtool_rx_flow_key, ipv4);

		}

		if (v4_m_spec->psrc) {

			match->key.tp.src = v4_spec->psrc;

			match->mask.tp.src = v4_m_spec->psrc;

		}

		if (v4_m_spec->pdst) {

			match->key.tp.dst = v4_spec->pdst;

			match->mask.tp.dst = v4_m_spec->pdst;

		}

		if (v4_m_spec->psrc ||

		    v4_m_spec->pdst) {

			match->dissector.used_keys |=

				BIT(FLOW_DISSECTOR_KEY_PORTS);

			match->dissector.offset[FLOW_DISSECTOR_KEY_PORTS] =

				offsetof(struct ethtool_rx_flow_key, tp);

		}

		if (v4_m_spec->tos) {

			match->key.ip.tos = v4_spec->tos;

			match->mask.ip.tos = v4_m_spec->tos;

			match->dissector.used_keys |=

				BIT(FLOW_DISSECTOR_KEY_IP);

			match->dissector.offset[FLOW_DISSECTOR_KEY_IP] =

				offsetof(struct ethtool_rx_flow_key, ip);

		}

		}

		break;

	case TCP_V6_FLOW:

	case UDP_V6_FLOW: {

		const struct ethtool_tcpip6_spec *v6_spec, *v6_m_spec;



		match->key.basic.n_proto = htons(ETH_P_IPV6);



		v6_spec = &fs->h_u.tcp_ip6_spec;

		v6_m_spec = &fs->m_u.tcp_ip6_spec;

		if (memcmp(v6_m_spec->ip6src, &zero_addr, sizeof(zero_addr))) {

			memcpy(&match->key.ipv6.src, v6_spec->ip6src,

			       sizeof(match->key.ipv6.src));

			memcpy(&match->mask.ipv6.src, v6_m_spec->ip6src,

			       sizeof(match->mask.ipv6.src));

		}

		if (memcmp(v6_m_spec->ip6dst, &zero_addr, sizeof(zero_addr))) {

			memcpy(&match->key.ipv6.dst, v6_spec->ip6dst,

			       sizeof(match->key.ipv6.dst));

			memcpy(&match->mask.ipv6.dst, v6_m_spec->ip6dst,

			       sizeof(match->mask.ipv6.dst));

		}

		if (memcmp(v6_m_spec->ip6src, &zero_addr, sizeof(zero_addr)) ||

		    memcmp(v6_m_spec->ip6src, &zero_addr, sizeof(zero_addr))) {

			match->dissector.used_keys |=

				BIT(FLOW_DISSECTOR_KEY_IPV6_ADDRS);

			match->dissector.offset[FLOW_DISSECTOR_KEY_IPV6_ADDRS] =

				offsetof(struct ethtool_rx_flow_key, ipv6);

		}

		if (v6_m_spec->psrc) {

			match->key.tp.src = v6_spec->psrc;

			match->mask.tp.src = v6_m_spec->psrc;

		}

		if (v6_m_spec->pdst) {

			match->key.tp.dst = v6_spec->pdst;

			match->mask.tp.dst = v6_m_spec->pdst;

		}

		if (v6_m_spec->psrc ||

		    v6_m_spec->pdst) {

			match->dissector.used_keys |=

				BIT(FLOW_DISSECTOR_KEY_PORTS);

			match->dissector.offset[FLOW_DISSECTOR_KEY_PORTS] =

				offsetof(struct ethtool_rx_flow_key, tp);

		}

		if (v6_m_spec->tclass) {

			match->key.ip.tos = v6_spec->tclass;

			match->mask.ip.tos = v6_m_spec->tclass;

			match->dissector.used_keys |=

				BIT(FLOW_DISSECTOR_KEY_IP);

			match->dissector.offset[FLOW_DISSECTOR_KEY_IP] =

				offsetof(struct ethtool_rx_flow_key, ip);

		}

		}

		break;

	default:

		ethtool_rx_flow_rule_destroy(flow);

		return ERR_PTR(-EINVAL);

	}



	switch (fs->flow_type & ~(FLOW_EXT | FLOW_MAC_EXT | FLOW_RSS)) {

	case TCP_V4_FLOW:

	case TCP_V6_FLOW:

		match->key.basic.ip_proto = IPPROTO_TCP;

		break;

	case UDP_V4_FLOW:

	case UDP_V6_FLOW:

		match->key.basic.ip_proto = IPPROTO_UDP;

		break;

	}

	match->mask.basic.ip_proto = 0xff;



	match->dissector.used_keys |= BIT(FLOW_DISSECTOR_KEY_BASIC);

	match->dissector.offset[FLOW_DISSECTOR_KEY_BASIC] =

		offsetof(struct ethtool_rx_flow_key, basic);



	if (fs->flow_type & FLOW_EXT) {

		const struct ethtool_flow_ext *ext_h_spec = &fs->h_ext;

		const struct ethtool_flow_ext *ext_m_spec = &fs->m_ext;



		if (ext_m_spec->vlan_etype &&

		    ext_m_spec->vlan_tci) {

			match->key.vlan.vlan_tpid = ext_h_spec->vlan_etype;

			match->mask.vlan.vlan_tpid = ext_m_spec->vlan_etype;



			match->key.vlan.vlan_id =

				ntohs(ext_h_spec->vlan_tci) & 0x0fff;

			match->mask.vlan.vlan_id =

				ntohs(ext_m_spec->vlan_tci) & 0x0fff;



			match->key.vlan.vlan_priority =

				(ntohs(ext_h_spec->vlan_tci) & 0xe000) >> 13;

			match->mask.vlan.vlan_priority =

				(ntohs(ext_m_spec->vlan_tci) & 0xe000) >> 13;



			match->dissector.used_keys |=

				BIT(FLOW_DISSECTOR_KEY_VLAN);

			match->dissector.offset[FLOW_DISSECTOR_KEY_VLAN] =

				offsetof(struct ethtool_rx_flow_key, vlan);

		}

	}

	if (fs->flow_type & FLOW_MAC_EXT) {

		const struct ethtool_flow_ext *ext_h_spec = &fs->h_ext;

		const struct ethtool_flow_ext *ext_m_spec = &fs->m_ext;



		if (ext_m_spec->h_dest) {

			memcpy(match->key.eth_addrs.dst, ext_h_spec->h_dest,

			       ETH_ALEN);

			memcpy(match->mask.eth_addrs.dst, ext_m_spec->h_dest,

			       ETH_ALEN);



			match->dissector.used_keys |=

				BIT(FLOW_DISSECTOR_KEY_ETH_ADDRS);

			match->dissector.offset[FLOW_DISSECTOR_KEY_ETH_ADDRS] =

				offsetof(struct ethtool_rx_flow_key, eth_addrs);

		}

	}



	act = &flow->rule->action.entries[0];

	switch (fs->ring_cookie) {

	case RX_CLS_FLOW_DISC:

		act->id = FLOW_ACTION_DROP;

		break;

	case RX_CLS_FLOW_WAKE:

		act->id = FLOW_ACTION_WAKE;

		break;

	default:

		act->id = FLOW_ACTION_QUEUE;

		if (fs->flow_type & FLOW_RSS)

			act->queue.ctx = input->rss_ctx;



		act->queue.vf = ethtool_get_flow_spec_ring_vf(fs->ring_cookie);

		act->queue.index = ethtool_get_flow_spec_ring(fs->ring_cookie);

		break;

	}



	return flow;

}

EXPORT_SYMBOL(ethtool_rx_flow_rule_create);



void ethtool_rx_flow_rule_destroy(struct ethtool_rx_flow_rule *flow)

{

	kfree(flow->rule);

	kfree(flow);

}

EXPORT_SYMBOL(ethtool_rx_flow_rule_destroy);

CRA Git | Maintained and supported by SUSTech CRA and CCSE