Lines Matching refs:msgq_rsp
39 struct rte_ring *msgq_rsp; member
59 struct rte_ring *msgq_rsp; member
72 struct rte_ring *msgq_rsp; member
98 if (t->msgq_rsp) in thread_free()
99 rte_ring_free(t->msgq_rsp); in thread_free()
110 struct rte_ring *msgq_req, *msgq_rsp; in thread_init() local
130 msgq_rsp = rte_ring_create(name, in thread_init()
135 if (msgq_rsp == NULL) { in thread_init()
142 t->msgq_rsp = msgq_rsp; in thread_init()
148 t_data->msgq_rsp = msgq_rsp; in thread_init()
200 struct rte_ring *msgq_rsp; member
239 struct rte_ring *msgq_rsp = t->msgq_rsp; in thread_msg_send_recv() local
250 status = rte_ring_sc_dequeue(msgq_rsp, (void **) &rsp); in thread_msg_send_recv()
297 tdp->msgq_rsp = p->msgq_rsp; in thread_pipeline_enable()
322 req->pipeline_enable.msgq_rsp = p->msgq_rsp; in thread_pipeline_enable()
446 thread_msg_send(struct rte_ring *msgq_rsp, in thread_msg_send() argument
452 status = rte_ring_sp_enqueue(msgq_rsp, rsp); in thread_msg_send()
480 p->msgq_rsp = req->pipeline_enable.msgq_rsp; in thread_msg_handle_pipeline_enable()
554 thread_msg_send(t->msgq_rsp, rsp); in thread_msg_handle()
755 struct rte_ring *msgq_rsp = p->msgq_rsp; in pipeline_msg_send_recv() local
766 status = rte_ring_sc_dequeue(msgq_rsp, (void **) &rsp); in pipeline_msg_send_recv()
2219 pipeline_msg_send(struct rte_ring *msgq_rsp, in pipeline_msg_send() argument
2225 status = rte_ring_sp_enqueue(msgq_rsp, rsp); in pipeline_msg_send()
3078 pipeline_msg_send(p->msgq_rsp, rsp); in pipeline_msg_handle()