Fix an issue in robustness test that watch created in the ClientSet is

henrybear327 · henrybear327 · commit 478d9e1c2f57 · 2025-09-21T20:49:24.000+02:00
closed wrongly

Signed-off-by: Chun-Hung Tseng &lt;henrytseng@google.com&gt;
diff --git a/tests/robustness/client/watch.go b/tests/robustness/client/watch.go
@@ -48,7 +48,6 @@ func CollectClusterWatchEvents(ctx context.Context, param CollectClusterWatchEve
 			if err != nil {
 				return err
 			}
-			defer c.Close()
 			err = watchUntilRevision(ctx, param.Lg, c, memberMaxRevisionChan, param.Cfg)
 			reports[i] = c.Report()
 			return err
@@ -71,7 +70,6 @@ func CollectClusterWatchEvents(ctx context.Context, param CollectClusterWatchEve
 				if err != nil {
 					return err
 				}
-				defer c.Close()
 				return openWatchPeriodically(ctx, &g, c, param.BackgroundWatchConfig, finish)
 			})
 		}

Original file line number	Diff line number	Diff line change
`@@ -48,7 +48,6 @@ func CollectClusterWatchEvents(ctx context.Context, param CollectClusterWatchEve`
`48`	`48`	`if err != nil {`
`49`	`49`	`return err`
`50`	`50`	`}`
`51`		`- defer c.Close()`
`52`	`51`	`err = watchUntilRevision(ctx, param.Lg, c, memberMaxRevisionChan, param.Cfg)`
`53`	`52`	`reports[i] = c.Report()`
`54`	`53`	`return err`
`@@ -71,7 +70,6 @@ func CollectClusterWatchEvents(ctx context.Context, param CollectClusterWatchEve`
`71`	`70`	`if err != nil {`
`72`	`71`	`return err`
`73`	`72`	`}`
`74`		`- defer c.Close()`
`75`	`73`	`return openWatchPeriodically(ctx, &g, c, param.BackgroundWatchConfig, finish)`
`76`	`74`	`})`
`77`	`75`	`}`