Function port_queue_action_handle_update

dpdk/app/test-pmd/config.c:3114–3178

Enqueue indirect action update operation. */

/** Enqueue indirect action update operation. */
int
port_queue_action_handle_update(portid_t port_id,
				uint32_t queue_id, bool postpone, uint32_t id,
				const struct rte_flow_action *action)
{
	const struct rte_flow_op_attr attr = { .postpone = postpone};
	struct rte_port *port;
	struct rte_flow_error error;
	struct rte_flow_action_handle *action_handle;
	struct queue_job *job;
	struct port_indirect_action *pia;
	struct rte_flow_update_meter_mark mtr_update;
	const void *update;

	action_handle = port_action_handle_get_by_id(port_id, id);
	if (!action_handle)
		return -EINVAL;

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

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

	pia = action_get_by_id(port_id, id);
	if (!pia) {
		free(job);
		return -EINVAL;
	}

	switch (pia->type) {
	case RTE_FLOW_ACTION_TYPE_AGE:
		update = action->conf;
		break;
	case RTE_FLOW_ACTION_TYPE_METER_MARK:
		rte_memcpy(&mtr_update.meter_mark, action->conf,
			sizeof(struct rte_flow_action_meter_mark));
		if (mtr_update.meter_mark.profile)
			mtr_update.profile_valid = 1;
		if (mtr_update.meter_mark.policy)
			mtr_update.policy_valid = 1;
		mtr_update.color_mode_valid = 1;
		mtr_update.state_valid = 1;
		update = &mtr_update;
		break;
	default:
		update = action;
		break;
	}

	if (rte_flow_async_action_handle_update(port_id, queue_id, &attr,