Function port_queue_flow_pull

dpdk/app/test-pmd/config.c:3494–3548

Pull queue operation results from the queue. */

/** Pull queue operation results from the queue. */
int
port_queue_flow_pull(portid_t port_id, queueid_t queue_id)
{
	struct rte_port *port;
	struct rte_flow_op_result *res;
	struct rte_flow_error error;
	int ret = 0;
	int success = 0;
	int i;
	struct queue_job *job;

	if (port_id_is_invalid(port_id, ENABLED_WARN) ||
	    port_id == (portid_t)RTE_PORT_ALL)
		return -EINVAL;
	port = &ports[port_id];

	if (queue_id >= port->queue_nb) {
		printf("Queue #%u is invalid\n", queue_id);
		return -EINVAL;
	}

	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));
	ret = rte_flow_pull(port_id, queue_id, res,
				 port->queue_sz, &error);
	if (ret < 0) {
		printf("Failed to pull a operation results\n");
		free(res);
		return -EINVAL;
	}

	for (i = 0; i < ret; i++) {
		if (res[i].status == RTE_FLOW_OP_SUCCESS)
			success++;
		job = (struct queue_job *)res[i].user_data;
		if (job->type == QUEUE_JOB_TYPE_FLOW_DESTROY ||
		    job->type == QUEUE_JOB_TYPE_FLOW_UPDATE)
			free(job->pf);
		else if (job->type == QUEUE_JOB_TYPE_ACTION_DESTROY)
			free(job->pia);
		else if (job->type == QUEUE_JOB_TYPE_ACTION_QUERY)
			port_action_handle_query_dump(port_id, job->pia,
						      &job->query);
		free(job);
	}
	printf("Queue #%u pulled %u operations (%u failed, %u succeeded)\n",
	       queue_id, ret, ret - success, success);
	free(res);
	return ret;
}

/* Set group miss actions */
int