diff mbox

[3/3] linux-gen: dpdk: move rx/tx locks

Message ID 1472653448-23947-3-git-send-email-matias.elo@nokia.com
State Accepted
Commit be6d2d4f3de94cc314d2367f76432306f4c88b94
Headers show

Commit Message

Elo, Matias (Nokia - FI/Espoo) Aug. 31, 2016, 2:24 p.m. UTC 
Protect only the required sections of rx/tx functions.

Signed-off-by: Matias Elo <matias.elo@nokia.com>

---
 platform/linux-generic/pktio/dpdk.c | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)

-- 
2.7.4
diff mbox

Patch

diff --git a/platform/linux-generic/pktio/dpdk.c b/platform/linux-generic/pktio/dpdk.c
index 99eb868..11f3509 100644
--- a/platform/linux-generic/pktio/dpdk.c
+++ b/platform/linux-generic/pktio/dpdk.c
@@ -912,6 +912,9 @@  static int dpdk_recv(pktio_entry_t *pktio_entry, int index,
 					 rx_mbufs, num);
 	}
 
+	if (!pkt_dpdk->lockless_rx)
+		odp_ticketlock_unlock(&pkt_dpdk->rx_lock[index]);
+
 	if (nb_rx > 0) {
 		if (pktio_entry->s.config.pktin.bit.ts_all ||
 		    pktio_entry->s.config.pktin.bit.ts_ptp) {
@@ -922,9 +925,6 @@  static int dpdk_recv(pktio_entry_t *pktio_entry, int index,
 				    ts);
 	}
 
-	if (!pktio_entry->s.pkt_dpdk.lockless_rx)
-		odp_ticketlock_unlock(&pkt_dpdk->rx_lock[index]);
-
 	return nb_rx;
 }
 
@@ -940,14 +940,17 @@  static int dpdk_send(pktio_entry_t *pktio_entry, int index,
 	if (odp_unlikely(pktio_entry->s.state != PKTIO_STATE_STARTED))
 		return 0;
 
-	if (!pktio_entry->s.pkt_dpdk.lockless_tx)
-		odp_ticketlock_lock(&pkt_dpdk->tx_lock[index]);
-
 	mbufs = pkt_to_mbuf(pktio_entry, tx_mbufs, pkt_table, num);
 
+	if (!pkt_dpdk->lockless_tx)
+		odp_ticketlock_lock(&pkt_dpdk->tx_lock[index]);
+
 	tx_pkts = rte_eth_tx_burst(pkt_dpdk->port_id, index,
 				   tx_mbufs, mbufs);
 
+	if (!pkt_dpdk->lockless_tx)
+		odp_ticketlock_unlock(&pkt_dpdk->tx_lock[index]);
+
 	if (odp_unlikely(tx_pkts < num)) {
 		for (i = tx_pkts; i < mbufs; i++)
 			rte_pktmbuf_free(tx_mbufs[i]);
@@ -955,9 +958,6 @@  static int dpdk_send(pktio_entry_t *pktio_entry, int index,
 
 	odp_packet_free_multi(pkt_table, tx_pkts);
 
-	if (!pktio_entry->s.pkt_dpdk.lockless_tx)
-		odp_ticketlock_unlock(&pkt_dpdk->tx_lock[index]);
-
 	if (odp_unlikely(tx_pkts == 0 && __odp_errno != 0))
 		return -1;