ethdev: validate input in register info
[dpdk.git] / drivers / net / ena / ena_ethdev.c
index 1728ceb..f60e843 100644 (file)
@@ -47,7 +47,7 @@
 #define ENA_HASH_KEY_SIZE      40
 #define ETH_GSTRING_LEN        32
 
-#define ARRAY_SIZE(x) (sizeof(x) / sizeof((x)[0]))
+#define ARRAY_SIZE(x) RTE_DIM(x)
 
 #define ENA_MIN_RING_DESC      128
 
@@ -767,8 +767,10 @@ static void ena_tx_queue_release_bufs(struct ena_ring *ring)
        for (i = 0; i < ring->ring_size; ++i) {
                struct ena_tx_buffer *tx_buf = &ring->tx_buffer_info[i];
 
-               if (tx_buf->mbuf)
+               if (tx_buf->mbuf) {
                        rte_pktmbuf_free(tx_buf->mbuf);
+                       tx_buf->mbuf = NULL;
+               }
        }
 }
 
@@ -1282,6 +1284,7 @@ static int ena_tx_queue_setup(struct rte_eth_dev *dev,
        txq->ring_size = nb_desc;
        txq->size_mask = nb_desc - 1;
        txq->numa_socket_id = socket_id;
+       txq->pkts_without_db = false;
 
        txq->tx_buffer_info = rte_zmalloc("txq->tx_buffer_info",
                                          sizeof(struct ena_tx_buffer) *
@@ -1456,7 +1459,7 @@ static int ena_populate_rx_queue(struct ena_ring *rxq, unsigned int count)
                "bad ring state\n");
 
        /* get resources for incoming packets */
-       rc = rte_mempool_get_bulk(rxq->mb_pool, (void **)mbufs, count);
+       rc = rte_pktmbuf_alloc_bulk(rxq->mb_pool, mbufs, count);
        if (unlikely(rc < 0)) {
                rte_atomic64_inc(&rxq->adapter->drv_stats->rx_nombuf);
                ++rxq->rx_stats.mbuf_alloc_fail;
@@ -1485,8 +1488,7 @@ static int ena_populate_rx_queue(struct ena_ring *rxq, unsigned int count)
        if (unlikely(i < count)) {
                PMD_DRV_LOG(WARNING, "refilled rx qid %d with only %d "
                        "buffers (from %d)\n", rxq->id, i, count);
-               rte_mempool_put_bulk(rxq->mb_pool, (void **)(&mbufs[i]),
-                                    count - i);
+               rte_pktmbuf_free_bulk(&mbufs[i], count - i);
                ++rxq->rx_stats.refill_partial;
        }
 
@@ -2359,8 +2361,8 @@ static void ena_update_hints(struct ena_adapter *adapter,
        }
 }
 
-static int ena_check_and_linearize_mbuf(struct ena_ring *tx_ring,
-                                       struct rte_mbuf *mbuf)
+static int ena_check_space_and_linearize_mbuf(struct ena_ring *tx_ring,
+                                             struct rte_mbuf *mbuf)
 {
        struct ena_com_dev *ena_dev;
        int num_segments, header_len, rc;
@@ -2370,13 +2372,21 @@ static int ena_check_and_linearize_mbuf(struct ena_ring *tx_ring,
        header_len = mbuf->data_len;
 
        if (likely(num_segments < tx_ring->sgl_size))
-               return 0;
+               goto checkspace;
 
        if (ena_dev->tx_mem_queue_type == ENA_ADMIN_PLACEMENT_POLICY_DEV &&
            (num_segments == tx_ring->sgl_size) &&
            (header_len < tx_ring->tx_max_header_size))
-               return 0;
+               goto checkspace;
 
+       /* Checking for space for 2 additional metadata descriptors due to
+        * possible header split and metadata descriptor. Linearization will
+        * be needed so we reduce the segments number from num_segments to 1
+        */
+       if (!ena_com_sq_have_enough_space(tx_ring->ena_com_io_sq, 3)) {
+               PMD_DRV_LOG(DEBUG, "Not enough space in the tx queue\n");
+               return ENA_COM_NO_MEM;
+       }
        ++tx_ring->tx_stats.linearize;
        rc = rte_pktmbuf_linearize(mbuf);
        if (unlikely(rc)) {
@@ -2386,7 +2396,19 @@ static int ena_check_and_linearize_mbuf(struct ena_ring *tx_ring,
                return rc;
        }
 
-       return rc;
+       return 0;
+
+checkspace:
+       /* Checking for space for 2 additional metadata descriptors due to
+        * possible header split and metadata descriptor
+        */
+       if (!ena_com_sq_have_enough_space(tx_ring->ena_com_io_sq,
+                                         num_segments + 2)) {
+               PMD_DRV_LOG(DEBUG, "Not enough space in the tx queue\n");
+               return ENA_COM_NO_MEM;
+       }
+
+       return 0;
 }
 
 static void ena_tx_map_mbuf(struct ena_ring *tx_ring,
@@ -2473,7 +2495,7 @@ static int ena_xmit_mbuf(struct ena_ring *tx_ring, struct rte_mbuf *mbuf)
        int nb_hw_desc;
        int rc;
 
-       rc = ena_check_and_linearize_mbuf(tx_ring, mbuf);
+       rc = ena_check_space_and_linearize_mbuf(tx_ring, mbuf);
        if (unlikely(rc))
                return rc;
 
@@ -2502,6 +2524,7 @@ static int ena_xmit_mbuf(struct ena_ring *tx_ring, struct rte_mbuf *mbuf)
                        tx_ring->id);
                ena_com_write_sq_doorbell(tx_ring->ena_com_io_sq);
                tx_ring->tx_stats.doorbells++;
+               tx_ring->pkts_without_db = false;
        }
 
        /* prepare the packet's descriptors to dma engine */
@@ -2580,13 +2603,10 @@ static uint16_t eth_ena_xmit_pkts(void *tx_queue, struct rte_mbuf **tx_pkts,
                return 0;
        }
 
-       nb_pkts = RTE_MIN(ena_com_free_q_entries(tx_ring->ena_com_io_sq),
-               nb_pkts);
-
        for (sent_idx = 0; sent_idx < nb_pkts; sent_idx++) {
                if (ena_xmit_mbuf(tx_ring, tx_pkts[sent_idx]))
                        break;
-
+               tx_ring->pkts_without_db = true;
                rte_prefetch0(tx_pkts[ENA_IDX_ADD_MASKED(sent_idx, 4,
                        tx_ring->size_mask)]);
        }
@@ -2595,10 +2615,11 @@ static uint16_t eth_ena_xmit_pkts(void *tx_queue, struct rte_mbuf **tx_pkts,
                ena_com_free_q_entries(tx_ring->ena_com_io_sq);
 
        /* If there are ready packets to be xmitted... */
-       if (sent_idx > 0) {
+       if (likely(tx_ring->pkts_without_db)) {
                /* ...let HW do its best :-) */
                ena_com_write_sq_doorbell(tx_ring->ena_com_io_sq);
                tx_ring->tx_stats.doorbells++;
+               tx_ring->pkts_without_db = false;
        }
 
        ena_tx_cleanup(tx_ring);