The BZ 2094046 test cases for oslat and cyclictest were negative tests

expecting to fail on HT-enabled systems, but they passed unexpectedly
on HT-disabled systems because the tools executed successfully.

Changes:
- Add hyperthreading detection in its test execution path
- Skip BZ 2094046 tests when HT is disabled to prevent false passes
- Isolated CPU selection with fallback to online CPU

Signed-Off-by: Sargun Narula <snarula@redhat.com>

Author: SargunNarula

test/e2e/performanceprofile/functests/5_latency_testing/latency_testing.go

@@ -2,6 +2,7 @@ package __latency_testing
 
 import (
 	"bytes"
+	"context"
 	"fmt"
 	"math"
 	"os"
@@ -12,7 +13,12 @@ import (
 	. "github.com/onsi/ginkgo/v2"
 	. "github.com/onsi/gomega"
 	"github.com/onsi/gomega/format"
+	"k8s.io/utils/cpuset"
+
+	testutils "github.com/openshift/cluster-node-tuning-operator/test/e2e/performanceprofile/functests/utils"
 	testlog "github.com/openshift/cluster-node-tuning-operator/test/e2e/performanceprofile/functests/utils/log"
+	"github.com/openshift/cluster-node-tuning-operator/test/e2e/performanceprofile/functests/utils/nodes"
+	"github.com/openshift/cluster-node-tuning-operator/test/e2e/performanceprofile/functests/utils/profiles"
 )
 
 // TODO get commonly used variables from one shared file that defines constants
@@ -107,6 +113,16 @@ var _ = DescribeTable("Test latency measurement tools tests", func(testGroup []l
 			// We only override ginkgo default value for positive tests
 			output, err = exec.Command(testExecutablePath, "-ginkgo.v", "-ginkgo.focus", test.toolToTest, "-ginkgo.timeout", test.ginkgoTimeout).Output()
 		} else {
+			// Special handling for BZ 2094046 test case - check if it should be skipped based on Hyper Threading status
+			if test.testCpus == "2" {
+				htEnabled, htErr := checkHyperthreading()
+				if htErr != nil {
+					testlog.Warningf("Failed to check hyperthreading status, running test anyway: %v", htErr)
+				} else if !htEnabled {
+					testlog.Infof("Skipping BZ 2094046 %s test case - hyperthreading is disabled, test would pass unexpectedly", test.toolToTest)
+					continue
+				}
+			}
 			// default ginkgo timeout value for negative tests
 			output, err = exec.Command(testExecutablePath, "-ginkgo.v", "-ginkgo.focus", test.toolToTest).Output()
 		}
@@ -219,6 +235,48 @@ func clearEnv() {
 	os.Unsetenv(latencyTestCpus)
 }
 
+// checkHyperthreading determines if the BZ 2094046 test should run based on HT status.
+// Returns true if the test should run (HT enabled), false if it should be skipped (HT disabled).
+func checkHyperthreading() (bool, error) {
+	profile, err := profiles.GetByNodeLabels(testutils.NodeSelectorLabels)
+	if err != nil {
+		return false, fmt.Errorf("get performance profile: %w", err)
+	}
+
+	workerNodes, err := nodes.GetByLabels(testutils.NodeSelectorLabels)
+	if err != nil {
+		return false, fmt.Errorf("get worker nodes: %w", err)
+	}
+	if len(workerNodes) == 0 {
+		return false, fmt.Errorf("no worker nodes found")
+	}
+	workerNode := &workerNodes[0]
+
+	ctx := context.Background()
+	var cpuID int = -1 // Use -1 to indicate no CPU selected yet
+
+	// Prefer isolated CPUs if defined
+	if profile.Spec.CPU != nil && profile.Spec.CPU.Isolated != nil {
+		if set, err := cpuset.Parse(string(*profile.Spec.CPU.Isolated)); err == nil && set.Size() > 0 {
+			cpuID = set.List()[0]
+		}
+	}
+
+	// Fallback: first online CPU
+	if cpuID == -1 {
+		set, err := nodes.GetOnlineCPUsSet(ctx, workerNode)
+		if err != nil || set.Size() == 0 {
+			return false, fmt.Errorf("get online CPUs: %w", err)
+		}
+		cpuID = set.List()[0]
+	}
+
+	isHTEnabled := nodes.IsHyperthreadingEnabled(ctx, cpuID, workerNode)
+	testlog.Infof("Hyperthreading status on node %s (CPU %d): %t", workerNode.Name, cpuID, isHTEnabled)
+
+	return isHTEnabled, nil
+}
+
 func getValidValuesTests(toolToTest string) []latencyTest {
 	var testSet []latencyTest
 
@@ -284,14 +342,14 @@ func getNegativeTests(toolToTest string) []latencyTest {
 		testSet = append(testSet, latencyTest{testRuntime: "2", oslatMaxLatency: fmt.Sprint(math.MaxInt32 + 1), outputMsgs: []string{invalidNumberOslatMaxLatency, fail}, toolToTest: toolToTest})
 		testSet = append(testSet, latencyTest{testRuntime: "2", oslatMaxLatency: "-3", outputMsgs: []string{invalidNumberOslatMaxLatency, fail}, toolToTest: toolToTest})
 		// Covers the scenario of BZ 2094046
-		testSet = append(testSet, latencyTest{testRuntime: "2", testCpus: "2", outputMsgs: []string{unexpectedError, fail}, toolToTest: toolToTest})
+		testSet = append(testSet, latencyTest{testRuntime: "2", testCpus: "2", oslatMaxLatency: untunedLatencyThreshold, outputMsgs: []string{unexpectedError, fail}, toolToTest: toolToTest})
 	}
 	if toolToTest == cyclictest {
 		testSet = append(testSet, latencyTest{testRuntime: "2", cyclictestMaxLatency: "&", outputMsgs: []string{incorrectCyclictestMaxLatency, fail}, toolToTest: toolToTest})
 		testSet = append(testSet, latencyTest{testRuntime: "2", cyclictestMaxLatency: fmt.Sprint(math.MaxInt32 + 1), outputMsgs: []string{invalidNumberCyclictestMaxLatency, fail}, toolToTest: toolToTest})
 		testSet = append(testSet, latencyTest{testRuntime: "2", cyclictestMaxLatency: "-3", outputMsgs: []string{invalidNumberCyclictestMaxLatency, fail}, toolToTest: toolToTest})
 		// Covers the scenario of BZ 2094046
-		testSet = append(testSet, latencyTest{testRuntime: "2", testCpus: "2", outputMsgs: []string{unexpectedError, fail}, toolToTest: toolToTest})
+		testSet = append(testSet, latencyTest{testRuntime: "2", testCpus: "2", cyclictestMaxLatency: untunedLatencyThreshold, outputMsgs: []string{unexpectedError, fail}, toolToTest: toolToTest})
 	}
 	if toolToTest == hwlatdetect {
 		testSet = append(testSet, latencyTest{testRuntime: "2", hwlatdetectMaxLatency: "&", outputMsgs: []string{incorrectHwlatdetectMaxLatency, fail}, toolToTest: toolToTest})

test/e2e/performanceprofile/functests/utils/nodes/nodes.go

@@ -274,6 +274,13 @@ func GetSMTLevel(ctx context.Context, cpuID int, node *corev1.Node) int {
 	return cpus.Size()
 }
 
+// IsHyperthreadingEnabled checks if hyperthreading (SMT) is enabled on the node
+// Returns true if SMT level > 1, false otherwise
+func IsHyperthreadingEnabled(ctx context.Context, cpuID int, node *corev1.Node) bool {
+	smtLevel := GetSMTLevel(ctx, cpuID, node)
+	return smtLevel > 1
+}
+
 // GetNumaNodes returns the number of numa nodes and the associated cpus as list on the node
 func GetNumaNodes(ctx context.Context, node *corev1.Node) (map[int][]int, error) {
 	lscpuCmd := []string{"lscpu", "-e=node,core,cpu", "-J"}