github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-22 11:21:47 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #107095 from songlh/fixing-4

Browse Source 
fixing three goroutine leaks in bounded_frequency_runner_test.go
This commit is contained in:
Kubernetes Prow Robot 2021-12-21 19:53:35 -08:00 committed by GitHub
commit c75d254beb
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
pkg/util/async/bounded_frequency_runner_test.go
View File

@ -277,6 +277,9 @@ func Test_BoundedFrequencyRunnerNoBurst(t *testing.T) {
// Clean up. // Clean up.
stop <- struct{}{} stop <- struct{}{}
// a message is sent to time.updated in func Stop() at the end of the child goroutine
// to terminate the child, a receive on time.updated is needed here
<-timer.updated
} }
func Test_BoundedFrequencyRunnerBurst(t *testing.T) { func Test_BoundedFrequencyRunnerBurst(t *testing.T) {
@ -358,6 +361,9 @@ func Test_BoundedFrequencyRunnerBurst(t *testing.T) {
// Clean up. // Clean up.
stop <- struct{}{} stop <- struct{}{}
// a message is sent to time.updated in func Stop() at the end of the child goroutine
// to terminate the child, a receive on time.updated is needed here
<-timer.updated
} }
func Test_BoundedFrequencyRunnerRetryAfter(t *testing.T) { func Test_BoundedFrequencyRunnerRetryAfter(t *testing.T) {
@ -441,4 +447,7 @@ func Test_BoundedFrequencyRunnerRetryAfter(t *testing.T) {
// Clean up. // Clean up.
stop <- struct{}{} stop <- struct{}{}
// a message is sent to time.updated in func Stop() at the end of the child goroutine
// to terminate the child, a receive on time.updated is needed here
<-timer.updated
} }