From f17765ab72e86d278a3fbd68e9372e57fc14e801 Mon Sep 17 00:00:00 2001 From: Wojciech Tyczynski Date: Mon, 20 Feb 2017 16:06:05 +0100 Subject: [PATCH] Speedup density test --- test/e2e/density.go | 2 +- test/e2e/framework/util.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/test/e2e/density.go b/test/e2e/density.go index 811f7d9bff6..9a959c7755e 100644 --- a/test/e2e/density.go +++ b/test/e2e/density.go @@ -732,7 +732,7 @@ var _ = framework.KubeDescribe("Density", func() { name := additionalPodsPrefix + "-" + strconv.Itoa(i+1) framework.ExpectNoError(framework.DeleteRCAndWaitForGC(c, rcNameToNsMap[name], name)) } - workqueue.Parallelize(16, nodeCount, deleteRC) + workqueue.Parallelize(25, nodeCount, deleteRC) } cleanupDensityTest(dConfig) diff --git a/test/e2e/framework/util.go b/test/e2e/framework/util.go index a8fee4e0896..dec506c6b7c 100644 --- a/test/e2e/framework/util.go +++ b/test/e2e/framework/util.go @@ -2882,7 +2882,7 @@ func DeleteRCAndWaitForGC(c clientset.Interface, ns, name string) error { // It waits until the reflector does a List() before returning. func podStoreForSelector(c clientset.Interface, ns string, selector labels.Selector) (*testutils.PodStore, error) { 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 { return true, nil }