lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-04-05 20:52:50 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

add RetryForever

Browse Source
This commit is contained in:
Chris Lu 2021-08-15 12:37:35 -07:00
parent a539d64896
commit fda2fc47b1
2 changed files with 24 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
weed/filesys/meta_cache/meta_cache_subscribe.go
View File

@ -59,8 +59,11 @@ func SubscribeMetaEvents(mc *MetaCache, selfSignature int32, client filer_pb.Fil
} }
return util.Retry("followMetaUpdates", func() error { util.RetryForever("followMetaUpdates", func() error {
return pb.WithFilerClientFollowMetadata(client, "mount", dir, lastTsNs, selfSignature, processEventFn, true) return pb.WithFilerClientFollowMetadata(client, "mount", dir, lastTsNs, selfSignature, processEventFn, true)
}, func(err error) bool {
glog.Errorf("follow metadata updates: %v", err)
return true
}) })
} }

20
weed/util/retry.go
View File

@ -32,6 +32,26 @@ func Retry(name string, job func() error) (err error) {
return err return err
} }
func RetryForever(name string, job func() error, onErrFn func(err error) bool) {
waitTime := time.Second
for {
err = job()
if err == nil {
break
}
if onErrFn(err) {
if strings.Contains(err.Error(), "transport") {
glog.V(0).Infof("retry %s: err: %v", name, err)
time.Sleep(waitTime)
if waitTime < RetryWaitTime {
waitTime += waitTime / 2
}
}
continue
}
}
}
// return the first non empty string // return the first non empty string
func Nvl(values ...string) string { func Nvl(values ...string) string {
for _, s := range values { for _, s := range values {