Lines Matching defs:pipeline

30 #include "pipeline.h"
54 struct pipeline *
57 	struct pipeline *pipeline;
62 	TAILQ_FOREACH(pipeline, &pipeline_list, node)
63 		if (strcmp(name, pipeline->name) == 0)
64 			return pipeline;
69 struct pipeline *
74 	struct pipeline *pipeline;
119 	pipeline = calloc(1, sizeof(struct pipeline));
120 	if (pipeline == NULL) {
128 	strlcpy(pipeline->name, name, sizeof(pipeline->name));
129 	pipeline->p = p;
130 	pipeline->n_ports_in = 0;
131 	pipeline->n_ports_out = 0;
132 	pipeline->n_tables = 0;
133 	pipeline->msgq_req = msgq_req;
134 	pipeline->msgq_rsp = msgq_rsp;
135 	pipeline->timer_period_ms = params->timer_period_ms;
136 	pipeline->enabled = 0;
137 	pipeline->cpu_id = params->cpu_id;
140 	TAILQ_INSERT_TAIL(&pipeline_list, pipeline, node);
142 	return pipeline;
161 	struct pipeline *pipeline;
178 	pipeline = pipeline_find(pipeline_name);
179 	if (pipeline == NULL)
310 			pipeline->cpu_id);
323 	status = rte_pipeline_port_in_create(pipeline->p,
332 		rte_pipeline_port_in_enable(pipeline->p, port_id);
335 	port_in = &pipeline->port_in[pipeline->n_ports_in];
339 	pipeline->n_ports_in++;
349 	struct pipeline *pipeline;
356 	pipeline = pipeline_find(pipeline_name);
357 	if ((pipeline == NULL) ||
358 		(port_id >= pipeline->n_ports_in) ||
359 		(table_id >= pipeline->n_tables))
363 	status = rte_pipeline_port_in_connect_to_table(pipeline->p,
393 	struct pipeline *pipeline;
408 	pipeline = pipeline_find(pipeline_name);
409 	if (pipeline == NULL)
562 	status = rte_pipeline_port_out_create(pipeline->p,
570 	pipeline->n_ports_out++;
736 	struct pipeline *pipeline;
751 	pipeline = pipeline_find(pipeline_name);
752 	if ((pipeline == NULL) ||
753 		(pipeline->n_tables >= RTE_PIPELINE_TABLE_MAX))
764 		pipeline_name, pipeline->n_tables);
948 			pipeline->cpu_id);
974 	status = rte_pipeline_table_create(pipeline->p,
983 	table = &pipeline->table[pipeline->n_tables];
990 	pipeline->n_tables++;