aboutsummaryrefslogtreecommitdiff
path: root/weed/util/retry.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/util/retry.go')
-rw-r--r--weed/util/retry.go9
1 files changed, 7 insertions, 2 deletions
diff --git a/weed/util/retry.go b/weed/util/retry.go
index 65cf07b41..6dccadddb 100644
--- a/weed/util/retry.go
+++ b/weed/util/retry.go
@@ -9,13 +9,18 @@ import (
func Retry(name string, waitTimeLimit time.Duration, job func() error) (err error) {
waitTime := time.Second
+ hasErr := false
for waitTime < waitTimeLimit {
err = job()
if err == nil {
+ if hasErr {
+ glog.V(0).Infof("retry %s successfully", name)
+ }
break
}
- if strings.Contains(err.Error(), "transport: ") {
- glog.V(1).Infof("retry %s", name)
+ if strings.Contains(err.Error(), "transport") {
+ hasErr = true
+ glog.V(0).Infof("retry %s", name)
time.Sleep(waitTime)
waitTime += waitTime / 2
}