diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-11-01 01:21:44 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-11-01 01:21:44 -0700 |
| commit | 004aa9ca5d9575851e667b4229f721e60424419f (patch) | |
| tree | 31d5d78e8d10bbddf29a42cc9fcaee18e6f24a5c | |
| parent | f7b21973acb5a405e6a0333b6f630d2a88088a52 (diff) | |
| download | seaweedfs-004aa9ca5d9575851e667b4229f721e60424419f.tar.xz seaweedfs-004aa9ca5d9575851e667b4229f721e60424419f.zip | |
only retry transport related errors
| -rw-r--r-- | weed/util/retry.go | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/weed/util/retry.go b/weed/util/retry.go index 7d6d8da23..65cf07b41 100644 --- a/weed/util/retry.go +++ b/weed/util/retry.go @@ -1,6 +1,7 @@ package util import ( + "strings" "time" "github.com/chrislusf/seaweedfs/weed/glog" @@ -13,9 +14,11 @@ func Retry(name string, waitTimeLimit time.Duration, job func() error) (err erro if err == nil { break } - glog.V(1).Infof("retry %s", name) - time.Sleep(waitTime) - waitTime += waitTime / 2 + if strings.Contains(err.Error(), "transport: ") { + glog.V(1).Infof("retry %s", name) + time.Sleep(waitTime) + waitTime += waitTime / 2 + } } return err }
\ No newline at end of file |