203 	struct thread_msg_req *req)  in thread_msg_send_recv()  argument
213 		status = rte_ring_sp_enqueue(msgq_req, req);  in thread_msg_send_recv()
231 	struct thread_msg_req *req;  in thread_pipeline_enable()  local
269 	req = thread_msg_alloc();  in thread_pipeline_enable()
270 	if (req == NULL)  in thread_pipeline_enable()
274 	req->type = THREAD_REQ_PIPELINE_ENABLE;  in thread_pipeline_enable()
275 	req->pipeline_enable.p = p->p;  in thread_pipeline_enable()
276 	req->pipeline_enable.timer_period_ms = p->timer_period_ms;  in thread_pipeline_enable()
279 	rsp = thread_msg_send_recv(thread_id, req);  in thread_pipeline_enable()
304 	struct thread_msg_req *req;  in thread_pipeline_disable()  local
356 	req = thread_msg_alloc();  in thread_pipeline_disable()
357 	if (req == NULL)  in thread_pipeline_disable()
361 	req->type = THREAD_REQ_PIPELINE_DISABLE;  in thread_pipeline_disable()
362 	req->pipeline_disable.p = p->p;  in thread_pipeline_disable()
365 	rsp = thread_msg_send_recv(thread_id, req);  in thread_pipeline_disable()
388 	struct thread_msg_req *req;  in thread_msg_recv()  local
390 	int status = rte_ring_sc_dequeue(msgq_req, (void **) &req);  in thread_msg_recv()
395 	return req;  in thread_msg_recv()
411 	struct thread_msg_req *req)  in thread_msg_handle_pipeline_enable()  argument
413 	struct thread_msg_rsp *rsp = (struct thread_msg_rsp *) req;  in thread_msg_handle_pipeline_enable()
422 	t->p[t->n_pipelines] = req->pipeline_enable.p;  in thread_msg_handle_pipeline_enable()
424 	p->p = req->pipeline_enable.p;  in thread_msg_handle_pipeline_enable()
426 		req->pipeline_enable.timer_period_ms) / 1000;  in thread_msg_handle_pipeline_enable()
438 	struct thread_msg_req *req)  in thread_msg_handle_pipeline_disable()  argument
440 	struct thread_msg_rsp *rsp = (struct thread_msg_rsp *) req;  in thread_msg_handle_pipeline_disable()
442 	struct rte_swx_pipeline *pipeline = req->pipeline_disable.p;  in thread_msg_handle_pipeline_disable()
477 		struct thread_msg_req *req;  in thread_msg_handle()  local
480 		req = thread_msg_recv(t->msgq_req);  in thread_msg_handle()
481 		if (req == NULL)  in thread_msg_handle()
484 		switch (req->type) {  in thread_msg_handle()
486 			rsp = thread_msg_handle_pipeline_enable(t, req);  in thread_msg_handle()
490 			rsp = thread_msg_handle_pipeline_disable(t, req);  in thread_msg_handle()
494 			rsp = (struct thread_msg_rsp *) req;  in thread_msg_handle()