diff mbox series

[ovs-dev,RFC,ovs,11/14] netdev-dpdk: Introduce an API to query if a dpdk port is an uplink port

Message ID 20201209134832.17998-12-elibr@nvidia.com
State RFC
Headers show
Series Netdev datapath VXLAN decap offload support | expand

Commit Message

Eli Britstein Dec. 9, 2020, 1:48 p.m. UTC 
When a vport is offloaded it has no explicit matching physical port so
rte_flows are created on each of the uplink ports. Add an API to query
if a DPDK port is an uplink port, as a pre-step towards applying vport
flows on the uplink ports.

Signed-off-by: Eli Britstein <elibr@nvidia.com>
---
 lib/netdev-dpdk.c | 22 ++++++++++++++++++++++
 lib/netdev-dpdk.h |  2 ++
 2 files changed, 24 insertions(+)
diff mbox series

Patch

diff --git a/lib/netdev-dpdk.c b/lib/netdev-dpdk.c
index 6db72d3fe..70f4bff72 100644
--- a/lib/netdev-dpdk.c
+++ b/lib/netdev-dpdk.c
@@ -443,6 +443,7 @@  struct netdev_dpdk {
         };
         struct dpdk_tx_queue *tx_q;
         struct rte_eth_link link;
+        bool is_uplink_port; /* True=uplink port, false=representor port. */
     );
 
     PADDED_MEMBERS_CACHELINE_MARKER(CACHE_LINE_SIZE, cacheline1,
@@ -1143,6 +1144,9 @@  dpdk_eth_dev_init(struct netdev_dpdk *dev)
         }
     }
 
+    dev->is_uplink_port = !(*info.dev_flags & RTE_ETH_DEV_REPRESENTOR) &&
+        info.switch_info.domain_id != RTE_ETH_DEV_SWITCH_DOMAIN_ID_INVALID;
+
     n_rxq = MIN(info.max_rx_queues, dev->up.n_rxq);
     n_txq = MIN(info.max_tx_queues, dev->up.n_txq);
 
@@ -5220,6 +5224,24 @@  out:
     return ret;
 }
 
+bool
+netdev_dpdk_is_uplink_port(struct netdev *netdev)
+{
+    struct netdev_dpdk *dev;
+    bool ret = false;
+
+    if (!is_dpdk_class(netdev->netdev_class)) {
+        goto out;
+    }
+
+    dev = netdev_dpdk_cast(netdev);
+    ovs_mutex_lock(&dev->mutex);
+    ret = dev->is_uplink_port;
+    ovs_mutex_unlock(&dev->mutex);
+out:
+    return ret;
+}
+
 bool
 netdev_dpdk_flow_api_supported(struct netdev *netdev)
 {
diff --git a/lib/netdev-dpdk.h b/lib/netdev-dpdk.h
index e987026de..96a3e65aa 100644
--- a/lib/netdev-dpdk.h
+++ b/lib/netdev-dpdk.h
@@ -50,6 +50,8 @@  netdev_dpdk_rte_flow_query_count(struct netdev *netdev,
                                  struct rte_flow_error *error);
 int
 netdev_dpdk_get_port_id(struct netdev *netdev);
+bool
+netdev_dpdk_is_uplink_port(struct netdev *netdev);
 #ifdef ALLOW_EXPERIMENTAL_API
 int
 netdev_dpdk_rte_flow_tunnel_decap_set(struct netdev *,