Function port_queue_flow_destroy

dpdk/app/test-pmd/config.c:2805–2863

Enqueue number of destroy flow rules operations. */

/** Enqueue number of destroy flow rules operations. */
int
port_queue_flow_destroy(portid_t port_id, queueid_t queue_id,
			bool postpone, uint32_t n, const uint64_t *rule)
{
	struct rte_flow_op_attr op_attr = { .postpone = postpone };
	struct rte_port *port;
	struct port_flow **tmp;
	int ret = 0;
	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;
	}

	tmp = &port->flow_list;
	while (*tmp) {
		uint32_t i;

		for (i = 0; i != n; ++i) {
			struct rte_flow_error error;
			struct port_flow *pf = *tmp;

			if (rule[i] != pf->id)
				continue;
			/*
			 * Poisoning to make sure PMD
			 * update it in case of error.
			 */
			memset(&error, 0x33, sizeof(error));
			job = calloc(1, sizeof(*job));
			if (!job) {
				printf("Queue flow destroy job allocate failed\n");
				return -ENOMEM;
			}
			job->type = QUEUE_JOB_TYPE_FLOW_DESTROY;
			job->pf = pf;

			if (rte_flow_async_destroy(port_id, queue_id, &op_attr,
						   pf->flow, job, &error)) {
				free(job);
				ret = port_flow_complain(&error);
				continue;
			}
			printf("Flow rule #%"PRIu64" destruction enqueued\n",
			       pf->id);
			*tmp = pf->next;
			break;
		}
		if (i == n)
			tmp = &(*tmp)->next;
	}
	return ret;