diff options
| author | chrislu <chris.lu@gmail.com> | 2023-05-07 23:39:33 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2023-05-07 23:39:33 -0700 |
| commit | 25b237b83ca38854154cf4ea3f76ae892fa88b12 (patch) | |
| tree | 0d963ab106276eb1e423683057e8b398b00d076b | |
| parent | 59f55c1a661516033e05f6cc306cdb92e885117c (diff) | |
| download | seaweedfs-25b237b83ca38854154cf4ea3f76ae892fa88b12.tar.xz seaweedfs-25b237b83ca38854154cf4ea3f76ae892fa88b12.zip | |
reset wait time on a successful retry
| -rw-r--r-- | weed/util/retry.go | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/weed/util/retry.go b/weed/util/retry.go index 6be052f77..997fa5d13 100644 --- a/weed/util/retry.go +++ b/weed/util/retry.go @@ -18,6 +18,7 @@ func Retry(name string, job func() error) (err error) { if hasErr { glog.V(0).Infof("retry %s successfully", name) } + waitTime = time.Second break } if strings.Contains(err.Error(), "transport") { @@ -41,6 +42,7 @@ func MultiRetry(name string, errList []string, job func() error) (err error) { if hasErr { glog.V(0).Infof("retry %s successfully", name) } + waitTime = time.Second break } if containErr(err.Error(), errList) { |