* Data plane threads: message handling */
| 2199 | * Data plane threads: message handling |
| 2200 | */ |
| 2201 | static inline struct pipeline_msg_req * |
| 2202 | pipeline_msg_recv(struct rte_ring *msgq_req) |
| 2203 | { |
| 2204 | struct pipeline_msg_req *req; |
| 2205 | |
| 2206 | int status = rte_ring_sc_dequeue(msgq_req, (void **) &req); |
| 2207 | |
| 2208 | if (status != 0) |
| 2209 | return NULL; |
| 2210 | |
| 2211 | return req; |
| 2212 | } |
| 2213 | |
| 2214 | static inline void |
| 2215 | pipeline_msg_send(struct rte_ring *msgq_rsp, |
no test coverage detected