Lines Matching refs:rx_queue_id
663 eth_dev_validate_rx_queue(const struct rte_eth_dev *dev, uint16_t rx_queue_id) in eth_dev_validate_rx_queue() argument
667 if (rx_queue_id >= dev->data->nb_rx_queues) { in eth_dev_validate_rx_queue()
671 rx_queue_id, port_id); in eth_dev_validate_rx_queue()
675 if (dev->data->rx_queues[rx_queue_id] == NULL) { in eth_dev_validate_rx_queue()
679 rx_queue_id, port_id); in eth_dev_validate_rx_queue()
711 rte_eth_dev_rx_queue_start(uint16_t port_id, uint16_t rx_queue_id) in rte_eth_dev_rx_queue_start() argument
726 ret = eth_dev_validate_rx_queue(dev, rx_queue_id); in rte_eth_dev_rx_queue_start()
732 if (rte_eth_dev_is_rx_hairpin_queue(dev, rx_queue_id)) { in rte_eth_dev_rx_queue_start()
735 rx_queue_id, port_id); in rte_eth_dev_rx_queue_start()
739 if (dev->data->rx_queue_state[rx_queue_id] != RTE_ETH_QUEUE_STATE_STOPPED) { in rte_eth_dev_rx_queue_start()
742 rx_queue_id, port_id); in rte_eth_dev_rx_queue_start()
746 return eth_err(port_id, dev->dev_ops->rx_queue_start(dev, rx_queue_id)); in rte_eth_dev_rx_queue_start()
750 rte_eth_dev_rx_queue_stop(uint16_t port_id, uint16_t rx_queue_id) in rte_eth_dev_rx_queue_stop() argument
758 ret = eth_dev_validate_rx_queue(dev, rx_queue_id); in rte_eth_dev_rx_queue_stop()
764 if (rte_eth_dev_is_rx_hairpin_queue(dev, rx_queue_id)) { in rte_eth_dev_rx_queue_stop()
767 rx_queue_id, port_id); in rte_eth_dev_rx_queue_stop()
771 if (dev->data->rx_queue_state[rx_queue_id] == RTE_ETH_QUEUE_STATE_STOPPED) { in rte_eth_dev_rx_queue_stop()
774 rx_queue_id, port_id); in rte_eth_dev_rx_queue_stop()
778 return eth_err(port_id, dev->dev_ops->rx_queue_stop(dev, rx_queue_id)); in rte_eth_dev_rx_queue_stop()
1710 rte_eth_rx_queue_setup(uint16_t port_id, uint16_t rx_queue_id, in rte_eth_rx_queue_setup() argument
1724 if (rx_queue_id >= dev->data->nb_rx_queues) { in rte_eth_rx_queue_setup()
1725 RTE_ETHDEV_LOG(ERR, "Invalid Rx queue_id=%u\n", rx_queue_id); in rte_eth_rx_queue_setup()
1819 (dev->data->rx_queue_state[rx_queue_id] != in rte_eth_rx_queue_setup()
1823 eth_dev_rxq_release(dev, rx_queue_id); in rte_eth_rx_queue_setup()
1853 port_id, rx_queue_id, local_conf.offloads, in rte_eth_rx_queue_setup()
1863 port_id, rx_queue_id, local_conf.share_group); in rte_eth_rx_queue_setup()
1890 ret = (*dev->dev_ops->rx_queue_setup)(dev, rx_queue_id, nb_rx_desc, in rte_eth_rx_queue_setup()
1898 rte_ethdev_trace_rxq_setup(port_id, rx_queue_id, nb_rx_desc, mp, in rte_eth_rx_queue_setup()
1904 rte_eth_rx_hairpin_queue_setup(uint16_t port_id, uint16_t rx_queue_id, in rte_eth_rx_hairpin_queue_setup() argument
1917 if (rx_queue_id >= dev->data->nb_rx_queues) { in rte_eth_rx_hairpin_queue_setup()
1918 RTE_ETHDEV_LOG(ERR, "Invalid Rx queue_id=%u\n", rx_queue_id); in rte_eth_rx_hairpin_queue_setup()
1957 if (i == rx_queue_id || rte_eth_dev_is_rx_hairpin_queue(dev, i)) in rte_eth_rx_hairpin_queue_setup()
1967 eth_dev_rxq_release(dev, rx_queue_id); in rte_eth_rx_hairpin_queue_setup()
1968 ret = (*dev->dev_ops->rx_hairpin_queue_setup)(dev, rx_queue_id, in rte_eth_rx_hairpin_queue_setup()
1971 dev->data->rx_queue_state[rx_queue_id] = in rte_eth_rx_hairpin_queue_setup()
3066 rte_eth_dev_set_rx_queue_stats_mapping(uint16_t port_id, uint16_t rx_queue_id, in rte_eth_dev_set_rx_queue_stats_mapping() argument
3070 rx_queue_id, in rte_eth_dev_set_rx_queue_stats_mapping()
3444 rte_eth_dev_set_vlan_strip_on_queue(uint16_t port_id, uint16_t rx_queue_id, in rte_eth_dev_set_vlan_strip_on_queue() argument
3452 if (rx_queue_id >= dev->data->nb_rx_queues) { in rte_eth_dev_set_vlan_strip_on_queue()
3453 RTE_ETHDEV_LOG(ERR, "Invalid rx_queue_id=%u\n", rx_queue_id); in rte_eth_dev_set_vlan_strip_on_queue()
3458 (*dev->dev_ops->vlan_strip_queue_set)(dev, rx_queue_id, on); in rte_eth_dev_set_vlan_strip_on_queue()