Improve virtual_network provider's public function

1.Add netperf compile function in netperf_base to support some function
test need to capture output
2.Improve network_base.check_throughput can accept netperf's absolute paths
3.Improve netdst obtain method in network_base
4.Improve ovs bridge's judgement method

Assisted-by: Gemini AI
Signed-off-by: Lei Yang <leiyang@redhat.com>

Author: yanglei-rh

provider/virtual_network/netperf_base.py

@@ -1,7 +1,7 @@
 import logging
 import os
 
-from virttest import data_dir, error_context, remote, utils_misc
+from virttest import data_dir, error_context, remote, utils_misc, utils_net, utils_netperf
 
 LOG_JOB = logging.getLogger("avocado.test")
 
@@ -147,3 +147,56 @@ def netperf_record(results, filter_list, header=False, base="17", fbase="2"):
         record += "%s|" % format_result(results[key], base=base, fbase=fbase)
     record = record.rstrip("|")
     return record, key_list
+
+
+def compile_netperf_pkg(params, env, address):
+    """
+    Prepare and compile netperf binaries on the target system
+
+    :param params: Test parameters dictionary configs
+    :param env: Test environment object
+    :param address: localhost, vm name, or ip address
+    :return: netserver_path, netperf_path
+    """
+    if address in ("localhost", "127.0.0.1",):
+        target_ip = utils_net.get_host_ip_address(params)
+        install_path = params.get("server_path", "/var/tmp")
+        user = params.get("hostusername", "root")
+        pwd = params.get("hostpassword", "")
+    elif address in params.get('vms', '').split():
+        vm = env.get_vm(address)
+        vm.verify_alive()
+        target_ip = vm.get_address()
+        install_path = params.get("client_path", "/var/tmp")
+        user = params.get("username", "")
+        pwd = params.get("password", "")
+    else:
+        target_ip = address
+        install_path = params.get("server_path", "/var/tmp")
+        user = params.get("remote_username", "")
+        pwd = params.get("remote_password", "")
+
+    netperf_link = params.get("netperf_link")
+    netperf_src = os.path.join(data_dir.get_deps_dir("netperf"), netperf_link)
+
+    LOG_JOB.info(f"Instantiating NetperfServer on {address} (IP: {target_ip})...")
+    n_server = utils_netperf.NetperfServer(
+        address=target_ip,
+        netperf_path=install_path,
+        md5sum=params.get("pkg_md5sum", ""),
+        netperf_source=netperf_src,
+        username=user,
+        password=pwd,
+        compile_option="--enable-demo=yes",
+        install=True
+    )
+
+    nserver_path = n_server.netserver_path
+    nperf_path = n_server.netperf_path
+
+    if n_server.session:
+        n_server.session.close()
+    if n_server.package and hasattr(n_server.package, "_release_session"):
+        n_server.package._release_session()
+
+    return nserver_path, nperf_path

provider/virtual_network/network_base.py

@@ -433,7 +433,8 @@ def cleanup_for_iface(iface_type, params):
             libvirt_network.create_or_del_network(network_dict, is_del=True)
 
 
-def check_throughput(serv_runner, cli_runner, ip_addr, bw, th_type):
+def check_throughput(serv_runner, cli_runner, ip_addr, bw, th_type,
+                     netserver_cmd='netserver', netperf_cmd='netperf'):
     """
     Check actual thoughput of network using netperf
 
@@ -442,12 +443,15 @@ def check_throughput(serv_runner, cli_runner, ip_addr, bw, th_type):
     :param ip_addr: ip address
     :param bw: bandwidth setting
     :param th_type: inbound or outbound
+    :param netserver_cmd: netserver command with path (default: 'netserver')
+    :param netperf_cmd: netperf command with path (default: 'netperf')
     """
 
-    serv_runner('netserver')
-    netperf_out = cli_runner(f'netperf -H {ip_addr}')
+    serv_runner(netserver_cmd)
+    netperf_out = cli_runner(f'{netperf_cmd} -H {ip_addr}')
     LOG.debug(netperf_out)
-    serv_runner('pkill netserver')
+    netserver_bin = os.path.basename(netserver_cmd.split()[0])
+    serv_runner(f'pkill {netserver_bin}')
 
     actual_throu = float(netperf_out.strip().splitlines()[-1].split()[-1])
     expect_throu = int(bw) * 8 / 1024
@@ -757,7 +761,7 @@ def cancel_if_ovs_bridge(params, test):
     :param params: Test parameters dict
     :param test: Test object
     """
-    bridge_name = params.get('netdst', '').split(',')[0]
+    bridge_name = params.get('netdst', '')
 
     try:
         br_backend = utils_net.find_bridge_manager(bridge_name)
@@ -775,14 +779,14 @@ def setup_ovs_bridge_attrs(params, iface_attrs):
     :param iface_attrs: Interface attributes dictionary to modify
     :return: True if OVS configuration applied, False otherwise
     """
-    bridge_name = params.get('netdst', '').split(',')[0]
-    is_ovs_bridge = not isinstance(utils_net.find_bridge_manager(bridge_name), utils_net.Bridge)
-
-    if is_ovs_bridge:
-        # Configure for OVS bridge
+    netdst = params.get('netdst', '')
+    br_obj = utils_net.find_bridge_manager(netdst)
+    if br_obj is None:
+        raise exceptions.TestError(f"Bridge '{netdst}' does not exist")
+    if "OpenVSwitch" in br_obj.__class__.__name__:
         iface_attrs['type_name'] = 'bridge'
-        iface_attrs['source'] = {'bridge': bridge_name}
+        iface_attrs['source'] = {'bridge': netdst}
         iface_attrs['virtualport'] = {'type': 'openvswitch'}
-        LOG.debug(f"Configured OVS bridge: {bridge_name}")
+        LOG.debug(f"Configured OVS bridge: {netdst}")
         return True
     return False