From 518c502f544cda70f8d821ee7006031038b953f6 Mon Sep 17 00:00:00 2001 From: tangwz Date: Sat, 12 Sep 2020 15:03:45 +0800 Subject: [PATCH] scheduler_perf: use time.Ticker in throughput measurement --- test/integration/scheduler_perf/util.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/test/integration/scheduler_perf/util.go b/test/integration/scheduler_perf/util.go index ca335b25019..dc1051701bc 100644 --- a/test/integration/scheduler_perf/util.go +++ b/test/integration/scheduler_perf/util.go @@ -238,12 +238,13 @@ func (tc *throughputCollector) run(ctx context.Context) { klog.Fatalf("%v", err) } lastScheduledCount := len(podsScheduled) + ticker := time.NewTicker(throughputSampleFrequency) + defer ticker.Stop() for { select { case <-ctx.Done(): return - // TODO(#94665): use time.Ticker instead - case <-time.After(throughputSampleFrequency): + case <-ticker.C: podsScheduled, err := getScheduledPods(tc.podInformer, tc.namespaces...) if err != nil { klog.Fatalf("%v", err)