Function port_queue_flow_update

dpdk/app/test-pmd/config.c:2905–2990

Enqueue update flow rule operation. */

/** Enqueue update flow rule operation. */
int
port_queue_flow_update(portid_t port_id, queueid_t queue_id,
		       bool postpone, uint32_t rule_idx, uint32_t actions_idx,
		       const struct rte_flow_action *actions)
{
	struct rte_flow_op_attr op_attr = { .postpone = postpone };
	struct rte_port *port;
	struct port_flow *pf, *uf;
	struct port_flow **tmp;
	struct port_table *pt;
	bool found;
	struct rte_flow_error error = { RTE_FLOW_ERROR_TYPE_NONE, NULL, NULL };
	struct rte_flow_action_age *age = age_action_get(actions);
	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;
	}

	found = false;
	tmp = &port->flow_list;
	while (*tmp) {
		pf = *tmp;
		if (rule_idx == pf->id) {
			found = true;
			break;
		}
		tmp = &(*tmp)->next;
	}
	if (!found) {
		printf("Flow rule #%u is invalid\n", rule_idx);
		return -EINVAL;
	}

	pt = pf->table;
	if (actions_idx >= pt->nb_actions_templates) {
		printf("Actions template index #%u is invalid,"
		       " %u templates present in the table\n",
		       actions_idx, pt->nb_actions_templates);
		return -EINVAL;
	}

	job = calloc(1, sizeof(*job));
	if (!job) {
		printf("Queue flow create job allocate failed\n");
		return -ENOMEM;
	}
	job->type = QUEUE_JOB_TYPE_FLOW_UPDATE;

	uf = port_flow_new(&pt->flow_attr, pf->rule.pattern_ro, actions, &error);
	if (!uf) {
		free(job);