diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-09-06 12:10:37 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-09-06 12:10:40 -0700 |
| commit | d8af6f62df569a9ad9bca31a9f238e675d03e17b (patch) | |
| tree | 5e659819bbe9c7785d8639fdf3db6805c69f3fd4 | |
| parent | 4f1b3c08a046dd697f0c2b35e55876f78dd733db (diff) | |
| download | seaweedfs-d8af6f62df569a9ad9bca31a9f238e675d03e17b.tar.xz seaweedfs-d8af6f62df569a9ad9bca31a9f238e675d03e17b.zip | |
adjust logging
| -rw-r--r-- | weed/filer/meta_aggregator.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/weed/filer/meta_aggregator.go b/weed/filer/meta_aggregator.go index 8df86c0bd..58905cb99 100644 --- a/weed/filer/meta_aggregator.go +++ b/weed/filer/meta_aggregator.go @@ -76,6 +76,7 @@ func (ma *MetaAggregator) subscribeToOneFiler(f *Filer, self string, peer string glog.V(0).Infof("follow peer: %v, last %v (%d)", peer, time.Unix(0, lastTsNs), lastTsNs) var counter int64 + var synced bool maybeReplicateMetadataChange = func(event *filer_pb.SubscribeMetadataResponse) { if err := Replay(f.Store.ActualStore, event); err != nil { glog.Errorf("failed to reply metadata change from %v: %v", peer, err) @@ -86,6 +87,9 @@ func (ma *MetaAggregator) subscribeToOneFiler(f *Filer, self string, peer string if err := ma.updateOffset(f, peer, peerSignature, event.TsNs); err == nil { if event.TsNs < time.Now().Add(-2*time.Minute).UnixNano() { glog.V(0).Infof("sync with %s progressed to: %v %0.2f/sec", peer, time.Unix(0, event.TsNs), float64(counter)/60.0) + } else if !synced{ + synced = true + glog.V(0).Infof("synced with %s", peer) } lastPersistTime = time.Now() counter = 0 |