Lines Matching defs:queue_id
770 "Invalid Rx queue_id=%u of device with port_id=%u",
794 "Invalid Tx queue_id=%u of device with port_id=%u",
811 rte_eth_rx_queue_is_valid(uint16_t port_id, uint16_t queue_id)
818 return eth_dev_validate_rx_queue(dev, queue_id);
822 rte_eth_tx_queue_is_valid(uint16_t port_id, uint16_t queue_id)
829 return eth_dev_validate_tx_queue(dev, queue_id);
2243 RTE_ETHDEV_LOG_LINE(ERR, "Invalid Rx queue_id=%u", rx_queue_id);
2457 RTE_ETHDEV_LOG_LINE(ERR, "Invalid Rx queue_id=%u", rx_queue_id);
2562 RTE_ETHDEV_LOG_LINE(ERR, "Invalid Tx queue_id=%u", tx_queue_id);
2666 RTE_ETHDEV_LOG_LINE(ERR, "Invalid Tx queue_id=%u", tx_queue_id);
2905 rte_eth_tx_done_cleanup(uint16_t port_id, uint16_t queue_id, uint32_t free_cnt)
2914 ret = eth_dev_validate_tx_queue(dev, queue_id);
2923 ret = (*dev->dev_ops->tx_done_cleanup)(dev->data->tx_queues[queue_id],
2927 rte_eth_trace_tx_done_cleanup(port_id, queue_id, free_cnt, ret);
3780 eth_dev_set_queue_stats_mapping(uint16_t port_id, uint16_t queue_id,
3788 if (is_rx && (queue_id >= dev->data->nb_rx_queues))
3791 if (!is_rx && (queue_id >= dev->data->nb_tx_queues))
3799 return (*dev->dev_ops->queue_stats_mapping_set) (dev, queue_id, stat_idx, is_rx);
5449 int rte_eth_rx_avail_thresh_set(uint16_t port_id, uint16_t queue_id,
5458 if (queue_id > dev->data->nb_rx_queues) {
5461 port_id, queue_id);
5474 queue_id, avail_thresh));
5476 rte_eth_trace_rx_avail_thresh_set(port_id, queue_id, avail_thresh, ret);
5481 int rte_eth_rx_avail_thresh_query(uint16_t port_id, uint16_t *queue_id,
5490 if (queue_id == NULL)
5492 if (*queue_id >= dev->data->nb_rx_queues)
5493 *queue_id = 0;
5498 queue_id, avail_thresh));
5500 rte_eth_trace_rx_avail_thresh_query(port_id, *queue_id, ret);
5695 rte_eth_dev_rx_intr_ctl_q_get_fd(uint16_t port_id, uint16_t queue_id)
5706 if (queue_id >= dev->data->nb_rx_queues) {
5707 RTE_ETHDEV_LOG_LINE(ERR, "Invalid Rx queue_id=%u", queue_id);
5722 vec = rte_intr_vec_list_index_get(intr_handle, queue_id);
5727 rte_ethdev_trace_rx_intr_ctl_q_get_fd(port_id, queue_id, fd);
5733 rte_eth_dev_rx_intr_ctl_q(uint16_t port_id, uint16_t queue_id,
5744 if (queue_id >= dev->data->nb_rx_queues) {
5745 RTE_ETHDEV_LOG_LINE(ERR, "Invalid Rx queue_id=%u", queue_id);
5760 vec = rte_intr_vec_list_index_get(intr_handle, queue_id);
5763 rte_ethdev_trace_rx_intr_ctl_q(port_id, queue_id, epfd, op, data, rc);
5768 port_id, queue_id, op, epfd, vec);
5777 uint16_t queue_id)
5785 ret = eth_dev_validate_rx_queue(dev, queue_id);
5791 ret = eth_err(port_id, (*dev->dev_ops->rx_queue_intr_enable)(dev, queue_id));
5793 rte_ethdev_trace_rx_intr_enable(port_id, queue_id, ret);
5800 uint16_t queue_id)
5808 ret = eth_dev_validate_rx_queue(dev, queue_id);
5814 ret = eth_err(port_id, (*dev->dev_ops->rx_queue_intr_disable)(dev, queue_id));
5816 rte_ethdev_trace_rx_intr_disable(port_id, queue_id, ret);
5823 rte_eth_add_rx_callback(uint16_t port_id, uint16_t queue_id,
5834 queue_id >= rte_eth_devices[port_id].data->nb_rx_queues) {
5839 if (rte_eth_dev_is_rx_hairpin_queue(dev, queue_id)) {
5856 rte_eth_devices[port_id].post_rx_burst_cbs[queue_id];
5863 &rte_eth_devices[port_id].post_rx_burst_cbs[queue_id],
5876 rte_eth_trace_add_rx_callback(port_id, queue_id, fn, user_param, cb);
5882 rte_eth_add_first_rx_callback(uint16_t port_id, uint16_t queue_id,
5891 queue_id >= rte_eth_devices[port_id].data->nb_rx_queues) {
5908 cb->next = rte_eth_devices[port_id].post_rx_burst_cbs[queue_id];
5913 &rte_eth_devices[port_id].post_rx_burst_cbs[queue_id],
5917 rte_eth_trace_add_first_rx_callback(port_id, queue_id, fn, user_param,
5924 rte_eth_add_tx_callback(uint16_t port_id, uint16_t queue_id,
5935 queue_id >= rte_eth_devices[port_id].data->nb_tx_queues) {
5941 if (rte_eth_dev_is_tx_hairpin_queue(dev, queue_id)) {
5959 rte_eth_devices[port_id].pre_tx_burst_cbs[queue_id];
5966 &rte_eth_devices[port_id].pre_tx_burst_cbs[queue_id],
5979 rte_eth_trace_add_tx_callback(port_id, queue_id, fn, user_param, cb);
5985 rte_eth_remove_rx_callback(uint16_t port_id, uint16_t queue_id,
5994 queue_id >= rte_eth_devices[port_id].data->nb_rx_queues)
6003 prev_cb = &dev->post_rx_burst_cbs[queue_id];
6015 rte_eth_trace_remove_rx_callback(port_id, queue_id, user_cb, ret);
6021 rte_eth_remove_tx_callback(uint16_t port_id, uint16_t queue_id,
6030 queue_id >= rte_eth_devices[port_id].data->nb_tx_queues)
6039 prev_cb = &dev->pre_tx_burst_cbs[queue_id];
6051 rte_eth_trace_remove_tx_callback(port_id, queue_id, user_cb, ret);
6057 rte_eth_rx_queue_info_get(uint16_t port_id, uint16_t queue_id,
6065 if (queue_id >= dev->data->nb_rx_queues) {
6066 RTE_ETHDEV_LOG_LINE(ERR, "Invalid Rx queue_id=%u", queue_id);
6072 port_id, queue_id);
6077 dev->data->rx_queues[queue_id] == NULL) {
6081 queue_id, port_id);
6085 if (rte_eth_dev_is_rx_hairpin_queue(dev, queue_id)) {
6088 queue_id, port_id);
6096 dev->dev_ops->rxq_info_get(dev, queue_id, qinfo);
6097 qinfo->queue_state = dev->data->rx_queue_state[queue_id];
6099 rte_eth_trace_rx_queue_info_get(port_id, queue_id, qinfo);
6105 rte_eth_tx_queue_info_get(uint16_t port_id, uint16_t queue_id,
6113 if (queue_id >= dev->data->nb_tx_queues) {
6114 RTE_ETHDEV_LOG_LINE(ERR, "Invalid Tx queue_id=%u", queue_id);
6120 port_id, queue_id);
6125 dev->data->tx_queues[queue_id] == NULL) {
6129 queue_id, port_id);
6133 if (rte_eth_dev_is_tx_hairpin_queue(dev, queue_id)) {
6136 queue_id, port_id);
6144 dev->dev_ops->txq_info_get(dev, queue_id, qinfo);
6145 qinfo->queue_state = dev->data->tx_queue_state[queue_id];
6147 rte_eth_trace_tx_queue_info_get(port_id, queue_id, qinfo);
6153 rte_eth_recycle_rx_queue_info_get(uint16_t port_id, uint16_t queue_id,
6162 ret = eth_dev_validate_rx_queue(dev, queue_id);
6169 dev->dev_ops->recycle_rxq_info_get(dev, queue_id, recycle_rxq_info);
6175 rte_eth_rx_burst_mode_get(uint16_t port_id, uint16_t queue_id,
6184 if (queue_id >= dev->data->nb_rx_queues) {
6185 RTE_ETHDEV_LOG_LINE(ERR, "Invalid Rx queue_id=%u", queue_id);
6192 port_id, queue_id);
6200 dev->dev_ops->rx_burst_mode_get(dev, queue_id, mode));
6202 rte_eth_trace_rx_burst_mode_get(port_id, queue_id, mode, ret);
6208 rte_eth_tx_burst_mode_get(uint16_t port_id, uint16_t queue_id,
6217 if (queue_id >= dev->data->nb_tx_queues) {
6218 RTE_ETHDEV_LOG_LINE(ERR, "Invalid Tx queue_id=%u", queue_id);
6225 port_id, queue_id);
6233 dev->dev_ops->tx_burst_mode_get(dev, queue_id, mode));
6235 rte_eth_trace_tx_burst_mode_get(port_id, queue_id, mode, ret);
6241 rte_eth_get_monitor_addr(uint16_t port_id, uint16_t queue_id,
6250 if (queue_id >= dev->data->nb_rx_queues) {
6251 RTE_ETHDEV_LOG_LINE(ERR, "Invalid Rx queue_id=%u", queue_id);
6258 port_id, queue_id);
6265 dev->dev_ops->get_monitor_addr(dev->data->rx_queues[queue_id], pmc));
6267 rte_eth_trace_get_monitor_addr(port_id, queue_id, pmc, ret);
7003 rte_eth_rx_descriptor_dump(uint16_t port_id, uint16_t queue_id,
7011 if (queue_id >= dev->data->nb_rx_queues) {
7012 RTE_ETHDEV_LOG_LINE(ERR, "Invalid Rx queue_id=%u", queue_id);
7025 queue_id, offset, num, file));
7029 rte_eth_tx_descriptor_dump(uint16_t port_id, uint16_t queue_id,
7037 if (queue_id >= dev->data->nb_tx_queues) {
7038 RTE_ETHDEV_LOG_LINE(ERR, "Invalid Tx queue_id=%u", queue_id);
7051 queue_id, offset, num, file));
7122 RTE_ETHDEV_LOG_LINE(ERR, "Invalid Tx queue_id=%u", tx_queue_id);