diff --git a/test/conformance/tests/test_sriov_operator.go b/test/conformance/tests/test_sriov_operator.go index 63a5df2595..b0d320eb67 100644 --- a/test/conformance/tests/test_sriov_operator.go +++ b/test/conformance/tests/test_sriov_operator.go @@ -2011,7 +2011,7 @@ func createVanillaNetworkPolicy(node string, sriovInfos *cluster.EnabledNodes, n }))) } -func runCommandOnConfigDaemon(nodeName string, command ...string) (string, string, error) { +func getConfigDaemonPod(nodeName string) *corev1.Pod { pods := &corev1.PodList{} label, err := labels.Parse("app=sriov-network-config-daemon") Expect(err).ToNot(HaveOccurred()) @@ -2020,8 +2020,13 @@ func runCommandOnConfigDaemon(nodeName string, command ...string) (string, strin err = clients.List(context.Background(), pods, &runtimeclient.ListOptions{Namespace: operatorNamespace, LabelSelector: label, FieldSelector: field}) Expect(err).ToNot(HaveOccurred()) Expect(len(pods.Items)).To(Equal(1)) + return &pods.Items[0] +} + +func runCommandOnConfigDaemon(nodeName string, command ...string) (string, string, error) { + - output, errOutput, err := pod.ExecCommand(clients, &pods.Items[0], command...) + output, errOutput, err := pod.ExecCommand(clients, getConfigDaemonPod(nodeName), command...) return output, errOutput, err } diff --git a/test/conformance/tests/test_switchdev.go b/test/conformance/tests/test_switchdev.go new file mode 100644 index 0000000000..ca09ddf24d --- /dev/null +++ b/test/conformance/tests/test_switchdev.go @@ -0,0 +1,86 @@ +package tests + +import ( + "context" + "time" + + sriovv1 "github.com/k8snetworkplumbingwg/sriov-network-operator/api/v1" + "github.com/k8snetworkplumbingwg/sriov-network-operator/test/util/cluster" + "github.com/k8snetworkplumbingwg/sriov-network-operator/test/util/discovery" + "github.com/k8snetworkplumbingwg/sriov-network-operator/test/util/namespaces" + "github.com/k8snetworkplumbingwg/sriov-network-operator/test/util/network" + corev1 "k8s.io/api/core/v1" + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + + . "github.com/onsi/ginkgo/v2" + . "github.com/onsi/gomega" +) + +var _ = Describe("[sriov] Switchdev", Ordered, func() { + + BeforeAll(func() { + if cluster.VirtualCluster() { + Skip("IGB driver does not support VF statistics") + } + + err := namespaces.Create(namespaces.Test, clients) + Expect(err).ToNot(HaveOccurred()) + + err = namespaces.Clean(operatorNamespace, namespaces.Test, clients, discovery.Enabled()) + Expect(err).ToNot(HaveOccurred()) + + WaitForSRIOVStable() + }) + + It("create switchdev policies on supported devices ", func() { + sriovInfos, err := cluster.DiscoverSriov(clients, operatorNamespace) + Expect(err).ToNot(HaveOccurred()) + Expect(len(sriovInfos.Nodes)).ToNot(BeZero()) + testNode := sriovInfos.Nodes[0] + + interfaces, err := sriovInfos.FindSriovDevices(testNode) + Expect(err).ToNot(HaveOccurred()) + + mainDevice := findMainSriovDevice(getConfigDaemonPod(testNode), interfaces) + + for _, intf := range interfaces { + if !doesInterfaceSupportSwitchdev(intf) { + continue + } + + if intf.Name == mainDevice.Name { + // Avoid testing switchdev on main NIC + continue + } + + By("Testing device " + intf.Name + " on node " + testNode) + resourceName := "swtichdev" + intf.Name + _, err = network.CreateSriovPolicy(clients, "test-switchdev-policy-", operatorNamespace, intf.Name, testNode, 8, resourceName, "netdevice", func(snnp *sriovv1.SriovNetworkNodePolicy) { + snnp.Spec.EswitchMode = "switchdev" + }) + Expect(err).ToNot(HaveOccurred()) + + WaitForSRIOVStable() + + Eventually(func() int64 { + testedNode, err := clients.CoreV1Interface.Nodes().Get(context.Background(), testNode, metav1.GetOptions{}) + Expect(err).ToNot(HaveOccurred()) + resNum := testedNode.Status.Allocatable[corev1.ResourceName("openshift.io/"+resourceName)] + capacity, _ := resNum.AsInt64() + return capacity + }, 10*time.Minute, time.Second).Should(Equal(int64(8))) + } + }) +}) + +func doesInterfaceSupportSwitchdev(intf *sriovv1.InterfaceExt) bool { + if intf.Driver == "mlx5_core" { + return true + } + + if intf.Driver == "ice" { + return true + } + + return false +}