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

Merge pull request #12042 from cjcullen/retry

Browse Source 
Make gce operation polling more robust.
This commit is contained in:
Mike Danese 2015-07-31 14:50:37 -07:00
commit ad90c92693
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
pkg/cloudprovider/gce/gce.go
View File

@ -276,13 +276,19 @@ func (gce *GCECloud) targetPoolURL(name, region string) string {
func waitForOp(op *compute.Operation, getOperation func() (*compute.Operation, error)) error {
pollOp := op
consecPollFails := 0
for pollOp.Status != "DONE" {
var err error
// TODO: add some backoff here.
time.Sleep(time.Second)
time.Sleep(3 * time.Second)
pollOp, err = getOperation()
if err != nil {
return err
if consecPollFails == 2 {
// Only bail if we've seen 3 consecutive polling errors.
return err
}
consecPollFails++
} else {
consecPollFails = 0
}
}
if pollOp.Error != nil && len(pollOp.Error.Errors) > 0 {