Lines Matching refs:queue
60 dump_pkt_burst(uint16_t port_id, uint16_t queue, struct rte_mbuf *pkts[], in dump_pkt_burst() argument
81 port_id, queue, in dump_pkt_burst()
130 printf(" - RSS queue=0x%x", (unsigned int) queue); in dump_pkt_burst()
227 (unsigned int) queue); in dump_pkt_burst()
237 dump_rx_pkts(uint16_t port_id, uint16_t queue, struct rte_mbuf *pkts[], in dump_rx_pkts() argument
241 dump_pkt_burst(port_id, queue, pkts, nb_pkts, 1); in dump_rx_pkts()
246 dump_tx_pkts(uint16_t port_id, uint16_t queue, struct rte_mbuf *pkts[], in dump_tx_pkts() argument
249 dump_pkt_burst(port_id, queue, pkts, nb_pkts, 0); in dump_tx_pkts()
254 tx_pkt_set_md(uint16_t port_id, __rte_unused uint16_t queue, in tx_pkt_set_md() argument
277 uint16_t queue; in add_tx_md_callback() local
287 for (queue = 0; queue < dev_info.nb_tx_queues; queue++) in add_tx_md_callback()
288 if (!ports[portid].tx_set_md_cb[queue]) in add_tx_md_callback()
289 ports[portid].tx_set_md_cb[queue] = in add_tx_md_callback()
290 rte_eth_add_tx_callback(portid, queue, in add_tx_md_callback()
298 uint16_t queue; in remove_tx_md_callback() local
308 for (queue = 0; queue < dev_info.nb_tx_queues; queue++) in remove_tx_md_callback()
309 if (ports[portid].tx_set_md_cb[queue]) { in remove_tx_md_callback()
310 rte_eth_remove_tx_callback(portid, queue, in remove_tx_md_callback()
311 ports[portid].tx_set_md_cb[queue]); in remove_tx_md_callback()
312 ports[portid].tx_set_md_cb[queue] = NULL; in remove_tx_md_callback()
317 tx_pkt_set_dynf(uint16_t port_id, __rte_unused uint16_t queue, in tx_pkt_set_dynf() argument
333 uint16_t queue; in add_tx_dynf_callback() local
343 for (queue = 0; queue < dev_info.nb_tx_queues; queue++) in add_tx_dynf_callback()
344 if (!ports[portid].tx_set_dynf_cb[queue]) in add_tx_dynf_callback()
345 ports[portid].tx_set_dynf_cb[queue] = in add_tx_dynf_callback()
346 rte_eth_add_tx_callback(portid, queue, in add_tx_dynf_callback()
354 uint16_t queue; in remove_tx_dynf_callback() local
364 for (queue = 0; queue < dev_info.nb_tx_queues; queue++) in remove_tx_dynf_callback()
365 if (ports[portid].tx_set_dynf_cb[queue]) { in remove_tx_dynf_callback()
366 rte_eth_remove_tx_callback(portid, queue, in remove_tx_dynf_callback()
367 ports[portid].tx_set_dynf_cb[queue]); in remove_tx_dynf_callback()
368 ports[portid].tx_set_dynf_cb[queue] = NULL; in remove_tx_dynf_callback()