diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-08-15 12:37:35 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-08-15 12:37:35 -0700 |
| commit | fda2fc47b1bed30b606539c8caad5e289376382f (patch) | |
| tree | a16d83a64b0bb1b38c2c051b9159ae1701d538fc /weed/filesys | |
| parent | a539d6489639217c1b2fded6ff7238b2d5e7b5da (diff) | |
| download | seaweedfs-fda2fc47b1bed30b606539c8caad5e289376382f.tar.xz seaweedfs-fda2fc47b1bed30b606539c8caad5e289376382f.zip | |
add RetryForever
Diffstat (limited to 'weed/filesys')
| -rw-r--r-- | weed/filesys/meta_cache/meta_cache_subscribe.go | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/weed/filesys/meta_cache/meta_cache_subscribe.go b/weed/filesys/meta_cache/meta_cache_subscribe.go index c650b8024..409120060 100644 --- a/weed/filesys/meta_cache/meta_cache_subscribe.go +++ b/weed/filesys/meta_cache/meta_cache_subscribe.go @@ -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) + }, func(err error) bool { + glog.Errorf("follow metadata updates: %v", err) + return true }) } |