Lines Matching refs:queue
71 dump_pkt_burst(uint16_t port_id, uint16_t queue, struct rte_mbuf *pkts[], in dump_pkt_burst() argument
95 "port %u/queue %u: %s %u packets\n", port_id, queue, in dump_pkt_burst()
162 " - RSS queue=0x%x", (unsigned int) queue); in dump_pkt_burst()
279 (unsigned int) queue); in dump_pkt_burst()
300 dump_rx_pkts(uint16_t port_id, uint16_t queue, struct rte_mbuf *pkts[], in dump_rx_pkts() argument
304 dump_pkt_burst(port_id, queue, pkts, nb_pkts, 1); in dump_rx_pkts()
309 dump_tx_pkts(uint16_t port_id, uint16_t queue, struct rte_mbuf *pkts[], in dump_tx_pkts() argument
312 dump_pkt_burst(port_id, queue, pkts, nb_pkts, 0); in dump_tx_pkts()
317 tx_pkt_set_md(uint16_t port_id, __rte_unused uint16_t queue, in tx_pkt_set_md() argument
340 uint16_t queue; in add_tx_md_callback() local
350 for (queue = 0; queue < dev_info.nb_tx_queues; queue++) in add_tx_md_callback()
351 if (!ports[portid].tx_set_md_cb[queue]) in add_tx_md_callback()
352 ports[portid].tx_set_md_cb[queue] = in add_tx_md_callback()
353 rte_eth_add_tx_callback(portid, queue, in add_tx_md_callback()
361 uint16_t queue; in remove_tx_md_callback() local
371 for (queue = 0; queue < dev_info.nb_tx_queues; queue++) in remove_tx_md_callback()
372 if (ports[portid].tx_set_md_cb[queue]) { in remove_tx_md_callback()
373 rte_eth_remove_tx_callback(portid, queue, in remove_tx_md_callback()
374 ports[portid].tx_set_md_cb[queue]); in remove_tx_md_callback()
375 ports[portid].tx_set_md_cb[queue] = NULL; in remove_tx_md_callback()
380 tx_pkt_set_dynf(uint16_t port_id, __rte_unused uint16_t queue, in tx_pkt_set_dynf() argument
396 uint16_t queue; in add_tx_dynf_callback() local
406 for (queue = 0; queue < dev_info.nb_tx_queues; queue++) in add_tx_dynf_callback()
407 if (!ports[portid].tx_set_dynf_cb[queue]) in add_tx_dynf_callback()
408 ports[portid].tx_set_dynf_cb[queue] = in add_tx_dynf_callback()
409 rte_eth_add_tx_callback(portid, queue, in add_tx_dynf_callback()
417 uint16_t queue; in remove_tx_dynf_callback() local
427 for (queue = 0; queue < dev_info.nb_tx_queues; queue++) in remove_tx_dynf_callback()
428 if (ports[portid].tx_set_dynf_cb[queue]) { in remove_tx_dynf_callback()
429 rte_eth_remove_tx_callback(portid, queue, in remove_tx_dynf_callback()
430 ports[portid].tx_set_dynf_cb[queue]); in remove_tx_dynf_callback()
431 ports[portid].tx_set_dynf_cb[queue] = NULL; in remove_tx_dynf_callback()