Lines Matching refs:tx_queue_id
922 eth_dev_validate_tx_queue(const struct rte_eth_dev *dev, uint16_t tx_queue_id) in eth_dev_validate_tx_queue() argument
926 if (tx_queue_id >= dev->data->nb_tx_queues) { in eth_dev_validate_tx_queue()
930 tx_queue_id, port_id); in eth_dev_validate_tx_queue()
934 if (dev->data->tx_queues[tx_queue_id] == NULL) { in eth_dev_validate_tx_queue()
938 tx_queue_id, port_id); in eth_dev_validate_tx_queue()
1021 rte_eth_dev_tx_queue_start(uint16_t port_id, uint16_t tx_queue_id) in rte_eth_dev_tx_queue_start() argument
1036 ret = eth_dev_validate_tx_queue(dev, tx_queue_id); in rte_eth_dev_tx_queue_start()
1042 if (rte_eth_dev_is_tx_hairpin_queue(dev, tx_queue_id)) { in rte_eth_dev_tx_queue_start()
1045 tx_queue_id, port_id); in rte_eth_dev_tx_queue_start()
1049 if (dev->data->tx_queue_state[tx_queue_id] != RTE_ETH_QUEUE_STATE_STOPPED) { in rte_eth_dev_tx_queue_start()
1052 tx_queue_id, port_id); in rte_eth_dev_tx_queue_start()
1056 return eth_err(port_id, dev->dev_ops->tx_queue_start(dev, tx_queue_id)); in rte_eth_dev_tx_queue_start()
1060 rte_eth_dev_tx_queue_stop(uint16_t port_id, uint16_t tx_queue_id) in rte_eth_dev_tx_queue_stop() argument
1069 ret = eth_dev_validate_tx_queue(dev, tx_queue_id); in rte_eth_dev_tx_queue_stop()
1075 if (rte_eth_dev_is_tx_hairpin_queue(dev, tx_queue_id)) { in rte_eth_dev_tx_queue_stop()
1078 tx_queue_id, port_id); in rte_eth_dev_tx_queue_stop()
1082 if (dev->data->tx_queue_state[tx_queue_id] == RTE_ETH_QUEUE_STATE_STOPPED) { in rte_eth_dev_tx_queue_stop()
1085 tx_queue_id, port_id); in rte_eth_dev_tx_queue_stop()
1089 return eth_err(port_id, dev->dev_ops->tx_queue_stop(dev, tx_queue_id)); in rte_eth_dev_tx_queue_stop()
2182 rte_eth_tx_queue_setup(uint16_t port_id, uint16_t tx_queue_id, in rte_eth_tx_queue_setup() argument
2195 if (tx_queue_id >= dev->data->nb_tx_queues) { in rte_eth_tx_queue_setup()
2196 RTE_ETHDEV_LOG(ERR, "Invalid TX queue_id=%u\n", tx_queue_id); in rte_eth_tx_queue_setup()
2230 (dev->data->tx_queue_state[tx_queue_id] != in rte_eth_tx_queue_setup()
2235 if (txq[tx_queue_id]) { in rte_eth_tx_queue_setup()
2238 (*dev->dev_ops->tx_queue_release)(txq[tx_queue_id]); in rte_eth_tx_queue_setup()
2239 txq[tx_queue_id] = NULL; in rte_eth_tx_queue_setup()
2270 port_id, tx_queue_id, local_conf.offloads, in rte_eth_tx_queue_setup()
2276 rte_ethdev_trace_txq_setup(port_id, tx_queue_id, nb_tx_desc, tx_conf); in rte_eth_tx_queue_setup()
2278 tx_queue_id, nb_tx_desc, socket_id, &local_conf)); in rte_eth_tx_queue_setup()
2282 rte_eth_tx_hairpin_queue_setup(uint16_t port_id, uint16_t tx_queue_id, in rte_eth_tx_hairpin_queue_setup() argument
2295 if (tx_queue_id >= dev->data->nb_tx_queues) { in rte_eth_tx_hairpin_queue_setup()
2296 RTE_ETHDEV_LOG(ERR, "Invalid TX queue_id=%u\n", tx_queue_id); in rte_eth_tx_hairpin_queue_setup()
2327 if (i == tx_queue_id || rte_eth_dev_is_tx_hairpin_queue(dev, i)) in rte_eth_tx_hairpin_queue_setup()
2338 if (txq[tx_queue_id] != NULL) { in rte_eth_tx_hairpin_queue_setup()
2341 (*dev->dev_ops->tx_queue_release)(txq[tx_queue_id]); in rte_eth_tx_hairpin_queue_setup()
2342 txq[tx_queue_id] = NULL; in rte_eth_tx_hairpin_queue_setup()
2345 (dev, tx_queue_id, nb_tx_desc, conf); in rte_eth_tx_hairpin_queue_setup()
2347 dev->data->tx_queue_state[tx_queue_id] = in rte_eth_tx_hairpin_queue_setup()
3218 rte_eth_dev_set_tx_queue_stats_mapping(uint16_t port_id, uint16_t tx_queue_id, in rte_eth_dev_set_tx_queue_stats_mapping() argument
3222 tx_queue_id, in rte_eth_dev_set_tx_queue_stats_mapping()