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

[Anna A <pacman.n908@gmail.com>]

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.
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?

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