| 1949 | } |
| 1950 | |
| 1951 | static inline int |
| 1952 | process_msg_ring(uint16_t proc_id, struct rte_mbuf **pkts_burst) |
| 1953 | { |
| 1954 | /* read msg from ring buf and to process */ |
| 1955 | uint16_t nb_rb; |
| 1956 | int i; |
| 1957 | |
| 1958 | nb_rb = rte_ring_dequeue_burst(msg_ring[proc_id].ring[0], |
| 1959 | (void **)pkts_burst, MAX_PKT_BURST, NULL); |
| 1960 | |
| 1961 | if (likely(nb_rb == 0)) |
| 1962 | return 0; |
| 1963 | |
| 1964 | for (i = 0; i < nb_rb; ++i) { |
| 1965 | handle_msg((struct ff_msg *)pkts_burst[i], proc_id); |
| 1966 | } |
| 1967 | |
| 1968 | return 0; |
| 1969 | } |
| 1970 | |
| 1971 | /* Send burst of packets on an output interface */ |
| 1972 | static inline int |
no test coverage detected