Lines Matching refs:qconf

251 send_burst(struct lcore_queue_conf *qconf, uint32_t thresh, uint16_t port)  in send_burst()  argument
256 txmb = qconf->tx_mbufs[port]; in send_burst()
265 k = rte_eth_tx_burst(port, qconf->tx_queue_id[port], in send_burst()
268 TX_LCORE_STAT_UPDATE(&qconf->tx_stat, call, 1); in send_burst()
269 TX_LCORE_STAT_UPDATE(&qconf->tx_stat, send, k); in send_burst()
284 struct lcore_queue_conf *qconf; in send_single_packet() local
288 qconf = &lcore_queue_conf[lcore_id]; in send_single_packet()
290 txmb = qconf->tx_mbufs[port]; in send_single_packet()
293 fill = send_burst(qconf, MAX_PKT_BURST, port); in send_single_packet()
296 TX_LCORE_STAT_UPDATE(&qconf->tx_stat, drop, 1); in send_single_packet()
302 TX_LCORE_STAT_UPDATE(&qconf->tx_stat, queue, 1); in send_single_packet()
312 struct lcore_queue_conf *qconf, uint64_t tms) in reassemble() argument
322 rxq = &qconf->rx_queue_list[queue]; in reassemble()
340 dr = &qconf->death_row; in reassemble()
385 dr = &qconf->death_row; in reassemble()
433 struct lcore_queue_conf *qconf; in main_loop() local
439 qconf = &lcore_queue_conf[lcore_id]; in main_loop()
441 if (qconf->n_rx_queue == 0) { in main_loop()
448 for (i = 0; i < qconf->n_rx_queue; i++) { in main_loop()
450 portid = qconf->rx_queue_list[i].portid; in main_loop()
471 send_burst(qconf, 1, portid); in main_loop()
480 for (i = 0; i < qconf->n_rx_queue; ++i) { in main_loop()
482 portid = qconf->rx_queue_list[i].portid; in main_loop()
498 i, qconf, cur_tsc); in main_loop()
504 i, qconf, cur_tsc); in main_loop()
507 rte_ip_frag_free_death_row(&qconf->death_row, in main_loop()
824 setup_port_tbl(struct lcore_queue_conf *qconf, uint32_t lcore, int socket, in setup_port_tbl() argument
843 qconf->tx_mbufs[port] = mtb; in setup_port_tbl()
961 const struct lcore_queue_conf *qconf; in queue_dump_stat() local
967 qconf = &lcore_queue_conf[lcore]; in queue_dump_stat()
968 for (i = 0; i < qconf->n_rx_queue; i++) { in queue_dump_stat()
972 lcore, qconf->rx_queue_list[i].portid); in queue_dump_stat()
974 qconf->rx_queue_list[i].frag_tbl); in queue_dump_stat()
979 qconf->tx_stat.call, in queue_dump_stat()
980 qconf->tx_stat.queue, in queue_dump_stat()
981 qconf->tx_stat.drop, in queue_dump_stat()
982 qconf->tx_stat.send); in queue_dump_stat()
998 struct lcore_queue_conf *qconf; in main() local
1046 qconf = &lcore_queue_conf[rx_lcore_id]; in main()
1061 qconf->n_rx_queue == (unsigned)rx_queue_per_lcore) { in main()
1067 qconf = &lcore_queue_conf[rx_lcore_id]; in main()
1074 queueid = qconf->n_rx_queue; in main()
1075 rxq = &qconf->rx_queue_list[queueid]; in main()
1089 qconf->n_rx_queue++; in main()
1166 qconf = &lcore_queue_conf[lcore_id]; in main()
1167 qconf->tx_queue_id[portid] = queueid; in main()
1168 setup_port_tbl(qconf, lcore_id, socket, portid); in main()