diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-11-26 01:29:30 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-11-26 01:29:30 -0800 |
| commit | a102157020ba54177802702c51ac1eb2f5535f94 (patch) | |
| tree | f4dd4a8911f5ddfa9a94bcbed83316305291c01b /weed/util/retry.go | |
| parent | b3adb221b29924c1878305d81fa214983c348e31 (diff) | |
| download | seaweedfs-a102157020ba54177802702c51ac1eb2f5535f94.tar.xz seaweedfs-a102157020ba54177802702c51ac1eb2f5535f94.zip | |
do not retry if failed with a non transport related error
Diffstat (limited to 'weed/util/retry.go')
| -rw-r--r-- | weed/util/retry.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/weed/util/retry.go b/weed/util/retry.go index 85c4d150d..7b0f2d3c3 100644 --- a/weed/util/retry.go +++ b/weed/util/retry.go @@ -22,9 +22,11 @@ func Retry(name string, job func() error) (err error) { } if strings.Contains(err.Error(), "transport") { hasErr = true - glog.V(0).Infof("retry %s", name) + glog.V(0).Infof("retry %s: err: %v", name, err) time.Sleep(waitTime) waitTime += waitTime / 2 + } else { + break } } return err |