diff options
Diffstat (limited to 'weed/filesys/meta_cache/meta_cache_subscribe.go')
| -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 }) } |