未验证 提交 821bfb7b 编写于 作者: W Wjie 提交者: GitHub

sync: Retry three times to avoid infinite loop (#745)

Signed-off-by: Nswj <1186093704@qq.com>
上级 77a4eae9
......@@ -145,11 +145,13 @@ func ListAll(store object.ObjectStorage, start, end string) (<-chan object.Objec
startTime = time.Now()
logger.Debugf("Continue listing objects from %s marker %q", store, marker)
objs, err = store.List("", marker, maxResults)
for err != nil {
count := 0
for err != nil && count < 3 {
logger.Warnf("Fail to list: %s, retry again", err.Error())
// slow down
time.Sleep(time.Millisecond * 100)
objs, err = store.List("", marker, maxResults)
count++
}
logger.Debugf("Found %d object from %s in %s", len(objs), store, time.Since(startTime))
if err != nil {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册