gitlab-com-seaweedfs/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2024-01-19 02:48:24 +00:00
Code Issues Projects Releases Wiki Activity

err msg with duplicated local subscription detected move to log level 1

Browse source 
https://github.com/chrislusf/seaweedfs/issues/3320
This commit is contained in:
Konstantin Lebedev 2022-07-20 00:45:13 +05:00
parent 2ae3f812f8
commit 11e393dbe7
1 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
weed/filer/meta_aggregator.go
View file

@ -7,6 +7,7 @@ import (
"github.com/chrislusf/seaweedfs/weed/pb/master_pb" "github.com/chrislusf/seaweedfs/weed/pb/master_pb"
"github.com/chrislusf/seaweedfs/weed/util" "github.com/chrislusf/seaweedfs/weed/util"
"io" "io"
"strings"
"sync" "sync"
"time" "time"
@ -99,7 +100,11 @@ func (ma *MetaAggregator) loopSubscribeToOneFiler(f *Filer, self pb.ServerAddres
return return
} }
if err != nil { if err != nil {
glog.V(0).Infof("subscribing remote %s meta change: %v", peer, err) errLvl := glog.Level(0)
if strings.Contains(err.Error(), "duplicated local subscription detected") {
errLvl = glog.Level(1)
}
glog.V(errLvl).Infof("subscribing remote %s meta change: %v", peer, err)
} }
if lastTsNs < nextLastTsNs { if lastTsNs < nextLastTsNs {
lastTsNs = nextLastTsNs lastTsNs = nextLastTsNs