diff options
| author | chrislu <chris.lu@gmail.com> | 2024-03-15 21:05:40 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-03-15 21:05:40 -0700 |
| commit | 56ce040ab6fd7359e3a573e127cc924d58eebddf (patch) | |
| tree | aacba36772fc73e01ac6e811678852cd25ce3272 | |
| parent | 549455c30d71f3010add1455f61c0dea63dbf92e (diff) | |
| download | seaweedfs-56ce040ab6fd7359e3a573e127cc924d58eebddf.tar.xz seaweedfs-56ce040ab6fd7359e3a573e127cc924d58eebddf.zip | |
log errors
| -rw-r--r-- | weed/filer/meta_aggregator.go | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/weed/filer/meta_aggregator.go b/weed/filer/meta_aggregator.go index 80a041d4e..663fdfe9f 100644 --- a/weed/filer/meta_aggregator.go +++ b/weed/filer/meta_aggregator.go @@ -188,6 +188,7 @@ func (ma *MetaAggregator) doSubscribeToOneFiler(f *Filer, self pb.ServerAddress, ClientEpoch: atomic.LoadInt32(&ma.filer.UniqueFilerEpoch), }) if err != nil { + glog.V(0).Infof("SubscribeLocalMetadata %v: %v", peer, err) return fmt.Errorf("subscribe: %v", err) } @@ -197,10 +198,12 @@ func (ma *MetaAggregator) doSubscribeToOneFiler(f *Filer, self pb.ServerAddress, return nil } if listenErr != nil { + glog.V(0).Infof("SubscribeLocalMetadata stream %v: %v", peer, listenErr) return listenErr } if err := processEventFn(resp); err != nil { + glog.V(0).Infof("SubscribeLocalMetadata process %v: %v", resp, err) return fmt.Errorf("process %v: %v", resp, err) } |