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 rte_ring_free(t->msgq_req); in thread_free()
108 struct rte_ring *msgq_req, *msgq_rsp; in thread_init() local
116 msgq_req = rte_ring_create(name, in thread_init()
121 if (msgq_req == NULL) { in thread_init()
139 t->msgq_req = msgq_req; in thread_init()
145 t_data->msgq_req = msgq_req; in thread_init()
197 struct rte_ring *msgq_req; member
236 struct rte_ring *msgq_req = t->msgq_req; in thread_msg_send_recv() local
243 status = rte_ring_sp_enqueue(msgq_req, req); in thread_msg_send_recv()
294 tdp->msgq_req = p->msgq_req; in thread_pipeline_enable()
319 req->pipeline_enable.msgq_req = p->msgq_req; in thread_pipeline_enable()
431 thread_msg_recv(struct rte_ring *msgq_req) in thread_msg_recv() argument
435 int status = rte_ring_sc_dequeue(msgq_req, (void **) &req); in thread_msg_recv()
477 p->msgq_req = req->pipeline_enable.msgq_req; in thread_msg_handle_pipeline_enable()
534 req = thread_msg_recv(t->msgq_req); in thread_msg_handle()
752 struct rte_ring *msgq_req = p->msgq_req; in pipeline_msg_send_recv() local
759 status = rte_ring_sp_enqueue(msgq_req, req); in pipeline_msg_send_recv()
2204 pipeline_msg_recv(struct rte_ring *msgq_req) in pipeline_msg_recv() argument
2208 int status = rte_ring_sc_dequeue(msgq_req, (void **) &req); in pipeline_msg_recv()
2998 req = pipeline_msg_recv(p->msgq_req); in pipeline_msg_handle()