Lines Matching refs:msgq_req
38 struct rte_ring *msgq_req; member
58 struct rte_ring *msgq_req; member
71 struct rte_ring *msgq_req; member
95 if (t->msgq_req) in thread_free()
96 rte_ring_free(t->msgq_req); in thread_free()
110 struct rte_ring *msgq_req, *msgq_rsp; in thread_init() local
118 msgq_req = rte_ring_create(name, in thread_init()
123 if (msgq_req == NULL) { in thread_init()
141 t->msgq_req = msgq_req; in thread_init()
147 t_data->msgq_req = msgq_req; in thread_init()
199 struct rte_ring *msgq_req; member
238 struct rte_ring *msgq_req = t->msgq_req; in thread_msg_send_recv() local
245 status = rte_ring_sp_enqueue(msgq_req, req); in thread_msg_send_recv()
296 tdp->msgq_req = p->msgq_req; in thread_pipeline_enable()
321 req->pipeline_enable.msgq_req = p->msgq_req; in thread_pipeline_enable()
433 thread_msg_recv(struct rte_ring *msgq_req) in thread_msg_recv() argument
437 int status = rte_ring_sc_dequeue(msgq_req, (void **) &req); in thread_msg_recv()
479 p->msgq_req = req->pipeline_enable.msgq_req; in thread_msg_handle_pipeline_enable()
536 req = thread_msg_recv(t->msgq_req); in thread_msg_handle()
754 struct rte_ring *msgq_req = p->msgq_req; in pipeline_msg_send_recv() local
761 status = rte_ring_sp_enqueue(msgq_req, req); in pipeline_msg_send_recv()
2206 pipeline_msg_recv(struct rte_ring *msgq_req) in pipeline_msg_recv() argument
2210 int status = rte_ring_sc_dequeue(msgq_req, (void **) &req); in pipeline_msg_recv()
3000 req = pipeline_msg_recv(p->msgq_req); in pipeline_msg_handle()