From b3d25c45fd6c86b7fc9b7ad117e9ef84760ad1fd Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=BA=90=E6=96=87=E9=9B=A8?=
 <41315874+fumiama@users.noreply.github.com>
Date: Sun, 17 Apr 2022 21:17:33 +0800
Subject: [PATCH] =?UTF-8?q?=E6=81=A2=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 main.go | 29 ++++++++++++++---------------
 1 file changed, 14 insertions(+), 15 deletions(-)

diff --git a/main.go b/main.go
index 8086ac9..f151ec8 100644
--- a/main.go
+++ b/main.go
@@ -14,6 +14,7 @@ import (
 	"unicode"
 	"unsafe"
 
+	"github.com/FloatTech/zbputils/process"
 	"github.com/fumiama/go-registry"
 	"github.com/wdvxdr1123/ZeroBot/utils/helper"
 )
@@ -46,26 +47,24 @@ func main() {
 		panic(err)
 	}
 	defer r.Close()
-	do1024 := func(k, v string) (err error) {
-		for i := 0; i < 1024; i++ {
-			err = r.Set(k, v)
-			if err == nil {
-				break
-			}
-			fmt.Println("accqiring set lock, retry times:", i)
-		}
-		return
-	}
 	var wg sync.WaitGroup
 	wg.Add(len(files))
 	for i, fn := range files {
 		go func(i int, fn string) {
-			err := do1024("data/"+fn, md5s[i])
-			if err != nil {
-				panic(err)
+			defer wg.Done()
+			for c := 0; c < 5; c++ {
+				err = r.Set("data/"+fn, md5s[i])
+				fmt.Println("set", "data/"+fn, "=", hex.EncodeToString(helper.StringToBytes(md5s[i])))
+				if err == nil {
+					break
+				}
+				if c >= 4 {
+					panic("ERROR:" + err.Error() + "max retry times exceeded")
+				} else {
+					fmt.Println("ERROR:", err, ", retry times:", c)
+				}
+				process.SleepAbout1sTo2s()
 			}
-			fmt.Println("set", "data/"+fn, "=", hex.EncodeToString(helper.StringToBytes(md5s[i])))
-			wg.Done()
 		}(i, fn)
 	}
 	wg.Wait()