Function mlx5_flow_create

dpdk/drivers/net/mlx5/mlx5_flow.c:7993–8042

* Create a flow. * * @see rte_flow_create() * @see rte_flow_ops */

 * @see rte_flow_ops
 */
struct rte_flow *
mlx5_flow_create(struct rte_eth_dev *dev,
		 const struct rte_flow_attr *attr,
		 const struct rte_flow_item items[],
		 const struct rte_flow_action actions[],
		 struct rte_flow_error *error)
{
	struct mlx5_priv *priv = dev->data->dev_private;
	struct rte_flow_attr *new_attr = (void *)(uintptr_t)attr;
	uint32_t prio = attr->priority;
	uint32_t flow_idx;

	if (priv->sh->config.dv_flow_en == 2) {
		rte_flow_error_set(error, ENOTSUP,
			  RTE_FLOW_ERROR_TYPE_UNSPECIFIED,
			  NULL,
			  "Flow non-Q creation not supported");
		return NULL;
	}
	/*
	 * If the device is not started yet, it is not allowed to created a
	 * flow from application. PMD default flows and traffic control flows
	 * are not affected.
	 */
	if (unlikely(!dev->data->dev_started)) {
		DRV_LOG(DEBUG, "port %u is not started when "
			"inserting a flow", dev->data->port_id);
		rte_flow_error_set(error, ENODEV,
				   RTE_FLOW_ERROR_TYPE_UNSPECIFIED,
				   NULL,
				   "port not started");
		return NULL;
	}
	if (unlikely(mlx5_need_cache_flow(priv, attr))) {
		if (attr->transfer ||
				(attr->ingress && !(priv->mode_info.mode_flag &
				RTE_PMD_MLX5_FLOW_ENGINE_FLAG_STANDBY_DUP_INGRESS)))
			new_attr->priority += 1;
	}
	flow_idx = flow_list_create(dev, MLX5_FLOW_TYPE_GEN, attr, items, actions, true, error);
	if (!flow_idx)
		return NULL;
	if (unlikely(mlx5_need_cache_flow(priv, attr))) {
		if (mlx5_flow_cache_flow_info(dev, attr, prio, items, actions, flow_idx)) {
			flow_list_destroy(dev, MLX5_FLOW_TYPE_GEN, flow_idx);
			flow_idx = 0;
		}
	}
	return (void *)(uintptr_t)flow_idx;
}

/**
 * Destroy a flow in a list.