| 441 | } |
| 442 | |
| 443 | static inline void |
| 444 | thread_msg_send(struct rte_ring *msgq_rsp, |
| 445 | struct thread_msg_rsp *rsp) |
| 446 | { |
| 447 | int status; |
| 448 | |
| 449 | do { |
| 450 | status = rte_ring_sp_enqueue(msgq_rsp, rsp); |
| 451 | } while (status == -ENOBUFS); |
| 452 | } |
| 453 | |
| 454 | static struct thread_msg_rsp * |
| 455 | thread_msg_handle_pipeline_enable(struct thread_data *t, |
no test coverage detected