Fix checking channel

Signed-off-by: Wenqi Qiu <[email protected]>
wenqiq · Mar 21, 2024 · 07daa09 · 07daa09
1 parent b39ad49
commit 07daa09
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/test/performance/framework/service.go b/test/performance/framework/service.go
@@ -59,7 +59,7 @@ func ScaleService(ctx context.Context, ch chan time.Duration, data *ScaleData) (
 	defer func() {
 		res.err = err
 		for {
-			if len(ch) == res.scaleNum {
+			if len(ch) == cap(ch) {
 				break
 			}
 			klog.InfoS("Waiting the check goroutine finish")
@@ -205,7 +205,7 @@ func scaleUp(ctx context.Context, data *ScaleData, ch chan time.Duration) (svcs
 				var err error
 				var clientPod *corev1.Pod
 				svc.Spec.ClusterIP = clusterIP.String()
-				klog.InfoS("go FetchTimestampFromLog", "cap(ch)", cap(ch))
+				klog.InfoS("go FetchTimestampFromLog", "cap(ch)", cap(ch), "len(ch)", len(ch))
 				fromPod := &podList.Items[testPodIndex%len(podList.Items)]
 				testPodIndex++
 				clientPod, err = workload_pod.CreateClientPod(ctx, cs, fromPod.Namespace, fromPod.Name, []string{fmt.Sprintf("%s:%d", clusterIP, 80)}, workload_pod.ScaleTestPodProbeContainerName)