1 /* SPDX-License-Identifier: BSD-3-Clause
2 * Copyright 2018 Mellanox Technologies, Ltd
5 #include <netinet/in.h>
12 /* ISO C doesn't support unnamed structs/unions, disabling -pedantic. */
14 #pragma GCC diagnostic ignored "-Wpedantic"
16 #include <infiniband/verbs.h>
18 #pragma GCC diagnostic error "-Wpedantic"
21 #include <rte_common.h>
22 #include <rte_ether.h>
23 #include <rte_ethdev_driver.h>
25 #include <rte_flow_driver.h>
26 #include <rte_malloc.h>
30 #include "mlx5_defs.h"
31 #include "mlx5_flow.h"
32 #include "mlx5_glue.h"
34 #include "mlx5_rxtx.h"
36 #define VERBS_SPEC_INNER(item_flags) \
37 (!!((item_flags) & MLX5_FLOW_LAYER_TUNNEL) ? IBV_FLOW_SPEC_INNER : 0)
40 * Create Verbs flow counter with Verbs library.
43 * Pointer to the Ethernet device structure.
44 * @param[in, out] counter
45 * mlx5 flow counter object, contains the counter id,
46 * handle of created Verbs flow counter is returned
47 * in cs field (if counters are supported).
50 * 0 On success else a negative errno value is returned
51 * and rte_errno is set.
54 flow_verbs_counter_create(struct rte_eth_dev *dev,
55 struct mlx5_flow_counter *counter)
57 #if defined(HAVE_IBV_DEVICE_COUNTERS_SET_V42)
58 struct mlx5_priv *priv = dev->data->dev_private;
59 struct ibv_context *ctx = priv->sh->ctx;
60 struct ibv_counter_set_init_attr init = {
61 .counter_set_id = counter->id};
63 counter->cs = mlx5_glue->create_counter_set(ctx, &init);
69 #elif defined(HAVE_IBV_DEVICE_COUNTERS_SET_V45)
70 struct mlx5_priv *priv = dev->data->dev_private;
71 struct ibv_context *ctx = priv->sh->ctx;
72 struct ibv_counters_init_attr init = {0};
73 struct ibv_counter_attach_attr attach;
76 memset(&attach, 0, sizeof(attach));
77 counter->cs = mlx5_glue->create_counters(ctx, &init);
82 attach.counter_desc = IBV_COUNTER_PACKETS;
84 ret = mlx5_glue->attach_counters(counter->cs, &attach, NULL);
86 attach.counter_desc = IBV_COUNTER_BYTES;
88 ret = mlx5_glue->attach_counters
89 (counter->cs, &attach, NULL);
92 claim_zero(mlx5_glue->destroy_counters(counter->cs));
107 * Get a flow counter.
110 * Pointer to the Ethernet device structure.
112 * Indicate if this counter is shared with other flows.
114 * Counter identifier.
117 * A pointer to the counter, NULL otherwise and rte_errno is set.
119 static struct mlx5_flow_counter *
120 flow_verbs_counter_new(struct rte_eth_dev *dev, uint32_t shared, uint32_t id)
122 struct mlx5_priv *priv = dev->data->dev_private;
123 struct mlx5_flow_counter *cnt;
127 TAILQ_FOREACH(cnt, &priv->sh->cmng.flow_counters, next) {
128 if (cnt->shared && cnt->id == id) {
134 cnt = rte_calloc(__func__, 1, sizeof(*cnt), 0);
140 cnt->shared = shared;
144 /* Create counter with Verbs. */
145 ret = flow_verbs_counter_create(dev, cnt);
147 TAILQ_INSERT_HEAD(&priv->sh->cmng.flow_counters, cnt, next);
150 /* Some error occurred in Verbs library. */
157 * Release a flow counter.
160 * Pointer to the Ethernet device structure.
162 * Pointer to the counter handler.
165 flow_verbs_counter_release(struct rte_eth_dev *dev,
166 struct mlx5_flow_counter *counter)
168 struct mlx5_priv *priv = dev->data->dev_private;
170 if (--counter->ref_cnt == 0) {
171 #if defined(HAVE_IBV_DEVICE_COUNTERS_SET_V42)
172 claim_zero(mlx5_glue->destroy_counter_set(counter->cs));
173 #elif defined(HAVE_IBV_DEVICE_COUNTERS_SET_V45)
174 claim_zero(mlx5_glue->destroy_counters(counter->cs));
176 TAILQ_REMOVE(&priv->sh->cmng.flow_counters, counter, next);
182 * Query a flow counter via Verbs library call.
184 * @see rte_flow_query()
188 flow_verbs_counter_query(struct rte_eth_dev *dev __rte_unused,
189 struct rte_flow *flow, void *data,
190 struct rte_flow_error *error)
192 #if defined(HAVE_IBV_DEVICE_COUNTERS_SET_V42) || \
193 defined(HAVE_IBV_DEVICE_COUNTERS_SET_V45)
194 if (flow->counter && flow->counter->cs) {
195 struct rte_flow_query_count *qc = data;
196 uint64_t counters[2] = {0, 0};
197 #if defined(HAVE_IBV_DEVICE_COUNTERS_SET_V42)
198 struct ibv_query_counter_set_attr query_cs_attr = {
199 .cs = flow->counter->cs,
200 .query_flags = IBV_COUNTER_SET_FORCE_UPDATE,
202 struct ibv_counter_set_data query_out = {
204 .outlen = 2 * sizeof(uint64_t),
206 int err = mlx5_glue->query_counter_set(&query_cs_attr,
208 #elif defined(HAVE_IBV_DEVICE_COUNTERS_SET_V45)
209 int err = mlx5_glue->query_counters
210 (flow->counter->cs, counters,
212 IBV_READ_COUNTERS_ATTR_PREFER_CACHED);
215 return rte_flow_error_set
217 RTE_FLOW_ERROR_TYPE_UNSPECIFIED,
219 "cannot read counter");
222 qc->hits = counters[0] - flow->counter->hits;
223 qc->bytes = counters[1] - flow->counter->bytes;
225 flow->counter->hits = counters[0];
226 flow->counter->bytes = counters[1];
230 return rte_flow_error_set(error, EINVAL,
231 RTE_FLOW_ERROR_TYPE_UNSPECIFIED,
233 "flow does not have counter");
237 return rte_flow_error_set(error, ENOTSUP,
238 RTE_FLOW_ERROR_TYPE_UNSPECIFIED,
240 "counters are not available");
245 * Add a verbs item specification into @p verbs.
248 * Pointer to verbs structure.
250 * Create specification.
252 * Size in bytes of the specification to copy.
255 flow_verbs_spec_add(struct mlx5_flow_verbs *verbs, void *src, unsigned int size)
261 assert(verbs->specs);
262 dst = (void *)(verbs->specs + verbs->size);
263 memcpy(dst, src, size);
264 ++verbs->attr->num_of_specs;
269 * Convert the @p item into a Verbs specification. This function assumes that
270 * the input is valid and that there is space to insert the requested item
273 * @param[in, out] dev_flow
274 * Pointer to dev_flow structure.
276 * Item specification.
277 * @param[in] item_flags
281 flow_verbs_translate_item_eth(struct mlx5_flow *dev_flow,
282 const struct rte_flow_item *item,
285 const struct rte_flow_item_eth *spec = item->spec;
286 const struct rte_flow_item_eth *mask = item->mask;
287 const unsigned int size = sizeof(struct ibv_flow_spec_eth);
288 struct ibv_flow_spec_eth eth = {
289 .type = IBV_FLOW_SPEC_ETH | VERBS_SPEC_INNER(item_flags),
294 mask = &rte_flow_item_eth_mask;
298 memcpy(ð.val.dst_mac, spec->dst.addr_bytes,
300 memcpy(ð.val.src_mac, spec->src.addr_bytes,
302 eth.val.ether_type = spec->type;
303 memcpy(ð.mask.dst_mac, mask->dst.addr_bytes,
305 memcpy(ð.mask.src_mac, mask->src.addr_bytes,
307 eth.mask.ether_type = mask->type;
308 /* Remove unwanted bits from values. */
309 for (i = 0; i < RTE_ETHER_ADDR_LEN; ++i) {
310 eth.val.dst_mac[i] &= eth.mask.dst_mac[i];
311 eth.val.src_mac[i] &= eth.mask.src_mac[i];
313 eth.val.ether_type &= eth.mask.ether_type;
315 flow_verbs_spec_add(&dev_flow->verbs, ð, size);
319 * Update the VLAN tag in the Verbs Ethernet specification.
320 * This function assumes that the input is valid and there is space to add
321 * the requested item.
323 * @param[in, out] attr
324 * Pointer to Verbs attributes structure.
326 * Verbs structure containing the VLAN information to copy.
329 flow_verbs_item_vlan_update(struct ibv_flow_attr *attr,
330 struct ibv_flow_spec_eth *eth)
333 const enum ibv_flow_spec_type search = eth->type;
334 struct ibv_spec_header *hdr = (struct ibv_spec_header *)
335 ((uint8_t *)attr + sizeof(struct ibv_flow_attr));
337 for (i = 0; i != attr->num_of_specs; ++i) {
338 if (hdr->type == search) {
339 struct ibv_flow_spec_eth *e =
340 (struct ibv_flow_spec_eth *)hdr;
342 e->val.vlan_tag = eth->val.vlan_tag;
343 e->mask.vlan_tag = eth->mask.vlan_tag;
344 e->val.ether_type = eth->val.ether_type;
345 e->mask.ether_type = eth->mask.ether_type;
348 hdr = (struct ibv_spec_header *)((uint8_t *)hdr + hdr->size);
353 * Convert the @p item into a Verbs specification. This function assumes that
354 * the input is valid and that there is space to insert the requested item
357 * @param[in, out] dev_flow
358 * Pointer to dev_flow structure.
360 * Item specification.
361 * @param[in] item_flags
365 flow_verbs_translate_item_vlan(struct mlx5_flow *dev_flow,
366 const struct rte_flow_item *item,
369 const struct rte_flow_item_vlan *spec = item->spec;
370 const struct rte_flow_item_vlan *mask = item->mask;
371 unsigned int size = sizeof(struct ibv_flow_spec_eth);
372 const int tunnel = !!(item_flags & MLX5_FLOW_LAYER_TUNNEL);
373 struct ibv_flow_spec_eth eth = {
374 .type = IBV_FLOW_SPEC_ETH | VERBS_SPEC_INNER(item_flags),
377 const uint32_t l2m = tunnel ? MLX5_FLOW_LAYER_INNER_L2 :
378 MLX5_FLOW_LAYER_OUTER_L2;
381 mask = &rte_flow_item_vlan_mask;
383 eth.val.vlan_tag = spec->tci;
384 eth.mask.vlan_tag = mask->tci;
385 eth.val.vlan_tag &= eth.mask.vlan_tag;
386 eth.val.ether_type = spec->inner_type;
387 eth.mask.ether_type = mask->inner_type;
388 eth.val.ether_type &= eth.mask.ether_type;
390 if (!(item_flags & l2m))
391 flow_verbs_spec_add(&dev_flow->verbs, ð, size);
393 flow_verbs_item_vlan_update(dev_flow->verbs.attr, ð);
395 dev_flow->verbs.vf_vlan.tag =
396 rte_be_to_cpu_16(spec->tci) & 0x0fff;
400 * Convert the @p item into a Verbs specification. This function assumes that
401 * the input is valid and that there is space to insert the requested item
404 * @param[in, out] dev_flow
405 * Pointer to dev_flow structure.
407 * Item specification.
408 * @param[in] item_flags
412 flow_verbs_translate_item_ipv4(struct mlx5_flow *dev_flow,
413 const struct rte_flow_item *item,
416 const struct rte_flow_item_ipv4 *spec = item->spec;
417 const struct rte_flow_item_ipv4 *mask = item->mask;
418 unsigned int size = sizeof(struct ibv_flow_spec_ipv4_ext);
419 struct ibv_flow_spec_ipv4_ext ipv4 = {
420 .type = IBV_FLOW_SPEC_IPV4_EXT | VERBS_SPEC_INNER(item_flags),
425 mask = &rte_flow_item_ipv4_mask;
427 ipv4.val = (struct ibv_flow_ipv4_ext_filter){
428 .src_ip = spec->hdr.src_addr,
429 .dst_ip = spec->hdr.dst_addr,
430 .proto = spec->hdr.next_proto_id,
431 .tos = spec->hdr.type_of_service,
433 ipv4.mask = (struct ibv_flow_ipv4_ext_filter){
434 .src_ip = mask->hdr.src_addr,
435 .dst_ip = mask->hdr.dst_addr,
436 .proto = mask->hdr.next_proto_id,
437 .tos = mask->hdr.type_of_service,
439 /* Remove unwanted bits from values. */
440 ipv4.val.src_ip &= ipv4.mask.src_ip;
441 ipv4.val.dst_ip &= ipv4.mask.dst_ip;
442 ipv4.val.proto &= ipv4.mask.proto;
443 ipv4.val.tos &= ipv4.mask.tos;
445 flow_verbs_spec_add(&dev_flow->verbs, &ipv4, size);
449 * Convert the @p item into a Verbs specification. This function assumes that
450 * the input is valid and that there is space to insert the requested item
453 * @param[in, out] dev_flow
454 * Pointer to dev_flow structure.
456 * Item specification.
457 * @param[in] item_flags
461 flow_verbs_translate_item_ipv6(struct mlx5_flow *dev_flow,
462 const struct rte_flow_item *item,
465 const struct rte_flow_item_ipv6 *spec = item->spec;
466 const struct rte_flow_item_ipv6 *mask = item->mask;
467 unsigned int size = sizeof(struct ibv_flow_spec_ipv6);
468 struct ibv_flow_spec_ipv6 ipv6 = {
469 .type = IBV_FLOW_SPEC_IPV6 | VERBS_SPEC_INNER(item_flags),
474 mask = &rte_flow_item_ipv6_mask;
477 uint32_t vtc_flow_val;
478 uint32_t vtc_flow_mask;
480 memcpy(&ipv6.val.src_ip, spec->hdr.src_addr,
481 RTE_DIM(ipv6.val.src_ip));
482 memcpy(&ipv6.val.dst_ip, spec->hdr.dst_addr,
483 RTE_DIM(ipv6.val.dst_ip));
484 memcpy(&ipv6.mask.src_ip, mask->hdr.src_addr,
485 RTE_DIM(ipv6.mask.src_ip));
486 memcpy(&ipv6.mask.dst_ip, mask->hdr.dst_addr,
487 RTE_DIM(ipv6.mask.dst_ip));
488 vtc_flow_val = rte_be_to_cpu_32(spec->hdr.vtc_flow);
489 vtc_flow_mask = rte_be_to_cpu_32(mask->hdr.vtc_flow);
490 ipv6.val.flow_label =
491 rte_cpu_to_be_32((vtc_flow_val & RTE_IPV6_HDR_FL_MASK) >>
492 RTE_IPV6_HDR_FL_SHIFT);
493 ipv6.val.traffic_class = (vtc_flow_val & RTE_IPV6_HDR_TC_MASK) >>
494 RTE_IPV6_HDR_TC_SHIFT;
495 ipv6.val.next_hdr = spec->hdr.proto;
496 ipv6.val.hop_limit = spec->hdr.hop_limits;
497 ipv6.mask.flow_label =
498 rte_cpu_to_be_32((vtc_flow_mask & RTE_IPV6_HDR_FL_MASK) >>
499 RTE_IPV6_HDR_FL_SHIFT);
500 ipv6.mask.traffic_class = (vtc_flow_mask & RTE_IPV6_HDR_TC_MASK) >>
501 RTE_IPV6_HDR_TC_SHIFT;
502 ipv6.mask.next_hdr = mask->hdr.proto;
503 ipv6.mask.hop_limit = mask->hdr.hop_limits;
504 /* Remove unwanted bits from values. */
505 for (i = 0; i < RTE_DIM(ipv6.val.src_ip); ++i) {
506 ipv6.val.src_ip[i] &= ipv6.mask.src_ip[i];
507 ipv6.val.dst_ip[i] &= ipv6.mask.dst_ip[i];
509 ipv6.val.flow_label &= ipv6.mask.flow_label;
510 ipv6.val.traffic_class &= ipv6.mask.traffic_class;
511 ipv6.val.next_hdr &= ipv6.mask.next_hdr;
512 ipv6.val.hop_limit &= ipv6.mask.hop_limit;
514 flow_verbs_spec_add(&dev_flow->verbs, &ipv6, size);
518 * Convert the @p item into a Verbs specification. This function assumes that
519 * the input is valid and that there is space to insert the requested item
522 * @param[in, out] dev_flow
523 * Pointer to dev_flow structure.
525 * Item specification.
526 * @param[in] item_flags
530 flow_verbs_translate_item_tcp(struct mlx5_flow *dev_flow,
531 const struct rte_flow_item *item,
532 uint64_t item_flags __rte_unused)
534 const struct rte_flow_item_tcp *spec = item->spec;
535 const struct rte_flow_item_tcp *mask = item->mask;
536 unsigned int size = sizeof(struct ibv_flow_spec_tcp_udp);
537 struct ibv_flow_spec_tcp_udp tcp = {
538 .type = IBV_FLOW_SPEC_TCP | VERBS_SPEC_INNER(item_flags),
543 mask = &rte_flow_item_tcp_mask;
545 tcp.val.dst_port = spec->hdr.dst_port;
546 tcp.val.src_port = spec->hdr.src_port;
547 tcp.mask.dst_port = mask->hdr.dst_port;
548 tcp.mask.src_port = mask->hdr.src_port;
549 /* Remove unwanted bits from values. */
550 tcp.val.src_port &= tcp.mask.src_port;
551 tcp.val.dst_port &= tcp.mask.dst_port;
553 flow_verbs_spec_add(&dev_flow->verbs, &tcp, size);
557 * Convert the @p item into a Verbs specification. This function assumes that
558 * the input is valid and that there is space to insert the requested item
561 * @param[in, out] dev_flow
562 * Pointer to dev_flow structure.
564 * Item specification.
565 * @param[in] item_flags
569 flow_verbs_translate_item_udp(struct mlx5_flow *dev_flow,
570 const struct rte_flow_item *item,
571 uint64_t item_flags __rte_unused)
573 const struct rte_flow_item_udp *spec = item->spec;
574 const struct rte_flow_item_udp *mask = item->mask;
575 unsigned int size = sizeof(struct ibv_flow_spec_tcp_udp);
576 struct ibv_flow_spec_tcp_udp udp = {
577 .type = IBV_FLOW_SPEC_UDP | VERBS_SPEC_INNER(item_flags),
582 mask = &rte_flow_item_udp_mask;
584 udp.val.dst_port = spec->hdr.dst_port;
585 udp.val.src_port = spec->hdr.src_port;
586 udp.mask.dst_port = mask->hdr.dst_port;
587 udp.mask.src_port = mask->hdr.src_port;
588 /* Remove unwanted bits from values. */
589 udp.val.src_port &= udp.mask.src_port;
590 udp.val.dst_port &= udp.mask.dst_port;
592 flow_verbs_spec_add(&dev_flow->verbs, &udp, size);
596 * Convert the @p item into a Verbs specification. This function assumes that
597 * the input is valid and that there is space to insert the requested item
600 * @param[in, out] dev_flow
601 * Pointer to dev_flow structure.
603 * Item specification.
604 * @param[in] item_flags
608 flow_verbs_translate_item_vxlan(struct mlx5_flow *dev_flow,
609 const struct rte_flow_item *item,
610 uint64_t item_flags __rte_unused)
612 const struct rte_flow_item_vxlan *spec = item->spec;
613 const struct rte_flow_item_vxlan *mask = item->mask;
614 unsigned int size = sizeof(struct ibv_flow_spec_tunnel);
615 struct ibv_flow_spec_tunnel vxlan = {
616 .type = IBV_FLOW_SPEC_VXLAN_TUNNEL,
622 } id = { .vlan_id = 0, };
625 mask = &rte_flow_item_vxlan_mask;
627 memcpy(&id.vni[1], spec->vni, 3);
628 vxlan.val.tunnel_id = id.vlan_id;
629 memcpy(&id.vni[1], mask->vni, 3);
630 vxlan.mask.tunnel_id = id.vlan_id;
631 /* Remove unwanted bits from values. */
632 vxlan.val.tunnel_id &= vxlan.mask.tunnel_id;
634 flow_verbs_spec_add(&dev_flow->verbs, &vxlan, size);
638 * Convert the @p item into a Verbs specification. This function assumes that
639 * the input is valid and that there is space to insert the requested item
642 * @param[in, out] dev_flow
643 * Pointer to dev_flow structure.
645 * Item specification.
646 * @param[in] item_flags
650 flow_verbs_translate_item_vxlan_gpe(struct mlx5_flow *dev_flow,
651 const struct rte_flow_item *item,
652 uint64_t item_flags __rte_unused)
654 const struct rte_flow_item_vxlan_gpe *spec = item->spec;
655 const struct rte_flow_item_vxlan_gpe *mask = item->mask;
656 unsigned int size = sizeof(struct ibv_flow_spec_tunnel);
657 struct ibv_flow_spec_tunnel vxlan_gpe = {
658 .type = IBV_FLOW_SPEC_VXLAN_TUNNEL,
664 } id = { .vlan_id = 0, };
667 mask = &rte_flow_item_vxlan_gpe_mask;
669 memcpy(&id.vni[1], spec->vni, 3);
670 vxlan_gpe.val.tunnel_id = id.vlan_id;
671 memcpy(&id.vni[1], mask->vni, 3);
672 vxlan_gpe.mask.tunnel_id = id.vlan_id;
673 /* Remove unwanted bits from values. */
674 vxlan_gpe.val.tunnel_id &= vxlan_gpe.mask.tunnel_id;
676 flow_verbs_spec_add(&dev_flow->verbs, &vxlan_gpe, size);
680 * Update the protocol in Verbs IPv4/IPv6 spec.
682 * @param[in, out] attr
683 * Pointer to Verbs attributes structure.
685 * Specification type to search in order to update the IP protocol.
686 * @param[in] protocol
687 * Protocol value to set if none is present in the specification.
690 flow_verbs_item_gre_ip_protocol_update(struct ibv_flow_attr *attr,
691 enum ibv_flow_spec_type search,
695 struct ibv_spec_header *hdr = (struct ibv_spec_header *)
696 ((uint8_t *)attr + sizeof(struct ibv_flow_attr));
700 for (i = 0; i != attr->num_of_specs; ++i) {
701 if (hdr->type == search) {
703 struct ibv_flow_spec_ipv4_ext *ipv4;
704 struct ibv_flow_spec_ipv6 *ipv6;
708 case IBV_FLOW_SPEC_IPV4_EXT:
709 ip.ipv4 = (struct ibv_flow_spec_ipv4_ext *)hdr;
710 if (!ip.ipv4->val.proto) {
711 ip.ipv4->val.proto = protocol;
712 ip.ipv4->mask.proto = 0xff;
715 case IBV_FLOW_SPEC_IPV6:
716 ip.ipv6 = (struct ibv_flow_spec_ipv6 *)hdr;
717 if (!ip.ipv6->val.next_hdr) {
718 ip.ipv6->val.next_hdr = protocol;
719 ip.ipv6->mask.next_hdr = 0xff;
727 hdr = (struct ibv_spec_header *)((uint8_t *)hdr + hdr->size);
732 * Convert the @p item into a Verbs specification. This function assumes that
733 * the input is valid and that there is space to insert the requested item
736 * @param[in, out] dev_flow
737 * Pointer to dev_flow structure.
739 * Item specification.
740 * @param[in] item_flags
744 flow_verbs_translate_item_gre(struct mlx5_flow *dev_flow,
745 const struct rte_flow_item *item __rte_unused,
748 struct mlx5_flow_verbs *verbs = &dev_flow->verbs;
749 #ifndef HAVE_IBV_DEVICE_MPLS_SUPPORT
750 unsigned int size = sizeof(struct ibv_flow_spec_tunnel);
751 struct ibv_flow_spec_tunnel tunnel = {
752 .type = IBV_FLOW_SPEC_VXLAN_TUNNEL,
756 const struct rte_flow_item_gre *spec = item->spec;
757 const struct rte_flow_item_gre *mask = item->mask;
758 unsigned int size = sizeof(struct ibv_flow_spec_gre);
759 struct ibv_flow_spec_gre tunnel = {
760 .type = IBV_FLOW_SPEC_GRE,
765 mask = &rte_flow_item_gre_mask;
767 tunnel.val.c_ks_res0_ver = spec->c_rsvd0_ver;
768 tunnel.val.protocol = spec->protocol;
769 tunnel.mask.c_ks_res0_ver = mask->c_rsvd0_ver;
770 tunnel.mask.protocol = mask->protocol;
771 /* Remove unwanted bits from values. */
772 tunnel.val.c_ks_res0_ver &= tunnel.mask.c_ks_res0_ver;
773 tunnel.val.protocol &= tunnel.mask.protocol;
774 tunnel.val.key &= tunnel.mask.key;
777 if (item_flags & MLX5_FLOW_LAYER_OUTER_L3_IPV4)
778 flow_verbs_item_gre_ip_protocol_update(verbs->attr,
779 IBV_FLOW_SPEC_IPV4_EXT,
782 flow_verbs_item_gre_ip_protocol_update(verbs->attr,
785 flow_verbs_spec_add(verbs, &tunnel, size);
789 * Convert the @p action into a Verbs specification. This function assumes that
790 * the input is valid and that there is space to insert the requested action
791 * into the flow. This function also return the action that was added.
793 * @param[in, out] dev_flow
794 * Pointer to dev_flow structure.
796 * Item specification.
797 * @param[in] item_flags
801 flow_verbs_translate_item_mpls(struct mlx5_flow *dev_flow __rte_unused,
802 const struct rte_flow_item *item __rte_unused,
803 uint64_t item_flags __rte_unused)
805 #ifdef HAVE_IBV_DEVICE_MPLS_SUPPORT
806 const struct rte_flow_item_mpls *spec = item->spec;
807 const struct rte_flow_item_mpls *mask = item->mask;
808 unsigned int size = sizeof(struct ibv_flow_spec_mpls);
809 struct ibv_flow_spec_mpls mpls = {
810 .type = IBV_FLOW_SPEC_MPLS,
815 mask = &rte_flow_item_mpls_mask;
817 memcpy(&mpls.val.label, spec, sizeof(mpls.val.label));
818 memcpy(&mpls.mask.label, mask, sizeof(mpls.mask.label));
819 /* Remove unwanted bits from values. */
820 mpls.val.label &= mpls.mask.label;
822 flow_verbs_spec_add(&dev_flow->verbs, &mpls, size);
827 * Convert the @p action into a Verbs specification. This function assumes that
828 * the input is valid and that there is space to insert the requested action
831 * @param[in] dev_flow
832 * Pointer to mlx5_flow.
834 * Action configuration.
837 flow_verbs_translate_action_drop
838 (struct mlx5_flow *dev_flow,
839 const struct rte_flow_action *action __rte_unused)
841 unsigned int size = sizeof(struct ibv_flow_spec_action_drop);
842 struct ibv_flow_spec_action_drop drop = {
843 .type = IBV_FLOW_SPEC_ACTION_DROP,
847 flow_verbs_spec_add(&dev_flow->verbs, &drop, size);
851 * Convert the @p action into a Verbs specification. This function assumes that
852 * the input is valid and that there is space to insert the requested action
855 * @param[in] dev_flow
856 * Pointer to mlx5_flow.
858 * Action configuration.
861 flow_verbs_translate_action_queue(struct mlx5_flow *dev_flow,
862 const struct rte_flow_action *action)
864 const struct rte_flow_action_queue *queue = action->conf;
865 struct rte_flow *flow = dev_flow->flow;
868 (*flow->rss.queue)[0] = queue->index;
869 flow->rss.queue_num = 1;
873 * Convert the @p action into a Verbs specification. This function assumes that
874 * the input is valid and that there is space to insert the requested action
878 * Action configuration.
879 * @param[in, out] action_flags
880 * Pointer to the detected actions.
881 * @param[in] dev_flow
882 * Pointer to mlx5_flow.
885 flow_verbs_translate_action_rss(struct mlx5_flow *dev_flow,
886 const struct rte_flow_action *action)
888 const struct rte_flow_action_rss *rss = action->conf;
889 const uint8_t *rss_key;
890 struct rte_flow *flow = dev_flow->flow;
893 memcpy((*flow->rss.queue), rss->queue,
894 rss->queue_num * sizeof(uint16_t));
895 flow->rss.queue_num = rss->queue_num;
896 /* NULL RSS key indicates default RSS key. */
897 rss_key = !rss->key ? rss_hash_default_key : rss->key;
898 memcpy(flow->rss.key, rss_key, MLX5_RSS_HASH_KEY_LEN);
900 * rss->level and rss.types should be set in advance when expanding
906 * Convert the @p action into a Verbs specification. This function assumes that
907 * the input is valid and that there is space to insert the requested action
910 * @param[in] dev_flow
911 * Pointer to mlx5_flow.
913 * Action configuration.
916 flow_verbs_translate_action_flag
917 (struct mlx5_flow *dev_flow,
918 const struct rte_flow_action *action __rte_unused)
920 unsigned int size = sizeof(struct ibv_flow_spec_action_tag);
921 struct ibv_flow_spec_action_tag tag = {
922 .type = IBV_FLOW_SPEC_ACTION_TAG,
924 .tag_id = mlx5_flow_mark_set(MLX5_FLOW_MARK_DEFAULT),
927 flow_verbs_spec_add(&dev_flow->verbs, &tag, size);
931 * Convert the @p action into a Verbs specification. This function assumes that
932 * the input is valid and that there is space to insert the requested action
935 * @param[in] dev_flow
936 * Pointer to mlx5_flow.
938 * Action configuration.
941 flow_verbs_translate_action_mark(struct mlx5_flow *dev_flow,
942 const struct rte_flow_action *action)
944 const struct rte_flow_action_mark *mark = action->conf;
945 unsigned int size = sizeof(struct ibv_flow_spec_action_tag);
946 struct ibv_flow_spec_action_tag tag = {
947 .type = IBV_FLOW_SPEC_ACTION_TAG,
949 .tag_id = mlx5_flow_mark_set(mark->id),
952 flow_verbs_spec_add(&dev_flow->verbs, &tag, size);
956 * Convert the @p action into a Verbs specification. This function assumes that
957 * the input is valid and that there is space to insert the requested action
961 * Pointer to the Ethernet device structure.
963 * Action configuration.
964 * @param[in] dev_flow
965 * Pointer to mlx5_flow.
967 * Pointer to error structure.
970 * 0 On success else a negative errno value is returned and rte_errno is set.
973 flow_verbs_translate_action_count(struct mlx5_flow *dev_flow,
974 const struct rte_flow_action *action,
975 struct rte_eth_dev *dev,
976 struct rte_flow_error *error)
978 const struct rte_flow_action_count *count = action->conf;
979 struct rte_flow *flow = dev_flow->flow;
980 #if defined(HAVE_IBV_DEVICE_COUNTERS_SET_V42) || \
981 defined(HAVE_IBV_DEVICE_COUNTERS_SET_V45)
982 unsigned int size = sizeof(struct ibv_flow_spec_counter_action);
983 struct ibv_flow_spec_counter_action counter = {
984 .type = IBV_FLOW_SPEC_ACTION_COUNT,
989 if (!flow->counter) {
990 flow->counter = flow_verbs_counter_new(dev, count->shared,
993 return rte_flow_error_set(error, rte_errno,
994 RTE_FLOW_ERROR_TYPE_ACTION,
999 #if defined(HAVE_IBV_DEVICE_COUNTERS_SET_V42)
1000 counter.counter_set_handle = flow->counter->cs->handle;
1001 flow_verbs_spec_add(&dev_flow->verbs, &counter, size);
1002 #elif defined(HAVE_IBV_DEVICE_COUNTERS_SET_V45)
1003 counter.counters = flow->counter->cs;
1004 flow_verbs_spec_add(&dev_flow->verbs, &counter, size);
1010 * Internal validation function. For validating both actions and items.
1013 * Pointer to the Ethernet device structure.
1015 * Pointer to the flow attributes.
1017 * Pointer to the list of items.
1018 * @param[in] actions
1019 * Pointer to the list of actions.
1020 * @param[in] external
1021 * This flow rule is created by request external to PMD.
1023 * Pointer to the error structure.
1026 * 0 on success, a negative errno value otherwise and rte_errno is set.
1029 flow_verbs_validate(struct rte_eth_dev *dev,
1030 const struct rte_flow_attr *attr,
1031 const struct rte_flow_item items[],
1032 const struct rte_flow_action actions[],
1033 bool external __rte_unused,
1034 struct rte_flow_error *error)
1037 uint64_t action_flags = 0;
1038 uint64_t item_flags = 0;
1039 uint64_t last_item = 0;
1040 uint8_t next_protocol = 0xff;
1041 uint16_t ether_type = 0;
1045 ret = mlx5_flow_validate_attributes(dev, attr, error);
1048 for (; items->type != RTE_FLOW_ITEM_TYPE_END; items++) {
1049 int tunnel = !!(item_flags & MLX5_FLOW_LAYER_TUNNEL);
1052 switch (items->type) {
1053 case RTE_FLOW_ITEM_TYPE_VOID:
1055 case RTE_FLOW_ITEM_TYPE_ETH:
1056 ret = mlx5_flow_validate_item_eth(items, item_flags,
1060 last_item = tunnel ? MLX5_FLOW_LAYER_INNER_L2 :
1061 MLX5_FLOW_LAYER_OUTER_L2;
1062 if (items->mask != NULL && items->spec != NULL) {
1064 ((const struct rte_flow_item_eth *)
1067 ((const struct rte_flow_item_eth *)
1069 ether_type = rte_be_to_cpu_16(ether_type);
1074 case RTE_FLOW_ITEM_TYPE_VLAN:
1075 ret = mlx5_flow_validate_item_vlan(items, item_flags,
1079 last_item = tunnel ? (MLX5_FLOW_LAYER_INNER_L2 |
1080 MLX5_FLOW_LAYER_INNER_VLAN) :
1081 (MLX5_FLOW_LAYER_OUTER_L2 |
1082 MLX5_FLOW_LAYER_OUTER_VLAN);
1083 if (items->mask != NULL && items->spec != NULL) {
1085 ((const struct rte_flow_item_vlan *)
1086 items->spec)->inner_type;
1088 ((const struct rte_flow_item_vlan *)
1089 items->mask)->inner_type;
1090 ether_type = rte_be_to_cpu_16(ether_type);
1095 case RTE_FLOW_ITEM_TYPE_IPV4:
1096 ret = mlx5_flow_validate_item_ipv4(items, item_flags,
1102 last_item = tunnel ? MLX5_FLOW_LAYER_INNER_L3_IPV4 :
1103 MLX5_FLOW_LAYER_OUTER_L3_IPV4;
1104 if (items->mask != NULL &&
1105 ((const struct rte_flow_item_ipv4 *)
1106 items->mask)->hdr.next_proto_id) {
1108 ((const struct rte_flow_item_ipv4 *)
1109 (items->spec))->hdr.next_proto_id;
1111 ((const struct rte_flow_item_ipv4 *)
1112 (items->mask))->hdr.next_proto_id;
1114 /* Reset for inner layer. */
1115 next_protocol = 0xff;
1118 case RTE_FLOW_ITEM_TYPE_IPV6:
1119 ret = mlx5_flow_validate_item_ipv6(items, item_flags,
1125 last_item = tunnel ? MLX5_FLOW_LAYER_INNER_L3_IPV6 :
1126 MLX5_FLOW_LAYER_OUTER_L3_IPV6;
1127 if (items->mask != NULL &&
1128 ((const struct rte_flow_item_ipv6 *)
1129 items->mask)->hdr.proto) {
1131 ((const struct rte_flow_item_ipv6 *)
1132 items->spec)->hdr.proto;
1134 ((const struct rte_flow_item_ipv6 *)
1135 items->mask)->hdr.proto;
1137 /* Reset for inner layer. */
1138 next_protocol = 0xff;
1141 case RTE_FLOW_ITEM_TYPE_UDP:
1142 ret = mlx5_flow_validate_item_udp(items, item_flags,
1147 last_item = tunnel ? MLX5_FLOW_LAYER_INNER_L4_UDP :
1148 MLX5_FLOW_LAYER_OUTER_L4_UDP;
1150 case RTE_FLOW_ITEM_TYPE_TCP:
1151 ret = mlx5_flow_validate_item_tcp
1154 &rte_flow_item_tcp_mask,
1158 last_item = tunnel ? MLX5_FLOW_LAYER_INNER_L4_TCP :
1159 MLX5_FLOW_LAYER_OUTER_L4_TCP;
1161 case RTE_FLOW_ITEM_TYPE_VXLAN:
1162 ret = mlx5_flow_validate_item_vxlan(items, item_flags,
1166 last_item = MLX5_FLOW_LAYER_VXLAN;
1168 case RTE_FLOW_ITEM_TYPE_VXLAN_GPE:
1169 ret = mlx5_flow_validate_item_vxlan_gpe(items,
1174 last_item = MLX5_FLOW_LAYER_VXLAN_GPE;
1176 case RTE_FLOW_ITEM_TYPE_GRE:
1177 ret = mlx5_flow_validate_item_gre(items, item_flags,
1178 next_protocol, error);
1181 last_item = MLX5_FLOW_LAYER_GRE;
1183 case RTE_FLOW_ITEM_TYPE_MPLS:
1184 ret = mlx5_flow_validate_item_mpls(dev, items,
1189 last_item = MLX5_FLOW_LAYER_MPLS;
1192 return rte_flow_error_set(error, ENOTSUP,
1193 RTE_FLOW_ERROR_TYPE_ITEM,
1194 NULL, "item not supported");
1196 item_flags |= last_item;
1198 for (; actions->type != RTE_FLOW_ACTION_TYPE_END; actions++) {
1199 switch (actions->type) {
1200 case RTE_FLOW_ACTION_TYPE_VOID:
1202 case RTE_FLOW_ACTION_TYPE_FLAG:
1203 ret = mlx5_flow_validate_action_flag(action_flags,
1208 action_flags |= MLX5_FLOW_ACTION_FLAG;
1210 case RTE_FLOW_ACTION_TYPE_MARK:
1211 ret = mlx5_flow_validate_action_mark(actions,
1217 action_flags |= MLX5_FLOW_ACTION_MARK;
1219 case RTE_FLOW_ACTION_TYPE_DROP:
1220 ret = mlx5_flow_validate_action_drop(action_flags,
1225 action_flags |= MLX5_FLOW_ACTION_DROP;
1227 case RTE_FLOW_ACTION_TYPE_QUEUE:
1228 ret = mlx5_flow_validate_action_queue(actions,
1234 action_flags |= MLX5_FLOW_ACTION_QUEUE;
1236 case RTE_FLOW_ACTION_TYPE_RSS:
1237 ret = mlx5_flow_validate_action_rss(actions,
1243 action_flags |= MLX5_FLOW_ACTION_RSS;
1245 case RTE_FLOW_ACTION_TYPE_COUNT:
1246 ret = mlx5_flow_validate_action_count(dev, attr, error);
1249 action_flags |= MLX5_FLOW_ACTION_COUNT;
1252 return rte_flow_error_set(error, ENOTSUP,
1253 RTE_FLOW_ERROR_TYPE_ACTION,
1255 "action not supported");
1259 * Validate the drop action mutual exclusion with other actions.
1260 * Drop action is mutually-exclusive with any other action, except for
1263 if ((action_flags & MLX5_FLOW_ACTION_DROP) &&
1264 (action_flags & ~(MLX5_FLOW_ACTION_DROP | MLX5_FLOW_ACTION_COUNT)))
1265 return rte_flow_error_set(error, EINVAL,
1266 RTE_FLOW_ERROR_TYPE_ACTION, NULL,
1267 "Drop action is mutually-exclusive "
1268 "with any other action, except for "
1270 if (!(action_flags & MLX5_FLOW_FATE_ACTIONS))
1271 return rte_flow_error_set(error, EINVAL,
1272 RTE_FLOW_ERROR_TYPE_ACTION, actions,
1273 "no fate action is found");
1278 * Calculate the required bytes that are needed for the action part of the verbs
1281 * @param[in] actions
1282 * Pointer to the list of actions.
1285 * The size of the memory needed for all actions.
1288 flow_verbs_get_actions_size(const struct rte_flow_action actions[])
1292 for (; actions->type != RTE_FLOW_ACTION_TYPE_END; actions++) {
1293 switch (actions->type) {
1294 case RTE_FLOW_ACTION_TYPE_VOID:
1296 case RTE_FLOW_ACTION_TYPE_FLAG:
1297 size += sizeof(struct ibv_flow_spec_action_tag);
1299 case RTE_FLOW_ACTION_TYPE_MARK:
1300 size += sizeof(struct ibv_flow_spec_action_tag);
1302 case RTE_FLOW_ACTION_TYPE_DROP:
1303 size += sizeof(struct ibv_flow_spec_action_drop);
1305 case RTE_FLOW_ACTION_TYPE_QUEUE:
1307 case RTE_FLOW_ACTION_TYPE_RSS:
1309 case RTE_FLOW_ACTION_TYPE_COUNT:
1310 #if defined(HAVE_IBV_DEVICE_COUNTERS_SET_V42) || \
1311 defined(HAVE_IBV_DEVICE_COUNTERS_SET_V45)
1312 size += sizeof(struct ibv_flow_spec_counter_action);
1323 * Calculate the required bytes that are needed for the item part of the verbs
1327 * Pointer to the list of items.
1330 * The size of the memory needed for all items.
1333 flow_verbs_get_items_size(const struct rte_flow_item items[])
1337 for (; items->type != RTE_FLOW_ITEM_TYPE_END; items++) {
1338 switch (items->type) {
1339 case RTE_FLOW_ITEM_TYPE_VOID:
1341 case RTE_FLOW_ITEM_TYPE_ETH:
1342 size += sizeof(struct ibv_flow_spec_eth);
1344 case RTE_FLOW_ITEM_TYPE_VLAN:
1345 size += sizeof(struct ibv_flow_spec_eth);
1347 case RTE_FLOW_ITEM_TYPE_IPV4:
1348 size += sizeof(struct ibv_flow_spec_ipv4_ext);
1350 case RTE_FLOW_ITEM_TYPE_IPV6:
1351 size += sizeof(struct ibv_flow_spec_ipv6);
1353 case RTE_FLOW_ITEM_TYPE_UDP:
1354 size += sizeof(struct ibv_flow_spec_tcp_udp);
1356 case RTE_FLOW_ITEM_TYPE_TCP:
1357 size += sizeof(struct ibv_flow_spec_tcp_udp);
1359 case RTE_FLOW_ITEM_TYPE_VXLAN:
1360 size += sizeof(struct ibv_flow_spec_tunnel);
1362 case RTE_FLOW_ITEM_TYPE_VXLAN_GPE:
1363 size += sizeof(struct ibv_flow_spec_tunnel);
1365 #ifdef HAVE_IBV_DEVICE_MPLS_SUPPORT
1366 case RTE_FLOW_ITEM_TYPE_GRE:
1367 size += sizeof(struct ibv_flow_spec_gre);
1369 case RTE_FLOW_ITEM_TYPE_MPLS:
1370 size += sizeof(struct ibv_flow_spec_mpls);
1373 case RTE_FLOW_ITEM_TYPE_GRE:
1374 size += sizeof(struct ibv_flow_spec_tunnel);
1385 * Internal preparation function. Allocate mlx5_flow with the required size.
1386 * The required size is calculate based on the actions and items. This function
1387 * also returns the detected actions and items for later use.
1390 * Pointer to the flow attributes.
1392 * Pointer to the list of items.
1393 * @param[in] actions
1394 * Pointer to the list of actions.
1396 * Pointer to the error structure.
1399 * Pointer to mlx5_flow object on success, otherwise NULL and rte_errno
1402 static struct mlx5_flow *
1403 flow_verbs_prepare(const struct rte_flow_attr *attr __rte_unused,
1404 const struct rte_flow_item items[],
1405 const struct rte_flow_action actions[],
1406 struct rte_flow_error *error)
1408 size_t size = sizeof(struct mlx5_flow) + sizeof(struct ibv_flow_attr);
1409 struct mlx5_flow *dev_flow;
1411 size += flow_verbs_get_actions_size(actions);
1412 size += flow_verbs_get_items_size(items);
1413 dev_flow = rte_calloc(__func__, 1, size, 0);
1415 rte_flow_error_set(error, ENOMEM,
1416 RTE_FLOW_ERROR_TYPE_UNSPECIFIED, NULL,
1417 "not enough memory to create flow");
1420 dev_flow->verbs.attr = (void *)(dev_flow + 1);
1421 dev_flow->verbs.specs = (void *)(dev_flow->verbs.attr + 1);
1422 dev_flow->ingress = attr->ingress;
1423 dev_flow->transfer = attr->transfer;
1428 * Fill the flow with verb spec.
1431 * Pointer to Ethernet device.
1432 * @param[in, out] dev_flow
1433 * Pointer to the mlx5 flow.
1435 * Pointer to the flow attributes.
1437 * Pointer to the list of items.
1438 * @param[in] actions
1439 * Pointer to the list of actions.
1441 * Pointer to the error structure.
1444 * 0 on success, else a negative errno value otherwise and rte_errno is set.
1447 flow_verbs_translate(struct rte_eth_dev *dev,
1448 struct mlx5_flow *dev_flow,
1449 const struct rte_flow_attr *attr,
1450 const struct rte_flow_item items[],
1451 const struct rte_flow_action actions[],
1452 struct rte_flow_error *error)
1454 uint64_t item_flags = 0;
1455 uint64_t action_flags = 0;
1456 uint64_t priority = attr->priority;
1457 uint32_t subpriority = 0;
1458 struct mlx5_priv *priv = dev->data->dev_private;
1460 if (priority == MLX5_FLOW_PRIO_RSVD)
1461 priority = priv->config.flow_prio - 1;
1462 for (; actions->type != RTE_FLOW_ACTION_TYPE_END; actions++) {
1465 switch (actions->type) {
1466 case RTE_FLOW_ACTION_TYPE_VOID:
1468 case RTE_FLOW_ACTION_TYPE_FLAG:
1469 flow_verbs_translate_action_flag(dev_flow, actions);
1470 action_flags |= MLX5_FLOW_ACTION_FLAG;
1472 case RTE_FLOW_ACTION_TYPE_MARK:
1473 flow_verbs_translate_action_mark(dev_flow, actions);
1474 action_flags |= MLX5_FLOW_ACTION_MARK;
1476 case RTE_FLOW_ACTION_TYPE_DROP:
1477 flow_verbs_translate_action_drop(dev_flow, actions);
1478 action_flags |= MLX5_FLOW_ACTION_DROP;
1480 case RTE_FLOW_ACTION_TYPE_QUEUE:
1481 flow_verbs_translate_action_queue(dev_flow, actions);
1482 action_flags |= MLX5_FLOW_ACTION_QUEUE;
1484 case RTE_FLOW_ACTION_TYPE_RSS:
1485 flow_verbs_translate_action_rss(dev_flow, actions);
1486 action_flags |= MLX5_FLOW_ACTION_RSS;
1488 case RTE_FLOW_ACTION_TYPE_COUNT:
1489 ret = flow_verbs_translate_action_count(dev_flow,
1494 action_flags |= MLX5_FLOW_ACTION_COUNT;
1497 return rte_flow_error_set(error, ENOTSUP,
1498 RTE_FLOW_ERROR_TYPE_ACTION,
1500 "action not supported");
1503 dev_flow->actions = action_flags;
1504 for (; items->type != RTE_FLOW_ITEM_TYPE_END; items++) {
1505 int tunnel = !!(item_flags & MLX5_FLOW_LAYER_TUNNEL);
1507 switch (items->type) {
1508 case RTE_FLOW_ITEM_TYPE_VOID:
1510 case RTE_FLOW_ITEM_TYPE_ETH:
1511 flow_verbs_translate_item_eth(dev_flow, items,
1513 subpriority = MLX5_PRIORITY_MAP_L2;
1514 item_flags |= tunnel ? MLX5_FLOW_LAYER_INNER_L2 :
1515 MLX5_FLOW_LAYER_OUTER_L2;
1517 case RTE_FLOW_ITEM_TYPE_VLAN:
1518 flow_verbs_translate_item_vlan(dev_flow, items,
1520 subpriority = MLX5_PRIORITY_MAP_L2;
1521 item_flags |= tunnel ? (MLX5_FLOW_LAYER_INNER_L2 |
1522 MLX5_FLOW_LAYER_INNER_VLAN) :
1523 (MLX5_FLOW_LAYER_OUTER_L2 |
1524 MLX5_FLOW_LAYER_OUTER_VLAN);
1526 case RTE_FLOW_ITEM_TYPE_IPV4:
1527 flow_verbs_translate_item_ipv4(dev_flow, items,
1529 subpriority = MLX5_PRIORITY_MAP_L3;
1530 dev_flow->hash_fields |=
1531 mlx5_flow_hashfields_adjust
1533 MLX5_IPV4_LAYER_TYPES,
1534 MLX5_IPV4_IBV_RX_HASH);
1535 item_flags |= tunnel ? MLX5_FLOW_LAYER_INNER_L3_IPV4 :
1536 MLX5_FLOW_LAYER_OUTER_L3_IPV4;
1538 case RTE_FLOW_ITEM_TYPE_IPV6:
1539 flow_verbs_translate_item_ipv6(dev_flow, items,
1541 subpriority = MLX5_PRIORITY_MAP_L3;
1542 dev_flow->hash_fields |=
1543 mlx5_flow_hashfields_adjust
1545 MLX5_IPV6_LAYER_TYPES,
1546 MLX5_IPV6_IBV_RX_HASH);
1547 item_flags |= tunnel ? MLX5_FLOW_LAYER_INNER_L3_IPV6 :
1548 MLX5_FLOW_LAYER_OUTER_L3_IPV6;
1550 case RTE_FLOW_ITEM_TYPE_TCP:
1551 flow_verbs_translate_item_tcp(dev_flow, items,
1553 subpriority = MLX5_PRIORITY_MAP_L4;
1554 dev_flow->hash_fields |=
1555 mlx5_flow_hashfields_adjust
1556 (dev_flow, tunnel, ETH_RSS_TCP,
1557 (IBV_RX_HASH_SRC_PORT_TCP |
1558 IBV_RX_HASH_DST_PORT_TCP));
1559 item_flags |= tunnel ? MLX5_FLOW_LAYER_INNER_L4_TCP :
1560 MLX5_FLOW_LAYER_OUTER_L4_TCP;
1562 case RTE_FLOW_ITEM_TYPE_UDP:
1563 flow_verbs_translate_item_udp(dev_flow, items,
1565 subpriority = MLX5_PRIORITY_MAP_L4;
1566 dev_flow->hash_fields |=
1567 mlx5_flow_hashfields_adjust
1568 (dev_flow, tunnel, ETH_RSS_UDP,
1569 (IBV_RX_HASH_SRC_PORT_UDP |
1570 IBV_RX_HASH_DST_PORT_UDP));
1571 item_flags |= tunnel ? MLX5_FLOW_LAYER_INNER_L4_UDP :
1572 MLX5_FLOW_LAYER_OUTER_L4_UDP;
1574 case RTE_FLOW_ITEM_TYPE_VXLAN:
1575 flow_verbs_translate_item_vxlan(dev_flow, items,
1577 subpriority = MLX5_PRIORITY_MAP_L2;
1578 item_flags |= MLX5_FLOW_LAYER_VXLAN;
1580 case RTE_FLOW_ITEM_TYPE_VXLAN_GPE:
1581 flow_verbs_translate_item_vxlan_gpe(dev_flow, items,
1583 subpriority = MLX5_PRIORITY_MAP_L2;
1584 item_flags |= MLX5_FLOW_LAYER_VXLAN_GPE;
1586 case RTE_FLOW_ITEM_TYPE_GRE:
1587 flow_verbs_translate_item_gre(dev_flow, items,
1589 subpriority = MLX5_PRIORITY_MAP_L2;
1590 item_flags |= MLX5_FLOW_LAYER_GRE;
1592 case RTE_FLOW_ITEM_TYPE_MPLS:
1593 flow_verbs_translate_item_mpls(dev_flow, items,
1595 subpriority = MLX5_PRIORITY_MAP_L2;
1596 item_flags |= MLX5_FLOW_LAYER_MPLS;
1599 return rte_flow_error_set(error, ENOTSUP,
1600 RTE_FLOW_ERROR_TYPE_ITEM,
1602 "item not supported");
1605 dev_flow->layers = item_flags;
1606 dev_flow->verbs.attr->priority =
1607 mlx5_flow_adjust_priority(dev, priority, subpriority);
1608 dev_flow->verbs.attr->port = (uint8_t)priv->ibv_port;
1613 * Remove the flow from the NIC but keeps it in memory.
1616 * Pointer to the Ethernet device structure.
1617 * @param[in, out] flow
1618 * Pointer to flow structure.
1621 flow_verbs_remove(struct rte_eth_dev *dev, struct rte_flow *flow)
1623 struct mlx5_flow_verbs *verbs;
1624 struct mlx5_flow *dev_flow;
1628 LIST_FOREACH(dev_flow, &flow->dev_flows, next) {
1629 verbs = &dev_flow->verbs;
1631 claim_zero(mlx5_glue->destroy_flow(verbs->flow));
1635 if (dev_flow->actions & MLX5_FLOW_ACTION_DROP)
1636 mlx5_hrxq_drop_release(dev);
1638 mlx5_hrxq_release(dev, verbs->hrxq);
1641 if (dev_flow->verbs.vf_vlan.tag &&
1642 dev_flow->verbs.vf_vlan.created) {
1643 mlx5_vlan_vmwa_release(dev, &dev_flow->verbs.vf_vlan);
1649 * Remove the flow from the NIC and the memory.
1652 * Pointer to the Ethernet device structure.
1653 * @param[in, out] flow
1654 * Pointer to flow structure.
1657 flow_verbs_destroy(struct rte_eth_dev *dev, struct rte_flow *flow)
1659 struct mlx5_flow *dev_flow;
1663 flow_verbs_remove(dev, flow);
1664 while (!LIST_EMPTY(&flow->dev_flows)) {
1665 dev_flow = LIST_FIRST(&flow->dev_flows);
1666 LIST_REMOVE(dev_flow, next);
1669 if (flow->counter) {
1670 flow_verbs_counter_release(dev, flow->counter);
1671 flow->counter = NULL;
1676 * Apply the flow to the NIC.
1679 * Pointer to the Ethernet device structure.
1680 * @param[in, out] flow
1681 * Pointer to flow structure.
1683 * Pointer to error structure.
1686 * 0 on success, a negative errno value otherwise and rte_errno is set.
1689 flow_verbs_apply(struct rte_eth_dev *dev, struct rte_flow *flow,
1690 struct rte_flow_error *error)
1692 struct mlx5_priv *priv = dev->data->dev_private;
1693 struct mlx5_flow_verbs *verbs;
1694 struct mlx5_flow *dev_flow;
1697 LIST_FOREACH(dev_flow, &flow->dev_flows, next) {
1698 verbs = &dev_flow->verbs;
1699 if (dev_flow->actions & MLX5_FLOW_ACTION_DROP) {
1700 verbs->hrxq = mlx5_hrxq_drop_new(dev);
1704 RTE_FLOW_ERROR_TYPE_UNSPECIFIED, NULL,
1705 "cannot get drop hash queue");
1709 struct mlx5_hrxq *hrxq;
1711 assert(flow->rss.queue);
1712 hrxq = mlx5_hrxq_get(dev, flow->rss.key,
1713 MLX5_RSS_HASH_KEY_LEN,
1714 dev_flow->hash_fields,
1716 flow->rss.queue_num);
1718 hrxq = mlx5_hrxq_new(dev, flow->rss.key,
1719 MLX5_RSS_HASH_KEY_LEN,
1720 dev_flow->hash_fields,
1722 flow->rss.queue_num,
1723 !!(dev_flow->layers &
1724 MLX5_FLOW_LAYER_TUNNEL));
1728 RTE_FLOW_ERROR_TYPE_UNSPECIFIED, NULL,
1729 "cannot get hash queue");
1734 verbs->flow = mlx5_glue->create_flow(verbs->hrxq->qp,
1737 rte_flow_error_set(error, errno,
1738 RTE_FLOW_ERROR_TYPE_UNSPECIFIED,
1740 "hardware refuses to create flow");
1743 if (priv->vmwa_context &&
1744 dev_flow->verbs.vf_vlan.tag &&
1745 !dev_flow->verbs.vf_vlan.created) {
1747 * The rule contains the VLAN pattern.
1748 * For VF we are going to create VLAN
1749 * interface to make hypervisor set correct
1750 * e-Switch vport context.
1752 mlx5_vlan_vmwa_acquire(dev, &dev_flow->verbs.vf_vlan);
1757 err = rte_errno; /* Save rte_errno before cleanup. */
1758 LIST_FOREACH(dev_flow, &flow->dev_flows, next) {
1759 verbs = &dev_flow->verbs;
1761 if (dev_flow->actions & MLX5_FLOW_ACTION_DROP)
1762 mlx5_hrxq_drop_release(dev);
1764 mlx5_hrxq_release(dev, verbs->hrxq);
1767 if (dev_flow->verbs.vf_vlan.tag &&
1768 dev_flow->verbs.vf_vlan.created) {
1769 mlx5_vlan_vmwa_release(dev, &dev_flow->verbs.vf_vlan);
1772 rte_errno = err; /* Restore rte_errno. */
1779 * @see rte_flow_query()
1783 flow_verbs_query(struct rte_eth_dev *dev,
1784 struct rte_flow *flow,
1785 const struct rte_flow_action *actions,
1787 struct rte_flow_error *error)
1791 for (; actions->type != RTE_FLOW_ACTION_TYPE_END; actions++) {
1792 switch (actions->type) {
1793 case RTE_FLOW_ACTION_TYPE_VOID:
1795 case RTE_FLOW_ACTION_TYPE_COUNT:
1796 ret = flow_verbs_counter_query(dev, flow, data, error);
1799 return rte_flow_error_set(error, ENOTSUP,
1800 RTE_FLOW_ERROR_TYPE_ACTION,
1802 "action not supported");
1808 const struct mlx5_flow_driver_ops mlx5_flow_verbs_drv_ops = {
1809 .validate = flow_verbs_validate,
1810 .prepare = flow_verbs_prepare,
1811 .translate = flow_verbs_translate,
1812 .apply = flow_verbs_apply,
1813 .remove = flow_verbs_remove,
1814 .destroy = flow_verbs_destroy,
1815 .query = flow_verbs_query,