| 14 | static struct ethdev_rx_node_main ethdev_rx_main; |
| 15 | |
| 16 | static __rte_always_inline uint16_t |
| 17 | ethdev_rx_node_process_inline(struct rte_graph *graph, struct rte_node *node, |
| 18 | ethdev_rx_node_ctx_t *ctx) |
| 19 | { |
| 20 | uint16_t count, next_index; |
| 21 | uint16_t port, queue; |
| 22 | |
| 23 | port = ctx->port_id; |
| 24 | queue = ctx->queue_id; |
| 25 | next_index = ctx->cls_next; |
| 26 | |
| 27 | /* Get pkts from port */ |
| 28 | count = rte_eth_rx_burst(port, queue, (struct rte_mbuf **)node->objs, |
| 29 | RTE_GRAPH_BURST_SIZE); |
| 30 | |
| 31 | if (!count) |
| 32 | return 0; |
| 33 | node->idx = count; |
| 34 | /* Enqueue to next node */ |
| 35 | rte_node_next_stream_move(graph, node, next_index); |
| 36 | |
| 37 | return count; |
| 38 | } |
| 39 | |
| 40 | static __rte_always_inline uint16_t |
| 41 | ethdev_rx_node_process(struct rte_graph *graph, struct rte_node *node, |
no test coverage detected