From 07f32feed0d9ba287bff0e5db71ec11362149bc9 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Sun, 6 Sep 2020 00:50:51 -0700 Subject: [PATCH] print sync progress --- weed/filer/meta_aggregator.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/weed/filer/meta_aggregator.go b/weed/filer/meta_aggregator.go index e13b29745..8df86c0bd 100644 --- a/weed/filer/meta_aggregator.go +++ b/weed/filer/meta_aggregator.go @@ -75,17 +75,20 @@ 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 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) return } + counter++ if lastPersistTime.Add(time.Minute).Before(time.Now()) { 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", peer, time.Unix(0, event.TsNs)) + glog.V(0).Infof("sync with %s progressed to: %v %0.2f/sec", peer, time.Unix(0, event.TsNs), float64(counter)/60.0) } lastPersistTime = time.Now() + counter = 0 } else { glog.V(0).Infof("failed to update offset for %v: %v", peer, err) }