diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-07-11 06:16:48 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-07-11 06:16:48 -0700 |
| commit | 2d1df97933136af00da8bd1c0579efbf366659d9 (patch) | |
| tree | 27936742a057be4e0e252cbe7aaaac1a913378a8 | |
| parent | e3e00d36c51c7b1ff83f71c0eb00f705b7ba2028 (diff) | |
| download | seaweedfs-2d1df97933136af00da8bd1c0579efbf366659d9.tar.xz seaweedfs-2d1df97933136af00da8bd1c0579efbf366659d9.zip | |
mount: fatal error if can not process meta data
| -rw-r--r-- | weed/filesys/meta_cache/meta_cache_subscribe.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/filesys/meta_cache/meta_cache_subscribe.go b/weed/filesys/meta_cache/meta_cache_subscribe.go index 2e411a48a..ca18411e0 100644 --- a/weed/filesys/meta_cache/meta_cache_subscribe.go +++ b/weed/filesys/meta_cache/meta_cache_subscribe.go @@ -56,13 +56,13 @@ func SubscribeMetaEvents(mc *MetaCache, client filer_pb.FilerClient, dir string, } if err := processEventFn(resp); err != nil { - return fmt.Errorf("process %v: %v", resp, err) + glog.Fatalf("process %v: %v", resp, err) } lastTsNs = resp.TsNs } }) if err != nil { - glog.V(0).Infof("subscribing filer meta change: %v", err) + glog.Errorf("subscribing filer meta change: %v", err) time.Sleep(time.Second) } } |