Support for PCAP physical interface MAC with phy_mac=1 devarg.

Signed-off-by: Juhamatti Kuusisaari <juhamatti.kuusisa...@coriant.com>
---
 drivers/net/pcap/rte_eth_pcap.c | 64 ++++++++++++++++++++++++++++++---
 1 file changed, 59 insertions(+), 5 deletions(-)

diff --git a/drivers/net/pcap/rte_eth_pcap.c b/drivers/net/pcap/rte_eth_pcap.c
index e8810a171..b693f26e7 100644
--- a/drivers/net/pcap/rte_eth_pcap.c
+++ b/drivers/net/pcap/rte_eth_pcap.c
@@ -7,6 +7,9 @@
 #include <time.h>
 
 #include <net/if.h>
+#include <sys/socket.h>
+#include <sys/ioctl.h>
+#include <unistd.h>
 
 #include <pcap.h>
 
@@ -17,6 +20,7 @@
 #include <rte_malloc.h>
 #include <rte_mbuf.h>
 #include <rte_bus_vdev.h>
+#include <rte_string_fns.h>
 
 #define RTE_ETH_PCAP_SNAPSHOT_LEN 65535
 #define RTE_ETH_PCAP_SNAPLEN ETHER_MAX_JUMBO_FRAME_LEN
@@ -29,6 +33,7 @@
 #define ETH_PCAP_RX_IFACE_IN_ARG "rx_iface_in"
 #define ETH_PCAP_TX_IFACE_ARG "tx_iface"
 #define ETH_PCAP_IFACE_ARG    "iface"
+#define ETH_PCAP_PHY_MAC_ARG  "phy_mac"
 
 #define ETH_PCAP_ARG_MAXLEN    64
 
@@ -87,6 +92,7 @@ static const char *valid_arguments[] = {
        ETH_PCAP_RX_IFACE_IN_ARG,
        ETH_PCAP_TX_IFACE_ARG,
        ETH_PCAP_IFACE_ARG,
+       ETH_PCAP_PHY_MAC_ARG,
        NULL
 };
 
@@ -909,7 +915,7 @@ eth_from_pcaps_common(struct rte_vdev_device *vdev,
                struct pmd_devargs *rx_queues, const unsigned int nb_rx_queues,
                struct pmd_devargs *tx_queues, const unsigned int nb_tx_queues,
                struct rte_kvargs *kvlist, struct pmd_internals **internals,
-               struct rte_eth_dev **eth_dev)
+               const int phy_mac, struct rte_eth_dev **eth_dev)
 {
        struct rte_kvargs_pair *pair = NULL;
        unsigned int k_idx;
@@ -955,6 +961,26 @@ eth_from_pcaps_common(struct rte_vdev_device *vdev,
        else
                (*internals)->if_index = if_nametoindex(pair->value);
 
+       if (phy_mac) {
+               const unsigned int numa_node = vdev->device.numa_node;
+               const char *if_name = pair->value;
+               int if_fd = socket(AF_INET, SOCK_DGRAM, 0);
+               if (if_fd != -1) {
+                       struct ifreq ifr;
+                       strlcpy(ifr.ifr_name, if_name, sizeof(ifr.ifr_name));
+                       if (!ioctl(if_fd, SIOCGIFHWADDR, &ifr)) {
+                               PMD_LOG(INFO, "Setting phy MAC for %s\n",
+                                               if_name);
+                               (*eth_dev)->data->mac_addrs =
+                                       rte_zmalloc_socket(NULL, ETHER_ADDR_LEN,
+                                                       0, numa_node);
+                               rte_memcpy((*eth_dev)->data->mac_addrs,
+                                               ifr.ifr_addr.sa_data,
+                                               ETHER_ADDR_LEN);
+                       }
+                       close(if_fd);
+               }
+       }
        return 0;
 }
 
@@ -962,7 +988,7 @@ static int
 eth_from_pcaps(struct rte_vdev_device *vdev,
                struct pmd_devargs *rx_queues, const unsigned int nb_rx_queues,
                struct pmd_devargs *tx_queues, const unsigned int nb_tx_queues,
-               struct rte_kvargs *kvlist, int single_iface,
+               struct rte_kvargs *kvlist, int single_iface, int phy_mac,
                unsigned int using_dumpers)
 {
        struct pmd_internals *internals = NULL;
@@ -970,7 +996,7 @@ eth_from_pcaps(struct rte_vdev_device *vdev,
        int ret;
 
        ret = eth_from_pcaps_common(vdev, rx_queues, nb_rx_queues,
-               tx_queues, nb_tx_queues, kvlist, &internals, &eth_dev);
+                       tx_queues, nb_tx_queues, kvlist, &internals, phy_mac, 
&eth_dev);
 
        if (ret < 0)
                return ret;
@@ -989,6 +1015,22 @@ eth_from_pcaps(struct rte_vdev_device *vdev,
        return 0;
 }
 
+static int
+select_phy_mac(const char *key, const char *value, void *extra_args)
+{
+       if (extra_args && strcmp(key, ETH_PCAP_PHY_MAC_ARG) == 0) {
+               const int phy_mac = atoi(value);
+               int *enable_phy_mac = extra_args;
+
+               if (phy_mac != 0 && phy_mac != 1)
+                       PMD_LOG(WARNING, "Value should be 0 or 1, set it as 
1!");
+
+               if (phy_mac)
+                       *enable_phy_mac = 1;
+       }
+       return 0;
+}
+
 static int
 pmd_pcap_probe(struct rte_vdev_device *dev)
 {
@@ -999,6 +1041,7 @@ pmd_pcap_probe(struct rte_vdev_device *dev)
        struct pmd_devargs dumpers = {0};
        struct rte_eth_dev *eth_dev;
        int single_iface = 0;
+       int phy_mac = 0;
        int ret;
 
        name = rte_vdev_device_name(dev);
@@ -1026,6 +1069,16 @@ pmd_pcap_probe(struct rte_vdev_device *dev)
        if (kvlist == NULL)
                return -1;
 
+       /*
+        * We check whether we want to use phy MAC of pcap interface.
+        */
+       if (rte_kvargs_count(kvlist, ETH_PCAP_PHY_MAC_ARG)) {
+               ret = rte_kvargs_process(kvlist, ETH_PCAP_PHY_MAC_ARG,
+                               &select_phy_mac, &phy_mac);
+               if (ret < 0)
+                       goto free_kvlist;
+       }
+
        /*
         * If iface argument is passed we open the NICs and use them for
         * reading / writing
@@ -1084,7 +1137,7 @@ pmd_pcap_probe(struct rte_vdev_device *dev)
 
 create_eth:
        ret = eth_from_pcaps(dev, &pcaps, pcaps.num_of_queue, &dumpers,
-               dumpers.num_of_queue, kvlist, single_iface, is_tx_pcap);
+                       dumpers.num_of_queue, kvlist, single_iface, phy_mac, 
is_tx_pcap);
 
 free_kvlist:
        rte_kvargs_free(kvlist);
@@ -1128,7 +1181,8 @@ RTE_PMD_REGISTER_PARAM_STRING(net_pcap,
        ETH_PCAP_RX_IFACE_ARG "=<ifc> "
        ETH_PCAP_RX_IFACE_IN_ARG "=<ifc> "
        ETH_PCAP_TX_IFACE_ARG "=<ifc> "
-       ETH_PCAP_IFACE_ARG "=<ifc>");
+       ETH_PCAP_IFACE_ARG "=<ifc> "
+       ETH_PCAP_PHY_MAC_ARG "=<int>");
 
 RTE_INIT(eth_pcap_init_log)
 {
-- 
2.17.1

Reply via email to