scheduler_perf: use time.Ticker in throughput measurement

2020-09-12 15:03:45 +08:00
parent b86e725694
commit 518c502f54
1 changed files with 3 additions and 2 deletions
--- 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)