github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-30 06:54:01 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #125867 from zhifei92/fix-e2e-node-density

Browse Source 
Fix the bug related to cleaning up density test pods
This commit is contained in:
Kubernetes Prow Robot 2024-07-15 11:55:09 -07:00 committed by GitHub
commit 48eef1fc4f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 7 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
test/e2e_node/density_test.go
View File

@ -354,10 +354,13 @@ func runDensityBatchTest(ctx context.Context, f *framework.Framework, rc *Resour
time.Sleep(sleepBeforeCreatePods)
rc.Start()
ginkgo.DeferCleanup(rc.Stop)
ginkgo.By("Creating a batch of pods")
// It returns a map['pod name']'creation time' containing the creation timestamps
createTimes := createBatchPodWithRateControl(ctx, f, pods, testArg.interval)
ginkgo.DeferCleanup(deletePodsSync, f, pods)
ginkgo.DeferCleanup(deletePodsSync, f, []*v1.Pod{getCadvisorPod()})
ginkgo.By("Waiting for all Pods to be observed by the watch...")
@ -400,9 +403,6 @@ func runDensityBatchTest(ctx context.Context, f *framework.Framework, rc *Resour
sort.Sort(e2emetrics.LatencySlice(e2eLags))
batchLag := lastRunning.Time.Sub(firstCreate.Time)
rc.Stop()
deletePodsSync(ctx, f, pods)
// Log time series data.
if isLogTimeSeries {
logDensityTimeSeries(rc, createTimes, watchTimes, testInfo)
@ -410,8 +410,6 @@ func runDensityBatchTest(ctx context.Context, f *framework.Framework, rc *Resour
// Log throughput data.
logPodCreateThroughput(batchLag, e2eLags, testArg.podsNr, testInfo)
deletePodsSync(ctx, f, []*v1.Pod{getCadvisorPod()})
return batchLag, e2eLags
}
@ -428,22 +426,21 @@ func runDensitySeqTest(ctx context.Context, f *framework.Framework, rc *Resource
// CreatBatch is synchronized, all pods are running when it returns
e2epod.NewPodClient(f).CreateBatch(ctx, bgPods)
ginkgo.DeferCleanup(deletePodsSync, f, bgPods)
ginkgo.DeferCleanup(deletePodsSync, f, []*v1.Pod{getCadvisorPod()})
time.Sleep(sleepBeforeCreatePods)
rc.Start()
ginkgo.DeferCleanup(rc.Stop)
// Create pods sequentially (back-to-back). e2eLags have been sorted.
batchlag, e2eLags := createBatchPodSequential(ctx, f, testPods, podType)
rc.Stop()
deletePodsSync(ctx, f, append(bgPods, testPods...))
ginkgo.DeferCleanup(deletePodsSync, f, testPods)
// Log throughput data.
logPodCreateThroughput(batchlag, e2eLags, testArg.podsNr, testInfo)
deletePodsSync(ctx, f, []*v1.Pod{getCadvisorPod()})
return batchlag, e2eLags
}