Commit f17765ab authored by Wojciech Tyczynski's avatar Wojciech Tyczynski

Speedup density test

parent 777de195
...@@ -732,7 +732,7 @@ var _ = framework.KubeDescribe("Density", func() { ...@@ -732,7 +732,7 @@ var _ = framework.KubeDescribe("Density", func() {
name := additionalPodsPrefix + "-" + strconv.Itoa(i+1) name := additionalPodsPrefix + "-" + strconv.Itoa(i+1)
framework.ExpectNoError(framework.DeleteRCAndWaitForGC(c, rcNameToNsMap[name], name)) framework.ExpectNoError(framework.DeleteRCAndWaitForGC(c, rcNameToNsMap[name], name))
} }
workqueue.Parallelize(16, nodeCount, deleteRC) workqueue.Parallelize(25, nodeCount, deleteRC)
} }
cleanupDensityTest(dConfig) cleanupDensityTest(dConfig)
......
...@@ -2882,7 +2882,7 @@ func DeleteRCAndWaitForGC(c clientset.Interface, ns, name string) error { ...@@ -2882,7 +2882,7 @@ func DeleteRCAndWaitForGC(c clientset.Interface, ns, name string) error {
// It waits until the reflector does a List() before returning. // It waits until the reflector does a List() before returning.
func podStoreForSelector(c clientset.Interface, ns string, selector labels.Selector) (*testutils.PodStore, error) { func podStoreForSelector(c clientset.Interface, ns string, selector labels.Selector) (*testutils.PodStore, error) {
ps := testutils.NewPodStore(c, ns, selector, fields.Everything()) ps := testutils.NewPodStore(c, ns, selector, fields.Everything())
err := wait.Poll(1*time.Second, 2*time.Minute, func() (bool, error) { err := wait.Poll(100*time.Millisecond, 2*time.Minute, func() (bool, error) {
if len(ps.Reflector.LastSyncResourceVersion()) != 0 { if len(ps.Reflector.LastSyncResourceVersion()) != 0 {
return true, nil return true, nil
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment