mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-03 17:30:00 +00:00
Merge pull request #125027 from haircommander/e2e-swap-v1
e2e_node: skip swap tests on cgroupv1
This commit is contained in:
commit
5cdab888bb
@ -19,17 +19,18 @@ package e2enode
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"fmt"
|
"fmt"
|
||||||
"k8s.io/kubernetes/pkg/apis/core/v1/helper/qos"
|
|
||||||
"k8s.io/kubernetes/pkg/kubelet/apis/config"
|
|
||||||
e2eskipper "k8s.io/kubernetes/test/e2e/framework/skipper"
|
|
||||||
"k8s.io/kubernetes/test/e2e/nodefeature"
|
|
||||||
imageutils "k8s.io/kubernetes/test/utils/image"
|
|
||||||
"math/big"
|
"math/big"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
"strconv"
|
"strconv"
|
||||||
"strings"
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
"k8s.io/kubernetes/pkg/apis/core/v1/helper/qos"
|
||||||
|
"k8s.io/kubernetes/pkg/kubelet/apis/config"
|
||||||
|
e2eskipper "k8s.io/kubernetes/test/e2e/framework/skipper"
|
||||||
|
"k8s.io/kubernetes/test/e2e/nodefeature"
|
||||||
|
imageutils "k8s.io/kubernetes/test/utils/image"
|
||||||
|
|
||||||
"github.com/onsi/ginkgo/v2"
|
"github.com/onsi/ginkgo/v2"
|
||||||
"github.com/onsi/gomega"
|
"github.com/onsi/gomega"
|
||||||
v1 "k8s.io/api/core/v1"
|
v1 "k8s.io/api/core/v1"
|
||||||
@ -70,7 +71,9 @@ var _ = SIGDescribe("Swap", "[LinuxOnly]", nodefeature.Swap, func() {
|
|||||||
pod := getSwapTestPod(f, qosClass, memoryRequestEqualLimit)
|
pod := getSwapTestPod(f, qosClass, memoryRequestEqualLimit)
|
||||||
pod = runPodAndWaitUntilScheduled(f, pod)
|
pod = runPodAndWaitUntilScheduled(f, pod)
|
||||||
|
|
||||||
gomega.Expect(isPodCgroupV2(f, pod)).To(gomega.BeTrueBecause("cgroup v2 is required for swap"))
|
if !isPodCgroupV2(f, pod) {
|
||||||
|
e2eskipper.Skipf("swap tests require cgroup v2")
|
||||||
|
}
|
||||||
gomega.Expect(getSwapBehavior()).To(gomega.Or(gomega.Equal(types.NoSwap), gomega.BeEmpty()), "NodeConformance is expected to run with NoSwap")
|
gomega.Expect(getSwapBehavior()).To(gomega.Or(gomega.Equal(types.NoSwap), gomega.BeEmpty()), "NodeConformance is expected to run with NoSwap")
|
||||||
|
|
||||||
expectNoSwap(f, pod)
|
expectNoSwap(f, pod)
|
||||||
@ -103,7 +106,9 @@ var _ = SIGDescribe("Swap", "[LinuxOnly]", nodefeature.Swap, func() {
|
|||||||
pod := getSwapTestPod(f, qosClass, memoryRequestEqualLimit)
|
pod := getSwapTestPod(f, qosClass, memoryRequestEqualLimit)
|
||||||
pod = runPodAndWaitUntilScheduled(f, pod)
|
pod = runPodAndWaitUntilScheduled(f, pod)
|
||||||
|
|
||||||
gomega.Expect(isPodCgroupV2(f, pod)).To(gomega.BeTrueBecause("cgroup v2 is required for swap"))
|
if !isPodCgroupV2(f, pod) {
|
||||||
|
e2eskipper.Skipf("swap tests require cgroup v2")
|
||||||
|
}
|
||||||
gomega.Expect(getSwapBehavior()).To(gomega.Equal(types.LimitedSwap))
|
gomega.Expect(getSwapBehavior()).To(gomega.Equal(types.LimitedSwap))
|
||||||
|
|
||||||
expectedSwapLimit := calcSwapForBurstablePod(f, pod)
|
expectedSwapLimit := calcSwapForBurstablePod(f, pod)
|
||||||
@ -136,7 +141,9 @@ var _ = SIGDescribe("Swap", "[LinuxOnly]", nodefeature.Swap, func() {
|
|||||||
|
|
||||||
sleepingPod := getSleepingPod(f.Namespace.Name)
|
sleepingPod := getSleepingPod(f.Namespace.Name)
|
||||||
sleepingPod = runPodAndWaitUntilScheduled(f, sleepingPod)
|
sleepingPod = runPodAndWaitUntilScheduled(f, sleepingPod)
|
||||||
gomega.Expect(isPodCgroupV2(f, sleepingPod)).To(gomega.BeTrueBecause("node uses cgroup v1"))
|
if !isPodCgroupV2(f, sleepingPod) {
|
||||||
|
e2eskipper.Skipf("swap tests require cgroup v2")
|
||||||
|
}
|
||||||
|
|
||||||
nodeName = sleepingPod.Spec.NodeName
|
nodeName = sleepingPod.Spec.NodeName
|
||||||
gomega.Expect(nodeName).ToNot(gomega.BeEmpty(), "node name is empty")
|
gomega.Expect(nodeName).ToNot(gomega.BeEmpty(), "node name is empty")
|
||||||
|
Loading…
Reference in New Issue
Block a user