Lines Matching refs:rx_thread
602 struct thread_rx_conf rx_thread[MAX_RX_THREAD]; variable
1921 thread_conf = &rx_thread[i].conf; in cpu_load_collector()
2235 rx_thread[i].conf.thread_id = i; in lthread_spawner()
2237 (void *)&rx_thread[i]); in lthread_spawner()
2459 if (rx_thread[i].conf.lcore_id == lcore_id) { in pthread_run()
2462 RTE_PER_LCORE(lcore_conf)->data = (void *)&rx_thread[i]; in pthread_run()
2463 pthread_rx((void *)&rx_thread[i]); in pthread_run()
2568 rx_conf = &rx_thread[rx_thread_id]; in init_rx_rings()
2602 nb_rx_queue = rx_thread[thread].n_rx_queue; in init_rx_queues()
2610 rx_thread[thread].conf.thread_id = thread; in init_rx_queues()
2611 rx_thread[thread].conf.lcore_id = rx_thread_params[i].lcore_id; in init_rx_queues()
2612 rx_thread[thread].rx_queue_list[nb_rx_queue].port_id = in init_rx_queues()
2614 rx_thread[thread].rx_queue_list[nb_rx_queue].queue_id = in init_rx_queues()
2616 rx_thread[thread].n_rx_queue++; in init_rx_queues()
3656 lcore_id = rx_thread[i].conf.lcore_id; in main()
3670 for (queue = 0; queue < rx_thread[i].n_rx_queue; ++queue) { in main()
3673 portid = rx_thread[i].rx_queue_list[queue].port_id; in main()
3674 queueid = rx_thread[i].rx_queue_list[queue].queue_id; in main()
3731 lcore_id = rx_thread[i].conf.lcore_id; in main()
3736 for (queue = 0; queue < rx_thread[i].n_rx_queue; ++queue) { in main()
3737 portid = rx_thread[i].rx_queue_list[queue].port_id; in main()
3738 queueid = rx_thread[i].rx_queue_list[queue].queue_id; in main()