Function port_queue_aged_flow_destroy

dpdk/app/test-pmd/config.c:3338–3395

Pull queue operation results from the queue. */

/** Pull queue operation results from the queue. */
static int
port_queue_aged_flow_destroy(portid_t port_id, queueid_t queue_id,
			     const uint64_t *rule, int nb_flows)
{
	struct rte_port *port = &ports[port_id];
	struct rte_flow_op_result *res;
	struct rte_flow_error error;
	uint32_t n = nb_flows;
	int ret = 0;
	int i;

	res = calloc(port->queue_sz, sizeof(struct rte_flow_op_result));
	if (!res) {
		printf("Failed to allocate memory for pulled results\n");
		return -ENOMEM;
	}

	memset(&error, 0x66, sizeof(error));
	while (nb_flows > 0) {
		int success = 0;

		if (n > port->queue_sz)
			n = port->queue_sz;
		ret = port_queue_flow_destroy(port_id, queue_id, true, n, rule);
		if (ret < 0) {
			free(res);
			return ret;
		}
		ret = rte_flow_push(port_id, queue_id, &error);
		if (ret < 0) {
			printf("Failed to push operations in the queue: %s\n",
			       strerror(-ret));
			free(res);
			return ret;
		}
		while (success < nb_flows) {
			ret = rte_flow_pull(port_id, queue_id, res,
					    port->queue_sz, &error);
			if (ret < 0) {
				printf("Failed to pull a operation results: %s\n",
				       strerror(-ret));
				free(res);
				return ret;
			}

			for (i = 0; i < ret; i++) {
				if (res[i].status == RTE_FLOW_OP_SUCCESS)
					success++;
			}
		}
		rule += n;
		nb_flows -= n;
		n = nb_flows;
	}

	free(res);
	return ret;
}