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

[Matias Elo]

Protect only the required sections of rx/tx functions.

Signed-off-by: Matias Elo <matias....@nokia.com>
---
 platform/linux-generic/pktio/dpdk.c | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)

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;
 
-- 
2.7.4