Re: Using rte_flow to distribute single flow type among multiple Rx queues using DPDK in Mellanox ConnectX-5 Ex

[Thomas Monjalon <thomas@monjalon.net>]

29/09/2021 07:26, Anna A:
> Hi,
> 
> I'm trying to use rte_flow_action_type_rss to distribute packets all of the
> same flow type among multiple Rx queues on a single port. Mellanox
> ConnectX-5 Ex and DPDK version 20.05 is used for this purpose. It doesn't
> seem to work and all the packets are sent only to a single queue.

Adding mlx5 maintainers Cc.

> My queries are :
> 1. What am I missing or doing differently?
> 2. Should I be doing any other configurations in rte_eth_conf or
> rte_eth_rxmode?

Do you see any error log?
For info, you can change log level with --log-level.
Experiment options with '--log-level help' in recent DPDK.

> My rte_flow configurations:
> 
>     struct rte_flow_item pattern[MAX_RTE_FLOW_PATTERN] = {};
>     struct rte_flow_action action[MAX_RTE_FLOW_ACTIONS] = {};
>     struct rte_flow_attr attr;
>     struct rte_flow_item_eth eth;
>     struct rte_flow *flow = NULL;
>     struct rte_flow_error error;
>     int ret;
>     int no_queues =2;
>     uint16_t queues[2];
>     struct rte_flow_action_rss rss;
>     memset(&error, 0x22, sizeof(error));
>     memset(&attr, 0, sizeof(attr));
>     attr.egress = 0;
>     attr.ingress = 1;
> 
>     memset(&pattern, 0, sizeof(pattern));
>     memset(&action, 0, sizeof(action));
>     /* setting the eth to pass all packets */
>     pattern[0].type = RTE_FLOW_ITEM_TYPE_ETH;
>     pattern[0].spec = ð
>     pattern[1].type = RTE_FLOW_ITEM_TYPE_END;
> 
>     rss.types = ETH_RSS_IP;
>     rss.level = 0;
>     rss.func = RTE_ETH_HASH_FUNCTION_TOEPLITZ;
>     rss.key_len =0;
>     rss.key = NULL;
>     rss.queue_num = no_queues;
>     for (int i= 0; i < no_queues; i++){
>         queues[i] = i;
>     }
>     rss.queue = queues;
>     action[0].type = RTE_FLOW_ACTION_TYPE_RSS;
>     action[0].conf = &rss;
> 
>     action[1].type = RTE_FLOW_ACTION_TYPE_END;
> 
>     ret = rte_flow_validate(portid, &attr, pattern, action, &error);
>      if (ret < 0) {
>       printf( "Flow validation failed %s\n", error.message);
>         return;
>     }
>     flow = rte_flow_create(portid, &attr, pattern, action, &error);
> 
>     if (flow == NULL)
>         printf(" Cannot create Flow create");
> 
> And Rx queues configuration:
> for (int j = 0; j < no_queues; j++) {
> 
>          int ret = rte_eth_rx_queue_setup(portid, j, nb_rxd,
> rte_eth_dev_socket_id(port_id),
>                                NULL,mbuf_pool);
>      if (ret < 0) {
>       printf( "rte_eth_rx_queue_setup:err=%d, port=%u", ret, (unsigned)
> portid);
>         exit(1);
>        }
> }
> 
> Thanks
> Anna