Function tmgr_port_create

dpdk/examples/ip_pipeline/tmgr.c:90–180

}

struct tmgr_port *
tmgr_port_create(const char *name, struct tmgr_port_params *params)
{
	struct rte_sched_subport_params subport_params;
	struct rte_sched_port_params p;
	struct tmgr_port *tmgr_port;
	struct rte_sched_port *s;
	uint32_t i, j;

	/* Check input params */
	if ((name == NULL) ||
		tmgr_port_find(name) ||
		(params == NULL) ||
		(params->n_subports_per_port == 0) ||
		(params->n_pipes_per_subport == 0) ||
		(params->cpu_id >= RTE_MAX_NUMA_NODES) ||
		(n_subport_profiles == 0) ||
		(n_pipe_profiles == 0))
		return NULL;

	/* Resource create */
	p.name = name;
	p.socket = (int) params->cpu_id;
	p.rate = params->rate;
	p.mtu = params->mtu;
	p.frame_overhead = params->frame_overhead;
	p.n_subports_per_port = params->n_subports_per_port;
	p.n_subport_profiles = n_subport_profiles;
	p.subport_profiles = subport_profile;
	p.n_max_subport_profiles = TMGR_SUBPORT_PROFILE_MAX;
	p.n_pipes_per_subport = params->n_pipes_per_subport;


	s = rte_sched_port_config(&p);
	if (s == NULL)
		return NULL;

	memcpy(&subport_params, &subport_params_default,
		sizeof(subport_params_default));

	subport_params.n_pipe_profiles = n_pipe_profiles;
	subport_params.n_pipes_per_subport_enabled =
						params->n_pipes_per_subport;

	for (i = 0; i < params->n_subports_per_port; i++) {
		int status;

		status = rte_sched_subport_config(
			s,
			i,
			&subport_params,
			0);

		if (status) {
			rte_sched_port_free(s);
			return NULL;
		}