86 		struct thread *t = &thread[i];  in thread_free()  local
92 		rte_ring_free(t->msgq_req);  in thread_free()
94 		rte_ring_free(t->msgq_rsp);  in thread_free()
106 		struct thread *t = &thread[i];  in thread_init()  local
136 		t->msgq_req = msgq_req;  in thread_init()
137 		t->msgq_rsp = msgq_rsp;  in thread_init()
138 		t->enabled = 1;  in thread_init()
212 	struct thread *t = &thread[thread_id];  in thread_msg_send_recv()  local
213 	struct rte_ring *msgq_req = t->msgq_req;  in thread_msg_send_recv()
214 	struct rte_ring *msgq_rsp = t->msgq_rsp;  in thread_msg_send_recv()
237 	struct thread *t;  in thread_pipeline_enable()  local
247 	t = &thread[thread_id];  in thread_pipeline_enable()
248 	if (t->enabled == 0)  in thread_pipeline_enable()
310 	struct thread *t;  in thread_pipeline_disable()  local
320 	t = &thread[thread_id];  in thread_pipeline_disable()
321 	if (t->enabled == 0)  in thread_pipeline_disable()
417 thread_msg_handle_pipeline_enable(struct thread_data *t,  in thread_msg_handle_pipeline_enable()  argument
421 	struct pipeline_data *p = &t->pipeline_data[t->n_pipelines];  in thread_msg_handle_pipeline_enable()
424 	if (t->n_pipelines >= THREAD_PIPELINES_MAX) {  in thread_msg_handle_pipeline_enable()
429 	t->p[t->n_pipelines] = req->pipeline_enable.p;  in thread_msg_handle_pipeline_enable()
436 	t->n_pipelines++;  in thread_msg_handle_pipeline_enable()
444 thread_msg_handle_pipeline_disable(struct thread_data *t,  in thread_msg_handle_pipeline_disable()  argument
448 	uint32_t n_pipelines = t->n_pipelines;  in thread_msg_handle_pipeline_disable()
454 		struct pipeline_data *p = &t->pipeline_data[i];  in thread_msg_handle_pipeline_disable()
461 				t->p[n_pipelines - 1];  in thread_msg_handle_pipeline_disable()
463 				&t->pipeline_data[n_pipelines - 1];  in thread_msg_handle_pipeline_disable()
465 			t->p[i] = pipeline_last;  in thread_msg_handle_pipeline_disable()
469 		t->n_pipelines--;  in thread_msg_handle_pipeline_disable()
481 thread_msg_handle(struct thread_data *t)  in thread_msg_handle()  argument
487 		req = thread_msg_recv(t->msgq_req);  in thread_msg_handle()
493 			rsp = thread_msg_handle_pipeline_enable(t, req);  in thread_msg_handle()
497 			rsp = thread_msg_handle_pipeline_disable(t, req);  in thread_msg_handle()
505 		thread_msg_send(t->msgq_rsp, rsp);  in thread_msg_handle()
515 	struct thread_data *t;  in thread_main()  local
519 	t = &thread_data[thread_id];  in thread_main()
526 		for (j = 0; j < t->n_pipelines; j++)  in thread_main()
527 			rte_swx_pipeline_run(t->p[j], PIPELINE_INSTR_QUANTA);  in thread_main()
534 			if (time < t->time_next_min)  in thread_main()
539 				uint64_t time_next = t->time_next;  in thread_main()
542 					thread_msg_handle(t);  in thread_main()
543 					time_next = time + t->timer_period;  in thread_main()
544 					t->time_next = time_next;  in thread_main()
551 			t->time_next_min = time_next_min;  in thread_main()