Fix removing RCs in density test

This commit is contained in:
Wojciech Tyczynski 2016-09-16 13:09:45 +02:00
parent 1534415323
commit 767bc90a20

View File

@ -35,6 +35,7 @@ import (
"k8s.io/kubernetes/pkg/runtime" "k8s.io/kubernetes/pkg/runtime"
"k8s.io/kubernetes/pkg/util/sets" "k8s.io/kubernetes/pkg/util/sets"
utiluuid "k8s.io/kubernetes/pkg/util/uuid" utiluuid "k8s.io/kubernetes/pkg/util/uuid"
"k8s.io/kubernetes/pkg/util/workqueue"
"k8s.io/kubernetes/pkg/watch" "k8s.io/kubernetes/pkg/watch"
"k8s.io/kubernetes/test/e2e/framework" "k8s.io/kubernetes/test/e2e/framework"
@ -662,10 +663,11 @@ var _ = framework.KubeDescribe("Density", func() {
framework.LogSuspiciousLatency(startupLag, e2eLag, nodeCount, c) framework.LogSuspiciousLatency(startupLag, e2eLag, nodeCount, c)
By("Removing additional replication controllers") By("Removing additional replication controllers")
for i := 1; i <= nodeCount; i++ { deleteRC := func(i int) {
name := additionalPodsPrefix + "-" + strconv.Itoa(i) name := additionalPodsPrefix + "-" + strconv.Itoa(i+1)
c.ReplicationControllers(ns).Delete(name, nil) framework.ExpectNoError(framework.DeleteRCAndWaitForGC(c, ns, name))
} }
workqueue.Parallelize(16, nodeCount, deleteRC)
} }
cleanupDensityTest(dConfig) cleanupDensityTest(dConfig)