246 	struct txa_service_queue_info *tqi;  in txa_service_queue()  local
251 	tqi = txa->txa_ethdev[port_id].queues;  in txa_service_queue()
253 	return likely(tqi != NULL) ? tqi + tx_queue_id : NULL;  in txa_service_queue()
345 	struct txa_service_queue_info *tqi;  in txa_service_queue_array_alloc()  local
357 	tqi = rte_zmalloc_socket(txa->mem_name,  in txa_service_queue_array_alloc()
361 	if (tqi == NULL)  in txa_service_queue_array_alloc()
363 	txa->txa_ethdev[port_id].queues = tqi;  in txa_service_queue_array_alloc()
372 	struct txa_service_queue_info *tqi;  in txa_service_queue_array_free()  local
378 	tqi = txa_ethdev->queues;  in txa_service_queue_array_free()
380 	rte_free(tqi);  in txa_service_queue_array_free()
458 	struct txa_service_queue_info *tqi;  in txa_service_is_queue_added()  local
460 	tqi = txa_service_queue(txa, dev->data->port_id, tx_queue_id);  in txa_service_is_queue_added()
461 	return tqi && tqi->added;  in txa_service_is_queue_added()
516 	struct txa_service_queue_info *tqi;  in txa_process_event_vector()  local
525 		tqi = txa_service_queue(txa, port, queue);  in txa_process_event_vector()
526 		if (unlikely(tqi == NULL || !tqi->added)) {  in txa_process_event_vector()
532 			nb_tx += rte_eth_tx_buffer(port, queue, tqi->tx_buf,  in txa_process_event_vector()
539 			tqi = txa_service_queue(txa, port, queue);  in txa_process_event_vector()
540 			if (unlikely(tqi == NULL || !tqi->added)) {  in txa_process_event_vector()
544 			nb_tx += rte_eth_tx_buffer(port, queue, tqi->tx_buf,  in txa_process_event_vector()
567 		struct txa_service_queue_info *tqi;  in txa_service_tx()  local
576 			tqi = txa_service_queue(txa, port, queue);  in txa_service_tx()
577 			if (unlikely(tqi == NULL || !tqi->added)) {  in txa_service_tx()
582 			nb_tx += rte_eth_tx_buffer(port, queue, tqi->tx_buf, m);  in txa_service_tx()
622 		struct txa_service_queue_info *tqi;  in txa_service_func()  local
640 				tqi = txa_service_queue(txa, i, q);  in txa_service_func()
641 				if (unlikely(tqi == NULL || !tqi->added))  in txa_service_func()
645 							tqi->tx_buf);  in txa_service_func()
762 	struct txa_service_queue_info *tqi;  in txa_service_queue_add()  local
821 	tqi = txa_service_queue(txa, eth_dev->data->port_id, tx_queue_id);  in txa_service_queue_add()
822 	if (tqi == NULL)  in txa_service_queue_add()
825 	txa_retry = &tqi->txa_retry;  in txa_service_queue_add()
834 	tqi->tx_buf = tb;  in txa_service_queue_add()
835 	tqi->added = 1;  in txa_service_queue_add()
860 	struct txa_service_queue_info *tqi;  in txa_service_queue_del()  local
877 		tqi = txa->txa_ethdev[port_id].queues;  in txa_service_queue_del()
881 			if (tqi[q].added) {  in txa_service_queue_del()
894 	tqi = txa_service_queue(txa, port_id, tx_queue_id);  in txa_service_queue_del()
895 	if (tqi == NULL || !tqi->added)  in txa_service_queue_del()
898 	tb = tqi->tx_buf;  in txa_service_queue_del()
899 	tqi->added = 0;  in txa_service_queue_del()
900 	tqi->tx_buf = NULL;  in txa_service_queue_del()