github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-08 11:38:15 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #118524 from onsi/fix-115945

Browse Source 
Fix flaky persistent volumes e2e test
This commit is contained in:
Kubernetes Prow Robot 2023-06-07 08:48:24 -07:00 committed by GitHub
commit c4f44b3de3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
test/e2e/storage/persistent_volumes-local.go
View File

@ -463,6 +463,8 @@ var _ = utils.SIGDescribe("PersistentVolumes-local ", func() {
ginkgo.BeforeEach(func(ctx context.Context) {
setupStorageClass(ctx, config, &waitMode)
ginkgo.DeferCleanup(cleanupStorageClass, config)
for i, node := range config.nodes {
ginkgo.By(fmt.Sprintf("Setting up %d local volumes on node %q", volsPerNode, node.Name))
allLocalVolumes[node.Name] = setupLocalVolumes(ctx, config, volType, &config.nodes[i], volsPerNode)
@ -476,6 +478,13 @@ var _ = utils.SIGDescribe("PersistentVolumes-local ", func() {
framework.ExpectNoError(err)
}
}
ginkgo.DeferCleanup(func(ctx context.Context) {
ginkgo.By("Clean all PVs")
for nodeName, localVolumes := range allLocalVolumes {
ginkgo.By(fmt.Sprintf("Cleaning up %d local volumes on node %q", len(localVolumes), nodeName))
cleanupLocalVolumes(ctx, config, localVolumes)
}
})
ginkgo.By("Start a goroutine to recycle unbound PVs")
backgroundCtx, cancel := context.WithCancel(context.Background())
var wg sync.WaitGroup
@ -532,15 +541,6 @@ var _ = utils.SIGDescribe("PersistentVolumes-local ", func() {
}()
})
ginkgo.AfterEach(func(ctx context.Context) {
ginkgo.By("Clean all PVs")
for nodeName, localVolumes := range allLocalVolumes {
ginkgo.By(fmt.Sprintf("Cleaning up %d local volumes on node %q", len(localVolumes), nodeName))
cleanupLocalVolumes(ctx, config, localVolumes)
}
cleanupStorageClass(ctx, config)
})
ginkgo.It("should be able to process many pods and reuse local volumes", func(ctx context.Context) {
var (
podsLock sync.Mutex