net/cxgbe: fix port ID in Rx mbuf
[dpdk.git] / drivers / net / sfc / sfc_tx.c
index ce2a9a6..f376f24 100644 (file)
@@ -54,23 +54,23 @@ sfc_tx_get_offload_mask(struct sfc_adapter *sa)
        uint64_t no_caps = 0;
 
        if (!encp->enc_hw_tx_insert_vlan_enabled)
-               no_caps |= DEV_TX_OFFLOAD_VLAN_INSERT;
+               no_caps |= RTE_ETH_TX_OFFLOAD_VLAN_INSERT;
 
        if (!encp->enc_tunnel_encapsulations_supported)
-               no_caps |= DEV_TX_OFFLOAD_OUTER_IPV4_CKSUM;
+               no_caps |= RTE_ETH_TX_OFFLOAD_OUTER_IPV4_CKSUM;
 
        if (!sa->tso)
-               no_caps |= DEV_TX_OFFLOAD_TCP_TSO;
+               no_caps |= RTE_ETH_TX_OFFLOAD_TCP_TSO;
 
        if (!sa->tso_encap ||
            (encp->enc_tunnel_encapsulations_supported &
             (1u << EFX_TUNNEL_PROTOCOL_VXLAN)) == 0)
-               no_caps |= DEV_TX_OFFLOAD_VXLAN_TNL_TSO;
+               no_caps |= RTE_ETH_TX_OFFLOAD_VXLAN_TNL_TSO;
 
        if (!sa->tso_encap ||
            (encp->enc_tunnel_encapsulations_supported &
             (1u << EFX_TUNNEL_PROTOCOL_GENEVE)) == 0)
-               no_caps |= DEV_TX_OFFLOAD_GENEVE_TNL_TSO;
+               no_caps |= RTE_ETH_TX_OFFLOAD_GENEVE_TNL_TSO;
 
        return ~no_caps;
 }
@@ -114,8 +114,8 @@ sfc_tx_qcheck_conf(struct sfc_adapter *sa, unsigned int txq_max_fill_level,
        }
 
        /* We either perform both TCP and UDP offload, or no offload at all */
-       if (((offloads & DEV_TX_OFFLOAD_TCP_CKSUM) == 0) !=
-           ((offloads & DEV_TX_OFFLOAD_UDP_CKSUM) == 0)) {
+       if (((offloads & RTE_ETH_TX_OFFLOAD_TCP_CKSUM) == 0) !=
+           ((offloads & RTE_ETH_TX_OFFLOAD_UDP_CKSUM) == 0)) {
                sfc_err(sa, "TCP and UDP offloads can't be set independently");
                rc = EINVAL;
        }
@@ -194,7 +194,7 @@ sfc_tx_qinit(struct sfc_adapter *sa, sfc_sw_index_t sw_index,
                SFC_TX_DEFAULT_FREE_THRESH;
        txq_info->offloads = offloads;
 
-       rc = sfc_dma_alloc(sa, "txq", sw_index,
+       rc = sfc_dma_alloc(sa, "txq", sw_index, EFX_NIC_DMA_ADDR_TX_RING,
                           efx_txq_size(sa->nic, txq_info->entries),
                           socket_id, &txq->mem);
        if (rc != 0)
@@ -226,6 +226,8 @@ sfc_tx_qinit(struct sfc_adapter *sa, sfc_sw_index_t sw_index,
        info.tso_max_payload_len = encp->enc_tx_tso_max_payload_length;
        info.tso_max_nb_outgoing_frames = encp->enc_tx_tso_max_nframes;
 
+       info.nic_dma_info = &sas->nic_dma_info;
+
        rc = sa->priv.dp_tx->qcreate(sa->eth_dev->data->port_id, sw_index,
                                     &RTE_ETH_DEV_TO_PCI(sa->eth_dev)->addr,
                                     socket_id, &info, &txq_info->dp);
@@ -290,7 +292,7 @@ sfc_tx_qfini(struct sfc_adapter *sa, sfc_sw_index_t sw_index)
        txq->evq = NULL;
 }
 
-static int
+int
 sfc_tx_qinit_info(struct sfc_adapter *sa, sfc_sw_index_t sw_index)
 {
        struct sfc_adapter_shared * const sas = sfc_sa2shared(sa);
@@ -306,10 +308,11 @@ sfc_tx_qinit_info(struct sfc_adapter *sa, sfc_sw_index_t sw_index)
 static int
 sfc_tx_check_mode(struct sfc_adapter *sa, const struct rte_eth_txmode *txmode)
 {
+       uint64_t dev_tx_offload_cap = sfc_tx_get_dev_offload_caps(sa);
        int rc = 0;
 
        switch (txmode->mq_mode) {
-       case ETH_MQ_TX_NONE:
+       case RTE_ETH_MQ_TX_NONE:
                break;
        default:
                sfc_err(sa, "Tx multi-queue mode %u not supported",
@@ -317,6 +320,13 @@ sfc_tx_check_mode(struct sfc_adapter *sa, const struct rte_eth_txmode *txmode)
                rc = EINVAL;
        }
 
+       if ((dev_tx_offload_cap & RTE_ETH_TX_OFFLOAD_MBUF_FAST_FREE) != 0 &&
+           (txmode->offloads & RTE_ETH_TX_OFFLOAD_MBUF_FAST_FREE) == 0) {
+               sfc_err(sa, "There is no FAST_FREE flag in the attempted Tx mode configuration");
+               sfc_err(sa, "FAST_FREE is always active as per the current Tx datapath variant");
+               rc = EINVAL;
+       }
+
        /*
         * These features are claimed to be i40e-specific,
         * but it does make sense to double-check their absence
@@ -354,7 +364,7 @@ sfc_tx_fini_queues(struct sfc_adapter *sa, unsigned int nb_tx_queues)
 
        /*
         * Finalize only ethdev queues since other ones are finalized only
-        * on device close and they may require additional deinitializaton.
+        * on device close and they may require additional deinitialization.
         */
        ethdev_qid = sas->ethdev_txq_count;
        while (--ethdev_qid >= (int)nb_tx_queues) {
@@ -376,6 +386,9 @@ sfc_tx_configure(struct sfc_adapter *sa)
        const efx_nic_cfg_t *encp = efx_nic_cfg_get(sa->nic);
        const struct rte_eth_conf *dev_conf = &sa->eth_dev->data->dev_conf;
        const unsigned int nb_tx_queues = sa->eth_dev->data->nb_tx_queues;
+       const unsigned int nb_rsvd_tx_queues = sfc_nb_txq_reserved(sas);
+       const unsigned int nb_txq_total = nb_tx_queues + nb_rsvd_tx_queues;
+       bool reconfigure;
        int rc = 0;
 
        sfc_log_init(sa, "nb_tx_queues=%u (old %u)",
@@ -395,11 +408,12 @@ sfc_tx_configure(struct sfc_adapter *sa)
        if (rc != 0)
                goto fail_check_mode;
 
-       if (nb_tx_queues == sas->txq_count)
+       if (nb_txq_total == sas->txq_count)
                goto done;
 
        if (sas->txq_info == NULL) {
-               sas->txq_info = rte_calloc_socket("sfc-txqs", nb_tx_queues,
+               reconfigure = false;
+               sas->txq_info = rte_calloc_socket("sfc-txqs", nb_txq_total,
                                                  sizeof(sas->txq_info[0]), 0,
                                                  sa->socket_id);
                if (sas->txq_info == NULL)
@@ -410,35 +424,37 @@ sfc_tx_configure(struct sfc_adapter *sa)
                 * since it should not be shared.
                 */
                rc = ENOMEM;
-               sa->txq_ctrl = calloc(nb_tx_queues, sizeof(sa->txq_ctrl[0]));
+               sa->txq_ctrl = calloc(nb_txq_total, sizeof(sa->txq_ctrl[0]));
                if (sa->txq_ctrl == NULL)
                        goto fail_txqs_ctrl_alloc;
        } else {
                struct sfc_txq_info *new_txq_info;
                struct sfc_txq *new_txq_ctrl;
 
+               reconfigure = true;
+
                if (nb_tx_queues < sas->ethdev_txq_count)
                        sfc_tx_fini_queues(sa, nb_tx_queues);
 
                new_txq_info =
                        rte_realloc(sas->txq_info,
-                                   nb_tx_queues * sizeof(sas->txq_info[0]), 0);
-               if (new_txq_info == NULL && nb_tx_queues > 0)
+                                   nb_txq_total * sizeof(sas->txq_info[0]), 0);
+               if (new_txq_info == NULL && nb_txq_total > 0)
                        goto fail_txqs_realloc;
 
                new_txq_ctrl = realloc(sa->txq_ctrl,
-                                      nb_tx_queues * sizeof(sa->txq_ctrl[0]));
-               if (new_txq_ctrl == NULL && nb_tx_queues > 0)
+                                      nb_txq_total * sizeof(sa->txq_ctrl[0]));
+               if (new_txq_ctrl == NULL && nb_txq_total > 0)
                        goto fail_txqs_ctrl_realloc;
 
                sas->txq_info = new_txq_info;
                sa->txq_ctrl = new_txq_ctrl;
-               if (nb_tx_queues > sas->ethdev_txq_count) {
-                       memset(&sas->txq_info[sas->ethdev_txq_count], 0,
-                              (nb_tx_queues - sas->ethdev_txq_count) *
+               if (nb_txq_total > sas->txq_count) {
+                       memset(&sas->txq_info[sas->txq_count], 0,
+                              (nb_txq_total - sas->txq_count) *
                               sizeof(sas->txq_info[0]));
-                       memset(&sa->txq_ctrl[sas->ethdev_txq_count], 0,
-                              (nb_tx_queues - sas->ethdev_txq_count) *
+                       memset(&sa->txq_ctrl[sas->txq_count], 0,
+                              (nb_txq_total - sas->txq_count) *
                               sizeof(sa->txq_ctrl[0]));
                }
        }
@@ -455,11 +471,18 @@ sfc_tx_configure(struct sfc_adapter *sa)
                sas->ethdev_txq_count++;
        }
 
-       sas->txq_count = sas->ethdev_txq_count;
+       sas->txq_count = sas->ethdev_txq_count + nb_rsvd_tx_queues;
+
+       if (!reconfigure) {
+               rc = sfc_repr_proxy_txq_init(sa);
+               if (rc != 0)
+                       goto fail_repr_proxy_txq_init;
+       }
 
 done:
        return 0;
 
+fail_repr_proxy_txq_init:
 fail_tx_qinit_info:
 fail_txqs_ctrl_realloc:
 fail_txqs_realloc:
@@ -477,6 +500,7 @@ void
 sfc_tx_close(struct sfc_adapter *sa)
 {
        sfc_tx_fini_queues(sa, 0);
+       sfc_repr_proxy_txq_fini(sa);
 
        free(sa->txq_ctrl);
        sa->txq_ctrl = NULL;
@@ -515,23 +539,23 @@ sfc_tx_qstart(struct sfc_adapter *sa, sfc_sw_index_t sw_index)
        if (rc != 0)
                goto fail_ev_qstart;
 
-       if (txq_info->offloads & DEV_TX_OFFLOAD_IPV4_CKSUM)
+       if (txq_info->offloads & RTE_ETH_TX_OFFLOAD_IPV4_CKSUM)
                flags |= EFX_TXQ_CKSUM_IPV4;
 
-       if (txq_info->offloads & DEV_TX_OFFLOAD_OUTER_IPV4_CKSUM)
+       if (txq_info->offloads & RTE_ETH_TX_OFFLOAD_OUTER_IPV4_CKSUM)
                flags |= EFX_TXQ_CKSUM_INNER_IPV4;
 
-       if ((txq_info->offloads & DEV_TX_OFFLOAD_TCP_CKSUM) ||
-           (txq_info->offloads & DEV_TX_OFFLOAD_UDP_CKSUM)) {
+       if ((txq_info->offloads & RTE_ETH_TX_OFFLOAD_TCP_CKSUM) ||
+           (txq_info->offloads & RTE_ETH_TX_OFFLOAD_UDP_CKSUM)) {
                flags |= EFX_TXQ_CKSUM_TCPUDP;
 
-               if (offloads_supported & DEV_TX_OFFLOAD_OUTER_IPV4_CKSUM)
+               if (offloads_supported & RTE_ETH_TX_OFFLOAD_OUTER_IPV4_CKSUM)
                        flags |= EFX_TXQ_CKSUM_INNER_TCPUDP;
        }
 
-       if (txq_info->offloads & (DEV_TX_OFFLOAD_TCP_TSO |
-                                 DEV_TX_OFFLOAD_VXLAN_TNL_TSO |
-                                 DEV_TX_OFFLOAD_GENEVE_TNL_TSO))
+       if (txq_info->offloads & (RTE_ETH_TX_OFFLOAD_TCP_TSO |
+                                 RTE_ETH_TX_OFFLOAD_VXLAN_TNL_TSO |
+                                 RTE_ETH_TX_OFFLOAD_GENEVE_TNL_TSO))
                flags |= EFX_TXQ_FATSOV2;
 
        rc = efx_tx_qcreate(sa->nic, txq->hw_index, 0, &txq->mem,
@@ -766,7 +790,7 @@ static unsigned int
 sfc_efx_tx_maybe_insert_tag(struct sfc_efx_txq *txq, struct rte_mbuf *m,
                            efx_desc_t **pend)
 {
-       uint16_t this_tag = ((m->ol_flags & PKT_TX_VLAN_PKT) ?
+       uint16_t this_tag = ((m->ol_flags & RTE_MBUF_F_TX_VLAN) ?
                             m->vlan_tci : 0);
 
        if (this_tag == txq->hw_vlan_tci)
@@ -862,14 +886,14 @@ sfc_efx_xmit_pkts(void *tx_queue, struct rte_mbuf **tx_pkts, uint16_t nb_pkts)
 
                /*
                 * Here VLAN TCI is expected to be zero in case if no
-                * DEV_TX_OFFLOAD_VLAN_INSERT capability is advertised;
+                * RTE_ETH_TX_OFFLOAD_VLAN_INSERT capability is advertised;
                 * if the calling app ignores the absence of
-                * DEV_TX_OFFLOAD_VLAN_INSERT and pushes VLAN TCI, then
+                * RTE_ETH_TX_OFFLOAD_VLAN_INSERT and pushes VLAN TCI, then
                 * TX_ERROR will occur
                 */
                pkt_descs += sfc_efx_tx_maybe_insert_tag(txq, m_seg, &pend);
 
-               if (m_seg->ol_flags & PKT_TX_TCP_SEG) {
+               if (m_seg->ol_flags & RTE_MBUF_F_TX_TCP_SEG) {
                        /*
                         * We expect correct 'pkt->l[2, 3, 4]_len' values
                         * to be set correctly by the caller
@@ -980,8 +1004,10 @@ sfc_efx_xmit_pkts(void *tx_queue, struct rte_mbuf **tx_pkts, uint16_t nb_pkts)
                                       txq->completed, &txq->added);
                SFC_ASSERT(rc == 0);
 
-               if (likely(pushed != txq->added))
+               if (likely(pushed != txq->added)) {
                        efx_tx_qpush(txq->common, txq->added, pushed);
+                       txq->dp.dpq.dbells++;
+               }
        }
 
 #if SFC_TX_XMIT_PKTS_REAP_AT_LEAST_ONCE
@@ -1066,6 +1092,10 @@ sfc_efx_tx_qcreate(uint16_t port_id, uint16_t queue_id,
        struct sfc_txq *ctrl_txq;
        int rc;
 
+       rc = ENOTSUP;
+       if (info->nic_dma_info->nb_regions > 0)
+               goto fail_nic_dma;
+
        rc = ENOMEM;
        txq = rte_zmalloc_socket("sfc-efx-txq", sizeof(*txq),
                                 RTE_CACHE_LINE_SIZE, socket_id);
@@ -1117,6 +1147,7 @@ fail_pend_desc_alloc:
        rte_free(txq);
 
 fail_txq_alloc:
+fail_nic_dma:
        return rc;
 }
 
@@ -1226,13 +1257,13 @@ struct sfc_dp_tx sfc_efx_tx = {
                .hw_fw_caps     = SFC_DP_HW_FW_CAP_TX_EFX,
        },
        .features               = 0,
-       .dev_offload_capa       = DEV_TX_OFFLOAD_VLAN_INSERT |
-                                 DEV_TX_OFFLOAD_MULTI_SEGS,
-       .queue_offload_capa     = DEV_TX_OFFLOAD_IPV4_CKSUM |
-                                 DEV_TX_OFFLOAD_UDP_CKSUM |
-                                 DEV_TX_OFFLOAD_TCP_CKSUM |
-                                 DEV_TX_OFFLOAD_OUTER_IPV4_CKSUM |
-                                 DEV_TX_OFFLOAD_TCP_TSO,
+       .dev_offload_capa       = RTE_ETH_TX_OFFLOAD_VLAN_INSERT |
+                                 RTE_ETH_TX_OFFLOAD_MULTI_SEGS,
+       .queue_offload_capa     = RTE_ETH_TX_OFFLOAD_IPV4_CKSUM |
+                                 RTE_ETH_TX_OFFLOAD_UDP_CKSUM |
+                                 RTE_ETH_TX_OFFLOAD_TCP_CKSUM |
+                                 RTE_ETH_TX_OFFLOAD_OUTER_IPV4_CKSUM |
+                                 RTE_ETH_TX_OFFLOAD_TCP_TSO,
        .qsize_up_rings         = sfc_efx_tx_qsize_up_rings,
        .qcreate                = sfc_efx_tx_qcreate,
        .qdestroy               = sfc_efx_tx_qdestroy,