275 		  uint16_t rx_queue_id,  in rxa_event_buf_get()  argument
281 		*stats = dev_info->rx_queue[rx_queue_id].stats;  in rxa_event_buf_get()
282 		return dev_info->rx_queue[rx_queue_id].event_buf;  in rxa_event_buf_get()
368 	int rx_queue_id)  in rxa_shared_intr()  argument
377 		rx_queue_id >= RTE_MAX_RXTX_INTR_VEC_ID - 1;  in rxa_shared_intr()
382 	int rx_queue_id)  in rxa_intr_queue()  argument
386 	queue_info = &dev_info->rx_queue[rx_queue_id];  in rxa_intr_queue()
394 	int rx_queue_id)  in rxa_polled_queue()  argument
398 	queue_info = &dev_info->rx_queue[rx_queue_id];  in rxa_polled_queue()
406 rxa_nb_intr_vect(struct eth_device_info *dev_info, int rx_queue_id, int add)  in rxa_nb_intr_vect()  argument
416 	if (rx_queue_id == -1) {  in rxa_nb_intr_vect()
432 		if (!rxa_shared_intr(dev_info, rx_queue_id))  in rxa_nb_intr_vect()
433 			n = add ? !rxa_intr_queue(dev_info, rx_queue_id) :  in rxa_nb_intr_vect()
434 				rxa_intr_queue(dev_info, rx_queue_id);  in rxa_nb_intr_vect()
447 			  struct eth_device_info *dev_info, int rx_queue_id,  in rxa_calc_nb_post_intr_del()  argument
452 	if (rx_queue_id == -1)  in rxa_calc_nb_post_intr_del()
455 		intr_diff = rxa_intr_queue(dev_info, rx_queue_id);  in rxa_calc_nb_post_intr_del()
465 			  struct eth_device_info *dev_info, int rx_queue_id,  in rxa_calc_nb_post_add_intr()  argument
473 	if (rx_queue_id == -1) {  in rxa_calc_nb_post_add_intr()
479 		intr_diff = !rxa_intr_queue(dev_info, rx_queue_id);  in rxa_calc_nb_post_add_intr()
480 		poll_diff = rxa_polled_queue(dev_info, rx_queue_id);  in rxa_calc_nb_post_add_intr()
481 		wrr_len_diff = poll_diff ? dev_info->rx_queue[rx_queue_id].wt :  in rxa_calc_nb_post_add_intr()
495 			  struct eth_device_info *dev_info, int rx_queue_id,  in rxa_calc_nb_post_poll_del()  argument
501 	if (rx_queue_id == -1) {  in rxa_calc_nb_post_poll_del()
505 		poll_diff = rxa_polled_queue(dev_info, rx_queue_id);  in rxa_calc_nb_post_poll_del()
506 		wrr_len_diff = poll_diff ? dev_info->rx_queue[rx_queue_id].wt :  in rxa_calc_nb_post_poll_del()
518 			  struct eth_device_info *dev_info, int rx_queue_id,  in rxa_calc_nb_post_add_poll()  argument
526 	if (rx_queue_id == -1) {  in rxa_calc_nb_post_add_poll()
533 		intr_diff = rxa_intr_queue(dev_info, rx_queue_id);  in rxa_calc_nb_post_add_poll()
534 		poll_diff = !rxa_polled_queue(dev_info, rx_queue_id);  in rxa_calc_nb_post_add_poll()
535 		wrr_len_diff = rxa_polled_queue(dev_info, rx_queue_id) ?  in rxa_calc_nb_post_add_poll()
536 				wt - dev_info->rx_queue[rx_queue_id].wt :  in rxa_calc_nb_post_add_poll()
548 		     struct eth_device_info *dev_info, int rx_queue_id,  in rxa_calc_nb_post_add()  argument
553 		rxa_calc_nb_post_add_poll(rx_adapter, dev_info, rx_queue_id,  in rxa_calc_nb_post_add()
556 		rxa_calc_nb_post_add_intr(rx_adapter, dev_info, rx_queue_id,  in rxa_calc_nb_post_add()
563 		     struct eth_device_info *dev_info, int rx_queue_id,  in rxa_calc_nb_post_del()  argument
567 	rxa_calc_nb_post_poll_del(rx_adapter, dev_info, rx_queue_id, nb_rx_poll,  in rxa_calc_nb_post_del()
569 	rxa_calc_nb_post_intr_del(rx_adapter, dev_info, rx_queue_id,  in rxa_calc_nb_post_del()
923 		 uint16_t rx_queue_id, struct rte_mbuf **mbufs, uint16_t num,  in rxa_buffer_mbufs()  argument
931 					&dev_info->rx_queue[rx_queue_id];  in rxa_buffer_mbufs()
981 		nb_cb = dev_info->cb_fn(eth_dev_id, rx_queue_id,  in rxa_buffer_mbufs()
1129 			  uint16_t rx_queue_id)  in rxa_intr_ring_del_entries()  argument
1139 		if (!rxa_shared_intr(dev_info, rx_queue_id)) {  in rxa_intr_ring_del_entries()
1141 				qd.queue == rx_queue_id)  in rxa_intr_ring_del_entries()
1626 		 struct eth_device_info *dev_info, uint16_t rx_queue_id)  in rxa_disable_intr()  argument
1630 	int sintr = rxa_shared_intr(dev_info, rx_queue_id);  in rxa_disable_intr()
1632 	err = rte_eth_dev_rx_intr_disable(eth_dev_id, rx_queue_id);  in rxa_disable_intr()
1635 			rx_queue_id);  in rxa_disable_intr()
1639 	err = rte_eth_dev_rx_intr_ctl_q(eth_dev_id, rx_queue_id,  in rxa_disable_intr()
1647 		dev_info->rx_queue[rx_queue_id].intr_enabled = 0;  in rxa_disable_intr()
1655 		   struct eth_device_info *dev_info, int rx_queue_id)  in rxa_del_intr_queue()  argument
1665 	if (rx_queue_id == -1) {  in rxa_del_intr_queue()
1686 		if (!rxa_intr_queue(dev_info, rx_queue_id))  in rxa_del_intr_queue()
1688 		if (!rxa_shared_intr(dev_info, rx_queue_id) ||  in rxa_del_intr_queue()
1691 					rx_queue_id);  in rxa_del_intr_queue()
1695 						rx_queue_id);  in rxa_del_intr_queue()
1699 			if (dev_info->intr_queue[i] == rx_queue_id) {  in rxa_del_intr_queue()
1713 		struct eth_device_info *dev_info, uint16_t rx_queue_id)  in rxa_config_intr()  argument
1720 	int sintr = rxa_shared_intr(dev_info, rx_queue_id);  in rxa_config_intr()
1722 	if (rxa_intr_queue(dev_info, rx_queue_id))  in rxa_config_intr()
1745 	qd.queue = rx_queue_id;  in rxa_config_intr()
1747 	err = rte_eth_dev_rx_intr_ctl_q(eth_dev_id, rx_queue_id,  in rxa_config_intr()
1753 			" Rx Queue %u err %d", rx_queue_id, err);  in rxa_config_intr()
1757 	err = rte_eth_dev_rx_intr_enable(eth_dev_id, rx_queue_id);  in rxa_config_intr()
1760 				" Rx Queue %u err %d", rx_queue_id, err);  in rxa_config_intr()
1770 			dev_info->rx_queue[rx_queue_id].intr_enabled = 1;  in rxa_config_intr()
1775 	err = rte_eth_dev_rx_intr_disable(eth_dev_id, rx_queue_id);  in rxa_config_intr()
1778 				" Rx Queue %u err %d", rx_queue_id, err);  in rxa_config_intr()
1780 	err1 = rte_eth_dev_rx_intr_ctl_q(eth_dev_id, rx_queue_id,  in rxa_config_intr()
1786 				" Rx Queue %u err %d", rx_queue_id, err1);  in rxa_config_intr()
1802 		   struct eth_device_info *dev_info, int rx_queue_id)  in rxa_add_intr_queue()  argument
1809 	if (rx_queue_id != -1) {  in rxa_add_intr_queue()
1810 		if (rxa_shared_intr(dev_info, rx_queue_id) && shared_done)  in rxa_add_intr_queue()
1812 		return rxa_config_intr(rx_adapter, dev_info, rx_queue_id);  in rxa_add_intr_queue()
1895 		 struct eth_device_info *dev_info, int32_t rx_queue_id,  in rxa_update_queue()  argument
1905 	if (rx_queue_id == -1) {  in rxa_update_queue()
1909 		queue_info = &dev_info->rx_queue[rx_queue_id];  in rxa_update_queue()
1947 	   struct eth_device_info *dev_info, int32_t rx_queue_id)  in rxa_sw_del()  argument
1958 	if (rx_queue_id == -1) {  in rxa_sw_del()
1970 		if (vec->queue != rx_queue_id)  in rxa_sw_del()
1976 	pollq = rxa_polled_queue(dev_info, rx_queue_id);  in rxa_sw_del()
1977 	intrq = rxa_intr_queue(dev_info, rx_queue_id);  in rxa_sw_del()
1978 	sintrq = rxa_shared_intr(dev_info, rx_queue_id);  in rxa_sw_del()
1979 	rxa_update_queue(rx_adapter, dev_info, rx_queue_id, 0);  in rxa_sw_del()
1987 			dev_info->rx_queue[rx_queue_id].event_buf;  in rxa_sw_del()
1989 			dev_info->rx_queue[rx_queue_id].stats;  in rxa_sw_del()
1993 		dev_info->rx_queue[rx_queue_id].event_buf = NULL;  in rxa_sw_del()
1994 		dev_info->rx_queue[rx_queue_id].stats = NULL;  in rxa_sw_del()
2000 	      struct eth_device_info *dev_info, int32_t rx_queue_id,  in rxa_add_queue()  argument
2014 	if (rx_queue_id == -1) {  in rxa_add_queue()
2027 	pollq = rxa_polled_queue(dev_info, rx_queue_id);  in rxa_add_queue()
2028 	intrq = rxa_intr_queue(dev_info, rx_queue_id);  in rxa_add_queue()
2029 	sintrq = rxa_shared_intr(dev_info, rx_queue_id);  in rxa_add_queue()
2031 	queue_info = &dev_info->rx_queue[rx_queue_id];  in rxa_add_queue()
2052 				    rx_queue_id, dev_info->dev->data->port_id);  in rxa_add_queue()
2064 	rxa_update_queue(rx_adapter, dev_info, rx_queue_id, 1);  in rxa_add_queue()
2065 	if (rxa_polled_queue(dev_info, rx_queue_id)) {  in rxa_add_queue()
2073 	if (rxa_intr_queue(dev_info, rx_queue_id)) {  in rxa_add_queue()
2097 				 eth_dev_id, rx_queue_id);  in rxa_add_queue()
2111 				 eth_dev_id, rx_queue_id);  in rxa_add_queue()
2126 				 eth_dev_id, rx_queue_id);  in rxa_add_queue()
2137 	   int rx_queue_id,  in rxa_sw_add()  argument
2168 					 eth_dev_id, rx_queue_id);  in rxa_sw_add()
2189 	rxa_calc_nb_post_add(rx_adapter, dev_info, rx_queue_id,  in rxa_sw_add()
2203 		num_intr_vec = rxa_nb_intr_vect(dev_info, rx_queue_id, 1);  in rxa_sw_add()
2209 		ret = rxa_add_intr_queue(rx_adapter, dev_info, rx_queue_id);  in rxa_sw_add()
2217 						rx_queue_id, 0);  in rxa_sw_add()
2223 						dev_info, rx_queue_id);  in rxa_sw_add()
2238 		if (rx_queue_id  == -1) {  in rxa_sw_add()
2242 			if (!rxa_intr_queue(dev_info, rx_queue_id))  in rxa_sw_add()
2244 					rx_queue_id;  in rxa_sw_add()
2250 	ret = rxa_add_queue(rx_adapter, dev_info, rx_queue_id, queue_conf);  in rxa_sw_add()
2554 		int32_t rx_queue_id,  in rte_event_eth_rx_adapter_queue_add()  argument
2633 		(rx_queue_id != -1)) {  in rte_event_eth_rx_adapter_queue_add()
2640 	if (rx_queue_id != -1 && (uint16_t)rx_queue_id >=  in rte_event_eth_rx_adapter_queue_add()
2643 			 (uint16_t)rx_queue_id);  in rte_event_eth_rx_adapter_queue_add()
2672 				rx_queue_id, queue_conf);  in rte_event_eth_rx_adapter_queue_add()
2677 					rx_queue_id,  in rte_event_eth_rx_adapter_queue_add()
2686 			ret = rxa_sw_add(rx_adapter, eth_dev_id, rx_queue_id,  in rte_event_eth_rx_adapter_queue_add()
2695 		rx_queue_id, queue_conf, ret);  in rte_event_eth_rx_adapter_queue_add()
2715 				int32_t rx_queue_id)  in rte_event_eth_rx_adapter_queue_del()  argument
2743 	if (rx_queue_id != -1 && (uint16_t)rx_queue_id >=  in rte_event_eth_rx_adapter_queue_del()
2746 			 (uint16_t)rx_queue_id);  in rte_event_eth_rx_adapter_queue_del()
2757 						rx_queue_id);  in rte_event_eth_rx_adapter_queue_del()
2761 					rx_queue_id,  in rte_event_eth_rx_adapter_queue_del()
2769 		rxa_calc_nb_post_del(rx_adapter, dev_info, rx_queue_id,  in rte_event_eth_rx_adapter_queue_del()
2783 						rx_queue_id, 0);  in rte_event_eth_rx_adapter_queue_del()
2785 					rx_queue_id);  in rte_event_eth_rx_adapter_queue_del()
2796 		rxa_sw_del(rx_adapter, dev_info, rx_queue_id);  in rte_event_eth_rx_adapter_queue_del()
2834 		rx_queue_id, ret);  in rte_event_eth_rx_adapter_queue_del()
2975 		uint16_t rx_queue_id,  in rte_event_eth_rx_adapter_queue_stats_get()  argument
2999 	if (rx_queue_id >= rte_eth_devices[eth_dev_id].data->nb_rx_queues) {  in rte_event_eth_rx_adapter_queue_stats_get()
3000 		RTE_EDEV_LOG_ERR("Invalid rx queue_id %" PRIu16, rx_queue_id);  in rte_event_eth_rx_adapter_queue_stats_get()
3006 	    !dev_info->rx_queue[rx_queue_id].queue_enabled) {  in rte_event_eth_rx_adapter_queue_stats_get()
3007 		RTE_EDEV_LOG_ERR("Rx queue %u not added", rx_queue_id);  in rte_event_eth_rx_adapter_queue_stats_get()
3012 		queue_info = &dev_info->rx_queue[rx_queue_id];  in rte_event_eth_rx_adapter_queue_stats_get()
3027 						rx_queue_id, stats);  in rte_event_eth_rx_adapter_queue_stats_get()
3082 		uint16_t rx_queue_id)  in rte_event_eth_rx_adapter_queue_stats_reset()  argument
3102 	if (rx_queue_id >= rte_eth_devices[eth_dev_id].data->nb_rx_queues) {  in rte_event_eth_rx_adapter_queue_stats_reset()
3103 		RTE_EDEV_LOG_ERR("Invalid rx queue_id %" PRIu16, rx_queue_id);  in rte_event_eth_rx_adapter_queue_stats_reset()
3110 	    !dev_info->rx_queue[rx_queue_id].queue_enabled) {  in rte_event_eth_rx_adapter_queue_stats_reset()
3111 		RTE_EDEV_LOG_ERR("Rx queue %u not added", rx_queue_id);  in rte_event_eth_rx_adapter_queue_stats_reset()
3116 		queue_info = &dev_info->rx_queue[rx_queue_id];  in rte_event_eth_rx_adapter_queue_stats_reset()
3124 						rx_queue_id);  in rte_event_eth_rx_adapter_queue_stats_reset()
3218 			uint16_t rx_queue_id,  in rte_event_eth_rx_adapter_queue_conf_get()  argument
3234 	if (rx_queue_id >= rte_eth_devices[eth_dev_id].data->nb_rx_queues) {  in rte_event_eth_rx_adapter_queue_conf_get()
3235 		RTE_EDEV_LOG_ERR("Invalid rx queue_id %u", rx_queue_id);  in rte_event_eth_rx_adapter_queue_conf_get()
3250 	    !dev_info->rx_queue[rx_queue_id].queue_enabled) {  in rte_event_eth_rx_adapter_queue_conf_get()
3251 		RTE_EDEV_LOG_ERR("Rx queue %u not added", rx_queue_id);  in rte_event_eth_rx_adapter_queue_conf_get()
3255 	queue_info = &dev_info->rx_queue[rx_queue_id];  in rte_event_eth_rx_adapter_queue_conf_get()
3281 						rx_queue_id,  in rte_event_eth_rx_adapter_queue_conf_get()
3359 	uint16_t rx_queue_id;  in handle_rxa_get_queue_conf()  local
3387 	rx_queue_id = strtoul(token, NULL, 10);  in handle_rxa_get_queue_conf()
3388 	if (rx_queue_id >= rte_eth_devices[eth_dev_id].data->nb_rx_queues) {  in handle_rxa_get_queue_conf()
3389 		RTE_EDEV_LOG_ERR("Invalid rx queue_id %u", rx_queue_id);  in handle_rxa_get_queue_conf()
3402 						    rx_queue_id, &queue_conf)) {  in handle_rxa_get_queue_conf()
3410 	rte_tel_data_add_dict_u64(d, "rx_queue_id", rx_queue_id);  in handle_rxa_get_queue_conf()
3431 	uint16_t rx_queue_id;  in handle_rxa_get_queue_stats()  local
3459 	rx_queue_id = strtoul(token, NULL, 10);  in handle_rxa_get_queue_stats()
3460 	if (rx_queue_id >= rte_eth_devices[eth_dev_id].data->nb_rx_queues) {  in handle_rxa_get_queue_stats()
3461 		RTE_EDEV_LOG_ERR("Invalid rx queue_id %u", rx_queue_id);  in handle_rxa_get_queue_stats()
3474 						    rx_queue_id, &q_stats)) {  in handle_rxa_get_queue_stats()
3482 	rte_tel_data_add_dict_u64(d, "rx_queue_id", rx_queue_id);  in handle_rxa_get_queue_stats()
3502 	uint16_t rx_queue_id;  in handle_rxa_queue_stats_reset()  local
3529 	rx_queue_id = strtoul(token, NULL, 10);  in handle_rxa_queue_stats_reset()
3530 	if (rx_queue_id >= rte_eth_devices[eth_dev_id].data->nb_rx_queues) {  in handle_rxa_queue_stats_reset()
3531 		RTE_EDEV_LOG_ERR("Invalid rx queue_id %u", rx_queue_id);  in handle_rxa_queue_stats_reset()
3545 						       rx_queue_id)) {  in handle_rxa_queue_stats_reset()