Lines Matching refs:tx_queue_id
687 eth_dev_validate_tx_queue(const struct rte_eth_dev *dev, uint16_t tx_queue_id) in eth_dev_validate_tx_queue() argument
691 if (tx_queue_id >= dev->data->nb_tx_queues) { in eth_dev_validate_tx_queue()
695 tx_queue_id, port_id); in eth_dev_validate_tx_queue()
699 if (dev->data->tx_queues[tx_queue_id] == NULL) { in eth_dev_validate_tx_queue()
703 tx_queue_id, port_id); in eth_dev_validate_tx_queue()
782 rte_eth_dev_tx_queue_start(uint16_t port_id, uint16_t tx_queue_id) in rte_eth_dev_tx_queue_start() argument
797 ret = eth_dev_validate_tx_queue(dev, tx_queue_id); in rte_eth_dev_tx_queue_start()
803 if (rte_eth_dev_is_tx_hairpin_queue(dev, tx_queue_id)) { in rte_eth_dev_tx_queue_start()
806 tx_queue_id, port_id); in rte_eth_dev_tx_queue_start()
810 if (dev->data->tx_queue_state[tx_queue_id] != RTE_ETH_QUEUE_STATE_STOPPED) { in rte_eth_dev_tx_queue_start()
813 tx_queue_id, port_id); in rte_eth_dev_tx_queue_start()
817 return eth_err(port_id, dev->dev_ops->tx_queue_start(dev, tx_queue_id)); in rte_eth_dev_tx_queue_start()
821 rte_eth_dev_tx_queue_stop(uint16_t port_id, uint16_t tx_queue_id) in rte_eth_dev_tx_queue_stop() argument
829 ret = eth_dev_validate_tx_queue(dev, tx_queue_id); in rte_eth_dev_tx_queue_stop()
835 if (rte_eth_dev_is_tx_hairpin_queue(dev, tx_queue_id)) { in rte_eth_dev_tx_queue_stop()
838 tx_queue_id, port_id); in rte_eth_dev_tx_queue_stop()
842 if (dev->data->tx_queue_state[tx_queue_id] == RTE_ETH_QUEUE_STATE_STOPPED) { in rte_eth_dev_tx_queue_stop()
845 tx_queue_id, port_id); in rte_eth_dev_tx_queue_stop()
849 return eth_err(port_id, dev->dev_ops->tx_queue_stop(dev, tx_queue_id)); in rte_eth_dev_tx_queue_stop()
1977 rte_eth_tx_queue_setup(uint16_t port_id, uint16_t tx_queue_id, in rte_eth_tx_queue_setup() argument
1989 if (tx_queue_id >= dev->data->nb_tx_queues) { in rte_eth_tx_queue_setup()
1990 RTE_ETHDEV_LOG(ERR, "Invalid Tx queue_id=%u\n", tx_queue_id); in rte_eth_tx_queue_setup()
2024 (dev->data->tx_queue_state[tx_queue_id] != in rte_eth_tx_queue_setup()
2028 eth_dev_txq_release(dev, tx_queue_id); in rte_eth_tx_queue_setup()
2058 port_id, tx_queue_id, local_conf.offloads, in rte_eth_tx_queue_setup()
2064 rte_ethdev_trace_txq_setup(port_id, tx_queue_id, nb_tx_desc, tx_conf); in rte_eth_tx_queue_setup()
2066 tx_queue_id, nb_tx_desc, socket_id, &local_conf)); in rte_eth_tx_queue_setup()
2070 rte_eth_tx_hairpin_queue_setup(uint16_t port_id, uint16_t tx_queue_id, in rte_eth_tx_hairpin_queue_setup() argument
2083 if (tx_queue_id >= dev->data->nb_tx_queues) { in rte_eth_tx_hairpin_queue_setup()
2084 RTE_ETHDEV_LOG(ERR, "Invalid Tx queue_id=%u\n", tx_queue_id); in rte_eth_tx_hairpin_queue_setup()
2123 if (i == tx_queue_id || rte_eth_dev_is_tx_hairpin_queue(dev, i)) in rte_eth_tx_hairpin_queue_setup()
2133 eth_dev_txq_release(dev, tx_queue_id); in rte_eth_tx_hairpin_queue_setup()
2135 (dev, tx_queue_id, nb_tx_desc, conf); in rte_eth_tx_hairpin_queue_setup()
2137 dev->data->tx_queue_state[tx_queue_id] = in rte_eth_tx_hairpin_queue_setup()
3057 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
3061 tx_queue_id, in rte_eth_dev_set_tx_queue_stats_mapping()