Add vdpa_utils.py

This patch introduces an OVSHandler class and supporting functions:
 - check ovs status and retrieve bridge/port information
 - handle vdpa device integration with ovs
 - add flow rules to ovs bridge
 - provide flexible bridge and port info for vm
 - add vdpa_dpdk case usage: add flows rules to ovs
 - add netperf case usage: add flows rules to ovs and get vdpa ovs
port info

Signed-off-by: Wenli Quan <[email protected]>

Author: quanwenli

generic/tests/cfg/netperf.cfg

@@ -34,6 +34,7 @@
     #numa configration
     numa_node = -1
     netperf_with_numa = yes
+    add_flows = yes
     # configure netperf test parameters, some seconds will be took to
     # wait all the clients work, this wait time should be less than
     # 0.5 * l, the wait time will augments if you have move

generic/tests/netperf.py

@@ -7,7 +7,7 @@
 from avocado.utils import process
 from virttest import error_context, remote, utils_misc, utils_net, utils_test, virt_vm
 
-from provider import netperf_base, win_driver_utils
+from provider import netperf_base, vdpa_utils, win_driver_utils
 
 LOG_JOB = logging.getLogger("avocado.test")
 
@@ -76,52 +76,13 @@ def mtu_set(mtu):
         if netdst in br_in_use:
             ifaces_in_use = host_bridges.list_iface()
             target_ifaces = list(ifaces_in_use + br_in_use)
-        if (
-            process.system(
-                "which ovs-vsctl && systemctl status openvswitch.service",
-                ignore_status=True,
-                shell=True,
-            )
-            == 0
-        ):
-            ovs_br_all = netperf_base.ssh_cmd(host, "ovs-vsctl list-br")
-            ovs_br = []
-            if ovs_br_all:
-                for nic in vm.virtnet:
-                    if nic.netdst in ovs_br_all:
-                        ovs_br.append(nic.netdst)
-                    elif nic.nettype == "vdpa":
-                        vf_pci = netperf_base.ssh_cmd(
-                            host,
-                            "vdpa dev show |grep %s | grep -o 'pci/[^[:space:]]*' | "
-                            "awk -F/ '{print $2}'" % nic.netdst,
-                        )
-                        pf_pci = netperf_base.ssh_cmd(
-                            host,
-                            "grep PCI_SLOT_NAME /sys/bus/pci/devices/%s/physfn/uevent |"
-                            " cut -d'=' -f2" % vf_pci,
-                        )
-                        port = netperf_base.ssh_cmd(
-                            host, "ls /sys/bus/pci/devices/%s/net/ | head -n 1" % pf_pci
-                        )
-                        ovs_br_vdpa = netperf_base.ssh_cmd(
-                            host, "ovs-vsctl port-to-br %s" % port
-                        )
-                        cmd = (
-                            f"ovs-ofctl add-flow {ovs_br_vdpa} '"
-                            "in_port=1,idle_timeout=0 actions=output:2'"
-                        )
-                        cmd += (
-                            f"&&  ovs-ofctl add-flow {ovs_br_vdpa} '"
-                            "in_port=2,idle_timeout=0 actions=output:1'"
-                        )
-                        cmd += "&&  ovs-ofctl dump-flows {}".format(ovs_br_vdpa)
-                        netperf_base.ssh_cmd(host, cmd)
-                        ovs_br.append(ovs_br_vdpa)
-                for br in ovs_br:
-                    ovs_list = "ovs-vsctl list-ports %s" % br
-                    ovs_port = netperf_base.ssh_cmd(host, ovs_list)
-                    target_ifaces.extend(ovs_port.split() + [br])
+
+        add_flows = params.get("add_flows", "yes") == "yes"
+        ovs_handler = vdpa_utils.OVSHandler(vm)
+        target_ifaces.extend(
+            ovs_handler.get_vdpa_ovs_info(add_flows=add_flows, return_ports=True)
+        )
+
         if vm.virtnet[0].nettype == "macvtap":
             target_ifaces.extend([vm.virtnet[0].netdst, vm.get_ifname(0)])
         error_context.context("Change all Bridge NICs MTU to %s" % mtu, test.log.info)

provider/vdpa_utils.py

@@ -0,0 +1,131 @@
+from avocado.utils import process
+
+
+def check_ovs_status():
+    """
+    Check if ovs-vsctl and openvswitch service are installed and running.
+    Returns True if both are available and running, otherwise False.
+    """
+    cmd = "which ovs-vsctl && systemctl status openvswitch.service"
+    return process.system(cmd, ignore_status=True, shell=True) == 0
+
+
+def get_ovs_bridges():
+    """
+    Get all ovs bridges.
+    Returns a list of ovs bridge names.
+    """
+    cmd = "ovs-vsctl list-br"
+    return process.system_output(cmd, shell=True).decode().split()
+
+
+def get_vf_pci_address(nic_netdst):
+    """
+    Get vf pci address from a given network destination.
+    Returns the vf pci address as a string.
+    """
+    cmd = (
+        "vdpa dev show | grep {0} | grep -o 'pci/[^[:space:]]*' | "
+        "awk -F/ '{{print $2}}'"
+    ).format(nic_netdst)
+    return process.system_output(cmd, shell=True).decode().strip()
+
+
+def get_pf_pci_address(vf_pci):
+    """
+    Get pf pci address using vf pci address.
+    Returns the pf pci address as a string.
+    """
+    cmd = (
+        "grep PCI_SLOT_NAME /sys/bus/pci/devices/{0}/physfn/uevent | cut -d'=' -f2"
+    ).format(vf_pci)
+    return process.system_output(cmd, shell=True).decode().strip()
+
+
+def get_pf_port(pf_pci):
+    """
+    Get the port for the pf pci address.
+    Returns the port name.
+    """
+    cmd = "ls /sys/bus/pci/devices/{0}/net/ | head -n 1".format(pf_pci)
+    return process.system_output(cmd, shell=True).decode().strip()
+
+
+def get_ovs_bridge_for_port(port):
+    """
+    Get the ovs bridge name for the given network port.
+    Returns the bridge name.
+    """
+    cmd = "ovs-vsctl port-to-br {0}".format(port)
+    return process.system_output(cmd, shell=True).decode().strip()
+
+
+def get_ovs_port_for_bridge(bridge):
+    """
+    Get the ovs port name for the given bridge port.
+    Returns the bridge name.
+    """
+    cmd = "ovs-vsctl list-ports {0}".format(bridge)
+    return process.system_output(cmd, shell=True).decode().strip()
+
+
+def get_vdpa_ovs_bridges(vm):
+    """
+    Get OVS bridge for VDPA devices in the VM.
+    Returns the OVS bridge name, or None if not found.
+    """
+    for nic in vm.virtnet:
+        if nic.nettype == "vdpa":
+            vf_pci = get_vf_pci_address(nic.netdst)
+            pf_pci = get_pf_pci_address(vf_pci)
+            port = get_pf_port(pf_pci)
+            return get_ovs_bridge_for_port(port)
+    return None
+
+
+def add_flows_to_ovs_bridge(br):
+    """
+    Add flow rules to the given ovs bridge.
+    """
+    cmd = "ovs-ofctl add-flow {0} 'in_port=1,idle_timeout=0 actions=output:2'".format(
+        br
+    )
+    cmd += (
+        " && ovs-ofctl add-flow {0} 'in_port=2,idle_timeout=0 actions=output:1'".format(
+            br
+        )
+    )
+    cmd += " && ovs-ofctl dump-flows {0}".format(br)
+    process.run(cmd, shell=True)
+
+
+class OVSHandler:
+    def __init__(self, vm):
+        self.vm = vm
+
+    def get_vdpa_ovs_info(self, add_flows=True, return_ports=True):
+        """
+        Get OVS bridge and port information
+        """
+        if check_ovs_status():
+            ovs_br_all = get_ovs_bridges()
+            ovs_br = []
+            target_ifaces = []
+
+            vdpa_br = get_vdpa_ovs_bridges(self.vm)
+            if vdpa_br:
+                if add_flows:
+                    add_flows_to_ovs_bridge(vdpa_br)
+                ovs_br.append(vdpa_br)
+
+            for nic in self.vm.virtnet:
+                if nic.netdst in ovs_br_all:
+                    ovs_br.append(nic.netdst)
+
+            for br in ovs_br:
+                ovs_port = get_ovs_port_for_bridge(br)
+                if return_ports:
+                    target_ifaces.extend(ovs_port.split() + [br])
+
+            if return_ports:
+                return target_ifaces

qemu/tests/cfg/vdpa_dpdk.cfg

@@ -30,6 +30,7 @@
     enable_guest_iommu = yes
     guest_iommu_option = pt
     kernel_extra_params_ad = "default_hugepagesz=1G hugepagesz=1G hugepages=10"
+    add_flows = yes
     # Packet Sending Host Configuration
     #dsthost = The IP address of the packet sending host
     #username_dsthost = Username for the host

qemu/tests/vdpa_dpdk.py

@@ -6,7 +6,7 @@
 from avocado.utils import process
 from virttest import remote, utils_misc, utils_net, utils_sriov
 
-from provider import dpdk_utils
+from provider import dpdk_utils, vdpa_utils
 
 LOG_JOB = logging.getLogger("avocado.test")
 
@@ -62,6 +62,7 @@ def run(test, params, env):
     guest_ver_cmd = params["guest_ver_cmd"]
     base = params.get("format_base", "12")
     fbase = params.get("format_fbase", "2")
+    add_flows = params.get("add_flows", "yes") == "yes"
 
     session = vm.wait_for_login(timeout=login_timeout, restart_network=True)
 
@@ -75,6 +76,9 @@ def run(test, params, env):
     result_file.write("### kvm_version : %s\n" % host_ver)
     result_file.write("### guest-kernel-ver :%s" % guest_ver)
 
+    ovs_handler = vdpa_utils.OVSHandler(vm)
+    ovs_handler.get_vdpa_ovs_info(add_flows=add_flows, return_ports=False)
+
     dpdk_utils.install_dpdk(params, session)
     dpdk_ver = session.cmd_output("rpm -qa |grep dpdk | head -n 1")
     result_file.write("### guest-dpdk-ver :%s" % dpdk_ver)