github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-14 06:15:45 +00:00
Code Issues Projects Releases Wiki Activity

Fix changes

Browse Source
This commit is contained in:
Gaurav Singh 2020-05-16 20:22:12 -04:00
parent 87e7d77e15
commit 0d0af48444
1 changed files with 7 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
staging/src/k8s.io/kube-aggregator/pkg/controllers/status/available_controller.go
View File

@ -321,16 +321,12 @@ func (c *AvailableConditionController) sync(key string) error {
// we had trouble with slow dial and DNS responses causing us to wait too long. // we had trouble with slow dial and DNS responses causing us to wait too long.
// we added this as insurance // we added this as insurance
case <-time.After(6 * time.Second): case <-time.After(6 * time.Second):
defer func() {
// errCh needs to have a reader since the above goroutine doing the work // errCh needs to have a reader since the above goroutine doing the work
// needs to send to it. This is defered to ensure it runs // needs to send to it.
// even if the post timeout work itself panics.
go func() { go func() {
res := <-errch if res := <-errch; res != nil {
if res != nil { fmt.Errorf("timed out response from %v: %v", discoveryURL, res)
fmt.Error("%v", res)
} }
}()
}() }()
results <- fmt.Errorf("timed out waiting for %v", discoveryURL) results <- fmt.Errorf("timed out waiting for %v", discoveryURL)
return return