update

Signed-off-by: Wenqi Qiu <[email protected]>
wenqiq · Jan 25, 2024 · 5bad1ba · 5bad1ba
1 parent 1c24f5b
commit 5bad1ba
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/test/performance/framework/case.go b/test/performance/framework/case.go
@@ -71,10 +71,14 @@ func (c *ScaleTestCase) Run(ctx context.Context, testData *ScaleData) error {
 	res := "failed"
 	defer func() {
 		var rows [][]string
-		respTime := <-ch
-		rows = append(rows, table.GenerateRow(caseName, res, time.Since(startTime),
-			respTime.avg.String(), respTime.max.String(), respTime.min.String()))
-		table.ShowResult(os.Stdout, rows)
+		select {
+		case respTime := <-ch:
+			rows = append(rows, table.GenerateRow(caseName, res, time.Since(startTime),
+				respTime.avg.String(), respTime.max.String(), respTime.min.String()))
+			table.ShowResult(os.Stdout, rows)
+		case <-time.After(testData.checkTimeout):
+			klog.InfoS("wait timeout", "check time duration", testData.checkTimeout)
+		}
 	}()
 
 	done := make(chan interface{}, 1)