| 1715 | } |
| 1716 | |
| 1717 | static inline int |
| 1718 | process_dispatch_ring(uint16_t port_id, uint16_t queue_id, |
| 1719 | struct rte_mbuf **pkts_burst, const struct ff_dpdk_if_context *ctx) |
| 1720 | { |
| 1721 | /* read packet from ring buf and to process */ |
| 1722 | uint16_t nb_rb; |
| 1723 | nb_rb = rte_ring_dequeue_burst(dispatch_ring[port_id][queue_id], |
| 1724 | (void **)pkts_burst, MAX_PKT_BURST, NULL); |
| 1725 | |
| 1726 | if(nb_rb > 0) { |
| 1727 | process_packets(port_id, queue_id, pkts_burst, nb_rb, ctx, 1); |
| 1728 | } |
| 1729 | |
| 1730 | return nb_rb; |
| 1731 | } |
| 1732 | |
| 1733 | static inline void |
| 1734 | handle_sysctl_msg(struct ff_msg *msg) |
no test coverage detected