Merge branch 'main' into fix__fix_regex_to_get_vfs_details_properly

Author: adrianlasota

CHANGELOG.md

@@ -2,6 +2,22 @@
 
 <!-- version list -->
 
+## v14.3.1 (2025-10-29)
+
+### Bug Fixes
+
+- Add optional additional parameters for bridge creation
+  ([`0a7533d`](https://github.com/intel/mfd-network-adapter/commit/0a7533d55860961b54859c122dba8adc743ff263))
+
+
+## v14.3.0 (2025-10-27)
+
+### Features
+
+- Add devlink commands and RSS queues settings
+  ([`4cd5f2c`](https://github.com/intel/mfd-network-adapter/commit/4cd5f2c05357dfa895e518230de1df9f4f229aae))
+
+
 ## v14.2.0 (2025-10-15)
 
 ### Features

README.md

@@ -87,7 +87,7 @@ interfaces = owner.get_interfaces()
 ```
 ## Exceptions raised by MFD-Network-Adapter module
 - related to module:  `NetworkAdapterModuleException`
-- related to Network Interface:  `InterfaceNameNotFound`, `IPException`, `IPAddressesNotFound`, `NetworkQueuesException`, `RDMADeviceNotFound`, `NumaNodeException`, `DriverInfoNotFound`, `FirmwareVersionNotFound`
+- related to Network Interface:  `InterfaceNameNotFound`, `IPException`, `IPAddressesNotFound`, `NetworkQueuesException`, `RDMADeviceNotFound`, `NumaNodeException`, `DriverInfoNotFound`, `FirmwareVersionNotFound`, `VirtualFunctionNotFoundException`, `HypervisorNotSupportedException`, `NetworkAdapterConfigurationException`, `NetworkInterfaceNotSupported`
 - related to NetworkInterface's features: `VirtualizationFeatureException`
 - 
 ## Classes
@@ -650,6 +650,11 @@ Value of param will be prepared for update for all interfaces using <driver_name
 prepare_values_sharing_same_driver(*, driver_name: str, param: str, value: int) -> str
 ```
 
+[Linux] Enable or disable SRIOV drivers auto probe.
+```python
+set_sriov_driver_autoprobe(self, state: bool) -> None
+```
+
 [Windows]
 
 `change_state_family_interfaces(*, driver_filename: str, enable: State.ENABLED) -> None`
@@ -927,6 +932,16 @@ verify_vmdq(interface: "NetworkInterface", desired_value: int) -> None
 get_vm_vf_ids(self, vm_name: str, interface: "ESXiNetworkInterface") -> list[int]
 ```
 
+[Linux] Set number of MSI-X vectors for PF interface.
+```python
+set_msix_vectors_count(self, count: int, method: MethodType = MethodType.DEVLINK) -> None
+```
+
+[Linux] Get number of MSI-X vectors of PF interface.
+```python
+get_msix_vectors_count(self, method: MethodType = MethodType.DEVLINK) -> int
+```
+
 ### Queue
 
 [L] Get number of queues from proc interrupts
@@ -1259,6 +1274,8 @@ class NetworkInterface(ABC):
 
 - `get_number_of_ports() -> int'` - Get number of ports in tested adapter.
 
+- `reload_adapter_devlink() -> None` - Reload adapter via devlink.
+
 - `restart() -> None` - Restart interface.
 
 #### Additional methods - Linux
@@ -2032,6 +2049,18 @@ get_queues_for_rss_engine(self) -> dict[str, list[str]]
 get_netq_defq_rss_queues(self, netq_rss: bool) -> list
 ```
 
+[Linux] Set RSS queues count.
+
+```python
+set_rss_queues_count(self, count: int, vf_pci_address: PCIAddress | None = None) -> None
+```
+
+[Linux] Get RSS queues count.
+
+```python
+get_rss_queues_count(self, vf_pci_address: PCIAddress | None = None) -> int
+```
+
 #### Stats
 
 
@@ -2258,6 +2287,7 @@ Virtualization related functionalities.
 - `set_link_for_vf(vf_id: int, link_state: LinkState) -> None` - Set link for a VF interface.
 - `set_vlan_for_vf(vf_id: int, vlan_id: int, proto: VlanProto) -> None` - Set port VLAN for a VF interface
 - `set_mac_for_vf(vf_id: int, mac: MACAddress) -> None` - Set MAC address for VF interface.
+- `get_vf_id_by_pci(vf_pci_address: PCIAddress) -> int` - Get VF ID based on PCI Address.
 - `get_max_vfs() -> int` - Get maximal number of VFs per interface based on either name or PCI Address (if name not set on the interface).
 - `get_current_vfs() -> int` - Get current number of VFs per interface based on either name or PCI Address (if name not set on the interface).
 - `get_designed_number_vfs() -> tuple[int, int]` - Get designed max number of VFs, total and per PF.

mfd_network_adapter/exceptions.py

@@ -17,3 +17,19 @@ class NetworkInterfaceIncomparableObject(Exception):
 
 class VirtualFunctionCreationException(Exception):
     """Exception raised when VF creation process fails."""
+
+
+class VirtualFunctionNotFoundException(Exception):
+    """Exception raised when VF is not found after creation."""
+
+
+class HypervisorNotSupportedException(Exception):
+    """Exception raised when the hypervisor is not supported."""
+
+
+class NetworkAdapterConfigurationException(Exception):
+    """Exception raised for errors in network adapter configuration."""
+
+
+class NetworkInterfaceNotSupported(Exception):
+    """Exception raised when the operation called on network interface is not supported."""

mfd_network_adapter/network_adapter_owner/feature/ip/linux.py

@@ -18,20 +18,27 @@
 class LinuxIP(BaseIPFeature):
     """Linux class for IP feature."""
 
-    def create_bridge(self, bridge_name: str, namespace: Optional[str] = None) -> None:
+    def create_bridge(
+        self, bridge_name: str, additional_parameters: str | None = None, namespace: str | None = None
+    ) -> None:
         """
         Create bridge.
 
         :param bridge_name: Bridge name.
+        :param additional_parameters: Additional parameters for bridge creation.
         :param namespace: Name of network namespace
         """
         self._connection.execute_command(
-            add_namespace_call_command(f"ip link add name {bridge_name} type bridge", namespace=namespace)
+            add_namespace_call_command(
+                f"ip link add name {bridge_name} type bridge"
+                f"{' ' + additional_parameters if additional_parameters else ''}",
+                namespace=namespace,
+            )
         )
 
-    def delete_bridge(self, bridge_name: str, namespace: Optional[str] = None) -> None:
+    def delete_bridge(self, bridge_name: str, namespace: str | None = None) -> None:
         """
-        Create bridge.
+        Delete bridge.
 
         :param bridge_name: Bridge name.
         :param namespace: Name of network namespace
@@ -60,7 +67,7 @@ def create_namespace(self, namespace_name: str) -> None:
         """
         self._connection.execute_command(f"ip netns add {namespace_name}")
 
-    def add_to_namespace(self, namespace_name: str, interface_name: str, namespace: Optional[str] = None) -> None:
+    def add_to_namespace(self, namespace_name: str, interface_name: str, namespace: str | None = None) -> None:
         """
         Add interface to namespace.
 
@@ -80,7 +87,7 @@ def delete_namespace(self, namespace_name: str) -> None:
         """
         self._connection.execute_command(f"ip netns delete {namespace_name}")
 
-    def add_virtual_link(self, device_name: str, device_type: str, namespace: Optional[str] = None) -> None:
+    def add_virtual_link(self, device_name: str, device_type: str, namespace: str | None = None) -> None:
         """
         Add device/interface with given device type.
 
@@ -93,7 +100,7 @@ def add_virtual_link(self, device_name: str, device_type: str, namespace: Option
             add_namespace_call_command(f"ip link add dev {device_name} type {device_type}", namespace=namespace)
         )
 
-    def create_veth_interface(self, interface_name: str, peer_name: str, namespace: Optional[str] = None) -> None:
+    def create_veth_interface(self, interface_name: str, peer_name: str, namespace: str | None = None) -> None:
         """
         Create Virtual Ethernet Interface.
 
@@ -118,7 +125,7 @@ def kill_namespace_processes(self, namespace: str) -> None:
         """
         self._connection.execute_command(f"ip netns pids {namespace} | xargs kill", shell=True)
 
-    def delete_virtual_link(self, device_name: str, namespace: Optional[str] = None) -> None:
+    def delete_virtual_link(self, device_name: str, namespace: str | None = None) -> None:
         """
         Delete device/interface.
 

mfd_network_adapter/network_interface/feature/driver/linux.py

@@ -2,12 +2,16 @@
 # SPDX-License-Identifier: MIT
 """Module for Driver feature for Linux."""
 
+import logging
 import re
 from typing import Dict, TYPE_CHECKING
 
+from mfd_common_libs import add_logging_level, log_levels
 from mfd_const import Speed
 from mfd_ethtool import Ethtool
+from mfd_typing.network_interface import InterfaceType
 
+from mfd_network_adapter.exceptions import NetworkInterfaceNotSupported, NetworkAdapterConfigurationException
 from .base import BaseFeatureDriver
 from ...exceptions import DriverInfoNotFound
 
@@ -16,6 +20,9 @@
     from mfd_network_adapter import NetworkInterface
     from mfd_typing.driver_info import DriverInfo
 
+logger = logging.getLogger(__name__)
+add_logging_level(level_name="MODULE_DEBUG", level_value=log_levels.MODULE_DEBUG)
+
 
 class LinuxDriver(BaseFeatureDriver):
     """Linux class for Driver feature."""
@@ -67,3 +74,28 @@ def get_formatted_driver_version(self) -> Dict:
 
             return ver_dict
         raise DriverInfoNotFound(f"Driver version not available for {self._interface().name}")
+
+    def set_sriov_drivers_autoprobe(self, state: bool) -> None:
+        """
+        Enable or disable SRIOV drivers auto probe.
+
+        :param state: State to set (True or False)
+        """
+        interface = self._interface()
+        if interface.interface_type is not InterfaceType.PF:
+            raise NetworkInterfaceNotSupported(
+                "Enabling/disabling SRIOV drivers auto probe is only supported on PF interface."
+            )
+        status = "enabled" if state else "disabled"
+        logger.log(
+            level=log_levels.MFD_DEBUG,
+            msg=f"{status} sriov_drivers_autoprobe on interface {interface.name}",
+        )
+        self._connection.execute_command(
+            f"echo {int(state)} > /sys/class/net/{interface.name}/device/sriov_drivers_autoprobe",
+            custom_exception=NetworkAdapterConfigurationException,
+        )
+        logger.log(
+            level=log_levels.MFD_INFO,
+            msg=f"Successfully {status} sriov_drivers_autoprobe on interface {interface.name}",
+        )

mfd_network_adapter/network_interface/feature/rss/linux.py

@@ -10,7 +10,11 @@
 from mfd_common_libs import add_logging_level, log_levels
 from mfd_ethtool import Ethtool
 from mfd_ethtool.exceptions import EthtoolExecutionError
+from mfd_typing import PCIAddress
+from mfd_typing.network_interface import InterfaceType
+
 from mfd_network_adapter.data_structures import State
+from mfd_network_adapter.exceptions import NetworkInterfaceNotSupported, NetworkAdapterConfigurationException
 from mfd_network_adapter.stat_checker.base import Trend
 
 from .base import BaseFeatureRSS
@@ -285,3 +289,54 @@ def validate_statistics(self, traffic_duration: int = 30) -> None:
             # in ethtool then get_stats will throw a RuntimeError. That is expected behavior.
             # If it does exist, it should be zero.
             logger.log(level=log_levels.MODULE_DEBUG, msg=f"Not found {stat_name} statistic, it's expected.")
+
+    def set_rss_queues_count(self, count: int, vf_pci_address: PCIAddress | None = None) -> None:
+        """
+        Set number of RSS queues for the given interface.
+
+        :param vf_pci_address: PCI address of VF to set RSS queues count for. If not provided, sets for PF.
+        :param count: Number of RSS queues to set
+        """
+        interface = self._interface()
+        if interface.interface_type is not InterfaceType.PF:
+            raise NetworkInterfaceNotSupported("Setting RSS queues count on VF is only supported through PF interface.")
+        logger.log(
+            level=log_levels.MFD_DEBUG,
+            msg=f"Setting RSS queues count to {count} for {'VF' if vf_pci_address else interface.name} interface.",
+        )
+        vf_path = ""
+        if vf_pci_address:
+            vf_num = str(interface.virtualization.get_vf_id_by_pci(vf_pci_address))
+            vf_path = f"virtfn{vf_num}/"
+        self._connection.execute_command(
+            f"echo {count} > /sys/class/net/{interface.name}/device/{vf_path}rss_lut_pf_attr",
+            custom_exception=NetworkAdapterConfigurationException,
+        )
+        logger.log(
+            level=log_levels.MFD_INFO,
+            msg=f"Successfully set RSS queues count on interface {interface.name} to {count}",
+        )
+
+    def get_rss_queues_count(self, vf_pci_address: PCIAddress | None = None) -> int:
+        """
+        Get number of RSS queues of the given interface.
+
+        :param vf_pci_address: PCI address of VF to get RSS queues count for. If not provided, gets for PF.
+        :return: Number of RSS queues
+        """
+        interface = self._interface()
+        if interface.interface_type is not InterfaceType.PF:
+            raise NetworkInterfaceNotSupported("Getting RSS queues count on VF is only supported through PF interface.")
+        logger.log(
+            level=log_levels.MFD_DEBUG,
+            msg=f"Retrieving RSS queues count of {'VF' if vf_pci_address else interface.name} interface.",
+        )
+        vf_path = ""
+        if vf_pci_address:
+            vf_num = str(interface.virtualization.get_vf_id_by_pci(vf_pci_address))
+            vf_path = f"virtfn{vf_num}/"
+        out = self._connection.execute_command(
+            f"cat /sys/class/net/{interface.name}/device/{vf_path}rss_lut_pf_attr",
+            expected_return_codes={0},
+        ).stdout
+        return int(out)

mfd_network_adapter/network_interface/feature/virtualization/data_structures.py

@@ -13,3 +13,11 @@ class VFInfo:
     vf_id: str
     pci_address: PCIAddress
     owner_world_id: str
+
+
+@dataclass
+class MethodType:
+    """Class for method types."""
+
+    DEVLINK: str = "devlink"
+    SYSFS: str = "sysfs"