diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-08-15 20:06:47 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-08-15 20:06:47 -0700 |
| commit | bb94930196ddf0e89da2a36b60b1d69514d7739b (patch) | |
| tree | 1ab4130b9d60954710338c19bd5519ac1244c538 | |
| parent | 5d5a21ba2deaeed7ae5387b8c58a6ff03e2909cc (diff) | |
| download | seaweedfs-bb94930196ddf0e89da2a36b60b1d69514d7739b.tar.xz seaweedfs-bb94930196ddf0e89da2a36b60b1d69514d7739b.zip | |
add some delays if error
| -rw-r--r-- | weed/util/retry.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/weed/util/retry.go b/weed/util/retry.go index 569f8fda1..e1ad99d54 100644 --- a/weed/util/retry.go +++ b/weed/util/retry.go @@ -42,10 +42,10 @@ func RetryForever(name string, job func() error, onErrFn func(err error) bool) { if onErrFn(err) { if strings.Contains(err.Error(), "transport") { glog.V(0).Infof("retry %s: err: %v", name, err) - time.Sleep(waitTime) - if waitTime < RetryWaitTime { - waitTime += waitTime / 2 - } + } + time.Sleep(waitTime) + if waitTime < RetryWaitTime { + waitTime += waitTime / 2 } continue } |
