[dpdk-dev] [PATCH 13/15] examples/l2fwd: move pkt send code to a new function
Anoob Joseph
anoob.joseph at caviumnetworks.com
Fri Jun 8 19:09:24 CEST 2018
Signed-off-by: Anoob Joseph <anoob.joseph at caviumnetworks.com>
---
examples/l2fwd/l2fwd_worker.c | 20 ++++++++++++++------
1 file changed, 14 insertions(+), 6 deletions(-)
diff --git a/examples/l2fwd/l2fwd_worker.c b/examples/l2fwd/l2fwd_worker.c
index 9ba78f6..56e0bdb 100644
--- a/examples/l2fwd/l2fwd_worker.c
+++ b/examples/l2fwd/l2fwd_worker.c
@@ -154,22 +154,30 @@ l2fwd_mac_updating(struct rte_mbuf *m, unsigned dest_portid)
ether_addr_copy(&l2fwd_ports_eth_addr[dest_portid], ð->s_addr);
}
+static inline void
+l2fwd_send_pkt(struct rte_mbuf *tx_pkt, unsigned port_id)
+{
+ int sent;
+ struct rte_eth_dev_tx_buffer *buffer;
+
+ buffer = tx_buffer[port_id];
+ sent = rte_eth_tx_buffer(port_id, 0, buffer, tx_pkt);
+ if (sent)
+ port_statistics[port_id].tx += sent;
+}
+
static void
l2fwd_simple_forward(struct rte_mbuf *m, unsigned portid)
{
unsigned dst_port;
- int sent;
- struct rte_eth_dev_tx_buffer *buffer;
dst_port = l2fwd_dst_ports[portid];
if (mac_updating)
l2fwd_mac_updating(m, dst_port);
- buffer = tx_buffer[dst_port];
- sent = rte_eth_tx_buffer(dst_port, 0, buffer, m);
- if (sent)
- port_statistics[dst_port].tx += sent;
+ /* Send packet */
+ l2fwd_send_pkt(m, dst_port);
}
/* main processing loop */
--
2.7.4
More information about the dev
mailing list