Merge git://git.kernel.org/pub/scm/linux/kernel/git/davem/net
[platform/kernel/linux-starfive.git] / drivers / net / ethernet / netronome / nfp / flower / offload.c
1 // SPDX-License-Identifier: (GPL-2.0-only OR BSD-2-Clause)
2 /* Copyright (C) 2017-2018 Netronome Systems, Inc. */
3
4 #include <linux/skbuff.h>
5 #include <net/devlink.h>
6 #include <net/pkt_cls.h>
7
8 #include "cmsg.h"
9 #include "main.h"
10 #include "../nfpcore/nfp_cpp.h"
11 #include "../nfpcore/nfp_nsp.h"
12 #include "../nfp_app.h"
13 #include "../nfp_main.h"
14 #include "../nfp_net.h"
15 #include "../nfp_port.h"
16
17 #define NFP_FLOWER_SUPPORTED_TCPFLAGS \
18         (TCPHDR_FIN | TCPHDR_SYN | TCPHDR_RST | \
19          TCPHDR_PSH | TCPHDR_URG)
20
21 #define NFP_FLOWER_SUPPORTED_CTLFLAGS \
22         (FLOW_DIS_IS_FRAGMENT | \
23          FLOW_DIS_FIRST_FRAG)
24
25 #define NFP_FLOWER_WHITELIST_DISSECTOR \
26         (BIT(FLOW_DISSECTOR_KEY_CONTROL) | \
27          BIT(FLOW_DISSECTOR_KEY_BASIC) | \
28          BIT(FLOW_DISSECTOR_KEY_IPV4_ADDRS) | \
29          BIT(FLOW_DISSECTOR_KEY_IPV6_ADDRS) | \
30          BIT(FLOW_DISSECTOR_KEY_TCP) | \
31          BIT(FLOW_DISSECTOR_KEY_PORTS) | \
32          BIT(FLOW_DISSECTOR_KEY_ETH_ADDRS) | \
33          BIT(FLOW_DISSECTOR_KEY_VLAN) | \
34          BIT(FLOW_DISSECTOR_KEY_ENC_KEYID) | \
35          BIT(FLOW_DISSECTOR_KEY_ENC_IPV4_ADDRS) | \
36          BIT(FLOW_DISSECTOR_KEY_ENC_IPV6_ADDRS) | \
37          BIT(FLOW_DISSECTOR_KEY_ENC_CONTROL) | \
38          BIT(FLOW_DISSECTOR_KEY_ENC_PORTS) | \
39          BIT(FLOW_DISSECTOR_KEY_ENC_OPTS) | \
40          BIT(FLOW_DISSECTOR_KEY_ENC_IP) | \
41          BIT(FLOW_DISSECTOR_KEY_MPLS) | \
42          BIT(FLOW_DISSECTOR_KEY_IP))
43
44 #define NFP_FLOWER_WHITELIST_TUN_DISSECTOR \
45         (BIT(FLOW_DISSECTOR_KEY_ENC_CONTROL) | \
46          BIT(FLOW_DISSECTOR_KEY_ENC_KEYID) | \
47          BIT(FLOW_DISSECTOR_KEY_ENC_IPV4_ADDRS) | \
48          BIT(FLOW_DISSECTOR_KEY_ENC_IPV6_ADDRS) | \
49          BIT(FLOW_DISSECTOR_KEY_ENC_OPTS) | \
50          BIT(FLOW_DISSECTOR_KEY_ENC_PORTS) | \
51          BIT(FLOW_DISSECTOR_KEY_ENC_IP))
52
53 #define NFP_FLOWER_WHITELIST_TUN_DISSECTOR_R \
54         (BIT(FLOW_DISSECTOR_KEY_ENC_CONTROL) | \
55          BIT(FLOW_DISSECTOR_KEY_ENC_IPV4_ADDRS) | \
56          BIT(FLOW_DISSECTOR_KEY_ENC_PORTS))
57
58 static int
59 nfp_flower_xmit_flow(struct nfp_app *app, struct nfp_fl_payload *nfp_flow,
60                      u8 mtype)
61 {
62         u32 meta_len, key_len, mask_len, act_len, tot_len;
63         struct sk_buff *skb;
64         unsigned char *msg;
65
66         meta_len =  sizeof(struct nfp_fl_rule_metadata);
67         key_len = nfp_flow->meta.key_len;
68         mask_len = nfp_flow->meta.mask_len;
69         act_len = nfp_flow->meta.act_len;
70
71         tot_len = meta_len + key_len + mask_len + act_len;
72
73         /* Convert to long words as firmware expects
74          * lengths in units of NFP_FL_LW_SIZ.
75          */
76         nfp_flow->meta.key_len >>= NFP_FL_LW_SIZ;
77         nfp_flow->meta.mask_len >>= NFP_FL_LW_SIZ;
78         nfp_flow->meta.act_len >>= NFP_FL_LW_SIZ;
79
80         skb = nfp_flower_cmsg_alloc(app, tot_len, mtype, GFP_KERNEL);
81         if (!skb)
82                 return -ENOMEM;
83
84         msg = nfp_flower_cmsg_get_data(skb);
85         memcpy(msg, &nfp_flow->meta, meta_len);
86         memcpy(&msg[meta_len], nfp_flow->unmasked_data, key_len);
87         memcpy(&msg[meta_len + key_len], nfp_flow->mask_data, mask_len);
88         memcpy(&msg[meta_len + key_len + mask_len],
89                nfp_flow->action_data, act_len);
90
91         /* Convert back to bytes as software expects
92          * lengths in units of bytes.
93          */
94         nfp_flow->meta.key_len <<= NFP_FL_LW_SIZ;
95         nfp_flow->meta.mask_len <<= NFP_FL_LW_SIZ;
96         nfp_flow->meta.act_len <<= NFP_FL_LW_SIZ;
97
98         nfp_ctrl_tx(app->ctrl, skb);
99
100         return 0;
101 }
102
103 static bool nfp_flower_check_higher_than_mac(struct tc_cls_flower_offload *f)
104 {
105         return dissector_uses_key(f->dissector,
106                                   FLOW_DISSECTOR_KEY_IPV4_ADDRS) ||
107                 dissector_uses_key(f->dissector,
108                                    FLOW_DISSECTOR_KEY_IPV6_ADDRS) ||
109                 dissector_uses_key(f->dissector,
110                                    FLOW_DISSECTOR_KEY_PORTS) ||
111                 dissector_uses_key(f->dissector, FLOW_DISSECTOR_KEY_ICMP);
112 }
113
114 static int
115 nfp_flower_calc_opt_layer(struct flow_dissector_key_enc_opts *enc_opts,
116                           u32 *key_layer_two, int *key_size)
117 {
118         if (enc_opts->len > NFP_FL_MAX_GENEVE_OPT_KEY)
119                 return -EOPNOTSUPP;
120
121         if (enc_opts->len > 0) {
122                 *key_layer_two |= NFP_FLOWER_LAYER2_GENEVE_OP;
123                 *key_size += sizeof(struct nfp_flower_geneve_options);
124         }
125
126         return 0;
127 }
128
129 static int
130 nfp_flower_calculate_key_layers(struct nfp_app *app,
131                                 struct net_device *netdev,
132                                 struct nfp_fl_key_ls *ret_key_ls,
133                                 struct tc_cls_flower_offload *flow,
134                                 enum nfp_flower_tun_type *tun_type)
135 {
136         struct flow_dissector_key_basic *mask_basic = NULL;
137         struct flow_dissector_key_basic *key_basic = NULL;
138         struct nfp_flower_priv *priv = app->priv;
139         u32 key_layer_two;
140         u8 key_layer;
141         int key_size;
142         int err;
143
144         if (flow->dissector->used_keys & ~NFP_FLOWER_WHITELIST_DISSECTOR)
145                 return -EOPNOTSUPP;
146
147         /* If any tun dissector is used then the required set must be used. */
148         if (flow->dissector->used_keys & NFP_FLOWER_WHITELIST_TUN_DISSECTOR &&
149             (flow->dissector->used_keys & NFP_FLOWER_WHITELIST_TUN_DISSECTOR_R)
150             != NFP_FLOWER_WHITELIST_TUN_DISSECTOR_R)
151                 return -EOPNOTSUPP;
152
153         key_layer_two = 0;
154         key_layer = NFP_FLOWER_LAYER_PORT;
155         key_size = sizeof(struct nfp_flower_meta_tci) +
156                    sizeof(struct nfp_flower_in_port);
157
158         if (dissector_uses_key(flow->dissector, FLOW_DISSECTOR_KEY_ETH_ADDRS) ||
159             dissector_uses_key(flow->dissector, FLOW_DISSECTOR_KEY_MPLS)) {
160                 key_layer |= NFP_FLOWER_LAYER_MAC;
161                 key_size += sizeof(struct nfp_flower_mac_mpls);
162         }
163
164         if (dissector_uses_key(flow->dissector, FLOW_DISSECTOR_KEY_VLAN)) {
165                 struct flow_dissector_key_vlan *flow_vlan;
166
167                 flow_vlan = skb_flow_dissector_target(flow->dissector,
168                                                       FLOW_DISSECTOR_KEY_VLAN,
169                                                       flow->mask);
170                 if (!(priv->flower_ext_feats & NFP_FL_FEATS_VLAN_PCP) &&
171                     flow_vlan->vlan_priority)
172                         return -EOPNOTSUPP;
173         }
174
175         if (dissector_uses_key(flow->dissector,
176                                FLOW_DISSECTOR_KEY_ENC_CONTROL)) {
177                 struct flow_dissector_key_ipv4_addrs *mask_ipv4 = NULL;
178                 struct flow_dissector_key_ports *mask_enc_ports = NULL;
179                 struct flow_dissector_key_enc_opts *enc_op = NULL;
180                 struct flow_dissector_key_ports *enc_ports = NULL;
181                 struct flow_dissector_key_control *mask_enc_ctl =
182                         skb_flow_dissector_target(flow->dissector,
183                                                   FLOW_DISSECTOR_KEY_ENC_CONTROL,
184                                                   flow->mask);
185                 struct flow_dissector_key_control *enc_ctl =
186                         skb_flow_dissector_target(flow->dissector,
187                                                   FLOW_DISSECTOR_KEY_ENC_CONTROL,
188                                                   flow->key);
189
190                 if (mask_enc_ctl->addr_type != 0xffff ||
191                     enc_ctl->addr_type != FLOW_DISSECTOR_KEY_IPV4_ADDRS)
192                         return -EOPNOTSUPP;
193
194                 /* These fields are already verified as used. */
195                 mask_ipv4 =
196                         skb_flow_dissector_target(flow->dissector,
197                                                   FLOW_DISSECTOR_KEY_ENC_IPV4_ADDRS,
198                                                   flow->mask);
199                 if (mask_ipv4->dst != cpu_to_be32(~0))
200                         return -EOPNOTSUPP;
201
202                 mask_enc_ports =
203                         skb_flow_dissector_target(flow->dissector,
204                                                   FLOW_DISSECTOR_KEY_ENC_PORTS,
205                                                   flow->mask);
206                 enc_ports =
207                         skb_flow_dissector_target(flow->dissector,
208                                                   FLOW_DISSECTOR_KEY_ENC_PORTS,
209                                                   flow->key);
210
211                 if (mask_enc_ports->dst != cpu_to_be16(~0))
212                         return -EOPNOTSUPP;
213
214                 if (dissector_uses_key(flow->dissector,
215                                        FLOW_DISSECTOR_KEY_ENC_OPTS)) {
216                         enc_op = skb_flow_dissector_target(flow->dissector,
217                                                            FLOW_DISSECTOR_KEY_ENC_OPTS,
218                                                            flow->key);
219                 }
220
221                 switch (enc_ports->dst) {
222                 case htons(NFP_FL_VXLAN_PORT):
223                         *tun_type = NFP_FL_TUNNEL_VXLAN;
224                         key_layer |= NFP_FLOWER_LAYER_VXLAN;
225                         key_size += sizeof(struct nfp_flower_ipv4_udp_tun);
226
227                         if (enc_op)
228                                 return -EOPNOTSUPP;
229                         break;
230                 case htons(NFP_FL_GENEVE_PORT):
231                         if (!(priv->flower_ext_feats & NFP_FL_FEATS_GENEVE))
232                                 return -EOPNOTSUPP;
233                         *tun_type = NFP_FL_TUNNEL_GENEVE;
234                         key_layer |= NFP_FLOWER_LAYER_EXT_META;
235                         key_size += sizeof(struct nfp_flower_ext_meta);
236                         key_layer_two |= NFP_FLOWER_LAYER2_GENEVE;
237                         key_size += sizeof(struct nfp_flower_ipv4_udp_tun);
238
239                         if (!enc_op)
240                                 break;
241                         if (!(priv->flower_ext_feats & NFP_FL_FEATS_GENEVE_OPT))
242                                 return -EOPNOTSUPP;
243                         err = nfp_flower_calc_opt_layer(enc_op, &key_layer_two,
244                                                         &key_size);
245                         if (err)
246                                 return err;
247                         break;
248                 default:
249                         return -EOPNOTSUPP;
250                 }
251
252                 /* Ensure the ingress netdev matches the expected tun type. */
253                 if (!nfp_fl_netdev_is_tunnel_type(netdev, *tun_type))
254                         return -EOPNOTSUPP;
255         }
256
257         if (dissector_uses_key(flow->dissector, FLOW_DISSECTOR_KEY_BASIC)) {
258                 mask_basic = skb_flow_dissector_target(flow->dissector,
259                                                        FLOW_DISSECTOR_KEY_BASIC,
260                                                        flow->mask);
261
262                 key_basic = skb_flow_dissector_target(flow->dissector,
263                                                       FLOW_DISSECTOR_KEY_BASIC,
264                                                       flow->key);
265         }
266
267         if (mask_basic && mask_basic->n_proto) {
268                 /* Ethernet type is present in the key. */
269                 switch (key_basic->n_proto) {
270                 case cpu_to_be16(ETH_P_IP):
271                         key_layer |= NFP_FLOWER_LAYER_IPV4;
272                         key_size += sizeof(struct nfp_flower_ipv4);
273                         break;
274
275                 case cpu_to_be16(ETH_P_IPV6):
276                         key_layer |= NFP_FLOWER_LAYER_IPV6;
277                         key_size += sizeof(struct nfp_flower_ipv6);
278                         break;
279
280                 /* Currently we do not offload ARP
281                  * because we rely on it to get to the host.
282                  */
283                 case cpu_to_be16(ETH_P_ARP):
284                         return -EOPNOTSUPP;
285
286                 case cpu_to_be16(ETH_P_MPLS_UC):
287                 case cpu_to_be16(ETH_P_MPLS_MC):
288                         if (!(key_layer & NFP_FLOWER_LAYER_MAC)) {
289                                 key_layer |= NFP_FLOWER_LAYER_MAC;
290                                 key_size += sizeof(struct nfp_flower_mac_mpls);
291                         }
292                         break;
293
294                 /* Will be included in layer 2. */
295                 case cpu_to_be16(ETH_P_8021Q):
296                         break;
297
298                 default:
299                         /* Other ethtype - we need check the masks for the
300                          * remainder of the key to ensure we can offload.
301                          */
302                         if (nfp_flower_check_higher_than_mac(flow))
303                                 return -EOPNOTSUPP;
304                         break;
305                 }
306         }
307
308         if (mask_basic && mask_basic->ip_proto) {
309                 /* Ethernet type is present in the key. */
310                 switch (key_basic->ip_proto) {
311                 case IPPROTO_TCP:
312                 case IPPROTO_UDP:
313                 case IPPROTO_SCTP:
314                 case IPPROTO_ICMP:
315                 case IPPROTO_ICMPV6:
316                         key_layer |= NFP_FLOWER_LAYER_TP;
317                         key_size += sizeof(struct nfp_flower_tp_ports);
318                         break;
319                 default:
320                         /* Other ip proto - we need check the masks for the
321                          * remainder of the key to ensure we can offload.
322                          */
323                         return -EOPNOTSUPP;
324                 }
325         }
326
327         if (dissector_uses_key(flow->dissector, FLOW_DISSECTOR_KEY_TCP)) {
328                 struct flow_dissector_key_tcp *tcp;
329                 u32 tcp_flags;
330
331                 tcp = skb_flow_dissector_target(flow->dissector,
332                                                 FLOW_DISSECTOR_KEY_TCP,
333                                                 flow->key);
334                 tcp_flags = be16_to_cpu(tcp->flags);
335
336                 if (tcp_flags & ~NFP_FLOWER_SUPPORTED_TCPFLAGS)
337                         return -EOPNOTSUPP;
338
339                 /* We only support PSH and URG flags when either
340                  * FIN, SYN or RST is present as well.
341                  */
342                 if ((tcp_flags & (TCPHDR_PSH | TCPHDR_URG)) &&
343                     !(tcp_flags & (TCPHDR_FIN | TCPHDR_SYN | TCPHDR_RST)))
344                         return -EOPNOTSUPP;
345
346                 /* We need to store TCP flags in the IPv4 key space, thus
347                  * we need to ensure we include a IPv4 key layer if we have
348                  * not done so already.
349                  */
350                 if (!(key_layer & NFP_FLOWER_LAYER_IPV4)) {
351                         key_layer |= NFP_FLOWER_LAYER_IPV4;
352                         key_size += sizeof(struct nfp_flower_ipv4);
353                 }
354         }
355
356         if (dissector_uses_key(flow->dissector, FLOW_DISSECTOR_KEY_CONTROL)) {
357                 struct flow_dissector_key_control *key_ctl;
358
359                 key_ctl = skb_flow_dissector_target(flow->dissector,
360                                                     FLOW_DISSECTOR_KEY_CONTROL,
361                                                     flow->key);
362
363                 if (key_ctl->flags & ~NFP_FLOWER_SUPPORTED_CTLFLAGS)
364                         return -EOPNOTSUPP;
365         }
366
367         ret_key_ls->key_layer = key_layer;
368         ret_key_ls->key_layer_two = key_layer_two;
369         ret_key_ls->key_size = key_size;
370
371         return 0;
372 }
373
374 static struct nfp_fl_payload *
375 nfp_flower_allocate_new(struct nfp_fl_key_ls *key_layer)
376 {
377         struct nfp_fl_payload *flow_pay;
378
379         flow_pay = kmalloc(sizeof(*flow_pay), GFP_KERNEL);
380         if (!flow_pay)
381                 return NULL;
382
383         flow_pay->meta.key_len = key_layer->key_size;
384         flow_pay->unmasked_data = kmalloc(key_layer->key_size, GFP_KERNEL);
385         if (!flow_pay->unmasked_data)
386                 goto err_free_flow;
387
388         flow_pay->meta.mask_len = key_layer->key_size;
389         flow_pay->mask_data = kmalloc(key_layer->key_size, GFP_KERNEL);
390         if (!flow_pay->mask_data)
391                 goto err_free_unmasked;
392
393         flow_pay->action_data = kmalloc(NFP_FL_MAX_A_SIZ, GFP_KERNEL);
394         if (!flow_pay->action_data)
395                 goto err_free_mask;
396
397         flow_pay->nfp_tun_ipv4_addr = 0;
398         flow_pay->meta.flags = 0;
399
400         return flow_pay;
401
402 err_free_mask:
403         kfree(flow_pay->mask_data);
404 err_free_unmasked:
405         kfree(flow_pay->unmasked_data);
406 err_free_flow:
407         kfree(flow_pay);
408         return NULL;
409 }
410
411 /**
412  * nfp_flower_add_offload() - Adds a new flow to hardware.
413  * @app:        Pointer to the APP handle
414  * @netdev:     netdev structure.
415  * @flow:       TC flower classifier offload structure.
416  *
417  * Adds a new flow to the repeated hash structure and action payload.
418  *
419  * Return: negative value on error, 0 if configured successfully.
420  */
421 static int
422 nfp_flower_add_offload(struct nfp_app *app, struct net_device *netdev,
423                        struct tc_cls_flower_offload *flow)
424 {
425         enum nfp_flower_tun_type tun_type = NFP_FL_TUNNEL_NONE;
426         struct nfp_flower_priv *priv = app->priv;
427         struct nfp_fl_payload *flow_pay;
428         struct nfp_fl_key_ls *key_layer;
429         struct nfp_port *port = NULL;
430         int err;
431
432         if (nfp_netdev_is_nfp_repr(netdev))
433                 port = nfp_port_from_netdev(netdev);
434
435         key_layer = kmalloc(sizeof(*key_layer), GFP_KERNEL);
436         if (!key_layer)
437                 return -ENOMEM;
438
439         err = nfp_flower_calculate_key_layers(app, netdev, key_layer, flow,
440                                               &tun_type);
441         if (err)
442                 goto err_free_key_ls;
443
444         flow_pay = nfp_flower_allocate_new(key_layer);
445         if (!flow_pay) {
446                 err = -ENOMEM;
447                 goto err_free_key_ls;
448         }
449
450         err = nfp_flower_compile_flow_match(app, flow, key_layer, netdev,
451                                             flow_pay, tun_type);
452         if (err)
453                 goto err_destroy_flow;
454
455         err = nfp_flower_compile_action(app, flow, netdev, flow_pay);
456         if (err)
457                 goto err_destroy_flow;
458
459         err = nfp_compile_flow_metadata(app, flow, flow_pay, netdev);
460         if (err)
461                 goto err_destroy_flow;
462
463         err = nfp_flower_xmit_flow(app, flow_pay,
464                                    NFP_FLOWER_CMSG_TYPE_FLOW_ADD);
465         if (err)
466                 goto err_destroy_flow;
467
468         flow_pay->tc_flower_cookie = flow->cookie;
469         err = rhashtable_insert_fast(&priv->flow_table, &flow_pay->fl_node,
470                                      nfp_flower_table_params);
471         if (err)
472                 goto err_destroy_flow;
473
474         if (port)
475                 port->tc_offload_cnt++;
476
477         /* Deallocate flow payload when flower rule has been destroyed. */
478         kfree(key_layer);
479
480         return 0;
481
482 err_destroy_flow:
483         kfree(flow_pay->action_data);
484         kfree(flow_pay->mask_data);
485         kfree(flow_pay->unmasked_data);
486         kfree(flow_pay);
487 err_free_key_ls:
488         kfree(key_layer);
489         return err;
490 }
491
492 /**
493  * nfp_flower_del_offload() - Removes a flow from hardware.
494  * @app:        Pointer to the APP handle
495  * @netdev:     netdev structure.
496  * @flow:       TC flower classifier offload structure
497  *
498  * Removes a flow from the repeated hash structure and clears the
499  * action payload.
500  *
501  * Return: negative value on error, 0 if removed successfully.
502  */
503 static int
504 nfp_flower_del_offload(struct nfp_app *app, struct net_device *netdev,
505                        struct tc_cls_flower_offload *flow)
506 {
507         struct nfp_flower_priv *priv = app->priv;
508         struct nfp_fl_payload *nfp_flow;
509         struct nfp_port *port = NULL;
510         int err;
511
512         if (nfp_netdev_is_nfp_repr(netdev))
513                 port = nfp_port_from_netdev(netdev);
514
515         nfp_flow = nfp_flower_search_fl_table(app, flow->cookie, netdev);
516         if (!nfp_flow)
517                 return -ENOENT;
518
519         err = nfp_modify_flow_metadata(app, nfp_flow);
520         if (err)
521                 goto err_free_flow;
522
523         if (nfp_flow->nfp_tun_ipv4_addr)
524                 nfp_tunnel_del_ipv4_off(app, nfp_flow->nfp_tun_ipv4_addr);
525
526         err = nfp_flower_xmit_flow(app, nfp_flow,
527                                    NFP_FLOWER_CMSG_TYPE_FLOW_DEL);
528         if (err)
529                 goto err_free_flow;
530
531 err_free_flow:
532         if (port)
533                 port->tc_offload_cnt--;
534         kfree(nfp_flow->action_data);
535         kfree(nfp_flow->mask_data);
536         kfree(nfp_flow->unmasked_data);
537         WARN_ON_ONCE(rhashtable_remove_fast(&priv->flow_table,
538                                             &nfp_flow->fl_node,
539                                             nfp_flower_table_params));
540         kfree_rcu(nfp_flow, rcu);
541         return err;
542 }
543
544 /**
545  * nfp_flower_get_stats() - Populates flow stats obtained from hardware.
546  * @app:        Pointer to the APP handle
547  * @netdev:     Netdev structure.
548  * @flow:       TC flower classifier offload structure
549  *
550  * Populates a flow statistics structure which which corresponds to a
551  * specific flow.
552  *
553  * Return: negative value on error, 0 if stats populated successfully.
554  */
555 static int
556 nfp_flower_get_stats(struct nfp_app *app, struct net_device *netdev,
557                      struct tc_cls_flower_offload *flow)
558 {
559         struct nfp_flower_priv *priv = app->priv;
560         struct nfp_fl_payload *nfp_flow;
561         u32 ctx_id;
562
563         nfp_flow = nfp_flower_search_fl_table(app, flow->cookie, netdev);
564         if (!nfp_flow)
565                 return -EINVAL;
566
567         ctx_id = be32_to_cpu(nfp_flow->meta.host_ctx_id);
568
569         spin_lock_bh(&priv->stats_lock);
570         tcf_exts_stats_update(flow->exts, priv->stats[ctx_id].bytes,
571                               priv->stats[ctx_id].pkts,
572                               priv->stats[ctx_id].used);
573
574         priv->stats[ctx_id].pkts = 0;
575         priv->stats[ctx_id].bytes = 0;
576         spin_unlock_bh(&priv->stats_lock);
577
578         return 0;
579 }
580
581 static int
582 nfp_flower_repr_offload(struct nfp_app *app, struct net_device *netdev,
583                         struct tc_cls_flower_offload *flower)
584 {
585         if (!eth_proto_is_802_3(flower->common.protocol))
586                 return -EOPNOTSUPP;
587
588         switch (flower->command) {
589         case TC_CLSFLOWER_REPLACE:
590                 return nfp_flower_add_offload(app, netdev, flower);
591         case TC_CLSFLOWER_DESTROY:
592                 return nfp_flower_del_offload(app, netdev, flower);
593         case TC_CLSFLOWER_STATS:
594                 return nfp_flower_get_stats(app, netdev, flower);
595         default:
596                 return -EOPNOTSUPP;
597         }
598 }
599
600 static int nfp_flower_setup_tc_block_cb(enum tc_setup_type type,
601                                         void *type_data, void *cb_priv)
602 {
603         struct nfp_repr *repr = cb_priv;
604
605         if (!tc_cls_can_offload_and_chain0(repr->netdev, type_data))
606                 return -EOPNOTSUPP;
607
608         switch (type) {
609         case TC_SETUP_CLSFLOWER:
610                 return nfp_flower_repr_offload(repr->app, repr->netdev,
611                                                type_data);
612         default:
613                 return -EOPNOTSUPP;
614         }
615 }
616
617 static int nfp_flower_setup_tc_block(struct net_device *netdev,
618                                      struct tc_block_offload *f)
619 {
620         struct nfp_repr *repr = netdev_priv(netdev);
621
622         if (f->binder_type != TCF_BLOCK_BINDER_TYPE_CLSACT_INGRESS)
623                 return -EOPNOTSUPP;
624
625         switch (f->command) {
626         case TC_BLOCK_BIND:
627                 return tcf_block_cb_register(f->block,
628                                              nfp_flower_setup_tc_block_cb,
629                                              repr, repr, f->extack);
630         case TC_BLOCK_UNBIND:
631                 tcf_block_cb_unregister(f->block,
632                                         nfp_flower_setup_tc_block_cb,
633                                         repr);
634                 return 0;
635         default:
636                 return -EOPNOTSUPP;
637         }
638 }
639
640 int nfp_flower_setup_tc(struct nfp_app *app, struct net_device *netdev,
641                         enum tc_setup_type type, void *type_data)
642 {
643         switch (type) {
644         case TC_SETUP_BLOCK:
645                 return nfp_flower_setup_tc_block(netdev, type_data);
646         default:
647                 return -EOPNOTSUPP;
648         }
649 }
650
651 struct nfp_flower_indr_block_cb_priv {
652         struct net_device *netdev;
653         struct nfp_app *app;
654         struct list_head list;
655 };
656
657 static struct nfp_flower_indr_block_cb_priv *
658 nfp_flower_indr_block_cb_priv_lookup(struct nfp_app *app,
659                                      struct net_device *netdev)
660 {
661         struct nfp_flower_indr_block_cb_priv *cb_priv;
662         struct nfp_flower_priv *priv = app->priv;
663
664         /* All callback list access should be protected by RTNL. */
665         ASSERT_RTNL();
666
667         list_for_each_entry(cb_priv, &priv->indr_block_cb_priv, list)
668                 if (cb_priv->netdev == netdev)
669                         return cb_priv;
670
671         return NULL;
672 }
673
674 static int nfp_flower_setup_indr_block_cb(enum tc_setup_type type,
675                                           void *type_data, void *cb_priv)
676 {
677         struct nfp_flower_indr_block_cb_priv *priv = cb_priv;
678         struct tc_cls_flower_offload *flower = type_data;
679
680         if (flower->common.chain_index)
681                 return -EOPNOTSUPP;
682
683         switch (type) {
684         case TC_SETUP_CLSFLOWER:
685                 return nfp_flower_repr_offload(priv->app, priv->netdev,
686                                                type_data);
687         default:
688                 return -EOPNOTSUPP;
689         }
690 }
691
692 static int
693 nfp_flower_setup_indr_tc_block(struct net_device *netdev, struct nfp_app *app,
694                                struct tc_block_offload *f)
695 {
696         struct nfp_flower_indr_block_cb_priv *cb_priv;
697         struct nfp_flower_priv *priv = app->priv;
698         int err;
699
700         if (f->binder_type != TCF_BLOCK_BINDER_TYPE_CLSACT_INGRESS)
701                 return -EOPNOTSUPP;
702
703         switch (f->command) {
704         case TC_BLOCK_BIND:
705                 cb_priv = kmalloc(sizeof(*cb_priv), GFP_KERNEL);
706                 if (!cb_priv)
707                         return -ENOMEM;
708
709                 cb_priv->netdev = netdev;
710                 cb_priv->app = app;
711                 list_add(&cb_priv->list, &priv->indr_block_cb_priv);
712
713                 err = tcf_block_cb_register(f->block,
714                                             nfp_flower_setup_indr_block_cb,
715                                             netdev, cb_priv, f->extack);
716                 if (err) {
717                         list_del(&cb_priv->list);
718                         kfree(cb_priv);
719                 }
720
721                 return err;
722         case TC_BLOCK_UNBIND:
723                 tcf_block_cb_unregister(f->block,
724                                         nfp_flower_setup_indr_block_cb, netdev);
725                 cb_priv = nfp_flower_indr_block_cb_priv_lookup(app, netdev);
726                 if (cb_priv) {
727                         list_del(&cb_priv->list);
728                         kfree(cb_priv);
729                 }
730
731                 return 0;
732         default:
733                 return -EOPNOTSUPP;
734         }
735         return 0;
736 }
737
738 static int
739 nfp_flower_indr_setup_tc_cb(struct net_device *netdev, void *cb_priv,
740                             enum tc_setup_type type, void *type_data)
741 {
742         switch (type) {
743         case TC_SETUP_BLOCK:
744                 return nfp_flower_setup_indr_tc_block(netdev, cb_priv,
745                                                       type_data);
746         default:
747                 return -EOPNOTSUPP;
748         }
749 }
750
751 int nfp_flower_reg_indir_block_handler(struct nfp_app *app,
752                                        struct net_device *netdev,
753                                        unsigned long event)
754 {
755         int err;
756
757         if (!nfp_fl_is_netdev_to_offload(netdev))
758                 return NOTIFY_OK;
759
760         if (event == NETDEV_REGISTER) {
761                 err = __tc_indr_block_cb_register(netdev, app,
762                                                   nfp_flower_indr_setup_tc_cb,
763                                                   netdev);
764                 if (err)
765                         nfp_flower_cmsg_warn(app,
766                                              "Indirect block reg failed - %s\n",
767                                              netdev->name);
768         } else if (event == NETDEV_UNREGISTER) {
769                 __tc_indr_block_cb_unregister(netdev,
770                                               nfp_flower_indr_setup_tc_cb,
771                                               netdev);
772         }
773
774         return NOTIFY_OK;
775 }