2 files changed, 32 insertions, 1 deletions
diff --git a/weed/util/constants.go b/weed/util/constants.go
index 177c20a60..498ef11a2 100644
--- a/weed/util/constants.go
+++ b/weed/util/constants.go
@@ -5,7 +5,7 @@ import (
 )
 
 var (
-	VERSION = fmt.Sprintf("%s %d.%02d", sizeLimit, 2, 07)
+	VERSION = fmt.Sprintf("%s %d.%02d", sizeLimit, 2, 8)
 	COMMIT  = ""
 )
 
diff --git a/weed/util/retry.go b/weed/util/retry.go
new file mode 100644
index 000000000..faaab0351
--- /dev/null
+++ b/weed/util/retry.go
@@ -0,0 +1,31 @@
+package util
+
+import (
+	"strings"
+	"time"
+
+	"github.com/chrislusf/seaweedfs/weed/glog"
+)
+
+var RetryWaitTime = 6 * time.Second
+
+func Retry(name string, job func() error) (err error) {
+	waitTime := time.Second
+	hasErr := false
+	for waitTime < RetryWaitTime {
+		err = job()
+		if err == nil {
+			if hasErr {
+				glog.V(0).Infof("retry %s successfully", name)
+			}
+			break
+		}
+		if strings.Contains(err.Error(), "transport") {
+			hasErr = true
+			glog.V(0).Infof("retry %s", name)
+			time.Sleep(waitTime)
+			waitTime += waitTime / 2
+		}
+	}
+	return err
+}