Lines Matching refs:qconf

162 send_burst(struct lcore_queue_conf *qconf, uint16_t port)  in send_burst()  argument
168 queueid = qconf->tx_queue_id[port]; in send_burst()
169 m_table = (struct rte_mbuf **)qconf->tx_mbufs[port].m_table; in send_burst()
170 n = qconf->tx_mbufs[port].len; in send_burst()
178 qconf->tx_mbufs[port].len = 0; in send_burst()
275 struct lcore_queue_conf *qconf, uint16_t port) in mcast_send_pkt() argument
290 len = qconf->tx_mbufs[port].len; in mcast_send_pkt()
291 qconf->tx_mbufs[port].m_table[len] = pkt; in mcast_send_pkt()
292 qconf->tx_mbufs[port].len = ++len; in mcast_send_pkt()
296 send_burst(qconf, port); in mcast_send_pkt()
302 mcast_forward(struct rte_mbuf *m, struct lcore_queue_conf *qconf) in mcast_forward() argument
359 qconf, port); in mcast_forward()
371 mcast_send_pkt(m, &dst_eth_addr.as_addr, qconf, port); in mcast_forward()
378 send_timeout_burst(struct lcore_queue_conf *qconf) in send_timeout_burst() argument
385 if (likely (cur_tsc < qconf->tx_tsc + drain_tsc)) in send_timeout_burst()
389 if (qconf->tx_mbufs[portid].len != 0) in send_timeout_burst()
390 send_burst(qconf, portid); in send_timeout_burst()
392 qconf->tx_tsc = cur_tsc; in send_timeout_burst()
403 struct lcore_queue_conf *qconf; in main_loop() local
406 qconf = &lcore_queue_conf[lcore_id]; in main_loop()
409 if (qconf->n_rx_queue == 0) { in main_loop()
418 for (i = 0; i < qconf->n_rx_queue; i++) { in main_loop()
420 portid = qconf->rx_queue_list[i]; in main_loop()
430 for (i = 0; i < qconf->n_rx_queue; i++) { in main_loop()
432 portid = qconf->rx_queue_list[i]; in main_loop()
446 mcast_forward(pkts_burst[j], qconf); in main_loop()
451 mcast_forward(pkts_burst[j], qconf); in main_loop()
456 send_timeout_burst(qconf); in main_loop()
648 struct lcore_queue_conf *qconf; in main() local
708 qconf = &lcore_queue_conf[rx_lcore_id]; in main()
723 qconf->n_rx_queue == (unsigned)rx_queue_per_lcore) { in main()
726 qconf = &lcore_queue_conf[rx_lcore_id]; in main()
731 qconf->rx_queue_list[qconf->n_rx_queue] = portid; in main()
732 qconf->n_rx_queue++; in main()
796 qconf = &lcore_queue_conf[lcore_id]; in main()
797 qconf->tx_queue_id[portid] = queueid; in main()