net/octeontx: add unicast MAC filter

[dpdk.git] / drivers / net / octeontx / octeontx_ethdev.c

diff --git a/drivers/net/octeontx/octeontx_ethdev.c b/drivers/net/octeontx/octeontx_ethdev.c
index 27eed47..e23162d 100644 (file)
--- a/drivers/net/octeontx/octeontx_ethdev.c
+++ b/drivers/net/octeontx/octeontx_ethdev.c
@@ -174,7 +174,7 @@ octeontx_port_stop(struct octeontx_nic *nic)
        return octeontx_bgx_port_stop(nic->port_id);
 }
 
-static void
+static int
 octeontx_port_promisc_set(struct octeontx_nic *nic, int en)
 {
        struct rte_eth_dev *dev;
@@ -185,15 +185,19 @@ octeontx_port_promisc_set(struct octeontx_nic *nic, int en)
        dev = nic->dev;
 
        res = octeontx_bgx_port_promisc_set(nic->port_id, en);
-       if (res < 0)
+       if (res < 0) {
                octeontx_log_err("failed to set promiscuous mode %d",
                                nic->port_id);
+               return res;
+       }
 
        /* Set proper flag for the mode */
        dev->data->promiscuous = (en != 0) ? 1 : 0;
 
        octeontx_log_dbg("port %d : promiscuous mode %s",
                        nic->port_id, en ? "set" : "unset");
+
+       return 0;
 }
 
 static int
@@ -224,12 +228,12 @@ octeontx_port_stats(struct octeontx_nic *nic, struct rte_eth_stats *stats)
        return 0;
 }
 
-static void
+static int
 octeontx_port_stats_clr(struct octeontx_nic *nic)
 {
        PMD_INIT_FUNC_TRACE();
 
-       octeontx_bgx_port_stats_clr(nic->port_id);
+       return octeontx_bgx_port_stats_clr(nic->port_id);
 }
 
 static inline void
@@ -304,7 +308,7 @@ octeontx_dev_configure(struct rte_eth_dev *dev)
 
        nic->num_tx_queues = dev->data->nb_tx_queues;
 
-       ret = octeontx_pko_channel_open(nic->port_id * PKO_VF_NUM_DQ,
+       ret = octeontx_pko_channel_open(nic->pko_vfid * PKO_VF_NUM_DQ,
                                        nic->num_tx_queues,
                                        nic->base_ochan);
        if (ret) {
@@ -444,22 +448,22 @@ octeontx_dev_stop(struct rte_eth_dev *dev)
        }
 }
 
-static void
+static int
 octeontx_dev_promisc_enable(struct rte_eth_dev *dev)
 {
        struct octeontx_nic *nic = octeontx_pmd_priv(dev);
 
        PMD_INIT_FUNC_TRACE();
-       octeontx_port_promisc_set(nic, 1);
+       return octeontx_port_promisc_set(nic, 1);
 }
 
-static void
+static int
 octeontx_dev_promisc_disable(struct rte_eth_dev *dev)
 {
        struct octeontx_nic *nic = octeontx_pmd_priv(dev);
 
        PMD_INIT_FUNC_TRACE();
-       octeontx_port_promisc_set(nic, 0);
+       return octeontx_port_promisc_set(nic, 0);
 }
 
 static int
@@ -545,13 +549,44 @@ octeontx_dev_stats_get(struct rte_eth_dev *dev, struct rte_eth_stats *stats)
        return octeontx_port_stats(nic, stats);
 }
 
-static void
+static int
 octeontx_dev_stats_reset(struct rte_eth_dev *dev)
 {
        struct octeontx_nic *nic = octeontx_pmd_priv(dev);
 
        PMD_INIT_FUNC_TRACE();
-       octeontx_port_stats_clr(nic);
+       return octeontx_port_stats_clr(nic);
+}
+
+static void
+octeontx_dev_mac_addr_del(struct rte_eth_dev *dev, uint32_t index)
+{
+       struct octeontx_nic *nic = octeontx_pmd_priv(dev);
+       int ret;
+
+       ret = octeontx_bgx_port_mac_del(nic->port_id, index);
+       if (ret != 0)
+               octeontx_log_err("failed to del MAC address filter on port %d",
+                                nic->port_id);
+}
+
+static int
+octeontx_dev_mac_addr_add(struct rte_eth_dev *dev,
+                         struct rte_ether_addr *mac_addr,
+                         __rte_unused uint32_t index,
+                         __rte_unused uint32_t vmdq)
+{
+       struct octeontx_nic *nic = octeontx_pmd_priv(dev);
+       int ret;
+
+       ret = octeontx_bgx_port_mac_add(nic->port_id, mac_addr->addr_bytes);
+       if (ret < 0) {
+               octeontx_log_err("failed to add MAC address filter on port %d",
+                                nic->port_id);
+               return ret;
+       }
+
+       return 0;
 }
 
 static int
@@ -569,11 +604,11 @@ octeontx_dev_default_mac_addr_set(struct rte_eth_dev *dev,
        return ret;
 }
 
-static void
+static int
 octeontx_dev_info(struct rte_eth_dev *dev,
                struct rte_eth_dev_info *dev_info)
 {
-       RTE_SET_USED(dev);
+       struct octeontx_nic *nic = octeontx_pmd_priv(dev);
 
        /* Autonegotiation may be disabled */
        dev_info->speed_capa = ETH_LINK_SPEED_FIXED;
@@ -581,7 +616,8 @@ octeontx_dev_info(struct rte_eth_dev *dev,
                        ETH_LINK_SPEED_1G | ETH_LINK_SPEED_10G |
                        ETH_LINK_SPEED_40G;
 
-       dev_info->max_mac_addrs = 1;
+       dev_info->max_mac_addrs =
+                               octeontx_bgx_port_mac_entries_get(nic->port_id);
        dev_info->max_rx_pktlen = PKI_MAX_PKTLEN;
        dev_info->max_rx_queues = 1;
        dev_info->max_tx_queues = PKO_MAX_NUM_DQ;
@@ -600,6 +636,10 @@ octeontx_dev_info(struct rte_eth_dev *dev,
 
        dev_info->rx_offload_capa = OCTEONTX_RX_OFFLOADS;
        dev_info->tx_offload_capa = OCTEONTX_TX_OFFLOADS;
+       dev_info->rx_queue_offload_capa = OCTEONTX_RX_OFFLOADS;
+       dev_info->tx_queue_offload_capa = OCTEONTX_TX_OFFLOADS;
+
+       return 0;
 }
 
 static void
@@ -713,7 +753,7 @@ octeontx_dev_tx_queue_setup(struct rte_eth_dev *dev, uint16_t qidx,
        RTE_SET_USED(nb_desc);
        RTE_SET_USED(socket_id);
 
-       dq_num = (nic->port_id * PKO_VF_NUM_DQ) + qidx;
+       dq_num = (nic->pko_vfid * PKO_VF_NUM_DQ) + qidx;
 
        /* Socket id check */
        if (socket_id != (unsigned int)SOCKET_ID_ANY &&
@@ -978,6 +1018,8 @@ static const struct eth_dev_ops octeontx_dev_ops = {
        .link_update             = octeontx_dev_link_update,
        .stats_get               = octeontx_dev_stats_get,
        .stats_reset             = octeontx_dev_stats_reset,
+       .mac_addr_remove         = octeontx_dev_mac_addr_del,
+       .mac_addr_add            = octeontx_dev_mac_addr_add,
        .mac_addr_set            = octeontx_dev_default_mac_addr_set,
        .tx_queue_start          = octeontx_dev_tx_queue_start,
        .tx_queue_stop           = octeontx_dev_tx_queue_stop,
@@ -995,11 +1037,13 @@ octeontx_create(struct rte_vdev_device *dev, int port, uint8_t evdev,
                        int socket_id)
 {
        int res;
+       size_t pko_vfid;
        char octtx_name[OCTEONTX_MAX_NAME_LEN];
        struct octeontx_nic *nic = NULL;
        struct rte_eth_dev *eth_dev = NULL;
        struct rte_eth_dev_data *data;
        const char *name = rte_vdev_device_name(dev);
+       int max_entries;
 
        PMD_INIT_FUNC_TRACE();
 
@@ -1033,7 +1077,15 @@ octeontx_create(struct rte_vdev_device *dev, int port, uint8_t evdev,
                goto err;
        }
        data->dev_private = nic;
+       pko_vfid = octeontx_pko_get_vfid();
+
+       if (pko_vfid == SIZE_MAX) {
+               octeontx_log_err("failed to get pko vfid");
+               res = -ENODEV;
+               goto err;
+       }
 
+       nic->pko_vfid = pko_vfid;
        nic->port_id = port;
        nic->evdev = evdev;
 
@@ -1065,7 +1117,16 @@ octeontx_create(struct rte_vdev_device *dev, int port, uint8_t evdev,
        data->all_multicast = 0;
        data->scattered_rx = 0;
 
-       data->mac_addrs = rte_zmalloc_socket(octtx_name, RTE_ETHER_ADDR_LEN, 0,
+       /* Get maximum number of supported MAC entries */
+       max_entries = octeontx_bgx_port_mac_entries_get(nic->port_id);
+       if (max_entries < 0) {
+               octeontx_log_err("Failed to get max entries for mac addr");
+               res = -ENOTSUP;
+               goto err;
+       }
+
+       data->mac_addrs = rte_zmalloc_socket(octtx_name, max_entries *
+                                            RTE_ETHER_ADDR_LEN, 0,
                                                        socket_id);
        if (data->mac_addrs == NULL) {
                octeontx_log_err("failed to allocate memory for mac_addrs");