1// SPDX-License-Identifier: (GPL-2.0+ OR BSD-3-Clause)
2/* Copyright 2014-2016 Freescale Semiconductor Inc.
3 * Copyright 2016-2022 NXP
4 */
5
6#include <linux/net_tstamp.h>
7#include <linux/nospec.h>
8
9#include "dpni.h"	/* DPNI_LINK_OPT_* */
10#include "dpaa2-eth.h"
11
12/* To be kept in sync with DPNI statistics */
13static char dpaa2_ethtool_stats[][ETH_GSTRING_LEN] = {
14	"[hw] rx frames",
15	"[hw] rx bytes",
16	"[hw] rx mcast frames",
17	"[hw] rx mcast bytes",
18	"[hw] rx bcast frames",
19	"[hw] rx bcast bytes",
20	"[hw] tx frames",
21	"[hw] tx bytes",
22	"[hw] tx mcast frames",
23	"[hw] tx mcast bytes",
24	"[hw] tx bcast frames",
25	"[hw] tx bcast bytes",
26	"[hw] rx filtered frames",
27	"[hw] rx discarded frames",
28	"[hw] rx nobuffer discards",
29	"[hw] tx discarded frames",
30	"[hw] tx confirmed frames",
31	"[hw] tx dequeued bytes",
32	"[hw] tx dequeued frames",
33	"[hw] tx rejected bytes",
34	"[hw] tx rejected frames",
35	"[hw] tx pending frames",
36};
37
38#define DPAA2_ETH_NUM_STATS	ARRAY_SIZE(dpaa2_ethtool_stats)
39
40static char dpaa2_ethtool_extras[][ETH_GSTRING_LEN] = {
41	/* per-cpu stats */
42	"[drv] tx conf frames",
43	"[drv] tx conf bytes",
44	"[drv] tx sg frames",
45	"[drv] tx sg bytes",
46	"[drv] tx tso frames",
47	"[drv] tx tso bytes",
48	"[drv] rx sg frames",
49	"[drv] rx sg bytes",
50	"[drv] tx converted sg frames",
51	"[drv] tx converted sg bytes",
52	"[drv] enqueue portal busy",
53	/* Channel stats */
54	"[drv] dequeue portal busy",
55	"[drv] channel pull errors",
56	"[drv] cdan",
57	"[drv] xdp drop",
58	"[drv] xdp tx",
59	"[drv] xdp tx errors",
60	"[drv] xdp redirect",
61	/* FQ stats */
62	"[qbman] rx pending frames",
63	"[qbman] rx pending bytes",
64	"[qbman] tx conf pending frames",
65	"[qbman] tx conf pending bytes",
66	"[qbman] buffer count",
67};
68
69#define DPAA2_ETH_NUM_EXTRA_STATS	ARRAY_SIZE(dpaa2_ethtool_extras)
70
71static void dpaa2_eth_get_drvinfo(struct net_device *net_dev,
72				  struct ethtool_drvinfo *drvinfo)
73{
74	struct dpaa2_eth_priv *priv = netdev_priv(net_dev);
75
76	strscpy(drvinfo->driver, KBUILD_MODNAME, sizeof(drvinfo->driver));
77
78	snprintf(drvinfo->fw_version, sizeof(drvinfo->fw_version),
79		 "%u.%u", priv->dpni_ver_major, priv->dpni_ver_minor);
80
81	strscpy(drvinfo->bus_info, dev_name(net_dev->dev.parent->parent),
82		sizeof(drvinfo->bus_info));
83}
84
85static int dpaa2_eth_nway_reset(struct net_device *net_dev)
86{
87	struct dpaa2_eth_priv *priv = netdev_priv(net_dev);
88	int err = -EOPNOTSUPP;
89
90	mutex_lock(&priv->mac_lock);
91
92	if (dpaa2_eth_is_type_phy(priv))
93		err = phylink_ethtool_nway_reset(priv->mac->phylink);
94
95	mutex_unlock(&priv->mac_lock);
96
97	return err;
98}
99
100static int
101dpaa2_eth_get_link_ksettings(struct net_device *net_dev,
102			     struct ethtool_link_ksettings *link_settings)
103{
104	struct dpaa2_eth_priv *priv = netdev_priv(net_dev);
105	int err;
106
107	mutex_lock(&priv->mac_lock);
108
109	if (dpaa2_eth_is_type_phy(priv)) {
110		err = phylink_ethtool_ksettings_get(priv->mac->phylink,
111						    link_settings);
112		mutex_unlock(&priv->mac_lock);
113		return err;
114	}
115
116	mutex_unlock(&priv->mac_lock);
117
118	link_settings->base.autoneg = AUTONEG_DISABLE;
119	if (!(priv->link_state.options & DPNI_LINK_OPT_HALF_DUPLEX))
120		link_settings->base.duplex = DUPLEX_FULL;
121	link_settings->base.speed = priv->link_state.rate;
122
123	return 0;
124}
125
126static int
127dpaa2_eth_set_link_ksettings(struct net_device *net_dev,
128			     const struct ethtool_link_ksettings *link_settings)
129{
130	struct dpaa2_eth_priv *priv = netdev_priv(net_dev);
131	int err = -EOPNOTSUPP;
132
133	mutex_lock(&priv->mac_lock);
134
135	if (dpaa2_eth_is_type_phy(priv))
136		err = phylink_ethtool_ksettings_set(priv->mac->phylink,
137						    link_settings);
138
139	mutex_unlock(&priv->mac_lock);
140
141	return err;
142}
143
144static void dpaa2_eth_get_pauseparam(struct net_device *net_dev,
145				     struct ethtool_pauseparam *pause)
146{
147	struct dpaa2_eth_priv *priv = netdev_priv(net_dev);
148	u64 link_options = priv->link_state.options;
149
150	mutex_lock(&priv->mac_lock);
151
152	if (dpaa2_eth_is_type_phy(priv)) {
153		phylink_ethtool_get_pauseparam(priv->mac->phylink, pause);
154		mutex_unlock(&priv->mac_lock);
155		return;
156	}
157
158	mutex_unlock(&priv->mac_lock);
159
160	pause->rx_pause = dpaa2_eth_rx_pause_enabled(link_options);
161	pause->tx_pause = dpaa2_eth_tx_pause_enabled(link_options);
162	pause->autoneg = AUTONEG_DISABLE;
163}
164
165static int dpaa2_eth_set_pauseparam(struct net_device *net_dev,
166				    struct ethtool_pauseparam *pause)
167{
168	struct dpaa2_eth_priv *priv = netdev_priv(net_dev);
169	struct dpni_link_cfg cfg = {0};
170	int err;
171
172	if (!dpaa2_eth_has_pause_support(priv)) {
173		netdev_info(net_dev, "No pause frame support for DPNI version < %d.%d\n",
174			    DPNI_PAUSE_VER_MAJOR, DPNI_PAUSE_VER_MINOR);
175		return -EOPNOTSUPP;
176	}
177
178	mutex_lock(&priv->mac_lock);
179
180	if (dpaa2_eth_is_type_phy(priv)) {
181		err = phylink_ethtool_set_pauseparam(priv->mac->phylink,
182						     pause);
183		mutex_unlock(&priv->mac_lock);
184		return err;
185	}
186
187	mutex_unlock(&priv->mac_lock);
188
189	if (pause->autoneg)
190		return -EOPNOTSUPP;
191
192	cfg.rate = priv->link_state.rate;
193	cfg.options = priv->link_state.options;
194	if (pause->rx_pause)
195		cfg.options |= DPNI_LINK_OPT_PAUSE;
196	else
197		cfg.options &= ~DPNI_LINK_OPT_PAUSE;
198	if (!!pause->rx_pause ^ !!pause->tx_pause)
199		cfg.options |= DPNI_LINK_OPT_ASYM_PAUSE;
200	else
201		cfg.options &= ~DPNI_LINK_OPT_ASYM_PAUSE;
202
203	if (cfg.options == priv->link_state.options)
204		return 0;
205
206	err = dpni_set_link_cfg(priv->mc_io, 0, priv->mc_token, &cfg);
207	if (err) {
208		netdev_err(net_dev, "dpni_set_link_state failed\n");
209		return err;
210	}
211
212	priv->link_state.options = cfg.options;
213
214	return 0;
215}
216
217static void dpaa2_eth_get_strings(struct net_device *netdev, u32 stringset,
218				  u8 *data)
219{
220	u8 *p = data;
221	int i;
222
223	switch (stringset) {
224	case ETH_SS_STATS:
225		for (i = 0; i < DPAA2_ETH_NUM_STATS; i++) {
226			strscpy(p, dpaa2_ethtool_stats[i], ETH_GSTRING_LEN);
227			p += ETH_GSTRING_LEN;
228		}
229		for (i = 0; i < DPAA2_ETH_NUM_EXTRA_STATS; i++) {
230			strscpy(p, dpaa2_ethtool_extras[i], ETH_GSTRING_LEN);
231			p += ETH_GSTRING_LEN;
232		}
233		dpaa2_mac_get_strings(p);
234		break;
235	}
236}
237
238static int dpaa2_eth_get_sset_count(struct net_device *net_dev, int sset)
239{
240	switch (sset) {
241	case ETH_SS_STATS: /* ethtool_get_stats(), ethtool_get_drvinfo() */
242		return DPAA2_ETH_NUM_STATS + DPAA2_ETH_NUM_EXTRA_STATS +
243		       dpaa2_mac_get_sset_count();
244	default:
245		return -EOPNOTSUPP;
246	}
247}
248
249/** Fill in hardware counters, as returned by MC.
250 */
251static void dpaa2_eth_get_ethtool_stats(struct net_device *net_dev,
252					struct ethtool_stats *stats,
253					u64 *data)
254{
255	struct dpaa2_eth_priv *priv = netdev_priv(net_dev);
256	union dpni_statistics dpni_stats;
257	int dpni_stats_page_size[DPNI_STATISTICS_CNT] = {
258		sizeof(dpni_stats.page_0),
259		sizeof(dpni_stats.page_1),
260		sizeof(dpni_stats.page_2),
261		sizeof(dpni_stats.page_3),
262		sizeof(dpni_stats.page_4),
263		sizeof(dpni_stats.page_5),
264		sizeof(dpni_stats.page_6),
265	};
266	u32 fcnt_rx_total = 0, fcnt_tx_total = 0;
267	u32 bcnt_rx_total = 0, bcnt_tx_total = 0;
268	struct dpaa2_eth_ch_stats *ch_stats;
269	struct dpaa2_eth_drv_stats *extras;
270	u32 buf_cnt, buf_cnt_total = 0;
271	int j, k, err, num_cnt, i = 0;
272	u32 fcnt, bcnt;
273
274	memset(data, 0,
275	       sizeof(u64) * (DPAA2_ETH_NUM_STATS + DPAA2_ETH_NUM_EXTRA_STATS));
276
277	/* Print standard counters, from DPNI statistics */
278	for (j = 0; j <= 6; j++) {
279		/* We're not interested in pages 4 & 5 for now */
280		if (j == 4 || j == 5)
281			continue;
282		err = dpni_get_statistics(priv->mc_io, 0, priv->mc_token,
283					  j, &dpni_stats);
284		if (err == -EINVAL)
285			/* Older firmware versions don't support all pages */
286			memset(&dpni_stats, 0, sizeof(dpni_stats));
287		else if (err)
288			netdev_warn(net_dev, "dpni_get_stats(%d) failed\n", j);
289
290		num_cnt = dpni_stats_page_size[j] / sizeof(u64);
291		for (k = 0; k < num_cnt; k++)
292			*(data + i++) = dpni_stats.raw.counter[k];
293	}
294
295	/* Print per-cpu extra stats */
296	for_each_online_cpu(k) {
297		extras = per_cpu_ptr(priv->percpu_extras, k);
298		for (j = 0; j < sizeof(*extras) / sizeof(__u64); j++)
299			*((__u64 *)data + i + j) += *((__u64 *)extras + j);
300	}
301	i += j;
302
303	/* Per-channel stats */
304	for (k = 0; k < priv->num_channels; k++) {
305		ch_stats = &priv->channel[k]->stats;
306		for (j = 0; j < DPAA2_ETH_CH_STATS; j++)
307			*((__u64 *)data + i + j) += *((__u64 *)ch_stats + j);
308	}
309	i += j;
310
311	for (j = 0; j < priv->num_fqs; j++) {
312		/* Print FQ instantaneous counts */
313		err = dpaa2_io_query_fq_count(NULL, priv->fq[j].fqid,
314					      &fcnt, &bcnt);
315		if (err) {
316			netdev_warn(net_dev, "FQ query error %d", err);
317			return;
318		}
319
320		if (priv->fq[j].type == DPAA2_TX_CONF_FQ) {
321			fcnt_tx_total += fcnt;
322			bcnt_tx_total += bcnt;
323		} else {
324			fcnt_rx_total += fcnt;
325			bcnt_rx_total += bcnt;
326		}
327	}
328
329	*(data + i++) = fcnt_rx_total;
330	*(data + i++) = bcnt_rx_total;
331	*(data + i++) = fcnt_tx_total;
332	*(data + i++) = bcnt_tx_total;
333
334	for (j = 0; j < priv->num_bps; j++) {
335		err = dpaa2_io_query_bp_count(NULL, priv->bp[j]->bpid, &buf_cnt);
336		if (err) {
337			netdev_warn(net_dev, "Buffer count query error %d\n", err);
338			return;
339		}
340		buf_cnt_total += buf_cnt;
341	}
342	*(data + i++) = buf_cnt_total;
343
344	mutex_lock(&priv->mac_lock);
345
346	if (dpaa2_eth_has_mac(priv))
347		dpaa2_mac_get_ethtool_stats(priv->mac, data + i);
348
349	mutex_unlock(&priv->mac_lock);
350}
351
352static int dpaa2_eth_prep_eth_rule(struct ethhdr *eth_value, struct ethhdr *eth_mask,
353				   void *key, void *mask, u64 *fields)
354{
355	int off;
356
357	if (eth_mask->h_proto) {
358		off = dpaa2_eth_cls_fld_off(NET_PROT_ETH, NH_FLD_ETH_TYPE);
359		*(__be16 *)(key + off) = eth_value->h_proto;
360		*(__be16 *)(mask + off) = eth_mask->h_proto;
361		*fields |= DPAA2_ETH_DIST_ETHTYPE;
362	}
363
364	if (!is_zero_ether_addr(eth_mask->h_source)) {
365		off = dpaa2_eth_cls_fld_off(NET_PROT_ETH, NH_FLD_ETH_SA);
366		ether_addr_copy(key + off, eth_value->h_source);
367		ether_addr_copy(mask + off, eth_mask->h_source);
368		*fields |= DPAA2_ETH_DIST_ETHSRC;
369	}
370
371	if (!is_zero_ether_addr(eth_mask->h_dest)) {
372		off = dpaa2_eth_cls_fld_off(NET_PROT_ETH, NH_FLD_ETH_DA);
373		ether_addr_copy(key + off, eth_value->h_dest);
374		ether_addr_copy(mask + off, eth_mask->h_dest);
375		*fields |= DPAA2_ETH_DIST_ETHDST;
376	}
377
378	return 0;
379}
380
381static int dpaa2_eth_prep_uip_rule(struct ethtool_usrip4_spec *uip_value,
382				   struct ethtool_usrip4_spec *uip_mask,
383				   void *key, void *mask, u64 *fields)
384{
385	int off;
386	u32 tmp_value, tmp_mask;
387
388	if (uip_mask->tos || uip_mask->ip_ver)
389		return -EOPNOTSUPP;
390
391	if (uip_mask->ip4src) {
392		off = dpaa2_eth_cls_fld_off(NET_PROT_IP, NH_FLD_IP_SRC);
393		*(__be32 *)(key + off) = uip_value->ip4src;
394		*(__be32 *)(mask + off) = uip_mask->ip4src;
395		*fields |= DPAA2_ETH_DIST_IPSRC;
396	}
397
398	if (uip_mask->ip4dst) {
399		off = dpaa2_eth_cls_fld_off(NET_PROT_IP, NH_FLD_IP_DST);
400		*(__be32 *)(key + off) = uip_value->ip4dst;
401		*(__be32 *)(mask + off) = uip_mask->ip4dst;
402		*fields |= DPAA2_ETH_DIST_IPDST;
403	}
404
405	if (uip_mask->proto) {
406		off = dpaa2_eth_cls_fld_off(NET_PROT_IP, NH_FLD_IP_PROTO);
407		*(u8 *)(key + off) = uip_value->proto;
408		*(u8 *)(mask + off) = uip_mask->proto;
409		*fields |= DPAA2_ETH_DIST_IPPROTO;
410	}
411
412	if (uip_mask->l4_4_bytes) {
413		tmp_value = be32_to_cpu(uip_value->l4_4_bytes);
414		tmp_mask = be32_to_cpu(uip_mask->l4_4_bytes);
415
416		off = dpaa2_eth_cls_fld_off(NET_PROT_UDP, NH_FLD_UDP_PORT_SRC);
417		*(__be16 *)(key + off) = htons(tmp_value >> 16);
418		*(__be16 *)(mask + off) = htons(tmp_mask >> 16);
419		*fields |= DPAA2_ETH_DIST_L4SRC;
420
421		off = dpaa2_eth_cls_fld_off(NET_PROT_UDP, NH_FLD_UDP_PORT_DST);
422		*(__be16 *)(key + off) = htons(tmp_value & 0xFFFF);
423		*(__be16 *)(mask + off) = htons(tmp_mask & 0xFFFF);
424		*fields |= DPAA2_ETH_DIST_L4DST;
425	}
426
427	/* Only apply the rule for IPv4 frames */
428	off = dpaa2_eth_cls_fld_off(NET_PROT_ETH, NH_FLD_ETH_TYPE);
429	*(__be16 *)(key + off) = htons(ETH_P_IP);
430	*(__be16 *)(mask + off) = htons(0xFFFF);
431	*fields |= DPAA2_ETH_DIST_ETHTYPE;
432
433	return 0;
434}
435
436static int dpaa2_eth_prep_l4_rule(struct ethtool_tcpip4_spec *l4_value,
437				  struct ethtool_tcpip4_spec *l4_mask,
438				  void *key, void *mask, u8 l4_proto, u64 *fields)
439{
440	int off;
441
442	if (l4_mask->tos)
443		return -EOPNOTSUPP;
444
445	if (l4_mask->ip4src) {
446		off = dpaa2_eth_cls_fld_off(NET_PROT_IP, NH_FLD_IP_SRC);
447		*(__be32 *)(key + off) = l4_value->ip4src;
448		*(__be32 *)(mask + off) = l4_mask->ip4src;
449		*fields |= DPAA2_ETH_DIST_IPSRC;
450	}
451
452	if (l4_mask->ip4dst) {
453		off = dpaa2_eth_cls_fld_off(NET_PROT_IP, NH_FLD_IP_DST);
454		*(__be32 *)(key + off) = l4_value->ip4dst;
455		*(__be32 *)(mask + off) = l4_mask->ip4dst;
456		*fields |= DPAA2_ETH_DIST_IPDST;
457	}
458
459	if (l4_mask->psrc) {
460		off = dpaa2_eth_cls_fld_off(NET_PROT_UDP, NH_FLD_UDP_PORT_SRC);
461		*(__be16 *)(key + off) = l4_value->psrc;
462		*(__be16 *)(mask + off) = l4_mask->psrc;
463		*fields |= DPAA2_ETH_DIST_L4SRC;
464	}
465
466	if (l4_mask->pdst) {
467		off = dpaa2_eth_cls_fld_off(NET_PROT_UDP, NH_FLD_UDP_PORT_DST);
468		*(__be16 *)(key + off) = l4_value->pdst;
469		*(__be16 *)(mask + off) = l4_mask->pdst;
470		*fields |= DPAA2_ETH_DIST_L4DST;
471	}
472
473	/* Only apply the rule for IPv4 frames with the specified L4 proto */
474	off = dpaa2_eth_cls_fld_off(NET_PROT_ETH, NH_FLD_ETH_TYPE);
475	*(__be16 *)(key + off) = htons(ETH_P_IP);
476	*(__be16 *)(mask + off) = htons(0xFFFF);
477	*fields |= DPAA2_ETH_DIST_ETHTYPE;
478
479	off = dpaa2_eth_cls_fld_off(NET_PROT_IP, NH_FLD_IP_PROTO);
480	*(u8 *)(key + off) = l4_proto;
481	*(u8 *)(mask + off) = 0xFF;
482	*fields |= DPAA2_ETH_DIST_IPPROTO;
483
484	return 0;
485}
486
487static int dpaa2_eth_prep_ext_rule(struct ethtool_flow_ext *ext_value,
488				   struct ethtool_flow_ext *ext_mask,
489				   void *key, void *mask, u64 *fields)
490{
491	int off;
492
493	if (ext_mask->vlan_etype)
494		return -EOPNOTSUPP;
495
496	if (ext_mask->vlan_tci) {
497		off = dpaa2_eth_cls_fld_off(NET_PROT_VLAN, NH_FLD_VLAN_TCI);
498		*(__be16 *)(key + off) = ext_value->vlan_tci;
499		*(__be16 *)(mask + off) = ext_mask->vlan_tci;
500		*fields |= DPAA2_ETH_DIST_VLAN;
501	}
502
503	return 0;
504}
505
506static int dpaa2_eth_prep_mac_ext_rule(struct ethtool_flow_ext *ext_value,
507				       struct ethtool_flow_ext *ext_mask,
508				       void *key, void *mask, u64 *fields)
509{
510	int off;
511
512	if (!is_zero_ether_addr(ext_mask->h_dest)) {
513		off = dpaa2_eth_cls_fld_off(NET_PROT_ETH, NH_FLD_ETH_DA);
514		ether_addr_copy(key + off, ext_value->h_dest);
515		ether_addr_copy(mask + off, ext_mask->h_dest);
516		*fields |= DPAA2_ETH_DIST_ETHDST;
517	}
518
519	return 0;
520}
521
522static int dpaa2_eth_prep_cls_rule(struct ethtool_rx_flow_spec *fs, void *key,
523				   void *mask, u64 *fields)
524{
525	int err;
526
527	switch (fs->flow_type & 0xFF) {
528	case ETHER_FLOW:
529		err = dpaa2_eth_prep_eth_rule(&fs->h_u.ether_spec, &fs->m_u.ether_spec,
530					      key, mask, fields);
531		break;
532	case IP_USER_FLOW:
533		err = dpaa2_eth_prep_uip_rule(&fs->h_u.usr_ip4_spec,
534					      &fs->m_u.usr_ip4_spec, key, mask, fields);
535		break;
536	case TCP_V4_FLOW:
537		err = dpaa2_eth_prep_l4_rule(&fs->h_u.tcp_ip4_spec, &fs->m_u.tcp_ip4_spec,
538					     key, mask, IPPROTO_TCP, fields);
539		break;
540	case UDP_V4_FLOW:
541		err = dpaa2_eth_prep_l4_rule(&fs->h_u.udp_ip4_spec, &fs->m_u.udp_ip4_spec,
542					     key, mask, IPPROTO_UDP, fields);
543		break;
544	case SCTP_V4_FLOW:
545		err = dpaa2_eth_prep_l4_rule(&fs->h_u.sctp_ip4_spec,
546					     &fs->m_u.sctp_ip4_spec, key, mask,
547					     IPPROTO_SCTP, fields);
548		break;
549	default:
550		return -EOPNOTSUPP;
551	}
552
553	if (err)
554		return err;
555
556	if (fs->flow_type & FLOW_EXT) {
557		err = dpaa2_eth_prep_ext_rule(&fs->h_ext, &fs->m_ext, key, mask, fields);
558		if (err)
559			return err;
560	}
561
562	if (fs->flow_type & FLOW_MAC_EXT) {
563		err = dpaa2_eth_prep_mac_ext_rule(&fs->h_ext, &fs->m_ext, key,
564						  mask, fields);
565		if (err)
566			return err;
567	}
568
569	return 0;
570}
571
572static int dpaa2_eth_do_cls_rule(struct net_device *net_dev,
573				 struct ethtool_rx_flow_spec *fs,
574				 bool add)
575{
576	struct dpaa2_eth_priv *priv = netdev_priv(net_dev);
577	struct device *dev = net_dev->dev.parent;
578	struct dpni_rule_cfg rule_cfg = { 0 };
579	struct dpni_fs_action_cfg fs_act = { 0 };
580	dma_addr_t key_iova;
581	u64 fields = 0;
582	void *key_buf;
583	int i, err;
584
585	if (fs->ring_cookie != RX_CLS_FLOW_DISC &&
586	    fs->ring_cookie >= dpaa2_eth_queue_count(priv))
587		return -EINVAL;
588
589	rule_cfg.key_size = dpaa2_eth_cls_key_size(DPAA2_ETH_DIST_ALL);
590
591	/* allocate twice the key size, for the actual key and for mask */
592	key_buf = kzalloc(rule_cfg.key_size * 2, GFP_KERNEL);
593	if (!key_buf)
594		return -ENOMEM;
595
596	/* Fill the key and mask memory areas */
597	err = dpaa2_eth_prep_cls_rule(fs, key_buf, key_buf + rule_cfg.key_size, &fields);
598	if (err)
599		goto free_mem;
600
601	if (!dpaa2_eth_fs_mask_enabled(priv)) {
602		/* Masking allows us to configure a maximal key during init and
603		 * use it for all flow steering rules. Without it, we include
604		 * in the key only the fields actually used, so we need to
605		 * extract the others from the final key buffer.
606		 *
607		 * Program the FS key if needed, or return error if previously
608		 * set key can't be used for the current rule. User needs to
609		 * delete existing rules in this case to allow for the new one.
610		 */
611		if (!priv->rx_cls_fields) {
612			err = dpaa2_eth_set_cls(net_dev, fields);
613			if (err)
614				goto free_mem;
615
616			priv->rx_cls_fields = fields;
617		} else if (priv->rx_cls_fields != fields) {
618			netdev_err(net_dev, "No support for multiple FS keys, need to delete existing rules\n");
619			err = -EOPNOTSUPP;
620			goto free_mem;
621		}
622
623		dpaa2_eth_cls_trim_rule(key_buf, fields);
624		rule_cfg.key_size = dpaa2_eth_cls_key_size(fields);
625	}
626
627	key_iova = dma_map_single(dev, key_buf, rule_cfg.key_size * 2,
628				  DMA_TO_DEVICE);
629	if (dma_mapping_error(dev, key_iova)) {
630		err = -ENOMEM;
631		goto free_mem;
632	}
633
634	rule_cfg.key_iova = key_iova;
635	if (dpaa2_eth_fs_mask_enabled(priv))
636		rule_cfg.mask_iova = key_iova + rule_cfg.key_size;
637
638	if (add) {
639		if (fs->ring_cookie == RX_CLS_FLOW_DISC)
640			fs_act.options |= DPNI_FS_OPT_DISCARD;
641		else
642			fs_act.flow_id = fs->ring_cookie;
643	}
644	for (i = 0; i < dpaa2_eth_tc_count(priv); i++) {
645		if (add)
646			err = dpni_add_fs_entry(priv->mc_io, 0, priv->mc_token,
647						i, fs->location, &rule_cfg,
648						&fs_act);
649		else
650			err = dpni_remove_fs_entry(priv->mc_io, 0,
651						   priv->mc_token, i,
652						   &rule_cfg);
653		if (err || priv->dpni_attrs.options & DPNI_OPT_SHARED_FS)
654			break;
655	}
656
657	dma_unmap_single(dev, key_iova, rule_cfg.key_size * 2, DMA_TO_DEVICE);
658
659free_mem:
660	kfree(key_buf);
661
662	return err;
663}
664
665static int dpaa2_eth_num_cls_rules(struct dpaa2_eth_priv *priv)
666{
667	int i, rules = 0;
668
669	for (i = 0; i < dpaa2_eth_fs_count(priv); i++)
670		if (priv->cls_rules[i].in_use)
671			rules++;
672
673	return rules;
674}
675
676static int dpaa2_eth_update_cls_rule(struct net_device *net_dev,
677				     struct ethtool_rx_flow_spec *new_fs,
678				     unsigned int location)
679{
680	struct dpaa2_eth_priv *priv = netdev_priv(net_dev);
681	struct dpaa2_eth_cls_rule *rule;
682	int err = -EINVAL;
683
684	if (!priv->rx_cls_enabled)
685		return -EOPNOTSUPP;
686
687	if (location >= dpaa2_eth_fs_count(priv))
688		return -EINVAL;
689
690	rule = &priv->cls_rules[location];
691
692	/* If a rule is present at the specified location, delete it. */
693	if (rule->in_use) {
694		err = dpaa2_eth_do_cls_rule(net_dev, &rule->fs, false);
695		if (err)
696			return err;
697
698		rule->in_use = 0;
699
700		if (!dpaa2_eth_fs_mask_enabled(priv) &&
701		    !dpaa2_eth_num_cls_rules(priv))
702			priv->rx_cls_fields = 0;
703	}
704
705	/* If no new entry to add, return here */
706	if (!new_fs)
707		return err;
708
709	err = dpaa2_eth_do_cls_rule(net_dev, new_fs, true);
710	if (err)
711		return err;
712
713	rule->in_use = 1;
714	rule->fs = *new_fs;
715
716	return 0;
717}
718
719static int dpaa2_eth_get_rxnfc(struct net_device *net_dev,
720			       struct ethtool_rxnfc *rxnfc, u32 *rule_locs)
721{
722	struct dpaa2_eth_priv *priv = netdev_priv(net_dev);
723	int max_rules = dpaa2_eth_fs_count(priv);
724	int i, j = 0;
725
726	switch (rxnfc->cmd) {
727	case ETHTOOL_GRXFH:
728		/* we purposely ignore cmd->flow_type for now, because the
729		 * classifier only supports a single set of fields for all
730		 * protocols
731		 */
732		rxnfc->data = priv->rx_hash_fields;
733		break;
734	case ETHTOOL_GRXRINGS:
735		rxnfc->data = dpaa2_eth_queue_count(priv);
736		break;
737	case ETHTOOL_GRXCLSRLCNT:
738		rxnfc->rule_cnt = 0;
739		rxnfc->rule_cnt = dpaa2_eth_num_cls_rules(priv);
740		rxnfc->data = max_rules;
741		break;
742	case ETHTOOL_GRXCLSRULE:
743		if (rxnfc->fs.location >= max_rules)
744			return -EINVAL;
745		rxnfc->fs.location = array_index_nospec(rxnfc->fs.location,
746							max_rules);
747		if (!priv->cls_rules[rxnfc->fs.location].in_use)
748			return -EINVAL;
749		rxnfc->fs = priv->cls_rules[rxnfc->fs.location].fs;
750		break;
751	case ETHTOOL_GRXCLSRLALL:
752		for (i = 0; i < max_rules; i++) {
753			if (!priv->cls_rules[i].in_use)
754				continue;
755			if (j == rxnfc->rule_cnt)
756				return -EMSGSIZE;
757			rule_locs[j++] = i;
758		}
759		rxnfc->rule_cnt = j;
760		rxnfc->data = max_rules;
761		break;
762	default:
763		return -EOPNOTSUPP;
764	}
765
766	return 0;
767}
768
769static int dpaa2_eth_set_rxnfc(struct net_device *net_dev,
770			       struct ethtool_rxnfc *rxnfc)
771{
772	int err = 0;
773
774	switch (rxnfc->cmd) {
775	case ETHTOOL_SRXFH:
776		if ((rxnfc->data & DPAA2_RXH_SUPPORTED) != rxnfc->data)
777			return -EOPNOTSUPP;
778		err = dpaa2_eth_set_hash(net_dev, rxnfc->data);
779		break;
780	case ETHTOOL_SRXCLSRLINS:
781		err = dpaa2_eth_update_cls_rule(net_dev, &rxnfc->fs, rxnfc->fs.location);
782		break;
783	case ETHTOOL_SRXCLSRLDEL:
784		err = dpaa2_eth_update_cls_rule(net_dev, NULL, rxnfc->fs.location);
785		break;
786	default:
787		err = -EOPNOTSUPP;
788	}
789
790	return err;
791}
792
793int dpaa2_phc_index = -1;
794EXPORT_SYMBOL(dpaa2_phc_index);
795
796static int dpaa2_eth_get_ts_info(struct net_device *dev,
797				 struct ethtool_ts_info *info)
798{
799	if (!dpaa2_ptp)
800		return ethtool_op_get_ts_info(dev, info);
801
802	info->so_timestamping = SOF_TIMESTAMPING_TX_HARDWARE |
803				SOF_TIMESTAMPING_RX_HARDWARE |
804				SOF_TIMESTAMPING_RAW_HARDWARE;
805
806	info->phc_index = dpaa2_phc_index;
807
808	info->tx_types = (1 << HWTSTAMP_TX_OFF) |
809			 (1 << HWTSTAMP_TX_ON) |
810			 (1 << HWTSTAMP_TX_ONESTEP_SYNC);
811
812	info->rx_filters = (1 << HWTSTAMP_FILTER_NONE) |
813			   (1 << HWTSTAMP_FILTER_ALL);
814	return 0;
815}
816
817static int dpaa2_eth_get_tunable(struct net_device *net_dev,
818				 const struct ethtool_tunable *tuna,
819				 void *data)
820{
821	struct dpaa2_eth_priv *priv = netdev_priv(net_dev);
822	int err = 0;
823
824	switch (tuna->id) {
825	case ETHTOOL_RX_COPYBREAK:
826		*(u32 *)data = priv->rx_copybreak;
827		break;
828	default:
829		err = -EOPNOTSUPP;
830		break;
831	}
832
833	return err;
834}
835
836static int dpaa2_eth_set_tunable(struct net_device *net_dev,
837				 const struct ethtool_tunable *tuna,
838				 const void *data)
839{
840	struct dpaa2_eth_priv *priv = netdev_priv(net_dev);
841	int err = 0;
842
843	switch (tuna->id) {
844	case ETHTOOL_RX_COPYBREAK:
845		priv->rx_copybreak = *(u32 *)data;
846		break;
847	default:
848		err = -EOPNOTSUPP;
849		break;
850	}
851
852	return err;
853}
854
855static int dpaa2_eth_get_coalesce(struct net_device *dev,
856				  struct ethtool_coalesce *ic,
857				  struct kernel_ethtool_coalesce *kernel_coal,
858				  struct netlink_ext_ack *extack)
859{
860	struct dpaa2_eth_priv *priv = netdev_priv(dev);
861	struct dpaa2_io *dpio = priv->channel[0]->dpio;
862
863	dpaa2_io_get_irq_coalescing(dpio, &ic->rx_coalesce_usecs);
864	ic->use_adaptive_rx_coalesce = dpaa2_io_get_adaptive_coalescing(dpio);
865
866	return 0;
867}
868
869static int dpaa2_eth_set_coalesce(struct net_device *dev,
870				  struct ethtool_coalesce *ic,
871				  struct kernel_ethtool_coalesce *kernel_coal,
872				  struct netlink_ext_ack *extack)
873{
874	struct dpaa2_eth_priv *priv = netdev_priv(dev);
875	struct dpaa2_io *dpio;
876	int prev_adaptive;
877	u32 prev_rx_usecs;
878	int i, j, err;
879
880	/* Keep track of the previous value, just in case we fail */
881	dpio = priv->channel[0]->dpio;
882	dpaa2_io_get_irq_coalescing(dpio, &prev_rx_usecs);
883	prev_adaptive = dpaa2_io_get_adaptive_coalescing(dpio);
884
885	/* Setup new value for rx coalescing */
886	for (i = 0; i < priv->num_channels; i++) {
887		dpio = priv->channel[i]->dpio;
888
889		dpaa2_io_set_adaptive_coalescing(dpio,
890						 ic->use_adaptive_rx_coalesce);
891		err = dpaa2_io_set_irq_coalescing(dpio, ic->rx_coalesce_usecs);
892		if (err)
893			goto restore_rx_usecs;
894	}
895
896	return 0;
897
898restore_rx_usecs:
899	for (j = 0; j < i; j++) {
900		dpio = priv->channel[j]->dpio;
901
902		dpaa2_io_set_irq_coalescing(dpio, prev_rx_usecs);
903		dpaa2_io_set_adaptive_coalescing(dpio, prev_adaptive);
904	}
905
906	return err;
907}
908
909static void dpaa2_eth_get_channels(struct net_device *net_dev,
910				   struct ethtool_channels *channels)
911{
912	struct dpaa2_eth_priv *priv = netdev_priv(net_dev);
913	int queue_count = dpaa2_eth_queue_count(priv);
914
915	channels->max_rx = queue_count;
916	channels->max_tx = queue_count;
917	channels->rx_count = queue_count;
918	channels->tx_count = queue_count;
919
920	/* Tx confirmation and Rx error */
921	channels->max_other = queue_count + 1;
922	channels->max_combined = channels->max_rx +
923				 channels->max_tx +
924				 channels->max_other;
925	/* Tx conf and Rx err */
926	channels->other_count = queue_count + 1;
927	channels->combined_count = channels->rx_count +
928				   channels->tx_count +
929				   channels->other_count;
930}
931
932const struct ethtool_ops dpaa2_ethtool_ops = {
933	.supported_coalesce_params = ETHTOOL_COALESCE_RX_USECS |
934				     ETHTOOL_COALESCE_USE_ADAPTIVE_RX,
935	.get_drvinfo = dpaa2_eth_get_drvinfo,
936	.nway_reset = dpaa2_eth_nway_reset,
937	.get_link = ethtool_op_get_link,
938	.get_link_ksettings = dpaa2_eth_get_link_ksettings,
939	.set_link_ksettings = dpaa2_eth_set_link_ksettings,
940	.get_pauseparam = dpaa2_eth_get_pauseparam,
941	.set_pauseparam = dpaa2_eth_set_pauseparam,
942	.get_sset_count = dpaa2_eth_get_sset_count,
943	.get_ethtool_stats = dpaa2_eth_get_ethtool_stats,
944	.get_strings = dpaa2_eth_get_strings,
945	.get_rxnfc = dpaa2_eth_get_rxnfc,
946	.set_rxnfc = dpaa2_eth_set_rxnfc,
947	.get_ts_info = dpaa2_eth_get_ts_info,
948	.get_tunable = dpaa2_eth_get_tunable,
949	.set_tunable = dpaa2_eth_set_tunable,
950	.get_coalesce = dpaa2_eth_get_coalesce,
951	.set_coalesce = dpaa2_eth_set_coalesce,
952	.get_channels = dpaa2_eth_get_channels,
953};
954